+ Pj_:RRt^RIHt^RIt^RIt^RIt^RIHtHtH t ]P!R4t ^t ]P!R]P4t^tRtRRlt!R R 4t!R R 4t!R R]4t] ]].]],3,t!RR4tRRlt!RR4tR#)uThe brain: a streaming, tool-calling chat loop over a swappable LLM vendor. Phase-1 vendor is DeepSeek (OpenAI-compatible chat completions), ported from the pattern in ``voice/deepseek.py`` and extended with SSE streaming + tool calling. The sentence-regrouping approach (start speaking sentence one while the rest still generates) is ported from ``voice/llm.py``. Vendor-swappable: ``Brain`` speaks a neutral event stream and OpenAI-shaped message history. To add Anthropic later, implement ``LLMAdapter.stream`` to translate that history to/from the Anthropic API and yield the same events — nothing else changes. Neutral adapter event contract (async iterator of dicts): {"type": "text", "text": ""} # streamed assistant text {"type": "tool_calls", "calls": [ {id,name,arguments}, ... ]} # 0..1 times {"type": "finish", "reason": "stop"|"tool_calls"|...} # exactly once ) annotationsN) AsyncIterator AwaitableCallableu[.!?؟…]['\")\]]?\s|\nu[*_`#~|]|^\s*[-•]\s+z<>c V^8dQhRRRR/#)textstrreturn)formats"brain.py __annotate__r*s++++cJ\PRV4P4#)z=Remove markdown symbols before a sentence goes to the UI/TTS.) _MD_STRIPsubstrip)rs&r clean_for_ttsr*s ==T " ( ( **rc>]tRt^/tRtRRltRRltRRltRtR #) SentenceRegrouperzAccumulates streamed token deltas and emits complete sentences. ``push(delta)`` returns a list of finished sentences (cleaned, [emotion] tags preserved); ``flush()`` returns whatever remains at end-of-turn. cV^8dQhRR/#rr Noner )r s"r rSentenceRegrouper.__annotate__6s$rc RVnR#)rN_bufselfs&r __init__SentenceRegrouper.__init__6s  rc V^8dQhRRRR/#)rrr r z list[str]r )r s"r rr9s%%%%rc V;PV, un.p\PVP4pV'dtVPRVP4P 4pVPVP4RVnV'dVP \ V44KK\VP4\8dVPPR^\4pV^(8dTM\pVPRVP 4pVPVRVnV'dVP \ V44EK?EKBTUu.uFqf'gK TNK up#uupi)TN ) r _SENTENCE_ENDsearchendrappendrlen _MAX_CHUNKrfind)r routmchunkcutss&& r pushSentenceRegrouper.push9s T $$TYY/A )AEEG,224 IIaeegh/ JJ}U34TYY*,iiooc1j9 2Xc: $3--/ IIcdO JJ}U34$3a!3$$$s # E:1E:cV^8dQhRR/#)rr r r )r s"r rrNssrc >\VP4pRVnV#)r)rr)r tails& r flushSentenceRegrouper.flushNsTYY'  rrN) __name__ __module__ __qualname____firstlineno____doc__r!r2r7__static_attributes__r rr rr/s %*rrc2]tRt^UtRtRRltRRltRtR#) LLMAdapterzCVendor interface. Implement ``stream`` to yield the neutral events.c$V^8dQhRRRRRR/#rmessages list[dict]toolslist[dict] | Noner zAsyncIterator[dict]r )r s"r rLLMAdapter.__annotate__Xs#""Z"-"2E"rc "\h5iN)NotImplementedError)r rCrEs&&&r streamLLMAdapter.streamXs !!s cV^8dQhRR/#rr )r s"r rrG\s  d rc "R#5irIr rs&r acloseLLMAdapter.aclose\s sr N)r9r:r;r<r=rKrOr>r rr r@r@UsM"  rr@cH]tRt^`tRtR RRlltRtRRltRR ltR t R#) DeepSeekAdapterz8DeepSeek / OpenAI-compatible streaming chat completions.Nc V^8dQhRRRR/#)rmodelz str | Noner rr )r s"r rDeepSeekAdapter.__annotate__cs++:++rc \PPRR4PR4VnT;'g!\PPRR4Vn\ \PPRR44Vn\\PPRR44Vn Wn VR JVn R #) DEEPSEEK_URLzhttps://api.deepseek.com/MODELzdeepseek-v4-proBRAIN_TEMPERATUREz0.6BRAIN_MAX_TOKENS1024N) osenvirongetrstripbaserTfloat temperatureint max_tokens_client _owns_client)r clientrTs&&&r r!DeepSeekAdapter.__init__csJJNN 688>s  HHbjjnnW6GH  0CU!KLbjjnn-?HI "dNrc VPf+^RIpVPVPR4R7VnVP#)Ng^@)timeout)rfhttpx AsyncClientTimeout)r rls& r _ensure_clientDeepSeekAdapter._ensure_clientls7 <<   ,,U]]55I,JDL||rcV^8dQhRR/#rr )r s"r rrUrs  d rc "VP'd<VPe,VPP4GRjxL RVnR#R#R#L5irI)rgrfrOrs&r rODeepSeekAdapter.aclosersB    !9,,%%' ' 'DL":  's>AAAc$V^8dQhRRRRRR/#rBr )r s"r rrUws#6=6=Z6=-6=2E6=rc  "\PPRR4pV'g \R4hRVPRVRRRVP RVP /pV'd W$R &R VR &VP4pR R V 2RR/p/pRpVPRVPR,WFR7;_uu_4GRjxL p V P4V P4RjxL p V 'dV PR4'gK+V \R4RP4p V R8XdEM\P !V 4p T PR4;'g/.p T ^,pTPR4;'g/pTPR4'dRRRTR,/5xTPR4;'g.FpTPR^4pTP%TRRRRRR/4pTPR4'd TR,TR&TPR 4;'g/pTPR4'd TR,TR&TPR4'gKTR;;,TR,, uu&K TPR!4'gEKTR!,pEKRRR4GRjxL V'd*RRR"\'V4Uu.uF pVV,NK up/5xRR#R$T;'gR%/5xR#ELREL, \"dEKBi;iEDALrLf +GRjxL 'giL};iuupi5i)&DEEPSEEK_API_KEYrzDEEPSEEK_API_KEY not setrTrCrKTrcrerEauto tool_choice AuthorizationzBearer z Content-Typezapplication/jsonNPOSTz/chat/completions)jsonheaderszdata:z[DONE]choicesdeltacontenttyper tool_callsindexidname argumentsfunction finish_reasoncallsfinishreasonstop)r]r^r_ RuntimeErrorrTrcrerorKraraise_for_status aiter_lines startswithr*rr{loads ValueError setdefaultsorted)r rCrEkeypayloadrhr|tool_bufrresplinedataobjr}choicer~tcidxslotfnis&&& r rKDeepSeekAdapter.streamwsjjnn/49: : TZZ  d 4++ $//   $G %+GM "$$&"gcUO!#57$&==5H)H&-!@@@CG  ! ! #"..0 5 5d4??7#;#;CLM*0028#**T*C''),44  7+11r99Y''!6653CDD 99\288b8B&&!,C#..dBKDFDvvd||%'XT  +11rBvvf~~')&zV vvk**[)R _<)9::o..#O4F=@@> <&2BC2BQXa[[2BCE Ex6+;+;V<r rr rRrR`sB+  6=6=rrRc6]tRt^tRtRRltRRRlltRtR#) BrainaRuns the streaming tool-calling loop for one user turn. ``messages`` is the full OpenAI-shaped list (system + history + the new user message). It is MUTATED in place: assistant/tool messages produced during the turn are appended, so the caller's history stays current. c(V^8dQhRRRRRRRR/#) radapterr@ tool_specsrF tool_execzToolExecutor | Noner rr )r s"r rBrain.__annotate__s+## #8I#/#48#rc @WnT;'gRVnW0nR#rI)rrr)r rrrs&&&&r r!Brain.__init__s $,,"rNc$V^8dQhRRRRRR/#)rrCrDon_tokenCallable[[], None] | Noner zAsyncIterator[str]r )r s"r rrs(BB*B5B)Brc "Rp\\4Fp\4pRp.pVPP WP 4RjxL pVP R4p V R8XdLVeV'g RpV!4WhR,, pVPVR,4Fp V 5xK KmV R8XgKvVP R4;'g.pK R#L \dLni;iDTP4p T 'dT 5xT'g/TP4'dTPR R R T/4R#TPR R R T;'gRR\T4U U u.uFVwrR T P R 4;'gR T 2RRRRT P RR4RT P R4;'gR//NKX Muup p iup p /4\T4EF wr\P!T P R4;'gR4p\T\ 4'g/pM \"d/pMi;iT P RR4pTP$'dTP%Y4GRjxL MRT R2pM0 \d#pRT R\'T4R, 2pRp?MRp?ii;iTPR RRT P R 4;'gR T 2R T/4EK EK5i)uYield reply sentences (raw, [emotion] tags intact) as they complete. ``on_token`` (optional) fires once, on the FIRST streamed text token of the turn — the caller uses it for time-to-first-token timing.FrNrrTrrrole assistantrrcall_rrrz{}ztool 'z' is unavailablez ' failed: :NNtool tool_call_id)range_MAX_TOOL_ROUNDSrrrKrr_ Exceptionr2r7rr) enumerater{r isinstancedictrrr )r rCrfired_roundregrouptext_accrevkindsentencer6rcargsrresultes&&& r run Brain.runs,-F')GH "E LL////J 2 2bvvf~6>+E $!$J6 *H$+LLF$<&%=\)FF7O11rE#.t m 2 )! !K==?D >>##OOV[)X$NO OO 8++t!*% 0 !1155;55E!+vz&!%%*;"-quu[/A/I/IT"KL!1   "%(::aeeK&8&@&@DAD%dD11!!DuuVR(E!%%)NN4$>>> &tf,<=!E%dV:c!fTl^DFE!/t1K1K%s !*F!45)sAK: C4C!C4%K:8K:;C#9K:K: K:!C4# C1.K:0C11K: K:K:0.K:K:0G 2G  G  !K:.'H6H65K:6 IK:IK:J.JJ JK: J<J72K:7J<<(K:%K:)rrrrI)r9r:r;r<r=r!rr>r rr rrs# BBrrc V^8dQhRRRR/#)rhistoryrDr r )r s"r rrs  : * rc.pVFspVPR4pVPR4pVR9gK.\V\4'gKFVP4'gK^VP RVRV/4Ku V#)u"The fast lane's view of the SHARED history: plain user/assistant text turns only. Tool-call scaffolding produced by full-brain turns (assistant messages with ``content=None`` + ``tool_calls``, and ``tool`` results) is dropped — the fast model has no tools and just needs the conversation.rr)userr)r_rr rr))rr-r.rrs& r _fast_historyrsj C uuV}%% " ( (Z-E-EMMOO JJi9 :  JrcB]tRtRtRtRRltRRltR RR lltR tR#) FastLaneiuThe cheap, tool-less front lane over a fast model (deepseek-v4-flash). Streams spoken sentences from a compact-persona prompt; if the model emits the escalation sentinel ``<>`` (per that prompt) it signals a handoff so the caller silently reruns the turn on the full ``Brain``. Ported from the desktop's ``voice/local_brain.py`` two-lane design. ``run`` yields tuples: ``("say", sentence)`` a spoken sentence (raw, [emotion] tag intact) ``("handoff", None)`` escalate — emitted ALONE and FIRST, then the generator stops (nothing spoken, nothing to commit) ``("final", text)`` LAST on a clean finish — the full assistant text (sentinel stripped) for the caller to commit to the shared history c$V^8dQhRRRRRR/#)rrr@ system_promptr r rr )r s"r rFastLane.__annotate__(s!++ +3+4+rc WnW nR#rIrr)r rrs&&&r r!FastLane.__init__(s  *rc$V^8dQhRRRRRR/#)rrrD user_contentr r r )r s"r rr,s"??j??&?rc \RRRVP/.\V4,RRRV/.,#)rsystemrr)rr)r rrs&&&r build_messagesFastLane.build_messages,s=(It/A/ABC()FI|<=> ?rNc(V^8dQhRRRRRRRR/#) rrrDrr rrr zAsyncIterator[tuple]r )r s"r rr2s*3333353+3rc L"VPW4p\4pRpRpRpVPPVR4p V RjxL p V P R4R8wdK"VeV'g RpV!4WjR,, pV'g7\ V9d,R 5x\V RR4p V eV !4GRjxL R#R#VPV R,4F/p \ V 9gV P4'gK&RpRV 35xK1 KL \ dLi;iLh \ dR#i;iDTP4p T'gJ\ T9d?R 5x\T RR4p T e&T !4GRjxL R# \ dR#i;iR#T 'd\ T 9d RpRT 35xT'g?R 5x\T RR4p T e&T !4GRjxL R# \ dR#i;iR#TP\ R4P4pT'dRT35x\T RR4p T e&T !4GRjxL R# \ dR#i;iR# \T RR4p T e$T !4GRjxL i \ dii;ii;i5i) rFNrrTrOsayfinal)handoffN) rrrrKr_r FAST_HANDOFFgetattrr2rr7replace)r rrrrCrfullspokerrKrrOrr6 committeds&&&& r r FastLane.run2s&&w=#%$$Xt4( " , ,b66&>V+' E 6 "!5++*VXt4F! (NN"+!( RZ 8H#x/x~~7G7G  E (++ !9 ,%<# M#&==?D\T1''VXt4F! (NN " D0dm#'' VXt4F! (NN "  \26<<>I **VXt4F! (NN "VXt4F! (NN "s>J$I+D<DD< %I+1I+4D;(I+#J$5 D*?D(D*J$;I+I+D< D%"I+$D%%I+(D** D95J$8D99J$<I+I+&J$8 F FF J$ FJ$FJ$I+&I+I+J$ G,$G'%G,*J$, G;7J$:G;;J$+I+,I+3J$ IIIJ$ I&"J$%I&&J$+J!> JJ  JJ! JJ!JJ!!J$rrI) r9r:r;r<r=r!rrr>r rr rrs +? 33rr)r= __future__rr{r]retypingrrrcompiler&r+ MULTILINErrrrrr@rRr r ToolExecutorrrrr rr rs$# 55  67   JJ0",, ?  + ""L  M=jM=bd Ys^34 PPh NNr