from typing import Generator, Optional

from fastapi import Depends, HTTPException, status
from fastapi.security import OAuth2PasswordBearer
from jose import jwt
from pydantic import ValidationError

from app.core.config import settings
from app.core import crud, models, schemas, security


reusable_oauth2 = OAuth2PasswordBearer(
        tokenUrl=f"{settings.API_V1_STR}/login/access-token"
)

async def get_current_user(
    token: str = Depends(reusable_oauth2)
) -> models.User:
    try:
        payload = jwt.decode(
            token, settings.SECRET_KEY, algorithms=[security.ALGORITHM]
        )
        token_data = schemas.TokenPayload(**payload)
    except (jwt.JWTError, ValidationError):
        raise HTTPException(
            status_code=status.HTTP_403_FORBIDDEN,
            detail="Could not validation credentials"
        )
    user = await crud.user.get(id=int(token_data.sub))
    if not user:
        raise HTTPException(
            status_code=404,
            detail="User not found"
        )
    return user

async def get_current_active_user(
    current_user: models.User = Depends(get_current_user)
) -> models.User:
    if not await crud.user.is_active(current_user):
        raise HTTPException(
            status_code=400,
            detail="Inactive user"
        )
    return current_user

async def get_current_active_superuser(
    current_user: models.User = Depends(get_current_user)
) -> models.User:
    if not await crud.user.is_superuser(current_user):
        raise HTTPException(
            status_code=400,
            detail="The user doesn't have enough privileges"
        )
    return current_user



1b89c0f1b5541145b23e8b2ce9a16c8d3b1dc663
<mask token>

<mask token>


async def get_current_user(token: str=Depends(reusable_oauth2)) ->models.User:
    try:
        payload = jwt.decode(token, settings.SECRET_KEY, algorithms=[
            security.ALGORITHM])
        token_data = schemas.TokenPayload(**payload)
    except (jwt.JWTError, ValidationError):
        raise HTTPException(status_code=status.HTTP_403_FORBIDDEN, detail=
            'Could not validation credentials')
    user = await crud.user.get(id=int(token_data.sub))
    if not user:
        raise HTTPException(status_code=404, detail='User not found')
    return user


async def get_current_active_user(current_user: models.User=Depends(
    get_current_user)) ->models.User:
    if not await crud.user.is_active(current_user):
        raise HTTPException(status_code=400, detail='Inactive user')
    return current_user


async def get_current_active_superuser(current_user: models.User=Depends(
    get_current_user)) ->models.User:
    if not await crud.user.is_superuser(current_user):
        raise HTTPException(status_code=400, detail=
            "The user doesn't have enough privileges")
    return current_user

<mask token>
reusable_oauth2 = OAuth2PasswordBearer(tokenUrl=
    f'{settings.API_V1_STR}/login/access-token')


async def get_current_user(token: str=Depends(reusable_oauth2)) ->models.User:
    try:
        payload = jwt.decode(token, settings.SECRET_KEY, algorithms=[
            security.ALGORITHM])
        token_data = schemas.TokenPayload(**payload)
    except (jwt.JWTError, ValidationError):
        raise HTTPException(status_code=status.HTTP_403_FORBIDDEN, detail=
            'Could not validation credentials')
    user = await crud.user.get(id=int(token_data.sub))
    if not user:
        raise HTTPException(status_code=404, detail='User not found')
    return user


async def get_current_active_user(current_user: models.User=Depends(
    get_current_user)) ->models.User:
    if not await crud.user.is_active(current_user):
        raise HTTPException(status_code=400, detail='Inactive user')
    return current_user


async def get_current_active_superuser(current_user: models.User=Depends(
    get_current_user)) ->models.User:
    if not await crud.user.is_superuser(current_user):
        raise HTTPException(status_code=400, detail=
            "The user doesn't have enough privileges")
    return current_user

from typing import Generator, Optional
from fastapi import Depends, HTTPException, status
from fastapi.security import OAuth2PasswordBearer
from jose import jwt
from pydantic import ValidationError
from app.core.config import settings
from app.core import crud, models, schemas, security
reusable_oauth2 = OAuth2PasswordBearer(tokenUrl=
    f'{settings.API_V1_STR}/login/access-token')


async def get_current_user(token: str=Depends(reusable_oauth2)) ->models.User:
    try:
        payload = jwt.decode(token, settings.SECRET_KEY, algorithms=[
            security.ALGORITHM])
        token_data = schemas.TokenPayload(**payload)
    except (jwt.JWTError, ValidationError):
        raise HTTPException(status_code=status.HTTP_403_FORBIDDEN, detail=
            'Could not validation credentials')
    user = await crud.user.get(id=int(token_data.sub))
    if not user:
        raise HTTPException(status_code=404, detail='User not found')
    return user


async def get_current_active_user(current_user: models.User=Depends(
    get_current_user)) ->models.User:
    if not await crud.user.is_active(current_user):
        raise HTTPException(status_code=400, detail='Inactive user')
    return current_user


async def get_current_active_superuser(current_user: models.User=Depends(
    get_current_user)) ->models.User:
    if not await crud.user.is_superuser(current_user):
        raise HTTPException(status_code=400, detail=
            "The user doesn't have enough privileges")
    return current_user

from typing import Generator, Optional

from fastapi import Depends, HTTPException, status
from fastapi.security import OAuth2PasswordBearer
from jose import jwt
from pydantic import ValidationError

from app.core.config import settings
from app.core import crud, models, schemas, security


reusable_oauth2 = OAuth2PasswordBearer(
        tokenUrl=f"{settings.API_V1_STR}/login/access-token"
)

async def get_current_user(
    token: str = Depends(reusable_oauth2)
) -> models.User:
    try:
        payload = jwt.decode(
            token, settings.SECRET_KEY, algorithms=[security.ALGORITHM]
        )
        token_data = schemas.TokenPayload(**payload)
    except (jwt.JWTError, ValidationError):
        raise HTTPException(
            status_code=status.HTTP_403_FORBIDDEN,
            detail="Could not validation credentials"
        )
    user = await crud.user.get(id=int(token_data.sub))
    if not user:
        raise HTTPException(
            status_code=404,
            detail="User not found"
        )
    return user

async def get_current_active_user(
    current_user: models.User = Depends(get_current_user)
) -> models.User:
    if not await crud.user.is_active(current_user):
        raise HTTPException(
            status_code=400,
            detail="Inactive user"
        )
    return current_user

async def get_current_active_superuser(
    current_user: models.User = Depends(get_current_user)
) -> models.User:
    if not await crud.user.is_superuser(current_user):
        raise HTTPException(
            status_code=400,
            detail="The user doesn't have enough privileges"
        )
    return current_user


