"""
Application entry point for the Joule Dynamics Intelligence API.
"""

import os
import uvicorn
from fastapi import FastAPI, APIRouter
from fastapi.middleware.cors import CORSMiddleware
from dotenv import load_dotenv

load_dotenv()

from langfuse import get_client
from openinference.instrumentation.groq import GroqInstrumentor

langfuse = get_client()
if not langfuse.auth_check():
    print("WARNING: Langfuse auth failed - check your keys ✋")

GroqInstrumentor().instrument()

from services.observability import setup_logger
logger = setup_logger(__name__)

app = FastAPI(
    title="Joule Dynamics Intelligence API",
    description="Real Estate Rate Monitor + RAG Customer Support",
    version="1.0.0",
)

app.add_middleware(
    CORSMiddleware,
    allow_origins=["*"],
    allow_methods=["POST", "GET"],
    allow_headers=["*"],
)

import unified_ingest
unified_ingest.ensure_ingested()

from services.market_registry import market_registry
market_registry.refresh()
logger.info(f"Market registry initialized: {market_registry.get_markets()}")

from routes import v1_router
app.include_router(v1_router)

from routes.v1.rag import router as _rag_router, rag_chat, RagChatRequest
_compat = APIRouter(tags=["Deprecated — use /api/v1/rag/chat"])


@_compat.post("/api/rag/chat", deprecated=True, include_in_schema=False)
def rag_chat_compat(req: RagChatRequest):
    """Deprecated: forwards to /api/v1/rag/chat for backwards compatibility."""
    return rag_chat(req)


app.include_router(_compat)