Update engine.py

engine.py

@@ -1,6 +1,6 @@
 # ==============================================================================
-# engine.py - [FINAL PRO VERSION FOR HUGGING FACE & LOCAL]
-# FEATURE UPGRADE: Cinematic Zoom (Ken Burns), Random Transitions, High Quality Render
+# engine.py - [FINAL FIXED VERSION]
+# FIX: Removed 'zoompan' which was pausing videos. Restored natural video motion.
 # ==============================================================================
 
 import os
@@ -28,15 +28,15 @@ except ImportError:
 # 1. Global Setup and Database Functions
 # ==============================================================================
 
-# प्रोजेक्ट की रूट डायरेक्टरी (Code 1 के अनुसार)
+# प्रोजेक्ट की रूट डायरेक्टरी
 APP_ROOT = '/code'
 
-# सभी ज़रूरी फोल्डरों के लिए एब्सोल्यूट पाथ (Code 1 के अनुसार)
+# सभी ज़रूरी फोल्डरों के लिए एब्सोल्यूट पाथ
 DATA_FOLDER = os.path.join(APP_ROOT, 'data')
 UPLOAD_FOLDER = os.path.join(APP_ROOT, 'uploads')
 OUTPUT_FOLDER = os.path.join(APP_ROOT, 'outputs')
 
-# डेटाबेस फाइल का पूरा एब्सोल्यूट पाथ (Code 1 के अनुसार)
+# डेटाबेस फाइल का पूरा एब्सोल्यूट पाथ
 DATABASE_FILE = os.path.join(DATA_FOLDER, 'tasks.db')
 
 def get_db_connection():
@@ -86,20 +86,13 @@ def update_task_final_status(task_id, status, error_message=None, output_filenam
     conn.close()
 
 def load_api_keys(prefix):
-    """
-    prefix (जैसे 'Gemini_Key') से शुरू होने वाली सभी environment variables को लोड करता है।
-    यह 'Gemini_Key_1', 'Gemini_Key_2' आदि को अपने आप पहचान लेगा।
-    """
     try:
         prefix_lower = prefix.lower()
-        # Environment variables को चेक करें (case-insensitive search)
         keys = [v.strip() for k, v in os.environ.items() if k.lower().startswith(prefix_lower) and v.strip()]
-        
         if keys:
-            print(f"✅ API Key Check: '{prefix}' के लिए {len(keys)} कीज़ मिलीं (Example: ...{keys[0][-4:]})")
+            print(f"✅ API Key Check: '{prefix}' के लिए {len(keys)} कीज़ मिलीं।")
         else:
             print(f"❌ API Key Check: '{prefix}' के लिए कोई कीज़ नहीं मिलीं!")
-            
         return keys
     except Exception as e:
         print(f"🚨 एनवायरनमेंट वेरिएबल्स लोड करते समय त्रुटि: {e}")
@@ -211,7 +204,8 @@ class GeminiTeam:
 
     def create_master_timeline(self, word_timestamps, enriched_scenes_with_paths):
         full_script_text = " ".join([word['word'] for word in word_timestamps]); total_duration = word_timestamps[-1]['end'] if word_timestamps else 0
-        prompt = f"""You are an expert AI video editor. Create a frame-perfect timeline JSON. Assets: 1. **Full Script:** "{full_script_text}" 2. **Total Audio Duration:** {total_duration:.2f} seconds. 3. **Available Scene Clips:** {json.dumps(enriched_scenes_with_paths, indent=2)} 4. **Word-Level Timestamps (with Pauses):** {json.dumps(word_timestamps, indent=2)}. RULES: 1. Your response MUST be ONLY a list of JSON objects. 2. Each object must have "start", "end", "matched_clip", and "start_offset_seconds". 3. **CRITICAL:** The timeline MUST cover the entire audio duration from 0 to {total_duration:.2f} seconds. There should be NO GAPS. 4. **CRITICAL:** You MUST use each video from the 'Available Scene Clips' list only once. Do not repeat clips. 5. **NEW CRITICAL RULE:** In the 'Word-Level Timestamps', you will find special words like '[PAUSE]'. This represents a deliberate silence in the narration. Treat this as a creative opportunity! It is the perfect moment for a beautiful transition between two clips or to let a cinematic shot play out for its full emotional impact. DO NOT repeat the previous clip to fill a pause. Use the pause to enhance the video's pacing. Create the final timeline JSON:"""
+        # NOTE: Added instructions to avoid excessively long clips at the end
+        prompt = f"""You are an expert AI video editor. Create a frame-perfect timeline JSON. Assets: 1. **Full Script:** "{full_script_text}" 2. **Total Audio Duration:** {total_duration:.2f} seconds. 3. **Available Scene Clips:** {json.dumps(enriched_scenes_with_paths, indent=2)} 4. **Word-Level Timestamps (with Pauses):** {json.dumps(word_timestamps, indent=2)}. RULES: 1. Your response MUST be ONLY a list of JSON objects. 2. Each object must have "start", "end", "matched_clip", and "start_offset_seconds". 3. **CRITICAL:** The timeline MUST cover the entire audio duration from 0 to {total_duration:.2f} seconds. There should be NO GAPS. 4. **CRITICAL:** You MUST use each video from the 'Available Scene Clips' list only once. Do not repeat clips. 5. **PACING RULE:** Avoid making the last clip excessively long. Try to distribute the duration evenly if possible. 6. **PAUSE RULE:** Use '[PAUSE]' moments for transitions. Create the final timeline JSON:"""
         result = self._make_resilient_api_call(prompt, timeout=180)
         json_str = result['candidates'][0]['content']['parts'][0]['text']
         clean_str = json_str[json_str.find('['):json_str.rfind(']') + 1]; final_timeline = json.loads(clean_str)
@@ -225,7 +219,7 @@ class GeminiTeam:
         print("-> Gemini ने सफलतापूर्वक स्क्रिप्ट जेनरेट कर दी है।"); return generated_script.strip()
 
 # ==============================================================================
-# 3. Enhanced Video Assembler (Cinematic Version)
+# 3. Enhanced Video Assembler (FIXED: NO FREEZE)
 # ==============================================================================
 
 class VideoAssembler:
@@ -253,8 +247,8 @@ class VideoAssembler:
     def assemble_video(self, log_callback):
         if not self.timeline: return
         
-        # --- STAGE 1: Cinematic Preparation (Zoom & Crop) ---
-        log_callback("-> Stage 1/3: क्लिप्स को Cinematic Zoom (Ken Burns) के साथ तैयार किया जा रहा है...", 91)
+        # --- STAGE 1: Clip Preparation (Motion Restored) ---
+        log_callback("-> Stage 1/3: क्लिप्स तैयार की जा रही हैं (Normal Motion)...", 91)
         prepared_clips = []
         
         for i, item in enumerate(self.timeline):
@@ -278,14 +272,13 @@ class VideoAssembler:
 
             output_clip_path = os.path.join(self.temp_dir, f"prepared_{i:03d}.mp4")
 
-            # 🔥 Cinematic Zoom Filter Logic
-            # यह धीरे-धीरे 1x से 1.2x तक ज़ूम करेगा (Motion Effect)
-            zoom_filter = f"zoompan=z='min(zoom+0.0015,1.2)':d=700:x='iw/2-(iw/zoom/2)':y='ih/2-(ih/zoom/2)':s={self.width}x{self.height}"
+            # 🔥 FIX: No 'zoompan'. Use scale and crop to keep video moving.
+            # scale='w=WIDTH:h=HEIGHT:force_original_aspect_ratio=increase' ensures cover
+            # crop='WIDTH:HEIGHT' centers the video
             
-            # High Quality settings for Hugging Face
             command = [
                 'ffmpeg', '-y', '-ss', str(start_offset), '-i', input_clip_path, '-t', str(duration),
-                '-vf', f"scale={self.width*2}:-1,{zoom_filter},fps=30", 
+                '-vf', f"scale='w={self.width}:h={self.height}:force_original_aspect_ratio=increase',crop={self.width}:{self.height},setsar=1,fps=30",
                 '-c:v', 'libx264', '-preset', 'medium', '-crf', '23', '-an', '-threads', '2',
                 output_clip_path
             ]
@@ -347,13 +340,11 @@ def run_ai_engine_worker(task_id, script_text, script_file_path, orientation, ma
     
     try:
         log("Step 0: API Keys की पुष्टि...", 2)
-        # कीज़ लोड करें
         gemini_keys = load_api_keys("Gemini_Key")
         pexels_keys = load_api_keys("Pexels_Key")
         pixabay_keys = load_api_keys("Pixabay_Key")
         groq_keys = load_api_keys("Groq_Key")
 
-        # अगर कोई की गायब है तो सटीक Error दें
         missing = []
         if not gemini_keys: missing.append("Gemini_Key")
         if not pexels_keys: missing.append("Pexels_Key")
@@ -361,7 +352,7 @@ def run_ai_engine_worker(task_id, script_text, script_file_path, orientation, ma
         if not groq_keys: missing.append("Groq_Key")
         
         if missing:
-            raise Exception(f"API Key Error: ये कीज़ नहीं मिलीं: {', '.join(missing)}. कृपया सुनिश्चित करें कि आपने उन्हें 'Gemini_Key_1' या 'Gemini_Key' जैसे नामों से सेट किया है।")
+            raise Exception(f"API Key Error: ये कीज़ नहीं मिलीं: {', '.join(missing)}")
 
         gemini = GeminiTeam(api_keys=gemini_keys); log("-> सभी जरूरी API कीज मौजूद हैं।", 5)
 
@@ -455,11 +446,10 @@ def run_ai_engine_worker(task_id, script_text, script_file_path, orientation, ma
                 if last_clip_end < total_duration: clip['end'] = total_duration
             final_gapless_timeline.append(clip)
 
-        log("Step 5: फाइनल वीडियो को रेंडर किया जा रहा है (Cinematic Transitions)...", 90)
+        log("Step 5: फाइनल वीडियो को रेंडर किया जा रहा है (Natural Motion, No Freeze)...", 90)
         width, height = (1080, 1920) if orientation == 'vertical' else (1920, 1080)
         output_filename = f"{task_id}_final_video.mp4"; output_path = os.path.join(OUTPUT_FOLDER, output_filename)
         
-        # Using the Enhanced VideoAssembler
         assembler = VideoAssembler(final_gapless_timeline, narration_audio_path, output_path, width, height, mute_final_video, temp_dir)
         assembler.assemble_video(log)