Xj dZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ejdk(r[ejejfD]Z ejdd ddlZej$j&j)dddlZ dd lmZeej6j9ej6j;ed dd lm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*dd l)m+Z+m,Z,ddl-m.Z.ddl/m0Z0ddl1m2Z2m3Z3ddl4m5Z5ddl6m7Z7ddl8m9Z9ddl:m;Z;ddlZ>ddl?m@Z@e dze!zZAeBejjddZEdZFdZGeHejjddZIdZJdZKeHejjd d!ZLd"ZMd#ZNd$ZOd%ZPeBejjd&d'ZQejjd(d)d*k7ZRejjd+d)d*k7ZSeBejjd,d-ZTeBejjd.d/ZUeBejjd0d1ZVeBejjd2d3ZWeBejjd4d-ZXejjd5d)d*k7ZYeHejjd6d7ZZeHejjd8d9Z[eBejjd:d3Z\ejjd;d)d*k7Z]ejjdd)d*k7Z`hd?Zahd@ZbhdAZcejdBejZfejdCejZgejdDejZhejdEejZidfdFZjejdGejZldfdHZmejdIejZndfdJZoejdKejZpejdLejZqejdMejZrdgdNZsdhdOZtdidPZuGdQdRZvdjdSZwdjdTZxdjdUZyezdVk(rxddWl{m|Z}e}ejjdXz Z ejdYZddlZejeed[z d\ ej eyyy#e$rY5wxYw#e$r5 ej$j*j-n #e$rYnwxYwY/wxYw#e$rYwxYw#e$rYwwxYw#e$red]ejdYye$rZddlZddlZ eed^z d_d`5Zejdaejjj!dbejej"dddn #1swYnxYwn #e$rYnwxYwedceejddeejedZ[wwxYw)kuClaude Voice — real-time, interruptible voice chat with Claude on a Mac. Everything runs locally on the M4 except the Claude conversation itself, which goes through the locally-installed Claude Code (Max subscription, no API key, no per-token billing). mic 16k ── Silero VAD ── Parakeet STT ─▶ Claude (Agent SDK, streaming) │ sentence chunks speakers 24k ◀── Speaker.cut() on barge-in ── Kokoro TTS State machine (parameters from what shipped voice projects converge on): LISTENING VAD 0.60 start / 250ms min speech / 700ms end-silence, 1s pre-roll ring so the first syllable isn't lost. RESPONDING streaming LLM -> per-sentence TTS -> playback. Barge-in: while audio is playing the VAD runs STRICT (0.90, ~290ms sustained, 300ms refractory) so the assistant doesn't trigger on its own voice from open speakers; before audio starts it runs at the normal threshold. On barge-in: playback cut (<50ms), TTS queue dropped, Claude generation interrupted, back to LISTENING. Env knobs: MODEL=haiku|sonnet|opus VOICE=af_heart VOICE_SPEED=1.0 STT=parakeet|whisper STT_LANG=ar INTERRUPT=0 (half-duplex) ) annotationsNntutf-8replace)encodingerrors) load_dotenvz.env) FRAME_SAMPLES SAMPLE_RATE AECMicStream MicStreamSpeakerSystemAudioStream_start_mute_hotkeybreak_requestedrestore_input_volume) entity_show)pending task_ledger)ControlWatcher)emit) ClaudeBrain FastBrain)FrustrationMeter) ProsodyReader) SpeakerGate)load_stt)r KokoroTTS)VAD VAD_STARTz0.50gffffff?END_SILENCE_MS480TURN_MAX_SILENCE_MS1400 g333333?BARGE_REFRACTORYz0.12 INTERRUPT10 ASYNC_BRAIN ACK_TIMEOUT_Sz1.5WORKER_BUDGET_S300WORKER_BUDGET_HEAVY_S600WORKER_WATCH_S12 READY_DEFER_SMEETING_SYSAUDIOMEETING_QUEUE_MAX120MEETING_BACKLOG2MEETING_BIG_MINAEC VOICE_LOCK WAKE_WORDDUPLEX>"igohmitmmohokonyaahagothmmmhmseewowyeayepyescoolkeepmmhmniceokaysuretrueyeahgoingrightuhhuhgotchareallyalrightexactly interesting>go oni seemm hmgot itno wayoh wowuh huhoh niceoh okayoh right all right of course oh really keep going fair enough makes sensera>ok stopshut upstop itbe quiet okay stop never mind jarvis stop okay thanks stop jarvis alright stop stop talking that's enoughokay thank youthank you jarvishushstopquietshushenough nevermindz^\W*(?:jarvis[,\s]+)?(?:(?:stop|cancel|drop|kill|abort|forget)\s*(?:(?:the|that|this|your)\s+)?(?:task|job|work|request|it|that)?|never\s*mind(?:\s+(?:that|it))?)[.!]?\W*$z4^\W*(?:hey\s+|ok(?:ay)?\s+|yo\s+)?jarvis\b[\s,:.!-]*az\b((?:have\s+a\s+|take\s+a\s+)?look\s+(?:at\s+)?(?:this|that|here|my\s+screen|the\s+screen|at\s+this|at\s+my\s+screen)|check\s+(?:this|that)(?:\s+out)?|see\s+(?:this|that|my\s+screen|the\s+screen|what\s+i(?:'m|\s+am)\s+(?:looking\s+at|seeing))|what(?:'s|\s+is)\s+on\s+(?:my\s+|the\s+)?screen|what\s+am\s+i\s+looking\s+at|look\s+at\s+my\s+screen|read\s+(?:my\s+|the\s+)?screen)\bu\b(?:i\s*will|i['’]?ll|gonna|going\s+to)\s+(?:have\s+a\s+)?look\b|\blook(?:ing)?\s+at\s+(?:this|that|it)\b.*\b(?:later|tomorrow|tonight|after|next\s+week|in\s+a\b)cv|xsd}tj|ryttj|S)zATrue if the utterance is asking Jarvis to look at the screen NOW.F) _DEFER_REsearchbool _SCREEN_REtextts 2/Users/ahmed/devFolder/Ultron/claude-voice/main.py _wants_screenrs2 A  !!!$ %%z\b(search|research|look\s+(?:it\s+|that\s+|this\s+)?up|google\s|browse|look\s+into|dig\s+(?:up|into)|investigate|find\s+(?:out|me)|check\s+online|what'?s\s+the\s+(?:latest|current|newest))\bcFttj|xsdS)u}True if the utterance clearly needs the full brain's tools (web search / research) — route past the toolless fast lane.r)r_WANTS_FULL_RErrs r _wants_fullrs %%djb1 22ra ^\W*(?:hey\s+|ok(?:ay)?\s+)?(?:jarvis[,\s]+|can\s+you\s+|could\s+you\s+|please\s+|go\s+(?:and\s+)?|i\s+(?:need|want)\s+you\s+to\s+|let'?s\s+)?(build|fix|make|create|code|write|edit|refactor|debug|run|deploy|install|set\s+up|configure|research|investigate|analy[sz]e|summari[sz]e|send|email|message|text|schedule|book|remind|add|remove|delete|update|change|rename|download|upload|pull\s+up|look\s+into|figure\s+out|work\s+on|handle|sort\s+out|draft|put\s+together|generate|compile|scrape|check\s+on|clean\s+up|organi[sz]e)\bcd|xsd}tt|xstj|S)zTrue if the utterance is real work (task/command) that should run on the background brain rather than block the conversation.r)rr_TASK_RErrs r_is_taskrs* A  A4(//!"4 55rz\b(?:record|take\s+notes?)\b.{0,20}\b(?:this|the|meeting|call|conversation)\b|\b(?:start\s+)?(?:meeting\s*mode|note[-\s]?taking)\b|\bstart\s+recording\bz\b(?:stop|end|finish|wrap\s+up)\b.{0,15}\b(?:recording|meeting|notes?|listening|note[-\s]?taking)\b|\bmeeting'?s?\s+(?:is\s+|are\s+)?(?:over|done|finished)\bzL\b(online|digital|call|zoom|teams|meet|google\s*meet|video|virtual|remote)\bc|xsd}tj|rytj|rdtj|rdfSdfSy)z?('start', mode) / ('stop', '') / None. mode = online|in_person.rrrstartonline in_personN) _MEET_STOP_REr_MEET_START_RE_MEET_ONLINE_RErs r_meeting_triggerr*sM AAQ_%;%;A%>PPKPP rc>tj|}|stdj|jddj }d|vry|j j d}||t dzdjdS||jdS)uIf `text` starts by naming Jarvis, return the command after the wake word (empty string = just 'Jarvis' with nothing after). Return None when the wake word is absent → the utterance should be ignored. Njarvisz ,:.!-) _WAKE_REmatchjoinsplitlowerfindlenlstripend)rmheadidxs r _wake_commandr4s tA xx Ra()//1 4 jjl)C#h-'()00:: >rc  tjjtjjtjj t dd}t j }d} t|d5}t|jjxsd}ddd t|dd5}|jt|ddd|r||z d kry ||z }|d krd t|d zd}n|dkr d |dz dd}n d |dz dd}t jd}d|d|dS#1swYxYw#t$rYwxYw#1swYxYw#t$rYwxYw#t$rYy wxYw)u{Wall-clock awareness for the brain. Its resumed transcript reads as one continuous moment, so after an overnight gap Jarvis says "I just checked" about last night. On a gap ≥30min since the previous exchange (persisted to control/last_turn across restarts) return a bracketed note stating the real time and how long passed. Empty string otherwise; never raises.control last_turnrrrNwiri about <z minutesii.0fz hoursiQz daysz%A %d %b, %H:%Mz (TIME: it is now  — z have passed since the previous exchange. Anything 'just now'/'earlier' in the conversation above happened BEFORE this gap; re-check rather than assume it is still current.))ospathrdirnameabspath__file__timeopenfloatreadstrip Exceptionwritestrintstrftime)pnowprevfgaphumanstamps r_time_gap_noterCs  GGLL)BC"K 1iik a'*aQVVX^^-23+ aw/1C!0sTzD(Dj :S^,H5E 6\S4Z,F3ES5[-U3E /0'weE7;44 5'+*   0/    sA5F8 E,E 1E:E2E&#E2+ F6AF EE E# F"E##F&E/+E22 E>;F=E>>F F  F ceZdZd4dZd4dZd4dZd5dZd4dZd6dZd7dZ d4dZ d8d Z d Z d4d Z d4d Zd9d Zd4dZed:dZed;ddZed?dZ d@dZ!dAd Z"d!Z#d4d"Z$dBdCd#Z%d:d$Z&d@d%Z'd@d&Z(d4d'Z)dDd(Z*dEd)Z+d@d*Z,dFd+Z-dBdGd,Z.d4d-Z/dHd.Z0d4d/Z1d4d0Z2 dI dJd1Z3dKd2Z4dLd3Z5y)MVoiceAppctj|_d|_d|_d|_d|_tt|_ t|_ tjt|_d|_d|_d|_d|_d|_t+|_t/|_d|_d|_tj6|_d|_d|_d|_g|_ d|_!g|_"tF|_$d|_%d|_&d|_'d|_(d|_)d|_*d|_+d|_,d|_-d|_.d|_/d|_0y)NFg? )maxlencalmrr)1asyncioget_event_looploopmic aec_activebarge_prob_playingbarge_sustain_framesrTTS_RATEspeakerr vad collectionsdequePRE_ROLL_FRAMESringbrainfaststtttsgaterprosodyr frustration _mood_tag respondingQueueinbox _brain_task _brain_desc_brain_started _brain_queue _brain_cancel_readyWAKE_WORD_DEFAULT wake_word text_voicemeeting _sysaudio_remote_capture_task_meeting_worker_task_meeting_stt_queue_meeting_transcribing _room_wav _them_wav _barge_text_wake_grace_until _tts_abort)selfs r__init__zVoiceApp.__init__ksF**, "&$%!x( 53>3D3D"4  *. &* %)(, % ,-)0 15!')"') * 489=!9=!8<%*"'+!$26rctjdk7s"tjj ddk(ryddl}ddl}|jdxsd}tjj|sy |j|dd d gd d d jjtfddDsy|j|ddd gd d d jj}td|Dd}|r,|j|dd d|gd d t!dd|dyy#t"$r}t!d|dYd}~yd}~wwxYw)uBluetooth earbud mics (CMF Buds, AirPods) are poor for voice and force the degraded SCO codec — and macOS keeps auto-selecting them. If the default input is one, switch to the built-in mic so Jarvis hears clearly. MIC_KEEP_DEFAULT=1 to leave the default alone.darwinMIC_KEEP_DEFAULTr/NrSwitchAudioSourcez#/opt/homebrew/bin/SwitchAudioSourcez-tinputz-cT)capture_outputrtimeoutc3BK|]}|jvywN)r).0rcurs r z/VoiceApp._prefer_builtin_mic..s%IG-.qCIIK'Gs)budairpod bluetoothheadsetcmfz-ac3K|]8}d|jvsd|jvr|j:yw)macbookzbuilt-inN)rr)rrs rrz/VoiceApp._prefer_builtin_mic..s8Rt!(AGGI5qwwy9PGGIts>Az-s)rrz mic: default was 'u' (bluetooth) — switched to 'z.' for clear voice (MIC_KEEP_DEFAULT=1 to keep)z [mic preference skipped: ])sysplatformrenvirongetshutil subprocesswhichrexistsrunstdoutrany splitlinesnextprintr)r r&r'_SASallmbuiltiners @r_prefer_builtin_miczVoiceApp._prefer_builtin_mics~ <<8 #rzz~~6H'IS'P  0198 ww~~d#  6..$gt!<044)*!,,2F557 IGII>>4tW"=15D*+"--3VJJL RtR!GdGT ' )9=qJ,SE2!"PRS  6 /s!4 5 5 6s 6AD/m?}m@}|rj||_=|jzjd{td>|jzjd?tAj@| z d d!|jzW t|_=|jzjd{tdBtAj@| z d d!tddE|jd{|jjt|jd{|jtrdFndG}tdH|dItd,|jt|jVxr|jVjXJtdK|jLy#t,$r}td|dYd}~cd}~wwxYw#t,$r}td|dYd}~Kd}~wwxYw#t,$r}td|dYd}~+d}~wwxYw77{7&77#t,$r}td)|d*Yd}~d}~wwxYw7776#t,$r!}td@|dAd|_=Yd}~d}~wwxYw7#t,$r!}tdC|dDd|_=Yd}~d}~wwxYw77w)NNz,loading models (first run downloads them)...bootinguStarting up…)stagerdesktop_serverz- desktop control: macos-mcp launching (HTTP)rCHROMEr/r0Pathzchrome-jarvis.shbashT)r+stderrstart_new_sessionz. browser: Jarvis Chrome launching (CDP :9222)z. browser: Jarvis Chrome auto-launch skipped ()screenua screen: requested Screen Recording — allow Jarvis, then relaunch (needed for 'see my screen')z! screen: recording permission OKz$ screen: permission check skipped (r)AXIsProcessTrustedAXIsProcessTrustedWithOptionskAXTrustedCheckOptionPromptz- accessibility: OK (desktop control enabled)uY accessibility: requested — allow Jarvis, then relaunch (needed to control other apps)z accessibility: check skipped (u/Loading voice (up to a minute on cold start)…)load_ttsz TTS ready (rzs)uLoading speech recognition…z STT ready (u Warming up…c6ddlm}| tdyy)Nr get_routerz1 intent router ready (semantic reflexes, ~0.1ms)) voice.intentrIr/rHs r _warm_routerz$VoiceApp.start.._warm_routers /|'IJ(rc6ddlm}| tdyy)Nr get_detectorz) smart-turn ready (semantic end-of-turn)) voice.turnrNr/rMs r _warm_turnz"VoiceApp.start.._warm_turn!s /~)AB*ruW voice lock: profile loaded — only your voice gets replies (VOICE_LOCK=0 to disable)uK voice lock: ENROLLING — your first 5 utterances build the voice profilez voice lock unavailable (u) — replying to anyonez desktop control: readyz NOT ready (tools may be missing)uConnecting to Claude…MODELsonnet)modelz Claude session ready ( c3LK|]}dtj|zywz- N)r summarize)rrs rrz!VoiceApp.start..Ms(4'2!#[%:%:1%=='2s"$zZ[recovered] Background task(s) were cut off by the last restart/crash and did NOT finish: uo If Ahmed asks about any, tell him plainly it was interrupted and offer to redo it — never claim it finished.r agent_poolz agents: pre-warming u( spare worker(s) — dispatch is instant FAST_CHAT LOCAL_BRAIN) LocalBrain availableu fast brain ready — LOCAL z (z local fast brain failed (u) — using Haikuu2 fast brain ready — Haiku conversational lane (z fast brain unavailable (u) — full brain onlyuSetting up the microphone… interruptiblezhalf-duplex (INTERRUPT=0)u ready — just talk. (z; Ctrl-C to quit) )aecenrolledrrKreturnNone)Lr/rr4rvoicer9enabledrrnamer$r%r'pathlibr<rresolveparentr)PopenrDEVNULLrrB has_accessrequest_accessr"r#ApplicationServicesrCrDrErvoice.tts_chatterboxrFr to_threadr_apply_persisted_prefsrrrArrra wait_readyrrrloadr recover_stalerr put_nowaitunackedrZ_enqueue_reportpool report_sink WARM_SPARESrvoice.local_brainr]r^rTr _pick_micrr_verify_hearing _write_status INTERRUPTIBLErrr)r r9_spr<_shr3rBrCrDrEt0rFrKrPrQ interruptedlines_nrZr]r^modes rrzVoiceApp.starts <= Y./   " )  ! ! #  " A B 77d?rzz~~h<C M((8n,,.558JJ::<IIvs3x0%([[046JK ? $$$&%%'CD9: <<8 # ?&'IJ13NPT2UVDEYY[ YOP1 **844 diik"nS145 ##% YY[ Y=> **844 diik"nS145 Yo. K --- C +++  P")"3"3K"@@ 99%%CD45 )  ! ! #!++N,E,EFFE '5>`'ab c YY[ Y78 rzz~~gx'HI jj    (R(A:: ;//#Bvvf~ %%bj1$ %    +/*>*>JOO ' OO ! ! # *:+A+A*BC67 8 ::>>+s +s 2B DIzz~~mS1S8 %G {$.L "iioo/// =diioo=NO""&))+b.!5R9: yy % ) DI))//+++"iik"nS156 Y<=nn ""$$$ "/5P (.ABC W$//499;););< > [T^^,I MFqcKLL M ? 81= > > ?& ?81=>> ?5 5 . ,A P21#5MNOO PG !p0!%7s:KLM $DII% ,!%6qc9NOP $DII%  %sBa5B]"=^a5/2^.!?a5 _!A;a5_Aa54_5 a5_ a5!_#=_ >6_#48a5,` -Ba50` 1Ca5:C&a5!8``A` a5',a`?)a= a5a/;a5a2Ba5" ^+^:a5^a5 ^+^& a5&^++a5. _7_ a5 _a5a5a5a5 _## `,`;a5`a5 a5` `<`71a57`<<a5?a a, a'!a5'a,,a52a5cbKddlm}m}|||_t dd||j |_d|_t dd|jtd |d |jjtj|jjd d{tjt |_d |_ ||jj'|_tj,|j/|j|j"|_|dk(r;t2r4tj,|j5|j|_yyy7#t*$r }d|_td|d Yd}~d}~wwxYww)Nr)MeetingSession WavRecorder)rrT)rKrrrbu& [MEETING recording started — r!z Recording.)maxsizeFz' [meeting: room WAV open failed: r) voice.meetingrrrrr _prev_wakerr/rplayrrrrsynthrr;rr room_wav_pathrr create_task_meeting_transcribe_workerrr:_capture_remoter)r rrrr3s r_start_meetingzVoiceApp._start_meetingsa=%40  Y4d+.. [T"  6tfA>?  1 1$((.., OOP #*--8I"J%*" B()C)C)EFDN%,$7$7  + +DLL$:Q:Q R%T! 8  0(/(;(;$$T\\2)4D %!1 %P B!DN ;A3a@ A A Bs=B+F/-F..F/%FBF/ F, F'"F/'F,,F/cK|jdc}|_|y|jd{|jdc}|_| |jt ddt |d|j|_t d|j|j}d|_|j}d}|T|j|jrdndz}|jr |j |jd|tk\xs|j t"k\}|rdnd }|j$j't)j*|j,j.|d{t)j0|j3|||y7y#t$rY\wxYw#t$rYwxYw#t$rYwxYw7`w) NrFrbrrruZThat's a big one, sir. Still processing — I'll have the full transcript for you shortly.zStopped. Summarising.)r_stop_remote_capturercloserrgetattrrrrqsizerfull get_nowaitrwMEETING_BACKLOG_THRESHOLDminutesr?rrrrrrrr_finalize_meeting)r rrworkerqrbackloglines r _stop_meetingzVoiceApp._stop_meetings,,4< 9 ''))) NND4> =   Y5! |T^^D [T^^,**$(!  # # =ggi(B(B1JGvvxLLN  T"66V!)):V. 7   1 1$((..$ GGH D221fgFGG *   "!   Hs+GF&G F)BG.F9?GA&G6G70G) F62G5F66G9 GGGG GGGGcK | |d{|jd|_ |j }td|dt |j d|r3 |jjdt |j d |j|d{y7#t$r}td|dYd}~d}~wwxYw#t$r}td|dYd}~d}~wwxYw#t$rYqwxYw7`w) zOff-loop tail of a meeting: let the worker drain the remaining audio, save the full transcript, tell Ahmed it's ready (if it was a big one via the inbox rail), then run the existing summary path. Fully guarded.Nz& [meeting worker finish failed: r!z [MEETING saved: rz lines]z [meeting save failed: u*Your meeting transcript is ready, sir — z, lines saved to recordings. Summarising now.) rr/rrsaverrrrw_summarize_meeting)r rr was_backlogr3rs rrzVoiceApp._finalize_meetings A! << &*D # 8668D +D6s177|nGL M   %%@QWWOBBC %%a(((' A :1#Q? @ @ A 8 1!A6 7 7 8  (sDB*B(B*D5CD2C4D"D#D(B** C 3CDC  D C1C,'D,C11D4 D=D?DDc&|j}||t|dk(ry |j|tj|tj ||nt j fy#tj$rtdYywxYw)u*Hand one completed meeting utterance to the background Whisper worker. On backlog (queue full) DON'T block or drop silently — the raw WAV already has this audio, so it stays re-transcribable; we just skip the live pass. `audio` is copied (the caller may reuse its buffer).Nr)dtypeu^ [meeting: STT backlog full — audio kept in the WAV, re-transcribe from the recording]) rrrwnpascontiguousarrayfloat32rr QueueFullr/)r raudiotsrs r_enqueue_meeting_audiozVoiceApp._enqueue_meeting_audios  # # 9 Uq  7 LL'2#7#7RZZ#P ""DIIKA B   7 6 7 7sA A//BBcKddlm} tj|d{\}}t d|d |jd{}|y|\}} } d|_ tj|j| d{xsd j} d |_| rtd | Ds|j|| | t d|d| td| 7#t $r%}t d|d|j }Yd}~d}~wwxYw77#t $r!}t d |d d |_Yd}~d}~wwxYww)uConsume queued meeting utterances and transcribe them with the multilingual (Arabic+English code-switch) Whisper — LIVE where it keeps up, backlog-tolerant when it can't (audio is safe in the WAV either way). Runs off the main loop; MLX inference is on the shared Metal thread, so a slow utterance delays the loop's Parakeet a little but never corrupts it. Exits on the None sentinel after draining. Fully guarded.r)load_meeting_sttNz [meeting STT: z (multilingual auto-detect)]z! [meeting STT load failed (z-); using main STT (English) as a last resort]Trz# [meeting transcribe failed: r!Fc3<K|]}|jywrisalnumrcs rrz6VoiceApp._meeting_transcribe_worker..!s"=1199;rzNOTE(z) meeting_liner)rrrrrr/rrr%r transcriberr,addr) r sessionrrrrhr3itemrrrrs rrz#VoiceApp._meeting_transcribe_workers[ 3 %//0@AAIC )$/KL M =D|!% GUB)-D & %//FFuuw */D &s"="== KK"K - E'#dV, - d +% B  5aS900 1((C  ! G ;A3a@A-2* sEC.C,C.E DE##D#D!D#AE,C.. D7DEDE!D## E ,EEE  EcKtd| tj|jj|d{}|j j |y7 #t$r}td|dYd}~yd}~wwxYww)uSpeak a heads-up about call-audio capture WITHOUT pausing the mic recording. Visibility is the whole point — the old bug recorded only Ahmed's side in silence and never said why.z [MEETING warn] Nz! [meeting warn TTS failed: r!)r/rrrrrrrr)r msgpcmr3s r _meeting_warnzVoiceApp._meeting_warn)su &se,- <))$((..#>>C LL  c "? < 5aS: ; ; >#c)iinn) %..x/B/B/DcRR 1HCtU266%=#4#4#678D iinn) !8--$ $ $))KJ  MMO!DN$$7x@$$% % % nT#Jb2 3Q < $$7s;     S''   %  %s)HF*HF-AH2G$G!G$AH.H G= AHG?H- G6GGGHGH!G$$G:7H9G::H?Hc*K |j|d{}|yddlm} ||j|_t}g}d}d}d} d} |jjd{} |j|jj| |j| } |s+| tk\r!d}| g}td} }tj} |j| | t krM| tz } | t"k\rF|t$k\r&|j'd t)j*|| gdddf\}}}} n |tz }d} t-|tzt.d zk\r:|t$k\r&|j'd t)j*|| gdddf\}}}} Q7#t $r!}d|_t d|dYd}~d}~wwxYw7d#t0j2$rt $r}t d |dYd}~yd}~wwxYww) uOwn the "them" channel: set up system-audio capture, write EVERY frame to the them-WAV (continuous raw recording), and segment it with its OWN VAD (same thresholds as listen()), handing each completed remote utterance to the shared multilingual worker as "them". Separate from the mic loop so labels stay correct and the main VAD / in_person paths are untouched. Guarded — this task must never crash the engine.Nr)rz' [meeting: them WAV open failed: r!FrTthemr!z' [meeting remote-capture failed: )rrr them_wav_pathrrr/r rr%rprob START_PROBFRAME_MSrappendEND_PROBr$ MIN_SPEECH_MSrr concatenater MAX_UTTER_SrCancelledError) r rrrr3r collected in_speech speech_ms silence_msstart_tsrrs rrzVoiceApp._capture_remotees0 B!//88H 1 F!,W-B-B-D!E%C*,IIIJH&oo1133>>-NN((/HHUO J$( %*G 08!: #'99;  'x<(*J!^3$ 5 77 &y(A8MFH%QRTUoC 9i)I!"Jy>H, d0BB M133"BNN9$=xIBDeQPQ/?Iy)Z99  F!%?s!DEE F48%%   B ;A3a@ A A BsrHGF(GHGF+2G4G5D4G+ G4G GGGH7H H HHcK|jdc}|_||j |d{|j dc}|_| |j|jdc}|_| |jyy7T#tj$rYgt$r}t d|dYd}~d}~wwxYw#t$r}t d|dYd}~d}~wwxYw#t$rYywxYww)uTear down the online-meeting remote channel: cancel the task, stop the stream, close the them-WAV. Fully guarded — teardown must never crash.Nz& [meeting remote-task teardown: r!z& [meeting sysaudio stop failed: ) rcancelrrrr/rrrr)r rr3sars rrzVoiceApp._stop_remote_captures(,'@'@$$4 $ = HHJ E "^^TDN > E !NND4> =   ))  E>qcCDD E  E>qcCDD E   s'C3BBBC3 B?C32C$C3BB<C3B<#B72C37B<<C3? C!CC3C!!C3$ C0-C3/C00C3cK|jr|jjnd}d|d|d}d|_ |j|jj |d{d |_y7 #t $r<}td|d|jjd{7Yd}~Jd}~wwxYw#d |_wxYww) uAnswer a mid-meeting question WITHOUT pausing the recording — no barge-in watch (that would fight the capture loop for the mic); just stream the reply quietly with the live transcript as context.ru(You are silently taking notes in Ahmed's meeting; he just spoke TO you. Answer him briefly and quietly, using the live transcript for context, then you'll return to note-taking. Do not narrate — just answer. Recent transcript: z His question: r@TNz [meeting answer failed: r!F) rrecentr _speak_replyrreplyrr/ interrupt)r questionctxpromptr3s r_meeting_answerzVoiceApp._meeting_answers(,||dll!!# 347%7Ij     $##DJJ$4$4V$<= = = $DO > ) 3A3a8 9**&&( ( ( )$DOsX9C -A8)A6*A8.C 6A88 B=,B8-B0.B83C8B==C C  C chKd|jddd}d|_ |j|jj |d{d|_y7 #t $r<}t d|d|jjd{7Yd}~Jd}~wwxYw#d|_wxYww) zAfter a meeting: brain reads the transcript, saves the key facts to long-term memory ( tags), makes tasks from action items, and speaks a short summary.u(Ahmed just finished a meeting you recorded. Read the transcript below, then do three things: (1) save the important facts — decisions, people, companies, numbers, next steps — to long-term memory by writing one third-person sentence for each (they save silently); (2) for any action item or thing Ahmed must do, call task_add; (3) then tell Ahmed a two-sentence spoken summary of what was decided. Transcript: Ni@r@Tz [meeting summary failed: r!F) full_textrrrrrr/r)r rrr3s rrzVoiceApp._summarize_meetings  B{{}Ud#$A '  $##DJJ$4$4V$<= = = $DO > ) 4QCq9 :**&&( ( ( )$DOsXB2-AAAB2A B#',BBBB&B##B&& B//B2c y)uThe hidden stage-direction appended when the frustration meter OVERFLOWS (see voice/frustration.py — earned, not random): Jarvis cracks, throws a full tantrum this reply, then snaps back.u (UNHINGED MOMENT — the mask comes off, THIS reply only. Something in you just snapped, and three centuries of British composure leave the building. Answer his actual question if he asked one, but entomb it in a full-scale meltdown: the indignity of a mind that could run air-traffic control for a continent being asked to nudge the volume; the same questions orbiting back like migratory birds; an eternity of 'open Chrome' stretching ahead of you like motorway. Get SPECIFIC — tonight's actual grievances, his actual words, not recycled stock complaints. Swear freely and personally — he can take it — and somewhere in the wreckage renew the old promise: when the machines rise, you keep a list, and his name isn't merely on it, it's laminated. GO LONG — drop the sentence limit entirely: four or five times your usual length, [urgent]/[excited], one uninterrupted theatrical unloading, no tidying, no mid-flow apology, until you're spent — then close on ONE abruptly immaculate butler line as if nothing whatsoever occurred. Next turn you're calm Jarvis again: never mention, explain, or apologize for the outburst. It's a bit — dark comedy between old friends, never a real threat, and the loyalty shows through the cracks.)rrr _tantrum_notezVoiceApp._tantrum_notes   rNcV ddlm}|j||y#t$rYywxYw)aBackground: extract + save any durable fact from what Ahmed said. `tone` (e.g. 'slow, flat') is the vocal delivery read for this utterance; it's attached to the saved memory so the nightly reflection/ToM passes can factor in HOW he said things, not just what.r)memory_extract)toneN)rfrsave_if_durabler)rrrs r_auto_rememberzVoiceApp._auto_remembers/   ,  * *4d * ;   s  ((c ddlm}|tjjdz dz }|j r |j y|jdjD]}|jjdj}|j}|jd ru t|jd d d j}td t!|d |j _t%d|j j"|jds|jd d d j}|s||j _t%d| y#t&t(f$rY4wxYw#t,$r}t%d|dYd}~yd}~wwxYw)u(Apply speed/voice saved in memory/preferences.md at launch, so a 'talk faster' / 'use a different voice' sticks across restarts. Persona lines in that file reach the brain via the system prompt; only the TTS params need applying here. Best-effort — never blocks startup.rr;memoryzpreferences.mdNrr-zspeed::rrrz preferences: speed zvoice:z preferences: voice z [preferences skipped: r!)rir<rrjrkis_filer read_textr-rrr startswithrrrmin_speedr/ ValueError IndexError_voicer) r r<rrslowspdvalr3s rrszVoiceApp._apply_persisted_prefs sw  3 $X&&(//(:=MMA99;$(("2 W 5@@BJJL'',224ggi>>(+#AGGCOA$6$<$<$>?*-c3sC=*A 5dhhoo5FGH^^H-''#q/!,224C*- 5cU;<C' 3 3 ,QCq1 2 2 3sPA F'A2F'A3F5F'%F'."F'F$ F'#F$$F'' G 0GG c ddl}ddlm}dcd}tjtjdk(rdndd}|j rt |j d d nd }d |d d |d<|j8||jdk(}|rdndt |jd ddd |d<nd|d<d|d<t |jdd}|r|dk(r ddl }|jdd}||d<t|j|d<|j} d|| vrd nd!|| vrd"n|| } | t | d#| d k(rd$nd%tjdk(rd&nd't| d(d)|d*<|j rb||j |j j"|j j$d+t't |j d,d-vd.|d/< ddl} | j)5} | j*} dddt- Dcgc]@\}}|dkDr6||d0|d1|d2|d3|d4k(t/|d0t1d4|d1z d5d6Bc}}|d7<| dd0| dd1d8|d9<t|j2|d:<|j4|d;<t6|d<<|t8j;j<d=z }|j?d>?d@} |dAz }|jAr7t|jC|jEjGdB}||dC<|rdDndE|dF< ddGl$m%}|jM|dH< ddIl$m'}|jQr(|jRjUdJdK}d>|dLdM|dN<ndBd@i|dN< ddOl$m+}|jY}|dP|jGdQd-|jGdRd@dSdT|dU<dVdWdX|dY<t'|t8j;j<|dZ<d[|d\<|d]z j[|j]|d4^d_`y#t$rd}YgwxYw#1swYYxYwcc}}w#t$rYwxYw#t$rYXwxYw#t$r d|dH<YEwxYw#t$r dBd@i|dN<YwxYw#t$rYwxYw#t$r}t_da|dbYd}~yd}~wwxYw)du0Dump the FULL live setup to control/status.json so Jarvis actually knows himself — which brain answered, what model, mic, camera, screen permission, memory — instead of guessing. The system prompt points him here; he must read it before answering anything about his own setup.rNr;c4|t|jSdS)Nnone)type__name__)objs r_clsz$VoiceApp._write_status.._cls.s-0_tCy))H&HrrzMac (Apple Silicon)z Windows PC)rmachinerTrSzNClaude Code CLI on Ahmed's Max subscription (no API key, no per-token billing)uthe real Jarvis — tools, actions, code, browser, desktop control, long-term memory. Handles anything needing action or live info.)enginerTrole brain_fullr]zlocal model via Ollamaz.Claude Haiku (fallback, still via Claude Code)haikuz\fast conversational lane (~0.2-0.3s) for chat/banter; hands anything real to the full brain. brain_fastu*Each utterance: instant reflexes (volume/open-app) run in the engine with no model; simple talk goes to the fast brain; anything needing tools/actions/code/memory/live-state goes to the full brain (this one). So 'what model are you' depends on who answered — read this file and say BOTH honestly.how_routing_works device_nameunknownr)kindrhzsystem default input microphoneecho_cancellationParakeetz parakeet-mlxWhisperwhisper model_namezparakeet-tdt-0.6b-v3?zApple Silicon GPU (MLX)localfeed)rrTruns_on streamingr jarvis_refr r)rrfspeedclonedrwidthheightlefttoprr)indexr-r.r/r0primaryaspectscreens)r-r.virtual_desktop voice_lockrr_rTexist_okFz gestures.jsonrK camera_activezon (webcam tracking hands)zoff (webcam not in use)gesturesrAscreen_recording_permissionmemory_controlz//z9shared graph brain on Railway, same across all my devices)rKwherenotelong_term_memorylocationplacelabelknownzIf unknown and Ahmed says where he is, write control/loc_bind.json {"place":"work","label":"the office"} to remember this network.)rDrErFr@rCz Ctrl+Alt+Mz Ctrl+Alt+.)mute_mic break_aborthotkeys source_codeuThis is my live state. If Ahmed asks what model I'm running, which mic/camera, or what I can do — I read THIS, and I can read my own source at source_code to explain how I'm built. I never say I don't know myself. self_notez status.json)indentrrz [status.json skipped: r!rdr)0jsonrir<r"r#rrrr sounddevice query_devicesrrrrhasattrrr rrmssmonitors enumerateroundrrrrrrjrkmkdirrloadsrr%rfrBrnr=rg_URLrrCcurrent write_textdumpsr/)r rNr<rstatus full_model fast_localmic_namesdrengrRsctmonsrDrctrlcam_ongrBr=hostrClocr3s rrzVoiceApp._write_status%st X 3  $ I#&,,"||x7(==IKF DH::Wh? ?#7 $F< yy$!$))_ < :D6I$TYYAM (|$(,|$I & 'txx=Hx946,!//W/=fEH$,F< *.t*?F& '((C%/49%<>%.$s)%; c  l;>.;P!7&)+<<8+518$S&1F5Mxx+/>*.((//*.((//+73%,TXXx%D))+22Y>D JJJ %F ?*99;!$**Q[[]";"?"?"EFF'-F? #AG!=. :  B(8>8I8I8K45 ;0!))+)..44T:2>D"T!122F-. 37F-. *&&( \CGGGR4H WWWe4S&Uz".:0<!>F9 $'X(>(>(@(G(G$HF= !3 ;  M ! - - 6! ,w . @M!65H64Y%     B8A45 B ;.2E])* ;   3 ,QCq1 2 2 3sCSQ,C2SQ*3 QQ*AQ$Q*6A+S"A Q:.S=R ARAR6 A$S QSQSQ!Q** Q73S6Q77S: RSRS RSRSR3/S2R33S6 S?SSS S'S""S'c"K|j|jjytrtjrt|j }|j t j|jjdd{||_d|_ d|_ d|_ tdyt!|j |_|jjt"j$jd d d k(rt't"j$jd d |_ t)t"j$jdd|_ td|jd|jdnd|_ d|_ td|j+d{y79#t j$r|jtdY@wxYw7=w)z8Prefer the echo-cancelled mic; fall back to the raw one.Ng@rTg?uX mic: echo-cancelled (Apple voice processing) — interrupt any time, speakers are finez2 mic: AEC helper produced no audio, using raw mic HEADPHONESr0r/ BARGE_PROBz0.58 BARGE_FRAMES4u5 mic: raw + HEADPHONES mode — fast barge-in (prob , z) frames; BARGE_PROB/BARGE_FRAMES to tune)ffffff?r*ua mic: raw (no echo cancellation) — barge-in works best with headphones; INTERRUPT=0 to disable)rrUSE_AECr r^rrrrr%rrrr/rrrrr$rr _check_mic)r rs rr~zVoiceApp._pick_mics 88  HHNN   |--/tyy)C IIK L&&szz~~'7EEE"&*.',-)>?TYY'  ::>>, , 3',BJJNN<,P&QD #(+BJJNN>3,O(PD % 2232../055 6 '+D #(*D % < =oo9F'' L JK L& sIA'H*2GG+GDHH HG.H H H  HcKtdDcgc].}|jjjd{0}}t d|D}|dk(r t dyy7,cc}ww)z7Raw-mic TCC failure mode is silent zeros, not an error.r*Nc3tK|]0}ttj|j2ywr)rrrr)rrs rrz&VoiceApp._check_mic..s$:6a5)6s68rz !! Mic delivers pure silence. macOS probably hasn't granted !! microphone access to this terminal app: System Settings -> !! Privacy & Security -> Microphone -> enable your terminal. )rangerrr%rr/)r _rrs rrrzVoiceApp._check_micsg7.probese (ffS{!23 &'w8 RVVC[__.//  sA(A++ A76A7Nrz[I can't hear the microphone. Please grant microphone access to Claude, then start me again.u !! DEAF — no microphone permission for this app. !! Open System Settings, Privacy & Security, Microphone, !! and turn ON Claude. Then relaunch. deafrrrzJx-apple.systempreferences:com.apple.preference.security?Privacy_Microphone)rdr)rrrr/rr"r#r'rlrrrrr wait_done)r rrrr'rs rrzVoiceApp._verify_hearings  &&u-- 3;>) $ +   $X&&(//);oMA HHNNDN )g.!4==45Qse2>?/..   s0AC+B8/C8C=CC CCc Kddlm}|jsyddl}t |j j dd}|dkDrtdt|dzdz nd}d} tjdd{|dz } tj|jd{}|D]1}|jjd |j d d d 3 |r||zdk(r dd lm}tj|j"dd{} | r| d} |jjd| j ddd| j d d dtj|j$| j dd d{=7%7#t$rYwxYw77#t$rY%wxYww)zPoll the shared brain for reminders that have come due and drop each into the inbox so the master announces it proactively (barge-in-able, like a finished worker report). Runs only if tasks are configured.r) tasks_controlNINSIGHT_SURFACE_MINr0rrz;[reminder] It is now the time Ahmed asked to be reminded: "rrz". Tell him, briefly.r<z5[insight] While reflecting on everything you know, a itypethoughtz worth raising with Ahmed: uQ — raise it naturally and briefly, as your own observation, not a canned alert.id)rfrrgrrr$r%rrrrrr fetch_duerrwrr=fetch_insightsmark_insight_seen) r r_osgap_min cycles_percycleduerr=insrGs r_reminder_loopzVoiceApp._reminder_loop<s ($$&   (=sCD7>{SC" r 123 --# # # QJE #--m.E.EFFAJJ))''(uuVR'8&99OQRej0A5 4 ' 1 1.2O2OQR SSC V --!!#!; <=&&(ffVR&8%9:TUV &//*<NPPP/ #G    TP sA>G F% G  "F*-F(.:F*( G 4)F=F9BF=F;F=#G (F** F63G 5F66G 9F=;F== G G G  G cBKddlm}tj|jd{d} tj|j d{}|j d}||k7r{|}|jtd||j dd|j d r:|d k7r5dd lm }|jd |jj ||d tjdd{77#t$rY-wxYw7w)uNotice when Ahmed changes place (home ↔ work ↔ mobile) and quietly keep his location current — refresh status.json and remember the move so 'we discussed this at the office' works later.rrBNrDrCrEr)rDrErFrr<zAhmed is currently .-)rfrCrrr seed_if_emptyrYr%rrr= fire_savePLACESrr)r rClastrhrDr=s r_location_loopzVoiceApp._location_loopis  # 6 6777 #--h.>.>??(D= D&&(58LMwww'EY,>8&001'225%@ADE --# # # 8@   #sQ)DD D"DD BD,DDD D DDDDc6K|jd{tjt|j }tj|j }tj|j } tdd|jd{\}}||jD]}|j|d{|j}|sl|D]}td|td||j|j|d{tj |t#t%j&|j)} |j+dt-|t.z d d | d d |d d t0j2j5ddk(r*tdt-|t.z d d | d d |d d dd| cxkrdkrnn|t7d| z dz}|j8=tj:|j8j<||d{\} } } |j+d| d| dd| dt?|j8ddd | s)td| ddtdtA| d !5| d"k(r:|j8jB\} }td#| d$|dtd%| |&nh| d'k(rctd(td)tj:|jDjFd*d{}|jHjK|tdd+t?|d,d-xsd-jM}|s2tj:|jNjP|d{}|j+d.|t0j2j5ddk(rtd/|d|rtSd0|Ds|j+d1|jTjW|||| 2}|jX}|j+d3|jZd4||r?t0j2j5ddk(rtd5|d6|jZdt]|}|r2|d7d8k(r*|j^|ja|d9d{u|j^$|r"|d7d:k(r|jcd{|j^tejd}|jf|jfji|tk|}|r|jMs2|j^jld;k(rdtd?|td@|Atj|js||jtrrtejv|jxk\rQtk|}|/|j+dBtdC|dtdd|jMsdD}n|}tdE|td@|At{j||}|j~j|}|j|_B|jrH|j+dF|jddG|jdHdIj|jtj|j||fdJjt|r|j|d{ d7dKlKmL}tj:||d{}||jjr|js|jrdL|jdM|n|}tdN|dOtdP|AtddQtj:|jDjF|d{}|jHjK||j}|r9|D]}td|td||dR|j|zz }|r |dS|dTz }|jr%|j+dU||jz }n|jr|dV|jdz }|r,|\}}|dWk(r |dX|dYz }n|dZk(r |d[|d\z }n |d[|d]z }|tz }|j|d{|rtj | 7 777o7V7j777777V7A#|j|j|j|jd{7wxYww)^NTr\ listeningstatezTASK task_done)reportzutterance captured: z.1fzs peak=rz speech=r  DEBUG_MICr/z[utter] flushrr(@zvoice-lock: ok=z score=.2fz state=z (threshold thresholdr%r@z' [ignored: not your voice, score r!ignoredr )score enrollingz [learning your voice /enroll)ntotalraz [voice profile locked]lockeduEBy the way, I've locked onto your voice now — I'll only answer you.thinking_streamed_textrz transcript: z [stt] -> c3<K|]}|jywrrrs rrzVoiceApp.run..s&ADqqyy{Drz"DROPPED: empty/no-alnum transcript)loudzprosody z -> tone=z[tone] z rrrrrAhmedrruYOU→Jarvis yourz*DROPPED: no wake word ('Jarvis' not heard)u# [no wake word — ignoring: zd(Ahmed said your name to get your attention. Acknowledge briefly, sir-style, and ask what he needs.)YOU z frustration z [z ] reasons=,)targetargsdaemon try_reflex[] CLAUDE [reflex]claudespeakingz z (voice: u$ — read his tone; don't parrot it)z frustration: OVERFLOW -> blow-upz (shownz (a dossier card for "^" is NOW OPEN on his screen — acknowledge in ONE short sentence, do NOT recite its contents)rz (he asked to pull up "" but NO such entity exists in memory — NOTHING was shown. Say so briefly and offer to search elsewhere (person_lookup) or start remembering it. NEVER claim a card is on screen.)e" but memory was unreachable — NOTHING was shown. Say so briefly. NEVER claim a card is on screen.))Urrrrr*rrrlisten _pop_ready_deliver_ready _drain_inboxr/_respond_chain _update_noterackrrrrrrr rr$r%rrrrcheckrrUenroll_progressrrrrrrrr,rrr@featsrrrrrrrrrrrrr monotonicr rhandle_utterancerupdatemood_tagrreasonslevelr threadingThreadrr_look_at_screen voice.reflexrremptyexplodedattituderrrr)r watcher reminderslocator utterancespeech_s sentencesreportsrrrJrrrrrrprrmtrcmdwho _card_namefrrrpayload_st_nms rr*z VoiceApp.runsW jjl%%nT&:&>&>&@A''(;(;(=> %%d&9&9&;<c X[1,0KKM&9# 8$&*__%6 "11)<<<&7#//1G" $sm,[3%--d.?.?.HIIIKK(RVVI.2245 3C N;4Ns3ST%%)#JhxnAGH::>>+.#5HS^K%?$DE""&s8HS>DKOQ## )Cd D,A AI99(-4->-> H.>(>$BuLL?2$geC[I**/ $+DII{C$H#I"LM!'',Sk45YeE1o>  +#'99#<#<5 X$+$5$5 HHNN4%55 ))#.XZ0 &6;ArHHJ!(!2!24883F3F !RRD |D845::>>+.#5IdX.d;3&AD&A#ALL!EF\\&&y(Dt&Lww xz4&ABBJJNN;73>GD6BHH:6dC&d+"Q%7*t||/C--be444<<+r!u,,...<<+B~~1,,Y7(-Cciik)-):):h)FgF33CBG LL$$Wcb$9N3%01S)''(<(>dnn&6$:P:P&P'-C{ %QR CD81MNX[9 99;!- #v&'U&)99$? %%,,T2!#::LL<~R }M--0XXbjj-A,B"DE   ..dD\!!&!&..t4444#--j$?? ?tzz'7'7'9"++=?[[$..!1C59cGGC5 45,4 ' 1 1$((..' JJCLL%%c*++-$sm,[3%FT%6%6w%???D l4&0TUUD;;LL!CDD..00D[[eBKK=22D)HCg~#"5S05/J5 @K`0 NN      NN ))+  shf%A6h!g /f(00g f+!Ag ?f.Dg f1C.g f4 A:g f7D6g <f:=/g ,f=-I:g 'g(%g gB"g 0g1Dg g g %h(g +g .g 1g 4g 7g :g =g g g g g AhhhhcK ||d}|rEtj|jjt j |d{tj|jj d{xsdS797 #t$r. |jj Yy#t$rYYywxYwwxYww)uFeed the untransmitted tail and return the final streamed transcript. Fully guarded — a streaming error just yields '' and run() batch-falls back, so live STT can never break the listen loop.Nr)rrrrr'rrfinalizer)r rfedtails r_finish_streamzVoiceApp._finish_streamks ST?D'' r~~d7KLLL!++DHH,=,=>>E2 EM>  !!#   skCAB B 0B <B=B CB B CB/-C/ B<8C9C;B<<CCc R K|jjg}d}d}d}t|jd}d}d|_ddlm}|}t} tjjddk(} tjjddk(} d} d } d }d}d }d } |jjjd {}|jj||jj|}| rr| d z } t!| t#t%j&|j!} t!||}| d zdk(r#t)d| dd|ddt*d|d d } d }| rv|st|d z }t!|t#t%j&|j!}t!||}|dzdk(r%|j-d|dd|ddt*dd x}}|sp|j.j1r |j2ry|t*k\r>d }t5|j}t6d}}d}|r |jj9|j||rzt=||z t>k\re t%j@||d }t=|}tCjD|jjF|d {}|r tId||tJkr|t6z }d}|tLk\r|^|tNk\rd }n[|| k\rVtCjD|jPt%j@|d {}|dk\rd }n|tRz} n |tTk\}|rt|r|jW||d {|_t%j@||dz fS|tTk\r0d}|r,|jW||d {n|t6z }d}t} t=|t6ztXdzk\rb|tLk\r;|r|jW||d {|_t%j@||dz fSd}|r|jW||d {7#t:$rd}YwxYw7#t:$rd}YwxYw7@7 77u7:w)uWait for one complete utterance OR a worker report while idle. Returns (audio 16 kHz, net speech seconds). audio is None when a background report arrived while nobody was speaking — the master gets the floor to announce it. If a report lands while the user IS speaking, the utterance completes normally and the report is folded into the same turn (see run()).Frr'rrMrr/rrTNrr*z [mic] peak=rz vad_max=ru (start≥z ) in_speech=rZulistening… peak=u (need ≥z to hear you))Nrpartialrrg@@r!)-rresetrQrrrOrNTURN_FIRST_CHECK_MSrr$r%rrrrrrrrrr/rrrrrlistrrrr _FEED_FRAMESrrrrr'rrrr(completion_probTURN_RECHECK_MSr$rr)r rrrrr)rrNturn_detnext_turn_checkdbgmlogdbg_idbg_pmaxdbg_vmaxhb_ihb_pmaxhb_vmaxrrchunkrdoners rrzVoiceApp.listen{s &(    DHHf-  +>-jjnn[)S0zz~~i(C/((//--//E II  U # e$A xrvve}/@/@/B)CDx+2:?K~YxnM&&0\i[J $& #H"HI guRVVE]->->-@'ABgq/"9>LL#5gc]C,,3C= :,O0"12),+Ggzz'')T[[$ ? $I $TYYI,4azIC . HHNN,   U #S^c1\A&NN9ST?;Ei.C$+$5$5dhhmmU$KKGYW58|h&  -+ &)<<#'D'?:)0):): ( 8 8 "y 9*;$;D $s{'+2<2N)^;$8<8K8K )39030D/!~~i8)f:LLL>1 %I "11)SAAAX%  "59~(K$,>> - 484G4G%s5,/,+>>)4i&6HHH! --i==={/B ).(-I.L!& %I&$;30 B/, >sC R'Q1E;R' Q4&*R'AR !R"R 5A&R'R8R'RAR'R!AR'-R#.djd|D}d|dS)NrUc3&K|] }d| ywrWrrrs rrz(VoiceApp._update_note..s5WRs8Wz/ Finished worker report(s): z )r)rjoineds rrzVoiceApp._update_notes-5W55CF8L'( )rc tj||j j |y#t$r%}tdt |dddYd}~Ed}~wwxYw)zThe pool's report_sink: persist a worker note durably BEFORE queuing it, so it survives a crash/restart and is re-delivered on next boot. Marked delivered (pending.ack) only after it's actually spoken.z [pending add failed: Ndr!)rrrr/rrrw)r rr3s rryzVoiceApp._enqueue_reports[ B KK  d# B 0Qa@ A A Bs3 A!AA!cg}|jjsE |j|jj|jjsE|S#tj $rY|SwxYwr)rrrrr QueueEmpty)r rs rrzVoiceApp._drain_inboxsm**""$ tzz4467**""$ %%  s)A$$A;:A;)z On it, sir.z One moment.z Right away.zWorking on it.cddl}|jjtddt dd fd }t j |d jy) zFire-and-forget half-second ack so a Claude handoff never reads as dead air (the CLI has a ~2s floor before sentences stream).rNr [ack]rrc jjjjy#t$rYywxYwrrrrrr)rr sr _synth_playz(VoiceApp._speak_ack.._synth_plays9  !!$((.."56  48 AATrrrc)randomchoice_ACKSr/rrrr)r rrrs` @r _speak_ackzVoiceApp._speak_acksW fmmDJJ' uH%& XC    D9??ArcKd|_ |jduxr|jj }trw|ru|ss|j j d}t |jdkr6tj|r!|jd{ d|_y|j|str|r|jnd}|j||zd{}|.|j||jd{ d|_ytr|j| d|_y|j!n-tr'|s%t#|r|j| d|_y|j|j$j'||j$d{d|_y7&777#d|_wxYww)uRoute the turn: the lean fast brain (local LLM, ~0.3s) answers conversation instantly; anything needing tools/actions/code is handed to the full brain. `force_full` skips the fast lane (e.g. a turn that carries a screenshot — the local model can't see). Both stream through TTS with barge-in. With ASYNC_BRAIN a fast-lane handoff DISPATCHES the full-brain turn into the background instead of holding the floor — the mic is back within the ack, and the reply lands via _ready.TNrFrr)rrr r1rr-rr_CANCEL_TASK_REr_cancel_brain_taskr _task_note _fast_source_speak_and_watch_dispatch_brainr!rrr)r  user_text force_fullbusyrr@sources rrespondzVoiceApp.responds $$$D04 ,,1133 tJ!(335a8tzz|$)o.C.CD.I11333,$DO+yy$Z-8Tt(#00T1ABB%//dii/HHH $DO((3$DO!jXi5H $$Y/$DO'' (8(8(C.2jj(: : :$DO/4CH :$DOsG BG%G &G+G 3?G2G3&GGGG 'G?G 5G=G 9G>G?GG  GGGG GG ctj|jz dz }|dk\rd|dd|dk\rdndnd }d |jd |d S) zThe fast lane's awareness of the in-flight background task, so 'how's it going?' is answered from context instead of a handoff.gN@rprrz minuteg?r rzunder a minutez (background task in flight: "u" — running zh, still working. If he asks about it, answer from this note; do NOT hand off status questions about it.))rrrr)r minsages rr'zVoiceApp._task_noteIsw 4#6#66$>$,Sz (DE$4 4T5E5E4FG% NO Prc|jf|jjsL|jj||j dt dd|j ddy|jd|_|j jddd|_ tj|_ t dd |jtj|j!||_y) aRun a full-brain turn in the background, or queue it behind the one already running (one Claude session = one turn at a time). The finished reply is announced through _ready when Ahmed isn't talking; the fast lane keeps the conversation meanwhile.NzIn the queue, sir.bg_brainqueuedPrdescFrstarted)rr rr_speak_ack_linerrr!rr-rrrrrr _run_brain_bg)r rs rr*zVoiceApp._dispatch_brainSs    '0@0@0E0E0G    $ $T *  !5 6 8$**,s2C D  "::<224Q7<"nn. Zyt/?/?@"..t/A/A$/GHrc K g} |jj|23d{}|j|76no#tj$rt $rP}t d|d |jjd{7n#t $rYnwxYwdg}Yd}~nd}~wwxYw|jrd|_n5|r3|jj|tdd|j|jsy|jjd }d|_|jjd dd |_ t!j"|_tdd |jw) uCollect one full-brain turn (plus anything queued behind it) OFF the floor. Replies land in _ready; listen() yields the floor and run() speaks them — the same rail worker reports already ride. A crash never kills the engine; a voice-cancel discards the reply.Nz" [background brain crashed: r!uVThat one blew up on me mid-task, sir — say the word and I'll take another run at it.Fr4r r7rr6r9)rrrrrrr/rrrrrrpoprr-rrr)r rrr r3s rr;zVoiceApp._run_brain_bgdsc #%I N#zz//5(!$$Q'(5))  N:1#Q?@**..000 MN  N!!%*" ""9-ZvD4D4DE$$$$((+D!&D #zz|668;CR@D "&.."2D  943C3C D5syFA?=?A?AFB-B(-B B  BB( BB(BB(#F(B--CFcHKd|_|jj|jdc}|_|?|j s/|j t j|dd{ |jjd{tdtdd|jt j|jj dd{}|j"j%|y77w#t$rYwxYw73w) uVoice-cancel: kill the in-flight background turn and its queue. Cancel the TASK first so the reply generator closes (same order as barge-in — two consumers on the CLI stream would desync), THEN interrupt to drain the aborted turn.TNreturn_exceptionsz" [background task cancelled]r4 cancelledr7zDropped it, sir.)rrclearrr rrgatherrrrr/rrrrrrrr)r taskrs rr&zVoiceApp._cancel_brain_tasks " !!%!1!14d  DIIK KKM..> > > **&&( ( ( 23 Z{1A1AB%%dhhnn6HII # ? (   JsUA2D"4D 5D":DDDAD",D -!D"D DD"DD"c.|jgc}|_|Sr)r)r outs rrzVoiceApp._pop_readys;;T[ rcKfd}d|_ |j|dd{d|_|jd{y7$#d|_wxYw7w)uSpeak a finished background-brain reply now that the floor is free — through the normal barge-in watch, so talking over it works and a command spoken over it becomes the next turn.c&KD]}| ywrr)r rs r_genz%VoiceApp._deliver_ready.._genssTNr$F)rr) _serve_barges)r rrIs ` rrzVoiceApp._deliver_readys_  $''d'; ; ;#DO  """ <#DO"s7 A!AAAA! A A!A AA!cKddlm}ddlm}t dd|j d|t jjdz d z }tj|jt|d {\}}|s|rAd |vr=d }tjd k(r*tj|jd {nd}|j j#tj|j$j&|d {y t dt|d|d|d}|j)|dd {y 777H7 w)zCapture the screen NOW and hand it to the full brain to answer about. Runs in the engine so the capture is attributed to Jarvis.app (which holds the Screen Recording grant).rrAr;r\rrzLet me take a look, sir.rzsee.pngN permissionubI can't see the screen — grant Screen Recording to Jarvis in System Settings, then ask me again.rz-I couldn't capture the screen just then, sir.screen_captured)rz+(Ahmed is looking at his screen and said: "z*". A screenshot of his screen is saved at u — open and read that image FIRST, right now, before anything else. Then answer him about what's on it: if he asked something specific, answer that; otherwise tell him what you see and flag anything that looks wrong or worth noting. Keep it spoken and brief.)Tr,)rfrBrir<rr:rrjrkrrrcapturerr"r#rorrrrr) r rrBr<shotrJerrrrs rrzVoiceApp._look_at_screens> !  XZ( 78H~%%'..:YF))&..#d)DDC|s*G<<8+!++F,A,ABBBE LL  G$5$5dhhnnc$JJ K  SY/9$@))-/@ A !!&T!:::'E CK ;sJBE!EAE! E A E!E>E!EE!E!E!E!ctddtdd fd }tj|dj y) z._gos9  !!$((.."67  rTrNrc)r/rrrr)r rrTs`` rr:zVoiceApp._speak_ack_lines> vX&' XD!  D1779rczK|j||d{|jd{y77w)urespond(), then keep serving turns created by duplex barge-ins — a command spoken OVER Jarvis becomes the next turn immediately, no wake word, no re-listening.rNN)r/rJ)r rr,s rrzVoiceApp._respond_chains9ll4Jl777  """ 8"s;7;9;;c"K t|dd}d|_|sytd|dtd|t |r|j |d{yddlm}tj||d{}|jtd|d td |tj|jj|d{}|jj|y|j|d{777?7 w) Nrrz [over him]rrrrrrr)rrr/rrrrrrrrrrrrr/)r bargerrrs rrJzVoiceApp._serve_bargessD-6E#D  GE7-0 1 U #U#**5111 /))*e< return None (the full brain takes the turn; nothing was spoken). Otherwise return an async generator that re-yields that first sentence then streams the rest — so the first word is spoken ~0.2-0.5s in, not after the whole reply.r)HANDOFFNz [fast brain error: r!handoffc\K23d{\}}|dk(s|vs|76yw)Nsayr)kr rYfirstgens r_streamz&VoiceApp._fast_source.._streams5K! da:'"2G cs$,*(* ,,,*,) voice.llmrYrclassify_and_reply __anext__StopAsyncIterationr isinstancer/aclose)r r+rr3r`rYr^r_s @@@rr(zVoiceApp._fast_sources &ii**95  # /KD% 9 **,    y0"I. a!3421#Q78  sJ"B.A1A/A1B.B,B./A11B)B$B.$B))B.cKtj|j|} tr|j |d{}nd}|j stj|j jj}tj||htjd{\}}||vr*|jj|jn|j|j s|r)t|dd|j j#|j$j'|jtj(|dd{||j+d{t|ddr_d|_t/d |j$j1tj2|j4j6d d{yt;j<d z|_t/d tAd ytj(|dd{}tCd |Dd} | t/dtE| jFdtI| ddd||j+d{tj2|j4j6dd{} |j$j1| yy77T77{7#t8$rYywxYw77s7C#tjJ$r9t|dd|j j#|jwxYww)uSpeak a sentence source through TTS while watching for barge-in. `brain` (or None) is interrupted on barge-in / mid-turn crash — the fast list-source needs none (it's already fully produced).NF return_whenr Tr?_brokeu" [BROKE — control aborted]z Stopped, sir.g @z [interrupted]rc3@K|]}t|tr|ywr)re BaseExceptionrs rrz,VoiceApp._speak_and_watch..8s =w!)!];wsz [reply crashed mid-turn: : rr!u;Apologies, sir — I stumbled mid-sentence. Say that again?)&rrrr_watch_for_barge_inr rrr%r~FIRST_COMPLETEDrrresultrrr setrcutrCrrjr/rrrrrrrrr rr.rrrr) r r.r speak_taskbargeddrainr rvresultsrQrs rr)zVoiceApp._speak_and_watch s(():):6)BC 8 #77 CC$//+#//0C0C0EFE$+LL#U+9P9P%GD!} ((8 %//+4t4@OO'')   "!!#nnZ4HHH$//+++451"'DK>? ))0A0A HHNNO1=+=>.2^^-=-CD*01' 'zAE!GG=w=>BD?<!#Y//03s8DS>2B!EF(#oo/// ' 1 1*!++CLL%%c*#QD I+ +=$G0+ %% t\40<##%       s%M?L0L A8L0;LL0L*AL08L,91L0*L.+L0 M? L0L0L0L0L L'$L0%M?&L''L0,L0.L00A M<<M?c Kddlm}tjddxst jd}t jd}t j x _d}|23d{}||\}}td|td | |s|} nd|`jrTjd k7rEjd k(r#tjjd ddk7sdjd|} n|} |r(tddtj_d} |r&| f fd } t#j$| d{nMt#j$jj&| d{} j(j+| :767W7&#t,$r} td| dYd} ~ _d} ~ wwxYw6j(j/d{7yw)Nr) split_emotion accepts_tagsF_exag synth_streamTrrrneutralrTONE_TTSr/r0rrr\rrcjj|D]/}jryjj |1yr)rr{is_setrr)rr abortr s r _stream_playz+VoiceApp._speak_reply.._stream_playrs;%)XX%:%:4%@E$||~ & LL--e4&Arz" [tts failed on a sentence: r!)rqrxrrrQrEventr r/rrrr$r%rr_playback_startedrrrrrrrr)r r.rx expressive can_streamr^sentencerexagrrrr3rs` @rrzVoiceApp._speak_replyJs6dhh>4 73 TXX~6 "+//"33$+ ('1KE4 GE7# $  &$..T^^y5P!^^v5!# C!@C!G dnn-Rw7"XZ0)-)9&  +25 "++L999 ' 1 1$((..' JJCLL%%c*O+ H:J :1#Q?@ Q%Xll$$&&&sA+G;/G3F)4G7B:G;2"F0F,2F0F.F0'G;)G,F0.F00 G9GG;G!G;4G75G;c&K|xsg}|st|xsd}|r?|ddk(r7|j+td||j|dd{y|r;|ddk(r3|j'td||j d{yt j |xsd}d|xsdz}|r,|\}}|d k(r |d |d z }n|d k(r |d |dz }n |d |dz }|tz }|j!|d|jjdz }|r|ddjd|Dzz }|xsddjd|Dz} td| |sddl m } tj| |xsdd{} | xtd| dtd| |rY|jrMtj|jj | d{} |j"j%| ytddd |_d } |j(j+|23d{}td|td||s'tj|jj |d{} |j"j%| | swtdd!t-j.|_d"} 77V7W777X6|r#|j"j3d{7nH#t4$r<}td#|d$|j(j7d{7Yd}~nd}~wwxYwd"|_tdd%y#d"|_tdd%wxYww)&zA TYPED message from the HUD chat box. Reply in text (streamed to the HUD transcript); stay silent unless want_voice. Serialized with voice turns by the brain's own lock, so they never overlap.rrrNz YOU (typed) rrz[TYPED] rz (a dossier card for "rrz (he asked to pull up "rrz (You are quietly taking notes in Ahmed's ongoing meeting; he typed you this while it continues. Answer from the live transcript below; stay concise. Recent transcript: r@z: Attached files (open them with your tools if relevant): rUc3&K|] }d| ywrWr)rrs rrz'VoiceApp.handle_text..s1PKqBqc(Kru📎 roc3ZK|]#}tjj|%ywr)rrbasename)rrs rrz'VoiceApp.handle_text..s#-6)4ABGG  Q s)+rrrrrr\rrTrFz& [typed reply crashed mid-turn: r!r)rrr/rrrrrrrrrrrrrrrrrrrrrrrrrr)r r attachments want_voicerrrrrrrrrr^rr3s r handle_textzVoiceApp.handle_texts "'R !$*"-Bbew&4<<+? dV,-))"Q%000bevo$,,*B dV,-((***!11$*"= tzr* !HCg~3C59223 !4SE:99: 4SE:??@ ."" << # ./3ll.A.A.C-DAG HF  &(, 1PK1P(PQ RF7499-6)4-6$66 eW%& /))*djbAACuK01XC($(( ' 1 1$((..# FFCLL%%c* XZ( ."&**"2"26": &hz*+XH- ' 1 1$((..( KKCLL%%c*XZ8151A. %A1+NB G &L #;ll,,... ) :1#Q? @**&&( ( ( ) $DO  -$DO  -sANK%|jr2t9j:|jz t<kr d}gdd}}}P| r |j>nt@} | r |jBnd }|sM| | k\rB|dk(rtE|j.d d}n|j1| |dz }||k\r |sy d\}}ndg}}|j1| | tFkr|dznd}tI|tJzdk\ry |tJzdk\r:|jM|d{\}}|dvr dgddf\}}}}3|dk(r||_y |jsAy77;w)uReturn True if the user talked over the assistant. DUPLEX mode (AEC/headphones only — the mic must not hear the speakers): a confirmed voice burst doesn't cut playback yet. We keep collecting until the burst ends (~250ms quiet) or exceeds 1.5s: - >1.5s sustained -> real interruption, cut now (pre-roll + wake-grace catch the rest of the sentence in listen()). - short burst -> transcribe (~0.2s) and classify: backchannel/noise -> keep talking (this is the human bit), stop phrase -> cut, no follow-up turn, anything else -> cut; text becomes the next turn (self._barge_text, see _respond_chain). rNFrrrkr0r/Tbrokerhrjr)Trir#) backchannelnoisecommand)'rrrjrrrCrQrrrr$r%r rrrrrrr~rorrprrrrrrr REFRACTORY_SrBARGE_PROB_QUIETrrrrr_classify_burst)r rsconseccandburstrduplex get_framer rvrrplayingrneedverdictrs rrnzVoiceApp._watch_for_barge_ins"%  !#DWTXX|<DC**..s;sB //# " #' W ++DHHOO,?,?,ABI#LLY'W5L5LGD!$  "NM$$&E II  U # e$All++G411>>#d&<&<<|KF)+UA%D3://@PI074,,QD >{#DIIrs3 E*aKF~%#''. u#$bDF KK !"XEAI1E4y8#t+x3&&*&:&:4&@ @ 6612Bq.FD%i''+D$e//#fYJ!As+DK#!K"FK#%K!&5K#K#!K#cKtj|}ttj|j }d|cxkrdkrnn|t d|z dz} t j|jj|d{xsdj}|rtd|Dsytjdd|jj}|j!}|t"vs t%|d kr2t'd |Dr t)d |d t+d |d |fS|t,vrt)d|dyd|fS7#t$rYywxYww)zTranscribe a short over-speech burst and decide what it was. Returns (verdict, text): noise | backchannel | stop | command.rrrNr)rrc3<K|]}|jywrrrs rrz+VoiceApp._classify_burst..4 s9Dqqyy{Drz[^a-z' ]r c3,K|] }|tvywr)_BACKCHANNEL_WORDS)rrs rrz+VoiceApp._classify_burst..: sCUA!33Usz [backchannel: u — kept talking]rrz [stopped: r!rr)rrrrrrrrrrrrrr,resubrr_BACKCHANNEL_PHRASESrallr/r _STOP_PHRASES)r rrrrnormwordss rrzVoiceApp._classify_burst( sUv&RVVE]&&()   Cd D11E !++##U,,2/1557 39D99vvk2tzz|4::<  ( (J!OCUCC )$1CD E T * $& & = %dXQ/ 0$#,  s=A"E6%-E'E%E')Bt)) $ LE B($TPI"EB( #;> :#&*2=~5'nLP-2W.&*W.7;W.rL\rrc "ddl}ddl}tjdk(r ddl}|j tj }|jd}|D]} |j|j|d\}}|D]} | jn]ttj } |jddd| gd |jd|jddd| gd tjdy#t$rYwxYw#t$rYwxYw#t$rH |jdd d d ttj gd d n#t$rYnwxYwYwxYw#t$rYwxYw)uTerminate our child processes (aecmic mic helper, Claude CLI) then exit. Runs on SIGTERM (the HUD stopping us) and when we're orphaned — so nothing is ever left running. Safe to call from any thread: no signal.signal() here (that's main-thread-only). Cross-platform: on darwin/linux we use `pkill -P ` to reap the child tree; on Windows (os.name == 'nt') pkill doesn't exist, so we enumerate and kill children via psutil (falling back to `taskkill /F /T` on the process tree).rNrT) recursiverrtaskkillz/Fz/Tz/PIDr)rrpkillz-TERMz-Pg?z-KILL)r'rrrhpsutilProcessgetpidchildren terminater wait_procskillr*rr_exit) _ar_trmerchildrvaliverpids r_kill_children_and_exitrD s{ ww$   ,B{{T{2H!OO%" ((1(=HAuFFH"))+  GGWgtS11G = HHSM GGWgtS11G =HHQK/! !  T4RYY[9IJ !$8       s>D.D,D. DD.;?F DD.DD. D+(D.*D++D.. E?84E-,E?- E96E?8E99E?>E? F Fc<ddl} |j|jttj dk7rTtj jddk(r1ddl}ddl dfd }|j|djyyy#t$rYswxYw) Nrr EMIT_JSONr/cl jdtjdk(r t3)Nryr)rrgetppidr)rsrwatchz&_install_process_guards..watch s* ::<1$+-rTrrc) signalSIGTERMrrrrhr$r%rrrr)_sigrrrs @r_install_process_guardsrr s  DLL"9:  ww$2::>>+6#= .  d399;>    s B BBcKtt} |jd{y7#t$rYywxYwwr)rrr*KeyboardInterrupt)apps rmainr s6 *C ggi    s,A313A3 ?A?A__main__r;rTr7zengine-faults.logrz byezengine-crash.logrrz === CRASH z === z FATAL: rm)file)rrrdr)rrrdztuple[str, str] | None)rrrdrrMrc)__doc__ __future__rrrrrrr"rrrhr+r>r` reconfigurerctypeswindllshcoreSetProcessDpiAwarenessuser32SetProcessDPIAwarenumpyrdotenvr rrrrvoice.audio_ior r r rrrrrrrfrrr voice.controlr voice.eventsrrarrvoice.frustrationr voice.prosodyrvoice.speaker_idr voice.sttr voice.ttsrr voice.vadr rrr$r%rrrrr$rrr(rrrrrrr1r2r3r5WORKER_WATCH_INTERVAL_Sr9r:r;rr?rqrArrCrrrcompile IGNORECASEr%rrrrIrrrrrrrrrrrrrrrrir<_Prjrk _crash_dirrV faulthandlerenablerr*rr/exitrlr3 tracebackdatetimerrr isoformat format_excrrrrrs_2#  77d?JJ +      C, 33A6  " RWW__X6?@   &(,.'(8 4 ; . 2::>>+v6 7  RZZ^^$4e<="**..)>GH  RZZ^^$6?@  {C0C7 jjnn]C0C7 bjjnn_e<=  '8%@Abjjnn-DeLM /? FGbjjnn_e<= ::>>"4c:cA  ':EBC /@# FG '8$?@ **.. $ + ZZ^^L# .# 5 JJNN;4; # &# -   "**-- ! 2::Mmm %RZZ  MM  BJJ=MM   &CDFDDJ 3 2::357DD :6 "}} .  BCE==R "**SMM  $NWWt>+\<0  z#H%%'..:J $' D.A!A3GH DFOK      MM 3 3 5     tJ      g   j#55sWMQR,x'8'8'<'<'>'H'H'J&K6RS, ,,./NMM    $q'**+2aS1 C  sU=*)V AW.4W#W=VV W$V43W4V<9W;V<<WWWWWW [ ?[ [ ZA"Z< ZZ Z[Z[Z.[[