"""Media service — FastAPI entrypoint."""

import logging

from fastapi import FastAPI, Depends
from sqlalchemy import select, func
from sqlalchemy.ext.asyncio import AsyncSession

from app.config import DEBUG, PORT

logging.basicConfig(
    level=logging.DEBUG if DEBUG else logging.INFO,
    format="%(asctime)s %(levelname)s %(name)s: %(message)s",
)

app = FastAPI(
    title="Media Service",
    description="Podcast and local audio management with playback tracking.",
    version="1.0.0",
    docs_url="/api/docs" if DEBUG else None,
    redoc_url=None,
)


@app.on_event("startup")
async def startup():
    from app.database import engine, Base
    from app.models import Show, Episode, Progress, QueueItem, PlaybackEvent  # noqa

    async with engine.begin() as conn:
        await conn.run_sync(Base.metadata.create_all)

    logging.getLogger(__name__).info("Media service started on port %s", PORT)


# Register routers
from app.api.shows import router as shows_router
from app.api.episodes import router as episodes_router
from app.api.playback import router as playback_router
from app.api.queue import router as queue_router

app.include_router(shows_router)
app.include_router(episodes_router)
app.include_router(playback_router)
app.include_router(queue_router)


@app.get("/api/health")
async def health():
    return {"status": "ok", "service": "media"}


from app.api.deps import get_user_id, get_db_session


@app.get("/api/stats")
async def get_stats(
    user_id: str = Depends(get_user_id),
    db: AsyncSession = Depends(get_db_session),
):
    from app.models import Show, Episode, Progress

    total_shows = await db.scalar(
        select(func.count(Show.id)).where(Show.user_id == user_id)
    )
    total_episodes = await db.scalar(
        select(func.count(Episode.id)).where(Episode.user_id == user_id)
    )
    total_seconds = await db.scalar(
        select(func.coalesce(func.sum(Progress.position_seconds), 0)).where(
            Progress.user_id == user_id,
        )
    )
    in_progress = await db.scalar(
        select(func.count(Progress.id)).where(
            Progress.user_id == user_id,
            Progress.position_seconds > 0,
            Progress.is_completed == False,  # noqa: E712
        )
    )

    return {
        "total_shows": total_shows or 0,
        "total_episodes": total_episodes or 0,
        "total_listened_hours": round((total_seconds or 0) / 3600, 1),
        "in_progress": in_progress or 0,
    }