Anaz
/
After_Chido_Api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

adding user service getuserbyemail

main
Anaz 2025-02-19 13:08:30 +04:00
parent eeede35323
commit a0d1fe40a9
2 changed files with 15 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
api/v1/users.py
View File

@ -33,3 +33,7 @@ async def unblock_user(user_action: UserBlockBan, db: AsyncSession = Depends(get
@router.post("/unban", status_code=200) @router.post("/unban", status_code=200)
async def unban_user(user_action: UserBlockBan, db: AsyncSession = Depends(get_db), token: str = Depends(oauth2_scheme)): async def unban_user(user_action: UserBlockBan, db: AsyncSession = Depends(get_db), token: str = Depends(oauth2_scheme)):
return await UserService.unban_user(user_action, db, token) return await UserService.unban_user(user_action, db, token)
@router.get("/getuserbymail", response_model=UserResponse)
async def get_user_by_email(email: str, db=Depends(get_db), token: str = Depends(oauth2_scheme)):
return await UserService.get_user_by_email(email, db, token)

10
services/user_service.py
View File

@ -128,3 +128,13 @@ class UserService:
if result.rowcount == 0: if result.rowcount == 0:
raise HTTPException(status_code=404, detail="User not found") raise HTTPException(status_code=404, detail="User not found")
return {"message": f"User {user_action.email} unbanned"} return {"message": f"User {user_action.email} unbanned"}
@staticmethod
async def get_user_by_email(email: str, db, token: str):
await AuthService.check_permissions(token, db, ["admin"] )
query = select(users_table).where(users_table.c.email == email)
result = await db.execute(query)
user = result.mappings().first()
if not user:
raise HTTPException(status_code=404, detail="User not found")
return UserResponse(**user)