46 lines
1.5 KiB
Python
46 lines
1.5 KiB
Python
from fastapi import APIRouter, HTTPException
|
|
from api.v1.models.user import User
|
|
from api.v1.database.user_queries import get_user_by_email, get_user_by_id
|
|
from api.v1.database.user_queries import create_user_db, update_user_db, delete_user_db
|
|
from api.v1.dependencies.security import hash_password
|
|
|
|
router = APIRouter()
|
|
|
|
|
|
@router.post("/users")
|
|
async def create_user(user: User):
|
|
result = get_user_by_email(user.email)
|
|
if result:
|
|
raise HTTPException(status_code=409, detail='User already exists')
|
|
|
|
create_user_db(username=user.username, password=hash_password(user.password), email=user.email)
|
|
created_user = get_user_by_email(user.email)
|
|
created_user_dict = {
|
|
"id": created_user[0],
|
|
"username": created_user[1],
|
|
"password": created_user[2],
|
|
"email": created_user[3],
|
|
}
|
|
|
|
return {'status': 'successful', 'user': created_user_dict}
|
|
|
|
|
|
@router.put("/users")
|
|
async def update_user(new_info: User):
|
|
old_info = get_user_by_id(new_info.id)
|
|
if old_info is None:
|
|
raise HTTPException(status_code=404, detail='User not found')
|
|
update_user_db(user_id=new_info.id, new_email=new_info.email,
|
|
new_username=new_info.username, new_password=hash_password(new_info.password))
|
|
|
|
|
|
@router.delete("/users")
|
|
async def delete_user(user_id: int):
|
|
user = get_user_by_id(user_id)
|
|
if user is None:
|
|
raise HTTPException(status_code=404, detail='User not found')
|
|
delete_user_db(user_id)
|
|
|
|
|
|
|