Update api/ltx_server.py

api/ltx_server.py

@@ -437,39 +437,67 @@ class VideoService:
 
         
 
-    def _concat_crossfade_cascade(self, videos, output_path, crossfade_frames=8):
+    
+    def _concat_crossfade_cascade(self, video_paths: List[str], output_path: str, crossfade_frames: int = 8):
         """
-        Concatena vídeos em cascata com crossfade.
+        Concatena vídeos em cascata com crossfade, usando FFmpeg.
         
-        :param videos: lista de caminhos de vídeos
-        :param output_path: caminho final do vídeo concatenado
-        :param crossfade_frames: duração do crossfade em frames
+        Args:
+            video_paths (List[str]): Lista de caminhos dos vídeos a serem concatenados.
+            output_path (str): Caminho do arquivo final de saída.
+            crossfade_frames (int): Número de frames para o crossfade.
         """
-        if len(videos) < 2:
-            raise ValueError("Precisa de pelo menos 2 vídeos para concatenar")
-    
-        temp_video = videos[0]
+        if len(video_paths) < 2:
+            raise ValueError("É necessário pelo menos 2 vídeos para concatenação com crossfade.")
         
-        for i in range(1, len(videos)):
-            next_video = videos[i]
-            tmp_output = f"/tmp/cascade_{i}.mp4"
-    
-            cmd = f"""
-            ffmpeg -y -i "{temp_video}" -i "{next_video}" -filter_complex "
+        # Cria uma lista de temporários
+        tmp_videos = []
+        for i in range(len(video_paths) - 1):
+            # Nome do arquivo temporário
+            tmp_file = tempfile.NamedTemporaryFile(delete=False, suffix=".mp4").name
+            tmp_videos.append(tmp_file)
+            
+            # Define vídeos para crossfade
+            if i == 0:
+                vid1 = video_paths[0]
+            else:
+                vid1 = tmp_videos[i-1]
+            vid2 = video_paths[i+1]
+            
+            # Filter complex FFmpeg
+            filter_complex = f"""
             [0:v]trim=0:-{crossfade_frames},setpts=PTS-STARTPTS[v0pre];
             [0:v]trim=-{crossfade_frames},setpts=PTS-STARTPTS[v0fade];
             [1:v]trim=0:{crossfade_frames},setpts=PTS-STARTPTS[v1fade];
             [v0fade][v1fade]blend=all_expr='A*(1-T/{crossfade_frames})+B*(T/{crossfade_frames})'[xf];
-            [0:v]trim=0:-{crossfade_frames},setpts=PTS-STARTPTS[v0start];
-            [1:v]trim={crossfade_frames}:,setpts=PTS-STARTPTS[v1end];
-            [v0start][xf][v1end]concat=n=3:v=1:a=0[v]" -map "[v]" -c:v libx264 -pix_fmt yuv420p "{tmp_output}"
+            [1:v]trim={crossfade_frames}:,setpts=PTS-STARTPTS[v1post];
+            [v0pre][xf][v1post]concat=n=3:v=1:a=0[v]
             """
-    
-            subprocess.run(cmd, shell=True, check=True)
-            temp_video = tmp_output  # próximo loop concatena sobre este
-    
-        # Renomeia o último temporário como saída final
-        os.rename(temp_video, output_path)
+            
+            cmd = [
+                "ffmpeg", "-y",
+                "-i", vid1,
+                "-i", vid2,
+                "-filter_complex", filter_complex,
+                "-map", "[v]",
+                "-c:v", "libx264",
+                "-pix_fmt", "yuv420p",
+                tmp_file
+            ]
+            
+            print(f"[DEBUG] Executando: {' '.join(cmd)}")
+            subprocess.run(cmd, check=True)
+        
+        # Último temporário é o arquivo final
+        final_tmp = tmp_videos[-1]
+        os.rename(final_tmp, output_path)
+        
+        # Limpa os temporários intermediários
+        for tmp in tmp_videos[:-1]:
+            if os.path.exists(tmp):
+                os.remove(tmp)
+        
+        print(f"[INFO] Vídeo final gerado: {output_path}")
         
 
     def generate(