qujl:.ddlZddlZddlZddlmZddlmZmZddlmZddl m Z ddl m Z ddlmZddlmZmZdd lmZdd lmZmZmZmZmZdd lmZmZmZdd lm Z m!Z!m"Z"dd l#m$Z$ejJe&Z'dZ(de)fdZ*dde+de+de+de+de+de+de+fdZ,y)N)datetime)ListDict)BadRequestError)settings)client)chat_system_prompt) TOOL_SCHEMAS dispatch_tool)disabled_tools_for)get_latest_summaryget_ticket_by_threadinsert_feedbackinsert_llm_usageinsert_summary)get_chat_historysave_chat_messageget_takeover_status) check_quotaQuotaExceededErrorestimate_text_tokens) publish_eventreturnct|ddxsi}t|tr*|jdxs|}|jddk(rydt |vxs dt |vS)zd6d7?c}$d8|j4D]}$ tAjB|$j:j>}%|$j:j<d:k(r`|%jKd;g}&tM|&tNr|jQ|&n,tjId|$j8tAjX|'d?@dA|$j:j<dBk(r?tM|'tZr/|'jKdCdDk(r|j|'dE|'dFd2dG|$j:j<dHk(stM|'tZs|'jKdCdIk(s|jQ|'dJtjIdKt"dL|dM|dN|sdO}t]|dPt^j`||||zdQ|it |d&|||d| tc|||||dR|dSdT|ru |||xsdXd5d?tijjjmtijjjm|d2dYdZzd[})d#d\d]|)d^}*tod_|d`|*d2{||||dbScc}w7cc}$w#t@jDtFf$r2tjId9|$j:j<i}%YwxYw7:#td$r(}(tjgdU|d/|(dVWYd2}(~(d2}(~(wwxYw7#td$r"}+tjIda|+Yd2}+~+d2}+~+wwxYw#tp$r},tjIdc|,d2},~,wtr$rY}-tu|-r$tjIdd|dedfggdgcYd2}-~-Stjgdh|-dVWdiggdgcYd2}-~-Sd2}-~-wtd$r*}.tjgdj|.dVWdiggdgcYd2}.~.Sd2}.~.wwxYww)kzY Core RAG-based chat logic with AI ticketing and mandatory integrated analytics. z#Processing chat request for tenant z , user_id z , thread z, user ai_tokens)r/rai_conversationsadminzIAdmin response detected. Logging to Firestore and skipping AI processing.zAdmin InteractionzMessage saved successfully.)urlsimages)text resourcesuserzThread z: is under human takeover. Logging message and skipping AI.z User Interaction (Human Handled)z:Human takeover active. A real person will respond shortly.zChat Interactionz* [SESSION CONTEXT: A support ticket (ID: ticket_idz) is already active for this session. Do NOT ask for the user's name, email, or phone number again as we already have them. Only focus on the new issue details if the user reports something else.]z> [USER INFO: The person you are talking to identification is z. Do NOT ask for their name.]z(Updating location preference for tenant z to: r0z' [LANGUAGE: Use professional business z^ English. Adapt your vocabulary, tone, and spelling to align with local business standards in z=. Prefer English unless context strongly suggests otherwise.] brand_personazU [BRAND PERSONA: You must strictly follow these personality traits while answering: ]system)r.contentr. assistantr> ai_responsesc3RK|]}t|jdd!ywr>Nrr#.0msgs r' z$get_chat_response..ts"#eUX$8B9O$P#es%')r/requested_amountfunctionnamezTools disabled for z: zCalling LLM with tool loop...)r*r,r-r/historyNc3XK|]"}t|jdxsd$ywrBrDrEs r'rHz$get_chat_response..s)/GJ();)ArB/s(*c|tjjjtj ddS)NrIgN@)modelmessagestoolsmax_completion_tokenstimeout) openai_clientchat completionscreater LLM_MODEL) active_toolsrQsr'z#get_chat_response..s8 **66==",,%&*. >r)rC)rL arguments)idtyperK)r.r> tool_callsz(Malformed tool arguments from model for attach_resourcesr8z0attach_resources returned non-list 'resources' (z ); ignoring.toolF) ensure_ascii)r. tool_call_idr> send_documentstatussent file_nameurl)labelrhimagerecommend_productsfoundproductszTool loop hit the z3-round bound without a final text response (tenant=z , thread=z). Returning fallback text.zaI've noted your request and taken the appropriate action. Is there anything else I can help with?Chatr,rV)interaction_typer/)r,r-questionanswermetadataz1Failed to log interaction to Postgres for tenant T)exc_info Anonymousdz...)r,r/r-summarytakeover_active created_at updated_atlast_message_previewnew_thread_createdzA new conversation has started)r^eventmessagedatatenant_z:conversation_listz'Failed to publish new thread to redis: )r7r8rRrmzQuota exceeded during chat: z4Azure content filter blocked the request for thread .zoI can't help with that request. Please rephrase it, or ask me something about our products, pricing or support.)r7r8rRzBad request to the LLM: z)I encountered an error. Please try again.zError in chat generation: );loggerinforrlenrrr r rrr appendsumr sortedrangeMAX_TOOL_ROUNDSanyio to_threadrun_syncusage prompt_tokenscompletion_tokenschoicesr}r_r>r]rKrLr\jsonloadsJSONDecodeError TypeErrorwarningr#r!listextendr^__name__r dumpsr"rrrYr Exceptionrrutcnow isoformatrrrr()1r*r+r,r-r.r/r0rM is_new_threadis_takeover_activedisabled_tools system_promptexisting_ticket_initialsession_context user_contextcurrent_locationlanguage_contextr;persona_contextrGrole_val content_val display_queryprojected_chat_tokensttool_ctxr8rm tools_used ai_responsetotal_prompt_tokenstotal_completion_tokens round_indexcurrent_projected_tokensresponsertc tool_argscandidate_resources tool_resultpg_errthread_payloadpayloadws_errqebreerZrQs1 @@r'get_chat_responser%s+  KK5i[ 7)S\]f\ggnoxnyz{ucI{G<"9iIG )    #5w G 7? KKc d iz9iQdnu v9QS_aHbc c1IwW $&. KK'),fg h iz9iQs~E FXprAhBC C )T:y)M_ipq ,I6*>: #7y)"L " LMdepMqLrswxO _ ,M ]^g]hiFGL \ )M  KKB9+US[R\] ^ 9j( ;-iD !JK[J\]{|L{MMJ K  - -M*9oF  wyFxGGHIO _ ,M%-@A HC6{H7"&i.K OOX+F G  H# MBC I~w? ##e\d#e ehl lI{GNcd $ '3L! }V4NJLL KK-i[6.;Q:RS T  34!*!*w7T   "# 1O KQ+./NV/,,(I{G-EG#__55HNNE #u':'::#'5+B+BB'""1%--C>>!kk  OO#;;,""nn55**,++*:*:I^I^!_a nn" =# $ 2;;+@+@ AI;;##'99*3-- R*H'!"5t<!(()<= $%8 9 B BC<Q!!"++"2"23$1"++2B2BIx$XX ,0JJ{QV,W!YZ KK$$7&{D9'OOH5?$${;/G-8-?/3&56KK$$(<<&{D9'OOH5@OOK $;,>@S02EH_2_%y1 3 )[+y)Ugqxy s I&&&%17GL (   S!*&!*!9k!',"*//"3"="="?"*//"3"="="?,6t,rs "$7/?:dcUU4   8 $StS{cs{c{c{cdg{cvy{cNQ{cdg{cr)