' jendZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlZddlZejdejejzZejdejZdDd ZddlmZddlmZddlmZddlmZddl m!Z!m"Z"ddl#m$Z$ddl%m&Z&ddl'm(Z(ddl)m*Z*m+Z+ddl,m-Z-m.Z.m/Z/ddl0m1Z1m2Z2ddl3m4Z4e(dZ5eGddZ6e&e6ej7de4ddd !Z8e8j9dEd'Z:e8j9dFd(Z;e8j9dGd*Ze8j9dId3Z?dJd6Z@dKd:ZAdLd<ZBe$e8e5jCe5jD=ZEeEFed>gd>gd>g?eEGd@eAdAgBeEGdCeBdAgBdS)MuYUI Agent — visualisation renderer for Enterprise Brain. Receives raw query rows and a plain-text explanation from a data agent (e.g. Tatasteel) and turns them into a frontend-ready widget stream. Endpoints: POST /query — sync: returns widget list JSON POST /query/stream — SSE: streams text tokens then emits the widget ) annotationsN) dataclassfield)Path)Anyz```mermaid\s*\n(.*?)\n```z textstrreturntuple[str, list[str]]cgdfd }t||}td|}|fS)aStrip
tags and extract mermaid code blocks from *text*. Returns: (cleaned_text, list_of_mermaid_diagrams) Each extracted diagram is emitted as a ``{"type": "mermaid"}`` widget so the frontend can render it natively instead of parsing raw markdown. mre.Matchr r c||ddS)N)appendgroupstrip)r diagramss D/var/www/html/ai-enterprise-brain/backend/chanakya/ui_agent/agent.py_pullz!_split_explanation.._pull(s0 ((**+++rr)r rr r ) _MERMAID_REsub _BR_TAG_REr)rrcleanedrs @r_split_explanationrsgHooeT**GnnR))//11G H r)logger) RunContext)CORSMiddleware)Request) JSONResponseStreamingResponse)make_metadata_aware_app)EnterpriseAgent)AGENT_REGISTRY)deserialize_historyload_conversation_history)VALID_CHART_KEYSvalidate_chart_contentvalidate_highlight_content)AgentQueryResponseUIRenderRequest)make_ui_agent_instructionsui_agentc&eZdZUdZeeZded<dZded<dZ ded<dZ ded <eeZ d ed <eeZ ded <dZ ded <eeZded<edZded<edZded<dZded<dS) UIAgentDepsz%Per-request context for the UI agent.)default_factoryzlist[dict[str, Any]]rowsrr question explanationmarket_context list[str]storyline_hintsdecision_support_contextdc_explanationwidgetsN)defaultz int | Nonepending_visualization_slotzasyncio.Queue | Noneprogress_queueGBP currency_code)__name__ __module__ __qualname____doc__rlistr3__annotations__r4r5r6r8r9r:r;r=r>r@rrr1r1Hs'//!&t!+>+>N>>>>Mrr1LITELLM_PROVIDER_BASE_URLzchanakya-alphazui-agent) deps_typeapi_base instructions logfire_env service_nameretriesctxRunContext[UIAgentDeps] chart_typecontentdict[str, Any]cK|}|tvrd}|jj}||d|dd{V|s<|jjd|dddtj d |d St| d tr^t|d d hkr7|d }d | d |i|}tjd || d |krKtjd| d |d |id|D}|jjH|jjdddt%|jjdz |j_|jj} t'|}|}n#t*$r}d|dcYd}~Sd}~wwxYwd|d|jj|<d|j_tj d||t%|jjdS)uqStore a frontend-ready visualisation widget. The agent is responsible for constructing ``content`` according to the exact ``BaseVisualizationConfig`` schema for the chosen ``chart_type`` (schemas are listed in the system prompt). This tool simply validates the type key and records the widget so the HTTP handler can return it. Args: chart_type: One of the supported chart keys (e.g. ``contract-bars``, ``status-arc``, ``variation-split``, …). Used only for the ``widget_loading`` progress event; the ``"type"`` field inside ``content`` is the authoritative discriminant. content: Fully-formed ``BaseVisualizationConfig`` dict — constructed by the agent by mapping SQL row columns to the schema fields shown in the system prompt. z multi-metric-constellation-chartNwidget_loading)type widget_type visualizationT)rW_emptyrWrSz0build_visualization empty content, chart_type={}zNo data to visualise.rSrWzFbuild_visualization: unwrapped double-nested content for chart_type={}zFbuild_visualization: content missing/wrong type ({!r}), injecting {!r}c&i|]\}}|dk ||S)rWrG).0kvs r z'build_visualization..s#!R!R!R41aa6kk!Qkkkr)rW_pendingrSchema validation failed: u Only the fields listed above are wrong — keep all other fields exactly as they were. Fix only the failing fields and call build_visualization again with the corrected content.z:build_visualization chart_type={} slot={} total_widgets={}z Widget built.)rlowerr)depsr>putr;r_logdebug isinstancegetdictsetkeyswarningitemsr=lenr* model_dump Exception) rPrRrSctqinnerslot validatedexcs rbuild_visualizationrxns,      ! ! # #B !!! / A}ee-bAABBBBBBBBB ' # "d33! !     ErJJJ&& 7;;y))400c    FI#6 6 6 "7;;vr22 &@Q@QSVWZW_WgShShiii " "s #A// B 9B>B B columnsr7 column_keys currency_keysc KstjddSstjddSttkrStjdttdtdtdS|jj}|stjd d St |d  fd D}|s;}tjd |t d|dt dS fdD}|rtjd|d'd fd|D}t | fdtD} |jj D]} | ddkrq| di dkrD| di d|krtjdd S|jj dd|| d!d"tj d#tt|t|jj d$td%t|d&S)(uRender a data table using ALL rows from the query result. Call this when the user explicitly asks for a table, or when the data is record-level detail that no chart encodes better (e.g. a list of specific items, a multi-column detail view, raw lookup results). **Do NOT pass rows yourself.** This tool maps every row from the query result automatically using ``column_keys``. You only declare which columns to show and which SQL key each column maps to. Args: columns: Ordered list of human-readable column header strings. Write what a business reader would see — never raw SQL column names. e.g. ``["Contractor", "Cost Impact (£)", "Status"]``. column_keys: Ordered list of SQL column names from the raw query result, corresponding 1-to-1 with ``columns``. e.g. ``["contractor", "change_to_prices", "status"]``. Must have the same length as ``columns``. currency_keys: Subset of ``column_keys`` whose values are monetary amounts (GBP or converted currency). The frontend uses this list to apply compact currency formatting (1K / 1M) to those columns. e.g. ``["change_to_prices", "base_contract"]``. Omit or pass ``[]`` for columns that are counts, days, or text. z)build_table: empty columns list, skippingu&Table skipped — no columns provided.z-build_table: empty column_keys list, skippingu*Table skipped — no column_keys provided.z;build_table: columns/column_keys length mismatch ({} vs {})uTable skipped — columns (z) and column_keys (z) must have the same length.z&build_table: no rows in deps, skippingu*Table skipped — no query data available.rcg|]}|v| SrGrGr]r^available_keyss r zbuild_table..bs#>>>a!~*=*=*=*=*=ruQbuild_table: no column_keys match primary rows — keys={} available={}, skippingu4Table skipped — none of the requested column_keys z7 exist in the primary query result. Available columns: z1. Use only columns from the primary rows dataset.cg|]}|v| SrGrGrs rrzbuild_table..ns#CCCq1N+B+B+B+B+Bru@build_table: some column_keys not in primary rows — missing={}valrr r c(|dSt|S)Nu—)r )rs r_fmtzbuild_table.._fmtrs ;53xxrcLg|]fdtD S)cTi|]$\}}||%SrGri)r]colkeyrrows rr`z*build_table...xs3KKKXS#dd3773<<  KKKr)zip)r]rrrrs @rrzbuild_table..wsL  LKKKKWk1J1JKKKrc"g|] \}}|v | SrGrG)r]rrcurrency_key_sets rrzbuild_table..~s/S@P9P9P9P9P9PrrWtablerSrr3z/build_table: duplicate table detected, skippingu*Table already built — duplicate skipped.)rWrr3currency_columnsr[z,build_table cols={} rows={} total_widgets={}uTable built — z columns, z rows.)rrr r )rfrmrordr3rkrlrEsortedrr;rirrg)rPrrrraw_rowsmatchingmissing unmatched mapped_rowsrexistingrrrs `` @@@r build_tabler*s@ 8 @AAA77 < DEEE;; 7||s;'''' I LL#k**    ?#g,, ? ?K   ? ? ? x}H < =>>>;;!))++,,N>>>>;>>>H    _ T.))    >7 > >8>~8N8N > > > DCCCKCCCId WYbccc K =))55 H$@@ LL G + + Y++// ::gEE Y++//77;FF LJ K K K???H 0    J6 G c+&&CH,<(=(= Oc'll N Nc+6F6F N N NNrcolumn operationcK|jjsdStj|jj}||jvrd|dt |jStj||d}|jrd|dS | |}n #t$r}d|d|d cYd }~Sd }~wwxYw|d |d |S) umCompute an exact aggregate over a numeric column in the row data. ALWAYS call this tool instead of computing totals, averages, counts, medians, or any other arithmetic mentally from the raw rows. Supported operations: sum, mean, median, min, max, count, std, var. For grouped aggregates (e.g. sum per category), call this once per group filtering is not needed — pandas handles mixed types gracefully. Args: column: Column name from the row data to aggregate. operation: Aggregation function — one of: sum, mean, median, min, max, count, std, var. zNo row data available.zColumn 'z ' not found. Available columns: coerce)errorsz' has no numeric values.z Operation 'z ' failed: z:. Supported: sum, mean, median, min, max, count, std, var.N(z) = ) rdr3pd DataFramerrE to_numericdropnaemptyaggrq)rPrrdfseriesresultrws rcompute_aggregaters( 8=('' chm $ $B RZT&TT$rzBRBRTTT ]2f:h 7 7 7 > > @ @F |;:&::::rI&& rrrqYqq#qqqqqqqqqr . .& . .f . ..sB$$ C.B<6C<Creq'UIRenderRequest'cd|jd|jd|jg}|jr|d|jz|jr/|dt j|jz|jr|d|jz|j r:|dd d |j Dz|j r|d |j z|j r|d |j z|d t|jd t j|jd |S)z'Build the full prompt for the UI agent.z Question: z Currency: zData agent explanation: usMarket & Industry Context (sourced from live web search — weave benchmarks and comparisons into your narrative): ziDecision Support Context (additional Tata Steel analysis datasets gathered after the main answer query): uDecision Context Mapping (for your background reasoning only — DO NOT emit a build_text widget for this content; it is automatically rendered in a separate hidden panel): uAction items (highest-priority items the user should act on — surface the top item as a build_primary_highlights block and list the rest via build_key_highlights):  c3 K|] }d|V dS)z- NrG)r]as r z#_build_ui_prompt..s(==QQ======ruyUrgency signal (use this to write the build_text narrative — emphasise the deadline or financial risk described here): z8Cost of inaction (weave into the build_text narrative): zRows (z total):  )r4r@r5r6rr9jsondumpsr:what_to_act_onjoinurgencycost_of_inactionror3)rpartss r_build_ui_promptrs $S\##(S&((43?44 E     G  !    #  xj566 7       6  !       aii==#*<===== >    {   3k       G" #    LLH#ch--HH$*SX2F2FHHIII ;;u  rrequestr!r"c K |d{V}tdi|}nQ#t$rD}tt jd|ddcYd}~Sd}~wwxYw|jt|j}nt|j d{V}t|j |j |j|jpd|jpg|jpg|jpd|j}t)|} t+jd |j dd  5t.j||| d{V}dddn #1swxYwYnn#t$ra}t5jd |tt jt9|dcYd}~Sd}~wwxYwt;|j\}} d|jD} t?d| D} g} | s|r| d|d| d| Dz } | | z } |jr| d|jd|jr| d|jdtt j!| S)u1POST /query — sync render: returns widget list.NInvalid request: PIPELINE_ERRORmessagecode status_coder)r3r4r5r6r8r9r:r@{q}xrsrdmessage_historyzui_agent render error: {}c<g|]}|d|Srarr]ws rrz#_render_handler.."s)GGGAQUU:5F5FGaGGGrc3HK|]}|ddkVdSrWrNrrs rrz"_render_handler..#s1JJa!%%--61JJJJJJrrr[cg|]}d|dSmermaidr[rGr]ds rrz#_render_handler..'s DDDaq11DDDrfollowup_questionsfollowup_explanationr;rG)"rr-rqr"r,failurerphistoryr'r(conversation_idr1r3r4r5r6r8r9r:r@rlogfirespanr/agentrunrferrorr rr;anyrsuccess) rbodyrrwrrdpromptr clean_textrfilled_widgetshas_text_widgetr;s r_render_handlerrs  \\^^######%%%%      &1C118H   jll            {-ck:: 9#:M N NNNNNNN  XO)/R+1r!$!=!C)/R'   Dc " "F \%3<#5 6 6 6 b b#>--f4Q`-aaaaaaaaF b b b b b b b b b b b b b b b     .444  &s3xx>N O O O Z Z \ \         .co>>JGGGGGNJJ>JJJJJO$&G @z@:>>??? DD8DDDDG ~G W 4ATUUVVV X 63CUVVWWW *27CCCNNPP Q QQs]&+ A99A4.A94A9 #E-,)E! E-!E%%E-(E%)E-- G7AG GG StreamingResponse | JSONResponsec K |d{V}tdi|nQ#t$rD}tt jd|ddcYd}~Sd}~wwxYwjtjntj d{Vtj tjjjjpdjpgjpgjpdj t-fd }t/|d d d d S)uPOST /query/stream — SSE streaming render. SSE events (server → client, in order): data: {"type": "widget_loading", "widget_type": str} data: {"type": "text_chunk", "content": str} data: {"type": "widget", "widget": {...}} data: {"type": "done", "success": true, "widgets": [...]} data: {"type": "error", "message": str, "code": str} Nrrrrrr) r3r4r5r6r8r9r:r>r@cKgtjtjdfd}fd}tj|}tj|} d{V}|ndt j|dWV9tj||dd{VrdSd}t|\}}d j D}td |D} g} | s|r| d |d | d |Dz } |D]5} dt jd| ddWV| | 6j r=dj d } dt jd| ddWV| | jr=djd } dt jd| ddWV| | dt jdditj| dWVdS)NFcKst tjdd{V}|d{Vn#tj$rYpwxYwtsAd{VAdd{VdS)Ng?)timeout)is_setasynciowait_forrire TimeoutErrorr get_nowait)event agent_donemergedr>s r_drain_progresszC_render_stream_handler..sse_events.._drain_progress`s: '')) ")"2>3E3E3G3GQU"V"V"VVVVVVVE **U+++++++++++H !''))  %**,, >jj!:!:!**T"" " " " " " " " " "sA A##A54A5cK tjd jdd5tj 4d{V}|d23d{V}|d|dd{V;6 dddd{Vn#1d{VswxYwYdddn #1swxYwYnZ#t$rM}tj d |dd t|d d d{VYd}~nd}~wwxYw dS# wxYw) NrrrrT)delta text_chunkr[z ui_agent stream render error: {}rr)rWrr)rrr4r/r run_stream stream_textrrerqrfrr rk) streamchunkrwrrd full_text had_errorrrrrs r _run_agentz>_render_stream_handler..sse_events.._run_agentks !\%3<+=>>>WW'~88d\k8llWWWWWWWpv+1+=+=D+=+I+IWWWWWWW%%,,U333"(**lu-U-U"V"VVVVVVVVV,J+IWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWWW  c c c =sCCC jj'c#hhP`!a!abbbbbbbbbbbbbb c          s#C )CB7(B#.6B7%C7 C CC C C CC CC E D7*AD2-E2D77EE&Tzdata: r)return_exceptionsrc<g|]}|d|Srrrs rrz>_render_stream_handler..sse_events..s)KKKz9J9JK!KKKrc3HK|]}|ddkVdSrrrs rrz=_render_stream_handler..sse_events..s1NN!aeeFmmv5NNNNNNrrr[cg|]}d|dSrrGrs rrz>_render_stream_handler..sse_events..s HHH!Y155HHHrwidget)rWr rrrWdoner)rQueueEvent create_taskrirrgatherrrr;rrr8r:r,rrp)rr drain_task agent_taskitem agent_textrrrrr;rfqferrrrrdrr>rrs @@@@r sse_eventsz*_render_stream_handler..sse_eventsZs:! ' ]__   # # # # # # # ! ! ! ! ! ! ! ! ! ! ! !():):;; (66  2%%%%%%D|14:d++111 1 1 1 1  2 nZtLLLLLLLLLL   FWWY'' 1*== HKKT\KKKNN~NNNNN(* D: D NNFzBB C C CHHxHHHH  AL4:x1&E&EFFLLL L L L L NN1       .3;NOOBM4:x2&F&FGGMMM M M M M NN2      0S=OPPBM4:x2&F&FGGMMM M M M M NN2   utz66"n5G5OX_5`5`5`5k5k5m5m"noouuuuuuuuurztext/event-streamzno-cacheno)z Cache-ControlzX-Accel-Buffering) media_typeheadersrG)rr-rqr"r,rrprr'r(rrrr1r3r4r5r6r8r9r:r@rr#) rrrwrrdrr>rrs @@@@@r_render_stream_handlerr1s  \\^^######%%%%      &1C118H   jll            {-ck:: 9#:M N NNNNNNN$+MOON  XO)/R+1r!$!=!C)/R%'   Dc " "FIvIvIvIvIvIvIvIvIvV  &",4HH   s&0 A>9A93A>9A>)name description*) allow_origins allow_methods allow_headersz/queryPOST)methodsz /query/stream)rr r r )rPrQrRr rSrTr r )rPrQrSr r r )rPrQr{rTr r ) rPrQrr7rr7rr7r r )rPrQrr rr r r )rrr r )rr!r r")rr!r r)HrD __future__rrrosre dataclassesrrpathlibrtypingrpandasrrcompileDOTALL IGNORECASErrrlogururrf pydantic_airstarlette.middleware.corsr starlette.requestsr!starlette.responsesr"r#backend.chanakya.a2a_contextr$backend.chanakya.baser%backend.chanakya.configr&&backend.chanakya.conversation._historyr'r()backend.chanakya.nl2sql_core.chart_configr)r*r+backend.chanakya.schemasr,r- backend.chanakya.ui_agent.promptr._cfgr1environr/toolrxrzrrrrrrrrrappadd_middleware add_routerGrrrAs-#""""" (((((((( bj5ry2=7PQQ RZ bm 4 4 &"!!!!!""""""444444&&&&&&????????@@@@@@111111222222aaaaaaaa IHHHHHHHGGGGGGj!   6 ? Z3 4++--      SSSSl & )')')')'X !#!#!#!#F  " nOnOnOnOnOb $/$/$/$/T++++b6R6R6R6Rrxxxx|   %%%  h& ::: o5x HHHHHr