Update app.py

app.py

@@ -23,12 +23,12 @@ from fastapi.responses import FileResponse, JSONResponse
 from starlette.background import BackgroundTask
 
 # ==============================================================================
-# 1. APLICATION CONFIGURATION & SETUP
+# 1. APPLICATION CONFIGURATION & SETUP
 # ==============================================================================
 app = FastAPI(
     title="FFmpeg as a Service for n8n",
     description="A robust API to create videos from image and audio Gradio URLs.",
-    version="3.1.0",
+    version="4.0.0",
 )
 
 TEMP_DIR = "/tmp/ffmpeg_processing"
@@ -75,7 +75,7 @@ async def process_video_from_urls(payload: Dict = Body(...)):
     unique_id = str(uuid.uuid4())
     temp_processing_dir = os.path.join(TEMP_DIR, unique_id)
     os.makedirs(temp_processing_dir)
-
+    
     try:
         image_urls = payload.get("image_urls", [])
         audio_url = payload.get("audio_url")
@@ -85,39 +85,37 @@ async def process_video_from_urls(payload: Dict = Body(...)):
         if not all([image_urls, audio_url, total_duration]):
             raise HTTPException(status_code=400, detail="Bad Request: 'image_urls', 'audio_url', and 'total_duration' are required.")
 
-        # --- Step 1: Download All Media in Parallel ---
-        print("--- STEP 1: DOWNLOADING ALL MEDIA ---")
+        # --- Step 1: Download All Media SEQUENTIALLY ---
+        print("--- STEP 1: DOWNLOADING ALL MEDIA (SEQUENTIAL MODE) ---")
         async with aiohttp.ClientSession(headers=BROWSER_HEADERS) as session:
-            all_urls = image_urls + [audio_url]
-            tasks = [session.get(url) for url in all_urls]
-            responses = await asyncio.gather(*tasks, return_exceptions=True)
-
-        local_image_paths = []
-        narracao_path = os.path.join(temp_processing_dir, "narracao.mp3")
-
-        for i, res in enumerate(responses):
-            if isinstance(res, Exception) or res.status != 200:
-                url = all_urls[i]
-                raise HTTPException(status_code=502, detail=f"Failed to download media from {url}. Status: {getattr(res, 'status', 'N/A')}")
-            
-            content = await res.read()
-            if i < len(image_urls):
-                path = os.path.join(temp_processing_dir, f"image_{i:02d}.jpg")
-                local_image_paths.append(path)
-                with open(path, 'wb') as f: f.write(content)
-            else:
-                with open(narracao_path, 'wb') as f: f.write(content)
-        
-        print("--- SUCCESS: ALL MEDIA DOWNLOADED ---")
-        
+            # First, download the audio file.
+            narracao_path = os.path.join(temp_processing_dir, "narracao.mp3")
+            print(f"Downloading audio from {audio_url}...")
+            async with session.get(audio_url) as resp:
+                if resp.status != 200:
+                    raise HTTPException(status_code=502, detail=f"Failed to download audio. Status: {resp.status}, URL: {audio_url}")
+                with open(narracao_path, "wb") as f: f.write(await resp.read())
+            print("SUCCESS: Audio downloaded.")
+
+            # Now, loop and download images one by one.
+            local_image_paths = []
+            for i, url in enumerate(image_urls):
+                local_path = os.path.join(temp_processing_dir, f"image_{i:02d}.jpg")
+                print(f"Downloading image {i+1}/{len(image_urls)} from {url}...")
+                async with session.get(url) as resp:
+                    if resp.status != 200:
+                        raise HTTPException(status_code=502, detail=f"Failed to download image {i+1}. Status: {resp.status}, URL: {url}")
+                    with open(local_path, "wb") as f: f.write(await resp.read())
+                local_image_paths.append(local_path)
+            print("SUCCESS: All images downloaded.")
+
         # --- Step 2: Create Silent Video Slideshow ---
         print("--- STEP 2: CREATING SILENT VIDEO ---")
         duration_per_image = total_duration / len(image_urls)
         silent_video_path = os.path.join(temp_processing_dir, "silent_video.mp4")
-        
-        # Usando a sintaxe de -framerate que é mais robusta
         input_pattern = shlex.quote(os.path.join(temp_processing_dir, 'image_%02d.jpg'))
         framerate = 1 / duration_per_image
+        
         cmd_video = f"ffmpeg -framerate {framerate} -i {input_pattern} -c:v libx264 -pix_fmt yuv420p -r 25 -y {shlex.quote(silent_video_path)}"
         await run_subprocess(cmd_video)
         print("--- SUCCESS: SILENT VIDEO CREATED ---")