
    i                        S SK r S SKJr  S SKJr  S SKJrJrJrJ	r	J
r
  S SKJr  S SKJrJr  S SKJr  S SKJrJr  \" 5       r\" S	\
" \5      /S
9rSr\" \5      rSSSS.0r\R5                  \S/SS/S/S9  \ R6                  " \5      r\R=                  \ R>                  5        \" SSSS9r \ R=                  \ RB                  5        \ RD                  " S5      r#\ RI                  \#5        \RK                  \ 5        S r& " S S\5      r'\
" \5      4S\4S jjr(\RS                  S\	RT                  S 9S\
" \(5      4S!\'S"\\+S-  \" S#S$94   4S% jj5       r,g)&    N)TimedRotatingFileHandler)	Annotated)FastAPIHeaderHTTPExceptionstatusDepends)CORSMiddleware)	HTTPBasicHTTPBasicCredentials)	BaseModel)create_enginetextz/api)	root_pathdependenciesztmysql+pymysql://admin:2!ecgRSV>QuiMN]@njara-candle-1.cdswweasecus.ap-south-1.rds.amazonaws.com:3306/trading_strategyadminnjara_adminz$8561f1a2-51f6-44e0-a497-255dd336dd13)passwordapi_keyzhttps://banjaronkidukan.work.gdTput*)allow_originsallow_credentialsallow_methodsallow_headersztoken_update.logD   )filenamewhenintervalzP%(asctime)s - %(name)s - %(levelname)s - %(funcName)s - %(message)s - %(lineno)dc                  *    [         R                  5       $ )N)DATABASE_ENGINEconnect     $/home/admin/njara/web/UpdateToken.pyengine_connectionr'   +   s    ""$$r%   c                   .    \ rS rSr% Sr\\S'   \\S'   Srg)TokenRequest/   Nr   access_tokenr$   )__name__
__module____qualname____firstlineno__r   str__annotations____static_attributes__r$   r%   r&   r)   r)   /   s    GSr%   r)   credc                     [         R                  S5        U R                  nU R                  nU[        ;   a  U[        U   S   :X  a  [        S5        U$ [        [        R                  SSS0S9e)NzBasic auth verificationr   zUser ValidatedzIncorrect email or passwordzWWW-AuthenticateBasic)status_codedetailheaders)	loginfousernamer   USERSprintr   r   HTTP_401_UNAUTHORIZED)r3   usersec_passs      r&   basic_auth_verificationrA   4   si    HH&'==D}}Hu}U4[%<< 440'1
 	
r%   z/update-token)r6   request_bodyaccept_headerAccept)aliasc                 Z  #    [         R                  S5        U(       az  [        U   S   U l        US:w  a
  [	        SSS9e[        5        n[        S5      nU R                  U R                  S.nUR                  XE5        UR                  5         S S S 5        g g ! , (       d  f       N= f7f)	Nz Received request to update tokenr   z!application/vnd.api.token+json.v1i  zUnsupported Accept header)r6   r7   zmUPDATE upstox_configuration_details set access_token=:access_token, date_updated=NOW() WHERE api_key=:api_key)r+   r   )
r9   r:   r<   r   r   r'   r   r+   executecommit)rB   rC   
login_user
connectionstmtparamss         r&   update_tokenrM   D   s      HH/0$Z0;??C8STT JAD&2&?&?LL`L`aFt, ! 	  ! s   AB+
AB
B+
B($B+)-logginglogging.handlersr   typingr   fastapir   r   r   r   r	   fastapi.middleware.corsr
   fastapi.securityr   r   pydanticr   
sqlalchemyr   r   authappDATABASE_URLr"   r<   add_middleware	getLoggerr,   r9   setLevelDEBUGfileHandlerINFO	Formatter	formattersetFormatter
addHandlerr'   r)   rA   r   HTTP_204_NO_CONTENTr0   rM   r$   r%   r&   <module>rd      sw    5  C C 2 <  * {gdm_= F-	}9_`a    55'%   ! W]] &0BWXY   W\\ "pq	    # { %9 
 :A 
"6 
  f&@&@Arv")*A"B\ )CRVJX^emXnLnBo  Br%   