hUddlmZmZddlZddlmZddlmZmZddlm Z ddl m Z ddl m cmcmZddlmZmZddlmZdd lmZmZdd lmZmZdd lmZd Zeed d fed<GddZ y))datetime timedeltaN)Literal)BackgroundTasks HTTPException)OAuth2PasswordRequestForm)Session) JWTManagerJWTPayloadSchema)Messages)UserBaseTblUser)RESET_OTP_EXPIRE_MINUTESsend_otp_email)CustomResponse)studentadmin superadmin. VALID_ROLESceZdZdedefdZdejfdZe de defdZ dZ d Z dejfd Zdej d efd Zdej&fd Zy) UserServicedbtokenc ||_||_y)N)rr)selfrrs //var/www/html/RetailAPI/app/api/user/service.py__init__zUserService.__init__s requestcKtj|}tj||j|jj t dtjSw)N1statusmessage) r model_validatercreatercommitrr USER_CREAT)rr created_users r create_userzUserService.create_usersI..w7 |TWW- S(2E2EFFsA+A- credentialscKd|ji}tj||}|stdtj |j |j k7rtdtj|jj}|tvrtdd|t|jd|tj}tj |}|d |j"||jd Sw) Nemail_id status_codedetailizInvalid role: r)user_id user_type user_roleexpbearer) access_token token_typer-roler3)usernamerget_by_user_filterrr USER_NOT_FOUNDpasswordINCORRECT_PASSWORDr:striprr r3rutcnowr create_access_tokenr-)r+r user_filteruser_logr:payloadr8s r user_loginzUserService.user_logins!;#7#78 --k2>C8O8OP P   8#4#4 4C8S8ST T}}""$ { "C.8OP P"$$!   "55g> (" ))&&   sDDcK|jjtdtjt j |jj|j}|stdtjS|Sw)Nr2r/-1r") rr3rr USER_ID_MISSINGr get_usr_idrrr=rusers r get_demo_userzUserService.get_demo_user5sd ::   %C8P8PQ Q!!$**"4"4dgg>!x7N7NO O sBBcK|jjtdtj|j j tjtj|jjk(j}|stdtjS|j jtdtjSw)Nr2r/rHr"r!)rr3rr rIrqueryrfilterfirstrr=r' USER_LOGOUTrKs rlogoutzUserService.logout=s ::   %C8P8PQ Qww}}W%,,W__ @R@R-RSYY[!x7N7NO O S(2F2FGGsC%C'cK|jj}|stdtjSt j j|}tj||j}|stdtjS|j|jk7rtdtjS|j|j k7rtdtj"S|j|_ |jj%tdtj&Sw)NrHr"r!)rr3rr rIschemasUserPassUpdater%rrJrr=current_passwordr>CURRENT_PASSORD_INCORRECT new_passwordconfirm_password%NEWPASSWORD_CONFIRMPASSWORD_NOT_MATCHr'PASSWORD_UPDATED)rrr3 updated_userrLs r update_passzUserService.update_passFs**$$!x7O7OP P--<Ebackground_tasksctK|jjtjtj|jk(j }|st dtjttjdd}||_ tjtt z|_|jj%||jj'|j)t*|j|t-dtj.Sw)z(Generates an OTP and sends it via email.r.r/ii?B)minutesr!r")rrOrrPr-rQrr r=strrandomrandintotprrArr otp_expiryaddr'add_taskrrOTP_SEND)rrr_rLres rforgot_password_servicez#UserService.forgot_password_serviceWsww}}W%,,W-=-=AQAQ-QRXXZCx7N7NO O&..01"//+i@X.YY  D !!.'2B2BCHS(2C2CDDsD6D8c||jjtjtj|jk(j }|st dtj|j|jk7s-|j!|jtjkrt dtj|j|_d|_ |jj!||jj#t%dtj&S)z'Verifies OTP and allows password reset.r.r/Nr2r!r")rrOrrPr-rQrr r=rerfrrA INVALID_OTPrYr>rgr'rr\)rrrLs rreset_password_servicez"UserService.reset_password_servicedsww}}W%,,W-=-=AQAQ-QRXXZC8O8OP P HH #t'>$//T\TcTcTeBeC8L8LM M,,   D S(2K2KLLrN)__name__ __module__ __qualname__r r rrU UserCreater* staticmethodrrFrMrSrVr^ForgotPasswordRequestrrjVerifyOTPRequestrmrrrrs7*:G););G  &? W  2HM)?)?M" EW5R5R Efu E Mg.F.F Mrr)!rrrctypingrfastapirrfastapi.securityrsqlalchemy.ormr app.api.user.schemasapirLrUapp.dependency.authanticationr r app.locale.messagesr app.models.main.userr rapp.utils.emailrrapp.utils.schemas_utilsrrtuple__annotations__rrurrrsW(( 26"&&F(2D2Eg U7;