Wj7dZddlmZddlZddlZddlZddlZddlZejjddZ dZ gdZ ejjdxse daejd Zd Zejd ej$Zdd Zd ZejdZdddZdZddZGddZy)uLocalBrain — the ~0.1s conversational front-line (local LLM via Ollama). Measured reality: a reply through the Claude Code CLI has a ~2s floor per turn (CLI overhead, any model). A small local model answers in ~0.11s to first token. So conversation — greetings, questions, banter, quick recall — goes to a local model here; anything needing an ACTION, tools, code, or live system state is declined with <> and the engine routes that turn to the full Claude brain. Instant chat, full power on demand. Backend: Ollama (already used for the screen watcher). Default model qwen2.5:3b (~2GB) — fits beside a game, and Ollama auto-falls to CPU when the GPU is full (still faster than the CLI). Stateless HTTP per call (full history sent each time), so barge-in just stops reading — no stale-stream to drain. Env: LOCAL_MODEL (default qwen2.5:3b), OLLAMA_URL, FAST_CHAT=0 to disable. ) annotationsN OLLAMA_URLzhttp://127.0.0.1:11434z<>)zqwen3:4b-instruct-2507zqwen3:4b-instructzqwen3:4bz qwen2.5:3b LOCAL_MODELu[.!?…]['\")\]]?\s|\nu[*_`#~|]|^\s*[-•]\s+cJtjd|jS)N) _MD_STRIPsubstrip)texts ?/Users/ahmed/devFolder/Ultron/claude-voice/voice/local_brain.py_cleanr*s ==T " ( ( **ueYou are Jarvis, a British butler voice assistant. Ahmed just gave you a task and you're starting it NOW. Reply with ONE very short spoken acknowledgment that NAMES the action, present-continuous, at most 8 words, addressing him as "sir". Plain spoken prose only — no markdown, no quotes, no emoji, no tone tags, exactly one line. Examples: "check my email" -> Checking your emails now, sir. "open whatsapp" -> Pulling up WhatsApp now, sir. "what's on my asana board" -> On the Asana board now, sir. "search the web for flights" -> Looking that up now, sir. Output ONLY the acknowledgment line, nothing else.z^\s*\[[^\]]{1,16}\]\s*c|xst}|dtdd|xsdjdddgddd d d d }|jd r d|vrd|d< t j |j }tjjtd|ddi}tjj||5}t j|j}dddjdxsijdxsdj} | syt j#d| j%d} t'| jjdjdj} | r$t(| vst+| j-dkDry| S#1swYxYw#t$rYywxYw)a5A fast, task-specific spoken ack from the local model (e.g. "Pulling up WhatsApp now, sir."). Non-streaming with a tiny generation budget (~0.3s); returns None on any error / slow Ollama / missing model / odd output so the caller can fall back to a generic canned line. Safe to call from a thread.systemrolecontentuserrNiF20mg333333? ) temperature num_predictmodelmessagesstream keep_aliveoptionsqwen3instructthink /api/chat Content-Typeapplication/jsondataheaderstimeoutmessagerr"' )MODEL _ACK_PROMPTr startswithjsondumpsencodeurllibrequestRequestOLLAMAurlopenloadsread Exceptionget_ACK_TAGr splitlinesrHANDOFFlensplit) r r*rmdlpayloadbodyreqrolines r ack_linerJEs .5C+ 6(:(:(> Same for a TERSE FOLLOW-UP — "where", "why", "and?", "it didn't work", "it's not there" — right after something was done or shown: he means THAT thing. Never ask "where what, sir?" — if the recent turns don't tell you confidently what he's pointing at, reply <> so the layer that did the thing answers. ALSO CRUCIAL — you have NO long-term memory of past conversations. Anything that asks you to RECALL — "do you remember", "do I have", "when is my", "what did I say about", "did I mention", "what's my", any question about his meetings, appointments, plans, people, notes, or anything he told you before — you CANNOT answer; emit <> so your full self can look it up. Never say "no" or "I don't remember" — hand off. CRUCIAL: questions about YOURSELF also need <> — "what model are you", "are you local or the cloud", "which mic/model are you using", "is the camera on", "how are you built", "what can you do", "what are your limits". You do NOT know these; your full self reads them from a live status file. Do not guess or say you're "an entity running on nothing" — just emit <>. No apology, no explanation — just <> and it is routed to your full self. When unsure whether you can truly answer, prefer <>.cDtjjdddk(ry tjj t dd5}tj|j}dddjd gDcgc]}|jd d }}tjjd rtd |DStD]tfd|Dd}|s|a yy#1swYxYwcc}w#t$rYywxYw)zTrue if Ollama is up and a usable model is present. When LOCAL_MODEL isn't forced, picks the best installed model from _PREFERRED (module global MODEL is updated so LocalBrain uses the pick). FAST_CHAT10Fz /api/tagsr)Nmodelsnamerrc3K|]6}|tk(xs'|jtjdd8yw):rN)r/r1rB).0ns r zavailable..s;' %1EzFQ\\%++c2B12E%FF %s<>c3NK|]}|k(s|jr|ywN)r1)rTrUwants r rVzavailable..s)/5aAI<<-5s"%T)osenvironr=r5r6r9r8r2r:r;any _PREFERREDnextr/r<)rGtagsmnameshitrYs @r availablercs  zz~~k3'3. ^^ # #vhi$8! # D::affh'DE,0HHXr,BC,Bqvr",BC ::>>- (' %'' 'D/5/046C E DC sG(D$D3DD(2D D<DDD  D DDcFeZdZd dZd dZd dZd d dZd dZd dZd dZ y) LocalBraincZt|_g|_tj|_yrX)r/r _messagesasyncioLock_lockselfs r __init__zLocalBrain.__init__s %'\\^ rc|K|jd23d{} 76|jjyw)Nu$(warm up — reply with just: ready))replyrgclear)rl_s r startzLocalBrain.starts6zz"HI !  I s<  < <c KywrXrks r stopzLocalBrain.stops  scK|jr1|jdddk(r|jjyyyw)Nr assistant)rgpop)rlr*s r interruptzLocalBrain.interrupts< >>dnnR08KG NN   H>s?Acd|j|ddddid}|jjdrd|jvrd|d <tj|j }t j jtd |d d i }t j j|dS)NTrrg333333?rr r!Fr"r#r$r%r&<r)) rr1r2r3r4r5r6r7r8r9)rlrrDrErFs r _post_streamzLocalBrain._post_streamsZZX]C,@  ::  )j .J$GG zz'"))+nn$$hi t#%78%:~~%%c2%66rcHK|j4d{dtdg|jddzd|dgz}|jjd|dd\}}t j }|j d|j|d{} |j d|jd{}|snl tj|}|jdxsijdd } | r|| z }|| z }t|vrJt|ttd zkr,t |jdddd{y t j#|} | rE|d| j%j'|| j%d}} | rot)| n`t|t*kDrM|j-d d t*} | d kDr| nt*} |d| j'|| d}} | rt)| nn|jdrn |j|j'} | rt| vrt)| t|vr.|j'r|jjd|ddddd{y777#t$rY*wxYw#t$rYwxYw7#t$rYwxYw# |jw#t$rYwwxYwxYw7e#1d{7swYyxYww)z2Yield spoken-sentence chunks from the local model.Nrrir)rrr+rr r(donerx)rj_PROMPTrgappendrhget_event_looprun_in_executorr}readliner2r:r<r=r@rAclose _SENTENCE_ENDsearchendr r _MAX_CHUNKrfind)rl user_textmsgsfullbufloopresprIrHpiecer`chunkcuttails r rozLocalBrain.replys:::&7;<nnST*+ &9=>?D NN ! !6i"H IID#))+D--dD4E4EtLLD% !%!5!5dDMM!JJD! JJt,UU9-388BGE u "d?s4yCL1CD s#(*0-$7 %#uuV}?BJJL99;Dt+Tl"d"tzz|%%{t&LMg::MK %! !:!YX!JJL Y:::s&L"J+L"A9L J.L  K&6J17K&J4A!K&8K L"KL"CK&,K++(# #  $3s%AA A A ,A A  AN)returnNone)g)r*floatrr)rz list[dict])rstr) __name__ __module__ __qualname__rmrrrurzr}rorrtrr reres'$   ! 75Nn $rre)r rrr)g?N)r rr*rr str | Nonerr)rbool)__doc__ __future__rrhr2rZreurllib.requestr5r[r=r8r@r]r/compilerr MULTILINEr rr0r>rJrrcrertrr rs"#   &> ?    }%6A 45  BJJ0",, ? + 9  2::/ 0#L3 =l4e$e$r