from __future__ import annotations

from fastapi import FastAPI, Request

from fastapi.middleware.cors import CORSMiddleware

from fastapi.responses import JSONResponse

from app.api.routes import api_router

from app.core.config import settings

from app.core.rate_limit import RateLimiter

app = FastAPI(

    title=settings.app_name,

    version="0.1.0",

    description="ALPR / Flock intelligence aggregation platform - investigations, plate "

                "correlation, camera mapping, watchlists, reporting, OSINT enrichment.",

)

app.add_middleware(

    CORSMiddleware,

    allow_origin_regex=".*",

    allow_credentials=False,

    allow_methods=["*"],

    allow_headers=["*"],

)

_limiter = RateLimiter(settings.rate_limit_per_minute)

@app.middleware("http")

async def rate_limit(request: Request, call_next):

    path = request.url.path

    exempt = path.endswith("/snapshot") or path.endswith("/satellites") or "/ingest/recent" in path

    if path.startswith("/api/") and not exempt:

        client = request.client.host if request.client else "unknown"

        if not _limiter.allow(client):

            return JSONResponse(status_code=429, content={"detail": "rate limit exceeded"})

    return await call_next(request)

app.include_router(api_router, prefix="/api/v1")

@app.get("/health")

def health():

    return {"status": "ok", "app": settings.app_name, "env": settings.environment}

@app.get("/health/ready")

def ready():

    from sqlalchemy import text

    from app.db.session import engine

    try:

        with engine.connect() as c:

            c.execute(text("SELECT 1"))

        return {"status": "ready", "db": "ok"}

    except Exception as e:

        return JSONResponse(status_code=503, content={"status": "not_ready", "db": str(e)})