Spaces:
Sleeping
Sleeping
Update controller/UserController.py
Browse files- controller/UserController.py +96 -96
controller/UserController.py
CHANGED
|
@@ -1,96 +1,96 @@
|
|
| 1 |
-
from fastapi import APIRouter, Query
|
| 2 |
-
from request import RequestUser
|
| 3 |
-
from response import ResponseUser as res
|
| 4 |
-
from service import UserService
|
| 5 |
-
from function import support_function
|
| 6 |
-
from fastapi import HTTPException
|
| 7 |
-
from response import ResponseUser as res
|
| 8 |
-
router = APIRouter()
|
| 9 |
-
|
| 10 |
-
@router.put("/update_user_info", tags=["User"])
|
| 11 |
-
async def update_user_info(request: RequestUser.RequestUpdateUserInfo):
|
| 12 |
-
user_id = request.user_id
|
| 13 |
-
check = support_function.check_value_user_id_controller(user_id)
|
| 14 |
-
if check is not True:
|
| 15 |
-
return check
|
| 16 |
-
uid = request.uid
|
| 17 |
-
email = request.email
|
| 18 |
-
display_name = request.display_name
|
| 19 |
-
photo_url = request.photo_url
|
| 20 |
-
if uid is None or uid.strip() == "":
|
| 21 |
-
return res.ReponseError(status=400,
|
| 22 |
-
data=res.Message(message="uid field is required."))
|
| 23 |
-
if email is None or email.strip() == "":
|
| 24 |
-
return res.ReponseError(status=400,
|
| 25 |
-
data=res.Message(message="email field is required."))
|
| 26 |
-
if display_name is None or display_name.strip() == "":
|
| 27 |
-
return res.ReponseError(status=400,
|
| 28 |
-
data=res.Message(message="display_name field is required."))
|
| 29 |
-
if photo_url is None or photo_url.strip() == "":
|
| 30 |
-
return res.ReponseError(status=400,
|
| 31 |
-
data=res.Message(message="photo_url field is required."))
|
| 32 |
-
return await UserService.update_user_info(request)
|
| 33 |
-
|
| 34 |
-
@router.get('/check_info_google', tags=["User"])
|
| 35 |
-
async def check_info_google(user_id: str = Query(None)):
|
| 36 |
-
check = support_function.check_value_user_id_controller(user_id)
|
| 37 |
-
if check is not True:
|
| 38 |
-
return check
|
| 39 |
-
request =RequestUser.RequestCheckInfoGoogle(user_id=user_id)
|
| 40 |
-
return await UserService.check_info_google(request)
|
| 41 |
-
|
| 42 |
-
@router.get('/check_info_google_signup', tags=["User"])
|
| 43 |
-
async def check_info_google_signup(email: str = None):
|
| 44 |
-
check = support_function.check_value_email_controller(email)
|
| 45 |
-
if check is not True:
|
| 46 |
-
return check
|
| 47 |
-
request =RequestUser.RequestCheckInfoGoogleEmail(email=email)
|
| 48 |
-
return await UserService.check_info_google_email(request)
|
| 49 |
-
|
| 50 |
-
@router.get('/check_state_login', tags=["User"])
|
| 51 |
-
async def check_state_login(user_id: str = Query(None), session_id_now: str = Query(None)):
|
| 52 |
-
check = support_function.check_value_user_id_controller(user_id)
|
| 53 |
-
if check is not True:
|
| 54 |
-
return check
|
| 55 |
-
if session_id_now is None or session_id_now.strip() == "":
|
| 56 |
-
return res.ReponseError(status=400,
|
| 57 |
-
data=res.Message(message="Session Id is required."))
|
| 58 |
-
try:
|
| 59 |
-
int(session_id_now)
|
| 60 |
-
return res.ReponseError(status=400,
|
| 61 |
-
data=res.Message(message="Session Id must be a string, not a number."))
|
| 62 |
-
except ValueError:
|
| 63 |
-
pass
|
| 64 |
-
request =RequestUser.RequestCheckStateLogin(user_id=user_id, session_id_now=session_id_now)
|
| 65 |
-
return await UserService.check_state_login(request)
|
| 66 |
-
|
| 67 |
-
|
| 68 |
-
@router.post('/reset_password', tags=["User"])
|
| 69 |
-
async def reset_password(request:RequestUser.RequestResetPassword):
|
| 70 |
-
email = request.email
|
| 71 |
-
check = support_function.check_value_email_controller(email)
|
| 72 |
-
if check is not True:
|
| 73 |
-
return check
|
| 74 |
-
return
|
| 75 |
-
|
| 76 |
-
@router.put('/change_password', tags=["User"])
|
| 77 |
-
async def reset_password_firebase(request:RequestUser.RequestChangePassword):
|
| 78 |
-
user_id = request.user_id
|
| 79 |
-
check = support_function.check_value_user_id_controller(user_id)
|
| 80 |
-
if check is not True:
|
| 81 |
-
return check
|
| 82 |
-
new_password = request.new_password
|
| 83 |
-
current_password = request.current_password
|
| 84 |
-
confirm_new_password = request.confirm_new_password
|
| 85 |
-
if confirm_new_password is None or confirm_new_password.strip() == "":
|
| 86 |
-
return res.ReponseError(status=400,
|
| 87 |
-
data=res.Message(message="Confirm New password field is required."))
|
| 88 |
-
elif new_password is None or new_password.strip() == "":
|
| 89 |
-
return res.ReponseError(status=400,
|
| 90 |
-
data=res.Message(message="New password field is required."))
|
| 91 |
-
elif current_password is None or current_password.strip() == "":
|
| 92 |
-
return res.ReponseError(status=400,
|
| 93 |
-
data=res.Message(message="Current password field is required."))
|
| 94 |
-
return await UserService.change_password(request)
|
| 95 |
-
|
| 96 |
-
|
|
|
|
| 1 |
+
from fastapi import APIRouter, Query
|
| 2 |
+
from request import RequestUser
|
| 3 |
+
from response import ResponseUser as res
|
| 4 |
+
from service import UserService
|
| 5 |
+
from function import support_function
|
| 6 |
+
from fastapi import HTTPException
|
| 7 |
+
from response import ResponseUser as res
|
| 8 |
+
router = APIRouter()
|
| 9 |
+
|
| 10 |
+
@router.put("/update_user_info", tags=["User"])
|
| 11 |
+
async def update_user_info(request: RequestUser.RequestUpdateUserInfo):
|
| 12 |
+
user_id = request.user_id
|
| 13 |
+
check = support_function.check_value_user_id_controller(user_id)
|
| 14 |
+
if check is not True:
|
| 15 |
+
return check
|
| 16 |
+
uid = request.uid
|
| 17 |
+
email = request.email
|
| 18 |
+
display_name = request.display_name
|
| 19 |
+
photo_url = request.photo_url
|
| 20 |
+
if uid is None or uid.strip() == "":
|
| 21 |
+
return res.ReponseError(status=400,
|
| 22 |
+
data=res.Message(message="uid field is required."))
|
| 23 |
+
if email is None or email.strip() == "":
|
| 24 |
+
return res.ReponseError(status=400,
|
| 25 |
+
data=res.Message(message="email field is required."))
|
| 26 |
+
if display_name is None or display_name.strip() == "":
|
| 27 |
+
return res.ReponseError(status=400,
|
| 28 |
+
data=res.Message(message="display_name field is required."))
|
| 29 |
+
if photo_url is None or photo_url.strip() == "":
|
| 30 |
+
return res.ReponseError(status=400,
|
| 31 |
+
data=res.Message(message="photo_url field is required."))
|
| 32 |
+
return await UserService.update_user_info(request)
|
| 33 |
+
|
| 34 |
+
@router.get('/check_info_google', tags=["User"])
|
| 35 |
+
async def check_info_google(user_id: str = Query(None)):
|
| 36 |
+
check = support_function.check_value_user_id_controller(user_id)
|
| 37 |
+
if check is not True:
|
| 38 |
+
return check
|
| 39 |
+
request =RequestUser.RequestCheckInfoGoogle(user_id=user_id)
|
| 40 |
+
return await UserService.check_info_google(request)
|
| 41 |
+
|
| 42 |
+
@router.get('/check_info_google_signup', tags=["User"])
|
| 43 |
+
async def check_info_google_signup(email: str = None):
|
| 44 |
+
check = support_function.check_value_email_controller(email)
|
| 45 |
+
if check is not True:
|
| 46 |
+
return check
|
| 47 |
+
request =RequestUser.RequestCheckInfoGoogleEmail(email=email)
|
| 48 |
+
return await UserService.check_info_google_email(request)
|
| 49 |
+
|
| 50 |
+
@router.get('/check_state_login', tags=["User"])
|
| 51 |
+
async def check_state_login(user_id: str = Query(None), session_id_now: str = Query(None)):
|
| 52 |
+
check = support_function.check_value_user_id_controller(user_id)
|
| 53 |
+
if check is not True:
|
| 54 |
+
return check
|
| 55 |
+
if session_id_now is None or session_id_now.strip() == "":
|
| 56 |
+
return res.ReponseError(status=400,
|
| 57 |
+
data=res.Message(message="Session Id is required."))
|
| 58 |
+
try:
|
| 59 |
+
int(session_id_now)
|
| 60 |
+
return res.ReponseError(status=400,
|
| 61 |
+
data=res.Message(message="Session Id must be a string, not a number."))
|
| 62 |
+
except ValueError:
|
| 63 |
+
pass
|
| 64 |
+
request =RequestUser.RequestCheckStateLogin(user_id=user_id, session_id_now=session_id_now)
|
| 65 |
+
return await UserService.check_state_login(request)
|
| 66 |
+
|
| 67 |
+
|
| 68 |
+
@router.post('/reset_password', tags=["User"])
|
| 69 |
+
async def reset_password(request:RequestUser.RequestResetPassword):
|
| 70 |
+
email = request.email
|
| 71 |
+
check = support_function.check_value_email_controller(email)
|
| 72 |
+
if check is not True:
|
| 73 |
+
return check
|
| 74 |
+
return UserService.reset_password(request)
|
| 75 |
+
|
| 76 |
+
@router.put('/change_password', tags=["User"])
|
| 77 |
+
async def reset_password_firebase(request:RequestUser.RequestChangePassword):
|
| 78 |
+
user_id = request.user_id
|
| 79 |
+
check = support_function.check_value_user_id_controller(user_id)
|
| 80 |
+
if check is not True:
|
| 81 |
+
return check
|
| 82 |
+
new_password = request.new_password
|
| 83 |
+
current_password = request.current_password
|
| 84 |
+
confirm_new_password = request.confirm_new_password
|
| 85 |
+
if confirm_new_password is None or confirm_new_password.strip() == "":
|
| 86 |
+
return res.ReponseError(status=400,
|
| 87 |
+
data=res.Message(message="Confirm New password field is required."))
|
| 88 |
+
elif new_password is None or new_password.strip() == "":
|
| 89 |
+
return res.ReponseError(status=400,
|
| 90 |
+
data=res.Message(message="New password field is required."))
|
| 91 |
+
elif current_password is None or current_password.strip() == "":
|
| 92 |
+
return res.ReponseError(status=400,
|
| 93 |
+
data=res.Message(message="Current password field is required."))
|
| 94 |
+
return await UserService.change_password(request)
|
| 95 |
+
|
| 96 |
+
|