Update app.py

app.py

@@ -3,6 +3,8 @@ import tempfile
 import logging
 import os
 import asyncio
+import time
+from threading import Timer
 from moviepy.editor import (
     VideoFileClip, AudioFileClip, ImageClip,
     concatenate_videoclips, CompositeVideoClip, CompositeAudioClip
@@ -21,6 +23,7 @@ MUSIC_BG = "musicafondo.mp3"
 FX_SOUND = "fxsound.mp3"
 WATERMARK = "watermark.png"
 EJEMPLO_VIDEO = "ejemplo.mp4"  # Video de ejemplo en el root
+OUTPUT_DIR = "output_videos"  # Carpeta para videos finales
 
 # Validar existencia de archivos obligatorios
 for file in [INTRO_VIDEO, OUTRO_VIDEO, MUSIC_BG, FX_SOUND, WATERMARK, EJEMPLO_VIDEO]:
@@ -28,6 +31,20 @@ for file in [INTRO_VIDEO, OUTRO_VIDEO, MUSIC_BG, FX_SOUND, WATERMARK, EJEMPLO_VI
         logging.error(f"Falta archivo necesario: {file}")
         raise FileNotFoundError(f"Falta archivo necesario: {file}")
 
+# Crear carpeta de salida si no existe
+os.makedirs(OUTPUT_DIR, exist_ok=True)
+
+def eliminar_archivo_tiempo(ruta, delay=1800):
+    """Elimina un archivo después de 'delay' segundos (30 minutos por defecto)."""
+    def eliminar():
+        try:
+            if os.path.exists(ruta):
+                os.remove(ruta)
+                logging.info(f"Archivo eliminado por timer: {ruta}")
+        except Exception as e:
+            logging.error(f"Error al eliminar {ruta}: {e}")
+    Timer(delay, eliminar).start()
+
 def cortar_video(video_path, metodo="inteligente", duracion=10):
     """Corta el video en clips según el método especificado."""
     try:
@@ -40,11 +57,11 @@ def cortar_video(video_path, metodo="inteligente", duracion=10):
             logging.info(f"Video cortado en {len(clips)} clips manuales.")
             return clips
         
-        # Método "inteligente" simplificado (cortes cada 5 segundos como fallback)
+        # Método "inteligente" simplificado (cortes cada 5 segundos)
         clips = []
         ultimo_corte = 0
         for i in range(1, math.ceil(video.duration)):
-            if i % 5 == 0:  # Corte cada 5 segundos (puedes mejorar esto con VAD más adelante)
+            if i % 5 == 0:
                 clips.append(video.subclip(ultimo_corte, i))
                 ultimo_corte = i
         if ultimo_corte < video.duration:
@@ -57,12 +74,14 @@ def cortar_video(video_path, metodo="inteligente", duracion=10):
 
 async def procesar_audio(texto, voz, duracion_total, duracion_intro, duracion_video_editado):
     """Genera el TTS y mezcla con la música de fondo."""
+    temp_files = []
     try:
         logging.info("Generando TTS y mezclando audio...")
         communicate = edge_tts.Communicate(texto, voz)
         with tempfile.NamedTemporaryFile(delete=False, suffix=".mp3") as tmp:
             await communicate.save(tmp.name)
             tts_audio = AudioFileClip(tmp.name)
+            temp_files.append(tmp.name)
         
         # Ajustar duración del TTS
         if tts_audio.duration > duracion_video_editado:
@@ -77,6 +96,7 @@ async def procesar_audio(texto, voz, duracion_total, duracion_intro, duracion_vi
         with tempfile.NamedTemporaryFile(delete=False, suffix=".mp3") as tmp:
             bg_music.export(tmp.name, format="mp3")
             bg_audio = AudioFileClip(tmp.name).volumex(0.10)
+            temp_files.append(tmp.name)
         
         # Combinar audios
         audio_final = CompositeAudioClip([
@@ -88,6 +108,15 @@ async def procesar_audio(texto, voz, duracion_total, duracion_intro, duracion_vi
     except Exception as e:
         logging.error(f"Error al procesar audio: {e}")
         raise
+    finally:
+        # Eliminar archivos temporales de audio inmediatamente
+        for file in temp_files:
+            try:
+                if os.path.exists(file):
+                    os.remove(file)
+                    logging.info(f"Archivo temporal de audio eliminado: {file}")
+            except Exception as e:
+                logging.warning(f"No se pudo eliminar el archivo temporal {file}: {e}")
 
 def agregar_transiciones(clips):
     """Agrega transiciones con watermark y sonido FX entre clips."""
@@ -112,7 +141,6 @@ def agregar_transiciones(clips):
 
 async def procesar_video(video_input, texto_tts, voz_seleccionada, metodo_corte, duracion_corte):
     """Procesa el video completo con intro, cortes, TTS y outro."""
-    temp_files = []
     try:
         logging.info("Iniciando procesamiento de video...")
         # Cortar y editar video
@@ -136,22 +164,18 @@ async def procesar_video(video_input, texto_tts, voz_seleccionada, metodo_corte,
         
         # Renderizar video final
         video_final = video_final.set_audio(audio_final)
-        with tempfile.NamedTemporaryFile(delete=False, suffix=".mp4") as tmp:
-            video_final.write_videofile(tmp.name, codec="libx264", fps=24)
-            temp_files.append(tmp.name)
-            logging.info("Video procesado y guardado temporalmente.")
-            return tmp.name
+        timestamp = int(time.time())
+        output_path = os.path.join(OUTPUT_DIR, f"video_{timestamp}.mp4")
+        
+        video_final.write_videofile(output_path, codec="libx264", fps=24)
+        
+        # Programar eliminación del video en 30 minutos
+        eliminar_archivo_tiempo(output_path, delay=1800)
+        logging.info(f"Video guardado temporalmente en: {output_path}")
+        return output_path
     except Exception as e:
         logging.error(f"Error durante el procesamiento: {e}")
         raise
-    finally:
-        for file in temp_files:
-            try:
-                if os.path.exists(file):
-                    os.remove(file)
-                    logging.info(f"Archivo temporal eliminado: {file}")
-            except Exception as e:
-                logging.warning(f"No se pudo eliminar el archivo temporal {file}: {e}")
 
 # Interfaz Gradio con ejemplo de uso
 with gr.Blocks() as demo: