Update app.py

app.py

@@ -331,6 +331,7 @@ def run_simulation_pipeline(job: TranslationJob, supabase_url: str, supabase_ano
             time.sleep(1)
             
         # Target Lang Mock URL selector
+        # To make it feel premium, we can point to a high quality public MP4 file
         mock_output_video = "https://commondatastorage.googleapis.com/gtv-videos-bucket/sample/ForBiggerEscapes.mp4"
         
         print(f"[{video_id}] Simulation complete. Updating database to completed.")
@@ -370,7 +371,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
             for chunk in res.iter_content(chunk_size=8192):
                 f.write(chunk)
                 
-        # 🎯 DÜZELTME 2: FFmpeg standartlaştırma parametreleri eksiksiz ve hatasız hale getirildi (-r 25 eklendi)
+        # 1.5. Standardize video (H.264/AAC, 25 FPS, YUV420p) for OpenCV / Wav2Lip stability
         print(f"[{video_id}] Standardizing downloaded video to MP4 format...")
         cmd_standardize = [
             "ffmpeg", "-y", "-i", downloaded_video_path,
@@ -437,6 +438,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
         
         # 4. Synthesize voice cloning using ElevenLabs API
         print(f"[{video_id}] Calling ElevenLabs TTS Voice Cloning with tone '{job.voice_tone}'...")
+        # We can use the default standard voice (e.g. Rachel: 21m00Tcm4TlvDq8ikWAM)
         voice_id = "21m00Tcm4TlvDq8ikWAM" 
         elevenlabs_url = f"https://api.elevenlabs.io/v1/text-to-speech/{voice_id}"
         
@@ -445,6 +447,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
             "Content-Type": "application/json"
         }
         
+        # Optional stability configurations based on voice tone
         stability = 0.5
         similarity_boost = 0.75
         if job.voice_tone == 'excited':
@@ -487,6 +490,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
                 "--outfile", f"../{lipsync_output_path}"
             ]
             
+            # Execute in the Wav2Lip directory to resolve relative imports
             result = subprocess.run(cmd_lipsync, cwd="Wav2Lip", capture_output=True, text=True)
             if result.returncode != 0:
                 print(f"Wav2Lip stdout: {result.stdout}")
@@ -508,6 +512,8 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
             )
             
             if job.has_lip_sync:
+                # Lip-synced video already has the synthesized audio merged inside it.
+                # So we map audio track from the same file (0:a)
                 cmd_merge = [
                     "ffmpeg", "-y", "-i", video_src_for_subtitles,
                     "-vf", f"subtitles={srt_file_path}:force_style='{style_str}'",
@@ -516,6 +522,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
                     output_video_path
                 ]
             else:
+                # Map audio from input 1 (synthesized audio path)
                 cmd_merge = [
                     "ffmpeg", "-y", "-i", video_src_for_subtitles, "-i", synthesized_audio_path,
                     "-vf", f"subtitles={srt_file_path}:force_style='{style_str}'",
@@ -537,6 +544,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
                 ]
                 subprocess.run(cmd_merge, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
                 
+        # Normalize Supabase base URL (remove trailing slash and rest/v1 path if present)
         base_url = supabase_url.rstrip("/")
         if base_url.endswith("/rest/v1"):
             base_url = base_url[:-8].rstrip("/")
@@ -552,11 +560,13 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
                 "Content-Type": "video/mp4"
             }
             upload_res = requests.post(storage_upload_url, headers=upload_headers, data=out_file)
+            # If exists, we can try to PUT (overwrite)
             if upload_res.status_code == 400 and "AlreadyExists" in upload_res.text:
                 upload_res = requests.put(storage_upload_url, headers=upload_headers, data=out_file)
             
             upload_res.raise_for_status()
             
+        # Get public url
         public_video_url = f"{base_url}/storage/v1/object/public/videos/{video_id}_translated.mp4"
         print(f"[{video_id}] Video successfully uploaded. Public URL: {public_video_url}")
         
@@ -583,5 +593,6 @@ def process_video(job: TranslationJob, background_tasks: BackgroundTasks):
 
 if __name__ == "__main__":
     import uvicorn
+    # Make sure we load local variables before starting
     load_env_local()
-    uvicorn.run(app, host="0.0.0.0", port=7860)
+    uvicorn.run(app, host="0.0.0.0", port=7860)