o ̿SiP@sdZddlmZmZmZmZddlmZmZddl Z ddl m Z ddl m Z ddl mZeZe eZejdd d ed ee jeefd eeeffd dZejddd ed ee jfd eeeffddZejddd ed ee jfd eeeffddZdS)zZZerodha hooks/callback routes for platform teGPT. NOTE: Move-only split from `teGPT.py`. ) APIRouterDepends HTTPExceptionBody)DictAnyN)datetime)database)get_current_userdetailsz /callbackzZerodha OAuth callback)summary.payloadc szS|d}t|d}|stddd|dd|i}|s'tdd dd d lm}||d |d }||}|dd|id|dt ddidddWSty\t yt} z t dtdt| dd} ~ ww)zHandle Zerodha OAuth callback request_token_idizMissing request token status_codedetailzerodha_settingsuser_idizZerodha settings not foundr) ZerodhaClientapi_key api_secret$set access_tokenactive)r login_timestatus connectedz!Zerodha authentication successful)rmessagezOAuth callback failedN) getstrrfind_oneapp.v1.services.zerodha.clientrgenerate_session update_onerutcnow Exceptionlogger exception) r db current_userr rsettingsrclientsessioner/A/var/www/html/Trade-python/app/v1/routers/platform/teGPT_hooks.pyoauth_callbacks8       r1z /postbackzZerodha postback handlerc z8d|td}|d||d}|r5|dd|id|d|d d |d td idd iWStyR}z tdtdt |dd}~ww)z%Handle Zerodha postback notificationszerodhasourcer received_atzerodha_postbacksorder_idorderszerodha_order_idrrfilled_quantityr average_pricerr;r< updated_atreceivedzPostback processing failedrrN rr% insert_onerr$r&r'r(rr )r r) postback_docr8r.r/r/r0zerodha_postback:0    rCz/webhook/zerodhazZerodha order update webhookc r2)z$Handle Zerodha order update webhooksr3r4webhooksr8r9r:rrr;rr<r=r?zWebhook processing failedrrNr@)r r) webhook_docr8r.r/r/r0zerodha_webhook_rDrG)__doc__fastapirrrrtypingrrloggingrapp.dbr app.v1.dependencies.authr router getLogger__name__r'post get_mongo_dbr r1rCrGr/r/r/r0s8       '  $