from datetime import datetime, timezone, timedelta from typing import Optional from fastapi import Depends, HTTPException from fastapi.security import OAuth2PasswordBearer import jwt from sqlalchemy.orm import Session from dotenv import load_dotenv import os from app.infrastructure.database.dependencies import get_db from app.infrastructure.database.repository.user_repository import UsersRepository load_dotenv() SECRET_KEY = os.getenv("SECRET_KEY") ALGORITHM = "HS256" ACCESS_TOKEN_EXPIRE_MINUTES = 30 oauth2_scheme = OAuth2PasswordBearer(tokenUrl="token") def create_access_token(data: dict, expires_delta: Optional[timedelta] = None): to_encode = data.copy() expire = datetime.now(timezone.utc) + (expires_delta if expires_delta else timedelta(minutes=15)) to_encode.update({"exp": expire}) return jwt.encode(to_encode, SECRET_KEY, algorithm=ALGORITHM) # Зависимость для проверки токена def verify_token(token: str = Depends(oauth2_scheme), db: Session = Depends(get_db)): credentials_exception = HTTPException( status_code=401, detail="Could not validate credentials", headers={"WWW-Authenticate": "Bearer"}, ) try: payload = jwt.decode(token, SECRET_KEY, algorithms=[ALGORITHM]) user_id: str = payload.get("sub") if user_id is None: raise credentials_exception user_repo = UsersRepository(db) user = user_repo.get_by_id(int(user_id)) if user is None: raise credentials_exception return user except jwt.PyJWTError: raise credentials_exception