Update licensing_client.py

licensing_client.py

@@ -1,619 +1,420 @@
 # =========================================================
-# MODULE: run_app.py
-# SYSTEM: ADVANCED RESOURCE & CONCURRENCY WORKSPACE CONTROL
-# FIX: REALTIME TERMINAL LOG PIPELINE & DISCONNECT MONITOR
+# MODULE: licensing_client.py
+# SYSTEM: ADVANCED RESOURCE & CONCURRENCY THREAD MANAGER
+# FIX: DYNAMIC FILE-BASED TRANSACTION SHARING FOR MULTI-WORKERS
 # AUTHOR: Abu Alone © 2026
 # =========================================================
 
 import os
-import sys
+import json
 import time
-import shutil
-import logging
+import signal
+import requests
 import subprocess
-from uuid import uuid4
+from datetime import datetime
 from loguru import logger
-from fastapi import FastAPI, Request, Form, HTTPException, BackgroundTasks
-from fastapi.responses import HTMLResponse, JSONResponse
-from fastapi.staticfiles import StaticFiles
-from fastapi.middleware.cors import CORSMiddleware
 
-# Import các logic cốt lõi tạo video (Giữ nguyên vẹn 100% cấu trúc của ông)
-from app.config import config
-from app.models.schema import VideoParams, VideoAspect, VideoConcatMode 
-from app.services import voice
-from app.services import task as tm
-from app.utils import utils
+# Cấu hình đường dẫn lưu trữ và thông tin Server cổng thanh toán dịch vụ
+STORAGE_FILE = "Hugging AbuAlone09/AI-Video-Engine-storage"
+# File trạng thái phân luồng dùng chung giữa toàn bộ các Worker tiến trình để số nhảy thực tế từng giây
+THREAD_STATUS_FILE = "Hugging AbuAlone09/AI-Video-Engine-threads"
 
-# Đồng bộ hóa chặt chẽ với module quản lý luồng bảo mật
-import licensing_client
+SERVER_URL = os.getenv("LICENSIFY_SERVER_URL", "https://abualone09-my-licensify-server.hf.space").strip()
+SECRET_API_KEY = os.getenv("SECRET_API_KEY", "YOUR_SECRET_API_KEY_HERE").strip()
 
-app = FastAPI(title="AI Video Engine Commercial")
+# Khởi tạo thư mục và tệp cấu trúc lưu trữ
+os.makedirs(os.path.dirname(STORAGE_FILE), exist_ok=True)
 
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    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()
-CF_ID = os.getenv("CF_ACCOUNT_ID", "").strip()
-
-if PEXELS_KEY:
-    config.app["pexels_api_keys"] = [PEXELS_KEY]
-if CF_TOKEN and CF_ID:
-    config.app["llm_provider"] = "cloudflare"
-    config.app["cloudflare_account_id"] = CF_ID
-    config.app["cloudflare_api_key"] = CF_TOKEN
-    config.app["cloudflare_model_name"] = "@cf/meta/llama-3-8b-instruct"
+def _init_system_files():
+    if not os.path.exists(STORAGE_FILE):
+        with open(STORAGE_FILE, "w", encoding="utf-8") as f:
+            json.dump({"keys": {}, "free_devices": {}}, f, indent=4)
+            
+    # Khởi tạo pool 6 luồng thực tế vào file dùng chung nếu chưa có
+    if not os.path.exists(THREAD_STATUS_FILE):
+        initial_pool = {str(i): {"status": "idle", "key": None, "type": None, "pid": None, "device": None, "start_time": 0} for i in range(1, 7)}
+        with open(THREAD_STATUS_FILE, "w", encoding="utf-8") as f:
+            json.dump(initial_pool, f, indent=4)
 
-OUTPUT_DIR = utils.storage_dir("videos", True)
-if os.path.exists(OUTPUT_DIR):
-    app.mount("/static_videos", StaticFiles(directory=OUTPUT_DIR), name="static_videos")
+_init_system_files()
 
-def get_voice_list():
-    path = os.path.join(os.path.dirname(__file__), "voice-list.txt")
-    if os.path.exists(path):
-        try:
-            with open(path, "r", encoding="utf-8") as f:
-                voices = [line.split("Name:")[-1].strip() for line in f if "Name:" in line]
-                if voices: return voices
-        except Exception as e:
-            logger.error(f"Error reading voice list: {e}")
-    return ["en-US-AvaNeural", "vi-VN-HoaiMyNeural"]
+# =========================================================
+# THÀNH PHẦN CORE: ĐỒNG BỘ THỜI GIAN THỰC ĐA TIẾN TRÌNH (FILE-BASED MONITOR)
+# =========================================================
 
-# --- API CẬP NHẬT TRẠNG THÁI LUỒNG THỜI GIAN THỰC ĐỒNG BỘ MỖI GIÂY ---
-@app.get("/api/system-status")
-async def get_system_status(key: str = "", request: Request = None):
-    device_id = request.client.host if request else "MOBILE_DEFAULT_NODE"
+def _load_threads_state() -> dict:
+    """Đọc trực tiếp trạng thái luồng từ tệp dùng chung để tránh lệch số giữa các API worker"""
     try:
-        thread_data = licensing_client.get_thread_status_json()
-        active_str = thread_data["busy_channels"]
-        
-        is_valid, key_info = licensing_client.verify_and_get_license_info(key.strip(), device_id)
-        
-        if is_valid:
-            return {
-                "thread_string": active_str,
-                "key_info": {
-                    "status": "success",
-                    "type": key_info.get("tier", "FREE").lower(),
-                    "username": key_info.get("username", "N/A"), # Trả thêm trường tên người dùng
-                    "tx_id": key_info.get("tx_name", "N/A"),
-                    "amount": key_info.get("amount", "N/A"),
-                    "issued_date": key_info.get("tx_date", "N/A"),
-                    "expiry_date": key_info.get("expiry", "N/A"),
-                    "days_left": key_info.get("days_left", 0),
-                    "show_test_panel": key_info.get("show_test_panel", False)
-                }
-            }
-        else:
-            return {
-                "thread_string": active_str,
-                "key_info": { "status": "failed", "type": "free", "show_test_panel": False }
-            }
+        if os.path.exists(THREAD_STATUS_FILE):
+            with open(THREAD_STATUS_FILE, "r", encoding="utf-8") as f:
+                return json.load(f)
     except Exception:
-        return { "thread_string": "0/6", "key_info": { "status": "failed", "type": "free", "show_test_panel": False } }
+        pass
+    return {str(i): {"status": "idle", "key": None, "type": None, "pid": None, "device": None, "start_time": 0} for i in range(1, 7)}
 
-# --- API CHUYÊN TRÁCH XỬ LÝ NÚT BẤM VALIDATE TOKEN ---
-@app.post("/api/validate-key")
-async def validate_user_key(request: Request):
+def _save_threads_state(state: dict):
+    """Ghi trạng thái luồng xuống tệp khóa ngay lập tức để đồng bộ hóa"""
     try:
-        data = await request.json()
-        token = data.get("key", "").strip()
-    except Exception:
-        return JSONResponse(status_code=400, content={"status": "error", "message": "Invalid raw payload structure."})
-        
-    device_id = request.client.host if request else "MOBILE_DEFAULT_NODE"
-    
-    if not token:
-        return JSONResponse(status_code=400, content={"status": "error", "message": "Access token cannot be empty!"})
-        
-    is_valid, key_info = licensing_client.verify_and_get_license_info(token, device_id)
-    
-    if not is_valid:
-        return JSONResponse(
-            status_code=401, 
-            content={
-                "status": "error", 
-                "message": "Authentication Failed: Invalid or expired security token."
-            }
-        )
-        
-    return {
-        "status": "success",
-        "message": "Credentials verification payload synchronized.",
-        "type": key_info.get("tier", "FREE").lower(),
-        "username": key_info.get("username", "N/A"),
-        "tx_id": key_info.get("tx_name", "N/A"),
-        "amount": key_info.get("amount", "N/A"),
-        "issued_date": key_info.get("tx_date", "N/A"),
-        "expiry_date": key_info.get("expiry", "N/A"),
-        "days_left": key_info.get("days_left", 0)
-    }
+        with open(THREAD_STATUS_FILE, "w", encoding="utf-8") as f:
+            json.dump(state, f, indent=4)
+    except Exception as e:
+        logger.error(f"Failed to write thread state cluster: {e}")
+
+def get_active_threads_count() -> int:
+    """Quét sạch tiến trình chết rớt mạng rồi tính tổng số luồng thực tế đang bận render"""
+    clean_dead_or_zombie_threads()
+    state = _load_threads_state()
+    return sum(1 for t in state.values() if t["status"] == "rendering")
+
+def clean_dead_or_zombie_threads():
+    """Kiểm tra PID hệ thống Linux để giải phóng luồng ngay lập tức nếu người dùng đóng tab, rớt mạng, F5"""
+    state = _load_threads_state()
+    changed = False
     
-# --- 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)}
+    for slot_id, thread in state.items():
+        if thread["status"] == "rendering":
+            pid = thread.get("pid")
+            if pid:
+                try:
+                    # Gửi tín hiệu 0 để kiểm tra xem tiến trình tạo video đó còn sống thực tế không
+                    os.kill(pid, 0)
+                except (ProcessLookupError, PermissionError):
+                    # Tiến trình đã chết (người dùng hủy tab hoặc crash giữa chừng) -> Trả luồng về idle lập tức
+                    logger.warning(f"🧹 Clean-up monitor detected dead PID {pid} on Slot {slot_id}. Reverting to idle.")
+                    state[slot_id] = {"status": "idle", "key": None, "type": None, "pid": None, "device": None, "start_time": 0}
+                    changed = True
+                    
+    if changed:
+        _save_threads_state(state)
 
-# --- 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}
+# =========================================================
+# CORE 1: XỬ LÝ ĐỌC / GHI & XÁC THỰC API KEY TỪ XA TỚI SERVER
+# =========================================================
 
-# --- 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:
-        released = licensing_client.force_abort_user_session(token, device_id)
-        if released:
-            return {"status": "success", "msg": "Task rendering forcefully terminated."}
-        return {"status": "error", "msg": "No active tasks found for this session."}
-    except Exception as e:
-        return {"status": "error", "msg": str(e)}
+def _load_storage():
+    with open(STORAGE_FILE, "r", encoding="utf-8") as f:
+        return json.load(f)
 
-# --- 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):
-    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)
+def _save_storage(data):
+    with open(STORAGE_FILE, "w", encoding="utf-8") as f:
+        json.dump(data, f, indent=4)
 
-# --- 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),
-    selected_voice: str = Form("en-US-AvaNeural"),
-    enable_subtitles: bool = Form(True),
-    enable_bgm: bool = Form(True),
-    license_key: str = Form("")
-):
-    if not video_script.strip():
-        return JSONResponse(status_code=400, content={"status": "error", "msg": "Please enter your script before generating!"})
-    
-    token = license_key.strip()
-    device_id = request.client.host if request.client else "MOBILE_NODE_2026"
-    
-    is_key_valid, key_info = licensing_client.verify_and_get_license_info(token, device_id)
-    is_vip_key = (key_info.get("tier") in ["VIP", "ADMIN"]) if is_key_valid else False
-    bypass_limits = key_info.get("bypass_limits", False)
+def clean_expired_keys():
+    data = _load_storage()
+    now_ts = time.time()
+    changed = False
     
-    if not bypass_limits:
-        allowed, limit_res = licensing_client.check_generation_limits(token, device_id, is_vip_key)
-        if not allowed:
-            return JSONResponse(status_code=400, content={"status": "error", "msg": limit_res})
+    for k, info in list(data["keys"].items()):
+        if now_ts > info.get("expiry_timestamp", 0):
+            del data["keys"][k]
+            changed = True
+            logger.warning(f"Key {k} expired and has been automatically purged from storage.")
             
-    success_alloc, slot_or_err = licensing_client.allocate_render_thread(token, device_id, is_vip_key)
-    if not success_alloc:
-        return JSONResponse(status_code=400, content={"status": "error", "msg": slot_or_err})
-        
-    allocated_slot = slot_or_err
-    current_pid = os.getpid()
-    licensing_client.register_process_to_slot(allocated_slot, token, device_id, is_vip_key, current_pid)
-    
-    background_tasks.add_task(monitor_disconnect_stream, request, token, device_id, allocated_slot)
+    today_str = datetime.now().strftime("%Y-%m-%d")
+    for dev, info in list(data["free_devices"].items()):
+        if info.get("last_date") != today_str:
+            info["daily_batches"] = 0
+            info["last_date"] = today_str
+            changed = True
+            
+    if changed:
+        _save_storage(data)
+
+def verify_and_get_license_info(key_input: str, device_id: str) -> tuple:
+    clean_expired_keys()
+    token = key_input.strip()
     
-    task_id = f"TASK-{int(time.time())}"
-    GLOBAL_TERMINAL_LOGS[task_id] = [f"🚀 System allocated Thread Slot #{allocated_slot} for PID {current_pid}"]
+    admin_secret = os.getenv("ADMIN_KEY", "ADMIN_ABUALONE_2026").strip()
+    vip_secret = os.getenv("VIP_KEY", "VIP_PROMO_2026").strip()
     
-    params = VideoParams(
-        video_subject=video_script[:30].strip(),
-        video_script=video_script,
-        video_aspect=VideoAspect.portrait, 
-        video_concat_mode=VideoConcatMode.random,
-        video_clip_duration=clip_duration,
-        voice_name=selected_voice,
-        voice_rate=voice_rate,
-        subtitle_enabled=enable_subtitles,
-        bgm_type="random" if enable_bgm else "",
-        n_threads=2
-    )
+    if token == admin_secret:
+        return True, {
+            "tier": "ADMIN", 
+            "tx_name": "System Master Administrator", 
+            "amount": "$0.00 (Root Privilege)",
+            "tx_date": datetime.now().strftime("%Y-%m-%d"), 
+            "expiry": "Permanent Access", 
+            "days_left": 9999,
+            "msg": "📋 SYSTEM STATUS: Admin Master Active. Full hardware diagnostic test layer unlocked.",
+            "show_test_panel": True,
+            "remove_watermark": True,
+            "bypass_limits": True
+        }
+        
+    if token == vip_secret:
+        return True, {
+            "tier": "VIP", 
+            "tx_name": "VIP Promotional Access", 
+            "amount": "$0.00 (Promo Tier)",
+            "tx_date": datetime.now().strftime("%Y-%m-%d"), 
+            "expiry": "2026-12-31", 
+            "days_left": 200,
+            "msg": "👑 VIP STATUS: Promo Key Verified. Watermarks and daily rendering limits removed.",
+            "show_test_panel": False,
+            "remove_watermark": True,
+            "bypass_limits": True
+        }
+        
+    data = _load_storage()
     
-    try:
-        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...")
+    if token in data["keys"]:
+        info = data["keys"][token]
+        days_left = int((info["expiry_timestamp"] - time.time()) / 86400)
+        return True, {
+            "tier": "VIP", "tx_name": info["tx_name"], "amount": info["amount"],
+            "tx_date": info["tx_date"], "expiry": info["expiry"], "days_left": max(0, days_left),
+            "msg": f"👑 VIP ACTIVE | User: {info['tx_name']} | {max(0, days_left)} days remaining.",
+            "show_test_panel": False,
+            "remove_watermark": True,
+            "bypass_limits": False
+        }
         
-        result = tm.start(task_id=task_id, params=params)
+    try:
+        headers = {"X-API-Key": SECRET_API_KEY, "Content-Type": "application/json"}
+        payload = {"key": token, "hwid": device_id}
+        response = requests.post(f"{SERVER_URL}/api/verify-key", json=payload, headers=headers, timeout=10)
         
-        if result and "videos" in result and len(result["videos"]) > 0:
-            video_path = result["videos"][0]
-            if os.path.exists(video_path):
-                filename = os.path.basename(video_path)
-                
-                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)
-                    
-                    drawtext_filter = "drawtext=text='Hugging/AbuAlone09':x='mod(t*35,w)':y='mod(t*15,h)':fontsize=24:fontcolor=white@0.35"
-                    ffmpeg_cmd = [
-                        'ffmpeg', '-y', 
-                        '-i', video_path,
-                        '-vf', drawtext_filter,
-                        '-c:v', 'libx264', 
-                        '-pix_fmt', 'yuv420p', 
-                        '-c:a', 'copy', 
-                        watermarked_path
-                    ]
-                    
-                    subprocess.run(ffmpeg_cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
-                    if os.path.exists(watermarked_path):
-                        filename = wm_filename
+        if response.status_code == 200:
+            res_data = response.json()
+            if res_data.get("status") == "success":
+                tx_info = res_data.get("data", {})
+                expiry_str = tx_info.get("expiry_date")
+                expiry_ts = time.mktime(time.strptime(expiry_str, "%Y-%m-%d"))
                 
-                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.")
+                data["keys"][token] = {
+                    "tx_name": tx_info.get("buyer_name", "Anonymous User"),
+                    "amount": tx_info.get("amount_paid", "$2.99"),
+                    "tx_date": tx_info.get("payment_date", datetime.now().strftime("%Y-%m-%d")),
+                    "expiry": expiry_str,
+                    "expiry_timestamp": expiry_ts
+                }
+                _save_storage(data)
                 
-                return {
-                    "status": "success", 
-                    "task_id": task_id,
-                    "video_url": f"/static_videos/{filename}"
+                days_left = int((expiry_ts - time.time()) / 86400)
+                return True, {
+                    "tier": "VIP", "tx_name": tx_info.get("buyer_name"), "amount": tx_info.get("amount_paid"),
+                    "tx_date": tx_info.get("payment_date"), "expiry": expiry_str, "days_left": max(0, days_left),
+                    "msg": f"👑 VIP KEY VERIFIED | Owner: {tx_info.get('buyer_name')} | Expiry: {expiry_str}.",
+                    "show_test_panel": False,
+                    "remove_watermark": True,
+                    "bypass_limits": False
                 }
-        
-        return JSONResponse(status_code=500, content={"status": "error", "task_id": task_id, "msg": "Render completed but output file not found."})
-        
+        return False, {"msg": "❌ Invalid Access Key or communication failure with payment gateway!", "show_test_panel": False, "remove_watermark": False, "tier": "FREE"}
     except Exception as e:
-        logger.error(f"Execution 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)
-        background_tasks.add_task(lambda: [time.sleep(30), GLOBAL_TERMINAL_LOGS.pop(task_id, None)])
-        
-# --- 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()])
-    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 | 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>
-        @import url('https://fonts.googleapis.com/css2?family=Plus+Jakarta+Sans:wght@400;500;600;700;800&display=swap');
-        body {{ font-family: 'Plus Jakarta Sans', sans-serif; background-color: #f1f5f9; background-image: radial-gradient(#cbd5e1 0.5px, transparent 0.5px); background-size: 24px 24px; }}
-        .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); }}
-    </style>
-</head>
-<body class="p-4 md:p-12 lg:p-16">
-    <div class="max-w-7xl mx-auto">
-        
-        <header class="text-center mb-12">
-            <div class="inline-block bg-indigo-100 text-indigo-700 px-4 py-1.5 rounded-full text-xs font-bold uppercase tracking-widest mb-6">Commercial Video System</div>
-            <h1 class="text-5xl md:text-7xl font-black text-slate-900 tracking-tighter italic">AI VIDEO ENGINE</h1>
-            <p class="text-slate-500 mt-4 font-semibold uppercase tracking-[0.3em] text-sm md:text-base">v3.1.0 Production Workshop</p>
-        </header>
-
-        <div class="glass-card rounded-[2.5rem] p-6 md:p-8 shadow-sm border border-slate-200 mb-8 text-sm text-slate-600 space-y-4 leading-relaxed">
-            <p>🌟 <strong>Automated Production Suite:</strong> An instant AI video factory engineered tailored for Shorts, TikTok, and Reels. It automatically aggregates premium background clips from Pexels, structures high-fidelity AI narrative voices, blends automated audio beds, and burns fully aligned dynamic subtitles—all rendered seamlessly with just 1-click.</p>
-            <p>💡 <strong>Our Mission:</strong> We are committed to engineering a highly accessible, low-cost automated content rendering architecture to help creators maximize efficiency while cutting software expenses down to zero.</p>
-            <p>⚠️ <strong>Hosting Environment Notice:</strong> This platform is deployed on a <strong>Free Tier Shared Server (2 vCPU, 16GB RAM, Shared Core Containers)</strong> on Hugging Face. Due to unallocated shared hardware limits, video generation cycles can be quite lengthy. To actively protect our instance against memory crashes or sudden cluster restarts, strict thread concurrency thresholds have been applied. We sincerely apologize for any processing delays and thank you for your understanding.</p>
-            <p>☕ <strong>Empower the Infrastructure:</strong> To expand our server performance capacities, maintain uninterrupted deployment pipelines, and invest in our upcoming formal platform architectures, your contributions are crucial! Our commercial premium license matrix remains incredibly cost-effective, with the highest tier priced under the cost of two standard cups of coffee. Secure your high-speed access keys here:</p>
-            <div class="bg-indigo-50 border border-indigo-100 p-4 rounded-2xl flex flex-col sm:flex-row items-center justify-between gap-4">
-                <span class="text-xs font-bold text-indigo-900 uppercase tracking-wide"><i class="fa-solid fa-cookie-bite mr-2"></i> Free tier users: 3 video creations/day (1 video per batch, 3-hour cooldown) with mobile fluid watermark.</span>
-                <a href="https://huggingface.co/spaces/AbuAlone09/my-licensify-server" target="_blank" class="bg-indigo-600 text-white font-extrabold px-6 py-2.5 rounded-xl text-xs uppercase tracking-wider hover:bg-indigo-700 transition-all shadow-md shrink-0 text-center w-full sm:w-auto">
-                    <i class="fa-solid fa-key mr-1.5"></i> Purchase Premium Keys
-                </a>
-            </div>
-        </div>
-
-        <div class="glass-card rounded-[3rem] p-6 md:p-10 shadow-xl border border-slate-200 mb-8">
-            <div class="flex items-center gap-4 mb-6">
-                <div class="w-12 h-12 bg-indigo-600 rounded-2xl flex items-center justify-center text-white shadow-lg shadow-indigo-200">
-                    <i class="fa-solid fa-lock text-xl"></i>
-                </div>
-                <div>
-                    <h3 class="text-xl font-extrabold text-slate-800">🔐 System Authentication</h3>
-                    <p class="text-slate-400 text-sm">Validate credentials to remove output limitations and stream watermarks</p>
-                </div>
-            </div>
-            <div class="flex flex-col md:flex-row gap-4">
-                <input type="password" id="licenseKey" placeholder="Enter valid access token or security key..." class="flex-grow bg-slate-50 border-2 border-slate-100 rounded-2xl px-5 py-4 outline-none focus:border-indigo-500 focus:bg-white transition-all font-mono text-base shadow-inner">
-                <button onclick="triggerVerificationHandshake()" class="bg-slate-900 text-white px-8 py-4 rounded-2xl font-black text-base hover:bg-black transition-all shadow-md active:scale-95 shrink-0">
-                    VALIDATE TOKEN
-                </button>
-            </div>
-            
-            <div id="keyDetails" class="text-xs font-bold text-amber-600 uppercase tracking-wider mt-4 flex flex-col gap-2 p-3 bg-amber-50/40 rounded-xl border border-amber-100">
-                <div><i class="fa-solid fa-circle-exclamation mr-1"></i> Status: Unverified (Free Tier System Active)</div>
-            </div>
-            
-            <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="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>
-
-        <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">
-                        <i class="fa-solid fa-sliders text-xl"></i>
-                    </div>
-                    <div>
-                        <h3 class="text-xl font-extrabold text-slate-800">⚙️ Video Configuration</h3>
-                        <p class="text-slate-400 text-sm">Tune rendering parameters and narration variables</p>
-                    </div>
-                </div>
-
-                <form id="videoForm" onsubmit="handleRenderCycle(event)" class="space-y-6">
-                    <div>
-                        <div class="flex justify-between items-center mb-2">
-                            <label class="text-xs font-black text-slate-500 uppercase tracking-wider">Video Narrative Script</label>
-                            <span id="charCounter" class="text-xs font-bold text-indigo-600 bg-indigo-50 px-2 py-0.5 rounded-md">0 / 1500 Chars</span>
-                        </div>
-                        <textarea name="video_script" id="video_script" rows="6" placeholder="Write or paste your script framework..." class="w-full bg-slate-50 border-2 border-slate-100 rounded-2xl px-5 py-4 outline-none focus:border-blue-500 focus:bg-white transition-all font-sans text-base shadow-inner leading-relaxed" required></textarea>
-                    </div>
-
-                    <div class="grid grid-cols-1 md:grid-cols-2 gap-4">
-                        <div>
-                            <label class="text-xs font-black text-slate-500 uppercase tracking-wider block mb-2">Clip Duration Selection</label>
-                            <select name="clip_duration" 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="5">5 Seconds</option>
-                                <option value="6">6 Seconds</option>
-                                <option value="7">7 Seconds</option>
-                                <option value="8">8 Seconds</option>
-                                <option value="9">9 Seconds</option>
-                                <option value="10" selected>10 Seconds (Default)</option>
-                            </select>
-                        </div>
-                        <div>
-                            <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="1.0" selected>1.0x (Normal)</option>
-                                <option value="1.5">1.5x</option>
-                                <option value="2.0">2.0x</option>
-                            </select>
-                        </div>
-                    </div>
-
-                    <div>
-                        <label class="text-xs font-black text-slate-500 uppercase tracking-wider block mb-2">Azure TTS Voice Engine</label>
-                        <select name="selected_voice" class="w-full bg-slate-50 border-2 border-slate-100 rounded-xl px-4 py-3.5 text-slate-800 focus:border-blue-500 outline-none font-medium">
-                            {voices_options}
-                        </select>
-                    </div>
-
-                    <div class="flex flex-wrap gap-6 bg-slate-50/80 p-4 rounded-2xl border border-slate-100">
-                        <label class="flex items-center gap-2 cursor-pointer select-none">
-                            <input type="checkbox" name="enable_subtitles" checked id="subCheck" class="w-4 h-4 rounded text-blue-600 focus:ring-blue-500 border-slate-300">
-                            <span class="text-sm font-bold text-slate-700">Render Subtitles</span>
-                        </label>
-                        <label class="flex items-center gap-2 cursor-pointer select-none">
-                            <input type="checkbox" name="enable_bgm" checked id="bgmCheck" class="w-4 h-4 rounded text-blue-600 focus:ring-blue-500 border-slate-300">
-                            <span class="text-sm font-bold text-slate-700">Background Music (BGM)</span>
-                        </label>
-                    </div>
+        return False, {"msg": f"⚠️ Connection error to Licensify Server! Info: {str(e)}", "show_test_panel": False, "remove_watermark": False, "tier": "FREE"}
 
-                    <button type="submit" id="mainSubmitBtn" class="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">
-                        <i class="fa-solid fa-play" id="btnIcon"></i> <span id="btnText">GENERATE PRODUCTION VIDEO</span>
-                    </button>
-                </form>
-            </div>
-
-            <div class="lg:col-span-5 glass-card rounded-[3rem] p-6 md:p-10 shadow-xl border border-slate-200 h-full flex flex-col justify-between">
-                <div class="flex items-center gap-4 mb-6">
-                    <div class="w-12 h-12 bg-emerald-600 rounded-2xl flex items-center justify-center text-white shadow-lg shadow-emerald-200">
-                        <i class="fa-solid fa-film text-xl"></i>
-                    </div>
-                    <div>
-                        <h3 class="text-xl font-extrabold text-slate-800">🎬 Studio Result</h3>
-                        <p class="text-slate-400 text-sm">Realtime output file delivery node</p>
-                    </div>
-                </div>
+# =========================================================
+# CORE 2: CƠ CHẾ PHÂN LUỒNG THÔNG MINH (5 VIP - 1 FREE, ÉP TRỤC XUẤT)
+# =========================================================
 
-                <div id="loadingBox" class="loading-box rounded-2xl p-5 mb-4 text-xs md:text-sm leading-relaxed font-medium">
-                    <div class="flex items-center gap-2 text-red-700 font-bold mb-2">
-                        <i class="fa-solid fa-circle-notch animate-spin text-base"></i> <span>Processing Pipeline Active...</span>
-                    </div>
-                    Video generation process initiated. This pipeline takes a minimum of 5 minutes to fully compile assets, render frames, and synchronize data nodes. Please be patient and maintain connection. You can actively track the technical generation progress logs inside your Hugging Face Space log panel.
-                </div>
+def get_thread_status_json():
+    """Hàm này nhảy số thực tế từng giây dựa trên trạng thái tệp tập trung"""
+    clean_dead_or_zombie_threads()
+    state = _load_threads_state()
+    busy_count = sum(1 for t in state.values() if t["status"] == "rendering")
+    vip_count = sum(1 for t in state.values() if t["type"] == "VIP")
+    free_count = sum(1 for t in state.values() if t["type"] == "FREE")
+    return {
+        "busy_channels": f"{busy_count}/6",
+        "vip_active": vip_count,
+        "free_active": free_count,
+        "pool": state
+    }
 
-                <div class="video-wrapper my-auto py-2">
-                    <video id="videoPlayer" controls playsinline poster="https://images.unsplash.com/photo-1618005182384-a83a8bd57fbe?q=80&w=400">
-                        <source id="videoSource" src="" type="video/mp4">
-                    </video>
-                </div>
-            </div>
-        </div>
+def allocate_render_thread(key_input: str, device_id: str, is_vip: bool) -> tuple:
+    """Cơ chế phân luồng nghiêm ngặt: 5 luồng VIP độc quyền (1-5), luồng 6 cho Free. 
+    Nếu VIP vào mà hệ thống full, Free ở luồng VIP hoặc luồng 6 sẽ bị ngắt tiến trình lập tức và không tính lượt."""
+    clean_dead_or_zombie_threads()
+    state = _load_threads_state()
+    token = key_input.strip()
+    
+    # Chặn đứng trường hợp chính Key đó hoặc Device đó đang render trùng lặp
+    for slot_id, thread in state.items():
+        if thread["status"] == "rendering":
+            if is_vip and thread["key"] == token:
+                return False, "❌ This VIP Key is already running a rendering process! Multi-thread allocation denied."
+            if not is_vip and thread["device"] == device_id:
+                return False, "❌ Your device is currently rendering a video. Please wait until it completes!"
+
+    target_slot = None
+    
+    if is_vip:
+        # 1. Tìm vị trí trống trong 5 slot đầu của VIP
+        for i in range(1, 6):
+            if state[str(i)]["status"] == "idle":
+                target_slot = str(i)
+                break
+                
+        # 2. Nếu 5 slot đầu bận, kiểm tra slot 6 của Free xem có trống không
+        if not target_slot and state["6"]["status"] == "idle":
+            target_slot = "6"
+            
+        # 3. [CƠ CHẾ ÉP TRỤC XUẤT]: Nếu toàn bộ máy chủ 6 luồng đều bận, tìm luồng nào của USER THƯỜNG đang chạy ké để ngắt khẩn cấp
+        if not target_slot:
+            for i in ["6", "1", "2", "3", "4", "5"]:
+                if state[i]["type"] == "FREE":
+                    free_pid = state[i]["pid"]
+                    logger.warning(f"👑 VIP Eviction Triggered: Terminating Free PID {free_pid} at Slot {i} to liberate resources.")
+                    try:
+                        if free_pid:
+                            os.kill(free_pid, signal.SIGKILL) # Đánh sập tiến trình tạo video của User thường lập tức
+                    except ProcessLookupError:
+                        pass
+                    
+                    target_slot = i
+                    state[i] = {"status": "idle", "key": None, "type": None, "pid": None, "device": None, "start_time": 0}
+                    break
+    else:
+        # Đối với User thường: Kiểm tra slot 6 độc quyền trước
+        if state["6"]["status"] == "idle":
+            target_slot = "6"
+        else:
+            # Nếu slot 6 bận, cho phép dùng ké các slot VIP từ 1-5 nếu chúng đang rảnh hoàn toàn
+            for i in range(1, 6):
+                if state[str(i)]["status"] == "idle":
+                    target_slot = str(i)
+                    break
+
+    if not target_slot:
+        return False, "⚠️ All rendering channels are currently full. Please try again in a few moments!"
+
+    return True, int(target_slot)
+
+def register_process_to_slot(slot: int, key_input: str, device_id: str, is_vip: bool, pid: int):
+    state = _load_threads_state()
+    state[str(slot)] = {
+        "status": "rendering",
+        "key": key_input.strip() if is_vip else None,
+        "type": "VIP" if is_vip else "FREE",
+        "pid": pid,
+        "device": device_id,
+        "start_time": time.time()
+    }
+    _save_threads_state(state)
 
-        <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 compiled directly via mobile system.</p>
-            </div>
-        </footer>
-    </div>
+def release_thread_slot(slot: int):
+    state = _load_threads_state()
+    slot_str = str(slot)
+    if slot_str in state:
+        state[slot_str] = {"status": "idle", "key": None, "type": None, "pid": None, "device": None, "start_time": 0}
+    _save_threads_state(state)
 
-    <script>
-        let currentTaskId = null;
-        let runningStateActive = false;
+# =========================================================
+# CORE 3: GIÁM SÁT HẠN MỨC CHẶN CHẶT CHẼ
+# =========================================================
 
-        const txtInput = document.getElementById("video_script");
-        const lblCounter = document.getElementById("charCounter");
+def check_generation_limits(key_input: str, device_id: str, is_vip: bool) -> tuple:
+    clean_expired_keys()
+    data = _load_storage()
+    today_str = datetime.now().strftime("%Y-%m-%d")
+    now_ts = time.time()
+    
+    if is_vip:
+        if key_input not in data["keys"]:
+            return False, "License error: Key missing from verified list."
         
-        function enforceInputConstraints() {{
-            if(txtInput.value.length > 1500) {{
-                txtInput.value = txtInput.value.substring(0, 1500);
-            }}
-            lblCounter.innerText = txtInput.value.length + " / 1500 Chars";
-        }}
-        txtInput.addEventListener("input", enforceInputConstraints);
-        txtInput.addEventListener("paste", () => {{ setTimeout(enforceInputConstraints, 10); }});
-
-        // --- HÀM XỬ LÝ KHI NGƯỜI DÙNG NHẤN NÚT KiỂM TRA KEY ---
-        async function triggerVerificationHandshake() {{
-            const currentToken = document.getElementById("licenseKey").value.trim();
-            const keyDetails = document.getElementById("keyDetails");
-            const adminPanel = document.getElementById("adminTestPanel");
+        vip_data = data["keys"][key_input]
+        if vip_data.get("last_date_used") != today_str:
+            vip_data["last_date_used"] = today_str
+            vip_data["daily_batches"] = 0 
+            vip_data["videos_this_batch"] = 0 
+            vip_data["cooldown_until"] = 0
             
-            if (!currentToken) {{
-                keyDetails.innerHTML = '<div class="text-amber-600 font-bold"><i class="fa-solid fa-triangle-exclamation mr-1"></i> Vui lòng nhập key trước khi kiểm tra!</div>';
-                return;
-            }}
+        if now_ts < vip_data.get("cooldown_until", 0):
+            wait_min = int((vip_data["cooldown_until"] - now_ts) / 60)
+            return False, f"⏱️ Cooldown active! Please return in {wait_min} minutes."
             
-            keyDetails.innerHTML = '<div class="text-blue-600 font-bold"><i class="fa-solid fa-spinner animate-spin mr-1"></i> Đang kết nối tới máy chủ xác thực...</div>';
+        if vip_data.get("daily_batches", 0) >= 5:
+            return False, "❌ You have exhausted your daily limit of 5 batches. Please return tomorrow!"
             
-            try {{
-                const response = await fetch("/api/validate-key", {{
-                    method: "POST",
-                    headers: {{ "Content-Type": "application/json" }},
-                    body: JSON.stringify({{ key: currentToken }})
-                }});
-                
-                const data = await response.json();
-                
-                if (!response.ok) {{
-                    throw new Error(data.message || "Key không tồn tại hoặc không hợp lệ.");
-                }}
-                
-                // TRƯỜNG HỢP KEY ĐÚNG -> HIỆN TICK XANH (✅) VÀ BẢNG THÔNG TIN CHI TIẾT
-                if(data.type === "admin") {{
-                    adminPanel.classList.remove("hidden");
-                }} 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 class="col-span-1 sm:col-span-2 text-emerald-700 font-black text-sm mb-1">
-                            <i class="fa-solid fa-circle-check text-base mr-1"></i> [✅ KEY HỢP LỆ] KÍCH HOẠT THÀNH CÔNG
-                        </div>
-                        <div>🆔 Mã giao dịch (TxID): \${{data.tx_id}}</div>
-                        <div>👤 Tên người dùng: \${{data.username}}</div>
-                        <div>💰 Số tiền đã thanh toán: \${{data.amount}}</div>
-                        <div>📅 Ngày cấp key: \${{data.issued_date}}</div>
-                        <div class="col-span-1 sm:col-span-2 text-indigo-700 mt-1">⏳ Hạn sử dụng: \${{data.expiry_date}} (\${{data.days_left}} ngày còn lại)</div>
-                    </div>
-                `;
-                
-            }} catch (error) {{
-                // TRƯỜNG HỢP KEY SAI -> HIỆN X ĐỎ (❌) KHÔNG HỢP LỆ
-                adminPanel.classList.add("hidden");
-                keyDetails.innerHTML = '<div class="text-rose-600 font-black text-sm"><i class="fa-solid fa-circle-xmark text-base mr-1"></i> [❌ KEY KHÔNG HỢP LỆ] Key không tồn tại, sai định dạng hoặc đã hết hạn!</div>';
-            }}
-        }}
-
-        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.trim();
-            
-            if(runningStateActive) {{
-                if(confirm("Do you want to terminate the active rendering cycle immediately?")) {{
-                    const fData = new FormData();
-                    fData.append("license_key", currentToken);
-                    await fetch("/api/cancel-task", {{ method: "POST", body: fData }});
-                    revertUiLayoutToNormal();
-                }}
-                return;
-            }}
-
-            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";
+        remaining_batches = 5 - vip_data.get("daily_batches", 0)
+        return True, {"status_str": f"VIP Usage: Batch {vip_data.get('daily_batches', 0)}/5"}
+    else:
+        if device_id not in data["free_devices"]:
+            data["free_devices"][device_id] = {
+                "last_date": today_str,
+                "daily_batches": 0,
+                "cooldown_until": 0
+            }
             
-            currentTaskId = "TASK-" + Math.floor(Date.now() / 1000);
+        free_data = data["free_devices"][device_id]
+        if free_data.get("last_date") != today_str:
+            free_data["last_date"] = today_str
+            free_data["daily_batches"] = 0
+            free_data["cooldown_until"] = 0
             
-            const formObj = document.getElementById("videoForm");
-            const payloadData = new FormData(formObj);
-            payloadData.append("license_key", currentToken);
+        if now_ts < free_data.get("cooldown_until", 0):
+            wait_hours = int((free_data["cooldown_until"] - now_ts) / 3600)
+            return False, f"⏱️ Free Tier Cooldown: Please wait {wait_hours + 1} hours before generating again, or upgrade to VIP Premium!"
             
-            const player = document.getElementById("videoPlayer");
-            const source = document.getElementById("videoSource");
-            player.pause();
+        if free_data.get("daily_batches", 0) >= 3:
+            return False, "❌ Free Tier Exhausted! Maximum 3 daily videos reached."
             
-            try {{
-                const response = await fetch("/api/generate", {{ method: "POST", body: payloadData }});
-                const serverResponse = await response.json();
-                
-                if(serverResponse.status === "success") {{
-                    source.src = serverResponse.video_url;
-                    player.src = serverResponse.video_url;
-                    player.load();
-                    setTimeout(() => {{ player.play().catch(e => {{}}); }}, 200);
-                    alert("✅ Video processing completed successfully!");
-                }} else {{
-                    alert("❌ " + serverResponse.msg);
-                }}
-            }} catch(err) {{
-                alert("❌ Connection lost or pipeline aborted.");
-            }} finally {{
-                revertUiLayoutToNormal();
-            }}
-        }}
+        return True, {"status_str": f"Free Tier Usage: {free_data.get('daily_batches', 0)}/3 Videos"}
 
-        function revertUiLayoutToNormal() {{
-            runningStateActive = false;
-            document.getElementById("loadingBox").style.display = "none";
-            
-            const targetBtn = document.getElementById("mainSubmitBtn");
-            const iconObj = document.getElementById("btnIcon");
-            const textObj = document.getElementById("btnText");
-            
-            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";
-        }}
-    </script>
-</body>
-</html>
-"""
-    return HTMLResponse(content=html_content)
+def commit_generation_success(key_input: str, device_id: str, is_vip: bool):
+    """Chỉ cắn trừ lượt tạo thực tế khi video đã render thành công hoàn toàn ra file output"""
+    data = _load_storage()
+    now_ts = time.time()
+    
+    if is_vip:
+        if key_input in data["keys"]:
+            vip_data = data["keys"][key_input]
+            vip_data["videos_this_batch"] = vip_data.get("videos_this_batch", 0) + 1
+            if vip_data["videos_this_batch"] >= 2:
+                vip_data["daily_batches"] = vip_data.get("daily_batches", 0) + 1
+                vip_data["videos_this_batch"] = 0 
+                vip_data["cooldown_until"] = now_ts + 3600
+    else:
+        if device_id in data["free_devices"]:
+            free_data = data["free_devices"][device_id]
+            free_data["daily_batches"] = free_data.get("daily_batches", 0) + 1
+            free_data["cooldown_until"] = now_ts + (3 * 3600)
+        
+    _save_storage(data)
+
+# =========================================================
+# CORE 4: FORCE STOP - KHÔNG TÍNH LƯỢT KHI HỦY HOẶC NÉT MẠNG RỚT
+# =========================================================
+
+def force_abort_user_session(key_input: str, device_id: str) -> bool:
+    """Khi người dùng nhấn nút STOP đỏ hoặc hệ thống quét F5: Hủy tiến trình Linux lập tức,
+    luồng giải phóng hoàn toàn về idle và TUYỆT ĐỐI KHÔNG cắn trừ lượt tạo video của user."""
+    state = _load_threads_state()
+    token = key_input.strip()
+    released = False
+    
+    for slot_id, thread in state.items():
+        if thread["status"] == "rendering":
+            # Đối soát chuẩn xác phiên làm việc dựa trên key (VIP) hoặc IP thiết bị (Free)
+            is_match = (thread["key"] == token) if thread["type"] == "VIP" else (thread["device"] == device_id)
+            if is_match:
+                pid = thread.get("pid")
+                if pid:
+                    try:
+                        logger.warning(f"🛑 Manual Force Abort triggered. Killing Video Engine Process PID {pid} instantly.")
+                        os.kill(pid, signal.SIGKILL)
+                    except ProcessLookupError:
+                        pass
+                
+                state[slot_id] = {"status": "idle", "key": None, "type": None, "pid": None, "device": None, "start_time": 0}
+                released = True
+                
+    if released:
+        _save_threads_state(state)
+    return released
+
+def execute_admin_diagnostic_test() -> str:
+    test_script = "tester.py"
+    if not os.path.exists(test_script):
+        return f"❌ FILE MISSING: Tệp '{test_script}' không tồn tại!"
+    try:
+        result = subprocess.run(["python", test_script], capture_output=True, text=True, timeout=15)
+        if result.returncode == 0:
+            return f"✅ [TESTER REPORT SUCCESS]:\n{result.stdout.strip()}"
+        else:
+            return f"❌ [TESTER REPORT CRASHED WITH EXIT CODE {result.returncode}]:\n{result.stderr.strip()}"
+    except subprocess.TimeoutExpired:
+        return "⚠️ [TESTER TIMEOUT]: Tiến trình kiểm thử vượt ngưỡng 15 giây!"
+    except Exception as e:
+        return f"❌ [SYSTEM CRASH]: Lỗi: {str(e)}"