!h*  ddlmZmZmZddlZddlZddlmZmZddl m Z ejejejeZeeZej#ddgd Zej#d d gd Zej#d d gdZej#dd gdZej#dd gdZej#ddgdZej1ddZej1ddZedk(r]ededededededed ed!ed"ej9d#d$d%&yy)')FlaskrequestjsonifyN)get_unprocessed_callssend_to_rabbitmq)send_to_sarvam)levelz/healthGET)methodsc tddddS)zHealth check endpointhealthyzRabbitMQ Sarvam API is runningz1.0.0)statusmessageversionr?C:\Users\pc\OneDrive\Desktop\rabbitasrvam\rabbitmqsarvam\app.py health_checkr s 3 rz /queue-callsPOSTc p tj}|stdddddfS|jd}|sd}tj dtj d |xsd t |}|std d |xsd |d dSt|td dt|d|xsd |t||Dcgc] }|d |ddc}dScc}w#t$rE}tjdt|tdt|dddfcYd}~Sd}~wwxYw)z Queue unprocessed calls for a specific business ID Expected JSON payload: { "bid": "6840" // Business ID (optional, defaults to 7417) } FNo JSON data provided$Please provide JSON with 'bid' fieldsuccesserrorrbidN$No bid provided, using default table$Processing request for business ID: defaultT)No unprocessed calls found for business: rrr business_id queued_countSuccessfully queued  calls for business: callidrrrr$r%callszError in queue_calls: Failed to queue calls) rget_jsonrgetloggerinforrlen Exceptionrstr)datarr,calles r queue_callsr9sr0! 0A  hhuoC KK> ? :3;K):LMN&c*FsGWiFXY" !   -c%j\9NsO_V_N`aJFKLedaa9eL    M  -c!fX67V.     s;&C'A)C'4C'C"C'"C'' D50:D0*D50D5z/process-callsc tj}|stdddddfS|jd}|sd}tj dtj d |xsd t |}td d ||d S#t$rE}tjdt|tdt|dddfcYd}~Sd}~wwxYw)z Directly process calls for a specific business ID (bypasses RabbitMQ) Expected JSON payload: { "bid": "6840" // Business ID (optional, defaults to 7417) } FrrrrrNr+Direct processing request for business ID: r!TCalls processed successfullyrrr$resultzError in process_calls: Failed to process callsr.) rr/rr0r1r2rr4rr5)r6rr>r8s r process_callsr@Rs$! 0A  hhuoC KK> ? A#BRASTU $5      /Ax89V0     s#&B A B C:C CCz/queue-calls/c  tjd|t|}|stdd||ddSt |tddt |d||t ||Dcgc] }|d|dd c}d Scc}w#t $rE}tjd t|td t|d ddfcYd}~Sd}~wwxYw)zg Queue calls for a specific business ID via URL parameter URL: POST /queue-calls/6840 r Tr"rr#r&r'r(r)r+zError in queue_calls_by_bid: Fr-rr.N) r1r2rrrr3r4rr5)rr,r7r8s rqueue_calls_by_bidrBs :3%@A&c*FseL" !   -c%j\9NseTJFKLedaa9eL    M  4SVH=>V.     s47B 0B *B<B B C:C CCz/process-calls/c  tjd|t|}tdd||dS#t$rE}tj dt |tdt |ddd fcYd }~Sd }~wwxYw) zt Directly process calls for a specific business ID via URL parameter URL: POST /process-calls/6840 r;Tr<r=zError in process_calls_by_bid: Fr?rr.N)r1r2rrr4rr5)rr>r8s rprocess_calls_by_bidrDs A#GH $5      6s1vh?@V0     s25 B:A>8B>Bz/list-businessesc ddlm}|}|j}|jd|j }g}|D]2}|dj dd}|j ||d|dd4|j|jtd|t|d S#t$rE}tjd t|td t|d d dfcYd}~Sd}~wwxYw)z, List all available business tables r)get_db_connectionzSHOW TABLES LIKE '%_calls'_calls_sarvamresponse)r calls_tableresponse_tableT)r businessescountzError in list_businesses: FzFailed to list businessesrr.N) db_configrFcursorexecutefetchallreplaceappendcloserr3r4r1rr5)rFconnrOtablesrLtablerr8s rlist_businessesrXs  "/ " 34" E(""8R0C   "%f~%(E"9    $_    1#a&:;V2     sB.B11 C?::C:4C?:C?c$tdddddfS)NFzEndpoint not foundz"Please check the API documentationrrYrrs r not_foundr\s' %7    rr.c$tdddddfS)NFzInternal server errorzSomething went wrong on our endrr.rr[s rinternal_errorr^s' (4    r__main__u+🚀 Starting RabbitMQ Sarvam API Server...u📋 Available endpoints:z GET /health - Health checkz. POST /queue-calls - Queue calls (JSON body)z4 POST /queue-calls/ - Queue calls (URL param)z; POST /process-calls - Process calls directly (JSON body)zA POST /process-calls/ - Process calls directly (URL param)z. GET /list-businesses - List all businessesu/🌐 Server will start on http://localhost:5000Tz0.0.0.0i)debughostport)flaskrrrjsonloggingrabbitrrsarvam_processorr basicConfigINFO getLogger__name__r1approuterr9r@rBrDrX errorhandlerr\r^printrunrrrrqs)) :+',,'   8 $ Ho9ug&'>F8,9-9v fX.-/-^ &2%3%N !F8456 w/&0&P#  #   z 78 %& *+ :; @A GH MN :; ;<GG$YTG2r