Update api/ltx_server.py

api/ltx_server.py

@@ -437,46 +437,39 @@ class VideoService:
 
         
 
-    def _concat_crossfade_videos_por_frames(selp, mp4_list, out_path, crossfade_frames=8):
+    def _concat_crossfade_cascade(self, videos, output_path, crossfade_duration=8):
         """
-        Concatena múltiplos vídeos com crossfade visual em número de frames.
-        Funciona mesmo com mais de 2 vídeos.
+        Concatena vídeos em cascata com crossfade.
+        
+        :param videos: lista de caminhos de vídeos
+        :param output_path: caminho final do vídeo concatenado
+        :param crossfade_duration: duração do crossfade em frames
         """
-        if len(mp4_list) < 2:
-            raise ValueError("É necessário ao menos dois vídeos.")
-    
-        filter_parts = []
-        concat_sequence = []
+        if len(videos) < 2:
+            raise ValueError("Precisa de pelo menos 2 vídeos para concatenar")
     
-        # Ajuste inicial de PTS
-        for i, path in enumerate(mp4_list):
-            filter_parts.append(f"[{i}:v]setpts=PTS-STARTPTS[v{i}]")
-    
-        # Cria crossfades entre pares consecutivos
-        for i in range(len(mp4_list) - 1):
-            filter_parts.append(
-                f"[v{i}]trim=0:-{crossfade_frames},setpts=PTS-STARTPTS[v{i}pre];"
-                f"[v{i}]trim=-{crossfade_frames},setpts=PTS-STARTPTS[v{i}fade];"
-                f"[v{i+1}]trim=0:{crossfade_frames},setpts=PTS-STARTPTS[v{i+1}fade];"
-                f"[v{i}fade][v{i+1}fade]blend=all_expr='A*(1-T/{crossfade_frames})+B*(T/{crossfade_frames})'[xf{i}]"
-            )
-            concat_sequence.append(f"[v{i}pre][xf{i}]")
+        temp_video = videos[0]
+        
+        for i in range(1, len(videos)):
+            next_video = videos[i]
+            tmp_output = f"/tmp/cascade_{i}.mp4"
     
-        # Último vídeo completo
-        concat_sequence.append(f"[v{len(mp4_list)-1}]")
+            cmd = f"""
+            ffmpeg -y -i "{temp_video}" -i "{next_video}" -filter_complex "
+            [0:v]trim=0:-{crossfade_duration},setpts=PTS-STARTPTS[v0pre];
+            [0:v]trim=-{crossfade_duration},setpts=PTS-STARTPTS[v0fade];
+            [1:v]trim=0:{crossfade_duration},setpts=PTS-STARTPTS[v1fade];
+            [v0fade][v1fade]blend=all_expr='A*(1-T/{crossfade_duration})+B*(T/{crossfade_duration})'[xf];
+            [0:v]trim=0:-{crossfade_duration},setpts=PTS-STARTPTS[v0start];
+            [1:v]trim={crossfade_duration}:,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}"
+            """
     
-        # Monta concat final
-        concat_str = "".join(concat_sequence)
-        filter_complex = ";".join(filter_parts) + ";" + concat_str + f"concat=n={len(concat_sequence)}:v=1:a=0[v]"
+            subprocess.run(cmd, shell=True, check=True)
+            temp_video = tmp_output  # próximo loop concatena sobre este
     
-        # Comando FFmpeg
-        inputs = " ".join([f"-i '{v}'" for v in mp4_list])
-        cmd = f"ffmpeg -y {inputs} -filter_complex \"{filter_complex}\" -map \"[v]\" -c:v libx264 -pix_fmt yuv420p '{out_path}'"
-        
-        print("[DEBUG] Executando FFmpeg:\n", cmd)
-        subprocess.run(cmd, shell=True, check=True)
-        print("✅ Vídeo final gerado:", out_path)
-        
+        # Renomeia o último temporário como saída final
+        os.rename(temp_video, output_path)
         
 
     def generate(
@@ -708,7 +701,7 @@ class VideoService:
 
             final_concat = os.path.join(results_dir, f"concat_fim_{used_seed}.mp4")
             #self._concat_mp4s_no_reencode(partes_mp4, final_concat)
-            self._concat_crossfade_videos_por_frames(
+            self._concat_crossfade_cascade(
                 partes_mp4, 
                 final_concat,
                 crossfade_frames=8,