Upload 3 files

app.py

@@ -1,44 +1,71 @@
 import os
-import ffmpeg
-import gradio as gr
-
-def generate_m3u8(audio_file):
-    """
-    Genera un archivo M3U8 a partir de un archivo de audio.
-    
-    Args:
-        audio_file (str): La ruta del archivo de audio.
-    
-    Returns:
-        str: La URL del archivo M3U8 generado.
-    """
-    # Obtener el nombre del archivo sin la extensión
-    file_name = os.path.splitext(os.path.basename(audio_file))[0]
-    
-    # Crear el archivo M3U8 y los segmentos TS
-    input_stream = ffmpeg.input(audio_file)
-    output_stream = ffmpeg.output(input_stream, f"{file_name}_%03d.ts", format='segment', segment_time=10)
-    output_stream = ffmpeg.output(output_stream, f"{file_name}.m3u8", f='hls', hls_time=10, hls_list_size=0, hls_wrap=0)
-    ffmpeg.run(output_stream)
-    
-    # Devolver la URL del archivo M3U8
-    return f"http://localhost:7860/{file_name}.m3u8"
-
-def main():
-    # Crear la interfaz de Gradio
-    audio_file = gr.File(label="Selecciona un archivo de audio")
-    output_url = gr.Textbox(label="URL del archivo M3U8")
-    
-    demo = gr.Interface(
-        fn=generate_m3u8,
-        inputs=audio_file,
-        outputs=output_url,
-        title="Generador de M3U8 a partir de audio",
-        description="Selecciona un archivo de audio y genera un archivo M3U8 en tiempo real."
-    )
-    
-    # Ejecutar la aplicación de Gradio con un enlace público
-    demo.launch(server_port=7860, share=True)
+import time
+import subprocess
+from multiprocessing import Process
+import uvicorn
+from fastapi import FastAPI, Response
+
+app = FastAPI()
+
+# Archivo de audio y rutas de salida
+audio_file = "/app/test.mp3"
+hls_output = "/app/stream.m3u8"
+hls_segment_prefix = "/app/stream"
+
+# Comando FFmpeg para transmitir audio en HLS
+ffmpeg_command = [
+    'ffmpeg',
+    '-re',
+    '-i', audio_file,
+    '-c:a', 'aac',
+    '-b:a', '128k',
+    '-f', 'hls',
+    '-hls_time', '10',
+    '-hls_list_size', '0',
+    '-hls_flags', 'delete_segments',
+    '-hls_segment_filename', f'{hls_segment_prefix}%d.ts',  # Nombre para los segmentos
+    hls_output
+]
+
+def stream_audio():
+    # Ejecuta el comando FFmpeg para iniciar la transmisión
+    process = subprocess.Popen(ffmpeg_command)
+    process.wait()
+
+def start_audio_streaming():
+    audio_process = Process(target=stream_audio)
+    audio_process.start()
+
+@app.on_event("startup")
+async def startup_event():
+    # Espera activa para verificar que el archivo M3U8 esté generado
+    while not os.path.exists(hls_output):
+        print("Esperando a que se genere el archivo M3U8...")
+        time.sleep(1)
+    print("Archivo M3U8 generado. Servidor listo para recibir solicitudes.")
+
+@app.get("/")
+async def read_root():
+    return {"message": "Servidor de Radio M3U8 Activo"}
+
+@app.get("/stream.m3u8")
+def get_m3u8():
+    # Devuelve el archivo M3U8 generado
+    with open(hls_output, "rb") as f:
+        m3u8_content = f.read()
+    return Response(content=m3u8_content, media_type="application/vnd.apple.mpegurl")
+
+@app.get("/stream{segment}.ts")
+def get_segment(segment: int):
+    # Devuelve los segmentos TS generados
+    segment_file = f"{hls_segment_prefix}{segment}.ts"
+    if os.path.exists(segment_file):
+        with open(segment_file, "rb") as f:
+            segment_content = f.read()
+        return Response(content=segment_content, media_type="video/mp2t")
+    else:
+        return Response(status_code=404, content="Segment not found")
 
 if __name__ == "__main__":
-    main()
+    start_audio_streaming()
+    uvicorn.run(app, host="0.0.0.0", port=7860)

requirements.txt

@@ -1,3 +1,4 @@
-flask==2.3.2
-opencv-python==4.8.0.74
+fastapi==0.79.0
+uvicorn==0.18.3
+requests==2.28.1
 ffmpeg-python==0.2.0