Spaces:

diwash-barla
/

script2video

Sleeping

App Files Files Community

diwash-barla commited on Nov 2, 2025

Commit

423659f

1 Parent(s): dc2e689

old recovery

Browse files

Files changed (6) hide show

app.py +56 -129
client_secret.json +1 -0
engine.py +31 -176
faltuapp.py +202 -0
oldapp.py +0 -129
oldengn.py +0 -442

app.py CHANGED Viewed

@@ -1,53 +1,53 @@
 import os
 import uuid
 import threading
-import zipfile
-import shutil
-from dotenv import load_dotenv
-from flask import Flask, request, jsonify, render_template, send_from_directory, send_file
 from werkzeug.utils import secure_filename
 from engine import (
-    init_db, create_task, get_task, get_db_connection, run_ai_engine_worker,
-    generate_script_with_ai, UPLOAD_FOLDER, OUTPUT_FOLDER, GoogleDriveHelper
 )
-load_dotenv()
-app = Flask(__name__)
-app.config['UPLOAD_FOLDER'] = UPLOAD_FOLDER
-app.config['OUTPUT_FOLDER'] = OUTPUT_FOLDER
-init_db()
 # ==============================================================================
-# PWA, Static File, and Favicon Routes
 # ==============================================================================
-@app.route('/favicon.ico')
-def favicon():
-    return send_from_directory('static', 'favicon.png')
-@app.route('/manifest.json')
-def serve_manifest():
-    return send_from_directory('static', 'manifest.json')
-@app.route('/sw.js')
-def serve_sw():
-    return send_from_directory('static', 'sw.js')
-@app.route('/icon-512x512.png')
-def serve_icon_512():
-    return send_from_directory('static', 'icon-512x512.png')
-@app.route('/icon-192x192.png')
-def serve_icon_192():
-    return send_from_directory('static', 'icon-192x192.png')
-# ==============================================================================
-# Main Application Routes
-# ==============================================================================
 @app.route('/')
 def home():
-    return render_template('home.html')
 @app.route('/process', methods=['POST'])
 def process_video():
@@ -72,7 +72,7 @@ def process_video():
         args=(task_id, script_text, script_file_path, orientation, max_clip_length, mute_final_video)
     )
     thread.start()
-    return render_template('processing.html', task_id=task_id)
 @app.route('/generate-script', methods=['POST'])
 def generate_script():
@@ -93,110 +93,37 @@ def progress(task_id):
     task = get_task(task_id)
     if not task:
         return jsonify({'status': 'error', 'log': 'Task not found.'})
-    # task object ko dictionary me convert karein
-    task_dict = dict(task)
-    # Timestamp ko string me convert karein agar woh object hai
-    if 'creation_timestamp' in task_dict and task_dict['creation_timestamp'] is not None:
-        task_dict['creation_timestamp'] = str(task_dict['creation_timestamp'])
-    return jsonify(task_dict)
-@app.route('/result/<task_id>')
-def result(task_id):
-    task = get_task(task_id)
-    if not task or task['status'] != 'complete':
-        return "Task not found or not complete.", 404
-    return render_template('result.html', task=dict(task))
-# Yeh route ab direct file serve nahi karega, isliye ise hata sakte hain ya aise hi chhod sakte hain
 @app.route('/outputs/<path:filename>')
 def serve_output_file(filename):
-    return "Direct file access is disabled. Please use history.", 403
-# ==============================================================================
-# History and Bulk Action Routes (Updated)
-# ==============================================================================
 @app.route('/history')
 def history():
-    conn = get_db_connection()
-    # Sirf complete tasks dikhayein, naye se purane kram me
-    tasks = conn.execute("SELECT * FROM tasks WHERE status = 'complete' ORDER BY creation_timestamp DESC").fetchall()
-    conn.close()
     history_items = []
-    for task in tasks:
-        item = {
-            'task_id': task['id'],
-            'video_link': task['video_share_link'],
-            'report_link': task['report_share_link'],
-            'timestamp': task['creation_timestamp']
-        }
-        history_items.append(item)
-    return render_template('history.html', items=history_items)
-@app.route('/history/delete', methods=['POST'])
-def delete_history_items():
-    data = request.get_json()
-    task_ids = data.get('task_ids', [])
-    if not task_ids:
-        return jsonify({'error': 'No task IDs provided'}), 400
     try:
-        gdrive = GoogleDriveHelper()
-        conn = get_db_connection()
-        for task_id in task_ids:
-            task = conn.execute("SELECT video_file_id, report_file_id FROM tasks WHERE id = ?", (task_id,)).fetchone()
-            if task:
-                if task['video_file_id']:
-                    gdrive.delete_file(task['video_file_id'])
-                if task['report_file_id']:
-                    gdrive.delete_file(task['report_file_id'])
-                conn.execute("DELETE FROM tasks WHERE id = ?", (task_id,))
-                conn.commit()
-        conn.close()
-        return jsonify({'success': True, 'message': f'{len(task_ids)} items deleted.'})
-    except Exception as e:
-        print(f"Error during bulk delete: {e}")
-        return jsonify({'error': str(e)}), 500
-@app.route('/history/download', methods=['POST'])
-def download_history_items():
-    data = request.get_json()
-    task_ids = data.get('task_ids', [])
-    if not task_ids:
-        return jsonify({'error': 'No task IDs provided'}), 400
-    temp_dir = os.path.join(app.config['UPLOAD_FOLDER'], f"download_{uuid.uuid4()}")
-    os.makedirs(temp_dir, exist_ok=True)
-    zip_path = os.path.join(app.config['UPLOAD_FOLDER'], f"download_{uuid.uuid4()}.zip")
-    try:
-        gdrive = GoogleDriveHelper()
-        conn = get_db_connection()
-        for task_id in task_ids:
-            task = conn.execute("SELECT video_file_id, report_file_id FROM tasks WHERE id = ?", (task_id,)).fetchone()
-            if task:
-                if task['video_file_id']:
-                    gdrive.download_file(task['video_file_id'], os.path.join(temp_dir, f"{task_id}_video.mp4"))
-                if task['report_file_id']:
-                    gdrive.download_file(task['report_file_id'], os.path.join(temp_dir, f"{task_id}_report.json"))
-        conn.close()
-        with zipfile.ZipFile(zip_path, 'w') as zipf:
-            for root, dirs, files in os.walk(temp_dir):
-                for file in files:
-                    zipf.write(os.path.join(root, file), arcname=file)
-        return send_file(zip_path, as_attachment=True, download_name='AI_Videos_Export.zip')
-    except Exception as e:
-        print(f"Error during bulk download: {e}")
-        return jsonify({'error': str(e)}), 500
-    finally:
-        if os.path.exists(temp_dir):
-            shutil.rmtree(temp_dir)
-        if os.path.exists(zip_path):
-            os.remove(zip_path)
 if __name__ == '__main__':
     app.run(host='0.0.0.0', port=5000, debug=True)

+# ==============================================================================
+# app.py - [FINAL CORRECTED VERSION FOR HUGGING FACE v2]
+# CHANGE: init_db() ko app startup par call kiya gaya hai.
+# ==============================================================================
 import os
+from dotenv import load_dotenv
+# Ye line aapke local .env file se variables load karegi (Hugging Face par iska koi asar nahi)
+load_dotenv()
 import uuid
 import threading
+from flask import Flask, request, jsonify, render_template_string, send_from_directory
 from werkzeug.utils import secure_filename
+# engine.py se zaroori functions AUR FOLDER PATHS import karein
 from engine import (
+    init_db, create_task, get_task, run_ai_engine_worker,
+    generate_script_with_ai,
+    UPLOAD_FOLDER,
+    OUTPUT_FOLDER
 )
 # ==============================================================================
+# 1. HTML Templates
 # ==============================================================================
+MODERN_CSS_BASE = """<link rel="preconnect" href="https://fonts.googleapis.com"><link rel="preconnect" href="https://fonts.gstatic.com" crossorigin><link href="https://fonts.googleapis.com/css2?family=Poppins:wght@300;400;600;700&display=swap" rel="stylesheet"><style>:root{--bg-color:#1a1a2e;--card-bg-color:rgba(22,22,46,0.7);--primary-color:#e94560;--secondary-color:#0f3460;--text-color:#f0f0f0;--text-muted-color:#a0a0a0;--border-color:rgba(233,69,96,0.2);--gradient:linear-gradient(90deg,#e94560,#a63f82)}body{font-family:'Poppins',sans-serif;background-color:var(--bg-color);background-image:linear-gradient(315deg,var(--bg-color) 0%,var(--secondary-color) 74%);color:var(--text-color);padding-top:20px;padding-bottom:20px}.card{background:var(--card-bg-color);border:1px solid var(--border-color);border-radius:16px;backdrop-filter:blur(10px);-webkit-backdrop-filter:blur(10px);box-shadow:0 8px 32px 0 rgba(0,0,0,0.37);animation:fadeInUp 0.5s ease-out}h1,h2,h3,h4,h5,h6{background:var(--gradient);-webkit-background-clip:text;-webkit-text-fill-color:transparent;font-weight:700}.text-muted{color:var(--text-muted-color) !important}.form-control,.form-select{background-color:rgba(0,0,0,0.2);color:var(--text-color);border:1px solid var(--border-color);border-radius:8px}.form-control:focus,.form-select:focus{background-color:rgba(0,0,0,0.3);color:var(--text-color);border-color:var(--primary-color);box-shadow:0 0 0 .25rem rgba(233,69,96,0.25)}.form-control::placeholder{color:var(--text-muted-color);opacity:.7}.btn{border:none;border-radius:8px;font-weight:600;padding:12px 24px;transition:transform .1s ease-out,box-shadow .2s ease-out,filter .2s ease-out}.btn:hover{transform:translateY(-3px);box-shadow:0 5px 15px rgba(0,0,0,.3)}.btn:active{transform:translateY(0) scale(.98);filter:brightness(1.2)}.btn-primary{background:var(--gradient);color:#fff}.btn-primary:active{box-shadow:0 0 5px var(--primary-color),0 0 25px var(--primary-color),0 0 50px var(--primary-color)}.btn-secondary:active,.btn-dark:active{box-shadow:0 0 5px rgba(255,255,255,.8),0 0 25px rgba(255,255,255,.5)}@keyframes fadeInUp{from{opacity:0;transform:translateY(20px)}to{opacity:1;transform:translateY(0)}}</style>"""
+HTML_HOME = """<!DOCTYPE html><html lang="hi"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>Sparkling Gyan AI - होम</title><link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.3/dist/css/bootstrap.min.css" rel="stylesheet"><link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.5.1/css/all.min.css">""" + MODERN_CSS_BASE + """<style>.ai-generator-controls{border:1px solid var(--border-color);border-radius:12px;padding:20px;margin-top:20px;background-color:rgba(0,0,0,.1)}</style></head><body><div class="container my-5"><div class="card p-4 p-md-5"><div class="d-flex justify-content-between align-items-center mb-3"><h1 class="mb-0">✨ Sparkling Gyan AI</h1><a href="/history" class="btn btn-secondary"><i class="fas fa-history"></i> हिस्ट्री देखें</a></div><p class="text-center text-muted mb-4">एक उन्नत, ऑटोमेटिक वीडियो जेनरेटर</p><form id="upload-form" action="/process" method="POST" enctype="multipart/form-data"><div class="mb-3"><label for="script_text" class="form-label fs-5 fw-bold text-light">१. कहानी लिखें</label><textarea class="form-control" id="script_text" name="script_text" rows="8" placeholder="यहाँ कोई टॉपिक लिखें (जैसे 'चंद्रमा के रहस्य') और नीचे 'AI से स्क्रिप्ट बनाएँ' बटन दबाएँ, या अपनी पूरी स्क्रिप्ट यहाँ पेस्ट करें..."></textarea></div><div class="ai-generator-controls"><div class="row align-items-end"><div class="col-md-5"><label for="video-length-select" class="form-label text-light">वीडियो की लंबाई</label><select id="video-length-select" class="form-select"><option value="short">छोटी (~30 सेकंड)</option><option value="medium" selected>मध्यम (~1 मिनट)</option><option value="long">लंबी (~2 मिनट)</option></select></div><div class="col-md-7 d-grid"><button type="button" id="generate-script-btn" class="btn btn-dark"><i class="fas fa-magic"></i> AI से स्क्रिप्ट बनाएँ</button></div></div><div id="ai-status" class="mt-2"></div></div><div class="text-center text-muted my-3">या</div><div class="mb-3"><label for="script_file" class="form-label">एक ऑडियो स्क्रिप्ट फ़ाइल अपलोड करें</label><input class="form-control" type="file" id="script_file" name="script_file" accept="audio/*"></div><h5 class="mt-4 mb-3 text-light">२. अतिरिक्त विकल्प</h5><div class="row mb-3"><div class="col-md-6"><label class="form-label">वीडियो ओरिएंटेशन</label><div class="form-check"><input class="form-check-input" type="radio" name="orientation" id="orientation_horizontal" value="horizontal" checked><label class="form-check-label" for="orientation_horizontal">Landscape (16:9)</label></div><div class="form-check"><input class="form-check-input" type="radio" name="orientation" id="orientation_vertical" value="vertical"><label class="form-check-label" for="orientation_vertical">Portrait (9:16)</label></div></div><div class="col-md-6"><label for="max_clip_length" class="form-label">अधिकतम क्लिप लंबाई (सेकंड)</label><input type="number" class="form-control" id="max_clip_length" name="max_clip_length" value="15" min="3"></div></div><div class="form-check mb-4"><input class="form-check-input" type="checkbox" value="true" id="mute_final_video" name="mute_final_video"><label class="form-check-label" for="mute_final_video">ऑडियो/वॉयसओवर ट्रैक को म्यूट करें</label></div><div class="d-grid mt-4"><button type="submit" class="btn btn-primary btn-lg">🚀 वीडियो बनाना शुरू करें!</button></div></form></div></div><script>document.addEventListener("DOMContentLoaded",()=>{const e=document.getElementById("generate-script-btn"),t=document.getElementById("script_text"),o=document.getElementById("video-length-select"),n=document.getElementById("ai-status");e.addEventListener("click",async()=>{const a=t.value.trim();if(!a)return void(n.innerHTML='<p class="text-danger">कृपया स्क्रिप्ट बनाने के लिए कोई टॉपिक लिखें।</p>');const i=o.value;e.disabled=!0,e.innerHTML='<i class="fas fa-spinner fa-spin"></i> जेनरेट हो रहा है...',n.innerHTML="<p>🧠 AI आपके लिए एक बेहतरीन स्क्रिप्ट लिख रहा है, कृपया प्रतीक्षा करें...</p>";try{const r=await fetch("/generate-script",{method:"POST",headers:{"Content-Type":"application/json"},body:JSON.stringify({topic:a,video_length:i})}),c=await r.json();if(!r.ok)throw new Error(c.error||"सर्वर से कोई अज्ञात त्रुटि हुई।");t.value=c.script,n.innerHTML='<p style="color: #2ea043;">✅ AI ने स्क्रिप्ट तैयार कर दी है! अब आप वीडियो बना सकते हैं।</p>'}catch(d){console.error("Script Generation Error:",d),n.innerHTML=`<p class="text-danger">स्क्रिप्ट बनाने में विफल: ${d.message}</p>`}finally{e.disabled=!1,e.innerHTML='<i class="fas fa-magic"></i> AI से स्क्रिप्ट बनाएँ'}})})</script></body></html>"""
+HTML_PROCESSING = """<!DOCTYPE html><html lang="hi"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>प्रोसेसिंग...</title><link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.3/dist/css/bootstrap.min.css" rel="stylesheet">""" + MODERN_CSS_BASE + """<style>body{display:flex;align-items:center;justify-content:center;min-height:100vh}#log-output{white-space:pre-wrap;background-color:rgba(0,0,0,.3);font-family:monospace;max-height:400px;overflow-y:auto;border-radius:8px;border:1px solid var(--border-color)}.progress-bar{background:var(--gradient)}.progress{height:25px;border-radius:8px;background-color:rgba(0,0,0,.3)}</style></head><body><div class="container"><div class="card p-4 p-md-5"><h2 class="text-center">मिशन कंट्रोल</h2><p id="status-text" class="text-center text-muted">प्रक्रिया शुरू हो रही है...</p><div class="progress mb-3" role="progressbar"><div class="progress-bar progress-bar-striped progress-bar-animated" id="progress-bar" style="width:0%">0%</div></div><pre id="log-output" class="p-3"></pre></div></div><script>const taskId="{{task_id}}",progressBar=document.getElementById("progress-bar"),statusText=document.getElementById("status-text"),logOutput=document.getElementById("log-output"),pollingInterval=setInterval(async()=>{try{const e=await fetch(`/progress/${taskId}`),t=await e.json(),o=t.log.trim().split("\\n").pop();statusText.innerText=o||"प्रतीक्षा में...",progressBar.style.width=t.progress+"%",progressBar.innerText=t.progress+"%",logOutput.innerText=t.log,logOutput.scrollTop=logOutput.scrollHeight,"complete"===t.status?(clearInterval(pollingInterval),window.location.href=`/result/${t.output_filename}`):"error"===t.status&&(clearInterval(pollingInterval),statusText.innerText="कोई त्रुटि हुई! विवरण के लिए लॉग देखें।",progressBar.classList.remove("bg-success"),progressBar.classList.add("bg-danger"))}catch(e){clearInterval(pollingInterval),statusText.innerText="सर्वर से कनेक्शन टूट गया।"}},1500)</script></body></html>"""
+HTML_RESULT = """<!DOCTYPE html><html lang="hi"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>आपकी वीडियो तैयार है!</title><link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.3/dist/css/bootstrap.min.css" rel="stylesheet"><link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.5.1/css/all.min.css">""" + MODERN_CSS_BASE + """<style>body{display:flex;align-items:center;justify-content:center;min-height:100vh;text-align:center}video{width:100%;max-width:800px;border-radius:12px;border:1px solid var(--border-color)}</style></head><body><div class="container"><div class="card p-4 p-md-5"><h1 class="mb-3">🎉 मिशन पूरा हुआ!</h1><p class="text-muted mb-4">आपकी फाइनल वीडियो नीचे है।</p><video controls autoplay muted loop><source src="/outputs/{{ filename }}" type="video/mp4"> आपका ब्राउज़र वीडियो टैग को सपोर्ट नहीं करता। </video><div class="d-grid gap-2 d-md-flex justify-content-md-center mt-4"><a href="/outputs/{{ filename }}" class="btn btn-primary" download><i class="fas fa-download"></i> वीडियो डाउनलोड करें</a> <a href="/" class="btn btn-secondary">एक और वीडियो बनाएँ</a></div></div></div></body></html>"""
+HTML_HISTORY = """<!DOCTYPE html><html lang="hi"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>वीडियो हिस्ट्री</title><link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.3/dist/css/bootstrap.min.css" rel="stylesheet"><link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.5.1/css/all.min.css">""" + MODERN_CSS_BASE + """<style>.history-grid{display:grid;grid-template-columns:repeat(auto-fill,minmax(350px,1fr));gap:20px}.card{transition:transform .3s ease}.card:hover{transform:translateY(-5px)}video{width:100%;border-radius:8px;margin-top:10px;border:1px solid var(--border-color)}.actions a{margin-right:10px;margin-bottom:10px}</style></head><body><div class="container"><a href="/" class="btn btn-secondary mb-4"><i class="fas fa-arrow-left"></i> वापस मुख्य पेज पर</a><h1 class="text-center mb-5">बनाए गए वीडियो की हिस्ट्री</h1> {% if items %}<div class="history-grid"> {% for item in items %}<div class="card"><div class="card-body"><h5 class="card-title">टास्क आईडी:</h5><p class="card-text text-muted" style="font-size:.8em">{{ item.task_id }}</p><video controls preload="metadata"><source src="/outputs/{{ item.video }}" type="video/mp4"></video><div class="actions mt-3"><a href="/outputs/{{ item.video }}" class="btn btn-primary" download><i class="fas fa-download"></i> डाउनलोड</a> {% if item.report %}<a href="/outputs/{{ item.report }}" class="btn btn-dark" target="_blank"><i class="fas fa-file-alt"></i> रिपोर्ट देखें</a> {% endif %}</div></div></div> {% endfor %}</div> {% else %}<div class="text-center card p-5"><h2>कोई हिस्ट्री नहीं मिली</h2><p class="text-muted">आपने अभी तक कोई वीडियो नहीं बनाया है।</p></div> {% endif %}</div></body></html>"""
+# ==============================================================================
+# Flask Application Setup
+# ==============================================================================
+app = Flask(__name__)
+app.config['UPLOAD_FOLDER'] = UPLOAD_FOLDER
+app.config['OUTPUT_FOLDER'] = OUTPUT_FOLDER
+# <<<--- YAHAN EK LINE JODI GAYI HAI --- >>>
+# Database table banayein agar pehle se nahi bani hai
+init_db()
+# <<<--- BADLAV YAHAN KHATM HOTA HAI --- >>>
 @app.route('/')
 def home():
+    return render_template_string(HTML_HOME)
 @app.route('/process', methods=['POST'])
 def process_video():
         args=(task_id, script_text, script_file_path, orientation, max_clip_length, mute_final_video)
     )
     thread.start()
+    return render_template_string(HTML_PROCESSING, task_id=task_id)
 @app.route('/generate-script', methods=['POST'])
 def generate_script():
     task = get_task(task_id)
     if not task:
         return jsonify({'status': 'error', 'log': 'Task not found.'})
+    return jsonify(dict(task))
+@app.route('/result/<filename>')
+def result(filename):
+    return render_template_string(HTML_RESULT, filename=filename)
 @app.route('/outputs/<path:filename>')
 def serve_output_file(filename):
+    return send_from_directory(app.config['OUTPUT_FOLDER'], filename)
 @app.route('/history')
 def history():
+    output_dir = app.config['OUTPUT_FOLDER']
     history_items = []
     try:
+        all_files = sorted(os.listdir(output_dir), reverse=True)
+        for filename in all_files:
+            if filename.endswith('_final_video.mp4'):
+                task_id = filename.replace('_final_video.mp4', '')
+                report_filename = f"{task_id}_report.json"
+                item = {
+                    'video': filename,
+                    'task_id': task_id,
+                    'report': report_filename if report_filename in all_files else None
+                }
+                history_items.append(item)
+    except FileNotFoundError:
+        print(f"'{output_dir}' directory not found.")
+    return render_template_string(HTML_HISTORY, items=history_items)
+# Is block ko ab production mein ignore kar diya jayega
 if __name__ == '__main__':
+    init_db()
     app.run(host='0.0.0.0', port=5000, debug=True)

client_secret.json ADDED Viewed

	@@ -0,0 +1 @@

+ {"installed":{"client_id":"370383806325-5oll4ae3ms62b3f2h3lj86gm61dovico.apps.googleusercontent.com","project_id":"lunar-arc-476205-b5","auth_uri":"https://accounts.google.com/o/oauth2/auth","token_uri":"https://oauth2.googleapis.com/token","auth_provider_x509_cert_url":"https://www.googleapis.com/oauth2/v1/certs","client_secret":"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","redirect_uris":["http://localhost"]}}

engine.py CHANGED Viewed

@@ -1,3 +1,9 @@
 import os
 import time
 import json
@@ -11,45 +17,30 @@ import shutil
 import re
 from gtts import gTTS
 from werkzeug.utils import secure_filename
-from google.oauth2 import service_account
-from googleapiclient.discovery import build
-from googleapiclient.http import MediaFileUpload, MediaIoBaseDownload
-import io
 # ==============================================================================
-# 1. Global Setup and Database Functions
 # ==============================================================================
-APP_ROOT = os.path.dirname(os.path.abspath(__file__))
 DATA_FOLDER = os.path.join(APP_ROOT, 'data')
 UPLOAD_FOLDER = os.path.join(APP_ROOT, 'uploads')
 OUTPUT_FOLDER = os.path.join(APP_ROOT, 'outputs')
 DATABASE_FILE = os.path.join(DATA_FOLDER, 'tasks.db')
-# Ensure directories exist
-os.makedirs(DATA_FOLDER, exist_ok=True)
-os.makedirs(UPLOAD_FOLDER, exist_ok=True)
-os.makedirs(OUTPUT_FOLDER, exist_ok=True)
 def get_db_connection():
     conn = sqlite3.connect(DATABASE_FILE, check_same_thread=False)
     conn.row_factory = sqlite3.Row
     return conn
 def init_db():
     conn = get_db_connection()
-    conn.execute('''
-    CREATE TABLE IF NOT EXISTS tasks (
-        id TEXT PRIMARY KEY,
-        status TEXT NOT NULL,
-        progress INTEGER NOT NULL,
-        log TEXT,
-        creation_timestamp DATETIME DEFAULT CURRENT_TIMESTAMP,
-        video_file_id TEXT,
-        video_share_link TEXT,
-        report_file_id TEXT,
-        report_share_link TEXT
-    )''')
     conn.commit()
     conn.close()
@@ -74,18 +65,22 @@ def update_task_log(task_id, message, progress):
     conn.commit()
     conn.close()
-def update_task_final_status(task_id, status, error_message=None):
     conn = get_db_connection()
     current_log = conn.execute('SELECT log FROM tasks WHERE id = ?', (task_id,)).fetchone()['log']
     if status == 'error':
         final_log = current_log + f"\n\n🚨 FATAL ERROR: {error_message}"
-        conn.execute('UPDATE tasks SET status = ?, log = ?, progress = ? WHERE id = ?', (status, final_log, 100, task_id))
-    # 'complete' status is now handled separately after gdrive upload
     conn.commit()
     conn.close()
 def load_api_keys(prefix):
     try:
         prefix_lower = prefix.lower()
         keys = [v for k, v in os.environ.items() if k.lower().startswith(prefix_lower)]
@@ -97,10 +92,9 @@ def load_api_keys(prefix):
         return []
 # ==============================================================================
-# 2. API and Worker Classes
 # ==============================================================================
-# ... (GroqAPI, PexelsAPI, PixabayAPI, GeminiTeam, VideoAssembler classes yahan pehle jaise hi rahengi) ...
 class GroqAPI:
     def __init__(self, api_keys): self.api_keys, self.api_url, self.model, self._key_index = api_keys, "https://api.groq.com/openai/v1/audio/transcriptions", "whisper-large-v3", 0
     def transcribe_audio(self, audio_path):
@@ -307,75 +301,9 @@ class VideoAssembler:
             '-c:a', 'aac', '-shortest', self.output_path
         ]
         self._run_ffmpeg_command(command)
-# ==============================================================================
-# 2.5. Google Drive Helper Class (नया सेक्शन)
-# ==============================================================================
-class GoogleDriveHelper:
-    SCOPES = ['https://www.googleapis.com/auth/drive']
-    # <<<--- YAHAN APNI GOOGLE DRIVE FOLDER ID DALEN --- >>>
-    # Example: '1gOmqyt6IirhGCrXpKhHeU3_zWKpi-tCK'
-    FOLDER_ID = '1gOmqyt6IirhGCrXpKhHeU3_zWKpi-tCK'
-    def __init__(self):
-        self.creds = self._get_credentials()
-        self.service = build('drive', 'v3', credentials=self.creds)
-        print("✅ Google Drive Helper सफलतापूर्वक शुरू हुआ।")
-    def _get_credentials(self):
-        creds_json_str = os.getenv('GOOGLE_CREDENTIALS_JSON')
-        if not creds_json_str:
-            raise Exception("Google Drive credentials secret (GOOGLE_CREDENTIALS_JSON) nahi mila.")
-        try:
-            creds_info = json.loads(creds_json_str)
-            return service_account.Credentials.from_service_account_info(creds_info, scopes=self.SCOPES)
-        except json.JSONDecodeError:
-            raise Exception("GOOGLE_CREDENTIALS_JSON secret me JSON format apekshit hai.")
-    def upload_file(self, file_path, file_name):
-        print(f"-> Google Drive पर '{file_name}' अपलोड किया जा रहा है...")
-        file_metadata = {'name': file_name, 'parents': [self.FOLDER_ID]}
-        media = MediaFileUpload(file_path, resumable=True)
-        file = self.service.files().create(body=file_metadata, media_body=media, fields='id, webViewLink, webContentLink').execute()
-        file_id = file.get('id')
-        print(f"-> फ़ाइल सफलतापूर्वक अपलोड हुई। ID: {file_id}")
-        print("-> अनुमतियाँ (Permissions) सेट की जा रही हैं...")
-        self.service.permissions().create(fileId=file_id, body={'type': 'anyone', 'role': 'reader'}).execute()
-        print("-> अनुमतियाँ सफलतापूर्वक सेट हुईं।")
-        return {
-            'id': file_id,
-            'view_link': file.get('webViewLink'),
-            'download_link': file.get('webContentLink')
-        }
-    def delete_file(self, file_id):
-        try:
-            print(f"-> Google Drive से फ़ाइल ID: {file_id} को हटाया जा रहा है...")
-            self.service.files().delete(fileId=file_id).execute()
-            print("-> फ़ाइल सफलतापूर्वक हटा दी गई।")
-            return True
-        except Exception as e:
-            print(f"🚨 Google Drive से फ़ाइल हटाने में त्रुटि: {e}")
-            return False
-    def download_file(self, file_id, save_path):
-        try:
-            print(f"-> Google Drive से फ़ाइल ID: {file_id} को डाउनलोड किया जा रहा है...")
-            request = self.service.files().get_media(fileId=file_id)
-            fh = io.FileIO(save_path, 'wb')
-            downloader = MediaIoBaseDownload(fh, request)
-            done = False
-            while done is False:
-                status, done = downloader.next_chunk()
-                print(f"  -> डाउनलोड {int(status.progress() * 100)}% पूरा हुआ।")
-            print(f"-> फ़ाइल सफलतापूर्वक '{save_path}' पर डाउनलोड हो गई।")
-            return save_path
-        except Exception as e:
-            print(f"🚨 Google Drive से फ़ाइल डाउनलोड करने में त्रुटि: {e}")
-            return None
 # ==============================================================================
-# 3. AI Engine Worker (Updated)
 # ==============================================================================
 def run_ai_engine_worker(task_id, script_text, script_file_path, orientation, max_clip_length, mute_final_video):
     log = lambda message, progress: update_task_log(task_id, message, progress)
@@ -384,11 +312,7 @@ def run_ai_engine_worker(task_id, script_text, script_file_path, orientation, ma
         log("Step 0: API Keys की पुष्टि...", 2)
         gemini_keys, pexels_keys, pixabay_keys, groq_keys = load_api_keys("Gemini_Key"), load_api_keys("Pexels_Key"), load_api_keys("Pixabay_Key"), load_api_keys("Groq_Key")
         if not all([gemini_keys, pexels_keys, pixabay_keys, groq_keys]): raise Exception("API Key Error: Missing one or more required keys.")
-        gemini = GeminiTeam(api_keys=gemini_keys)
-        gdrive = GoogleDriveHelper()
-        log("-> सभी जरूरी API कीज मौजूद हैं।", 5)
-        # ... (Step 1 se 5 ka code pehle jaisa hi rahega) ...
         log("Step 1: स्क्रिप्ट तैयार की जा रही है...", 8)
         os.makedirs(temp_dir, exist_ok=True); narration_audio_path = ""
         if script_file_path:
@@ -485,44 +409,16 @@ def run_ai_engine_worker(task_id, script_text, script_file_path, orientation, ma
         output_filename = f"{task_id}_final_video.mp4"; output_path = os.path.join(OUTPUT_FOLDER, output_filename)
         assembler = VideoAssembler(final_gapless_timeline, narration_audio_path, output_path, width, height, mute_final_video, temp_dir)
         assembler.assemble_video(log)
-        report_file_path = os.path.join(OUTPUT_FOLDER, f'{task_id}_report.json')
         try:
-            log("-> अंतिम विस्तृत रिपोर्ट बनाई जा रही है...", 99)
             report_data = { "full_transcribed_script": full_script_text, "groq_word_timestamps": word_timestamps, "timestamps_with_pauses_added": timestamps_with_pauses, "gemini_scene_analysis_and_downloads": successful_scenes, "gemini_raw_timeline": final_timeline, "processed_gapless_timeline": final_gapless_timeline, }
             with open(report_file_path, 'w', encoding='utf-8') as f: json.dump(report_data, f, ensure_ascii=False, indent=4)
             log(f"-> विस्तृत रिपोर्ट सफलतापूर्वक '{report_file_path}' में सहेजी गई।", 99)
         except Exception as e: log(f"🚨 चेतावनी: विस्तृत रिपोर्ट सहेजने में विफल: {e}", 99)
-        log("Step 6: Google Drive पर अंतिम फ़ाइलें अपलोड की जा रही हैं...", 99)
-        video_upload_result = gdrive.upload_file(output_path, f"{task_id}_final_video.mp4")
-        report_upload_result = None
-        if os.path.exists(report_file_path):
-            report_upload_result = gdrive.upload_file(report_file_path, f"{task_id}_report.json")
-        log("-> डेटाबेस में अंतिम जानकारी सहेजी जा रही है...", 99)
-        conn = get_db_connection()
-        final_log = get_task(task_id)['log'] + "🎉 मिशन पूरा हुआ! फ़ाइलें Google Drive पर सुरक्षित हैं।"
-        conn.execute('''
-            UPDATE tasks
-            SET status = ?, progress = ?, log = ?,
-                video_file_id = ?, video_share_link = ?,
-                report_file_id = ?, report_share_link = ?
-            WHERE id = ?
-        ''', ('complete', 100, final_log,
-                video_upload_result['id'], video_upload_result['view_link'],
-                report_upload_result['id'] if report_upload_result else None,
-                report_upload_result['view_link'] if report_upload_result else None,
-                task_id))
-        conn.commit()
-        conn.close()
-        log("Step 7: पुरानी वीडियो को साफ़ किया जा रहा है (ऑटो-क्लीनअप)...", 100)
-        cleanup_old_videos(gdrive)
     except Exception as e:
-        import traceback
-        traceback.print_exc()
         update_task_final_status(task_id, 'error', error_message=str(e))
     finally:
         if os.path.exists(temp_dir):
@@ -530,12 +426,6 @@ def run_ai_engine_worker(task_id, script_text, script_file_path, orientation, ma
                 shutil.rmtree(temp_dir)
                 log(f"-> Temporary files aur folder '{temp_dir}' ko saaf kar diya gaya hai.", 100)
             except Exception as e: print(f"Cleanup Error: {e}")
-        # Clean up local output files after upload
-        local_video = os.path.join(OUTPUT_FOLDER, f"{task_id}_final_video.mp4")
-        local_report = os.path.join(OUTPUT_FOLDER, f"{task_id}_report.json")
-        if os.path.exists(local_video): os.remove(local_video)
-        if os.path.exists(local_report): os.remove(local_report)
 # ==============================================================================
 # 4. AI Script Generation Function
@@ -550,38 +440,3 @@ def generate_script_with_ai(topic, video_length):
         return script
     except Exception as e:
         raise e
-# ==============================================================================
-# 5. Auto-Cleanup Function (New)
-# ==============================================================================
-def cleanup_old_videos(gdrive_helper, keep_latest=20):
-    print(f"-> ऑटो-क्लीनअप शुरू: नवीनतम {keep_latest} वीडियो को छोड़कर ���ाकी सब हटाए जाएंगे।")
-    try:
-        conn = get_db_connection()
-        tasks_to_delete = conn.execute(
-            "SELECT * FROM tasks WHERE status = 'complete' ORDER BY creation_timestamp DESC LIMIT -1 OFFSET ?",
-            (keep_latest,)
-        ).fetchall()
-        if not tasks_to_delete:
-            print("-> हटाने के लिए कोई पुरानी वीडियो नहीं मिली।")
-            conn.close()
-            return
-        print(f"-> हटाने के लिए {len(tasks_to_delete)} पुरानी वीडियो मिलीं।")
-        for task in tasks_to_delete:
-            task_id = task['id']
-            print(f"  -> टास्क हटाया जा रहा है: {task_id}")
-            if task['video_file_id']:
-                gdrive_helper.delete_file(task['video_file_id'])
-            if task['report_file_id']:
-                gdrive_helper.delete_file(task['report_file_id'])
-            conn.execute("DELETE FROM tasks WHERE id = ?", (task_id,))
-            conn.commit()
-            print(f"  -> टास्क {task_id} सफलतापूर्वक हटा दिया गया।")
-        conn.close()
-    except Exception as e:
-        print(f"🚨 ऑटो-क्लीनअप के दौरान त्रुटि: {e}")

+# ==============================================================================
+# engine.py - [FINAL CORRECTED VERSION FOR HUGGING FACE]
+# CHANGE 1: API Keys environment variables se load hongi.
+# CHANGE 2: Sabhi folder paths (data, uploads, outputs) absolute hain.
+# ==============================================================================
+# engine.py के शुरुआत में
 import os
 import time
 import json
 import re
 from gtts import gTTS
 from werkzeug.utils import secure_filename
 # ==============================================================================
+# 1. Global Setup and Database Functions (FINAL CORRECTED VERSION)
 # ==============================================================================
+# <<<--- YAHAN SE BADLAV SHURU HAI --- >>>
+# प्रोजेक्ट की रूट डायरेक्टरी को एब्सोल्यूट पाथ के रूप में सेट करें
+APP_ROOT = '/code'
+# सभी ज़रूरी फोल्डरों के लिए एब्सोल्यूट पाथ बनाएँ
 DATA_FOLDER = os.path.join(APP_ROOT, 'data')
 UPLOAD_FOLDER = os.path.join(APP_ROOT, 'uploads')
 OUTPUT_FOLDER = os.path.join(APP_ROOT, 'outputs')
+# डेटाबेस फाइल का पूरा एब्सोल्यूट पाथ सेट करें
 DATABASE_FILE = os.path.join(DATA_FOLDER, 'tasks.db')
+# <<<--- BADLAV YAHAN KHATM HOTA HAI --- >>>
 def get_db_connection():
+    # अब यह सही पाथ का उपयोग करेगा: /code/data/tasks.db
     conn = sqlite3.connect(DATABASE_FILE, check_same_thread=False)
     conn.row_factory = sqlite3.Row
     return conn
 def init_db():
     conn = get_db_connection()
+    conn.execute('CREATE TABLE IF NOT EXISTS tasks (id TEXT PRIMARY KEY, status TEXT NOT NULL, progress INTEGER NOT NULL, log TEXT, output_filename TEXT)')
     conn.commit()
     conn.close()
     conn.commit()
     conn.close()
+def update_task_final_status(task_id, status, error_message=None, output_filename=None):
     conn = get_db_connection()
     current_log = conn.execute('SELECT log FROM tasks WHERE id = ?', (task_id,)).fetchone()['log']
     if status == 'error':
         final_log = current_log + f"\n\n🚨 FATAL ERROR: {error_message}"
+        conn.execute('UPDATE tasks SET status = ?, log = ? WHERE id = ?', (status, final_log, task_id))
+    elif status == 'complete':
+        final_log = current_log + "🎉 मिशन पूरा हुआ!"
+        conn.execute('UPDATE tasks SET status = ?, progress = ?, output_filename = ?, log = ? WHERE id = ?', (status, 100, output_filename, final_log, task_id))
     conn.commit()
     conn.close()
 def load_api_keys(prefix):
+    """
+    सिस्टम के एनवायरनमेंट वेरिएबल्स से API कीज़ लोड करता है।
+    """
     try:
         prefix_lower = prefix.lower()
         keys = [v for k, v in os.environ.items() if k.lower().startswith(prefix_lower)]
         return []
 # ==============================================================================
+# 2. All API and Worker Classes
+# (Is section mein koi badlav nahi hai)
 # ==============================================================================
 class GroqAPI:
     def __init__(self, api_keys): self.api_keys, self.api_url, self.model, self._key_index = api_keys, "https://api.groq.com/openai/v1/audio/transcriptions", "whisper-large-v3", 0
     def transcribe_audio(self, audio_path):
             '-c:a', 'aac', '-shortest', self.output_path
         ]
         self._run_ffmpeg_command(command)
 # ==============================================================================
+# 3. AI इंजन का मुख्य वर्कर
 # ==============================================================================
 def run_ai_engine_worker(task_id, script_text, script_file_path, orientation, max_clip_length, mute_final_video):
     log = lambda message, progress: update_task_log(task_id, message, progress)
         log("Step 0: API Keys की पुष्टि...", 2)
         gemini_keys, pexels_keys, pixabay_keys, groq_keys = load_api_keys("Gemini_Key"), load_api_keys("Pexels_Key"), load_api_keys("Pixabay_Key"), load_api_keys("Groq_Key")
         if not all([gemini_keys, pexels_keys, pixabay_keys, groq_keys]): raise Exception("API Key Error: Missing one or more required keys.")
+        gemini = GeminiTeam(api_keys=gemini_keys); log("-> सभी जरूरी API कीज मौजूद हैं।", 5)
         log("Step 1: स्क्रिप्ट तैयार की जा रही है...", 8)
         os.makedirs(temp_dir, exist_ok=True); narration_audio_path = ""
         if script_file_path:
         output_filename = f"{task_id}_final_video.mp4"; output_path = os.path.join(OUTPUT_FOLDER, output_filename)
         assembler = VideoAssembler(final_gapless_timeline, narration_audio_path, output_path, width, height, mute_final_video, temp_dir)
         assembler.assemble_video(log)
+        log("-> अंतिम विस्तृत रिपोर्ट बनाई जा रही है...", 99)
         try:
             report_data = { "full_transcribed_script": full_script_text, "groq_word_timestamps": word_timestamps, "timestamps_with_pauses_added": timestamps_with_pauses, "gemini_scene_analysis_and_downloads": successful_scenes, "gemini_raw_timeline": final_timeline, "processed_gapless_timeline": final_gapless_timeline, }
+            report_file_path = os.path.join(OUTPUT_FOLDER, f'{task_id}_report.json')
             with open(report_file_path, 'w', encoding='utf-8') as f: json.dump(report_data, f, ensure_ascii=False, indent=4)
             log(f"-> विस्तृत रिपोर्ट सफलतापूर्वक '{report_file_path}' में सहेजी गई।", 99)
         except Exception as e: log(f"🚨 चेतावनी: विस्तृत रिपोर्ट सहेजने में विफल: {e}", 99)
+        update_task_final_status(task_id, 'complete', output_filename=output_filename)
     except Exception as e:
+        import traceback; traceback.print_exc()
         update_task_final_status(task_id, 'error', error_message=str(e))
     finally:
         if os.path.exists(temp_dir):
                 shutil.rmtree(temp_dir)
                 log(f"-> Temporary files aur folder '{temp_dir}' ko saaf kar diya gaya hai.", 100)
             except Exception as e: print(f"Cleanup Error: {e}")
 # ==============================================================================
 # 4. AI Script Generation Function
         return script
     except Exception as e:
         raise e

faltuapp.py ADDED Viewed

	@@ -0,0 +1,202 @@

+import os
+import uuid
+import threading
+import zipfile
+import shutil
+from dotenv import load_dotenv
+from flask import Flask, request, jsonify, render_template, send_from_directory, send_file
+from werkzeug.utils import secure_filename
+from engine import (
+    init_db, create_task, get_task, get_db_connection, run_ai_engine_worker,
+    generate_script_with_ai, UPLOAD_FOLDER, OUTPUT_FOLDER
+)
+load_dotenv()
+app = Flask(__name__)
+app.config['UPLOAD_FOLDER'] = UPLOAD_FOLDER
+app.config['OUTPUT_FOLDER'] = OUTPUT_FOLDER
+init_db()
+# ==============================================================================
+# PWA, Static File, and Favicon Routes
+# ==============================================================================
+@app.route('/favicon.ico')
+def favicon():
+    return send_from_directory('static', 'favicon.png')
+@app.route('/manifest.json')
+def serve_manifest():
+    return send_from_directory('static', 'manifest.json')
+@app.route('/sw.js')
+def serve_sw():
+    return send_from_directory('static', 'sw.js')
+@app.route('/icon-512x512.png')
+def serve_icon_512():
+    return send_from_directory('static', 'icon-512x512.png')
+@app.route('/icon-192x192.png')
+def serve_icon_192():
+    return send_from_directory('static', 'icon-192x192.png')
+# ==============================================================================
+# Main Application Routes
+# ==============================================================================
+@app.route('/')
+def home():
+    return render_template('home.html')
+@app.route('/process', methods=['POST'])
+def process_video():
+    task_id = str(uuid.uuid4())
+    create_task(task_id)
+    script_text = request.form.get('script_text')
+    script_file = request.files.get('script_file')
+    orientation = request.form.get('orientation', 'horizontal')
+    max_clip_length = int(request.form.get('max_clip_length', 15))
+    mute_final_video = request.form.get('mute_final_video') == 'true'
+    script_file_path = None
+    if script_file and script_file.filename:
+        filename = secure_filename(script_file.filename)
+        task_upload_dir = os.path.join(app.config['UPLOAD_FOLDER'], task_id)
+        os.makedirs(task_upload_dir, exist_ok=True)
+        script_file_path = os.path.join(task_upload_dir, filename)
+        script_file.save(script_file_path)
+    if not script_text and not script_file_path:
+        return "Please provide a script text or an audio file.", 400
+    thread = threading.Thread(
+        target=run_ai_engine_worker,
+        args=(task_id, script_text, script_file_path, orientation, max_clip_length, mute_final_video)
+    )
+    thread.start()
+    return render_template('processing.html', task_id=task_id)
+@app.route('/generate-script', methods=['POST'])
+def generate_script():
+    data = request.get_json()
+    topic = data.get('topic')
+    video_length = data.get('video_length')
+    if not topic or not video_length:
+        return jsonify({'error': 'Topic and video length are required.'}), 400
+    try:
+        generated_script = generate_script_with_ai(topic, video_length)
+        return jsonify({'script': generated_script})
+    except Exception as e:
+        print(f"Error during script generation: {e}")
+        return jsonify({'error': f"AI से संपर्क करने में विफल: {str(e)}"}), 500
+@app.route('/progress/<task_id>')
+def progress(task_id):
+    task = get_task(task_id)
+    if not task:
+        return jsonify({'status': 'error', 'log': 'Task not found.'})
+    # task object ko dictionary me convert karein
+    task_dict = dict(task)
+    # Timestamp ko string me convert karein agar woh object hai
+    if 'creation_timestamp' in task_dict and task_dict['creation_timestamp'] is not None:
+        task_dict['creation_timestamp'] = str(task_dict['creation_timestamp'])
+    return jsonify(task_dict)
+@app.route('/result/<task_id>')
+def result(task_id):
+    task = get_task(task_id)
+    if not task or task['status'] != 'complete':
+        return "Task not found or not complete.", 404
+    return render_template('result.html', task=dict(task))
+# Yeh route ab direct file serve nahi karega, isliye ise hata sakte hain ya aise hi chhod sakte hain
+@app.route('/outputs/<path:filename>')
+def serve_output_file(filename):
+    return "Direct file access is disabled. Please use history.", 403
+# ==============================================================================
+# History and Bulk Action Routes (Updated)
+# ==============================================================================
+@app.route('/history')
+def history():
+    conn = get_db_connection()
+    # Sirf complete tasks dikhayein, naye se purane kram me
+    tasks = conn.execute("SELECT * FROM tasks WHERE status = 'complete' ORDER BY creation_timestamp DESC").fetchall()
+    conn.close()
+    history_items = []
+    for task in tasks:
+        item = {
+            'task_id': task['id'],
+            'video_link': task['video_share_link'],
+            'report_link': task['report_share_link'],
+            'timestamp': task['creation_timestamp']
+        }
+        history_items.append(item)
+    return render_template('history.html', items=history_items)
+@app.route('/history/delete', methods=['POST'])
+def delete_history_items():
+    data = request.get_json()
+    task_ids = data.get('task_ids', [])
+    if not task_ids:
+        return jsonify({'error': 'No task IDs provided'}), 400
+    try:
+        gdrive = GoogleDriveHelper()
+        conn = get_db_connection()
+        for task_id in task_ids:
+            task = conn.execute("SELECT video_file_id, report_file_id FROM tasks WHERE id = ?", (task_id,)).fetchone()
+            if task:
+                if task['video_file_id']:
+                    gdrive.delete_file(task['video_file_id'])
+                if task['report_file_id']:
+                    gdrive.delete_file(task['report_file_id'])
+                conn.execute("DELETE FROM tasks WHERE id = ?", (task_id,))
+                conn.commit()
+        conn.close()
+        return jsonify({'success': True, 'message': f'{len(task_ids)} items deleted.'})
+    except Exception as e:
+        print(f"Error during bulk delete: {e}")
+        return jsonify({'error': str(e)}), 500
+@app.route('/history/download', methods=['POST'])
+def download_history_items():
+    data = request.get_json()
+    task_ids = data.get('task_ids', [])
+    if not task_ids:
+        return jsonify({'error': 'No task IDs provided'}), 400
+    temp_dir = os.path.join(app.config['UPLOAD_FOLDER'], f"download_{uuid.uuid4()}")
+    os.makedirs(temp_dir, exist_ok=True)
+    zip_path = os.path.join(app.config['UPLOAD_FOLDER'], f"download_{uuid.uuid4()}.zip")
+    try:
+        gdrive = GoogleDriveHelper()
+        conn = get_db_connection()
+        for task_id in task_ids:
+            task = conn.execute("SELECT video_file_id, report_file_id FROM tasks WHERE id = ?", (task_id,)).fetchone()
+            if task:
+                if task['video_file_id']:
+                    gdrive.download_file(task['video_file_id'], os.path.join(temp_dir, f"{task_id}_video.mp4"))
+                if task['report_file_id']:
+                    gdrive.download_file(task['report_file_id'], os.path.join(temp_dir, f"{task_id}_report.json"))
+        conn.close()
+        with zipfile.ZipFile(zip_path, 'w') as zipf:
+            for root, dirs, files in os.walk(temp_dir):
+                for file in files:
+                    zipf.write(os.path.join(root, file), arcname=file)
+        return send_file(zip_path, as_attachment=True, download_name='AI_Videos_Export.zip')
+    except Exception as e:
+        print(f"Error during bulk download: {e}")
+        return jsonify({'error': str(e)}), 500
+    finally:
+        if os.path.exists(temp_dir):
+            shutil.rmtree(temp_dir)
+        if os.path.exists(zip_path):
+            os.remove(zip_path)
+if __name__ == '__main__':
+    app.run(host='0.0.0.0', port=5000, debug=True)

oldapp.py DELETED Viewed

@@ -1,129 +0,0 @@
-# ==============================================================================
-# app.py - [FINAL CORRECTED VERSION FOR HUGGING FACE v2]
-# CHANGE: init_db() ko app startup par call kiya gaya hai.
-# ==============================================================================
-import os
-from dotenv import load_dotenv
-# Ye line aapke local .env file se variables load karegi (Hugging Face par iska koi asar nahi)
-load_dotenv()
-import uuid
-import threading
-from flask import Flask, request, jsonify, render_template_string, send_from_directory
-from werkzeug.utils import secure_filename
-# engine.py se zaroori functions AUR FOLDER PATHS import karein
-from engine import (
-    init_db, create_task, get_task, run_ai_engine_worker,
-    generate_script_with_ai,
-    UPLOAD_FOLDER,
-    OUTPUT_FOLDER
-)
-# ==============================================================================
-# 1. HTML Templates
-# ==============================================================================
-MODERN_CSS_BASE = """<link rel="preconnect" href="https://fonts.googleapis.com"><link rel="preconnect" href="https://fonts.gstatic.com" crossorigin><link href="https://fonts.googleapis.com/css2?family=Poppins:wght@300;400;600;700&display=swap" rel="stylesheet"><style>:root{--bg-color:#1a1a2e;--card-bg-color:rgba(22,22,46,0.7);--primary-color:#e94560;--secondary-color:#0f3460;--text-color:#f0f0f0;--text-muted-color:#a0a0a0;--border-color:rgba(233,69,96,0.2);--gradient:linear-gradient(90deg,#e94560,#a63f82)}body{font-family:'Poppins',sans-serif;background-color:var(--bg-color);background-image:linear-gradient(315deg,var(--bg-color) 0%,var(--secondary-color) 74%);color:var(--text-color);padding-top:20px;padding-bottom:20px}.card{background:var(--card-bg-color);border:1px solid var(--border-color);border-radius:16px;backdrop-filter:blur(10px);-webkit-backdrop-filter:blur(10px);box-shadow:0 8px 32px 0 rgba(0,0,0,0.37);animation:fadeInUp 0.5s ease-out}h1,h2,h3,h4,h5,h6{background:var(--gradient);-webkit-background-clip:text;-webkit-text-fill-color:transparent;font-weight:700}.text-muted{color:var(--text-muted-color) !important}.form-control,.form-select{background-color:rgba(0,0,0,0.2);color:var(--text-color);border:1px solid var(--border-color);border-radius:8px}.form-control:focus,.form-select:focus{background-color:rgba(0,0,0,0.3);color:var(--text-color);border-color:var(--primary-color);box-shadow:0 0 0 .25rem rgba(233,69,96,0.25)}.form-control::placeholder{color:var(--text-muted-color);opacity:.7}.btn{border:none;border-radius:8px;font-weight:600;padding:12px 24px;transition:transform .1s ease-out,box-shadow .2s ease-out,filter .2s ease-out}.btn:hover{transform:translateY(-3px);box-shadow:0 5px 15px rgba(0,0,0,.3)}.btn:active{transform:translateY(0) scale(.98);filter:brightness(1.2)}.btn-primary{background:var(--gradient);color:#fff}.btn-primary:active{box-shadow:0 0 5px var(--primary-color),0 0 25px var(--primary-color),0 0 50px var(--primary-color)}.btn-secondary:active,.btn-dark:active{box-shadow:0 0 5px rgba(255,255,255,.8),0 0 25px rgba(255,255,255,.5)}@keyframes fadeInUp{from{opacity:0;transform:translateY(20px)}to{opacity:1;transform:translateY(0)}}</style>"""
-HTML_HOME = """<!DOCTYPE html><html lang="hi"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>Sparkling Gyan AI - होम</title><link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.3/dist/css/bootstrap.min.css" rel="stylesheet"><link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.5.1/css/all.min.css">""" + MODERN_CSS_BASE + """<style>.ai-generator-controls{border:1px solid var(--border-color);border-radius:12px;padding:20px;margin-top:20px;background-color:rgba(0,0,0,.1)}</style></head><body><div class="container my-5"><div class="card p-4 p-md-5"><div class="d-flex justify-content-between align-items-center mb-3"><h1 class="mb-0">✨ Sparkling Gyan AI</h1><a href="/history" class="btn btn-secondary"><i class="fas fa-history"></i> हिस्ट्री देखें</a></div><p class="text-center text-muted mb-4">एक उन्नत, ऑटोमेटिक वीडियो जेनरेटर</p><form id="upload-form" action="/process" method="POST" enctype="multipart/form-data"><div class="mb-3"><label for="script_text" class="form-label fs-5 fw-bold text-light">१. कहानी लिखें</label><textarea class="form-control" id="script_text" name="script_text" rows="8" placeholder="यहाँ कोई टॉपिक लिखें (जैसे 'चंद्रमा के रहस्य') और नीचे 'AI से स्क्रिप्ट बनाएँ' बटन दबाएँ, या अपनी पूरी स्क्रिप्ट यहाँ पेस्ट करें..."></textarea></div><div class="ai-generator-controls"><div class="row align-items-end"><div class="col-md-5"><label for="video-length-select" class="form-label text-light">वीडियो की लंबाई</label><select id="video-length-select" class="form-select"><option value="short">छोटी (~30 सेकंड)</option><option value="medium" selected>मध्यम (~1 मिनट)</option><option value="long">लंबी (~2 मिनट)</option></select></div><div class="col-md-7 d-grid"><button type="button" id="generate-script-btn" class="btn btn-dark"><i class="fas fa-magic"></i> AI से स्क्रिप्ट बनाएँ</button></div></div><div id="ai-status" class="mt-2"></div></div><div class="text-center text-muted my-3">या</div><div class="mb-3"><label for="script_file" class="form-label">एक ऑडियो स्क्रिप्ट फ़ाइल अपलोड करें</label><input class="form-control" type="file" id="script_file" name="script_file" accept="audio/*"></div><h5 class="mt-4 mb-3 text-light">२. अतिरिक्त विकल्प</h5><div class="row mb-3"><div class="col-md-6"><label class="form-label">वीडियो ओरिएंटेशन</label><div class="form-check"><input class="form-check-input" type="radio" name="orientation" id="orientation_horizontal" value="horizontal" checked><label class="form-check-label" for="orientation_horizontal">Landscape (16:9)</label></div><div class="form-check"><input class="form-check-input" type="radio" name="orientation" id="orientation_vertical" value="vertical"><label class="form-check-label" for="orientation_vertical">Portrait (9:16)</label></div></div><div class="col-md-6"><label for="max_clip_length" class="form-label">अधिकतम क्लिप लंबाई (सेकंड)</label><input type="number" class="form-control" id="max_clip_length" name="max_clip_length" value="15" min="3"></div></div><div class="form-check mb-4"><input class="form-check-input" type="checkbox" value="true" id="mute_final_video" name="mute_final_video"><label class="form-check-label" for="mute_final_video">ऑडियो/वॉयसओवर ट्रैक को म्यूट करें</label></div><div class="d-grid mt-4"><button type="submit" class="btn btn-primary btn-lg">🚀 वीडियो बनाना शुरू करें!</button></div></form></div></div><script>document.addEventListener("DOMContentLoaded",()=>{const e=document.getElementById("generate-script-btn"),t=document.getElementById("script_text"),o=document.getElementById("video-length-select"),n=document.getElementById("ai-status");e.addEventListener("click",async()=>{const a=t.value.trim();if(!a)return void(n.innerHTML='<p class="text-danger">कृपया स्क्रिप्ट बनाने के लिए कोई टॉपिक लिखें।</p>');const i=o.value;e.disabled=!0,e.innerHTML='<i class="fas fa-spinner fa-spin"></i> जेनरेट हो रहा है...',n.innerHTML="<p>🧠 AI आपके लिए एक बेहतरीन स्क्रिप्ट लिख रहा है, कृपया प्रतीक्षा करें...</p>";try{const r=await fetch("/generate-script",{method:"POST",headers:{"Content-Type":"application/json"},body:JSON.stringify({topic:a,video_length:i})}),c=await r.json();if(!r.ok)throw new Error(c.error||"सर्वर से कोई अज्ञात त्रुटि हुई।");t.value=c.script,n.innerHTML='<p style="color: #2ea043;">✅ AI ने स्क्रिप्ट तैयार कर दी है! अब आप वीडियो बना सकते हैं।</p>'}catch(d){console.error("Script Generation Error:",d),n.innerHTML=`<p class="text-danger">स्क्रिप्ट बनाने में विफल: ${d.message}</p>`}finally{e.disabled=!1,e.innerHTML='<i class="fas fa-magic"></i> AI से स्क्रिप्ट बनाएँ'}})})</script></body></html>"""
-HTML_PROCESSING = """<!DOCTYPE html><html lang="hi"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>प्रोसेसिंग...</title><link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.3/dist/css/bootstrap.min.css" rel="stylesheet">""" + MODERN_CSS_BASE + """<style>body{display:flex;align-items:center;justify-content:center;min-height:100vh}#log-output{white-space:pre-wrap;background-color:rgba(0,0,0,.3);font-family:monospace;max-height:400px;overflow-y:auto;border-radius:8px;border:1px solid var(--border-color)}.progress-bar{background:var(--gradient)}.progress{height:25px;border-radius:8px;background-color:rgba(0,0,0,.3)}</style></head><body><div class="container"><div class="card p-4 p-md-5"><h2 class="text-center">मिशन कंट्रोल</h2><p id="status-text" class="text-center text-muted">प्रक्रिया शुरू हो रही है...</p><div class="progress mb-3" role="progressbar"><div class="progress-bar progress-bar-striped progress-bar-animated" id="progress-bar" style="width:0%">0%</div></div><pre id="log-output" class="p-3"></pre></div></div><script>const taskId="{{task_id}}",progressBar=document.getElementById("progress-bar"),statusText=document.getElementById("status-text"),logOutput=document.getElementById("log-output"),pollingInterval=setInterval(async()=>{try{const e=await fetch(`/progress/${taskId}`),t=await e.json(),o=t.log.trim().split("\\n").pop();statusText.innerText=o||"प्रतीक्षा में...",progressBar.style.width=t.progress+"%",progressBar.innerText=t.progress+"%",logOutput.innerText=t.log,logOutput.scrollTop=logOutput.scrollHeight,"complete"===t.status?(clearInterval(pollingInterval),window.location.href=`/result/${t.output_filename}`):"error"===t.status&&(clearInterval(pollingInterval),statusText.innerText="कोई त्रुटि हुई! विवरण के लिए लॉग देखें।",progressBar.classList.remove("bg-success"),progressBar.classList.add("bg-danger"))}catch(e){clearInterval(pollingInterval),statusText.innerText="सर्वर से कनेक्शन टूट गया।"}},1500)</script></body></html>"""
-HTML_RESULT = """<!DOCTYPE html><html lang="hi"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>आपकी वीडियो तैयार है!</title><link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.3/dist/css/bootstrap.min.css" rel="stylesheet"><link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.5.1/css/all.min.css">""" + MODERN_CSS_BASE + """<style>body{display:flex;align-items:center;justify-content:center;min-height:100vh;text-align:center}video{width:100%;max-width:800px;border-radius:12px;border:1px solid var(--border-color)}</style></head><body><div class="container"><div class="card p-4 p-md-5"><h1 class="mb-3">🎉 मिशन पूरा हुआ!</h1><p class="text-muted mb-4">आपकी फाइनल वीडियो नीचे है।</p><video controls autoplay muted loop><source src="/outputs/{{ filename }}" type="video/mp4"> आपका ब्राउज़र वीडियो टैग को सपोर्ट नहीं करता। </video><div class="d-grid gap-2 d-md-flex justify-content-md-center mt-4"><a href="/outputs/{{ filename }}" class="btn btn-primary" download><i class="fas fa-download"></i> वीडियो डाउनलोड करें</a> <a href="/" class="btn btn-secondary">एक और वीडियो बनाएँ</a></div></div></div></body></html>"""
-HTML_HISTORY = """<!DOCTYPE html><html lang="hi"><head><meta charset="UTF-8"><meta name="viewport" content="width=device-width,initial-scale=1"><title>वीडियो हिस्ट्री</title><link href="https://cdn.jsdelivr.net/npm/bootstrap@5.3.3/dist/css/bootstrap.min.css" rel="stylesheet"><link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.5.1/css/all.min.css">""" + MODERN_CSS_BASE + """<style>.history-grid{display:grid;grid-template-columns:repeat(auto-fill,minmax(350px,1fr));gap:20px}.card{transition:transform .3s ease}.card:hover{transform:translateY(-5px)}video{width:100%;border-radius:8px;margin-top:10px;border:1px solid var(--border-color)}.actions a{margin-right:10px;margin-bottom:10px}</style></head><body><div class="container"><a href="/" class="btn btn-secondary mb-4"><i class="fas fa-arrow-left"></i> वापस मुख्य पेज पर</a><h1 class="text-center mb-5">बनाए गए वीडियो की हिस्ट्री</h1> {% if items %}<div class="history-grid"> {% for item in items %}<div class="card"><div class="card-body"><h5 class="card-title">टास्क आईडी:</h5><p class="card-text text-muted" style="font-size:.8em">{{ item.task_id }}</p><video controls preload="metadata"><source src="/outputs/{{ item.video }}" type="video/mp4"></video><div class="actions mt-3"><a href="/outputs/{{ item.video }}" class="btn btn-primary" download><i class="fas fa-download"></i> डाउनलोड</a> {% if item.report %}<a href="/outputs/{{ item.report }}" class="btn btn-dark" target="_blank"><i class="fas fa-file-alt"></i> रिपोर्ट देखें</a> {% endif %}</div></div></div> {% endfor %}</div> {% else %}<div class="text-center card p-5"><h2>कोई हिस्ट्री नहीं मिली</h2><p class="text-muted">आपने अभी तक कोई वीडियो नहीं बनाया है।</p></div> {% endif %}</div></body></html>"""
-# ==============================================================================
-# Flask Application Setup
-# ==============================================================================
-app = Flask(__name__)
-app.config['UPLOAD_FOLDER'] = UPLOAD_FOLDER
-app.config['OUTPUT_FOLDER'] = OUTPUT_FOLDER
-# <<<--- YAHAN EK LINE JODI GAYI HAI --- >>>
-# Database table banayein agar pehle se nahi bani hai
-init_db()
-# <<<--- BADLAV YAHAN KHATM HOTA HAI --- >>>
-@app.route('/')
-def home():
-    return render_template_string(HTML_HOME)
-@app.route('/process', methods=['POST'])
-def process_video():
-    task_id = str(uuid.uuid4())
-    create_task(task_id)
-    script_text = request.form.get('script_text')
-    script_file = request.files.get('script_file')
-    orientation = request.form.get('orientation', 'horizontal')
-    max_clip_length = int(request.form.get('max_clip_length', 15))
-    mute_final_video = request.form.get('mute_final_video') == 'true'
-    script_file_path = None
-    if script_file and script_file.filename:
-        filename = secure_filename(script_file.filename)
-        task_upload_dir = os.path.join(app.config['UPLOAD_FOLDER'], task_id)
-        os.makedirs(task_upload_dir, exist_ok=True)
-        script_file_path = os.path.join(task_upload_dir, filename)
-        script_file.save(script_file_path)
-    if not script_text and not script_file_path:
-        return "Please provide a script text or an audio file.", 400
-    thread = threading.Thread(
-        target=run_ai_engine_worker,
-        args=(task_id, script_text, script_file_path, orientation, max_clip_length, mute_final_video)
-    )
-    thread.start()
-    return render_template_string(HTML_PROCESSING, task_id=task_id)
-@app.route('/generate-script', methods=['POST'])
-def generate_script():
-    data = request.get_json()
-    topic = data.get('topic')
-    video_length = data.get('video_length')
-    if not topic or not video_length:
-        return jsonify({'error': 'Topic and video length are required.'}), 400
-    try:
-        generated_script = generate_script_with_ai(topic, video_length)
-        return jsonify({'script': generated_script})
-    except Exception as e:
-        print(f"Error during script generation: {e}")
-        return jsonify({'error': f"AI से संपर्क करने में विफल: {str(e)}"}), 500
-@app.route('/progress/<task_id>')
-def progress(task_id):
-    task = get_task(task_id)
-    if not task:
-        return jsonify({'status': 'error', 'log': 'Task not found.'})
-    return jsonify(dict(task))
-@app.route('/result/<filename>')
-def result(filename):
-    return render_template_string(HTML_RESULT, filename=filename)
-@app.route('/outputs/<path:filename>')
-def serve_output_file(filename):
-    return send_from_directory(app.config['OUTPUT_FOLDER'], filename)
-@app.route('/history')
-def history():
-    output_dir = app.config['OUTPUT_FOLDER']
-    history_items = []
-    try:
-        all_files = sorted(os.listdir(output_dir), reverse=True)
-        for filename in all_files:
-            if filename.endswith('_final_video.mp4'):
-                task_id = filename.replace('_final_video.mp4', '')
-                report_filename = f"{task_id}_report.json"
-                item = {
-                    'video': filename,
-                    'task_id': task_id,
-                    'report': report_filename if report_filename in all_files else None
-                }
-                history_items.append(item)
-    except FileNotFoundError:
-        print(f"'{output_dir}' directory not found.")
-    return render_template_string(HTML_HISTORY, items=history_items)
-# Is block ko ab production mein ignore kar diya jayega
-if __name__ == '__main__':
-    init_db()
-    app.run(host='0.0.0.0', port=5000, debug=True)

oldengn.py DELETED Viewed

@@ -1,442 +0,0 @@
-# ==============================================================================
-# engine.py - [FINAL CORRECTED VERSION FOR HUGGING FACE]
-# CHANGE 1: API Keys environment variables se load hongi.
-# CHANGE 2: Sabhi folder paths (data, uploads, outputs) absolute hain.
-# ==============================================================================
-# engine.py के शुरुआत में
-import os
-import time
-import json
-import uuid
-import threading
-import subprocess
-import requests
-import sqlite3
-import random
-import shutil
-import re
-from gtts import gTTS
-from werkzeug.utils import secure_filename
-# ==============================================================================
-# 1. Global Setup and Database Functions (FINAL CORRECTED VERSION)
-# ==============================================================================
-# <<<--- YAHAN SE BADLAV SHURU HAI --- >>>
-# प्रोजेक्ट की रूट डायरेक्टरी को एब्सोल्यूट पाथ के रूप में सेट करें
-APP_ROOT = '/code'
-# सभी ज़रूरी फोल्डरों के लिए एब्सोल्यूट पाथ बनाएँ
-DATA_FOLDER = os.path.join(APP_ROOT, 'data')
-UPLOAD_FOLDER = os.path.join(APP_ROOT, 'uploads')
-OUTPUT_FOLDER = os.path.join(APP_ROOT, 'outputs')
-# डेटाबेस फाइल का पूरा एब्सोल्यूट पाथ सेट करें
-DATABASE_FILE = os.path.join(DATA_FOLDER, 'tasks.db')
-# <<<--- BADLAV YAHAN KHATM HOTA HAI --- >>>
-def get_db_connection():
-    # अब यह सही पाथ का उपयोग करेगा: /code/data/tasks.db
-    conn = sqlite3.connect(DATABASE_FILE, check_same_thread=False)
-    conn.row_factory = sqlite3.Row
-    return conn
-def init_db():
-    conn = get_db_connection()
-    conn.execute('CREATE TABLE IF NOT EXISTS tasks (id TEXT PRIMARY KEY, status TEXT NOT NULL, progress INTEGER NOT NULL, log TEXT, output_filename TEXT)')
-    conn.commit()
-    conn.close()
-def create_task(task_id):
-    log_message = "मिशन शुरू हो रहा है...\n"
-    conn = get_db_connection()
-    conn.execute('INSERT INTO tasks (id, status, progress, log) VALUES (?, ?, ?, ?)', (task_id, 'processing', 0, log_message))
-    conn.commit()
-    conn.close()
-def get_task(task_id):
-    conn = get_db_connection()
-    task = conn.execute('SELECT * FROM tasks WHERE id = ?', (task_id,)).fetchone()
-    conn.close()
-    return task
-def update_task_log(task_id, message, progress):
-    conn = get_db_connection()
-    current_log = conn.execute('SELECT log FROM tasks WHERE id = ?', (task_id,)).fetchone()['log']
-    new_log = current_log + message + "\n"
-    conn.execute('UPDATE tasks SET log = ?, progress = ? WHERE id = ?', (new_log, progress, task_id))
-    conn.commit()
-    conn.close()
-def update_task_final_status(task_id, status, error_message=None, output_filename=None):
-    conn = get_db_connection()
-    current_log = conn.execute('SELECT log FROM tasks WHERE id = ?', (task_id,)).fetchone()['log']
-    if status == 'error':
-        final_log = current_log + f"\n\n🚨 FATAL ERROR: {error_message}"
-        conn.execute('UPDATE tasks SET status = ?, log = ? WHERE id = ?', (status, final_log, task_id))
-    elif status == 'complete':
-        final_log = current_log + "🎉 मिशन पूरा हुआ!"
-        conn.execute('UPDATE tasks SET status = ?, progress = ?, output_filename = ?, log = ? WHERE id = ?', (status, 100, output_filename, final_log, task_id))
-    conn.commit()
-    conn.close()
-def load_api_keys(prefix):
-    """
-    सिस्टम के एनवायरनमेंट वेरिएबल्स से API कीज़ लोड करता है।
-    """
-    try:
-        prefix_lower = prefix.lower()
-        keys = [v for k, v in os.environ.items() if k.lower().startswith(prefix_lower)]
-        if not keys:
-            print(f"🚨 चेतावनी: '{prefix}' से शुरू होने वाला कोई एनवायरनमेंट वेरिएबल नहीं मिला।")
-        return keys
-    except Exception as e:
-        print(f"🚨 एनवायरनमेंट वेरिएबल्स लोड करते समय त्रुटि: {e}")
-        return []
-# ==============================================================================
-# 2. All API and Worker Classes
-# (Is section mein koi badlav nahi hai)
-# ==============================================================================
-class GroqAPI:
-    def __init__(self, api_keys): self.api_keys, self.api_url, self.model, self._key_index = api_keys, "https://api.groq.com/openai/v1/audio/transcriptions", "whisper-large-v3", 0
-    def transcribe_audio(self, audio_path):
-        if not self.api_keys: raise Exception("Groq API key not found.")
-        api_key = self.api_keys[self._key_index % len(self.api_keys)]; self._key_index += 1
-        data = {'model': self.model, 'response_format': 'verbose_json', 'timestamp_granularities[]': 'word'}
-        headers = {'Authorization': f'Bearer {api_key}'}
-        try:
-            with open(audio_path, 'rb') as audio_file:
-                files = {'file': (os.path.basename(audio_path), audio_file, 'audio/mpeg')}; print(f"-> Groq API को शब्द-स्तर पर टाइमस्टैम्प के लिए भेजा जा रहा है...")
-                response = requests.post(self.api_url, headers=headers, data=data, files=files, timeout=120); response.raise_for_status()
-                words_data = response.json().get('words', []); print(f"-> ट्रांसक्रिप्शन सफल: {len(words_data)} शब्दों के टाइमस्टैम्प मिले।"); return words_data
-        except Exception as e: raise Exception(f"Groq API Error: {e}")
-class PexelsAPI:
-    def __init__(self, api_keys):
-        if not api_keys: raise Exception("Pexels API key not found.")
-        self.api_key = api_keys[0]; self.api_url = "https://api.pexels.com/videos/search"
-    def search_and_download(self, query, download_path, orientation, search_page=1):
-        print(f"-> Pexels पर खोजा जा रहा है (Direct API): '{query}' (Page: {search_page}, Orientation: {orientation})")
-        headers = {'Authorization': self.api_key}; params = {'query': query, 'page': search_page, 'per_page': 1, 'orientation': orientation}
-        try:
-            response = requests.get(self.api_url, headers=headers, params=params, timeout=60); response.raise_for_status(); data = response.json()
-            if not data.get('videos'): print(f"-> Pexels पर '{query}' के लिए कोई परिणाम नहीं मिला।"); return None
-            video_data = data['videos'][0]; video_files = video_data.get('video_files', []); best_link = None
-            for video_file in video_files:
-                if video_file.get('quality') == 'hd': best_link = video_file.get('link'); break
-            if not best_link and video_files: best_link = video_files[0].get('link')
-            if not best_link: print(f"-> Pexels परिणाम में कोई डाउनलोड करने योग्य लिंक नहीं मिला।"); return None
-            print(f"-> Pexels से वीडियो डाउनलोड किया जा रहा है..."); download_response = requests.get(best_link, stream=True, timeout=60); download_response.raise_for_status()
-            with open(download_path, 'wb') as f:
-                for chunk in download_response.iter_content(chunk_size=8192): f.write(chunk)
-            print(f"-> सफलतापूर्वक सहेजा गया: {download_path}"); return download_path
-        except requests.exceptions.RequestException as e: print(f"🚨 Pexels API में त्रुटि: {e}"); return None
-        except Exception as e: print(f"🚨 Pexels वीडियो डाउनलोड करने में अज्ञात त्रुटि: {e}"); return None
-class PixabayAPI:
-    def __init__(self, api_keys):
-        if not api_keys: raise Exception("Pixabay API key not found.")
-        self.api_key = api_keys[0]; self.api_url = "https://pixabay.com/api/videos/"
-    def search_and_download(self, query, download_path, orientation, max_clip_length, search_index=0):
-        print(f"-> Pixabay पर खोजा जा रहा है: '{query}' (Index: {search_index})")
-        params = {'key': self.api_key, 'q': query, 'per_page': 5, 'orientation': orientation, 'max_duration': int(max_clip_length)}
-        try:
-            response = requests.get(self.api_url, params=params, timeout=60); response.raise_for_status(); results = response.json()
-            if not results['hits'] or len(results['hits']) <= search_index: print(f"-> Pixabay पर '{query}' के लिए index {search_index} पर कोई परिणाम नहीं मिला।"); return None
-            video_url = results['hits'][search_index]['videos']['medium']['url']; print(f"-> Pixabay से वीडियो डाउनलोड किया जा रहा है...")
-            response = requests.get(video_url, stream=True, timeout=60); response.raise_for_status()
-            with open(download_path, 'wb') as f:
-                for chunk in response.iter_content(chunk_size=8192): f.write(chunk)
-            print(f"-> सफलतापूर्वक सहेजा गया: {download_path}"); return download_path
-        except Exception as e: print(f"🚨 Pixabay API में त्रुटि: {e}"); return None
-class GeminiTeam:
-    MODELS_LIST_URL = "https://generativelanguage.googleapis.com/v1beta/models"
-    def __init__(self, api_keys):
-        self.api_keys = api_keys
-        if not self.api_keys: raise Exception("Gemini API key not found.")
-        self.model_name = self._find_best_model()
-        if not self.model_name: raise Exception("Could not dynamically find a suitable Gemini 'flash' model from any of the provided keys.")
-        self.api_url = f"https://generativelanguage.googleapis.com/v1beta/{self.model_name}:generateContent"
-        print(f"✅ स्मार्ट मॉडल हंटर सफल: '{self.model_name}' का उपयोग किया जाएगा।")
-    def _find_best_model(self):
-        print("-> स्मार्ट मॉडल हंटर: सबसे अच्छे 'gemini-*-flash' मॉडल को खोजा जा रहा है...")
-        for api_key in self.api_keys:
-            try:
-                print(f"-> API Key के अंतिम 4 अक्षरों से कोशिश की जा रही है: ...{api_key[-4:]}")
-                response = requests.get(f"{self.MODELS_LIST_URL}?key={api_key}", timeout=20); response.raise_for_status(); data = response.json()
-                available_models = [m['name'] for m in data.get('models', []) if 'flash' in m['name'] and 'generateContent' in m.get('supportedGenerationMethods', []) and 'exp' not in m['name']]
-                if not available_models: continue
-                available_models.sort(reverse=True); print(f"-> उपलब्ध 'flash' मॉडल मिले: {available_models}"); return available_models[0]
-            except requests.exceptions.RequestException as e: print(f"🚨 API Key ...{api_key[-4:]} के साथ त्रुटि: {e}. अगली की आजमाई जा रही है..."); continue
-        print("🚨 स्मार्ट मॉडल हंटर में गंभीर त्रुटि: कोई भी Gemini API Key काम नहीं कर रही है।"); return None
-    def _make_resilient_api_call(self, prompt, timeout=120):
-        headers = {'Content-Type': 'application/json'}; payload = {'contents': [{'parts': [{'text': prompt}]}]}
-        for api_key in self.api_keys:
-            try:
-                print(f"-> Gemini को अनुरोध भेजा जा रहा है (Key: ...{api_key[-4:]}, Model: {self.model_name.split('/')[-1]})")
-                response = requests.post(f"{self.api_url}?key={api_key}", headers=headers, json=payload, timeout=timeout); response.raise_for_status(); result = response.json()
-                if 'candidates' not in result or not result['candidates']: print(f"🚨 चेतावनी: Key ...{api_key[-4:]} से कोई कैंडिडेट नहीं मिला (संभवतः सुरक्षा ब्लॉक)। अगली की आजमाई जा रही है..."); continue
-                return result
-            except requests.exceptions.RequestException as e: print(f"🚨 API कॉल में त्रुटि (Key: ...{api_key[-4:]}): {e}. अगली की आजमाई जा रही है...");
-        raise Exception("Gemini API Error: All available API keys failed. Please check your keys and quotas.")
-    def extract_keywords(self, script_text):
-        prompt = f"""You are a search query expert. Analyze the script below and for each scene, create a JSON object. Each object must contain: 1. "scene_description": A brief description of the scene. 2. "primary_query": A highly creative, emotional, and cinematic search query in English. This is the main attempt. 3. "fallback_query": A simple, literal, and direct search query in English. Use this if the primary query fails. RULES: - Your response MUST be ONLY a JSON list of objects. - All queries must be in English. Script: "{script_text}" Example: [ {{"scene_description": "A person looking at a mountain.", "primary_query": "inspirational mountain peak cinematic hope", "fallback_query": "man looking at mountain"}} ] Generate the JSON:"""
-        result = self._make_resilient_api_call(prompt)
-        json_str = result['candidates'][0]['content']['parts'][0]['text']
-        clean_str = json_str[json_str.find('['):json_str.rfind(']') + 1]; scenes = json.loads(clean_str)
-        try:
-            log_file_path = os.path.join(OUTPUT_FOLDER, 'gemini_analysis_log.json')
-            with open(log_file_path, 'w', encoding='utf-8') as f: json.dump(scenes, f, ensure_ascii=False, indent=4)
-            print(f"-> Gemini का विश्लेषण सफलतापूर्वक '{log_file_path}' में सहेजा गया।")
-        except Exception as e: print(f"🚨 चेतावनी: Gemini विश्लेषण लॉग करने में विफल: {e}")
-        print(f"-> Gemini ने सफलतापूर्वक {len(scenes)} प्राथमिक/फ़ॉलबैक दृश्य निकाले।"); return scenes
-    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:"""
-        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)
-        print(f"-> Gemini Master Editor ने सफलतापूर्वक {len(final_timeline)} क्लिप्स की टाइमलाइन और ऑफसेट बना दी है।"); return final_timeline
-    def generate_script(self, topic, video_length):
-        word_count_map = {"short": "~75 शब्द", "medium": "~150 शब्द", "long": "~300 शब्द"}; target_word_count = word_count_map.get(video_length, "~150 शब्द")
-        prompt = f"""आप 'स्पार्कलिंग ज्ञान' के लिए एक विशेषज्ञ हिंदी स्क्रिप्ट राइटर हैं।
-विषय: "{topic}".
-निर्देश:
-1. इस विषय पर एक आकर्षक, {target_word_count} की स्क्रिप्ट लिखें।
-2. भाषा सरल और बोलचाल वाली हो।
-3. हर 2-3 लाइनों के बाद एक नया विज़ुअल या सीन दिखाया जा सके, इस तरह से लिखें।
-4. **CRITICAL RULE:** आपका आउटपुट सिर्फ और सिर्फ बोले जाने वाले डायलॉग्स (narration) होने चाहिए। किसी भी तरह के विज़ुअल निर्देश, सीन डिस्क्रिप्शन या ब्रैकेट () [] में लिखी कोई भी जानकारी आउटपुट में नहीं होनी चाहिए। सिर्फ वो टेक्स्ट दें जो ऑडियो में बोला जाएगा।
-अब, स्क्रिप्ट लिखें:"""
-        result = self._make_resilient_api_call(prompt)
-        generated_script = result['candidates'][0]['content']['parts'][0]['text']
-        print("-> Gemini ने सफलतापूर्वक स्क्रिप्ट जेनरेट कर दी है।"); return generated_script.strip()
-class VideoAssembler:
-    TRANSITION_DURATION = 0.5
-    def __init__(self, timeline, narration_audio, output_path, width, height, mute_audio, temp_dir):
-        self.timeline = timeline; self.narration_audio = narration_audio; self.output_path = output_path; self.width = width; self.height = height; self.mute_audio = mute_audio
-        self.temp_dir = temp_dir
-    def _run_ffmpeg_command(self, command, suppress_errors=False):
-        process = subprocess.run(command, capture_output=True, text=True)
-        if not suppress_errors and process.returncode != 0:
-            error_details = f"Return Code {process.returncode}"
-            if process.returncode == -9: error_details += " (SIGKILL): Process was killed, likely due to excessive memory usage."
-            raise Exception(f"FFmpeg Error ({error_details}):\nSTDERR:\n{process.stderr}")
-        return process
-    def assemble_video(self, log_callback):
-        if not self.timeline: return
-        log_callback("-> Stage 1/3: सभी क्लिप्स को व्यक्तिगत रूप से तैयार किया जा रहा है...", 91)
-        prepared_clips = []
-        for i, item in enumerate(self.timeline):
-            input_clip_path = item['matched_clip']
-            try:
-                ffprobe_command = ['ffprobe', '-v', 'error', '-show_entries', 'format=duration', '-of', 'default=noprint_wrappers=1:nokey=1', input_clip_path]
-                duration_proc = self._run_ffmpeg_command(ffprobe_command)
-                actual_clip_duration = float(duration_proc.stdout.strip())
-            except Exception as e:
-                log_callback(f"🚨 चेतावनी: क्लिप {os.path.basename(input_clip_path)} की अवधि का पता नहीं लगाया जा सका, इसे छोड़ दिया जाएगा। त्रुटि: {e}", 91)
-                continue
-            start_offset = float(item.get('start_offset_seconds', 0.0))
-            if start_offset >= actual_clip_duration:
-                log_callback(f"  -> 🚨 चेतावनी: AI द्वारा दिया गया स्टार्ट ऑफसेट ({start_offset}s) क्लिप की वास्तविक लंबाई ({actual_clip_duration:.2f}s) से अधिक है। ऑफसेट को 0 पर रीसेट किया जा रहा है।", 91)
-                start_offset = 0.0
-            is_last_clip = (i == len(self.timeline) - 1)
-            overlap = 0 if is_last_clip else self.TRANSITION_DURATION
-            duration = (float(item['end']) - float(item['start'])) + overlap
-            if duration <= 0: continue
-            output_clip_path = os.path.join(self.temp_dir, f"prepared_{i:03d}.mp4")
-            command = [
-                'ffmpeg', '-y', '-ss', str(start_offset), '-i', input_clip_path, '-t', str(duration),
-                '-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', 'ultrafast', '-an', '-threads', '1', output_clip_path
-            ]
-            self._run_ffmpeg_command(command)
-            prepared_clips.append(output_clip_path)
-        log_callback("-> Stage 2/3: क्लिप्स को ट्रांजीशन के साथ जोड़ा जा रहा है...", 94)
-        if not prepared_clips: raise Exception("कोई भी क्लिप सफलतापूर्वक तैयार नहीं हो सकी।")
-        if len(prepared_clips) == 1:
-            shutil.copy(prepared_clips[0], self.output_path)
-            transitioned_video_path = self.output_path
-        else:
-            current_video = prepared_clips[0]
-            for i in range(len(prepared_clips) - 1):
-                next_video = prepared_clips[i+1]
-                output_path = os.path.join(self.temp_dir, f"transition_{i:03d}.mp4")
-                total_transitions = len(prepared_clips) - 1
-                progress = 94 + int((i / total_transitions) * 4) if total_transitions > 0 else 94
-                log_callback(f"  -> ट्रांजीशन बनाया जा रहा है: क्लिप {i+1} और {i+2}", progress)
-                ffprobe_command = ['ffprobe', '-v', 'error', '-show_entries', 'format=duration', '-of', 'default=noprint_wrappers=1:nokey=1', current_video]
-                duration_proc = self._run_ffmpeg_command(ffprobe_command)
-                transition_offset = float(duration_proc.stdout.strip()) - self.TRANSITION_DURATION
-                command = [
-                    'ffmpeg', '-y', '-i', current_video, '-i', next_video,
-                    '-filter_complex', f"[0:v][1:v]xfade=transition=fade:duration={self.TRANSITION_DURATION}:offset={transition_offset},format=yuv420p",
-                    '-c:v', 'libx264', '-preset', 'ultrafast', output_path
-                ]
-                self._run_ffmpeg_command(command)
-                current_video = output_path
-            transitioned_video_path = current_video
-        log_callback("-> Stage 3/3: फाइनल वीडियो में ऑडियो जोड़ा जा रहा है...", 98)
-        audio_input = [] if self.mute_audio else ['-i', self.narration_audio]
-        audio_map = ['-an'] if self.mute_audio else ['-map', '0:v:0', '-map', '1:a:0']
-        command = [
-            'ffmpeg', '-y', '-i', transitioned_video_path,
-        ] + audio_input + [
-            '-c:v', 'copy',
-        ] + audio_map + [
-            '-c:a', 'aac', '-shortest', self.output_path
-        ]
-        self._run_ffmpeg_command(command)
-# ==============================================================================
-# 3. AI इंजन का मुख्य वर्कर
-# ==============================================================================
-def run_ai_engine_worker(task_id, script_text, script_file_path, orientation, max_clip_length, mute_final_video):
-    log = lambda message, progress: update_task_log(task_id, message, progress)
-    temp_dir = os.path.join(UPLOAD_FOLDER, task_id)
-    try:
-        log("Step 0: API Keys की पुष्टि...", 2)
-        gemini_keys, pexels_keys, pixabay_keys, groq_keys = load_api_keys("Gemini_Key"), load_api_keys("Pexels_Key"), load_api_keys("Pixabay_Key"), load_api_keys("Groq_Key")
-        if not all([gemini_keys, pexels_keys, pixabay_keys, groq_keys]): raise Exception("API Key Error: Missing one or more required keys.")
-        gemini = GeminiTeam(api_keys=gemini_keys); log("-> सभी जरूरी API कीज मौजूद हैं।", 5)
-        log("Step 1: स्क्रिप्ट तैयार की जा रही है...", 8)
-        os.makedirs(temp_dir, exist_ok=True); narration_audio_path = ""
-        if script_file_path:
-            narration_audio_path = script_file_path; log("-> ऑडियो फ़ाइल प्राप्त हुई।", 12)
-        else:
-            cleaned_script_for_tts = re.sub(r'\[.*?\]|\(.*?\)', '', script_text)
-            full_script_text_for_tts = cleaned_script_for_tts.strip()
-            narration_audio_path = os.path.join(temp_dir, "narration.mp3")
-            gTTS(full_script_text_for_tts, lang='hi').save(narration_audio_path)
-            log(f"-> TTS ke liye saaf script bheji gayi: '{full_script_text_for_tts}'", 12)
-            log("-> टेक्स्ट से ऑडियो सफलतापूर्वक बनाया गया।", 12)
-        log("Step 2: ऑडियो का सटीक विश्लेषण (Groq)...", 15)
-        groq_api = GroqAPI(api_keys=groq_keys); word_timestamps = groq_api.transcribe_audio(narration_audio_path)
-        if not word_timestamps: raise Exception("Transcription failed or returned no words.")
-        log("-> Smart Pause Detector: ऑडियो में लंबी chuppi खोजी जा रही है...", 20)
-        timestamps_with_pauses = []
-        pause_threshold = 1.5
-        pause_count = 0
-        if word_timestamps:
-            timestamps_with_pauses.append(word_timestamps[0])
-            for i in range(len(word_timestamps) - 1):
-                current_word_end = float(word_timestamps[i]['end'])
-                next_word_start = float(word_timestamps[i+1]['start'])
-                gap = next_word_start - current_word_end
-                if gap > pause_threshold:
-                    pause_event = {'word': '[PAUSE]', 'start': current_word_end, 'end': next_word_start}
-                    timestamps_with_pauses.append(pause_event)
-                    pause_count += 1
-                timestamps_with_pauses.append(word_timestamps[i+1])
-        if pause_count > 0:
-            log(f"-> Pause Detector ne सफलतापूर्वक {pause_count} pauses jode. Ab AI inka creative istemaal karega.", 22)
-        else:
-            log("-> Pause Detector ko koi lamba pause nahi mila. Sab theek hai.", 22)
-        full_script_text = " ".join([word['word'] for word in timestamps_with_pauses]); log(f"-> पूर्ण स्क्रिप्ट (pauses ke saath): '{full_script_text}'", 25)
-        log("Step 3: Contextual वीडियो खोजे जा रहे हैं (Smart Search)...", 30)
-        scenes_from_gemini = gemini.extract_keywords(full_script_text)
-        pexels = PexelsAPI(api_keys=pexels_keys); pixabay = PixabayAPI(api_keys=pixabay_keys)
-        for i, scene in enumerate(scenes_from_gemini):
-            scene['downloaded_path'] = None; primary_query = scene.get('primary_query'); fallback_query = scene.get('fallback_query')
-            log(f"-> Scene {i+1} ('{scene['scene_description'][:20]}...') के लिए वीडियो खोजा जा रहा है...", 30 + i * 5)
-            filename = f"scene_{i+1}_{secure_filename(primary_query)[:20]}.mp4"; download_path = os.path.join(temp_dir, filename)
-            log(f"  -> प्राथमिक कोशिश (Primary): '{primary_query}'...", 30 + i * 5)
-            for attempt in range(2):
-                path = pexels.search_and_download(primary_query, download_path, orientation, search_page=attempt + 1)
-                if path: scene['downloaded_path'] = path; break
-                path = pixabay.search_and_download(primary_query, download_path, orientation, max_clip_length, search_index=attempt)
-                if path: scene['downloaded_path'] = path; break
-            if not scene.get('downloaded_path'):
-                log(f"  -> प्राथमिक कोशिश विफल। फ़ॉलबैक कोशिश (Fallback): '{fallback_query}'...", 30 + i * 5)
-                for attempt in range(2):
-                    path = pexels.search_and_download(fallback_query, download_path, orientation, search_page=attempt + 1)
-                    if path: scene['downloaded_path'] = path; break
-                    path = pixabay.search_and_download(fallback_query, download_path, orientation, max_clip_length, search_index=attempt)
-                    if path: scene['downloaded_path'] = path; break
-            if scene['downloaded_path']: log(f"-> Scene {i+1} के लिए वीडियो सफलतापूर्वक डाउनलोड हुआ: {os.path.basename(scene['downloaded_path'])}", 30 + i * 5)
-            else: log(f"🚨 चेतावनी: Scene {i+1} के लिए कोई भी वीडियो नहीं मिला (Primary और Fallback दोनों विफल)।", 30 + i * 5)
-        successful_scenes = [scene for scene in scenes_from_gemini if scene.get('downloaded_path')]
-        if not successful_scenes: raise Exception("Could not download any videos for the given script.")
-        log(f"-> {len(successful_scenes)} वीडियो क्लिप्स सफलतापूर्वक डाउनलोड हुए।", 60)
-        log("Step 4: मास्टर टाइमलाइन और इंटेलिजेंट क्लिप ट्रिमिंग की जा रही है...", 75)
-        final_timeline = gemini.create_master_timeline(timestamps_with_pauses, successful_scenes); log(f"-> मास्टर टाइमलाइन AI से प्राप्त हुई।", 85)
-        log("-> मास्टर टाइमलाइन को सत्यापित और डी-डुप्लिकेट किया जा रहा है...", 86)
-        validated_timeline = []
-        used_clips = set()
-        for clip in final_timeline:
-            path_value = clip.get('matched_clip')
-            actual_path = None
-            if isinstance(path_value, str):
-                actual_path = path_value
-            elif isinstance(path_value, dict):
-                actual_path = path_value.get('downloaded_path')
-            if actual_path and isinstance(actual_path, str) and os.path.exists(actual_path) and actual_path not in used_clips:
-                clip['matched_clip'] = actual_path
-                validated_timeline.append(clip)
-                used_clips.add(actual_path)
-            else:
-                log(f"🚨 चेतावनी: टाइमलाइन में एक अमान्य या डुप्लिकेट क्लिप को अनदेखा किया जा रहा है: {os.path.basename(actual_path or 'Invalid Path')}", 87)
-        if not validated_timeline:
-            raise Exception("Timeline verification failed. No valid, unique clips found on disk.")
-        log("-> टाइमलाइन में गैप्स की जाँच और उन्हें ठीक किया जा रहा है...", 88)
-        final_gapless_timeline = []; total_duration = word_timestamps[-1]['end'] if word_timestamps else 0
-        validated_timeline.sort(key=lambda x: float(x['start']))
-        for i, clip in enumerate(validated_timeline):
-            if i < len(validated_timeline) - 1:
-                current_clip_end = float(clip['end']); next_clip_start = float(validated_timeline[i+1]['start'])
-                if current_clip_end < next_clip_start: log(f"  -> Gap मिला: क्लिप {i+1} को {current_clip_end} से {next_clip_start} तक बढ़ाया जा रहा है।", 88); clip['end'] = next_clip_start
-            elif i == len(validated_timeline) - 1:
-                last_clip_end = float(clip['end'])
-                if last_clip_end < total_duration: log(f"  -> अंतिम क्लिप को ऑडियो के अंत तक बढ़ाया जा रहा है: {last_clip_end} से {total_duration}", 88); clip['end'] = total_duration
-            final_gapless_timeline.append(clip)
-        log(f"-> गैप-फिलिंग सफल। {len(final_gapless_timeline)} क्लिप्स की एक सहज टाइमलाइन तैयार है।", 89)
-        log("Step 5: फाइनल वीडियो को रेंडर किया जा रहा है (Cinematic Transitions)...", 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)
-        assembler = VideoAssembler(final_gapless_timeline, narration_audio_path, output_path, width, height, mute_final_video, temp_dir)
-        assembler.assemble_video(log)
-        log("-> अंतिम विस्तृत रिपोर्ट बनाई जा रही है...", 99)
-        try:
-            report_data = { "full_transcribed_script": full_script_text, "groq_word_timestamps": word_timestamps, "timestamps_with_pauses_added": timestamps_with_pauses, "gemini_scene_analysis_and_downloads": successful_scenes, "gemini_raw_timeline": final_timeline, "processed_gapless_timeline": final_gapless_timeline, }
-            report_file_path = os.path.join(OUTPUT_FOLDER, f'{task_id}_report.json')
-            with open(report_file_path, 'w', encoding='utf-8') as f: json.dump(report_data, f, ensure_ascii=False, indent=4)
-            log(f"-> विस्तृत रिपोर्ट सफलतापूर्वक '{report_file_path}' में सहेजी गई।", 99)
-        except Exception as e: log(f"🚨 चेतावनी: विस्तृत रिपोर्ट सहेजने में विफल: {e}", 99)
-        update_task_final_status(task_id, 'complete', output_filename=output_filename)
-    except Exception as e:
-        import traceback; traceback.print_exc()
-        update_task_final_status(task_id, 'error', error_message=str(e))
-    finally:
-        if os.path.exists(temp_dir):
-            try:
-                shutil.rmtree(temp_dir)
-                log(f"-> Temporary files aur folder '{temp_dir}' ko saaf kar diya gaya hai.", 100)
-            except Exception as e: print(f"Cleanup Error: {e}")
-# ==============================================================================
-# 4. AI Script Generation Function
-# ==============================================================================
-def generate_script_with_ai(topic, video_length):
-    print(f"-> AI स्क्रिप्ट जेनरेटर शुरू हुआ: Topic='{topic}', Length='{video_length}'")
-    try:
-        gemini_keys = load_api_keys("Gemini_Key")
-        if not gemini_keys: raise Exception("Gemini API key not found for script generation.")
-        gemini_agent = GeminiTeam(api_keys=gemini_keys)
-        script = gemini_agent.generate_script(topic, video_length)
-        return script
-    except Exception as e:
-        raise e