"""BAN YARO — Tierärzte Routes (user-level, nie löschen)"""

from fastapi import APIRouter, Depends, HTTPException
from pydantic import BaseModel
from typing import Optional
from database import db
from auth import get_current_user

router = APIRouter()


class TierarztCreate(BaseModel):
    name:             str
    strasse:          Optional[str] = None
    plz:              Optional[str] = None
    ort:              Optional[str] = None
    telefon:          Optional[str] = None
    notfall_telefon:  Optional[str] = None
    email:            Optional[str] = None
    website:          Optional[str] = None
    notizen:          Optional[str] = None
    ist_notfallpraxis: bool = False


class TierarztUpdate(BaseModel):
    name:             Optional[str]  = None
    strasse:          Optional[str]  = None
    plz:              Optional[str]  = None
    ort:              Optional[str]  = None
    telefon:          Optional[str]  = None
    notfall_telefon:  Optional[str]  = None
    email:            Optional[str]  = None
    website:          Optional[str]  = None
    notizen:          Optional[str]  = None
    ist_notfallpraxis: Optional[bool] = None
    aktiv:            Optional[bool] = None   # False = inaktiv (Umzug etc.)


@router.get("")
async def list_tieraerzte(user=Depends(get_current_user)):
    """Alle Tierärzte des Users — aktive zuerst, dann inaktive (für Historienansicht)."""
    with db() as conn:
        rows = conn.execute(
            "SELECT * FROM tieraerzte WHERE user_id=? ORDER BY aktiv DESC, name",
            (user["id"],)
        ).fetchall()
    return [dict(r) for r in rows]


@router.post("", status_code=201)
async def create_tierarzt(data: TierarztCreate, user=Depends(get_current_user)):
    with db() as conn:
        conn.execute(
            """INSERT INTO tieraerzte
               (user_id, name, strasse, plz, ort, telefon, notfall_telefon,
                email, website, notizen, ist_notfallpraxis)
               VALUES (?,?,?,?,?,?,?,?,?,?,?)""",
            (user["id"], data.name, data.strasse, data.plz, data.ort,
             data.telefon, data.notfall_telefon, data.email, data.website,
             data.notizen, int(data.ist_notfallpraxis))
        )
        row = conn.execute(
            "SELECT * FROM tieraerzte WHERE user_id=? ORDER BY id DESC LIMIT 1",
            (user["id"],)
        ).fetchone()
    return dict(row)


@router.patch("/{tierarzt_id}")
async def update_tierarzt(tierarzt_id: int, data: TierarztUpdate,
                           user=Depends(get_current_user)):
    with db() as conn:
        entry = conn.execute(
            "SELECT id FROM tieraerzte WHERE id=? AND user_id=?",
            (tierarzt_id, user["id"])
        ).fetchone()
        if not entry:
            raise HTTPException(404, "Tierarzt nicht gefunden.")

        updates = {k: v for k, v in data.model_dump().items() if v is not None}
        if "ist_notfallpraxis" in updates:
            updates["ist_notfallpraxis"] = int(updates["ist_notfallpraxis"])
        if "aktiv" in updates:
            updates["aktiv"] = int(updates["aktiv"])
        if not updates:
            row = conn.execute("SELECT * FROM tieraerzte WHERE id=?", (tierarzt_id,)).fetchone()
            return dict(row)

        set_clause = ", ".join(f"{k}=?" for k in updates)
        conn.execute(
            f"UPDATE tieraerzte SET {set_clause} WHERE id=?",
            list(updates.values()) + [tierarzt_id]
        )
        row = conn.execute("SELECT * FROM tieraerzte WHERE id=?", (tierarzt_id,)).fetchone()
    return dict(row)