|
|
|
@ -240,8 +240,15 @@ def notify_admin_on_rate_limit_sync(
|
|
|
|
log.error(f"Error notifying admin: {str(e)}")
|
|
|
|
log.error(f"Error notifying admin: {str(e)}")
|
|
|
|
return {"status": False, "message": str(e), "data": payload}
|
|
|
|
return {"status": False, "message": str(e), "data": payload}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
async def admin_required(request: Request):
|
|
|
|
|
|
|
|
user = await get_current_user(request)
|
|
|
|
|
|
|
|
if user.role != "Admin" or user.role != "Superadmin":
|
|
|
|
|
|
|
|
raise HTTPException(
|
|
|
|
|
|
|
|
status_code=403, detail="Invalid authorization code."
|
|
|
|
|
|
|
|
)
|
|
|
|
|
|
|
|
return user
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
Admin = Annotated[UserBase, Depends(admin_required)]
|
|
|
|
CurrentUser = Annotated[UserBase, Depends(get_current_user)]
|
|
|
|
CurrentUser = Annotated[UserBase, Depends(get_current_user)]
|
|
|
|
Token = Annotated[str, Depends(get_token)]
|
|
|
|
Token = Annotated[str, Depends(get_token)]
|
|
|
|
InternalKey = Annotated[str, Depends(internal_key)]
|
|
|
|
InternalKey = Annotated[str, Depends(internal_key)]
|