"""Live-camera ALPR scan API: run the recognition engine over live DOT snapshot feeds.

  POST /alpr/scan-live   {camera_ids?, state?, limit, min_conf} -> scan a batch, ingest any plates

Runs synchronously (each camera = one HTTP fetch + one inference pass), so a batch can take

~10-30s. NOTE: public wide-area traffic cams rarely yield readable plates - 0 results is the

normal outcome; recognized plates flow through the standard ingest pipeline as real reads."""

from __future__ import annotations

from fastapi import APIRouter, Depends, HTTPException

from pydantic import BaseModel

from sqlalchemy.orm import Session

from app.api.deps import Perm, get_db, require

from app.models import User

router = APIRouter(tags=["live-alpr"])

MAX_LIMIT = 50

class ScanLiveReq(BaseModel):

    camera_ids: list[str] | None = None

    state: str | None = None

    limit: int = 20

    min_conf: float = 0.5

@router.post("/alpr/scan-live")

def scan_live(req: ScanLiveReq, db: Session = Depends(get_db),

              user: User = Depends(require(Perm.INGEST))):

    """Scan live-feed cameras for plates and ingest anything recognized (synchronous batch)."""

    from app.services.live_alpr_scan import scan_live_cameras

    if req.limit < 1 or req.limit > MAX_LIMIT:

        raise HTTPException(400, f"limit must be between 1 and {MAX_LIMIT}")

    return scan_live_cameras(db, camera_ids=req.camera_ids, state=req.state,

                             limit=req.limit, min_conf=req.min_conf, created_by=user.id)