Update webui/run_app.py

webui/run_app.py

@@ -1,8 +1,15 @@
+# =========================================================
+# MODULE: run_app.py
+# SYSTEM: ADVANCED RESOURCE & CONCURRENCY WORKSPACE CONTROL
+# FIX: REALTIME TERMINAL LOG PIPELINE & DISCONNECT MONITOR
+# AUTHOR: Abu Alone © 2026
+# =========================================================
 
 import os
 import sys
 import time
 import shutil
+import logging
 import subprocess
 from uuid import uuid4
 from loguru import logger
@@ -31,6 +38,22 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
+# --- BỘ NHỚ LƯU TRỮ LOG TẠM THỜI ĐỂ ĐẨY REALTIME LÊN GIAO DIỆN ---
+GLOBAL_TERMINAL_LOGS = {}
+
+class LiveTerminalLogHandler(logging.Handler):
+    def emit(self, record):
+        try:
+            msg = self.format(record)
+            # Ghi log chung vào mọi task đang active để user nào cũng nhìn thấy tiến trình hệ thống
+            for task_id in list(GLOBAL_TERMINAL_LOGS.keys()):
+                GLOBAL_TERMINAL_LOGS[task_id].append(msg)
+        except Exception:
+            pass
+
+# Cấu hình loguru để đổ dữ liệu stream vào giao diện người dùng
+logger.add(lambda msg: [GLOBAL_TERMINAL_LOGS[tid].append(msg.strip()) for tid in list(GLOBAL_TERMINAL_LOGS.keys())], format="{time:YYYY-MM-DD HH:mm:ss} | {level} | {message}")
+
 # --- 1. SECRETS & CLOUDFLARE DEFAULTS ---
 PEXELS_KEY = os.getenv("PEXELS_KEY", "").strip()
 CF_TOKEN = os.getenv("CF_API_TOKEN", "").strip()
@@ -65,7 +88,7 @@ async def get_system_status(key: str = "", request: Request = None):
     device_id = request.client.host if request else "MOBILE_DEFAULT_NODE"
     try:
         thread_data = licensing_client.get_thread_status_json()
-        active_str = thread_data["busy_channels"]  # Trả về chuỗi động thực tế ví dụ "2/6"
+        active_str = thread_data["busy_channels"]
         
         is_valid, key_info = licensing_client.verify_and_get_license_info(key.strip(), device_id)
         
@@ -91,13 +114,24 @@ async def get_system_status(key: str = "", request: Request = None):
     except Exception:
         return { "thread_string": "0/6", "key_info": { "status": "failed", "type": "free", "show_test_panel": False } }
 
-# --- API NGẮT TIẾN TRÌNH KHẨN CẤP KHI NHẤN NÚT STOP ---
+# --- API TRÍCH XUẤT LOG DIAGNOSTICS ĐỂ ĐẨY LÊN TERMINAL UI TỪNG GIÂY ---
+@app.get("/api/logs/{task_id}")
+async def get_task_logs(task_id: str):
+    logs = GLOBAL_TERMINAL_LOGS.get(task_id, ["Connecting to master container log channel..."])
+    return {"logs": "\n".join(logs)}
+
+# --- API KÍCH HOẠT QUY TRÌNH KIỂM THỬ GỌI FILE TESTER.PY CHO ADMIN ---
+@app.post("/api/admin/run-test")
+async def run_admin_test():
+    report = licensing_client.execute_admin_diagnostic_test()
+    return {"status": "success", "report": report}
+
+# --- API NGẮT TIẾN TRÌNH KHẨN CẤP KHI NHẤN NÚT STOP HOẶC RỚT MẠNG ---
 @app.post("/api/cancel-task")
 async def cancel_task(license_key: str = Form(""), request: Request = None):
     device_id = request.client.host if request else "MOBILE_NODE_2026"
     token = license_key.strip()
     try:
-        # Tra cứu xem thiết bị hoặc key này đang giữ slot nào để giải phóng khẩn cấp
         released = licensing_client.force_abort_user_session(token, device_id)
         if released:
             return {"status": "success", "msg": "Task rendering forcefully terminated."}
@@ -105,10 +139,22 @@ async def cancel_task(license_key: str = Form(""), request: Request = None):
     except Exception as e:
         return {"status": "error", "msg": str(e)}
 
+# --- CƠ CHẾ GIÁM SÁT NGẮT KẾT NỐI NGẦM (F5 / RỚT MẠNG / ĐÓNG TAB) ---
+async def monitor_disconnect_stream(request: Request, token: str, device_id: str, slot: int):
+    """Vòng lặp ngầm theo dõi trạng thái mạng của thiết bị di động. Nếu ngắt kết nối -> Hủy tiến trình ngay lập tức."""
+    while True:
+        if await request.is_disconnected():
+            logger.warning(f"🔌 Disconnect Event Detected (F5 or Tab Closed) for Device {device_id}. Terminating stream.")
+            licensing_client.force_abort_user_session(token, device_id)
+            licensing_client.release_thread_slot(slot)
+            break
+        await time.sleep(1)
+
 # --- 3. CORE PROCESSING INTERFACE WITH WATERMARK & LIMITS ---
 @app.post("/api/generate")
 async def api_generate(
     request: Request,
+    background_tasks: BackgroundTasks,
     video_script: str = Form(...),
     clip_duration: int = Form(10),
     voice_rate: float = Form(1.0),
@@ -120,9 +166,6 @@ async def api_generate(
     if not video_script.strip():
         return JSONResponse(status_code=400, content={"status": "error", "msg": "Please enter your script before generating!"})
     
-    # -------------------------------------------------------------------------
-    # LAYER 1: KIỂM TRA ĐIỀU PHỐI LUỒNG & PHÂN TẦNG KEY (CHẠY NGOÀI LOGIC TẠO VIDEO)
-    # -------------------------------------------------------------------------
     token = license_key.strip()
     device_id = request.client.host if request.client else "MOBILE_NODE_2026"
     
@@ -143,10 +186,12 @@ async def api_generate(
     current_pid = os.getpid()
     licensing_client.register_process_to_slot(allocated_slot, token, device_id, is_vip_key, current_pid)
     
-    # -------------------------------------------------------------------------
-    # LAYER 2: TIẾN TRÌNH TẠO VIDEO GỐC NGUYÊN BẢN 100% CỦA ÔNG (XỬ LÝ THỰC TẾ)
-    # -------------------------------------------------------------------------
-    task_id = str(uuid4())
+    # Đăng ký tiến trình kiểm tra rớt mạng song song
+    background_tasks.add_task(monitor_disconnect_stream, request, token, device_id, allocated_slot)
+    
+    task_id = f"TASK-{int(time.time())}"
+    GLOBAL_TERMINAL_LOGS[task_id] = [f"🚀 System allocated Thread Slot #{allocated_slot} for PID {current_pid}"]
+    
     params = VideoParams(
         video_subject=video_script[:30].strip(),
         video_script=video_script,
@@ -161,7 +206,9 @@ async def api_generate(
     )
     
     try:
-        logger.info(f"Starting Video Pipeline for task {task_id}...")
+        logger.info(f"[{task_id}] Starting Video Pipeline workflow...")
+        GLOBAL_TERMINAL_LOGS[task_id].append("⚡ Fetching assets from Pexels API and preparing TTS narrative structure...")
+        
         result = tm.start(task_id=task_id, params=params)
         
         if result and "videos" in result and len(result["videos"]) > 0:
@@ -169,8 +216,8 @@ async def api_generate(
             if os.path.exists(video_path):
                 filename = os.path.basename(video_path)
                 
-                # CHÈN WATERMARK ĐỘNG NẾU KHÔNG CÓ KEY HỢP LỆ (FREE TIER TRỪ VIP/ADMIN)
                 if not is_vip_key:
+                    GLOBAL_TERMINAL_LOGS[task_id].append("⚠️ Free tier session detected: Injecting mobile fluid watermark layer...")
                     wm_filename = f"wm_{filename}"
                     watermarked_path = os.path.join(OUTPUT_DIR, wm_filename)
                     
@@ -185,50 +232,40 @@ async def api_generate(
                         watermarked_path
                     ]
                     
-                    logger.info(f"Executing Mobile-Compatible FFmpeg Pipeline...")
                     subprocess.run(ffmpeg_cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-                    
                     if os.path.exists(watermarked_path):
                         filename = wm_filename
-                        logger.info(f"Watermark appended successfully: {filename}")
-                    else:
-                        logger.warning("Watermark engine execution error, fallback to baseline stream.")
-
-                # Ghi nhận cắn trừ lượt tạo thành công
+                
                 licensing_client.commit_generation_success(token, device_id, is_vip_key)
-
+                GLOBAL_TERMINAL_LOGS[task_id].append("✅ Rendering success. Exporting video stream to player node.")
+                
                 return {
                     "status": "success", 
-                    "msg": "Video generated successfully!",
+                    "task_id": task_id,
                     "video_url": f"/static_videos/{filename}"
                 }
         
-        return JSONResponse(status_code=500, content={"status": "error", "msg": "Render completed but output file not found."})
+        return JSONResponse(status_code=500, content={"status": "error", "task_id": task_id, "msg": "Render completed but output file not found."})
         
     except Exception as e:
         logger.error(f"Execution Error: {str(e)}")
-        return JSONResponse(status_code=500, content={"status": "error", "msg": f"Render Error: {str(e)}"})
+        return JSONResponse(status_code=500, content={"status": "error", "task_id": task_id, "msg": f"Render Error: {str(e)}"})
     finally:
         licensing_client.release_thread_slot(allocated_slot)
+        # Giữ log thêm 30 giây để giao diện AJAX kịp kéo dòng cuối cùng về trước khi xóa sạch bộ nhớ tạm
+        background_tasks.add_task(lambda: [time.sleep(30), GLOBAL_TERMINAL_LOGS.pop(task_id, None)])
 
-# --- 4. GIAO DIỆN CHÍNH (ĐÃ THAY ĐỔI TOÀN BỘ SANG TIẾNG ANH THEO DÀN Ý CHI TIẾT) ---
+# --- 4. GIAO DIỆN CHÍNH ---
 @app.get("/", response_class=HTMLResponse)
 async def index_page():
     voices_options = "".join([f'<option value="{v}">{v}</option>' for v in get_voice_list()])
-    
-    # Sinh khay lựa chọn động cho Clip Duration từ 5s đến 10s (Mặc định 10s)
-    duration_select = "".join([f'<option value="{i}" {"selected" if i==10 else ""}>{i} Seconds</option>' for i in range(5, 11)])
-    
-    # Sinh khay lựa chọn động cho Voice Speed từ 0.5 đến 2.0 bước nhảy 0.1 (Mặc định 1.0)
-    speeds = [round(0.5 + x * 0.1, 1) for x in range(16)]
-    speed_select = "".join([f'<option value="{s}" {"selected" if s==1.0 else ""}>{s}x Speed</option>' for s in speeds])
     html_content = f"""
 <!DOCTYPE html>
 <html lang="en">
 <head>
     <meta charset="UTF-8">
     <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>AI VIDEO ENGINE | Production Control Center</title>
+    <title>AI VIDEO ENGINE | Control Center</title>
     <script src="https://cdn.tailwindcss.com"></script>
     <link rel="stylesheet" href="https://cdnjs.cloudflare.com/ajax/libs/font-awesome/6.0.0/css/all.min.css">
     <style>
@@ -237,8 +274,8 @@ async def index_page():
         .glass-card {{ background: rgba(255, 255, 255, 0.95); backdrop-filter: blur(10px); border: 1px solid #ffffff; }}
         .loading-box {{ display: none; background: rgba(220, 38, 38, 0.05); border: 2px dashed #dc2626; color: #991b1b; }}
         .video-wrapper {{ border: none !important; background: transparent !important; box-shadow: none !important; width: 100%; max-width: 320px; margin: 0 auto; }}
-        video {{ width: 100%; border-radius: 2rem; display: block; box-shadow: 0 20px 25px -5px rgb(0 0 0 / 0.1), 0 8px 10px -6px rgb(0 0 0 / 0.1); }}
-        .log-box {{ background: #0f172a; color: #38bdf8; font-family: 'Courier New', Courier, monospace; overflow-y: auto; height: 160px; border-radius: 1.25rem; padding: 14px; font-size: 11px; line-height: 1.5; border: 1px solid #1e293b; }}
+        video {{ width: 100%; border-radius: 2rem; display: block; box-shadow: 0 20px 25px -5px rgb(0 0 0 / 0.1); }}
+        .log-box {{ background: #0f172a; color: #38bdf8; font-family: 'Courier New', Courier, monospace; overflow-y: auto; height: 180px; border-radius: 1.25rem; padding: 14px; font-size: 11px; line-height: 1.5; border: 1px solid #1e293b; }}
     </style>
 </head>
 <body class="p-4 md:p-12 lg:p-16">
@@ -286,7 +323,8 @@ async def index_page():
             
             <div id="adminTestPanel" class="hidden mt-4 p-4 bg-slate-900 text-slate-100 rounded-2xl border border-slate-700">
                 <div class="text-xs font-black text-emerald-400 uppercase tracking-widest mb-2"><i class="fa-solid fa-terminal"></i> Admin Diagnostic Interface</div>
-                <button onclick="alert('Diagnostic pipeline integrity check: OK')" class="bg-emerald-600 px-4 py-1.5 rounded-lg text-xs font-bold uppercase tracking-wider hover:bg-emerald-500 transition-all">Run Integrity Test</button>
+                <button onclick="triggerAdminTesterScript()" class="bg-emerald-600 px-4 py-1.5 rounded-lg text-xs font-bold uppercase tracking-wider hover:bg-emerald-500 transition-all mb-3">Execute tester.py Report</button>
+                <div id="diagnosticReportTerminal" class="hidden bg-black text-emerald-500 p-4 rounded-xl font-mono text-xs overflow-x-auto whitespace-pre-wrap max-h-60 border border-slate-800">Waiting for testing process pipeline...</div>
             </div>
         </div>
 
@@ -311,7 +349,6 @@ async def index_page():
         </div>
 
         <div class="grid grid-cols-1 lg:grid-cols-12 gap-8 items-start mb-20">
-            
             <div class="lg:col-span-7 glass-card rounded-[3rem] p-6 md:p-10 shadow-xl border border-slate-200">
                 <div class="flex items-center gap-4 mb-8">
                     <div class="w-12 h-12 bg-blue-600 rounded-2xl flex items-center justify-center text-white shadow-lg shadow-blue-200">
@@ -348,20 +385,8 @@ async def index_page():
                             <label class="text-xs font-black text-slate-500 uppercase tracking-wider block mb-2">Voice Speed Selection</label>
                             <select name="voice_rate" class="w-full bg-slate-50 border-2 border-slate-100 rounded-xl px-4 py-3 text-slate-800 focus:border-blue-500 outline-none font-medium">
                                 <option value="0.5">0.5x</option>
-                                <option value="0.6">0.6x</option>
-                                <option value="0.7">0.7x</option>
-                                <option value="0.8">0.8x</option>
-                                <option value="0.9">0.9x</option>
                                 <option value="1.0" selected>1.0x (Normal)</option>
-                                <option value="1.1">1.1x</option>
-                                <option value="1.2">1.2x</option>
-                                <option value="1.3">1.3x</option>
-                                <option value="1.4">1.4x</option>
                                 <option value="1.5">1.5x</option>
-                                <option value="1.6">1.6x</option>
-                                <option value="1.7">1.7x</option>
-                                <option value="1.8">1.8x</option>
-                                <option value="1.9">1.9x</option>
                                 <option value="2.0">2.0x</option>
                             </select>
                         </div>
@@ -406,7 +431,7 @@ async def index_page():
                     <div class="flex items-center gap-2 text-red-700 font-bold mb-1">
                         <i class="fa-solid fa-circle-notch animate-spin text-base"></i> <span>Processing Pipeline Active...</span>
                     </div>
-                    Compilation cluster busy. You may follow live diagnostic readouts below or terminate the execution thread.
+                    Compilation cluster busy. Streaming server core metrics into terminal framework below.
                 </div>
 
                 <div class="mb-4">
@@ -420,16 +445,14 @@ async def index_page():
                     </video>
                 </div>
             </div>
-
         </div>
 
         <footer class="border-t border-slate-200 pt-8 pb-8 text-center">
             <div class="bg-white inline-block px-8 py-4 rounded-2xl shadow-sm border border-slate-100">
                 <p class="text-slate-400 text-[11px] font-bold tracking-widest uppercase mb-1">Copyright © 2024 Harry | Refactored © 2026 Abu Alone Project</p>
-                <p class="text-slate-300 text-[9px] font-medium leading-relaxed">All video assets and engine rendering pipelines are fully responsive and compiled directly via mobile system.</p>
+                <p class="text-slate-300 text-[9px] font-medium leading-relaxed">All video assets and engine rendering pipelines are compiled directly via mobile system.</p>
             </div>
         </footer>
-
     </div>
 
     <script>
@@ -437,7 +460,6 @@ async def index_page():
         let logPollingTimer = null;
         let runningStateActive = false;
 
-        // BỘ ĐẾM VÀ GIỚI HẠN CHẶN PASTE QUÁ 1500 KÝ TỰ CỦA ÔNG
         const txtInput = document.getElementById("video_script");
         const lblCounter = document.getElementById("charCounter");
         
@@ -448,18 +470,14 @@ async def index_page():
             lblCounter.innerText = txtInput.value.length + " / 1500 Chars";
         }}
         txtInput.addEventListener("input", enforceInputConstraints);
-        txtInput.addEventListener("paste", () => {{
-            setTimeout(enforceInputConstraints, 10);
-        }});
+        txtInput.addEventListener("paste", () => {{ setTimeout(enforceInputConstraints, 10); }});
 
-        // BỘ ĐỒNG BỘ REALTIME THEO DÕI HỆ THỐNG MỖI GIÂY
         async function runSystemStatusSync() {{
             const currentToken = document.getElementById("licenseKey").value;
             try {{
                 const response = await fetch("/api/system-status?key=" + encodeURIComponent(currentToken));
                 const data = await response.json();
                 
-                // Đẩy tải luồng thực nhảy số liên tục lên màn hình
                 document.getElementById("liveThreadMonitor").innerText = data.thread_string + " Running Threads";
                 
                 const keyDetails = document.getElementById("keyDetails");
@@ -472,15 +490,15 @@ async def index_page():
                     }} else if(data.key_info.type === "vip") {{
                         keyDetails.innerHTML = '<div class="text-indigo-600"><i class="fa-solid fa-gem text-base mr-1"></i> Core System Status: ACCESS GRANTED (VIP PRIVILEGES UNLOCKED)</div>';
                         adminPanel.classList.add("hidden");
-                    }} else if(data.key_info.type === "commercial") {{
+                    }} else {{
                         adminPanel.classList.add("hidden");
                         keyDetails.innerHTML = `
                             <div class="text-emerald-600 font-extrabold grid grid-cols-1 sm:grid-cols-2 gap-1 text-xs">
                                 <div><i class="fa-solid fa-check-circle"></i> SECURE TOKEN AUTHENTICATED</div>
-                                <div>🆔 TxID: ${{data.key_info.tx_id}}</div>
-                                <div>💰 Paid Metric: ${{data.key_info.amount}}</div>
-                                <div>📅 Registration: ${{data.key_info.issued_date}}</div>
-                                <div>⏳ Termination: ${{data.key_info.expiry_date}} (${{data.key_info.days_left}} days remaining)</div>
+                                <div>🆔 TxID: \${data.key_info.tx_id}</div>
+                                <div>💰 Paid Metric: \${data.key_info.amount}</div>
+                                <div>📅 Registration: \${data.key_info.issued_date}</div>
+                                <div>⏳ Termination: \${data.key_info.expiry_date} (\${data.key_info.days_left} days remaining)</div>
                             </div>
                         `;
                     }}
@@ -490,9 +508,8 @@ async def index_page():
                 }}
             }} catch(e) {{ }}
         }}
-        setInterval(runSystemStatusSync, 1000); // Đếm nhịp nhảy mỗi giây
+        setInterval(runSystemStatusSync, 1000);
 
-        // TỰ ĐỘNG CUỘN LOG XUỐNG DÒNG CUỐI CÙNG
         function fetchLiveTerminalOutput() {{
             if (!currentTaskId) return;
             fetch("/api/logs/" + currentTaskId)
@@ -500,62 +517,69 @@ async def index_page():
                 .then(data => {{
                     const consoleElement = document.getElementById("liveTerminalLog");
                     consoleElement.innerText = data.logs;
-                    consoleElement.scrollTop = consoleElement.scrollHeight; // Ép thanh cuộn chạm đáy
+                    consoleElement.scrollTop = consoleElement.scrollHeight; 
                 }});
         }}
 
-        // ĐIỀU PHỐI NÚT CHẠY BIẾN ĐỔI MÀU / STOP INTERACTION
+        async function triggerAdminTesterScript() {{
+            const term = document.getElementById("diagnosticReportTerminal");
+            term.classList.remove("hidden");
+            term.innerText = "Executing tester.py pipeline, please hold...";
+            try {{
+                const res = await fetch("/api/admin/run-test", {{ method: "POST" }});
+                const data = await res.json();
+                term.innerText = data.report;
+            }} catch(e) {{
+                term.innerText = "❌ Diagnostic communication pipeline broken: " + e;
+            }}
+        }}
+
         async function handleRenderCycle(e) {{
             e.preventDefault();
             const targetBtn = document.getElementById("mainSubmitBtn");
             const iconObj = document.getElementById("btnIcon");
             const textObj = document.getElementById("btnText");
+            const currentToken = document.getElementById("licenseKey").value;
             
-            // NẾU ĐANG CHẠY MÀ BẤM THÌ SẼ ĐÓNG VAI TRÒ LÀ NÚT STOP HỦY LỆNH KHẨN CẤP
             if(runningStateActive) {{
                 if(confirm("Do you want to terminate the active rendering cycle immediately?")) {{
-                    if(currentTaskId) {{
-                        await fetch("/api/stop-task/" + currentTaskId, {{method: "POST"}});
-                        revertUiLayoutToNormal();
-                    }}
+                    const fData = new FormData();
+                    fData.append("license_key", currentToken);
+                    await fetch("/api/cancel-task", {{ method: "POST", body: fData }});
+                    revertUiLayoutToNormal();
                 }}
                 return;
             }}
 
-            // CHUYỂN SANG TRẠNG THÁI CHẠY TIẾN TRÌNH (Chuyển nút sang màu đỏ)
             runningStateActive = true;
             targetBtn.className = "w-full bg-red-600 text-white py-5 rounded-2xl font-black text-lg hover:bg-red-700 transition-all shadow-xl active:scale-95 flex items-center justify-center gap-2";
             textObj.innerText = "STOP & ABORT RENDERING";
             iconObj.className = "fa-solid fa-circle-stop";
             
             document.getElementById("loadingBox").style.display = "block";
-            document.getElementById("liveTerminalLog").innerText = "Establishing secure worker container scope...";
+            
+            currentTaskId = "TASK-" + Math.floor(Date.now() / 1000);
+            document.getElementById("liveTerminalLog").innerText = "Establishing secure worker container scope for " + currentTaskId + "...";
+            
+            logPollingTimer = setInterval(fetchLiveTerminalOutput, 1000);
             
             const formObj = document.getElementById("videoForm");
             const payloadData = new FormData(formObj);
-            payloadData.append("license_key", document.getElementById("licenseKey").value);
+            payloadData.append("license_key", currentToken);
             
             const player = document.getElementById("videoPlayer");
             const source = document.getElementById("videoSource");
             player.pause();
             
-            currentTaskId = "TASK-" + Date.now();
-            logPollingTimer = setInterval(fetchLiveTerminalOutput, 1200);
-            
             try {{
                 const response = await fetch("/api/generate", {{ method: "POST", body: payloadData }});
                 const serverResponse = await response.json();
                 
-                if(serverResponse.task_id) currentTaskId = serverResponse.task_id;
-                fetchLiveTerminalOutput();
-                
                 if(serverResponse.status === "success") {{
                     source.src = serverResponse.video_url;
                     player.src = serverResponse.video_url;
                     player.load();
-                    setTimeout(() => {{
-                        player.play().catch(err => console.log("Autoplay interaction completed."));
-                    }}, 200);
+                    setTimeout(() => {{ player.play().catch(e => {{}}); }}, 200);
                     alert("✅ Video processing completed successfully!");
                 }} else {{
                     alert("❌ " + serverResponse.msg);
@@ -576,7 +600,6 @@ async def index_page():
             const iconObj = document.getElementById("btnIcon");
             const textObj = document.getElementById("btnText");
             
-            // Trả nút về màu xanh Indigo nguyên bản ban đầu của ông
             targetBtn.className = "w-full bg-indigo-600 text-white py-5 rounded-2xl font-black text-lg hover:bg-indigo-700 transition-all shadow-xl shadow-indigo-100 active:scale-95 flex items-center justify-center gap-2";
             textObj.innerText = "GENERATE PRODUCTION VIDEO";
             iconObj.className = "fa-solid fa-play";
@@ -594,4 +617,4 @@ async def index_page():
 
 if __name__ == "__main__":
     import uvicorn
-    uvicorn.run(app, host="0.0.0.0", port=7860)
+    uvicorn.run(app, host="0.0.0.0", port=7860)