Update app.py

app.py

@@ -9,8 +9,9 @@ import json
 import shutil
 from typing import Optional
 
-# Google API Kararlı Sürüm Zorlaması (Beta Devri Bitti!)
-os.environ["GEMINI_API_VERSION"] = "v1"
+# 🎯 DÜZELTME 1: Google API için v1beta sürümünü zorunlu kılıyoruz. 
+# Gemini 2.0 Flash modeli faturalı (Paid) hesaplarda bile sadece v1beta otoyolunda çalışır.
+os.environ["GEMINI_API_VERSION"] = "v1beta"
 
 app = FastAPI(title="VoiceClips heavy video processor (Wav2Lip + FFmpeg)")
 
@@ -330,7 +331,6 @@ 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.")
@@ -374,8 +374,7 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
         print(f"[{video_id}] Standardizing downloaded video to MP4 format...")
         cmd_standardize = [
             "ffmpeg", "-y", "-i", downloaded_video_path,
-            "-c:v", "libx264", "-pix_fmt", "yuv420p", "-r", "25",
-            "-c:a", "aac", "-ar", "16000", "-ac", "1",
+            "25", "-c:a", "aac", "-ar", "16000", "-ac", "1",
             input_video_path
         ]
         subprocess.run(cmd_standardize, check=True, stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
@@ -394,7 +393,9 @@ def run_production_pipeline(job: TranslationJob, gemini_key: str, elevenlabs_key
         with open(extracted_audio_path, "rb") as audio_file:
             audio_data = base64.b64encode(audio_file.read()).decode("utf-8")
             
-        gemini_url = f"https://generativelanguage.googleapis.com/v1/models/gemini-2.0-flash:generateContent?key={gemini_key}"
+        # 🎯 DÜZELTME 2: Endpoint URL'ini tam olarak v1beta'ya yönlendiriyoruz.
+        # Artık hem faturalı bakiyemiz devrede hem de model jilet gibi adreste bulunacak!
+        gemini_url = f"https://generativelanguage.googleapis.com/v1beta/models/gemini-2.0-flash:generateContent?key={gemini_key}"
         
         if job.has_captions:
             gemini_prompt = f"Transcribe the following audio, translate it accurately to '{job.target_lang}', and output the result in SRT subtitle format. Keep each caption line short (max 4-5 words) and ensure the timing is aligned with the audio. Output ONLY the raw SRT text, no extra markdown formatting, tags, or explanations."
@@ -436,7 +437,6 @@ 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,7 +445,6 @@ 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':
@@ -488,7 +487,6 @@ 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}")
@@ -510,8 +508,6 @@ 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}'",
@@ -520,7 +516,6 @@ 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}'",
@@ -542,7 +537,6 @@ 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("/")
@@ -558,13 +552,11 @@ 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}")
         
@@ -591,6 +583,5 @@ 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)