mirror/poke
1
0
Fork 0
mirror of https://codeberg.org/ashley/poke.git synced 2024-11-26 22:18:20 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Added video streaming

Browse source
This commit is contained in:
nin0dev 2024-06-24 00:26:57 -04:00
parent 6dafa572a4
commit 113fbd91f8
1 changed files with 33 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
videobundler/main.py
View file

@ -59,9 +59,39 @@ async def merge(request):
#) #)
#print(f"ffmpeg -i \"https://eu-proxy.poketube.fun/latest_version?id={video_id}&itag={audio_itag}&local=true\" -i \"https://eu-proxy.poketube.fun/latest_version?id={video_id}&itag={video_itag}&local=true\" -c copy -f mp4 -movflags frag_keyframe+empty_moov -") #print(f"ffmpeg -i \"https://eu-proxy.poketube.fun/latest_version?id={video_id}&itag={audio_itag}&local=true\" -i \"https://eu-proxy.poketube.fun/latest_version?id={video_id}&itag={video_itag}&local=true\" -c copy -f mp4 -movflags frag_keyframe+empty_moov -")
#stdout, _ = await proc_ffmpeg.communicate() #stdout, _ = await proc_ffmpeg.communicate()
iwannakillmyself = await run_command(cmdline) #iwannakillmyself = await run_command(cmdline)
response = Response(body=iwannakillmyself, content_type="video/mp4", headers="") process = await asyncio.create_subprocess_shell(
return response cmdline,
stdout=asyncio.subprocess.PIPE,
)
# Wait for the subprocess to finish
#stdout, stderr = await process.communicate()
response = web.StreamResponse(status=200, reason='OK', headers={
'Content-Type': 'video/mp4',
'Transfer-Encoding': 'chunked',
})
await response.prepare(request)
try:
while True:
# Read data from stdout
chunk = await process.stdout.readline()
if not chunk:
break
# Write the chunk to the response
await response.write(chunk)
except Exception as e:
print(f"Error streaming FFmpeg output: {e}")
finally:
# Close the response
await response.write_eof()
return response
# Check for errors
#if process.returncode != 0: # Log or handle the error
#print(f"Command '{args}' failed with return code {process.returncode}")
#return None
# Decode stdout and return return stdout
#response = Response(body=stdout, content_type="video/mp4", headers="")
#return response
async def ping(request): async def ping(request):
return web.Response(body='{"success": true}', content_type="application/json") return web.Response(body='{"success": true}', content_type="application/json")