import mimetypes
import os
import time
import uuid
from contextlib import ExitStack
from pathlib import Path

import requests

BASE_URL = os.environ.get("BASE_URL", "https://ic.xshow.live").rstrip("/")
MODEL = os.environ.get("MODEL", "head-swap")
session = requests.Session()
session.cookies.set("ic_session", os.environ["IC_SESSION"])


def checked(response):
    if not response.ok:
        raise RuntimeError(f"HTTP {response.status_code}: {response.text[:1000]}")
    return response


with ExitStack() as stack:
    files = []
    for filename in ("target.png", "head-reference.png"):
        handle = stack.enter_context(open(filename, "rb"))
        files.append(("image", (Path(filename).name, handle, mimetypes.guess_type(filename)[0] or "image/png")))
    created = checked(session.post(
        f"{BASE_URL}/api/proxy/v1/images/edits/tasks",
        headers={"X-IC-Operation-ID": str(uuid.uuid4())},
        data={"model": MODEL, "prompt": "自然替换完整头部，保持目标身体、服装、姿势和背景"},
        files=files,
        timeout=300,
    )).json()

task_id = created.get("id") or (created.get("data") or {}).get("id")
if not task_id:
    raise RuntimeError(f"创建响应缺少任务 ID: {created}")

deadline = time.time() + 6 * 60 * 60
while time.time() < deadline:
    state = checked(session.post(f"{BASE_URL}/api/proxy/v1/images/tasks/{task_id}", timeout=60)).json()
    status = str(state.get("status") or (state.get("data") or {}).get("status") or "pending").lower()
    print("status:", status)
    if status == "completed":
        result = checked(session.get(
            f"{BASE_URL}/api/proxy/v1/images/tasks/{task_id}/content",
            params={"index": 0},
            timeout=600,
        ))
        Path("head-swap-result.png").write_bytes(result.content)
        break
    if status in {"failed", "cancelled", "canceled", "expired"}:
        raise RuntimeError(f"任务失败: {state}")
    time.sleep(3)
else:
    raise TimeoutError(f"任务 {task_id} 超时")