whddlmZmZmZmZddlmZddlmZm Z m Z ddl m Z ddl mZddlmZddlmZddlmZdd lmZdd lmZdd lmZmZdd lmZmZmZmZm Z dd l!Z!eZ"eZ#ejHZ$ejJZ%ejLZ&ejNZ'ejPZ(e!jRe$e%e&e'dZ*GddeZ+e"jYdde+fdZ-e#j]dee/e fed ded ded dd d eeeefde0de e/de e/de e/de e0d e e0d!e d"efd#Z1e#j]d$ee/e fed ded ded dd d eeeefde0de e/de e/de e/de e0d e e0d!e d"efd%Z2e#j]d&ee/e fed ded ded dd d eeeefde0de e/de e/de e/de e0d e e0d!e d"efd'Z3e#j]d(ee/e fed ded ded dd d eeeefde0de e/de e/de e/de e0d e e0d!e d"efd)Z4e#j]d*ee/e fed ded ded dd d eeeefde0de e/de e/de e/de e0d e e0d!e d"efd+Z5y ),) APIRouter HTTPExceptionDependsQuery) BaseModel)DictAnyOptional)Session)get_db)User)settings)get_current_user)process_csv_review_data)List)FeedbackResponse TaskResponse)fetch_sentiment_countsfetch_sentiment_breakdownfetch_review_countfetch_feedback_ratingfetch_sentiment_scoreNT)app_idkeysecretclustersslcJeZdZUeed<eed<eed<eed<eed<eed<y)WebhookPayloadstore_id branch_id datasource_id source_type snapshot_idreviewsN)__name__ __module__ __qualname__int__annotations__strlist7/var/www/html/hubwallet-dev/src/apps/feedback/router.pyrr#s#MN Mr.rz/webhookpayloadc K tj|jd|jdS#t$r}t dt | tjdddddddd  n-#t$r!}t d t |Yd }~nd }~wwxYwtd t |d }~wwxYww)zw Webhook that receives data and sends it to Celery for processing. Sends a Pusher notification on failure. z$Data received and processing started)messager$z[Webhook Error] z import-updatezprogress-updaterfailedzWebhook failed) processedtotalpercentstatus status_msg) event_namedataz/[Pusher Error in Webhook Failure Notification] Ni) status_codedetail) rdelaydictr$ Exceptionprintr+ pusher_clienttriggerr)r0e pusher_errs r/ receive_datarE+s <%%glln5>"..  <  Q)* W  ! !,!" &"2  "  W CC OCTU V V WCF;;'B9A65B96 B ?BB9B  B99B>>Cz/sentiment_counts)response_modelzFilter by feedback source) descriptionzStart date in YYYY-MM-DD formatzEnd date in YYYY-MM-DD formatr!source start_dateend_date min_rating max_ratingdb current_userc &t||||||||S)z API route to fetch sentiment counts (Protected). - Ensures the branch belongs to the logged-in user. - Allows filtering by source and date range. )rr!rHrIrJrKrLrMrNs r/get_sentiment_counts_resultsrQRs ")RvzS[\fhr ssr.z/sentiment_breakdownc &t||||||||S)z API route to fetch sentiment breakdown (Protected). - Ensures the branch belongs to the logged-in user. - Allows filtering by source and date range. )rrPs r/get_sentiment_breakdown_resultsrSgs %YL&*V^_iku vvr.z /review_countc &t||||||||S)z API route to fetch review count results (Protected). - Ensures the branch belongs to the logged-in user. - Allows filtering by source and date range. )rrPs r/get_review_count_resultsrU{s i\6:xXbdn oor.z /rating_countc &t||||||||S)z API route to fetch sentiment analysis results (Protected). - Ensures the branch belongs to the logged-in user. - Allows filtering by source and date range. )rrPs r/get_rating_count_resultsrWs !B fjRZ[egq rrr.z/sentiment_scorec &t||||||||S)z API route to fetch sentiment score (Protected). - Ensures the branch belongs to the logged-in user. - Allows filtering by source and date range. )rrPs r/get_sentiment_scorerYs !B fjRZ\fhr ssr.)6fastapirrrrpydanticrtypingrr r sqlalchemy.ormr src.utils.dbr src.apps.users.modelsr src.utils.settingsrsrc.apps.auth.controllerrsrc.utils.celery_workerrrsrc.apps.feedback.schemasrrsrc.apps.feedback.controllerrrrrrpusherrouterfeedback_routerrrrr batch_sizePusherrArpostrEgetr+r)rQrSrUrWrYr-r.r/rls<<&&"&'5;D\\ + ll           YZ!<!<!