from fastapi import APIRouter, Depends, HTTPException
from fastapi.security import OAuth2PasswordBearer
from sqlalchemy.ext.asyncio import AsyncSession

from app.auth.jwt import decode_token
from app.models.user import User
from app.utils.db import get_async_session
from app.utils.logger_cfg import logger

router = APIRouter()
oauth2_scheme = OAuth2PasswordBearer(tokenUrl="/api/auth/login")


@router.get("/me")
async def read_current_user(
    token: str = Depends(oauth2_scheme),
    session: AsyncSession = Depends(get_async_session),
):

    if not token:
        logger.warning("No token provided in /me request")
        raise HTTPException(status_code=401, detail="Unauthorized")

    try:
        payload = decode_token(token)
        user_id = int(payload.get("sub"))
        user = await User.get_user_by_id(user_id, session=session)

        if not user:
            logger.warning("User not found in /me | id={}", user_id)
            raise HTTPException(status_code=404, detail="User not found")

        logger.info("User accessed /me | id={} username={}", user.id, user.username)

        user_data = {
            "id": user.id,
            "username": user.username,
            "email": user.email,
            "premium": user.premium,
            "is_banned": user.is_banned,
            "is_moderator": user.is_moderator,
        }
        logger.debug("Returning /me data: {}", user_data)
        return user_data

    except ValueError as e:
        logger.warning("Invalid token in /me request: {}", e)
        raise HTTPException(status_code=401, detail="Invalid token")