o d6i@sddlZddlZddlmZmZmZddlmZddlm Z ddl m Z ddl m Z ddlmZddlmZdd lmZdd lmZe ejd d eeZed dZejedgd dgdgde eGddde ZeddefddZeddefddZdS)N)FastAPI HTTPExceptionRequest)CORSMiddleware) BaseModel) load_dotenv) setup_logging)tracing)init_db)chat_with_karishye)clean_indian_phone_numberT)level use_colorszKarishye AI Chat API)title*) allow_originsallow_credentials allow_methods allow_headersc@s&eZdZUeed<eed<eed<dS) ChatRequestuser_idmessage session_idN)__name__ __module__ __qualname__str__annotations__rr,/var/www/html/karishye-ai-python/app/main.pyr*s  rz/chatpayloadc sz4ddl}|}t|j|j|jIdH}|}||}td|dd|j|j|j|dd}|WStyR}ztdt |j t d d d d}~ww) z Chat endpoint using karishye_agent with RAG and Puja tools. Handles conversation flow, puja bookings, and intent tracking. rNz[/chat] Response completed in .2fsT)rr user_messagekarishye_agent_responsesuccessz[/chat] Error: iz3Something went wrong. Please try again in a moment.) status_codedetail) timer rrrloggerinfo Exceptionerrortyperr)r r( start_timeresponseend_time total_timeresulterrrchat2s6 r4z /webhook/watirequestc s z|IdH}|stddddWS|dd}|dd}|d d}|d d}|d p7|d }|s>|r>|}|rF|d krF|n dtjdd}|r]|d kr]d|ndtj}|rkt|nd} d} |r}|dkr}|r}|} |r|dkrtddddWSz.ddl } | } t |||| | ddIdH} | }|| }t d|ddd| dWWSt y}zt dt|jd}d|dWYd}~WSd}~wwt y}zt dt|jdddWYd}~Sd}~ww)zz WATI webhook endpoint to receive WhatsApp messages. Integrates with karishye_agent for AI-powered responses. Nz[WATI Webhook] Empty payloadFzEmpty payload received)r% ai_messageNamePhoneEmailMessagewaIdwa_idz@phone whatsapp_wati_z@namez@messagez[WATI Webhook] No message textzNo message text receivedrT) phone_number user_nameformat_for_whatsappz%[WATI Webhook] Response completed in r!r"z[WATI Webhook] AI error: zKSomething went wrong. Please visit https://www.karishye.co/ for assistance.z[WATI Webhook] Error: )jsonr)warninggetuuiduuid4hexr stripr(r r*r+r,r-r)r5r namephoneemail message_textr=rr clean_phone clean_namer(r. ai_responser0 response_timeai_errorfallback_responser3rrr wati_webhook[st     (&      rU) loggingrGfastapirrrfastapi.middleware.corsrpydanticrdotenvrapp.logging_configr app.utilsr app.dbr app.llmr app.utils.puja_session_utilsr INFO getLoggerrr)appadd_middlewarerpostr4rUrrrrs8          (