DWjN^UdZddlmZddlZddlZddlZddlZddlZddl m Z ddl m Z d$dZ d$dZd%d Zd&d Zd'd Zeej&j)d d ZdZdZdZdZehdZej8ZiddddZded<iZ ded<d(dZ!d)dZ"d)dZ#d*dZ$d+dZ%dDcgc]}ejM|ejN c}dDcgc]}ejM|c}zZ(ejLdejNZ)d,dZ*d,d Z+d-d!Z,d.d"Z-d#Z.ycc}wcc}w)/uEntity Dossier — put a profile card of a person/company/concept on the HUD. Two ways in: 1. The brain's ``show_entity(name)`` tool (mcp__entity__show_entity) — Jarvis calls it when Ahmed says "show me Saud" / "who is X / tell me about X". 2. AUTO-SHOW — main.py's listen loop calls ``maybe_autoshow(text)`` on every addressed utterance. When Ahmed names exactly ONE known entity (word- boundary match against a name set refreshed ~every 10 min) and that entity's per-entity cooldown is clear, its card pops on its own. The card is delivered to the HUD as an ``entity_profile`` event: emit("entity_profile", profile={...}) The HUD renders the dossier from that JSON and can send back-channel actions (control/entity_action.json → voice/control.py: drill-down, note, summary edit). SERVER CONTRACT (memory service, GET /profile?name=X → dossier JSON with keys entity, summary, read, quick, relations, timeline, facts_by_kind, tasks, counts, also_matched): - a KNOWN-ABSENT entity comes back HTTP 200 with ``{"entity": null, ...}`` — that is "nothing known", NOT an error: we speak "I don't have anything on X yet" and do NOT emit the event. - an AMBIGUOUS name returns the best entity plus ``also_matched: [names]`` — we name the runner-up in the spoken confirmation so Ahmed can drill down. Everything here degrades gracefully. The network may hang or the route may not exist yet — every call has a hard timeout, swallows errors to a log line, and NEVER blocks the voice loop (the name-set refresh and the auto-show fetch both run on daemon threads; the brain tool wraps the fetch in asyncio.to_thread). ) annotationsN)memory_control)emitc ~|xsdj}|rtjsy tjj |tj d}tjdd|d}t|tr|SdS#t$r'}td|d t|dd Yd}~yd}~wwxYw) u2GET /profile?name=X — the dossier JSON. Hard 3s ceiling. Returns None only on a network/timeout error or when memory isn't configured. A known-absent entity is NOT an error (the server answers 200 with {"entity": null}); that dict is returned as-is and the caller checks the ``entity`` field.NnamegroupGETz /profile?timeoutz$ [entity] profile fetch failed for : d) striprenabledurllibparse urlencode_GROUP_req Exceptionprintstr isinstancedict)r qsoutes ?/Users/ahmed/devFolder/Ultron/claude-voice/voice/entity_show.py fetch_profiler!/s JB   D ~--/ \\ # #N$9$9 :<!!%9RD)91ES$'31T1  4THBs1vds|nMNsA B B<B77B<c |xsdj}|rtjsy tjdd|tjdd}t|tsy|jd }t|tr|SdS#t $r'}t d|d t|dd Yd}~yd}~wwxYw) uPOST /dossier {"name","group"} → {"composed": {...}|null, "cached": bool} — the LLM-COMPOSED dossier (a written narrative over the raw profile). Hard 25s ceiling: composition is 5-12s uncached, instant when cached. Returns the composed dict, or None on a 404 (route not deployed yet), timeout, network error, non-dict body, or a null composition — every one degrades to the HUD's raw rendering. Never raises.rNPOSTz/dossierrr z& [entity] dossier compose failed for rrcomposed) rrrrrrrrrrget)r rrr%s r fetch_composedr'As JB   D ~--/!! JN$9$9 : c4 wwz"H!(D18;t;  6thbQOPs*B B=B88B=rct|}|$tjtt|} t d||dy#t $r$}t dt|ddYd}~yd}~wwxYw)ujSTAGE 2 (daemon thread): compose the dossier off the hot path and swap it into the already-showing card with a SECOND ``entity_profile`` event. On success it carries ``composed= composing=False``; on failure/timeout/ null it carries ``composed=None composing=False`` so the HUD drops the "composing…" spinner and falls back to rendering the raw profile. Never raises, never blocks a turn. One RETRY after a short wait: a slow first composition can outlive our timeout while still finishing (and caching) server-side — the second POST then returns the cached result instantly.Nentity_profileFprofiler% composingz! [entity] composed emit failed: r)r'timesleep_COMPOSE_RETRY_Srrrr)shownr+r%rs r _compose_and_emitr1Ysre$H #$!%(B w% 1 B 1#a&#,@AABsA A0 A++A0c|xsdj}|sd|gfSt|}|d|gfS|jdsd|gfS|jdxsi}t|jdxs|jxs|}|jdxsgDcgc]4}t|jrt|j6}} t d|dd t|tjt||fd jd||fScc}w#t $r)}t d t|dd d||fcYd}~Sd}~wwxYw)uThe TRUTHFUL core every entry point shares. STAGE 1: fetch /profile (≤3s) and emit the card with ``composed=None composing=True`` — it pops instantly. STAGE 2: a daemon thread POSTs /dossier and a second emit swaps the composed narrative in. Returns (status, shown_name, also_matched): 'shown' — the card IS on the HUD 'unknown' — no such entity in memory; NO card was emitted 'error' — memory unreachable / emit failed; NO card on screen Callers must only claim a card is visible when status == 'shown' — the old fire-and-forget version let the brain say "on your HUD, sir" while nothing showed (Ahmed asked for "reval clients", not an entity, and got gaslit).rerrorNentityunknownr also_matchedr)Tr*z [entity] emit failed: rtargetargsdaemonr0) rr!r&rrrr _mark_shown threadingThreadr1start)r r+entr0aalsors r _showrBosc JB   D r""D!Gr"" ;;x 4$$ ++h  %2C '4 ( . . 0 8DE%,[[%@%FB%F %Fq1v||~ FLLN%FD & wN -UG4D ""'%' UD !!  & (Q78%%&s$ 9D'D,, E5EEEc|xsdj}|syt|\}}}|dk(rd|dS|dk(rd|dS|r$t|d k(r|d n|d d }d |d |dSd |dS)uBrain-tool / control-file entry: run ``_show`` and return a short SPOKEN confirmation string (plain prose, TTS-safe) the MOMENT the card is up — it NEVER waits for composition. Callers on the event loop wrap it in asyncio.to_thread / a daemon thread. Never raises.rzI need a name to show, sir.r5zI don't have anything on z yet, sir.r3zI couldn't reach memory for u, sir — no card, I'm afraid.rz and otherszShowing u, sir — I also know a .z's profile, sir.)rrBlen)r statusr0rAextras r show_entityrIs JB   D ,+FE4 *5'<< -eW4RSS t9>Q$q'+/F% 8qAA eW, --ENTITY_COMPOSE_RETRY_S8g@r >Lallandanyarebutcandidforr&gothadhasherhimhishowletnewnotnowoneourrseeshesirthetwowaswhowhyyepyesyoucalldoesfromhaveherehomeintojustlikeneednopeokaysometaskteamtextthatthemtheythiswantwerewhatwhenwillwithworkyeahyourahmedemailphonetherethesethosetodaywherejarvispleasethankstonighttomorrowF)mappatternat refreshing_NAMES _COOLDOWNct5tjt|j <dddy#1swYyxYwN) _names_lockr- monotonicrlower)r s r r;r;s& "&.."2 $**, s *:Ac tjjdtji}tj dd|d}i}|j dxsgD]}t|j dxsdjd s1t|j d xsdj}t|tks|jtvr|||j<d }|rCtd |Dtd }tj ddj#|zdz}t$5|t&d<|t&d<t)j(t&d<d d d t+dt|dt$5dt&d<d d d y #1swY:xYw#t,$r[}t+dt|d dt$5t)j(t&d<d d d n #1swYnxYwYd }~d }~wwxYw#1swYy xYw#t$5dt&d<d d d w#1swYwxYwxYw)u\Rebuild the known-entity matcher from GET /graph — the lightest endpoint that enumerates entities (/export is a full dump). Entity nodes come back as ``{"id": "ent:", "text": , "kind": "entity:"}``. Runs on a daemon thread with a bounded timeout; on any failure the last good matcher stays in place. Never raises.r r z/graph?r nodeskindrzentity:r}Nc3FK|]}tj|ywr)reescape).0ts r z!_refresh_names..s6A299Q<s!T)keyreversez (? .F29 F> H%2F;7F>> H" H'H  H H HH1H""H1%H.1I8 I  I I Ic<tjsyt5tjtdz t k}|s tdr dddydtd<dddt jtdjy#1swY3xYw)uKick a background refresh if the matcher is stale and none is in flight. Non-blocking — returns at once; the daemon thread does the network.NrrT)r8r:) rrrr-r _REFRESH_Sr<r=rr>)recents r _maybe_refreshrsw  ! ! # ))+t , : VL)   $|  N48>>@ s2B BBct|xsdj}|sgSt5td}td}dddgSg}t }|j |D]Y}j |jd|jd}||vs8|j||j|[|S#1swYxYw)u1Known entity display-names named in ``text``, by Unicode word-boundary match against the cached name set (2+ chars, generic words skipped). Does NO network on the hot path — it only kicks a background refresh — and returns [] until the set is first populated. Safe to call every utterance.rrrNr) rrrrsetfinditerr&r addappend)r}rrmappinghitsseenmdisps r mentioned_entitiesrs  A  #-  DD   a {{1771:qwwqz2 t  HHTN KK  ! K s CC c ddlm}tt|ddxr|jj S#t $rYywxYw)uTrue while a background worker is running — auto-show stays out of the way during an active task dispatch (best-effort, never raises).r agent_poolpoolNF)voicerboolgetattrr_runningrrs r _agents_busyrsF$GJ51"002 2 s36 AA)z\b(?:pull up|bring up|show me|open up)\s+(?:everything\s+(?:we|you)\s+know\s+about\s+|everything\s+about\s+|the\s+profile\s+(?:of|for|on)\s+|a\s+profile\s+(?:of|for|on)\s+)?(.{2,60}?)[\s.!?]*$z\b(?:who\s+is|who's|tell me (?:everything )?about|what do (?:we|you) know about|everything (?:we|you) know about)\s+(.{2,60}?)[\s.!?]*$)uN(?:من هو|مين هو|وريني|ورني|اعرض)\s+(.{2,60}?)[\s.!?؟]*$uF(?:كل (?:شي|شيء) (?:نعرفه? )?عن)\s+(.{2,60}?)[\s.!?؟]*$zV^(?:the|a|his|her|their|this|that|please|profile of|about)\s+|\s+(?:please|now|again)$c tD]}|j|xsd}|s|jdxsdj}d}|r3||k7r.|tj d|j}}|r||k7r.t |dkrt|}|rt|t n|}tj}|tjd|jzdz dkrd |fcS|td|jz<t|\}} } || fcS y#t$r$} t!d t#| dd Yd} ~ yd} ~ wwxYw) uIf the utterance is an explicit profile ask, show the card INLINE (≤3s fetch — truth beats speed here) and return (status, name): ('shown', X) — the card IS on the HUD ('unknown', X) — no such entity; nothing was shown ('error', X) — memory unreachable; nothing was shown Returns None when the utterance isn't a profile ask. Prefers a KNOWN entity named in the tail; otherwise sends the tail itself — the server resolves fuzzily.rrDNrMrq:rg$@r0z! [entity] explicit_ask skipped: r) _EXPLICIT_RESsearchr r _TAIL_STRIPsubrFrmaxr-rrr&rrBrrr) r}rxrtailprevknownr r`rGr0_alsors r explicit_askr2sFB-B $*"%AGGAJ$"++-DD44<!;??2t#<#B#B#Dd44<4y1}&t,E*/3u#&TD.."CY]]4$**,#6<A5D&4.D&#D&& E/EEc8t|}|r|St|y)umain.py's ONE integration line: deterministic explicit-ask intercept first (always wins), mention auto-show as the fallback. Returns (status, name) for an EXPLICIT ask — 'shown' means the card is genuinely on the HUD (brain: acknowledge in one line); 'unknown'/'error' mean NO card is visible (brain: say so, never claim otherwise). Returns None on a non-ask (a passive mention auto-show still pops its card silently and needs no brain note).N)rmaybe_autoshow)r}ress r handle_utterancerSs! t C  4 rJc t|}|syt|t}tj}|t j d|jzdz dkry|t d|jz<|t |j<tjt|fdjy#t$r$}tdt|dd Yd}~yd}~wwxYw) uDETERMINISTIC card on an explicit ask. Called by the brain's memory_search tool: when Ahmed asks memory about something that names a known entity ("pull up everything about AIN"), the dossier card MUST appear — regardless of which tool the brain chose to answer with. Picks the LONGEST entity match in the query, fires on a daemon thread, and only guards against immediate double-fires (30s), not the 10-min auto-show cooldown — an explicit ask always re-shows. Never raises, never blocks.Nrrrg>@Tr7z# [entity] show_for_query skipped: r)rrrFr-rrr&rr<r=rIr>rrr)querynamesr r`rs r show_for_queryrbs D"5) 5c"nn tdjjl2C8 84 ? ), $%&"% $**, 4'$GMMO D 3CF4CL>BCCDs$ CAC#AC C- C((C-c tjjdddk(rytryt |Dcgc]}t |t k\s|}}t |dk7ry|d}tj}t5|tj|jdz tkr dddy|t|j<dddtjt|fd j!ycc}w#1swY:xYw#t"$r$}t%d t'|dd Yd}~yd}~wwxYw) u]AUTO-SHOW entry point for main.py's listen loop — ONE line of integration. If Ahmed named exactly ONE strong, known entity and its 10-min cooldown is clear, pop its card. Gated by env ENTITY_AUTOSHOW (default on) and suppressed while a background agent is running. Never blocks (the fetch runs on a daemon thread) and never raises.ENTITY_AUTOSHOW10NrDrrTr7z [entity] auto-show skipped: r)osenvironr&rrrF _STRONG_LENr-rrrr _COOLDOWN_Sr<r=rIr>rrr)r}hstrongr r`rs r rrys ? ::>>+S 1S 8  > /5O5Q;9N!5O v;!  aynn Y]]4::<55 C['*Idjjl #  4'$GMMOP [ ? .s1vds|n=>>?sb#D D DDDD+D 0D:DD3DDDD E (EE crddlddlm}m}d d|dddtid fd }|d d |g S)uThe in-process ``entity`` MCP server — ONE brain tool, show_entity. Follows the memory/agent-pool pattern; dict-shorthand marks ``name`` required.rN)create_sdk_mcp_servertoolcdd|dgiS)Ncontentr})typer})msgs r _textzbuild_server.._textsVS9:;;rJrIuGShow a full profile card (dossier) of a person/company/project/concept on Ahmed's screen: summary, contacts, relations, timeline of every interaction. ALWAYS call this when he says 'show me X', 'pull up X', 'pull up everything about X', 'who is X', or 'tell me about X' — the card is the answer; speak only a brief highlight.r cKt|jddj}|sdS jt|d{}|S7 #t $r!}dt|ddcYd}~Sd}~wwxYww)Nr rz"show_entity failed: no name given.zshow_entity failed: )rr&r to_threadrIr)r9r rrrasyncios r show_entity_toolz&build_server..show_entity_tools488FB'(..0=> > @))+t<? ? @sF4B A AA B A B )B?B B B  B r4z1.0.0)r versiontools)rrreturnr)r9rrr)rclaude_agent_sdkrrr)rrrrrs @@r build_serverrsT<< - O 3-  ! w/?.@ rJ)r rrz dict | None)r0rr+rrNone)r rrztuple[str, str, list])r rrr)r rrr)rr)r}rrz list[str])rr)r}rrz tuple | None)rrrr)r}rrr)/__doc__ __future__rrrr<r- urllib.parserrr voice.eventsrr!r'r1rBrIfloatrr&r/rrrr frozensetrLockrr__annotations__rr;rrrrr IGNORECASErrrrrrr)ps0r rsg<#   2$<0B, "F..(@#FG      inn d#UKK 43 ")J A0 88!Ar}}-8 bjjm  bjj !#0 B D.?<i s .#D%D*