import secrets

from fastapi import APIRouter, HTTPException, Depends
from pydantic import BaseModel
from app.services.auth import get_user_id
from app.services.supabase import get_supabase

router = APIRouter()


class ShareRequest(BaseModel):
    job_id: str


@router.get("/{token}")
async def get_shared_result(token: str):
    supabase = get_supabase()
    result = supabase.table("jobs").select("*").eq("share_token", token).execute()
    if not result.data:
        raise HTTPException(status_code=404, detail="Shared result not found")
    job = result.data[0]

    # Hydrate the full context from Storage if it was offloaded (mirrors jobs.py).
    # Without this the shared page receives only the minimal creation payload.
    if job.get("storage_url") and not (job.get("context_json") or {}).get("blast"):
        from app.services.artifact_storage import download_json
        results = download_json(job["storage_url"])
        if results:
            job["context_json"] = results
            job["results"] = results

    return job


@router.post("")
async def create_share_link(req: ShareRequest, user_id: str | None = Depends(get_user_id)):
    supabase = get_supabase()
    job = supabase.table("jobs").select("id, user_id, share_token").eq("id", req.job_id).execute()
    if not job.data:
        raise HTTPException(status_code=404, detail="Job not found")
    owner = job.data[0]["user_id"]
    # Anonymous/guest jobs (user_id NULL) are shareable by anyone with the job id;
    # owned jobs require the matching signed-in user.
    if owner and owner != user_id:
        raise HTTPException(status_code=403, detail="Not your job")
    if job.data[0].get("share_token"):
        token = job.data[0]["share_token"]
    else:
        token = secrets.token_urlsafe(16)
        supabase.table("jobs").update({"share_token": token}).eq("id", req.job_id).execute()
    return {"token": token, "url": f"/shared/{token}"}