PmjvFUdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl Z ddl Z ddlZddlZddlmZmZmZmZmZejeZdZdZdefdZd eddfd Zdefd Zdefd Z dd l!m"Z#de$fdZ%dee$fdZ&dZ'defdZ(defdZ)defdZ*de+fdZ,dZ-dZ.dZ/dZ0dZ1dZ2ej34e j5dZ6dZ7de8fdZ9de8defdZ:dpd"ed#e8d$eddfd%Z;da<e j=Z>d&eddfd'Z?defd(Z@e j=ZAdaBee jCeDd)<defd*ZEd"e8dd+fd,ZFd-e jCddfd.ZGdqdefd/ZHdrd0ZIGd1d2ZJGd3d4ZKdeKeJzfd5ZLhd6ZMejNd7ejO8ZPd9e$defd:ZQd;ZRdeSfd<ZTdqd9e$d=eeSdefd>ZUde$fd?ZVdqd@e$dAee$dee$effdBZWdCe$dDedefdEZXd@e$dAee$dDedee$effdFZYd@e$dDedee$fdGZZda[eej\eDdH<e j=Z]drdIZ^defdJZ_defdKZ`defdLZadCe$defdMZbdCe$defdNZc dsdUegefdVeedWedXedYedZeegdfd[ed\ed]efd^Zdd_Zed`ZfdZgdefdaZhdbe$ddfdcZi dtdUegefdfeegefdZeee$gdfdgee8dWedXedhed[ed\ed]edee$fdiZjdje$defdkZkdee$effdlZldudnedefdoZmdS)vaLVoice Mode -- Push-to-talk audio recording and playback for the CLI. Provides audio capture via sounddevice, WAV encoding via stdlib wave, STT dispatch via tools.transcription_tools, and TTS playback via sounddevice or system audio players. Dependencies (optional): pip install sounddevice numpy or: uv sync --extra voice N)Path)AnyCallableDictListOptionalcddl}ddl}||fS)zLazy-import sounddevice and numpy. Returns (sd, np). Raises ImportError or OSError if the libraries are not available (e.g. PortAudio missing on headless servers). rN) sounddevicenumpy)sdnps 6/home/thesage/.hermes/hermes-agent/tools/voice_mode.py _import_audior#s%  r6Mcddl}|S)uLazy-import numpy only (no sounddevice). Returns the module. Used where we need to synthesize/convert audio samples but must NOT import sounddevice — see _sounddevice_output_allowed. rN)r )r s r _import_numpyr.s  Irreturnc0tjdkS)aWhether sounddevice may be used for audio OUTPUT. Returns False on macOS: importing/initializing sounddevice (PortAudio/CoreAudio) for output triggers a kTCCServiceMediaLibrary permission prompt, even though playback needs no media-library access. On macOS all output is routed through ``afplay`` instead. This does NOT affect audio *input* (recording), which legitimately needs microphone permission. See PR #62601 / #13291. Darwin)platformsystemrr_sounddevice_output_allowedr8s ?   ((r sample_ratecd} tjdd}|j}tj|d5}|d|d|||| dddn #1swxYwYt|n2#t$r%}t d|Yd}~nd}~wwxYw|r( tj|dS#t $rYdSwxYwdS#|r& tj|w#t $rYwwxYwwxYw) zWrite int16 mono PCM to a temp WAV and play it via play_audio_file. Used on macOS so tone/beep output goes through ``afplay`` instead of sounddevice (avoids the TCC media-library prompt). N.wavF)suffixdeletewbz!Tone tempfile playback failed: %s)tempfileNamedTemporaryFilenamewaveopen setnchannels setsampwidth setframerate writeframestobytesplay_audio_file ExceptionloggerdebugosunlinkOSError)audiortmp_pathtmpwfes r_play_int16_via_tempfiler8Es H)FFF8 YsD ! ! ,R OOA    OOA    OOK ( ( ( NN5==?? + + +  , , , , , , , , , , , , , , , !!!! === 8!<<<<<<<<=    (#####      8   (####     s2CA'B) C)B--C0B-1CD" C3C.)D".C33D"9D DD"E &D;:E ; EE EE cT tdS#ttf$rYdSwxYw)z/Return True if audio libraries can be imported.TF)r ImportErrorr2rrr_audio_availabler;_s<t  !uus ''cR |dd}t|tr|dnt |dd}t|t t fr"|dkrt t|Sn#t$rYnwxYwtS)zReturn the preferred capture rate for the default input device. Falls back to the Whisper-friendly 16 kHz constant when the backend does not expose a numeric default rate. Ninputdefault_samplerater) query_devices isinstancedictgetgetattrintfloatroundr- SAMPLE_RATE)r inforates r_default_input_sampleraterJhs  g..1;D$1G1Gvtxx,---WUY[oquMvMv dS%L ) ) $dQhhuT{{## #      sBB BB) is_termuxctrdS tjttdtjkr8t tjdz dz }|r|dSn#t $rYnwxYwdS)NzGpkg install python-numpy portaudio && python -m pip install sounddevice base_prefixbinpipz install sounddevice numpyzpip install sounddevice numpy)_is_termux_environmentsysprefixrCrexistsr-) pip_in_venvs r_voice_capture_install_hintrU{sYXX :mSZ@@ @ @sz**U2U:K!!## B%AAAA      * *sA%A99 BBcJtsdStjdS)Ntermux-microphone-record)rPshutilwhichrrr_termux_microphone_commandrZs& ! # #t <2 3 33r))pmlistpackagescom.termux.api)cmdpackager\r]r^c tsdSd}tD]} tjt |ddddddtj}n1#t ttf$rd}YRtj $rd}YdwxYw|j dkrd}vd|j pd vrdS|r0tjd td dSdS) uReturn True iff the Termux:API Android app is installed. Strategy (issue #31015): 1. Try each probe in ``_TERMUX_API_PACKAGE_PROBES`` and look for ``package:com.termux.api`` in stdout. Any positive hit is authoritative — return True. 2. If every probe is *inconclusive* (binary missing, permission denied, timeout, non-zero exit) we cannot honestly say the app is missing; fall back to trusting the ``termux-microphone-record`` binary on PATH. The binary ships with the ``termux-api`` package and is only useful when the Android app is installed; users who installed the package deliberately almost always have the app too. A false negative on this gate blocks ``/voice on`` outright (the symptom reported in #31015), while a false positive only surfaces a precise runtime error from the binary itself — strictly more actionable. 3. If at least one probe ran cleanly and definitively did not mention the package, treat the app as missing and return False — that's the genuine "Termux:API CLI installed without the app" case the existing warning was written for. FTutf-8replacecapture_outputtextencodingerrorstimeoutcheckstdinrzpackage:com.termux.apirWNzlTermux package-manager probes inconclusive; trusting termux-microphone-record binary on PATH (issue #31015).)rP_TERMUX_API_PACKAGE_PROBES subprocessrunr\DEVNULLFileNotFoundErrorPermissionErrorr2TimeoutExpired returncodestdoutlowerrXrYr.r/) inconclusiver_results r_termux_api_app_installedrzs9. " # #uL) ^S #GI ( FF"?G<   L H(   L H    ! !L  # (;'B'B'D'D D D44 E %?@@L  F   t 5s3AA?,A?>A?c>tduo tSN)rZrzrrr_termux_voice_capture_availabler}s % ' 't 3 S8Q8S8SSrcddl}ddl}g}tjdd}|dD]U}|}|dr*||tddVtjd}|r3|tj |dtjd }|rg|tj |d d|tj |d |D]}|s | tj|j s3n#t$rY@wxYw||j|j} |d || |d S#t$rY|wxYw#|wxYwdS)aReturn True if a PulseAudio/PipeWire socket is reachable on disk. Covers the common case where a sound server runs locally (e.g. on a remote SSH host) without ``PULSE_SERVER``/``PIPEWIRE_REMOTE`` being set -- the client just connects to the default socket under the runtime dir. We look at ``PULSE_SERVER`` unix paths, ``PULSE_RUNTIME_PATH``, and ``XDG_RUNTIME_DIR`` for a ``pulse/native`` or ``pipewire-0`` socket (issue #35622). rN PULSE_SERVERrm;zunix:PULSE_RUNTIME_PATHnativeXDG_RUNTIME_DIRpulsez pipewire-0?TF)socketstatr0environrBsplitstrip startswithappendlenpathjoinS_ISSOCKst_moder2AF_UNIX SOCK_STREAM settimeoutconnectclose) rr candidates pulse_serverpart pulse_runtime xdg_runtimersocks r_pulse_socket_reachablersDMMMKKKJ:>>."55L""3''33zz|| ??7 # # 3   d3w<<==1 2 2 2JNN#788MA"',,}h??@@@*..!233KC"',,{GXFFGGG"',,{LAABBB   ==!677      H }}V^V-?@@  OOC LL    JJLLLLLL     JJLLLL  JJLLLL 5s6:,F(( F54F5*H H<%H?;H<<H??Icg}g}t}t}t|o|}ttjdp,tjdp t }tddDr-|r|dn|dddl m }|r-|r|d n|d  td d d 5}d| vrQ|r|dn9tr|dn|ddddn #1swxYwYn#tt t"f$rYnwxYw t%\}} |} | sE|r|dn-|r|dn|dnU#t($rH|r|dn-|r|dn|dYnwxYwn#t*$rZ|r|dn?|r|s|dn%|dt-dYnzt"$rn|r|dnS|r|s|dn9t/r|dn|d YnwxYw| ||d!S)"zDetect if the current environment supports audio I/O. Returns dict with 'available' (bool), 'warnings' (list of hard-fail reasons that block voice mode), and 'notices' (list of informational messages that do NOT block voice mode). rPIPEWIRE_REMOTEc3TK|]#}tj|V$dSr|)r0rrB).0vs r z+detect_audio_environment..)s0 R R2:>>!   R R R R R Rr) SSH_CLIENTSSH_TTYSSH_CONNECTIONzBRunning over SSH with a reachable PulseAudio/PipeWire sound serverzRunning over SSH -- no audio devices available. If a sound server (PulseAudio/PipeWire) is running on this host, point Hermes at it, e.g.: export XDG_RUNTIME_DIR=/run/user/$(id -u) # or: export PULSE_SERVER=unix:$XDG_RUNTIME_DIR/pulse/nativer) is_containerzGRunning inside container (Docker/Podman/LXC) with host audio forwardingaRunning inside container (Docker/Podman/LXC) -- no audio devices. Forward host audio with one of (substitute $XDG_RUNTIME_DIR for your runtime dir, typically /run/user/$UID): PulseAudio: -v $XDG_RUNTIME_DIR/pulse/native:$XDG_RUNTIME_DIR/pulse/native \ -e PULSE_SERVER=unix:$XDG_RUNTIME_DIR/pulse/native PipeWire: -e PIPEWIRE_REMOTE=$XDG_RUNTIME_DIR/pipewire-0 /proc/versionrrb)rh microsoftz@Running in WSL with a reachable PulseAudio/PipeWire sound serveraSRunning in WSL without a PulseAudio bridge -- TTS playback will use the PowerShell/Media.SoundPlayer fallback. Voice INPUT (recording) still requires a PulseAudio bridge: 1. Set PULSE_SERVER=unix:/mnt/wslg/PulseServer 2. Create ~/.asoundrc pointing ALSA at PulseAudio 3. Verify with: arecord -d 3 /tmp/test.wav && aplay /tmp/test.wavzRunning in WSL -- audio requires a forwarded sound server. PulseAudio: export PULSE_SERVER=unix:/mnt/wslg/PulseServer PipeWire: export PIPEWIRE_REMOTE=$XDG_RUNTIME_DIR/pipewire-0 Then verify: arecord -d 3 /tmp/test.wav && aplay /tmp/test.wavNzSNo PortAudio devices detected but host audio forwarding is configured -- continuingzMNo PortAudio devices detected, but Termux:API microphone capture is availablez&No audio input/output devices detectedzOAudio device query failed but host audio forwarding is configured -- continuingzMPortAudio device query failed, but Termux:API microphone capture is availablez6Audio subsystem error (PortAudio cannot query devices)zDTermux:API microphone recording available (sounddevice not required)zkTermux:API Android app is not installed. Install/update the Termux:API app to use termux-microphone-record.zAudio libraries not installed ()zBTermux:API microphone recording available (PortAudio not required)zmPortAudio system library not found -- install it first: Termux: pkg install portaudio Then retry /voice on.zPortAudio system library not found -- install it first: Linux: sudo apt-get install libportaudio2 macOS: brew install portaudio Then retry /voice on.) availablewarningsnotices)rZrzboolr0rrBranyrhermes_constantsrr&readrw_wsl_powershell_tts_availablerrrsr2rr?r-r:rUrP) rrtermux_mic_cmdtermux_app_installedtermux_capturehas_forwarded_audiorfr _devicess rdetect_audio_environmentrsHG/11N466.A-ABBN ~&& % :>>+ , , % " $ $ R R&Q R R RRR    NN_ ` ` ` ` OOS   .-----|~~    NNd e e e e OOR   & /3 9 9 9 Qaffhhnn....&NN#effff244NN^OO[               (  8     5A Z&&((G N&NNNm$NNN#rssssOO$LMMM Z Z Z# Ze  Znoooo XYYY Z ```  ` NNa b b b b  `$8 ` OO}     OO^>Y>[>[^^^ _ _ _    NN_ ` ` ` `  $8  OO}    $ % %  OO(     OO(   ,"\  swF3!A:F' F3'F++F3.F+/F33G  G J#AH?>J?AJJJJA!M/8A4M/.M/i>r int16r!@ hermes_voice333333?c ddlm}|di}t|tst S|dt }n#t $r t cYSwxYw t|}n#ttf$r t cYSwxYwt|ts|dks|dkst|rt S|S)aRRead ``voice.beep_volume`` from config.yaml; clamps to 0.0-1.0. Defaults to 0.3 when the key is missing, invalid, or when the config system can't be imported (e.g. broken ~/.hermes/config.yaml during a partial install). Failures fall back silently so the audio cue never breaks the voice loop on a degenerate config. r load_configvoice beep_volume?) hermes_cli.configrrBr@rA_DEFAULT_BEEP_VOLUMEr-rE TypeError ValueErrorr_is_nan)r voice_cfgrawvolumes r_get_beep_volumers$111111KMM%%gr22 )T** (' 'mmM+?@@ $$$####$$s z "$$$####$#t$   ## Ms)?AAA21A26BB! B!valuecN tj|S#t$rYdSwxYw)NF)mathisnanr-)rs rrrs9z%   uus  $$pQ? frequencydurationcountc " t}n#t$rYdSwxYw d}tt|z}tt|z}t }g}t |D]!} |d||d} |d|jz|z| z} tttdz|dz} | d| xx|dd | zcc<| | dxx|d d| zcc<| | |zd z |j | |d z kr/| | ||j #||} tst!| tdS t#\}}n#tt$f$rYdSwxYw|| t t)jd z}|r|jrot)j|krXt)jd|r0|jrt)j|kX|dS#t4$r&}t6d|Yd}~dSd}~wwxYw)zPlay a short beep tone using numpy + sounddevice. Args: frequency: Tone frequency in Hz (default 880 = A5). duration: Duration of each beep in seconds. count: Number of beeps to play (with short gap between). NgQ?rFendpointr!{Gz?r dtype samplerate@zBeep playback failed: %s)rr:rDrGrrangelinspacesinpiminrastyperzeros concatenaterr8rr2playtime monotonic get_streamactivesleepstopr-r.r/)rrrr gapsamples_per_beepsamples_per_gaprpartsittonefade_lenr3r rdeadliner7s r play_beeprs __ %4{X566kC/00&(( u H HA Ax)9E JJA66!be)i/!344D3{T1224D4IJJH (OOOr{{1a:: :OOO (    Aq( ; ; ;    LL$,u4<##c)mmoo "--//"8 T^=M=MPX=X=X Jt   mmoo "--//"8 T^=M=MPX=X=X  444 /3333333334sI F*KG"!K"G73K6G77C%K L(L  Lrc~t5tdt|rdndzaddddS#1swxYwYdS)uReference-count real audio output (TTS/file playback). Playback paths bracket their work with ``mark_audio_output_active(True)`` / ``(False)`` so ``is_audio_output_active()`` reflects whether speech audio is leaving the speakers RIGHT NOW — unlike the per-turn TTS-done events, which stay 'busy' for a whole turn even while the pipeline is silently waiting for text. rr N)_audio_output_lockmax_audio_output_active_count)rs rmark_audio_output_activer&s   %( )&-@QQbA& & "                  s 266cZt5tdkcdddS#1swxYwYdS)z>True while TTS/file audio is actually playing on the speakers.rN)rrrrris_audio_output_activer6st ..)A-..................s $$_thinking_stopc ddlm}ddlm}|di}t |t r!||dddSn#t$rYnwxYwdS)z5Config gate: ``voice.thinking_sound`` (default True).rr)is_truthy_valuerthinking_soundT)default)rrutilsrrBr@rAr-)rrrs rthinking_sound_enabledr @s  111111))))))KMM%%gr22 i & & "? .55t        4sAA## A0/A0rcd}tt|z}|d||d}|dd|}d|jz|||zztz }||}d|zd ||d z zz}td tz}||} |d d|| d |<| || dzz} tdz} || z| zdz |j S)z~One soft 'blub': short sine with a gentle downward pitch glide and a smooth attack/decay envelope (no clicks), low-volume.g{Gz?rFrrg ףp= ?r!皙?g?r{Gz?rNg,@rr) rDrGrrcumsumronesexprrr) r rrnrglidephaserattackenvrs r_synth_thinking_bliprPs/H K( "##A AxU 33A KKT1 % %E I )e"344 4{ BE 66%==D :bffUS[111 1D  # $ $F ''!**C;;sC00CL2661"t)  C   # %F 3J % ' / / 9 99rrc tsdS t\} n#ttf$rYdSwxYwddl}d} fd|D}d}|s | |rz||t |z}||t| t |tz dz| |dz }n3#t$r&}t d|Yd}~dSd}~wwxYw| d |d zz|dSdS) ueDaemon loop: play alternating-pitch blips every ~0.8-1.2s until *stop*. Skips a blip (without stopping) whenever *should_play* returns False — e.g. TTS audio started flowing or the mic re-armed. macOS: sounddevice output is TCC-gated, and per-second afplay subprocess churn is worse than silence, so the loop exits immediately there. Nr)gx@gt@c0g|]}t|Sr)r)rpr s r z(_thinking_sound_loop..ws$ : : :Q !"a ( ( : : :rrrr zThinking sound blip failed: %srg?)rrr:r2randomis_setrrrGwaitrr-r.r/) r should_playr rpitchesblipsrblipr7r s @r_thinking_sound_loopr$es ' ( (BB  !MMMG : : : :' : : :E Akkmm / "kkmm"QU^,555 #d))k1D8999 Q    LL91 = = = FFFFF  # #--...kkmm / / / / /s%%::(BC// D9DDcLtsdSt5t'ts ddddSt j}|adddn #1swxYwYt jt||fdddS)aStart the ambient thinking sound (idempotent). *should_play* is polled before each blip; return False to skip while speech audio flows or the mic is capturing. Returns True when the loop was started (or already running), False when disabled/unavailable. FNTzvoice-thinking-sound)targetargsdaemonr$) r _thinking_lockrr threadingEventThreadr$start)r rs rstart_thinking_soundr.s " # #u   %n.C.C.E.E %    #K  #   eggg 4s"A(A((A,/A,ct5tdc}adddn #1swxYwY||dSdS)z7Stop the ambient thinking sound instantly (idempotent).N)r)rsetrs rstop_thinking_soundr2s 44-tn444444444444444   s ##ceZdZdZdZddZedefdZede fdZ ede fdZ ddd Z dd Zdeefd Zdd Zdd ZdS)TermuxAudioRecorderzBRecorder backend that uses Termux:API microphone capture commands.FrNcntj|_d|_d|_d|_d|_dS)NFrr)r*Lock_lock _recording _start_time_recording_path _current_rmsselfs r__init__zTermuxAudioRecorder.__init__s6^%% .2rc|jSr|r8r<s r is_recordingz TermuxAudioRecorder.is_recordings rcJ|jsdStj|jz SNrr8rrr9r<s relapsed_secondsz#TermuxAudioRecorder.elapsed_seconds' 3~$"222rc|jSr|r;r<s r current_rmszTermuxAudioRecorder.current_rmss   rc ~t}|stdtstd|j5|jr ddddSt jtdtj d}t j td|d|_ dddn #1swxYwY|d|j d d d d d ttdttg } t!j|ddddddt jny#t j$rG}|jp|jpt|}td||d}~wt.$r}td||d}~wwxYw|j5tj|_d|_d|_dddn #1swxYwYt6ddS)NzTermux voice capture requires the termux-api package and app. Install with: pkg install termux-api Then install/update the Termux:API Android app.zrTermux voice capture requires the Termux:API Android app. Install/update the Termux:API app, then retry /voice on.Texist_ok %Y%m%d_%H%M%S recording_z.aac-fz-l0z-eaacz-r-crbrcrez Termux microphone start failed: rzTermux voice recording started)rZ RuntimeErrorrzr7r8r0makedirs _TEMP_DIRrstrftimerrr:strrGCHANNELSrorprqCalledProcessErrorstderrrvrr-rr9r;r.rH)r=on_silence_stopmic_cmd timestampcommandr7detailss rr-zTermuxAudioRecorder.starts ,.. B  )** K  Z Y Y  Y Y Y Y Y Y Y Y K D 1 1 1 1 o66I#%7<< ;W ;W;W;W#X#XD  Y Y Y Y Y Y Y Y Y Y Y Y Y Y Y  $& # % #k"" #h--   N N74dW]fprz~GQGY Z Z Z Z Z, T T Tx5185s1vv<<>>GK'KKLLRS S N N NE!EEFFA M NZ " "#~//D "DO !D  " " " " " " " " " " " " " " "  455555sP CACC C&D--F#> F# FF#-'G  G$'G$c zt}|sdStj|dgddddddtjdS)N-qTrbrcrSFre)rZrorprq)r=r]s r_stop_termux_recordingz*TermuxAudioRecorder._stop_termux_recordingsk,..  Ft$QXajtvDLVL^ _ _ _ _ _ _rcr|j5|js ddddSd|_|j}d|_|j}d|_dddn #1swxYwY||rt j|sdStj |z dkr( t j |n#t$rYnwxYwdSt j |dkr( t j |n#t$rYnwxYwdStd||S)NFrrz"Termux voice recording stopped: %s)r7r8r:r9r;rcr0risfilerrr1r2getsizer.rH)r=r started_ats rrzTermuxAudioRecorder.stops Z " "?  " " " " " " " "$DO'D#'D )J !D  " " " " " " " " " " " " " " " ##%%% 27>>$// 4 >  j (3 . .  $    4 7??4 A % %  $    4 8$??? s: A #A  AA*B?? C  C 5D DDc|j5|j}d|_d|_d|_dddn #1swxYwY |n#t $rYnwxYw|rEt j|r& t j |n#t$rYnwxYwt ddS)NFrz Termux voice recording cancelled) r7r:r8r;rcr-r0rrer1r2r.rH)r=rs rcancelzTermuxAudioRecorder.cancels" Z " "'D#DO#'D !D   " " " " " " " " " " " " " " "    ' ' ) ) ) )    D   BGNN4((   $     677777s/155A AAB B&%B&c.|dSr|)rir<s rshutdownzTermuxAudioRecorder.shutdown$s rrNr|)__name__ __module__ __qualname____doc__supports_silence_autostopr>propertyrrArErErDrIr-rcrrXrrirkrrrr4r4s"LL %dX3333X3 !S!!!X!*6*6*6*6*6X____ hsm88888"rr4ceZdZdZdZddZdedefdZe defdZ e de fd Z e defd Z dd Zddd ZddeddfdZdeefdZddZddZeedde defdZdS) AudioRecorderaThread-safe audio recorder using sounddevice.InputStream. Usage:: recorder = AudioRecorder() recorder.start(on_silence_stop=my_callback) # ... user speaks ... wav_path = recorder.stop() # returns path to WAV file # or recorder.cancel() # discard without saving If ``on_silence_stop`` is provided, recording automatically stops when the user is silent for ``silence_duration`` seconds and calls the callback. TrNcltj|_d|_g|_d|_d|_t|_d|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_t$|_t(|_d|_d|_d|_d|_dS)NFrrg.@r)r*r6r7_stream_framesr8r9rG _sample_rate _has_spoken _speech_start _dip_start_min_speech_duration_max_dip_tolerance_silence_start _resume_start_resume_dip_start_on_silence_stopSILENCE_RMS_THRESHOLD_silence_thresholdSILENCE_DURATION_SECONDS_silence_duration _max_wait_max_recording_seconds _peak_rmsr;r<s rr>zAudioRecorder.__init__=s^%%   "$ "%!, $'!$+.!),%($'(+ $'<(@ $.1#!"relapsedcF|j}t|o |dko||kS)a6Whether the configured hard recording-length cap has elapsed. ``voice.max_recording_seconds`` is applied by the CLI before each recording (see ``HermesCLI._voice_start_recording``). A value <= 0 (or unset) disables the cap, preserving the previous unbounded behaviour. r)rr)r=rcaps r_max_duration_reachedz#AudioRecorder._max_duration_reachedYs,)C6C!G63777rcJ|jsdStj|jz SrCrDr<s rrEzAudioRecorder.elapsed_secondsfrFrc|jS)zBCurrent audio input RMS level (0-32767). Updated each audio chunk.rHr<s rrIzAudioRecorder.current_rmsls   rc|jS)z,Whether audio recording is currently active.r@r<s rrAzAudioRecorder.is_recordingqs rctjdSt\}fd}d} |jtt |}|nN#t$rA}|& |n#t$rYnwxYwtd|d|d}~wwxYw|_dS)a_Create the audio InputStream once and keep it alive. The stream stays open for the lifetime of the recorder. Between recordings the callback simply discards audio chunks (``_recording`` is ``False``). This avoids the CoreAudio bug where closing and re-opening an ``InputStream`` hangs indefinitely on macOS. Nc  |rtd| jsdS j|t  | j dz}| _ t j | _ jtj}| jz }| jkrd _ jdkr| _nD js=| jz jkr*d _td| jz  jsd _nd _ jdkr| _n| jz jkrd _d _n jr@ jdkr4 jdkr| _n| jz jkrd _d _nb jdkrW jdkr| _nD| jz jkr1td| jz d _d _d} jrT| jkrI jdkr| _nj| jz jkr"td jd}n4 js-| jkr"td jd}|s7 |r"td jd}|r` j 5 j d _dddn #1swxYwY r3 fd }tCj"|d #dSdSdSdS)Nzsounddevice status: %sr!rTz(Speech confirmed (%.2fs above threshold)rz'Speech attempt reset (dip lasted %.2fs)Fz'Silence detected (%.1fs), auto-stoppingz%No speech within %.0fs, auto-stoppingz3Max recording length reached (%.0fs), auto-stoppingc dS#t$r(}td|dYd}~dSd}~wwxYw)NzSilence callback failed: %sTexc_info)r-r.error)r7cbs r_safe_cbzAAudioRecorder._ensure_stream.._callback.._safe_cbsg^ "#,^^^ & -JAX\ ] ] ] ] ] ] ] ] ]^s  A<Ar&r()$r.r/r8rwrcopyrDsqrtmeanrfloat64r;rrrrrr9rr{rzryr|r~rrr}rrHrrrr7r*r,r-) indataframes time_infostatusrmsnowr should_firerrr r=s @r _callbackz/AudioRecorder._ensure_stream.._callbacksG ? 5v>>>?  L   . . .bggbggfmmBJ&?&?1&DEEFFGGC #D  55DN$0n&& 00000&)DO)S00-0**!-?#8J2JdNg2g2g+/( %O%(4+=%=???  + 5.1++ 25.-4414D.. 4#559RRR25D/14D.%.)A--1S8858D22 4#99T=TTT14D.58D2'!++#--*-t.$2III %N%(4?%:<<<-0**- $ # 't/F(F(F*c11.1++t22d6LLL $M$($:<<<&* )'g.G.GKK G $000"&K #'t'A'A''J'J'KK U $ ;==="&K O55!204-555555555555555O^^^^^ "(FFFLLNNNNNo10Z O OOOsL66L:=L:)rchannelsrcallbackz#Failed to open audio input stream: z6. Check that a microphone is connected and accessible.) rvr InputStreamrxrYDTYPEr-r-rrT)r=r rstreamr7r s` @r_ensure_streamzAudioRecorder._ensure_streamxs& < # FBe Oe Oe Oe Oe Oe OP ^^,!" $F LLNNNN   !LLNNNN DGaGGG   s;._do_closeHsH       s (- ;;Trr皙?rju:Audio stream close timed out after %.1fs — forcing ahead) rvr*r,r- __import__ris_aliverr.warning)r=rjrrrrs @r_close_stream_with_timeoutz(AudioRecorder._close_stream_with_timeout@s$ <  F        Id ; ; ;  f%%//11G;jjll z&11;;==HH FF3F   jjll z&11;;==HH ::<< b NNWY` a a a a a b brc$|j5|js ddddSd|_d|_|js ddddSt \}}||jd}g|_t j|jz }t d|t|t|j dz}t||kr6tdt| ddddS|jt kr4t d|jt  ddddS|||j cdddS#1swxYwYdS) uStop recording and write captured audio to a WAV file. The underlying stream is kept alive for reuse — only frame collection is stopped. Returns: Path to the WAV file, or ``None`` if no audio was captured. NFraxisz+Voice recording stopped (%.1fs, %d samples)rz,Recording too short (%d samples), discardingz2Recording too quiet (peak RMS=%d < %d), discardingr)r7r8r;rwrrrrr9r.rHrrDrxr/rr _write_wav)r=rr audio_datar min_sampless rrzAudioRecorder.stopXslZ N N?  N N N N N N N N$DO !D <  N N N N N N N N"OOEAr 1==JDLn&&)99G KKEwPST^P_P_ ` ` `d/#566K:,, KSQ[__]]]/ N N N N N N N N6~ 555 P N,ACCC= N N N N N N N N@??:4;L?MMA N N N N N N N N N N N N N N N N N Ns) FFC F7FFF  F c|j5d|_g|_d|_d|_dddn #1swxYwYt ddS)zoStop recording and discard all captured audio. The underlying stream is kept alive for reuse. FNrzVoice recording cancelled)r7r8rwrr;r.rHr<s rrizAudioRecorder.cancels Z " "#DODL$(D ! !D   " " " " " " " " " " " " " " "  /00000s 155c|j5d|_g|_d|_dddn #1swxYwY|t ddS)zrErrrrrErDrIrArr-rrrXrrirk staticmethodrGrrrrrtrt+s  !%####8 8U 8t 8 8 8 83333X3 !S!!!X!dX HHHHT<c<c<c<c<c|bb%b$bbbb0)Nhsm)N)N)N)NV 1 1 1 1////5@sS\rrtcVtrtStS)z=Return the best recorder backend for the current environment.)r}r4rtrrrcreate_audio_recorderrs&&((%"$$$ ??r>%продолжение следует(продолжение следует...*ご視聴ありがとうございました,sottotitoli creati dalla comunità amara.org5sous-titres réalisés par la communauté d'amara.orgbye.the endthe end. amara.org thank you thank you. sous-titres www.mooji.orgplease subscribeplease subscribe.like and subscribelike and subscribe.thanks for watchingthanks for watching.thank you for watchingsubscribe to my channelthank you for watching.subscribe to my channel.untertitel von stephanie geigesbyeyouz9^(?:thank you|thanks|bye|you|ok|okay|the end|\.|\s|,|!)+$)flags transcriptc|}|sdS|dtvs |tvrdSt|rdSdS)zBCheck if a transcript is a known Whisper hallucination on silence.Tz.!F)rrwrstripWHISPER_HALLUCINATIONS_HALLUCINATION_REPEAT_REmatch)rcleaneds ris_whisper_hallucinationrst  &&((G t~~d555DZ9Z9Zt%%g..t 5rr1cz ddlm}|di}t|trj|dt }t|t r|g}t|ttfrtd|D}|Sn#t$rYnwxYwt S)zReturn the configured ``voice.stop_phrases`` list (default: ("stop",)). Malformed config (scalar, dict, list of non-strings) falls back to the default rather than crashing the voice loop. rrr stop_phrasesc3K|]z}t|tttf$t|Et|V{dSr|)r@rXrDrErrw)rrs rrz+_load_voice_stop_phrases..s}  /0!!c3%677 t}|sdSd|ddS)aOne-line 'Say "stop" to end the voice chat.' hint for voice-mode start. Sources the phrase from ``voice.stop_phrases`` (first entry) so a custom phrase renders correctly; returns "" when stop phrases are disabled (``stop_phrases: []``) so surfaces show no hint at all. Every surface that announces voice-mode start (CLI /voice on, TUI, desktop) uses this one owner instead of hardcoding the wording. rmzSay "rz" to end the voice chat.)r)rs rvoice_stop_hintr!s1'((G r 771: 7 7 77rrmodelcddlm}m}|||}|ds*d|ddvrt |||}|dr[|d d}t |r6t |s'td |d d dd d S|d rd dd dS|S)aTranscribe a WAV recording using the existing Whisper pipeline. Delegates to ``tools.transcription_tools.transcribe_audio()``. Filters out known Whisper hallucinations on silent audio. Args: wav_path: Path to the WAV file. model: Whisper model name (default: from config or ``whisper-1``). Returns: Dict with ``success``, ``transcript``, and optionally ``error``. r) MAX_FILE_SIZEtranscribe_audiorsuccesszFile too largerrm)r max_file_sizerz"Filtered Whisper hallucination: %rT)rrfiltered no_speech)rrr) tools.transcription_toolsrrrB_transcribe_wav_in_chunksrrr.rH)rrrrryraw_transcripts rtranscribe_recordingr3s JIIIIIII  he 4 4 4F ::i _%5GR9P9P%P%P*85P]^^^zz)IL"55 #N 3 3 I

R S S S#24HH H zz+FrEEE Mr file_pathrc|dsdS tj||kS#t $rYdSwxYw)z@Return whether a CLI WAV recording needs to be split before STT.rF)rwendswithr0rrfr2)rrs r_should_chunk_for_transcriptionr`sg ??   % %f - -uwy))M99 uus"A AAc  ddlm}g}g} t||}|sOdddd|D]F} tj|rtj|7#t$rYCwxYwSt dt||t|d D]\}}||| }| d s}| d d} ddd|dt|d| dc|D]F} tj|rtj|7#t$rYCwxYwS| dd } | r$t| s|| dd| | dt|d|D]F} tj|rtj|7#t$rYCwxYwS#t"$rz} td|| dddd| dcYd} ~ |D]F} tj|rtj|7#t$rYCwxYwSd} ~ wwxYw#|D]F} tj|rtj|7#t$rYCwxYwwxYw)zGSplit an oversized WAV into provider-sized chunks and join transcripts.r)r)rFrmzNo audio chunks were created)rrrz+Transcribing oversized WAV in %d chunks: %sr )r-rrrzUnknown transcription errorzChunk /z failed: rT provider)rrr chunksz'Chunked transcription failed for %s: %srzChunked transcription failed: N)rr_split_wav_for_transcriptionr0rrer1r2r.rHr enumeraterBrrrrr-r) rrrr chunk_paths transcripts chunk_pathindexryrrr7s rrrjs;:::::KK#28=YYY  a$BA_``6&  J 7>>*--*Ij)))      3  A3{CSCSU]^^^!*;a!@!@!@ / / E:%%j>>>F::i((  7,IJJ$"$PePPc+.>.>PPPP(&  J 7>>*--*Ij)))       L"55;;==J /"::"F"F /"":...((;//5577 :..+&&   &  J 7>>*--*Ij)))       ccc >!VZ [[[ =a^_=a=abbbbbbb%  J 7>>*--*Ij)))       c&  J 7>>*--*Ij)))      sH03A A*)A*.BH03D;; EE BH0+3H H,+H,0 J4:&J/ J4!J7*3J J+*J+/J44J77L=3K10L1 K> ;L=K> >Lctjtdg}d}tj|d5}|}t d|j|jz}||z }||krtdt d||z}d} | |} | sn| dz } tj tj tj |dd| d d d td } | j} |  tj| d5} | |j| |j| |j| |j|j| | dddn #1swxYwY|| n5#t6$r( tj| n#t:$rYnwxYwwxYw dddn #1swxYwY|S)zDWrite WAV chunks small enough to pass the shared STT file-size gate.TrKirbr z/STT max_file_size is too small for WAV chunkingr_chunk03drrF)rRrdirrrN)r0rUrVr%r& getparamsr nchannels sampwidthr readframesr"r#rsplitextbasenamer$rr'r(r) framerate setcomptypecomptypecompnamer*rr-r1r2)rrr header_reservesourceparams block_alignmax_data_bytesframes_per_chunkrrtemprchunks rr r sK D))))KN 8T " "%f!!##!V-0@@AA &7 K ' 'NOO Oq.K"?@@ &&'788F  QJE.'**27+;+;H+E+EFFqI]]QV]]]] D J JJLLL Yz400.E&&v'7888&&v'7888&&v'7888%%fovGGG%%f--- ............... "":....   Ij))))D  / %%%%%%%%%%%%%%%N ssC?H?5G; BG G;G G;!G "G;:H?; H-HH- H(%H-'H((H--H??II_active_playbackcpt5t}dadddn #1swxYwY|rT|@ |tdn#t $rYnwxYw t\}}|dS#t $rYdSwxYw)z/Interrupt the currently playing audio (if any).NzAudio playback interrupted) _playback_lockr(poll terminater.rHr-rr)procr rs r stop_playbackr.s                    #  NN    KK4 5 5 5 5    D  A       s0 "".A// A<;A<%B'' B54B5c tdddd5}d|vcdddS#1swxYwYdS#t$rYdSwxYw) z5True when running inside Windows Subsystem for Linux.rrrbrcrhrirNF)r&rrwr-)rs r_is_wslr1s /3 K K K 3q!&&((.."2"22 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 uus3A(A  A AAAA A%$A%c tddd5}d|vcdddS#1swxYwYdS#t$rYdSwxYw)aUReturn True when running inside WSL2 (Windows Subsystem for Linux 2). Reads /proc/version and checks for the Microsoft kernel signature. Returns False on any error (non-WSL Linux, Docker, SSH, etc.). Extracted as a module-level function so tests can patch it directly without fighting builtins.open patching complexity. rrbrcr0rNF)r&rrwr2)_fvs r _is_wsl2_envr4s /GI F F F 5##((**"2"2"4"44 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 uus3A(A  A A  AA A A$#A$ctto'tjdotjdS)acReturn True when the WSL2 PowerShell TTS playback fallback can be used. This only covers OUTPUT (TTS playback via Media.SoundPlayer on the Windows host) -- it does NOT make microphone recording work. A caller using this to relax the audio-environment gate must still surface the existing PulseAudio-bridge guidance for recording/STT. powershell.exeffmpeg)rr4rXrYrrrrrsB  # L) * * # L " "  rctd t|tdS#tdwxYw)ayPlay an audio file through the default output device. Strategy: 1. WAV files via ``sounddevice.play()`` when available. 2. System commands: ``afplay`` (macOS), ``ffplay`` (cross-platform), ``aplay`` (Linux ALSA). Playback can be interrupted by calling ``stop_playback()``. Returns: ``True`` if playback succeeded, ``False`` otherwise. TF)r_play_audio_file_impl)rs rr,r,sHT"""($Y// '''' ''''s /Ac .tj|std|dS|drt r t\}}tj |d5}| | }| ||j }|}dddn #1swxYwYtrt!d|z}t!d|z}|dd||j} ||j} | d|xx| zcc<|t!d |z|j } ||||j | |j | g}d } nd } |||| t/||z } t1j| zd z}|r|jrot1j|krXt1jd|r0|jrt1j|kX|dS#t<t>f$rYn1t@$r%}t!d|Yd}~nd}~wwxYwtEj#}g}|dkr|$d|g|dkrtKj&drtKj&drtOr d dl(}tSj*gdtRj+d,d-}tSj*dd|gtRj+d,d-}|r.|.j/dd}tj0|d|d}tSj*dd|gtRj+d,d-}|r|1d d!}d"|d#}d$0tej0dd%|d&d'|d(d)d*g tej0dd+d,|gg}tej0d-d&|g}d.|d/|d0}|3d d1d2|gn#t@$rYnwxYw|$d3d4d5d(d)|g|dkr|$d6d7|g|D]}tKj&|d }|r d d8l4m5}tSj6|tRj+tRj+tRj+|d9:} tn5| a8dddn #1swxYwY| 9d;<| j:}!tn5da8dddn #1swxYwY|!d krdSt!d=|d |!#tRj;$rntd>|d | <| 9tn5da8dddn #1swxYwYYot@$rN}t!d?|d |tn5da8dddn #1swxYwYYd}~d}~wwxYwtd@|dS)ANzAudio file not found: %sFrrrrrrg?ir)r blocksizerrTzsounddevice playback failed: %srafplayLinuxr6r7)zcmd.exez/cz echo %TEMP%)r[rjrc)riwslpathz-uz hermes-tts-z-w'z''z(New-Object Media.SoundPlayer 'z ').PlaySync()z && z-irOwavz -loglevelquietz-yz -NoProfilez-Commandrmz( z ); rc=$?; z ; exit $rcz/bin/shrRffplayz-nodispz -autoexitaplayrb)hermes_subprocess_env)inherit_credentials)rvr[rlr,rz1System player %s exited with code %d, trying nextz+System player %s timed out, killing processzSystem player %s failed: %sz No audio player available for %s)=r0rrer.rrrrr%r&r getnframes frombufferr getframerater1rDrrrrrrrrrrrrrr:r2r-r/rrrrXrYr4uuidro check_outputrqdecoderuuid4hexrrcshlexinserttools.environments.localrGPopenr*r(rrurtkill)"rr r r6rrrsilence_samples fade_samplesfade audio_floattailr; duration_secsrr7rplayersrM _win_tmp_raw _win_tmp_wsl_unique_wsl_wav_win_wav _win_wav_safe _ps_script_ps_cmd_cleanup _full_cmdr_exerGr-rcs" rr9r9&s  7>>) $ $19===u &!!(?&A&C&C(?' ?"__FB9d++ 0rr}}77]]6]BB  oo//  0 0 0 0 0 0 0 0 0 0 0 0 0 0 0yy "%cK&7"8"8"3#455 {{3\{LL(// ;; M\M***d2***xxD;$6 7 7rxxHH^^HH_BHH==&&rx00- !  GGJ;)G L L L OOk9M~''-7#=H--// !bmmoo&< !AQAQT\A\A\ 4   --// !bmmoo&< !AQAQT\A\A\ GGIII4W%    D ? ? ? LL:A > > > > > > > > ?_  FG ),---V\*:;; X@V@V >>( '  )6444%-q   & &**5577 *6l3%-q   & &**5577 H"jjll.rr2G!w||L:U:U:U:UVVH)6"D(3)11   fIf..uuww H(0(8(8d(C(C ZmZZZ##)++!J$ 4(0+w(NOO!J(8, (2(455/## $):tT8.D#E#E %R$Q$QX$Q$Q$Q q9dI*FGGG     NNHik7IVWWW y1222$,$,l3q6"" " ,! ,KJJJJJ!'%-%-$,--%HHH $,,'+$,,,,,,,,,,,,,,, # &&&_#,,'+$,,,,,,,,,,,,,,,7744 PRUVWRXZ\]]]], , , ,LcRSfUUU  #,,'+$,,,,,,,,,,,,,,, , , , :CFAFFF#,,'+$,,,,,,,,,,,,,,, ,?" ,H NN5yAAA 5s #&K$ AC-! K$-C11K$4C15G-K$$L%7 L%L  L%GU$$ U10U1AZ"X-! Z"-X1 1Z"4X1 5'Z"Y+ Z"+Y/ /Z"2Y/ 3 Z"?"Z""A]5\ ]5\ ]5\ ]5 ]5')]0] ]0]# #]0&]# ']00]5rIF0u should_stop threshold sustained_mscalibration_mscapture on_trigger pre_roll_msendpoint_silence_msmax_utterance_msc  t\} } n#ttf$r |rdndcYSwxYwddlm} t t dz} td|dz} td|dz}td|dz}td|dz}| t| d }| td|dz }d}d }d} | t dd | 5}|sw| | \}}t| | | | jd z}|r'|||dz }t#|| kr|||d kr\t#|| krIt| t'|d}t|t(d z}n0t| t'|d}t||}tt|p t(d z|dz}t+|d}||kr||||kr|dznd}|dkr/t,d|||||||t#| ||kr t,d|||||||r> |n2#t2$r%}t,d|Yd}~nd}~wwxYw|s ddddSt'|}d}t5|D]}| | \}}||t| | | | jd z}|t(kr|dznd}||krnt6| |dcdddS dddn #1swxYwYn2#t2$r%}t,d|Yd}~nd}~wwxYw|rdndS)uBlock until sustained speech is heard on the mic, or *should_stop*. Barge-in monitor: run in a side thread while TTS is playing. Without *capture* it returns ``True`` when the user started talking (cut playback). With ``capture=True`` it ALSO records the interruption — a rolling *pre_roll_ms* buffer means the utterance is kept from its first syllable, not from the moment detection tripped — and keeps rolling until the user goes quiet for *endpoint_silence_ms*, then returns the WAV path (or ``None`` if speech never tripped). *on_trigger* fires at the moment of detection so the caller can stop playback while capture continues. The noise floor is calibrated from the first *calibration_ms* of input — playback is already audible then, so speaker bleed is baked into the floor and only louder-than-playback speech trips the trigger. Requiring *sustained_ms* of consecutive above-threshold blocks filters out coughs, keyboard thumps, and playback transients. NFrdequeQ?r dmaxlenrrrrrr;r!Zg @@@zfVAD above-trigger: block=%d rms=%.0f floor=%.0f trigger=%.0f consec=%d/%d min_floor=%.0f window_len=%duhVAD TRIPPED: block=%d rms=%.0f floor=%.0f trigger=%.0f consec=%d min_floor=%.0f — cutting TTS playbackz$Barge-in trigger callback failed: %sTrzBarge-in listener failed: %s)rr:r2 collectionsryrDrGrrrrErrrrrrr percentiler\rrr.r/rHr-rrtrr) rnrorprqrrrsrtrurvr r ryblock calib_blocks trip_blocksendpoint_blocks max_blocks floor_windowpre_roll consecutive min_floor block_idxrdatarr_pct90_floortriggerr7rrCs rlisten_for_speechrs8*BB  !***)ttE)))*"!!!!!  d" # #Eq.B.//La+,,K!0B677OQ(B.//J$)5L#0F0F#G#G#GLe3q+*;#<#<===HKIIe8 ^^{QgY^^ _ _b Pci!kmma P ++e,,aBGGBGGDKK ,C,Cq,H$I$IJJKK1OODIIKK000Q |$$|33 '',,,&##L(9(9\(I(I"2==l1C1CR#H#HIIF #F,AA,E F FII"2==l1C1CR#H#HIIF VY//eI$J1F1JKKVVY\ZZ gv.. == '',,,14kAooQ ??LLD!3#YL0A0A  ,, HsFG[) PP" $PPP %KQOOOOOOOOP kb Pb Pb Pb Pb Pb Pb Pb Pr%)NNz**A$kk%00GD!MM$))++... BJ0G0G10L(M(M N NOOC),/D)D)DEAII!E//0$//vA0N0NOOEb Pb Pb Pb Pb Pb Pb Pb Pa Pb Pb Pb Pb Pb Pb Pb Pb Pb Pb Pb Pb Pb Pb Pb PF 888 3Q777777778 %44%s..R6H.R% L0/R0 M:MRMR% R2C:R, R: RR  R R R SR<<Sgp@rcntjdddkS)NHERMES_VOICE_DEBUGrm1)r0rrBrrrr_voice_debug_enabledrs* :>>. 3 3 9 9 ; ;s BBrmsgct|tr3 td|tjddS#t $rYdSwxYwdS)uVAD decision-point diagnostic — always logger.debug, plus stderr when HERMES_VOICE_DEBUG=1 so live hardware tuning doesn't need a log tail.z [voice-vad] T)fileflushN)r.r/rprintrQr[r-)rs r_vad_logrs{ LL  &&&SZt D D D D D D    DD sA AA is_playing multipliergrace_msc  t\} } n#ttf$rYdSwxYwddlm} t t dz} td|dz}td|dz}tdt t|dz}td|dz}td|dz}td| dz}|rt|nt}| d }| td|dz }| | }tt}d }d }d }d}d }d} | t dd | 5}|s| | \} }!t| | | | jdz}"|| |dz }|t)|nd }#|s|#s||"t+||ks|#r|r0t| t/|dntt}$t|$tt}d}t1d|dd|$ddt+|d|dd |s|#r'|s%|r|dkr|}t1d|d|dzdd}|#}|#rdn|dz}||z}%|#rt|%t2}%n%t|%ttdz}%t5|%t6}%|#sm|"|%krg||"|rPtt| t/|dtt}|"|%k}&|&r&|dkr t1d|d|"dd|%dd|d d }&|dkr|dz}||&|"|%d!zkr;t1d"|d|"dd#|dd|%dd$|&d%t9|d&|d'|#rd(nd)|&rt9||ks%|#rd(nd)}'t1d*|'d+|d|"dd#|dd|%dd%t9|d&t+||r? ||'n2#t:$r%}(t<d,|(Yd}(~(nd}(~(wwxYwt/|})d}*tA|D]}!| | \} }!|)| t| | | | jdz}"|"tkr|*dznd}*|*|krntB"| #|)d-cdddS dddn #1swxYwYn2#t:$r%}(t<d.|(Yd}(~(nd}(~(wwxYwdS)/uJListen across an ENTIRE agent turn; return the captured interruption. Runs from utterance-submit to turn-complete. Two phases, decided per 30ms block by *is_playing* (usually ``is_audio_output_active``): * ``generation`` — no TTS audio flowing. The room is quiet; the first *calibration_ms* establish the noise floor (pre-playback calibration). Trigger = quiet_floor x *multiplier* (clamped to a sane minimum), i.e. ordinary speech detection. * ``playback`` — TTS audio flowing. The quiet baseline is HELD (never recalibrated against speaker bleed); the trigger is additionally clamped up to ``PLAYBACK_MIN_TRIGGER`` so bleed alone can't trip it, and a *grace_ms* window after playback first starts suppresses trips from the playback onset transient. Detection is a windowed majority — >=80% of the last *sustained_ms* worth of blocks above trigger (with the current block above) — so intra-word energy dips don't reset progress the way the old strictly- consecutive counter did. On detection ``on_trigger(phase)`` fires (cut TTS / interrupt the turn), then capture continues from the rolling *pre_roll_ms* buffer until *endpoint_silence_ms* of quiet, and the WAV path is returned. Returns ``None`` when *should_stop* ends the turn without speech. Nrrxrzr r{rr|r}Fi'rrr!rTzcalibrated quiet floor=z.0fz (pct90=z, z blocks, mult=gr!zplayback started (block=u ) — grace mszgrace suppression: block=z rms=z trigger=z (z blocks left)rzblock=z floor=z above=z window=rz phase=playback generationz TRIPPED (z ): block=z'full-duplex trigger callback failed: %srzFull-duplex listener failed: %s)$rr:r2rryrDrGrrFrEDEFAULT_BARGE_MULTIPLIERrrrrrrrrrrrrr\rPLAYBACK_MIN_TRIGGERrTRIGGER_CEILINGsumr-r.r/rrtrr)+rnrrsrrprqrrtrurvr r ryrrr trip_needed grace_blocksrrmultambientr recent_above quiet_floor floor_locked playing_prev playback_seengrace_remainingblocks_since_playbackrrrrrplayingpct90raboverr7rrCs+ rfull_duplex_listenrsJBB  !tt"!!!!!  d" # #Eq.B.//La+,,KaU;#4556677Kq(b.))L!0B677OQ(B.//J * H5   0HD#e3///Ge3q+*;#<#<===H"'%{";";";L-..KLLMO"Is; ^^"Qg  p P !kmmm P ++e,,aBGGBGGDKK ,C,Cq,H$I$IJJKK ,,,Q 0:0F$zz||,,,E $!",s+++7|||33w3 '>E"--W r"B"BCCC!&'EFF!,//FF25l2C2CFF SS" 5))))$SSS %NPQRRRRRRRRS %)NNz**A$kk%00GD!MM$))++... BJ0G0G10L(M(M N NOOC),/D)D)DEAII!E//0$//vA0N0NOOap Pp Pp Pp Pp Pp Pp Pp Pm Pp Pp Pp Pp Pp Pp Pp Pp Pp Pp Pp Pp Pp Pp Pp Pb ;;; 6::::::::; 4sz))X/!M/X# SX# T 'TX#T  C=X# X/ X/#X''X/*X'+X// Y9YYr c|sdS|}|dkrdS ddlm}ddlm}|||}||d||}n4#t $r'}td ||Yd}~dSd}~wwxYw|dS t| S#t $r)}t d ||d Yd}~dSd}~wwxYw) z@Return True when *provider* resolves to an available STT plugin.Fnoner) get_provider)_ensure_plugins_discoveredNT)forcez2STT plugin requirements check skipped for '%s': %szfSTT plugin provider '%s' is_available() raised during requirements check: %s - treating as unavailabler) rwragent.transcription_registryrhermes_cli.pluginsrr-r.r/r is_availabler)r keyrrplugin_providerexcs r_check_plugin_stt_providerrXsy u ..   " "C f}}u======AAAAAA""$$$&,s++  " ' &T 2 2 2 2*l3//O  @#s   uuuuu  u O0022333  2      uuuuus/:A// B 9BB ( C C<C77C<cHddlm}m}m}m}|}||}||}|dv}d}d} |r|s|||}|t |} |o|p|dup| } g} t } tp| } | s| ddgt}| o | o|d}g}| r| d n=| r| d n%| d td |s| d n|dkr| dn|dkr| dn|dkr| dn|dkr| dn|dkr| dn|dkr| dni|dkr| dnM|| d|d n1| r| d|d n| d|dD]}| d || d!gD]}| d ||| | | d" ||d#S)$zCheck if all voice mode requirements are met. Returns: Dict with ``available``, ``audio_available``, ``stt_available``, ``missing_packages``, and ``details``. r) _get_provider_load_stt_config$_resolve_command_stt_provider_configis_stt_enabled>xaigroqlocalopenaimistral elevenlabs local_commandNFr r rz)Audio capture: OK (Termux:API microphone)zAudio capture: OKzAudio capture: MISSING (rz5STT provider: DISABLED in config (stt.enabled: false)rz'STT provider: OK (local faster-whisper)rz STT provider: OK (local command)rzSTT provider: OK (Groq)rzSTT provider: OK (OpenAI)rz"STT provider: OK (Mistral Voxtral)rzSTT provider: OK (xAI Grok STT)rz$STT provider: OK (ElevenLabs Scribe)zSTT provider: OK (command: zSTT provider: OK (plugin: uSTT provider: MISSING (uv pip install faster-whisper — `pip install faster-whisper` also works if pip is on PATH, or set GROQ_API_KEY / VOICE_TOOLS_OPENAI_KEY)rz Environment: r )raudio_available stt_availablemissing_packagesr` environment)rrrrrrr}r;extendrrrUrBr)rrrr stt_config stt_enabled stt_providernative_stt_availablecommand_stt_configplugin_stt_availablermissingr has_audio env_checkr details_partsrnotices rcheck_voice_requirementsrs "!##J .,,K =,,L', L/LAA *    %#=l#K#K  T )  G466N ""4nI 1 w/000)**IFmF +0FIMZHIIII Z01111X8S8U8UXXXYYY  TUUUU  FGGGG  ( (?@@@@   67777  ! !89999  " "ABBBB   >????  % %CDDDD  'J<JJJKKKK  I,IIIJJJJ <   Z(886W667777-- 2..775V556666$&#99]++   rmax_age_secondsc"tjtsdSd}t j}tjtD]}|r|jdrl|j drR || j z }||krtj |j|dz }#t$rYwxYw|rtd||S)zRemove old temporary voice recording files. Args: max_age_seconds: Delete files older than this (default: 1 hour). Returns: Number of files deleted. rrNrr z"Cleaned up %d old voice recordings)r0risdirrVrscandiris_filer$rrrst_mtimer1r2r.r/)rdeletedrentryages rcleanup_temp_recordingsrs 7== # #qG )++CI&& ==?? uz44\BB uzGZGZ[aGbGb  EJJLL11((Iej)))qLG    D 97CCC Ns AC!! C.-C.)rrr r|rl)NrIrjFNrkrlrm) NNNrIrrrkrlrm)r)nrploggingrr0rrerRrXrorQpathlibrr"r*rr%typingrrrrr getLoggerrmr.rrrrrDr8r;rJrrKrPrXrUrZrnrzr}rrArrGrYrrrrrr gettempdirrVrrErrrrr6rrrr)rr+__annotations__r rr$r.r2r4rtrrcompile IGNORECASErrrrrrrrrrr r(rUr*r.r1r4rr,r9rrrrrrrrrrrrrrs}        66666666666666  8 $ $ )T ) ) ) )4$ S     A@@@@@+S++++&4HSM4444 747777tTTTTT22222jQ$QQQQl   GLL,,.. ? ? %25T343434e34334t34343434J#Y^%%  T  d     .....  !!,0)000      ::%::::*/y/////Dd0zzzzzzzz@BBBBBBBBJ }/BB>&2:@ -      $'&%&&&&0##S##SW####( 8 8 8 8 8$**3*x}*SRUX****Zs34// C=/ /  #s(^ ////d-3-#-$s)----j04(:+,333!!    ( d     t    (s(t((((,\S\T\\\\H $/3#"[&[&"d(#[&}[&[& [&  [& "d(+, [&[&[&[&[&[&[&rCdCCCC#$0426"&#"tt"d(#t"d(+,t3%+./t t  t  tttttc]ttttt%%%%%%Pc$sCx.ccccRSCr