"""Versioned platform APIs: buildings, telemetry, points."""
from __future__ import annotations

from typing import Optional

from fastapi import APIRouter, HTTPException, Query

from backend.knowledge.hvac_guide_catalog import catalog_all, catalog_record
from backend.services.canonical_telemetry_service import latest_points
from database.models import Building, Equipment, Point
from database.session import SessionLocal

router = APIRouter(prefix="/api/v1", tags=["v1"])


@router.get("/guide-catalog")
@router.get("/opportunities/catalog")
async def guide_catalog():
    return {
        "opportunities": catalog_all(),
        "source_document": "150317hvacguide.pdf",
        "energy_impact_note": "guide_savings_potential is GUIDE_POTENTIAL, not measured savings",
    }


@router.get("/guide-catalog/{oid}")
@router.get("/opportunities/catalog/{oid}")
async def guide_catalog_one(oid: str):
    item = catalog_record(oid)
    if not item:
        raise HTTPException(status_code=404, detail={"code": "UNKNOWN_OPPORTUNITY", "message": "Official catalog IDs are O1–O20."})
    return item


@router.get("/buildings")
async def buildings():
    db = SessionLocal()
    try:
        rows = db.query(Building).all()
        return {
            "buildings": [
                {
                    "id": b.id,
                    "name": b.name,
                    "location": b.location,
                    "area_sqft": b.area_sqft,
                    "floors": b.floors,
                    "design_cooling_tonnage": b.design_cooling_tonnage,
                }
                for b in rows
            ]
        }
    finally:
        db.close()


@router.get("/buildings/{building_id}")
async def building_one(building_id: str):
    db = SessionLocal()
    try:
        b = db.query(Building).filter_by(id=building_id).first()
        if not b:
            raise HTTPException(status_code=404, detail={"code": "NOT_FOUND", "message": "Building not found."})
        eq = db.query(Equipment).filter_by(building_id=building_id).all()
        return {
            "id": b.id,
            "name": b.name,
            "location": b.location,
            "area_sqft": b.area_sqft,
            "equipment": [{"id": e.id, "name": e.name, "type": e.type} for e in eq],
        }
    finally:
        db.close()


@router.get("/equipment")
async def equipment(building_id: Optional[str] = None):
    db = SessionLocal()
    try:
        q = db.query(Equipment)
        if building_id:
            q = q.filter_by(building_id=building_id)
        rows = q.all()
        return {"equipment": [{"id": e.id, "building_id": e.building_id, "name": e.name, "type": e.type} for e in rows]}
    finally:
        db.close()


@router.get("/telemetry")
async def telemetry(building_id: Optional[str] = None):
    return {"points": latest_points(building_id)}


@router.get("/points")
async def points(equipment_id: Optional[str] = None):
    db = SessionLocal()
    try:
        q = db.query(Point)
        if equipment_id:
            q = q.filter_by(equipment_id=equipment_id)
        rows = q.limit(500).all()
        return {
            "points": [
                {"id": p.id, "name": p.name, "equipment_id": p.equipment_id, "unit": p.unit, "category": p.category}
                for p in rows
            ]
        }
    finally:
        db.close()