Update app.py

app.py

@@ -38,7 +38,7 @@ def eliminar_archivo_tiempo(ruta, delay=1800):
     from threading import Timer
     Timer(delay, eliminar).start()
 
-async def procesar_audio(texto, voz, duracion_video, audio_original):
+async def procesar_audio(texto, voz, duracion_video, audio_original=None):
     temp_files = []
     try:
         logging.info("Iniciando procesamiento de audio")
@@ -82,17 +82,11 @@ async def procesar_audio(texto, voz, duracion_video, audio_original):
         
         audio_final = CompositeAudioClip(audios).set_duration(duracion_video)
         logging.info("Audio procesado exitosamente")
-        return audio_final
+        return audio_final, temp_files  # Retornamos los archivos temporales para limpieza
     
     except Exception as e:
         logging.error(f"Fallo en procesamiento de audio: {str(e)}")
         raise
-    finally:
-        for file in temp_files:
-            try:
-                os.remove(file)
-            except Exception as e:
-                logging.warning(f"Error limpiando {file}: {e}")
 
 def aplicar_glitch(video_clip):
     def glitch_effect(frame):
@@ -107,21 +101,22 @@ def aplicar_glitch(video_clip):
     return video_clip.fl_image(glitch_effect)
 
 async def procesar_fragmento(chunk, texto_tts, voz_seleccionada, start_time):
+    temp_files = []
     try:
         audio_original = chunk.audio
         duracion_chunk = chunk.duration
         
         # Si el chunk es demasiado corto, devolver sin procesar
         if duracion_chunk <= 18:
-            audio_final = await procesar_audio(
+            audio_final, temp_files = await procesar_audio(
                 texto_tts,
                 voz_seleccionada,
                 duracion_chunk,
                 audio_original
             )
-            return chunk.set_audio(audio_final)
+            return chunk.set_audio(audio_final), temp_files
         
-        audio_final = await procesar_audio(
+        audio_final, temp_files = await procesar_audio(
             texto_tts,
             voz_seleccionada,
             duracion_chunk,
@@ -159,20 +154,14 @@ async def procesar_fragmento(chunk, texto_tts, voz_seleccionada, start_time):
 
         video_chunk = concatenate_videoclips(segments, method="compose")
         video_chunk = video_chunk.set_audio(audio_final)
-        return video_chunk
+        return video_chunk, temp_files
             
     except Exception as e:
         logging.error(f"Fallo procesando fragmento: {str(e)}")
         raise
-    finally:
-        try:
-            chunk.close()
-            audio_original.close()
-            audio_final.close()
-        except:
-            pass
 
 async def procesar_video(video_input, texto_tts, voz_seleccionada):
+    temp_files = []
     try:
         logging.info("Iniciando procesamiento de video")
         video_original = VideoFileClip(video_input, target_resolution=(720, 1280))
@@ -189,8 +178,9 @@ async def procesar_video(video_input, texto_tts, voz_seleccionada):
         processed_clips = []
         for i, (start_time, chunk) in enumerate(chunks):
             logging.info(f"Procesando chunk {i+1}/{len(chunks)}")
-            processed_chunk = await procesar_fragmento(chunk, texto_tts, voz_seleccionada, start_time)
+            processed_chunk, chunk_temp_files = await procesar_fragmento(chunk, texto_tts, voz_seleccionada, start_time)
             processed_clips.append(processed_chunk)
+            temp_files.extend(chunk_temp_files)
         
         # Combinar chunks
         final_video = concatenate_videoclips(processed_clips, method="compose")
@@ -226,11 +216,17 @@ async def procesar_video(video_input, texto_tts, voz_seleccionada):
         raise
     finally:
         try:
+            # Cerrar recursos solo después de completar todo el procesamiento
             video_original.close()
             intro.close()
             outro.close()
-        except:
-            pass
+            for file in temp_files:
+                try:
+                    os.remove(file)
+                except Exception as e:
+                    logging.warning(f"Error limpiando {file}: {e}")
+        except Exception as e:
+            logging.warning(f"Error al cerrar recursos: {str(e)}")
 
 # Interfaz Gradio
 with gr.Blocks() as demo: