from fastapi import Depends, HTTPException, status from fastapi.security import HTTPBearer, HTTPAuthorizationCredentials from sqlalchemy.orm import Session from app.database import get_db from app.models import Usuario from app.auth import decode_access_token security = HTTPBearer() async def get_current_user( credentials: HTTPAuthorizationCredentials = Depends(security), db: Session = Depends(get_db) ) -> Usuario: """ Dependency para obtener el usuario actual desde el token JWT """ credentials_exception = HTTPException( status_code=status.HTTP_401_UNAUTHORIZED, detail="No se pudo validar las credenciales", headers={"WWW-Authenticate": "Bearer"}, ) token = credentials.credentials payload = decode_access_token(token) if payload is None: raise credentials_exception username: str = payload.get("sub") if username is None: raise credentials_exception user = db.query(Usuario).filter(Usuario.username == username).first() if user is None: raise credentials_exception if not user.is_active: raise HTTPException( status_code=status.HTTP_403_FORBIDDEN, detail="Usuario inactivo" ) return user async def get_current_active_superuser( current_user: Usuario = Depends(get_current_user) ) -> Usuario: """ Dependency para verificar que el usuario sea superusuario """ if not current_user.is_superuser: raise HTTPException( status_code=status.HTTP_403_FORBIDDEN, detail="No tiene permisos suficientes" ) return current_user