Update app.py

app.py

@@ -23,7 +23,7 @@ gemini_key_cycler = itertools.cycle(GEMINI_API_KEYS)
 
 DEFAULT_BYTEZ_MODEL = "ali-vilab/text-to-video-ms-1.7b"
 
-# ---------- MODEL HUNTER FUNCTIONS (No changes needed here) ----------
+# ---------- MODEL HUNTER FUNCTIONS ----------
 def find_best_groq_model(api_key):
     try:
         print("🤖 Hunting for the best Groq model...")
@@ -69,7 +69,7 @@ job_queue = queue.Queue()
 generated_clips_dict = {}
 clips_lock = threading.Lock()
 
-# ---------- HELPER FUNCTIONS (Including the fixed generate_clip) ----------
+# ---------- HELPER FUNCTIONS ----------
 def set_progress(log_message=None, **kwargs):
     global progress
     with threading.Lock():
@@ -81,7 +81,6 @@ def get_progress_copy():
     with threading.Lock(): return progress.copy()
 
 def get_prompt_from_gemini(image_data, user_text, mime_type, api_key):
-    # This function is correct, no changes needed
     print(f"🧠 Contacting Gemini (Creative Director) using key ...{api_key[-4:]}")
     try:
         encoded_image = base64.b64encode(image_data).decode('utf-8')
@@ -104,7 +103,6 @@ def get_prompt_from_gemini(image_data, user_text, mime_type, api_key):
     except Exception as e: return None, f"An unexpected error occurred with Gemini: {e}"
 
 def generate_visual_blueprint_with_groq(user_prompt, api_key, model_name):
-    # This function is correct, no changes needed
     print("🎨 Contacting Groq (Quality Enhancer)...")
     try:
         client = Groq(api_key=api_key)
@@ -115,16 +113,20 @@ def generate_visual_blueprint_with_groq(user_prompt, api_key, model_name):
         return visual_blueprint, None
     except Exception as e: return None, f"Groq API Error: {e}"
 
+# हमने यहाँ से distill_prompt_for_short_video फंक्शन को हटा दिया है।
+
 def generate_clip(prompt, idx, api_key, bytez_model):
-    # This is the "bulletproof" version that fixes the ValueError
     from bytez import Bytez
     sdk = Bytez(api_key)
     model = sdk.model(bytez_model)
+    
     out = None
     err = None
+    
     try:
         result = model.run(prompt)
         print(f"DEBUG: model.run() returned a '{type(result)}'. Full result: {result}")
+
         if isinstance(result, tuple) and len(result) >= 2:
             out = result[0]
             err = result[1]
@@ -134,11 +136,14 @@ def generate_clip(prompt, idx, api_key, bytez_model):
         else:
             out = result
             err = None
+
     except Exception as e:
         print(f"🛑 CRITICAL ERROR during model.run() call: {e}")
         return None, str(e)
+
     if err:
         return None, f"Model Error (Key ...{api_key[-4:]}): {err}"
+        
     filename = f"clip_{idx}_{uuid.uuid4().hex}.mp4"
     filepath = os.path.join(OUTPUT_FOLDER, filename)
     try:
@@ -152,10 +157,10 @@ def generate_clip(prompt, idx, api_key, bytez_model):
             return None, f"Unexpected or empty output from model. Output type: {type(out)}"
     except Exception as e:
         return None, f"Failed to save or download the generated clip: {e}"
+        
     return filepath, None
 
 def process_and_merge_clips(clip_files):
-    # This function is correct, no changes needed
     if not clip_files: return None
     list_file = os.path.join(OUTPUT_FOLDER, f"clips_{uuid.uuid4().hex}.txt")
     with open(list_file, "w") as f:
@@ -176,7 +181,6 @@ def process_and_merge_clips(clip_files):
     except Exception as e: print(f"⚠️ Cinematic processing failed: {e}. Falling back to raw video."); return raw_merge_path
 
 def worker(api_key):
-    # This function is correct, no changes needed
     while True:
         try:
             prompt, idx, num_clips_in_job, bytez_model = job_queue.get()
@@ -190,7 +194,6 @@ def worker(api_key):
         finally: job_queue.task_done()
 
 def generate_video_job(prompt, num_clips, bytez_model):
-    # This function is correct, no changes needed
     temp_clip_paths = []
     try:
         with clips_lock: generated_clips_dict.clear()
@@ -217,14 +220,13 @@ def generate_video_job(prompt, num_clips, bytez_model):
         for clip in temp_clip_paths:
             if os.path.exists(clip): os.remove(clip)
 
-# ---------- FLASK ROUTES (With the critical fix) ----------
+# ---------- FLASK ROUTES ----------
 @app.route("/", methods=["GET"])
 def home():
     return render_template("index.html")
 
 @app.route("/start", methods=["POST"])
 def start():
-    # This is the simplified version without the Prompt Distiller
     set_progress(live_log=[])
     if get_progress_copy().get("active", False): return jsonify({"error": "A video is already being generated. Please wait."}), 429
     user_prompt = request.form.get("prompt", "").strip()
@@ -258,8 +260,13 @@ def start():
     if err:
         set_progress(status="error", error=err, active=False, log_message=f"🛑 Groq Enhancer Failure: {err}"); return jsonify({"error": err}), 500
     set_progress(log_message=f"✨ Enhanced Blueprint: \"{visual_blueprint[:80]}...\"")
+
+    ### --- यह हिस्सा बदला गया है --- ###
+    # हमने यहाँ से "Prompt Distiller" को हटा दिया है।
+    # अब हम विस्तृत प्रॉम्प्ट को सीधे उपयोग करेंगे।
     
     negative_keywords = "blurry, deformed, ugly, bad anatomy, watermark, noise, grain, low quality, distortion, glitch, pixelated, artifacts"
+    # अब हम `visual_blueprint` का सीधा उपयोग कर रहे हैं।
     final_prompt = f"{visual_blueprint}, {negative_keywords}"
     
     print(f"🚀 Final Prompt for Bytez (Model: {bytez_model}): {final_prompt}")
@@ -276,9 +283,6 @@ def serve_output_file(filename):
     if ".." in filename or filename.startswith("/"): abort(400)
     return send_from_directory(OUTPUT_FOLDER, filename)
 
-# /// --- यह PWA के लिए महत्वपूर्ण हिस्सा है --- ///
-# यह सुनिश्चित करता है कि सर्वर manifest, service worker, और सभी आइकन फाइलों को परोस सकता है।
-
 @app.route('/manifest.json')
 def serve_manifest():
     return send_from_directory('static', 'manifest.json')
@@ -287,13 +291,6 @@ def serve_manifest():
 def serve_sw():
     return send_from_directory('static', 'service-worker.js')
 
-# /// --- यह वह "Missing Piece" है जो आइकन की समस्या को ठीक करेगा --- ///
-@app.route('/static/<path:filename>')
-def serve_static_files(filename):
-    return send_from_directory('static', filename)
-
-# /// ---------------------------------------------------------------- ///
-
 # ---------- RUN ----------
 print(f"Starting {len(API_KEYS)} worker threads for this process...")
 for api_key in API_KEYS: