PmjQ UdZddlmZddlZddlZddlZddlZddlZddlm Z ddl m Z m Z m Z mZejeZdZdZdZd Zd Zd ZGd d eZd dddddeddZded<dZehdZdndodZdpdZ dqdZ!d a"drd!Z#dpd"Z$dsd#Z%dtd&Z&drd'Z'dud)Z(dvd+Z)dwd-Z*dxdyd/Z+dxdzd1Z,dqd2Z-d{d4Z.d5Z/dpd6Z0d|d8Z1d}d:Z2d}d;Z3Gd<d=Z4d~d?Z5Gd@dAe4Z6dBZ7dCZ8ddEZ9dxddHZ:GdIdJe4Z;GdKdLe4ZdpdOZ?dxddPZ@GdQdRZAdaBdSedT<daCdUedV<daDejEZFddWZGdxddYZHdd[ZIdd]ZJdd^dddZKddeZLddfZMddgZNddhZOdpdiZPdpdjZQdxddkZRddmZSdS)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/thesage/.hermes/hermes-agent/tools/wake_word.pyr r CsMMMMrr Fauto openwakeword hey hermesg333333?T)enabledsurface input_deviceproviderphrase 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_pathr6\si)nn**,,2244@@((fC 7<<11;CV@^@^Y\@^@^ _ __rboolcZddl}tjdko|dkS)Nrdarwinarm64)platformsysmachine)r;s r_is_macos_arm64r>bs.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_frameworkr@hs'(( 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.r@r>_warned_onnx_coercedloggerwarning)rAsubr&s rresolve_inference_frameworkrKys&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_litertrMtypes ModuleType__path__r<modules setdefaultrHdebug)rN_litertrRpkgs rensure_tflite_runtimerZs ))))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\rE ExceptionrDrF)r\rAs rload_wake_word_configr`sq111111kmm ,, S$'' /33R/s #& 55keyrc||t|}|t|n|SN)rEr!)rAravals r_getres< ''#y}}S)) * *C!$9==   #5rctt|dpdS)Nrr)r'rer-r.rAs r _providerrhs7 tC$$ % % + + - - 3 3 5 5 GGrint | str | Nonect|d}|t|trdSt|tr|St |}|pdS)zBConfigured PortAudio input selector, preserving indices and names.rN)rerDr7intr'r-)rArawvalues r _input_devicerns_ sN # #C {jd++{t#s HHNN  E =Drfloatct|d} t|}n1#ttf$rttd}YnwxYwt t |ddS)Nr?)rero TypeError ValueErrorr!minmax)rArlss r _sensitivityrxsq sM " "C, #JJ z ",,, )M* + +, s1c{{C  s"+AArkct|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 )rerkrsrt_DEFAULT_CONFIRMATION_FRAMESrurv)rArlns 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)r`r'rergs r wake_phrasers3##&;&=&=C tC"" # # 3|3rrc:||n t}|dsdStt|dpd}|dkp)||kS)a/Should ``surface`` (``cli`` / ``tui`` / ``gui``) host the listener? True when the wake word is enabled and the configured ``surface`` is either ``auto`` or this exact surface. ``auto`` makes a surface eligible; the process/machine ownership lock still permits only the first claimant. NrFrr)r`rEr'rer-r.)rrAwants rwake_surface_enabledrs##&;&=&=C 779  u tC## $ $ * * , , 2 2 4 4 >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^rrrrgetattrr'rrErDrFr-r_) phrasesrrrinforcfg_pathrlwcrs renrolled_profile_phrasesrsh!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)npsds r _import_audior8s# r6MrcT tdS#ttf$rYdSwxYw)NTF)rrPOSErrorrrr_audio_availabler?s<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. rinputerrorNrmax_input_channelsdefault_sampleratehostapi hostapi_index) query_devicesr_r'rDrFrErkroquery_hostapis) rrdetailsrerchannelsraterr hostapi_names r_describe_input_devicerGs *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'rEr-)rrrlabelrs r _device_labelrls w{{6""(b ) ) / / 1 1D{{:&&H  M)9%%s8}}E'++i((.B//5577G%, 7e ! !w ! ! ! !%7rctjdkr dStjdkrdt|dSdt|dS)zEPlatform-specific remediation for an armed stream delivering silence.r9zMicrophone delivers only silence. Grant the Hermes backend microphone access in System Settings > 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_hintrtsw |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.rk frame_lengthNOptional[tuple[str, str]] last_matchr(r7ctrc)NotImplementedErrorselfframes rprocessz_Engine.processs!!rNonecdS)zDClear any internal audio/feature buffer (called on every (re)start).Nrrs rresetz _Engine.resets rcdSrcrrs rclosez _Engine.closes rr(r7r(r) rrrrr__annotations__rrrrrrrrrs|IIL -1J0000""""          rrrmctj|vp3|dptj|S)N)z.onnxz.tflitez.ppn)r/sependswithr0exists)rms r_looks_like_pathrs; % ! >>6 7 7 ! 7>>% rc6eZdZdZdZd dZddZdd Zdd Zd S)_OpenWakeWordEngineu4openWakeWord — free, local ONNX hotword detection.rrAr 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_modelsrC)#toolsrensureropenwakeword.modelrrDrErFr'r4r-rKrx _thresholdr}_confirm_needed_confirm_streakrZr_rHrWr> RuntimeErrorrIr._BUNDLED_MODEL_ALIASESr6utilsdownload_models_modellistmodelskeys_labels) rrArrrrJ 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(r7cj|}tfd|D}|r+xjdz c_jjkr d_dSdSd_dS)Nc3.K|]}|jkVdSrc)r).0scorers r z._OpenWakeWordEngine.process..s*II5DO+IIIIIIrrzrTF)rpredictanyvaluesrr)rrscoresovers` rrz_OpenWakeWordEngine.processs$$U++IIIIIIIII    A % #t';;;'($t5 urrcjd|_ |jdS#t$rYdSwxYwr)rrrr_rs rrz_OpenWakeWordEngine.resetsM !  K           DD s $ 22c.|dSrc)rrs rrz_OpenWakeWordEngine.close rNrAr 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_constantsrrs r_sherpa_model_rootrs,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: )r_SHERPA_KWS_MODEL_DIRrtarfileurllib.requestmkdirrHrrequest urlretrieve_SHERPA_KWS_MODEL_URLopen extractallunlinkr)rtargetrurllibarchivetfs r_ensure_sherpa_modelrsm  '%''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. rrAr 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#rzsherpa KWS model not found at rrprofile_routingTc6g|]}|Sr)upper)rps r z-_SherpaKwsEngine.__init__..Ts ( ( (1QWWYY ( ( (rbpez bpe.model)tokens tokens_type bpe_modelwz.txtz hermes-kws-zutf-8)modesuffixprefixdeleteencoding _z @ g?g?patternr'r(ct|}|stdd|t|dS)Nzsherpa KWS model file missing: /r)sortedglobrr')r6hitsds r _model_filez._SherpaKwsEngine.__init__.._model_filepsR!&&//**D T"#RQ#R#R#R#RSSStAw<< rzencoder-*[!8].onnxzdecoder-*[!8].onnxzjoiner-*[!8].onnxrz)r*encoderdecoderjoiner keywords_filekeywords_threshold num_threads)r6r'r(r')&rrr sherpa_onnxr!rDrErFr'r-rrrrrerr7ritemsrVrtempfile_display_to_profileNamedTemporaryFilezipr&replacewriter1rr_keywords_filerrxKeywordSpotter_spotter create_stream_stream)rrArrDr!rJr#r own_profile phrase_mapprofr'rr*rFkwtoksdisplay thresholdr=r<s @rrz_SherpaKwsEngine.__init__8sy######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(r7c|ddl}|||jdz }|jt |d}|j|jr|j|j|j |j}|rxd}t|}| dd |j |df|_|j|j|j|j|S) Nr)dtypeg@FTr4r3r#)rasarrayfloat32rPaccept_waveform SAMPLE_RATErNis_ready decode_stream get_resultr'rJr.rGrEr reset_stream)rrrsamplesfiredresultrVs 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$rYdSwxYwrc)rNrOrPr_rs rrz_SherpaKwsEngine.resetsB =6688DLLL    DD s " 00c\ tj|jdS#t$rYdSwxYwrc)r/rrLrrs rrz_SherpaKwsEngine.closesB  Id) * * * * *    DD   ++Nrrrrrrrrr,szLG5G5G5G5R(rrc*eZdZdZd dZd dZd d Zd S)_PorcupineEngineu@Picovoice Porcupine — premium, on-device, needs an access key.rAr 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). porcupinekeywordjarvisrr) access_key sensitivities keyword_pathskeywordsr)rrr pvporcupiner/getenvr-rrDrErFr'rxrcreate _porcupiner) rrArrtrprJrnporcupine_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(r7c>|j|dkSr)rwrrs rrz_PorcupineEngine.processs&&u--22rrc\ |jdS#t$rYdSwxYwrc)rwr1r_rs rrz_PorcupineEngine.closesC  O " " $ $ $ $ $    DD rgNrrr)rrrrrrrrrrririsVJJ9999>3333rrict|}|dkrt|S|dvrt|S|dvrt|St d|)Nrmr" sherpa-onnxkwsr)rowwlocalzUnknown wake_word provider: )rhrirrrt)rArs r _build_enginersq~~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_readyrsy]]]]]]]]]]%%'' ~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_rErr is_available_allow_lazy_installsrr7)rrr_LAZY_TTS_FEATURESfeaturerrs r _tts_readyrsHBBBBBBBB =!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} nW|s|s||pd } n;| sd} n6|r|sd} n/|r| s+ddd|fd| ffD} d| d} |o|o | o | o|r|p| o||||||| t!|| d S)zDReport whether wake-word detection can run, with a remediation hint.Nrrrmrkr}r rFTr#)rmr"r~rrr*rrlzDSet PORCUPINE_ACCESS_KEY (free key at https://console.picovoice.ai).zNThe wake word needs the tflite runtime on this Mac: pip install ai-edge-litertzHMicrophone capture needs sounddevice + numpy and a working audio device.z and c3$K|] \}}||V dSrcr)rroks rrz/check_wake_word_requirements..Ls@  T2ac       rzspeech-to-textztext-to-speechzWake word needs uN configured — run `hermes tools` (Voice section) or see the voice-mode docs.) availablerdeps_availableaudio_availableaccess_key_set stt_available tts_availablerhint)r`rhrrrrrrrrKrZr/rur-feature_install_commandr1r)rArrrdeps_oklazy_okaudio_okkey_okstt_oktts_okr tflite_okr&missings rcheck_wake_word_requirementsrsa##&;&=&=C~~H;" = = =%$$W--G,,..G&-7!!!%H F\\F \\F DILLL/44  -//p93I3IJd3e3epipI; 2H(I(I(OR'V'V'X'XU  @W @0099?R  @_ @@Y @6@,,  #3V"X!Y     ?7???BB6BiB"( @G (?!# c""   rcreZdZdZeddfdd ZeddZddZddZ ddZ ddZ ddZ ddZ d 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. Nengineron_wakeCallable[[], None]cooldownro on_failure.Optional[Callable[['WakeWordDetector'], None]]rric&||_||_||_||_||_d|i|_d|_tj|_ tj|_ d|_ tj |_ d|_d|_dS)NrrqFr)rrrrrinput_device_details_thread threadingEvent_stop_callback_inflight _last_fireLock_lock audio_silent_silent_frames)rrrrrrs rrzWakeWordDetector.__init__ks    $(5?4N!37 _&& "+/"3"3^%% "rr(r7c@|j}|duo|Src)ris_aliverts rrunningzWakeWordDetector.runnings L}--rrcH|j5|j'|jr ddddS|jt j}g}t j|j||fdd|_|j dddn #1swxYwY| ts#| td|r*| td|ddS)z-Open the mic and begin listening. Idempotent.NTz wake-word)rargsdaemonrz1Timed 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 rrzWakeWordDetector.starts 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.|dSrc)rrs rpausezWakeWordDetector.pauses rc.|dSrc)rrs rresumezWakeWordDetector.resumerrc`||jdSrc)rrrrs rstopzWakeWordDetector.stops.  rc|j5|j|j}|+|t jur|d|j|urd|_ddddS#1swxYwYdS)Nr )timeout)rrsetrrcurrent_threadr1rs rrzWakeWordDetector._halt_threads 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_rHrIrr)rrs r_dispatch_wakezWakeWordDetector._dispatch_wakes , LLNNNN ? ? ? NN:A > > > > > > > > ?  # ) ) + + + + +D # ) ) + + + +s*A$ AAA$AA$$A?rthreading.Eventrlist[BaseException]c  t\}}nc#ttf$rO}td||||Yd}~dSd}~wwxYw|jj}t||j |_ t d|j dpd|j |j dpd|j dpdt ||j tdd | }|n\#t"$rO}td ||||Yd}~dSd}~wwxYw |jn#t"$rYnwxYwt d |t|d }t'dt)t*tzt'd|z } |js ||\} } nM#t"$r@}td||j }Yd}~nPd}~wwxYwt5| dddkr | dddfn| } t7| r.t)t9| nd} n#t"$r t:dz} YnwxYw| t:kr\|xjdz c_|j| kr@d|_tdt:t*tA|j n6|jr/|jrt dd|_d |_ |j!| }n3#t"$r&}t"d|Yd}~d}~wwxYw|rtGj$}||j%z |j&kr||_%t d|j'sG|j'tQj)|j*ddnt"d|j |+|,n#t"$rYnwxYwt d|r|j-|-|dSdSdS# |+|,n#t"$rYnwxYwt d|r|j-|-|wwwxYw)Nz*wake word: audio libraries unavailable: %sz`wake word: opening microphone device=%s selector=%r hostapi=%s default_rate=%s requested_rate=%drrrunknownrrzint16)device sampleraterrY blocksizez(wake word: failed to open microphone: %sz(wake word: listening (frame=%d, rate=%d)Fz wake word: stream read error: %sndimrTz;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)rrru0wake word: detection within cooldown — ignoredzwake word: stream closed).rrPrrHrappendrrrrrrrrEr] InputStreamrr_rrvrk_SILENCE_ALERT_SECONDSris_setreadrIrlenabs _SILENCE_PEAKrrrrrWtime monotonicrrrrrrrrr)rrrrr4rrstreamfailedsilent_alert_framesr  _overflowrpeakrcnows rrzWakeWordDetector._runs: !OOEBW%    LLEq I I I  ! !! $ $ $ IIKKK FFFFF   {/ $:2t?P$Q$Q!  0  % ) )& 1 1 E5E    % ) )) 4 4 A  % ) )*> ? ? L9     ^^(&& $F LLNNNN    LLCQ G G G  ! !! $ $ $ IIKKK FFFFF    K          D   > kZZZ "!S)?+)MPSTUWcPdPd)d%e%eff6 &j'')), Y&,kk,&?&?OD)) NN#EqIII!%!2!2!4!44FEEEE'.dFA&>&>!&C&CQQQT -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 %WXXXYj'')), Y\        KK2 3 3 3 &$/5%%%%% & &55         KK2 3 3 3 &$/5%%%% &5sA4AA//A48E F'AF""F'+G GGV #I<;V < K5K;V K&V -?L-,V -MV MB V %P?V P0 P+%V +P00C!V (T;; UU W? (V43W?4 W>W?W>W?) rrrrrrorrrrirr)rrrrr(r)rrrr_FIRE_COOLDOWN_SECONDSrpropertyrrrrrrrrrrrrrds$:NR26     *...X.bbbb.$$$$,,,,h&h&h&h&h&h&rrzOptional[WakeWordDetector] _detectorz object | None_detector_ownerc.ddlm}|dz dz S)Nrget_default_hermes_rootruntimezwake-word.lock)rrrs r _lock_pathr,s.888888 " " $ $y 03C CCrr0c|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.Trza+bntrNrz&Wake-word microphone is already owned.)rparentrrr/rmsvcrtseekSEEK_ENDtellrKflushlockingfilenoLK_NBLCKfcntlflockLOCK_EXLOCK_NBrBlockingIOErrorrr )r0 lock_pathhandlerr rs r_acquire_machine_lockr2sK$ 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)Nrrrz) r/rrrr r LK_UNLCKr rLOCK_UNrr)rrr s r_release_machine_lockrKs ~  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_lockrrrr)r lock_handles r_detector_failedr^s  / / H $ $  / / / / / / / /*  " / O ! ! # # # !+ . . . . !+ . . . . . / / / / / / / / / / / / / / / / / /s- A9 A9AA9A((A99A=A=)configrrownerobjectrc |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 Noner)rr)rtrrrr rrrr`rrrrnrrr_rr)rr rrrArrs rstart_listeningr#ns };<<<     e++#$LMMM 'I               ,--  ".&&4I4K4KC"3''F'+*3// H !I#O"-  NN   +        ,   $NN$$$$ DI"O"&  !+ . . .  -          sOA E1EA!C..EDE D'$E&D''EEE Echt5tduot|ucdddS#1swxYwYdSrc)rrrr s r owns_listenerr&s BB$AE)ABBBBBBBBBBBBBBBBBBs '++ct5t t|ur ddddSt ddddS#1swxYwYdS)z;Release the microphone only when ``owner`` holds the lease.NFT)rrrrr%s rpause_listeningr(s   u < <  AAAAct5t t|ur ddddSt ddddS#1swxYwYdS)z;Re-open the microphone only when ``owner`` holds the lease.NFT)rrrrr%s rresume_listeningr+s   u < <  r)ct5t t|ur ddddSt}t}dadada |t |n#t |wxYw ddddS#1swxYwYdS)zr@rGrKrZr`rerhrnrxr}rrrrrrrrrrrrrrrrrrirrrrrrrrrrrrrrr#r&r(r+r.r1r4r6r8rrrr?s>#"""""  000000000000  8 $ $  !  NNNNNLNNN7      #"#M#M#MNN````` FFFF 5 5 5 5F<00006666 HHHH!!!!    44444 = = = = =$L""""J88880        ,YYYYY'YYYBCO5555 *uuuuuwuuup*****w***ZBBBB     ))))XAAAAAP{&{&{&{&{&{&{&{&D)- ,,,,!%%%%%!!DDDD 2& / / / /((, 000000fBBBB $++++ 0 0 0 0 0 0 0 0 0 333333r