qujudZddlZddlZddlZddlZddlmZddlmZ ddl m Z ddl m Z mZmZmZmZmZddlmZddlmZmZmZdd lmZdd lmZdd lmZdd lm Z m!Z!dd l"m#Z#ddl$m%Z%m&Z&ejNe(Z)dZ*ddddddddidgdddddddddddddddddgd d!dd"ddd#ddd$dd%gd&ddddd'd(ddd)ddd*dd+d,d-gddddd.d/dd0dd1did0gddddd2d3ddd4ddd5ddd6dd7gd7ddddd8d9dd:d;ddd?gdd@id:gdddddAdBdddCdddDddEdFgdddddGdHdddIdddJddKdgdddgZ+dLZ,dMZ-dNZ.dOZ/dPZ0dQZ1dRZ2dSe3fdTZ4dUZ5dVZ6dWZ7dXZ8e,e-e/e0e6e1e7e8dYZ9dZZ:y)[zNative tool-calling layer: schemas + executors for actions the chat model can take. Replaces the legacy fenced signal blocks (ticket_creation_signal, etc.). N)settings)client)TICKET_CONSOLIDATION_PROMPT) create_ticket get_ticketget_ticket_by_threadinsert_feedbacksearch_vector_data update_ticket download_link)email_configuredis_valid_email send_email)get_email_settings)get_embeddings)set_intervention_status)search_productsto_card)QuotaExceededError)get_redis_client publish_event)zdon't have enough informationzdo not have enough informationfunctionsearch_knowledge_baseuSearch this business's knowledge base for facts. You have NO built-in knowledge about this business — its products, pricing, services, features, policies, hours, contact details or support processes are ONLY available through this tool. You MUST call it before answering any question about the business. If the results do not answer the question, call it again with a differently worded or more specific query before concluding you cannot answer. Returns matching content chunks, each with its source URL.objectquerystringzeWhat to search for. Use the user's own wording, or a rephrasing targeting the specific fact you need.)type description)r propertiesrequired)namer parameters)rrcreate_or_update_ticketu0Create a support ticket, or update the session's existing ticket with a new issue. Use when the user reports an issue/complaint/bug, or wants to book a demo/meeting or contact the team/sales. ASK THE USER WHAT THE ISSUE IS before raising a ticket. Do not assemble the problem description from context or assume what went wrong — if they have only said something vague like 'it is broken', ask them what exactly is happening. The content field must be their own account of the problem, not your guess. Alongside that, collect their email address and phone number (and their name if not already known); ask for what is missing together rather than one question per turn. Never reuse an email or phone number that came from search results or a document — only what the user gives you here. You may write the short heading yourself, and set priority from how they describe the urgency. STOP ASKING once you have (a) their description of the problem and (b) their email and phone — call this tool immediately in that same turn. Do NOT then ask for a website URL, error messages, screenshots, what changed, or any other extra detail: the support team will follow up for those. One or two questions total, never an interrogation. If the session already has a ticket, do NOT re-ask contact details; just ask what the new issue is.z User's namezShort ticket headingzDetailed issue description)LowMediumHigh)renumzUser's email addresszUser's phone numberzOptional other contact info) user_nameheadingcontentpriorityemail contact_noany_other_contact_mediumr*r+r,submit_feedbackuStore the user's feedback about this conversation or the service. You MUST call this tool whenever the user expresses satisfaction or dissatisfaction — whether or not you asked them for it. That includes: any rating ('5 out of 5', '4/5', 'I'd give it a 3'), any verdict on whether you helped ('that was helpful', 'this didn't help at all', 'you've been useless'), and any praise or complaint about the service. Thanking the user in text WITHOUT calling this tool loses their feedback permanently — the reply text is not stored anywhere as feedback. Set `question` to what you asked, or to a short description of what they were reacting to if they volunteered it unprompted. Do NOT call this for a plain 'thanks'/'ok' that carries no opinion about the service.zThe feedback question askedzThe user's feedback answer)questionanswerr2r3request_human_takeoveruNotify a real human team member to join this conversation. This is the ONLY way a human is actually notified — saying so in text without calling this tool notifies no one. Call it immediately, in the same turn, whenever the user explicitly REQUESTS a human/real person/agent/someone from the team (e.g. 'can I speak to someone', 'I want to talk to a real human', 'this isn't helping, connect me with your team'), or when the request is too complex or unsafe for you to handle safely. Do NOT call this for a QUESTION merely asking about human handoff capability (e.g. 'can this be escalated to a person if needed?', 'do you support human takeover?') — answer questions like that from context instead. Keep helping the user until the human joins.reasonzWhy human help is neededruEmail information to the user. Use ONLY when the user explicitly asks for something to be emailed to them (e.g. 'email me this', 'can you send that to my inbox', 'mail me the pricing'). Before calling: you MUST have searched the knowledge base for the content, and you MUST have the user's email address and have confirmed it back to them in your previous message ('Shall I send it to x@y.com?'). Never guess or invent an address, and never email an address the user did not give in this conversation. The `body` must be written ONLY from knowledge-base search results and what was already said in this conversation — never invent facts, prices or policies to fill out the email. If the knowledge base does not contain the information, tell the user instead of sending a made-up email. NEVER offer to email, and never call this tool, when your answer is that you could not find the information — an email saying you do not know is worse than no email. Offer a ticket or a human instead.z3The recipient address, exactly as the user gave it.z@Short, specific subject line, e.g. 'GalaxiQ BrandForge pricing'.zPlain text body written from knowledge-base content. Use short paragraphs; '- ' at line start for bullets. Include the source URLs where relevant. No greeting placeholders like [Name].)to_emailsubjectbodyattach_resourcesuAttach the source URLs/images your answer relied on so the frontend can render them as clickable buttons or image cards. Every result returned by search_knowledge_base carries a 'source' and may carry an 'images' list. ONLY attach a source that is a real web address starting with http:// or https://. A source that is an uploaded file name such as 'Pricing Sheet.docx' or 'policy.pdf' is NOT a URL -- never pass it here, because it produces a card that leads nowhere. To give the visitor an uploaded file, use send_document instead. You MUST call this tool, in the same turn as your text answer, whenever you used a search result that has a source URL or an image to produce your answer — this is REQUIRED, not optional, any time the context you drew on has a source. Never write the raw URL or image link directly into your reply text instead of calling this tool; the link belongs in the tool call, and your reply text should read naturally without it. Only include resources that directly relate to the current answer, and keep a URL and its matching image in the same object. Skip this tool only when no search result you actually used has a source URL or image. resourcesarrayrnull)urlimagelabelr?)ritems send_documentu%Give the visitor the actual uploaded file — the brochure, price list, spec sheet or policy PDF itself — as a download link, rather than only describing what is in it. Call this when the visitor asks for the document ('do you have a brochure?', 'send me the pricing PDF', 'can I get that as a file?'), or when you have just answered from a document and handing them the original is obviously useful. Search the knowledge base FIRST: every result carries a 'source', and when that source is an uploaded file name (something ending in .pdf, .docx and so on) that is exactly what you pass as file_name. Never invent a file name — only use one you have actually seen in a search result. If the tool reports the document was not found, tell the visitor the file is not available and do not make up a link.z`Exact file name as it appeared in the 'source' field of a search result, e.g. 'pricing-2026.pdf'z#Briefly, what the visitor asked for) file_namer5rBrecommend_productsaShow the visitor actual products, plans or services as cards they can act on, with the business's own buttons. Call this when the visitor is asking WHICH thing to get rather than asking ABOUT something: 'what do you have', 'show me', 'do you sell X', 'which plan suits me', anything with a budget or a category. Do NOT call it for a question about a product they already named -- 'what does BrandForge do', 'does it integrate with Shopify' -- that is search_knowledge_base, and answering in prose is correct there. The tool returns only products this business actually has. If it returns none, say so plainly; never name a product, quote a price, or describe a button that did not come back from this tool.z3What the visitor is looking for, in their own wordsz4Category to narrow to, only if the visitor named one)rcategoryc8K|jdxsdj}|sgdddS t||d|jd}t|d|d }g}|xsgD]}|jdxsi}|jdxsg} g} | ddD]Z} t| tr&| jdr| j| d9t| tsJ| j| \|j|jdd|jdxs|jdxsd| d|t||sddSddS#t$rt $r*}t jd |d gdddcYd}~Sd}~wwxYww)zBRetrieval as a model-chosen action. Returns content, not a status.rrz Empty query.)resultscountnote tenant_iduser_id)rJrKlimitz#Tool search_knowledge_base failed: Texc_infozSearch failed.Nmetadata top_imagesr=r+source source_urlzInternal Knowledge Base)r+rTimageszNNo matches. Try a different wording before telling the user you cannot answer.) getstriprr r Exceptionloggererror isinstancedictappendstrlen) argsctxr embeddinghitsexrGhitmetarV image_urlsimgs 6/var/www/html/strategist-ai/app/services/chat_tools.pyexecute_search_knowledge_baserk2s XXg  $" + + -E >BBE"5C 4DcggV_N`a !#k"2IQGGzr  wwz"(b,'-2 "1: 'C#t$!!#e*-C%!!#&  ' wwy"-hhx(_DHH\,B_F_     Wb &*  +  E :2$?$ O3CDDEs<,F1E BF&A5FF-F F FFFcLK|d}|d}|jd}|jd} t||}|rS tj|d|d|d|d}tj j jtjd|d gd }|jd jjj} | jd djddj} tj | } | jd|d| jd|dd|d|dd} t)||d| } | r(t+||ddd|ddd{d|ddSd|ddSt-|}dt/j0j2ddj5|d<|r||d<|r||d<t7|||}|r't+||dd d!|dd{d"|ddSdddS#t"$r:} t$j'd| |d|dd|d|dd} Yd} ~  d} ~ wwxYw77Y#t8$rt"$r)}t$j'd#|d$%dddcYd}~Sd}~wwxYww)&zDCreate a new ticket, or consolidate into the session's existing one.rJ thread_idr)rKr*r+) old_heading old_content new_heading new_contentuser)roler+i )modelmessagesmax_completion_tokensrz```jsonrFz```z --- r,r0zConsolidation LLM call failed: z --- [Update]: N ticket_idticket_updatedzTicket z& has been consolidated with new issuesupdated)statusrwr[zTICK-)rmnew_ticket_createdzA new ticket has been created: createdz%Tool create_or_update_ticket failed: TrO)rWrrformat openai_clientchat completionscreater LLM_MODELchoicesmessager+rXreplacejsonloadsrYrZr[r _publish_ticket_eventr]uuiduuid4hexupperrr)rarbrJrmr)rKexisting cons_prompt cons_responserawcons update_datacons_exsuccess ticket_datanew_idres rjexecute_create_or_update_ticketrWsK IK I $Iggi G36' 9=  9@@ ( 3)AT $YT)_ !. 2 2 > > E E",,'-+FG*-!F! $++A.66>>DDFkk)R088CIIKzz##xx 4 ?C#xx hy6I5J)TXYbTcSd3ef $Z 0 $Ix /DkRG+Ix 7LN^.5h{6K5LLr,suuu"+(;:OPP%H[4IJ J4j %*4::<+;+;BQ+?+E+E+G*H#I K '0K $ %,K "y+K ' ;{3KMa*I+VaJbIc(df f f'k+6NO O!553  >wiHI#I"*9"5!66J4PY?J[\ $Z 0  u f  6  I& J$ I&J$A8I& I$ I&J$I&J$ I%/II&II&$I&&J!8JJ!J$J!!J$cK t||}|rtd|dd|||dd{yy7#t$r%}tj d|d|Yd}~yd}~wwxYww)Ntenant_z:ticketssystemreventrdatazFailed to publish z to redis: )rrrYrZwarning)rJrwrrfullws_errs rjrrsH)Y/ ')H =)1Eg_c df f f  f H+E7+fXFGGHs6A$&313A$3 A!AA$A!!A$cK|d}|d}|jd}|jdg} |d|d||d}i}|r9tdt|Dd td t|Dd d }d |d |d<t||ddiS#t$r(}t j d|d ddicYd }~Sd }~wwxYww)z-Store explicit user feedback for this thread.rJrmr)historyr2r3)r2r3rmr)c38K|]}|ddk(s |dyw)rsrrr+N.0ms rj z*execute_submit_feedback..s#(h!TUV\T]agTg9(h  Nc38K|]}|ddk(s |dyw)rs assistantr+Nrrs rjrz*execute_submit_feedback..s#)n1UVW]U^bmUm!I,)nr)last_user_querylast_ai_responseT)is_explicit_feedbackrated_conversationrQrzsavedzTool submit_feedback failed: rOr[)rWnextreversedr rYrZr[) rarbrJrmr)r feedback_datalast_interactionres rjexecute_submit_feedbackrsK IK I $Iggi$G#%)*%5h&/iI  #'(hx?P(hjn#o$()n@Q)npt$u  >BYi$j j! =1'"" # 4RD9D I'""#s5.CA!BC CB?9C:C?CCc K|d}|d}|jd} t||d| td|ddd d |||jd |d d d{ddiS7#t$r"}tj d|Yd}~,d}~wwxYw#t$r(}tj d|dddicYd}~Sd}~wwxYww)z@Flag the thread for human intervention and notify the dashboard.rJrmrKT)rKrz:conversation_listrintervention_requestedz-AI has requested human assistance for thread r5)rmr5rKrNz1Failed to publish intervention request to redis: rzflaggedz$Tool request_human_takeover failed: rOr[)rWrrrYrZrr[)rarbrJrmrKrres rjexecute_request_human_takeoverrsK IK Iggi G # 9dGL Y')4F G +CJ9+V&/488H;MZabJ  )$$   Y NNNvhW X X Y # ;B4@4 P'""#soC B.A(A&A("B%C &A(( B1B BBB CC<C=C CC cpK|jd}t|tr t|nd}d|dSw)zJResources are collected by the chat loop; this only acknowledges the call.r:rattached)rzrH)rWr\listr`)rarbr:rHs rjexecute_attach_resourcesrs3%I(D9C NqE 5 11s46cd|d|S)Nz chat_emails::r)rJrms rj_email_count_keyrs )Ai[ 11returnc K t}|jt||d{}t|xsdS7#t$r5}t j d|d|tjcYd}~Sd}~wwxYww)aHow many emails this conversation has already sent. Only consulted when a cap is configured. Fails CLOSED on a Redis outage: if we cannot prove the conversation is under the limit, we refuse rather than risk turning the chat into a mail relay. NrzCould not read email count for : ) rrWrintrYrZr[rEMAIL_MAX_PER_THREAD)rJrmrvalueres rj_emails_sent_in_threadrsu-!#jj!1)Y!GHH5:AI - 6ykB4HI,,,-sCB(AAABA B *A;5B6B;BBcKt||} t}|j|d{}|dk(r|j|dd{yy7%7#t$r%}t j d|d|Yd}~yd}~wwxYww)Ni: z Could not record sent email for r)rrincrexpirerYrZr[)rJrmkeyrrHres rj_record_email_sentrs 9i 0CK!#kk#&& A:--%56 6 6 ' 6 K 7 {"RDIJJKsP B AAA AAB AA B!B<B BB c*K|jdxsdj|jdxsd|jdxsdtdjdds tj ddd d d St sd d d St s d d dd Sjsd dd StfdtDr,tjdjdd dd Stj}|dkDrtddd{nd}|dkDrB||k\r=tj dtjdjdd dd Stjjfdd{}|jddk(rDt!ddd{tjddjd|S77`74w)zEmail knowledge-base content to an address the user gave in this conversation. Rate-limited per conversation so a misbehaving model cannot turn the chat into a mail relay. r6rFr7r8rJenabledTz%send_email called while disabled for r[zOEmailing is turned off for this business. Tell the user you cannot send emails.rzdetailzBEmail is not configured. Tell the user you cannot email right now.'z;' is not a valid email address. Ask the user to confirm it.z Refusing to send an empty email.c3BK|]}|jvyw)N)lower)rmarkerr8s rjrz%execute_send_email.. s @f6TZZ\ ! @sz2Refusing to email a no-answer response for thread rmuThere is nothing useful to email — the knowledge base did not answer this. Tell the user you could not find the information, and offer to raise a ticket or connect them with the team instead.rNz Email limit (z) reached for thread zfEmail limit reached for this conversation. Tell the user you cannot send any more emails in this chat.cHtjddS)Nr)rJ) first_namerJ)rrW)r8rbr7r6srjz$execute_send_email..s'JxRV&)ggk&:c+FV5Xrrzsentz Chat emailed for thread )rWrXrrZrrranyREFUSAL_MARKERSinforrranyio to_threadrun_syncr)rarbrN already_sentresultr8r7r6s ` @@@rjexecute_send_emailrs= $*113Hhhy!'RG 88F  !rD c+. / 3 3It D>s;?O>PQR!)* *  !^` ` ( #!hZ'bce e ::<!-OPP @ @@ HQ\I]H^_`!RS S  ) )EW\_`W`/K0@#kBRSSSfgL qy\U*H99::OPSPWPWXcPdOe f "?@ @??++-XYYF zz(v% [!13{3CDDD mH:\#''+:N9OPQ MTY Es7D2H8H 9A5H.H/-HH1HHHctK|jdxsdjsdddStjj fdd{}|s't j dd d d d d dSt j d|ddjdddi|S7`w)zFTurn a file name into a temporary download link the visitor can click.rBrFr[zNo file name given.rc"tdS)NrJr )rbrBsrjrz'execute_send_document..,s c+. :rNz'send_document: no stored file matching  for rJ not_foundzNo uploaded document named z-. Tell the visitor the file is not available.zsend_document: rrmrzr)rWrXrrrrZr)rarblinkrBs ` @rjexecute_send_documentr%s+&,"335I !-BCC)):< .>sK 0%qArNz$recommend_products: nothing matched rrJnonezWThis business has no matching products. Tell the visitor plainly and do not invent one.)rzproductsrzrecommend_products: rrmfound)rzr) rWrXrrrrZrrr`)rarbrowsrrrs ` @rjexecute_recommend_productsr8s XXg  $" + + -E))AC CD  :5)D{+,. / b;< <%))q )H) KK&s8}o\#''+BVAWXY8 44 C*s$A CC .C=C ;C C)rr$r1r4rr9rArCcKtj|}|tjd|dddS|||d{S7w)zQRoute a model tool call to its executor. Returns a JSON-serializable result dict.Nz!Unknown tool requested by model: r[z unknown toolr)TOOL_EXECUTORSrWrZr[)r"rarbhandlers rj dispatch_toolrWsM  &G 8?@!^<<s# ## #sAA AA );__doc__rloggingrrapp.core.configrapp.core.llm_clientrrapp.core.promptsrapp.services.databaserrrr r r app.services.documentsr app.services.email_servicerrrapp.services.tools_settingsrapp.services.embeddingrapp.services.firestore_servicerapp.services.productsrrapp.services.quotasrapp.services.redis_servicerr getLogger__name__rZr TOOL_SCHEMASrkrrrrrrrrrrrrrrrrrjr sV  $781SS:1B:2F   8 $+M! ((O%I  6-$,!*2=!Q(0AWX(0A]^)1;T U&.?UV+3DY"Z9ARo0p? 1% (T%h!)1B_ `'/@\](2  4,?!x@Z[&J  2  ? !!)'\! !)'i  !)T$<)%( +Z&-"! '$,(.60B'C*08V2D)E*0();+ *1 " " )M!'% (T# O!!))Q" !)'L )M  D( @!!)'\ !)']! %I   WL ^"J96xH#.#*22 -# - K3l&&5(;>.<$0*4 $r