import gradio as gr
from gradio_client import Client, handle_file
import random
import os
from PIL import Image

# ==========================================
# PRIVATE SODA-GEN (SINGLE TARGET WAN 2.2)
# Version: V5.1 (Integer Bugfix & Safe Mode Bypassed)
# ==========================================

TARGET_URL = "https://r3gm-wan2-2-fp8da-aoti-preview-2.hf.space"

GENERATION_TOKENS = [
    # --- OLD TOKENS ---
    "hf_" + "PiRCDDtPcPFMLWkTkVaZmzoleHOunXnLIA", "hf_" + "BHvZXGICstaktSwycmwNmzHGrTNmKxnlRZ",
    "hf_" + "ZdgawyTPzXIpwhnRYIteUKSMsWnEDtGKtM", "hf_" + "nMiFYAFsINxAJWPwiCQlaunmdgmrcxKoaT",
    "hf_" + "PccpUIbTckCiafwErDLkRlsvqhgtfZaBHL", "hf_" + "faGyXBPfBkaHXDMUSJtxEggonhhZbomFIz",
    "hf_" + "SndsPaRWsevDXCgZcSjTUlBYUJqOkSfFmn", "hf_" + "CqobFdUpeVCeuhUaiuXwvdczBUmoUHXRGa",
    "hf_" + "JKCQYUhhHPPkpucegqkNSyureLdXpmeXRF", "hf_" + "tBYfslUwHNiNMufzwAYIlrDVovEWmOQulC",
    "hf_" + "LKLdrdUxyUyKODSUthmqHXqDMfHrQueera", "hf_" + "ivSBboJYQVcifWkCNcOTOnxUQrZOtOglnU",
    "hf_" + "jiSbBMUmAniRpJOmVIlczuqpRjwSeuizLk", "hf_" + "VcXaKQLEawBWZbNrBOSLTjrVtTuSvobhLL",
    "hf_" + "ZrlTPvhDmYqZGGFuIqDDCrQRcWRhYcuyOI", "hf_" + "FCambosUqUQJrThbIveHglnvjoNpOGWBsW",
    "hf_" + "kUyoiWTbZlNfSrdTNaVINuwlNTQseFCfZB", "hf_" + "WGarKlgPBzpJeKxpqirFgnKKAtOFBFomSe",
    "hf_" + "IZwzmRBCALYfvYtmtvTWsIQYvHuRGUiGyr", "hf_" + "NtijfwwAPQRknELkhIWjMQQUUqzgwhIjeu",
    "hf_" + "obVKYRMqECBoLsBWOKyfVWtHlugAhhuaIH", "hf_" + "EsDAvVqRZCbigQrpDFNinlVeijagnAjETW",
    "hf_" + "yuMifxRJoXWKPRGgYFrXHXTGdoKBuCZCUU", "hf_" + "YthKrdEtrmyDbBteZcGzNeoDqGAxzeEinv",
    "hf_" + "JgNjfcunLsOBcZIaOYcFqgcZIZWjbnocJn", "hf_" + "cINBgwvihyKiTpxwDTXjnHTnlQivLCluGJ",
    "hf_" + "jnciPeeWUwQbHNITBRtOgPjnqWkgAqZDhq",
    # --- NEW TOKENS BATCH 1 ---
    "hf_" + "uwTpdbUKmiKUZkpWgsOJyaywRBSPeSHcLY", "hf_" + "ddTsgQvyVXUSRsYrcAioNbGnTsOVugcSpK",
    "hf_" + "BoDGLtNQdSSiIvuveGBiCFJKzEEqQmZTbz", "hf_" + "aKBQewTCodMpeijniAvkcsqoSEhMrbhiKE",
    "hf_" + "hOrZAwkLlabOCjjZVStFoufImunhcjlEhz", "hf_" + "NkfolaYSzHbBLkqkalzvbLJWHxDQfUEwsr",
    "hf_" + "OoFVTidQQHCpKkDBnTsTvPeOogJkVfEWAZ", "hf_" + "plFpieuUJmDJBhyPIdjBmDKKTVNcNpulXJ",
    "hf_" + "AyHpfXRVxcrmiOFUYMLiNAaVtyLwwkdvWJ", "hf_" + "pHNLBEtYhQwfUQJFAxtLcklIaIXyQQkIAt",
    "hf_" + "CpXxqjXPCvnLEyfdlsbgdqXdotkMkzvmBU", "hf_" + "PerSDYxXPlPviQNmACCXyzyIfNBnJgpXst",
    "hf_" + "PKxgUunqjxFjeMUrhgPuHAfUYhrGsFPlBh"
]

CLIENT_CACHE = {}

def get_cached_client(token):
    if token not in CLIENT_CACHE:
        CLIENT_CACHE[token] = Client(TARGET_URL, headers={"Authorization": f"Bearer {token}"})
    return CLIENT_CACHE[token]

def resize_image_for_video(image_path, width=768, height=512):
    try:
        if not image_path or not os.path.exists(image_path): return None
        print(f"🖼️ Resizing image to {width}x{height}...")
        img = Image.open(image_path)
        img = img.resize((int(width), int(height)), Image.LANCZOS)
        img.save(image_path) 
        return image_path
    except Exception as e:
        return image_path 

def generate_wan_video(prompt, input_image, end_image, duration, steps, frame_mult):
    print(f"\n🎬 [WAN 2.2 TARGET] PROMPT: {prompt[:50]}...")
    if not prompt: return None, "❌ Prompt is required."

    safe_img1 = handle_file(resize_image_for_video(input_image)) if input_image else None
    safe_img2 = handle_file(resize_image_for_video(end_image)) if end_image else None

    wan_neg = "色调艳丽, 过曝, 静态, 细节模糊不清, 字幕, 风格, 作品, 画作, 画面, 静止, 整体发灰, 最差质量, 低质量, JPEG压缩残留, 丑陋的, 残缺的, 多余手指, 画不好手部, 畸形, 毁容"

    session_tokens = GENERATION_TOKENS.copy()
    random.shuffle(session_tokens)
    
    final_video = None
    last_error = ""

    for i, token in enumerate(session_tokens):
        try:
            print(f"🚀 Attempt {i+1}/{len(session_tokens)} connecting...")
            client = get_cached_client(token)
            
            # MENGIRIM REQUEST KE API WAN 2.2 DENGAN 16 PARAMETER LENGKAP
            result = client.predict(
                input_image=safe_img1,
                last_image=safe_img2,
                prompt=prompt,
                steps=float(steps),
                negative_prompt=wan_neg,
                duration_seconds=float(duration),
                guidance_scale=1.0,
                guidance_scale_2=1.0,
                seed=float(random.randint(0, 999999)),
                randomize_seed=True,
                quality=6.0,
                scheduler="UniPCMultistep",
                flow_shift=3.0,
                frame_multiplier=int(frame_mult), # 🔥 FIX MUTLAK: UBAH JADI INTEGER
                safe_mode=False, # 🔥 BYPASS FILTER AKTIF!
                video_component=True,
                api_name="/generate_video"
            )
            
            # Return tuple: (generated_video, download_video, seed)
            if isinstance(result, (list, tuple)):
                final_video = result[0]
            else:
                final_video = result
                
            break # Berhasil, keluar dari loop

        except Exception as e:
            last_error = str(e)
            print(f"⚠️ Token {token[:8]} failed: {last_error[:50]}")
            if token in CLIENT_CACHE:
                del CLIENT_CACHE[token]
            continue 

    if final_video: 
        print("✅ SUCCESS: WAN Video generated!")
        return final_video, "✅ Success! Video ready."
    
    return None, f"❌ ALL TOKENS FAILED. Error: {last_error[:50]}"

# --- GRADIO INTERFACE (BACKEND TESTING UI) ---
with gr.Blocks(theme=gr.themes.Monochrome()) as app:
    gr.Markdown("# 🎬 Private WAN 2.2 Node")
    gr.Markdown("*Direct API Link | Safe Mode: Disabled*")
    
    with gr.Row():
        with gr.Column(scale=1):
            p_in = gr.Textbox(label="Prompt", lines=3, placeholder="Describe your cinematic shot...")
            
            with gr.Row():
                img_in = gr.Image(type="filepath", label="Start Image (Optional)")
                img_end_in = gr.Image(type="filepath", label="End Image (Optional)")
            
            with gr.Row():
                d_in = gr.Slider(minimum=1.0, maximum=15.0, step=0.5, value=3.5, label="Duration (s)")
                s_in = gr.Slider(minimum=1.0, maximum=30.0, step=1.0, value=6.0, label="Steps")
                f_mult = gr.Dropdown(choices=['16', '32', '64', '128'], value='16', label="Frame Multiplier")

            btn_gen = gr.Button("🚀 GENERATE RAW", variant="primary")
        
        with gr.Column(scale=1):
            vid_out = gr.Video(label="Output Video")
            txt_out = gr.Textbox(label="System Log", interactive=False)
            
    btn_gen.click(
        fn=generate_wan_video, 
        inputs=[p_in, img_in, img_end_in, d_in, s_in, f_mult], 
        outputs=[vid_out, txt_out], 
        api_name="generate_private"
    )

if __name__ == "__main__":
    app.queue(max_size=10).launch(share=False, server_name="0.0.0.0")