wh0ddlmZmZmZmZmZmZddlZddlZddl m Z ddl m Z m Z ddlmZddlmZmZmZmZmZddlmZddlmZmZdd lmZdd lmZdd lmZddlZeeZeZej<d Zej@Z ejBZ!ejDZ"ejFZ#ejHZ$ejJe e!e"e#d Z&ejOdedfdede(fdZ)ejOddefdZ*y)) APIRouter HTTPExceptionDependsQueryRequestHeaderN)urlparse)DictAny) load_dotenv)rrrrr)Session)get_db SessionLocal)settings) Datasource)process_bright_review_dataWEBHOOK_STATIC_TOKENT)app_idkeysecretclustersslz/webhook request_body authorizationc |K|r|jds tdd|jd}t|dks |dtk7r tdd |j d {}t d |tj|d d iS7+#t$r}t d t| jdd}tjddddddddn-#t$r!}t dt|Yd }~nd }~wwxYwtddt|id }~wwxYww)z Webhook to receive review data from Bright Data API. - Verifies Bearer Token. - Sends data to Celery for processing. - Sends Pusher notification on failure. zBearer izMissing Bearer Token status_codedetail zInvalid Bearer TokenNz[Webhook Received Data]: messagez/Data received and sent to Celery for processingz[Webhook Error] datasource_idunknown import-updateprogress-updaterfailedzWebhook failed) processedtotalpercentstatus status_msg event_namedataz/[Pusher Error in Webhook Failure Notification] error) startswithrsplitlen WEBHOOK_TOKENjsonprintrdelay Exceptionstrget pusher_clienttrigger)rr token_parts bright_dataer# pusher_errs >/var/www/html/hubwallet-dev/src/mock_bright_data_api/router.pybright_data_api_webhookrC.sR  8 8 C4JKK%%c*K ;!{1~>4JKKG(--//  )+78 #((5LMM 0 G  Q)* W'OOOYGM  ! !,!" &"2  "  W CC OCTU V V WWc!f4EFF+GsfAD<B/B0*BD<B D9&D4>0C/.D4/ D8DD4DD44D99D<z/notifyrequestc dK |jd{}tdttj|d|jdd}|jddj }|jdd}|jd i}t |xs|}|r d }|xsd }n|d vrd }d}ntddd|diSt jdd|ddd||ddd|iS7#t$r)} tdt| tddd} ~ wwxYww)zl Webhook to receive Bright Data API notifications (success or failure) and forward them via Pusher. Nu- 📩 Received Notification from Bright Data:r )indent snapshot_idr+r1 error_codesr'zBright Data API failed)readydonesuccessz$Bright Data API fetched successfullyu8⚠️ Notification status is unknown or not actionable.r"zStatus 'z ' ignored.r%r&r)rGr(r)r*r+r,r-zPusher notification sent: u❌ Error in notify webhook: r0z*Failed to process Bright Data notificationr) r6r7dumpsr;lowerboolr<r=r9r:r) rDpayloadrGr+ error_msgrI is_failurefrontend_statusfrontend_status_msgr@s rBbright_data_notifyrUds[ +b & >? djj+,kk-4 Xr*002KK, kk-4 )2{3  &O"+"G/G  ( ('O"H  L M&<= =  (*)1   77HIJJM'P b -c!fX674`aabsED0C;C9B:C;D0%C;8D09C;; D-$D((D--D0)+fastapirrrrrrosr6 urllib.parser typingr r dotenvr sqlalchemy.ormr src.utils.dbrrsrc.utils.settingsrsrc.utils.modelsrsrc.utils.celery_workerrpusherrouterbright_data_routergetenvr5rrrr batch_sizePusherr<postr:rCrUrBrisMM !FF"-''> [  01  ll           $ 0G0G0G%0Gj#/bg/b$/brh