yj& ZUdZddlmZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z mZejeZdZdZdZd Zd Zd ZGd d eZd ddddddedd Zded<dZehdZdydzdZd{dZ d|dZ!d a"d}d!Z#d{d"Z$d~d#Z%dd&Z&d}d'Z'dd)Z(dd+Z)dd-Z*ddd/Z+ dd d d0dd3Z,d{d4Z-ddd6Z.d|d7Z/dd9Z0d:Z1d{d;Z2dd=Z3dd?Z4dd@Z5ddBZ6ddCZ7GdDdEZ8ddGZ9GdHdIe8Z:dJZ;dKZGdQdRe8Z?GdSdTe8Z@ddUZAd{dVZBd{dWZCdddXZDGdYdZZEdaFd[ed\<daGd]ed^<daHejIZJdd_ZKdddaZLddcZMddeZNdd dfddmZOddnZPddoZQddpZRddqZSd{drZTd{dsZUdddtZVddvZWddwZXd~dxZYdS)uWake-word ("Hey Hermes") detection — hands-free session trigger. A lightweight, always-on hotword listener that fires a callback when a wake phrase is spoken — the "Hey Siri" / "Alexa" pattern. Shared by the CLI, TUI, and desktop GUI (one of them owns it, gated by ``wake_surface_enabled``): say the wake word, Hermes opens a fresh session and captures voice via the existing pipeline, then answers. Three engines, all fully on-device (no audio leaves the machine for detection): * **openwakeword** (default, free, no API key) — loads an ONNX model. Defaults to the bundled "hey hermes" model (``tools/wakewords/``) so the wake word works out of the box; or point ``wake_word.openwakeword.model`` at a built-in name (``hey_jarvis``, ``alexa``, …) or a custom ``.onnx`` for another phrase. * **sherpa** (free, no API key, open vocabulary) — sherpa-onnx keyword spotting. Detects ANY typed phrase with no training: set ``wake_word.phrase`` and the phrase is tokenized at runtime against a small streaming zipformer model (~13 MB English model, one-time download). * **porcupine** (premium) — Picovoice's engine. Needs ``PORCUPINE_ACCESS_KEY``; supports built-in keywords and custom ``.ppn`` files from the Picovoice Console. Audio capture reuses the same 16 kHz mono int16 ``sounddevice`` path as voice mode. The detector runs on its own daemon thread; callers ``pause()`` it while a voice turn holds the microphone and ``resume()`` it once the system is idle again (two input streams on one device is unreliable cross-platform). Nothing here mutates agent context or the prompt cache — on wake we hand a plain string to the caller, exactly like a voice transcript. ) annotationsN)Path)AnyCallableDictOptionali>@g@ ceZdZdZdS) WakeWordInUsezCRaised when another surface or process owns the wake-word listener.N)__name__ __module__ __qualname____doc__5/home/ragecks/.hermes/hermes-agent/tools/wake_word.pyr r CsMMMMrr Fauto openwakeword hey hermesg333333?T) enabledsurface input_devicecaptureproviderphrase sensitivityconfirmation_framesstart_new_sessionDict[str, Any] _DEFAULTS hey_hermes>hermesr#ronnx frameworkstrreturnct|dkrdnd}tjtjtdtd|S)zGPath to the shipped hey_hermes model (.onnx/.tflite) for ``framework``.tfliter& wakewords.) r(striplowerospathjoindirname__file___BUNDLED_MODEL_NAME)r'exts r_bundled_wakeword_pathr7asi)nn**,,2244@@((fC 7<<11;CV@^@^Y\@^@^ _ __rboolcZddl}tjdko|dkS)Nrdarwinarm64)platformsysmachine)r<s r_is_macos_arm64r?gs.OOO <8 # E(8(8(:(:g(EErc&trdndS)uThe openWakeWord backend to use on this platform. openWakeWord's ONNX backend produces near-zero scores on macOS ARM64 — its shared *embedding* model is the broken stage (the melspectrogram front-end and the wake classifier both match tflite exactly). The detector arms, the microphone works, and no phrase can ever cross the threshold. Prefer the tflite backend there; ONNX stays the default everywhere else. Upstream: https://github.com/dscripka/openWakeWord/issues/336 r+r&)r?rrrdefault_inference_frameworkrAms'(( 488f4rcfgct|dtr|dni}t|dpd}|st S|dkr3tr%tsdat ddS|S)uResolve the effective openWakeWord backend from config. Honors an explicit ``openwakeword.inference_framework`` — EXCEPT the one combination that is provably dead: an explicit ``onnx`` on macOS ARM64, where ONNX's embedding model never lets a phrase cross threshold (upstream #336). Existing macOS users who pinned ``onnx`` before the tflite fix landed would otherwise keep a wake word that arms but never fires. Coerce that one case to tflite (with a one-time warning) instead of silently shipping a dead ear. Every other explicit value is respected as-is; empty falls back to the platform default. rinference_frameworkr$r&Tuwake: openwakeword.inference_framework='onnx' is set but ONNX's embedding model never fires on macOS ARM64 (openWakeWord #336) — using tflite instead. Set inference_framework to '' (auto) or 'tflite' in config.yaml to silence this.r+) isinstancegetdictr(r.r/rAr?_warned_onnx_coercedloggerwarning)rBsubr's rresolve_inference_frameworkrL~s&00G0G%N%N V#''. ! ! !TVCCGG1228b99??AAGGIII -*,,,F00# #' NN;    x rc8 ddl}dS#t$rYnwxYw ddlm}n#t$rYdSwxYwddl}|d}g|_tj d||tjd<t ddS) usMake ``import tflite_runtime.interpreter`` resolve, returning success. openWakeWord hardcodes that import but only declares ``tflite-runtime`` for ``platform_system == "Linux"``; on macOS the equivalent wheel is ``ai-edge-litert``. Alias the module so the upstream import succeeds. The alias is process-local — nothing is written to site-packages. rNT) interpreterFtflite_runtimeztflite_runtime.interpreterz3wake word: bridged tflite_runtime -> ai_edge_litert) tflite_runtime.interpreter ImportErrorai_edge_litertrNtypes ModuleType__path__r=modules setdefaultrIdebug)rO_litertrSpkgs rensure_tflite_runtimer[s ))))t      9999999 uuLLL   + , ,CCLK+S11107CK,- LLFGGG 4s  ..c ddlm}|d}n#t$rd}YnwxYwt |t r|niS)zAReturn the ``wake_word`` config section, shape-guarded to a dict.r) load_config wake_wordN)hermes_cli.configr]rF ExceptionrErG)r]rBs rload_wake_word_configrasq111111kmm ,, S$'' /33R/s #& 55keyrc||t|}|t|n|SN)rFr")rBrbvals r_getrfs< ''#y}}S)) * *C!$9==   #5rctt|dpdS)Nrr)r(rfr.r/rBs r _providerris7 tC$$ % % + + - - 3 3 5 5 GGrint | str | Nonect|d}|t|trdSt|tr|St |}|pdS)zBConfigured PortAudio input selector, preserving indices and names.rN)rfrEr8intr(r.)rBrawvalues r _input_deviceros_ sN # #C {jd++{t#s HHNN  E =Drfloatct|d} t|}n1#ttf$rttd}YnwxYwt t |ddS)Nr?)rfrp TypeError ValueErrorr"minmax)rBrmss r _sensitivityrysq sM " "C, #JJ z ",,, )M* + +, s1c{{C  s"+AArlct|d} t|}n#ttf$r t}YnwxYwt t |ddS)zHow many consecutive over-threshold frames are required to fire. ``1`` restores the old single-frame behaviour; higher values reject ambient-speech blips at the cost of a few tens of ms of extra latency. Clamped to a sane 1..10. rr )rfrlrtru_DEFAULT_CONFIRMATION_FRAMESrvrw)rBrmns r_confirmation_framesr~sg s) * *C) HH z "))) () s1ayy"  s "==Optional[Dict[str, Any]]cd||n t}tt|dpdS)zHHuman-facing wake phrase label (purely cosmetic; engine keys detection).Nrr)rar(rfrhs r wake_phrasers3##&;&=&=C tC"" # # 3|3r) prefer_client force_localrrc||n t}|rdStt|dpd}|dvrdS|dkrdSt rdS|rdSdS)zReturn ``local`` or ``client`` capture mode for this arm. ``prefer_client`` is set by remote desktop (Mac mic, headless backend). ``force_local`` keeps CLI/TUI on the process mic. Config ``capture`` is ``auto`` | ``local`` | ``client``. Nlocalrr)clientremoteexternalr)rar(rfr.r/_local_input_device_ready)rBrrrms rresolve_capture_moders##&;&=&=Cw d3 "",f - - 3 3 5 5 ; ; = =C ...x g~~w !""wx 7rc t\}}n#ttf$rYdSwxYw |}n#t$rYdSwxYwt |t r(t|dpddkS |D]Y}t |t r|dnd}|t|dd}t|pddkrdSZn#t$rYdSwxYw |dd}t |t r|dnd}t|pddkS#t$rYdSwxYw)zGTrue when PortAudio is importable and at least one input device exists.Fmax_input_channelsrNTinput) _import_audiorQOSError query_devicesr`rErGrlrFgetattr)sd_devicesdevchannelsinfos rrrsAA  !uu""$$ uu'4  ?7;;3449::Q>>  C8B38M8MWsww3444SWH"3(D 6> wake phrase`` for every wake-enabled profile. Reads each profile's own ``config.yaml`` raw (cheap, no full config merge). A profile is enrolled when its ``wake_word.enabled`` is truthy; its phrase defaults to ``"hey "`` when unset. Used by the sherpa engine to listen for every enrolled profile's phrase at once and route the wake to the matching profile. Best-effort: unreadable profiles are skipped. r)read_user_config_raw)get_profile_dir list_profilesnameNz config.yamlr^rrzhey ) r_rrrrrr(rrFrErGr.r`) phrasesrrrrrcfg_pathrmwcrs renrolled_profile_phrasesrWsh!G ::::::FFFFFFFF!MOO  D4..;#d))D   5 566F**844WW[))/R!"d++266)3D3DRVVH-->??EEGG+$*GDM           NsB:C9A'C(&C9'AC('C9( C52C94C55C99 DDcddl}ddl}||fSNr)numpy sounddevice)nprs rrr}s# r6MrcT tdS#ttf$rYdSwxYw)NTF)rrQrrrr_audio_availablers<t  !uus ''selectorcd|i} ||d}n+#t$r}t||d<|cYd}~Sd}~wwxYwt|trf|d}|rt||d<|d}t|t tfrt ||d<|d}t|t tfrt||d<|d}t|t tfrt ||d < |t |} t| tr| dnd} | rt| |d<n#t$rYnwxYw|S) zResolve a PortAudio selector into JSON-safe diagnostics. Device discovery is diagnostic only. ``InputStream`` remains the authority on whether the selected device can actually open at the requested format. rrerrorNrrdefault_sampleratehostapi hostapi_index) rr`r(rErGrFrlrpquery_hostapis) rrdetailsrerrraterr hostapi_names r_describe_input_devicers *84G'22 q66$xx  (!$iiGFO88011 he - - :,/MMG( )xx,-- dS%L ) ) 8,1$KKG( )++ mc5\ 2 2 '*='9'9GO $ ++C ,>,>??6@$6O6OYw{{6222UY ;),\):):GI&     Ns, AAAAA"F44 GGrcFt|dpd}|d}|p|dnt|}t|dpd}|r|d|dn|S)Nrr$rsystem defaultrz ())r(rFr.)rrrlabelrs r _device_labelrs w{{6""(b ) ) / / 1 1D{{:&&H  M)9%%s8}}E'++i((.B//5577G%, 7e ! !w ! ! ! !%7rc|d}t|ttfrOt|ts:|dkr4 tt |S#t tf$rYnwxYwtS)zAUse the selected device's native rate when PortAudio reports one.rr) rFrErlrpr8round OverflowErrorru SAMPLE_RATE)rrs r_capture_sample_raters ;;+ , ,D$e %%jt.D.DPQ uT{{## #z*    D  sA**A>=A> output_lengthc(|||jd}|j|kr/|||jdS|jdkr|||jS|j|kr`|d|j|dz|j}|j ||dd| |z }nW| |j|j}|d|jdz |}| |||}| |dd|jS)z?Convert one native-rate capture block to an exact engine frame.dtyperr{Nii)asarrayfloat64reshapesizeint16zeroslinspaceint64addreduceatdiffarangeinterprintclipastype)rframersourceedgesvaluessource_positionstarget_positionss r_resample_audio_framers] ZZRZZ 0 0 8 8 < Privacy & Security > Microphone, then toggle the wake word.win32z&Microphone delivers only silence from z^. Set wake_word.input_device to a different PortAudio input device, then toggle the wake word.z=. Check the selected input device, then toggle the wake word.)r=r<r)rs rsilent_audio_hintrsw |x 5   |w )]75K5K ) ) )  Fw1G1G F F FrcHeZdZUdZdZded<dZded<dd Zdd Zdd Z dS)_Enginez?Minimal hotword-engine contract: feed int16 frames, get a bool.rl frame_lengthNOptional[tuple[str, str]] last_matchr)r8ctrd)NotImplementedErrorselfrs rprocessz_Engine.processs!!rNonecdS)zDClear any internal audio/feature buffer (called on every (re)start).Nrrs rresetz _Engine.resets rcdSrdrrs rclosez _Engine.closes rr)r8r)r) rrrrr__annotations__rrrrrrrrrs|IIL -1J0000""""          rrrnctj|vp3|dptj|S)N)z.onnxz.tflitez.ppn)r0sependswithr1exists)rns r_looks_like_pathr s; % ! >>6 7 7 ! 7>>% rc6eZdZdZdZd dZddZdd Zdd Zd S)_OpenWakeWordEngineu4openWakeWord — free, local ONNX hotword detection.rrBr!cddlm}|ddddl}ddlm}t |dtr|dni}t|dpt }t|}t||_t||_d|_|d krt%s |d dn2#t&$r%}t(d |Yd}~nd}~wwxYwt%s9t-rt/d t(d d}|t4vrt7|} |j|gn2#t&$r%}t(d|Yd}~nd}~wwxYw|g} || ||_t?|jj !|_"dS)Nr lazy_depswake.openwakewordFprompt)Modelrmodelr+wake.openwakeword.tflitez,wake word: tflite runtime install failed: %sz{The wake word needs the tflite backend on this Mac, but its runtime is missing. Install it with: pip install ai-edge-litertu?wake word: no tflite runtime available — falling back to onnxr&z'openwakeword model download skipped: %s)wakeword_modelsrD)#toolsrensureropenwakeword.modelrrErFrGr(r5r.rLry _thresholdr~_confirm_needed_confirm_streakr[r`rIrXr? RuntimeErrorrJr/_BUNDLED_MODEL_ALIASESr7utilsdownload_models_modellistmodelskeys_labels) rrBrrrrK model_refr'rrs r__init__z_OpenWakeWordEngine.__init__s######,U;;;,,,,,,)3CGGN4K4KT)R)RZcggn%%%XZ((?,?@@FFHH /44 's++3C88   )>)@)@  P  !;E JJJJ P P P KQOOOOOOOO P(** #"$$&Z`aaa"  ??   6 6 6.y99I G   . . { ; ; ; ; G G G LLBA F F F F F F F F GeF RRR DK.335566 s05D D<D77D<1G G<G77G<r)r8cj|}tfd|D}|r+xjdz c_jjkr d_dSdSd_dS)Nc3.K|]}|jkVdSrd)r).0scorers r z._OpenWakeWordEngine.process..Ts*II5DO+IIIIIIrr{rTF)rpredictanyrrr)rrscoresovers` rrz_OpenWakeWordEngine.processRs$$U++IIIIIIIII    A % #t';;;'($t5 urrcjd|_ |jdS#t$rYdSwxYwr)rrrr`rs rrz_OpenWakeWordEngine.reset`sM !  K           DD s $ 22c.|dSrd)rrs rrz_OpenWakeWordEngine.closei rNrBr!rr rrrrrrrrrrrrrrsr>>L97979797v    rrzhttps://github.com/k2-fsa/sherpa-onnx/releases/download/kws-models/sherpa-onnx-kws-zipformer-gigaspeech-3.3M-2024-01-01.tar.bz2z4sherpa-onnx-kws-zipformer-gigaspeech-3.3M-2024-01-01rc.ddlm}|dz dz S)Nrget_hermes_homecacher,)hermes_constantsr-r,s r_sherpa_model_rootr0xs,000000 ?  w & 44rrootOptional[Path]c@|p t}|tz }|dz r|Sddl}ddl}|dd|tdz }t d|j t|| |d5}| |d dddn #1swxYwY| d |dz std ||S) zBDownload + unpack the sherpa KWS model once; return its directory. tokens.txtrNTparentsexist_okz.tar.bz2z:wake word: downloading sherpa KWS model (one-time, ~13 MB)zr:bz2data)filter) missing_okz sherpa KWS model unpack failed: )r0_SHERPA_KWS_MODEL_DIRrtarfileurllib.requestmkdirrIrrequest urlretrieve_SHERPA_KWS_MODEL_URLopen extractallunlinkr)r1targetr<urllibarchivetfs r_ensure_sherpa_modelrI~sm  '%''D ) )F%%'' NNNJJtdJ+++-7777G KKLMMM N4g>>> gw ' '+2 d6 ***+++++++++++++++ NNdN### \ ! ) ) + +HFfFFGGG Ms0CCCc6eZdZdZdZd dZddZdd Zdd Zd S)_SherpaKwsEngineuCsherpa-onnx open-vocabulary keyword spotting — any typed phrase, zero training. The configured ``wake_word.phrase`` is BPE-tokenized at runtime against the model's vocabulary, so "hey hermes", "hey coder", or any other phrase works immediately. Here ``phrase`` is DETECTION config, not a cosmetic label. rrBr!c nddlm}|ddddl}ddlm}t |dtr|dni}t|dpd  }|rt|n td z std tt|d pd  }t}||i} t!|ddrNt#D]-\} } | | | .t)| } |d| Dtd z dtdz } ddl}i|_|ddddd}t1| | D]l\} }| dd}| | |j|<|d|d|dzm||j|_d|_ ddtC|zz}d(fd" }|"td z |d#|d$|d%|j|d&'|_#|j#$|_%dS))Nrr wake.sherpaFr) text2tokensherpa model_dirr$r4zsherpa KWS model not found at rrprofile_routingTc6g|]}|Sr)upper)rps r z-_SherpaKwsEngine.__init__..s ( ( (1QWWYY ( ( (rbpez bpe.model)tokens tokens_type bpe_modelwz.txtz hermes-kws-zutf-8)modesuffixprefixdeleteencoding rz @ g?g?patternr(r)ct|}|stdd|t|dS)Nzsherpa KWS model file missing: /r)sortedglobrr()rbhitsds r _model_filez._SherpaKwsEngine.__init__.._model_filesR!&&//**D T"#RQ#R#R#R#RSSStAw<< rzencoder-*[!8].onnxzdecoder-*[!8].onnxzjoiner-*[!8].onnxr{)rWencoderdecoderjoiner keywords_filekeywords_threshold num_threads)rbr(r)r()&r rr  sherpa_onnxrNrErFrGr(r.rrIrrrfrr8ritemsrWrtempfile_display_to_profileNamedTemporaryFileziprSreplacewriter2rr_keywords_filerryKeywordSpotter_spotter create_stream_stream)rrBrrprNrKrPr own_profile phrase_mapprofrTrrWrrkwtoksdisplay thresholdrirhs @rrz_SherpaKwsEngine.__init__sy######u555******#-cggh.?.?#F#FNcgghB ,,23399;; ( DDOOO.B.D.DL ((** ECCCDD D T#x((8L99??AA*,, &,k%: )400 1 1 7355;;== 7 7a%%aggii6666z"" ( ( ( ( (q<'((!k/**     46  ( (VM%RY)  7F++ 8 8GAtggii''S11G0:1 D $W - HHSXXd^^&67&6&6&66 7 7 7 7   g59 3c!2!222       $22q<'((K 455K 455;233-(3   }2244 rr)r8c|ddl}|||jdz }|jt |d}|j|jr|j|j|j |j}|rxd}t|}| dd |j |df|_|j|j|j|j|S) Nrrg@FTrr`r$)rrfloat32r|accept_waveformrrzis_ready decode_stream get_resultr(rvr/rsrFr reset_stream)rrrsamplesfiredresultrs rrz_SherpaKwsEngine.processs!**U"**55? $$[':::m$$T\22 9 M ' ' 5 5 5]--dl;;F 9f++OOC--3355,00"==#  **4<888m$$T\22 9 rrcf |j|_dS#t$rYdSwxYwrd)rzr{r|r`rs rrz_SherpaKwsEngine.resetsB =6688DLLL    DD s " 00c\ tj|jdS#t$rYdSwxYwrd)r0rDrxrrs rrz_SherpaKwsEngine.closesB  Id) * * * * *    DD   ++Nr)rrr*rrrrKrKszLG5G5G5G5R(rrKc*eZdZdZd dZd dZd d Zd S)_PorcupineEngineu@Picovoice Porcupine — premium, on-device, needs an access key.rBr!cRddlm}|ddddl}t jdpd}|stdt| d tr| d ni}t| d pd }d t|z }||gd }t|r|g|d<n|g|d<|jdi||_|jj|_dS)Nrrwake.porcupineFrPORCUPINE_ACCESS_KEYr$zcPorcupine wake word requires PORCUPINE_ACCESS_KEY (get a free key at https://console.picovoice.ai). porcupinekeywordjarvisrs) access_key sensitivities keyword_pathskeywordsr)r rr  pvporcupiner0getenvr.rrErFrGr(ryrcreate _porcupiner) rrBrrrrKrporcupine_sensitivitykwargss rrz_PorcupineEngine.__init__sW######)%888i 677=2DDFF  D  '11E1Et&L&LTcggk"""RTcggi((4H55;;== !$l3&7&7 70:NcMd!e!e G $ $ +'.iF? # #")F: ,+,66v66 O8rr)r8c>|j|dkSr)rrrs rrz_PorcupineEngine.process-s&&u--22rrc\ |jdS#t$rYdSwxYwrd)rr^r`rs rrz_PorcupineEngine.close1sC  O " " $ $ $ $ $    DD rNr)rr)rrrrrrrrrrrr sVJJ9999>3333rrct|}|dkrt|S|dvrt|S|dvrt|St d|)NrrO sherpa-onnxkwsrB)rowwrzUnknown wake_word provider: )rirrKrru)rBrs r _build_enginer8sq~~H;$$$;;;$$$333"3''' @H@@ A AArc ddlm}m}m}|}||o||dkS#t$rYdSwxYw)uIs a speech-to-text provider configured and enabled? A wake without STT arms the mic but every captured utterance dies at transcription — a useless (and confusing) experience. Same standard as voice mode's ``check_voice_requirements``: enabled + a real provider. r) _get_provider_load_stt_configis_stt_enablednoneF)tools.transcription_toolsrrrr`)rrr stt_configs r _stt_readyrGsy]]]]]]]]]]%%'' ~j))QmmJ.G.G6.QQ uus -0 >>cz ddlm}m}||}n#t$rYdSwxYwdddd}||}|B dd lm}||s|Sn#t$rYdSwxYw dd lm }t|S#t$rYdSwxYw) uCan the configured text-to-speech provider run (or install at first use)? The wake flow is fully hands-free (wake → speak → hear the reply); without TTS the reply is silent and the loop is pointless. PROBE, not an installer: ``check_tts_requirements`` lazily pip-installs the provider SDK via ``_import_*`` → ``lazy_deps.ensure`` — running that inside a status poll froze wake.status for the length of a pip install (and a failed install marked the wake word unavailable, unmounting the desktop ear). When the provider's deps aren't installed yet, "installable at first use" counts as ready and we never touch pip from here. r)r_load_tts_configFztts.edgeztts.elevenlabsz tts.mistral)edge elevenlabsmistralNr)check_tts_requirements) tools.tts_toolrrr`rFr r is_available_allow_lazy_installsrr8)rrr_LAZY_TTS_FEATURESfeaturerrs r _tts_readyrWsHBBBBBBBB =!1!1!3!344 uu&  !$$X..G  ' ' ' ' ' '))'22 8 55777 8   55 999999**,,--- uus0 ,, .A== B  B B,, B:9B:c ||n t}t|}ddlm}|dkrd}n |dvrd}nd}||}|}|rt nd }d }t}t} d } d } |d vr:t|} | d kr%tp|dp|} |dkr-tj dpd sd }d} nj|s|s||pd } nN| sd} nI|r|st|dkrd} n/|r| s+ddd|fd| ffD} d| d} t|}|rt#nd }|dkr#|p| o|}|r| s| drd } n|r|p| o|}|r|s| sd} |o|o| o| o||||||||| t'|| d S)zDReport whether wake-word detection can run, with a remediation hint.NrrrrrrMrFTr$)rrOrrrBr+r rzDSet PORCUPINE_ACCESS_KEY (free key at https://console.picovoice.ai).zNThe wake word needs the tflite runtime on this Mac: pip install ai-edge-litertrzHMicrophone capture needs sounddevice + numpy and a working audio device.z and c3$K|] \}}||V dSrdr)rroks rr!z/check_wake_word_requirements..s@  T2ac       rzspeech-to-textztext-to-speechzWake word needs uN configured — run `hermes tools` (Voice section) or see the voice-mode docs.rzMicrophone capture needsuNo local microphone on this backend. Remote desktop can stream the client mic — set wake_word.capture: client or use a desktop build with client-capture wake support.) availablerdeps_availableaudio_availablelocal_input_availableraccess_key_set stt_available tts_availablerhint)rarir rrrrrrrLr[r0rr.feature_install_commandrr2r startswithr)rBrrrdeps_oklazy_okaudio_okkey_okstt_oktts_okr tflite_okr'missing capture_modelocal_input_okmic_oks rcheck_wake_word_requirementsrs##&;&=&=C~~H;" = = =%$$W--G,,..G&-7!!!%H F\\F \\F DILLL/44  -//p93I3IJd3e3epipI; 2H(I(I(OR'V'V'X'XU  @W @0099?R  @_ @@&:3&?&?7&J&JY @6@,,  #3V"X!Y     ?7???(,,L4;F.000Nx5[4W  4 9:: &hDK,CG  8 D : JJ6JiJF!#!/ c""   rc|eZdZdZedddfd dZed!dZd"dZd"dZ d"dZ d"dZ d"dZ d"dZ d"dZd#dZdS)$WakeWordDetectorzBackground hotword listener. Fires ``on_wake()`` when the phrase is heard. The engine is built once and kept alive across pause/resume; only the audio stream + reader thread cycle, so toggling the mic for a voice turn is cheap. NFengineron_wakeCallable[[], None]cooldownrp on_failure.Optional[Callable[['WakeWordDetector'], None]]rrjexternal_audior8c||_||_||_||_||_t ||_|jrddddnd|i|_d|_tj |_ tj |_ d|_ tj|_ddl}|d |_d |_d|_dS) Nrzclient capturer)rrrrrrr@)maxsizeF)rrrrrr8rinput_device_details_thread threadingEvent_stop_callback_inflight _last_fireLock_lockqueueQueue_audio_q audio_silent_silent_frames)rrrrrrr_queues rrzWakeWordDetector.__init__s     $(">22" ,+; Q Q Ql+ ! 48 _&& "+/"3"3^%% -3\\"\-E-E "rr)c@|j}|duo|Srd)ris_aliverts rrunningzWakeWordDetector.runnings L}--rrcd|jsdS ddl}n#t$rYdSwxYwt|tt t fr|||j}n/| ||j d}t|j j }|dkrdSd}t|jd}||kr||||z}||z }|jd|kr0|||j}||d|jd<|} |j|ng#t$rZ |jn#t$rYnwxYw |j|n#t$rYnwxYwYnwxYw||kdSdS)zEnqueue one int16 mono frame (or raw bytes) for client capture. Frame length should match ``engine.frame_length`` (typically 1280 samples at 16 kHz). Short frames are zero-padded; long frames are split. Nrrr)rrr`rEbytes bytearray memoryview frombufferrrrrlrrshaperr put_nowait get_nowait) r pcm_int16rarrfloffsetr}chunkpads rfeedzWakeWordDetector.feed s  "  F          FF  i%J!? @ @ D-- -::CC**Ybh*77??CCC ) * * 77 F  !  qjj",-E bLF{1~""hhrh22(-$ek!n$%  ((////   M,,.... DM,,U3333 D qjjjjjjsf &E F% E&%F%& E30F%2E33F%7FF% FF%FF%$F%cH|j5|j'|jr ddddS|jt j}g}t j|j||fdd|_|j dddn #1swxYwY| ts#| td|r*| td|ddS)z@Open the mic (or client feeder) and begin listening. Idempotent.NTz wake-word)rEargsdaemonrz1Timed out while opening the wake-word microphone.z(Failed to open the wake-word microphone.r)rrrrclearrrThread_runstartwait_START_TIMEOUT_SECONDS _halt_thread TimeoutErrorr)rreadystartup_errorss rr zWakeWordDetector.start3s Z ! !|'DL,A,A,C,C' ! ! ! ! ! ! ! ! J     O%%E24N$+y^, DL L    ! ! ! ! ! ! ! ! ! ! ! ! ! ! !zz011 T      RSS S  b      IJJP^_`Pa a b bs"B.A+B..B25B2c.|dSrd)rrs rpausezWakeWordDetector.pauseJs rc.|dSrd)r rs rresumezWakeWordDetector.resumeMr(rc`||jdSrd)rrrrs rstopzWakeWordDetector.stopPs.  rc|j5|j|j}|+|t jur|d|j|urd|_ddddS#1swxYwYdS)Nr timeout)rrsetrrcurrent_threadr2rs rrzWakeWordDetector._halt_threadTs Z $ $ JNN    A})*B*D*D!D!Ds###|q  #  $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $sAA33A7:A7c |n2#t$r%}td|Yd}~nd}~wwxYw|jdS#|jwxYw)Nzwake word callback failed: %s)rr`rIrJrr )rrs r_dispatch_wakezWakeWordDetector._dispatch_wake]s , LLNNNN ? ? ? NN:A > > > > > > > > ?  # ) ) + + + + +D # ) ) + + + +s*A$ AAA$AA$$A?rthreading.Eventrlist[BaseException]c R|jj}|}t}d}d}|jrO |j#t $rYnwxYwtd|tn t\}}nc#ttf$rO} t d| | | |Yd} ~ dSd} ~ wwxYwt||j|_t%|j}t'dt)t+||ztz }td|jdpd|j|jdpd |jd pd |t ||j|dd | }|n\#t $rO} t d | | | |Yd} ~ dSd} ~ wwxYw |jn#t $rYnwxYwtd|t|j|d} t'dt)t4tzt'd|z } |js$ |jrR |jd} n2#t $r%|xjdz c_|j| krd|_YmwxYw| } n||\} }nM#t $r@} t d| |j } Yd} ~ nld} ~ wwxYwtC| dddkr | dddfn| } |tkrtE|| |} tG| r.t)tI| nd}n#t $r tJdz}YnwxYw|tJkr\|xjdz c_|j| kr@d|_t dtJt4tM|jn6|jr/|jrtdd|_d|_ |j'| }n3#t $r&} t(d| Yd} ~ Xd} ~ wwxYw|rtSj*}||j+z |j,kr||_+td|j-sG|j-t]j/|j0ddnt(d|j$|: |1|2n#t $rYnwxYwtd| r|j3|3|dSdSdS#|: |1|2n#t $rYnwxYwtd| r|j3|3|wwwxYw)NTuLwake word: client-capture mode (frame=%d, rate=%d) — waiting for wake.feedz*wake word: audio libraries unavailable: %sr{zmwake word: opening microphone device=%s selector=%r hostapi=%s default_rate=%s capture_rate=%d engine_rate=%drrrunknownrr)device sampleraterr blocksizez(wake word: failed to open microphone: %sz5wake word: listening (frame=%d, rate=%d, external=%s)Fg?rz wake word: stream read error: %sndimrz;wake word: mic delivers only silence (peak<=%d for %ds); %su0wake word: mic audio detected — stream healthyzwake word: engine error: %su.wake word: phrase detected — firing callbackzwake-word-callback)rEr ru0wake word: detection within cooldown — ignoredzwake word: stream closed)4rrrrrrr`rIrrrQrrappendrrrrrrwrlrrF InputStreamr r_SILENCE_ALERT_SECONDSris_setrrreadrJrrlenabs _SILENCE_PEAKrrrXtime monotonicrrrrr r rrr)rrrrcapture_frame_length capture_raterstreamrrfailedsilent_alert_framesrr8 _overflowpeakrnows rr zWakeWordDetector._runes{/ +"   0  /M,,.../     KK^k      &BB)    I1MMM%%a(((    )?r4CT(U(UD %/0IJJL#&3u\L8;FGGHH$$  KKA)--f55I9I!)--i88EI)--.BCCPy    ,+!2 (     GKKK%%a(((     K          D   K +t/B D D D "!S)?+)MPSTUWcPdPd)d%e%effD &j''))9 Y* L%$(M$5$5d$5$C$CEE(%%% //14//#26III48 1$H % %*0++6J*K*Ki NN#EqIII!%!2!2!4!44FEEEE'.dFA&>&>!&C&CQQQT ;..1"e\JJE-47JJE3s5zz~~//000ADD ---(1,DDD-=((''1,''*.AAA,0)Y)+A-d.GHH (.(X $VWWW*+D'(-D% K//66EE LL!>BBBHHHH Y.**CT_, ==*- $TUUU#6==??& 377999%,'+':'+%9$eggg %WXXXsj''))9 Yv!KKMMMLLNNNN D KK2 3 3 3 &$/5%%%%% & &55!KKMMMLLNNNN D KK2 3 3 3 &$/5%%%% &5s:= A  A 1BC#ACC#3G66 IAI  II-- I:9I:6Z.NL54N5,M$!N"Z.#M$$NZ. O  5OZ.O  AZ.?QZ.Q'$Z.&Q''B Z.T#"Z.# U-UZ.UC!Z.7(Y Y-,Y-.\&2([\& [(%\&'[((>\&) rrrrrrprrrrjrr8rr)rr!rr"r)r)rrrr_FIRE_COOLDOWN_SECONDSrpropertyrrr rrrrr r rrrrrs$:NR26(-      >...X.((((Tbbbb.$$$$,,,,M&M&M&M&M&M&rrzOptional[WakeWordDetector] _detectorz object | None_detector_ownerc.ddlm}|dz dz S)Nrget_default_hermes_rootruntimezwake-word.lock)r/rBrAs r _lock_pathrDs.888888 " " $ $y 03C CCrr1c|p t}|jddt|d} tjdkrddl}|dtj| dkr)| d| |d| | |jdn9ddl}|| |j|jzn=#t&t(f$r)}|t-d |d}~wwxYw|S) zCAcquire the cross-process microphone lease, or raise WakeWordInUse.Tr5za+bntrNr{&Wake-word microphone is already owned.)rDparentr>rBr0rmsvcrtseekSEEK_ENDtellrwflushlockingfilenoLK_NBLCKfcntlflockLOCK_EXLOCK_NBrBlockingIOErrorrr )r1 lock_pathhandlerJrRrs r_acquire_machine_lockrYsK$ I 4$777 )U # #FM 7d?? MMM KK2; ' ' '{{}}!! U###  KKNNN NN6==??FOQ ? ? ? ? LLL KK )F G G G _ %MMM DEE1LM MsC2D11E+$E&&E+rc|dS tjdkrHddl}|d|||jdn1ddl}|||j n#t$rYnwxYw| dS#| wxYw)NrFrr{) r0rrJrKrOrPLK_UNLCKrRrSLOCK_UNrr)rXrJrRs r_release_machine_lockr]s ~  7d?? MMM KKNNN NN6==??FOQ ? ? ? ? LLL KK  7 7 7         s*B BB6 BB6BB66C detectorc t5t|ur ddddSt}dadada |jt |n#t |wxYw ddddS#1swxYwYdS)zDRelease ownership if the active microphone stream dies unexpectedly.N)_detector_lockr>_detector_file_lockr?rrr])r^ lock_handles r_detector_failedrc1s  / / H $ $  / / / / / / / /*  " / O ! ! # # # !+ . . . . !+ . . . . . / / / / / / / / / / / / / / / / / /s- A9 A9AA9A((A99A=A=)configrrrownerobjectrdrc |tdt5tPt|urt d|t_ttcdddSt} ||n t}t|}t||tt||}|a|a|a ||cdddS#t$rIt+ tn#t$rYnwxYwdadada t#|wxYw#1swxYwYdS)a/Claim, build, and start the detector. Idempotent for the same owner. Raises if engine construction fails (missing deps / access key / model); callers should probe :func:`check_wake_word_requirements` first. A different owner, including another process, receives :class:`WakeWordInUse`. Nz wake-word owner must not be NonerH)rrr)rur`r>r?r rrrYrarrrcrorar r`rr])rrerdrrbrBrr^s rstart_listeningrhAs };<<< !!  e++#$LMMM 'I        !!!!!!!!,--  ".&&4I4K4KC"3''F'+*3//- H!I#O"-  NN   -!!!!!!!!.   $NN$$$$ DI"O"&  !+ . . .  /!!!!!!!!!!sOA E1EA"C//EDE D(%E'D((EEE  E cht5tduot|ucdddS#1swxYwYdSrd)r`r>r?res r owns_listenerrkvs BB$AE)ABBBBBBBBBBBBBBBBBBs '++ct5t t|ur ddddSt ddddS#1swxYwYdS)z;Release the microphone only when ``owner`` holds the lease.NFT)r`r>r?rrjs rpause_listeningrm{s   u < <  AAAAct5t t|ur ddddSt ddddS#1swxYwYdS)z;Re-open the microphone only when ``owner`` holds the lease.NFT)r`r>r?rrjs rresume_listeningrps   u < <  rnct5t t|ur ddddSt}t}dadada |t |n#t |wxYw ddddS#1swxYwYdS)zr?rarr])redetrbs rstop_listeningrss     u < <        )  " / HHJJJ !+ . . . . !+ . . . .                  s-BBA B A11BB Bcdt5t}dddn #1swxYwY|duo|jSrd)r`r>rrrs r is_listeningrvss  d? *s{*   cdt5t}dddn #1swxYwY|duo|jS)aTrue when the armed stream has delivered only silence (dead mic). The stream opens fine but every frame is zeros, so detection can never fire. Lets status surfaces show "listening but the microphone appears silent" instead of a healthy state. N)r`r>rrus raudio_is_silentrysv  d? /s//rwcbt5t}dddn #1swxYwY|t|jS||n t }t |} t \}}n0#ttf$r}|t|dcYd}~Sd}~wwxYwt||S)zDReturn configured/active PortAudio input diagnostics for status UIs.N)rr) r`r>rGrrarorrQrr(r)rBrrrrrrs rget_input_device_statusr{s  C,---##&;&=&=CS!!H7AA  !777$s1vv666666667 !"h / //s*  A11BBBBrct5t}dddn #1swxYwY|dSt|jddS)z(matched phrase, profile) of the most recent wake fire, if the engine reports per-phrase matches (sherpa multi-profile routing). None otherwise.Nr)r`r>rrrus rget_last_matchr}s  {t 3:|T 2 22rwct5t t|ur ddddStjs ddddSt}dddn #1swxYwY||dS)zPush client-captured PCM into the armed detector (client capture mode). Returns True when the frame was accepted for ``owner``'s armed detector. NFT)r`r>r?rr)rerrrs r feed_audiors   u < <'     HHY 4sA AAAAct5t}dddn #1swxYwY| tddSttt |jddpdt |jdS)z8Sample rate + frame length for client capture streamers.Nr) sample_raterr)rrr)r`r>rrlrrr8rrus rdetector_frame_infors  {*DAAA"GCJEEMNNs122  rw)r&)r'r(r)r(r)r)r()rBr!r)r()r)r!)rBr!rbr(r)r)rBr!r)rj)rBr!r)rp)rBr!r)rlrd)rBrr)r()rBrrr8rr8r)r()rr(rBrr)r8)r)r)rrjr)r!)rr!r)r()rr!r)rl)rrl)rnr(r)r8)r)r)r1r2r)r)rBr!r)r)rBrr)r!)r1r2r)r^rr)r) rrrerfrdrrr8r)r)rerfr)r8)r)r)Zr __future__rloggingr0r=rr2pathlibrtypingrrrr getLoggerrrIrr<rr|r1r,rr r"rr5 frozensetrr7r?rArHrLr[rarfriroryr~rrrrrrrrrrrrrrrrrAr;r0rIrKrrrrrrr>r?rarr`rDrYr]rcrhrkrmrprsrvryr{r}rrrrrrs>#"""""  000000000000  8 $ $  !  NNNNNLNNN 7 $#"#M#M#MNN````` FFFF 5 5 5 5F<00006666 HHHH!!!!    44444%)  D< = = = = =$L""""J8888@@@@.0        ,YYYYY'YYYBCO5555 *uuuuuwuuup*****w***ZBBBB     ))))XTTTTTvT&T&T&T&T&T&T&T&v)- ,,,,!%%%%%!!DDDD 2& / / / /((, 222222jBBBB $++++ 0 0 0 0 0 0 0 0 0 3333          r