)jP >UdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z mZmZmZejeZdZdefdZddlmZdefdZdeefd Zdefd Zdefd Zdefd Zde fd Z!dZ"dZ#dZ$dZ%dZ&dZ'ej()ej*dZ+d4de,de-de,ddfdZ.GddZ/GddZ0de0e/zfdZ1hd Z2ej3d!ej4"Z5d#edefd$Z6d5d%ed&eedeee ffd'Z7d(ed)e,defd*Z8d%ed&eed)e,deee ffd+Z9d%ed)e,deefd,Z:da;eej<e=d-<e j>Z?d6d.Z@d(edefd/ZAdeee ffd0ZBd7d2e,de,fd3ZCdS)8aVVoice 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: pip install hermes-agent[voice] N)AnyDictListOptionalcddl}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 7/home/wildlama/.hermes/hermes-agent/tools/voice_mode.py _import_audior s%  r6MreturncT tdS#ttf$rYdSwxYw)z/Return True if audio libraries can be imported.TF)r ImportErrorOSErrorrr _audio_availabler+s<t  !uus '') is_termuxc&trdSdS)NzGpkg install python-numpy portaudio && python -m pip install sounddevicezpip install sounddevice numpy)_is_termux_environmentrrr _voice_capture_install_hintr7sYXX * *rcJtsdStjdS)Nztermux-microphone-record)rshutilwhichrrr _termux_microphone_commandr=s& ! # #t <2 3 33rctsdS tjgdddddtj}d|jpdvS#t $rYdSwxYw)NF)pmlistpackageszcom.termux.apiTcapture_outputtexttimeoutcheckstdinzpackage:com.termux.api)r subprocessrunDEVNULLstdout Exception)results r _termux_api_app_installedr/Ds ! # #u  8 8 8$    (FM,?R@@ uus0A AAc>tduo tSN)rr/rrr _termux_voice_capture_availabler2Us % ' '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_SERVERr(;zunix:PULSE_RUNTIME_PATHnativeXDG_RUNTIME_DIRpulsez pipewire-0g?TF)socketstatosenvirongetsplitstrip startswithappendlenpathjoinS_ISSOCKst_moderAF_UNIX SOCK_STREAM settimeoutconnectclose) r:r; candidates pulse_serverpart pulse_runtime xdg_runtimerDsocks r _pulse_socket_reachablerSYsDMMMKKKJ:>>."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| vrJtjdr|dn|ddddn #1swxYwYn#ttt 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|dYnwxYw| ||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). r4PIPEWIRE_REMOTEc3TK|]#}tj|V$dSr1)r<r=r>).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-0z /proc/versionrzutf-8)encoding microsoftz%Running in WSL with PulseAudio bridgezRunning in WSL -- audio requires 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.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)rr/boolr<r=r>rSanyrBhermes_constantsr]openreadlowerFileNotFoundErrorPermissionErrorrr query_devicesr-rrr) rcrdtermux_mic_cmdtermux_app_installedtermux_capturehas_forwarded_audior]fr _devicess r detect_audio_environmentrusHG/11N466.A-ABBN ~&& % :>>+ , , % " $ $ R R&Q R R RRR    NN_ ` ` ` ` OOS   .-----|~~    NNd e e e e OOR     /3 9 9 9 Qaffhhnn....:>>.11NN#JKKKKOO^                 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(   ,"\  swF,!A3F  F, F$$F,'F$(F,,GG JAH87J8AJ J J  JA!M(1A4M('M(i>int16@ hermes_voicepQ? frequencydurationcountc z t\}}n#ttf$rYdSwxYw d}tt|z}tt|z}g}t |D]!} |d||d} |d|jz|z| z} tttdz|dz} | d| xx|dd | zcc<| | dxx|d d| zcc<| | d zd z |j | |d z kr/| | ||j #||} || t t!jdz}|r|jrot!j|krXt!jd|r0|jrt!j|kX|dS#t,$r&}t.d|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?rF)endpointrx{Gz?rv333333?idtype samplerate@zBeep playback failed: %s)r rrint SAMPLE_RATErangelinspacesinpiminrBastyperwzeros concatenateplaytime monotonic get_streamactivesleepstopr-loggerdebug)r~rrr r gapsamples_per_beepsamples_per_gappartsittonefade_lenaudiodeadlinees r play_beepr#sBB  !4{X566kC/00u H HA Ax)9E JJA66!be)i/!344D3{T1224D4IJJH (OOOr{{1a:: :OOO (    Aq( ; ; ;    LL$*u,44RX>> ? ? ?519}} RXXoRXXFFGGGu%% +...>##c)mmoo "--//"8 T^=M=MPX=X=X Jt   mmoo "--//"8 T^=M=MPX=X=X  444 /3333333334s$))IJ J:J55J: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)NFr) threadingLock_lock _recording _start_time_recording_path _current_rmsselfs r __init__zTermuxAudioRecorder.__init__Ts6^%% .2rc|jSr1rrs r is_recordingz TermuxAudioRecorder.is_recording[s rcJ|jsdStj|jz SNrrrrrrs r elapsed_secondsz#TermuxAudioRecorder.elapsed_seconds_' 3~$"222rc|jSr1rrs r current_rmszTermuxAudioRecorder.current_rmses   rc  ~t}|stdtstd|j5|jr ddddSt jtdtj d}t j td|d|_ dddn #1swxYwY|d|j d d d d d ttdttg } t!j|ddddt 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.aacz-fz-l0z-eaacz-rz-cr"z Termux microphone start failed: rzTermux voice recording started)r RuntimeErrorr/rrr<makedirs _TEMP_DIRrstrftimerDrErstrrCHANNELSr)r*r+CalledProcessErrorstderrr,r@r-rrrrinfo)ron_silence_stopmic_cmd timestampcommandrdetailss r startzTermuxAudioRecorder.startis ,.. 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 N74dBVZblbt u u u u u, T T Tx5185s1vv<<>>GK'KKLLRS S N N NE!EEFFA M NZ " "#~//D "DO !D  " " " " " " " " " " " " " " "  455555sP CACC C$D++F!:AE<< F! FF!+'GG"%G"cvt}|sdStj|dgddddtjdS)N-qTrFr")rr)r*r+)rrs r _stop_termux_recordingz*TermuxAudioRecorder._stop_termux_recordingsG,..  Ft$PRZ_gqgyzzzzzzrcr|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)rrrrrrr<rDisfilerrunlinkrgetsizerr)rrD started_ats r rzTermuxAudioRecorder.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) rrrrrr-r<rDrrrrr)rrDs r cancelzTermuxAudioRecorder.cancels" Z " "'D#DO#'D !D   " " " " " " " " " " " " " " "    ' ' ) ) ) )    D   BGNN4((   $     677777s/155A AAB B&%B&c.|dSr1)rrs r shutdownzTermuxAudioRecorder.shutdowns rrNr1)__name__ __module__ __qualname____doc__supports_silence_autostoprpropertyrerfloatrrrrrrrrrrrrr rrOs"LL %dX3333X3 !S!!!X!*6*6*6*6*6X{{{{ hsm88888"rrceZdZdZdZddZedefdZede fdZ ede fdZ dd Z ddd Zdd eddfd ZdeefdZddZddZedefdZdS) 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. TrNcFtj|_d|_g|_d|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_d|_t |_t$|_d|_d|_d|_dS)NFrrg.@r)rrr_stream_framesrr _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 _peak_rmsrrs r rzAudioRecorder.__init__s^%%   "$ "% $'!$+.!),%($'(+ $'<(@ $!"rcJ|jsdStj|jz Srrrs r rzAudioRecorder.elapsed_secondsrrc|jS)zBCurrent audio input RMS level (0-32767). Updated each audio chunk.rrs r rzAudioRecorder.current_rmss   rc|jS)z,Whether audio recording is currently active.rrs r rzAudioRecorder.is_recordings rctjdSt\}fd}d} |ttt |}|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 | _ jktj}| 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}|r` j5 j d _dddn #1swxYwY r3 fd }t?j |d !dSdSdSdS) Nzsounddevice status: %srxrTz(Speech confirmed (%.2fs above threshold)rz'Speech attempt reset (dip lasted %.2fs)Fz'Silence detected (%.1fs), auto-stoppingz%No speech within %.0fs, auto-stoppingc dS#t$r(}td|dYd}~dSd}~wwxYw)NzSilence callback failed: %sTexc_info)r-rerror)rcbs r _safe_cbzAAudioRecorder._ensure_stream.._callback.._safe_cbrsg^ "#,^^^ & -JAX\ ] ] ] ] ] ] ] ] ]^s  A<Atargetdaemon)"rrrrrBcopyrsqrtmeanrfloat64rmaxrrrrrrrrrrrrrrrrrrrThreadr) indataframes time_infostatusrmsnowelapsed should_firer r r rs @r _callbackz/AudioRecorder._ensure_stream.._callbacks ? 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 O55!204-555555555555555O^^^^^ "(FFFLLNNNNN_10J O OOOs"K==LL)rchannelsrcallbackz#Failed to open audio input stream: z6. Check that a microphone is connected and accessible.) rr InputStreamrrDTYPErr-rLr)rr rstreamrr s` @r _ensure_streamzAudioRecorder._ensure_stream s# < # FB] O] O] O] O] O] O@ ^^&!" $F LLNNNN   !LLNNNN DGaGGG   s;._do_closesH       s (- ;;Tr rg?r%u:Audio stream close timed out after %.1fs — forcing ahead) rrrr __import__ris_aliverErwarning)rr%r*rrr#s @r _close_stream_with_timeoutz(AudioRecorder._close_stream_with_timeouts$ <  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|ttdz}t||kr6tdt| ddddS|jt kr4t d|jt  ddddS||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. NFr)axisz+Voice recording stopped (%.1fs, %d samples)rz,Recording too short (%d samples), discardingz2Recording too quiet (peak RMS=%d < %d), discarding)rrrrr rrrrrrrCrrrrr _write_wav)rrsr audio_datar min_sampless r rzAudioRecorder.stops.Z / /?  / / / / / / / /$DO !D <  / / / / / / / /"OOEAr 1==JDLn&&)99G KKEwPST^P_P_ ` ` `kC/00K:,, KSQ[__]]]/ / / / / / / / /6~ 555 P N,ACCC= / / / / / / / /@??:..A / / / / / / / / / / / / / / / / / /s) E>E>C E>7E>E>>FFc|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)rrrrrrrrs r rzAudioRecorder.cancels Z " "#DODL$(D ! !D   " " " " " " " " " " " " " " "  /00000s 155c|j5d|_g|_d|_dddn #1swxYwY|t ddS)z%продолжение следует(продолжение следует...*ご視聴ありがとうございました,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)r@rjrstripWHISPER_HALLUCINATIONS_HALLUCINATION_REPEAT_REmatch)rbcleaneds r is_whisper_hallucinationri]st  &&((G t~~d555DZ9Z9Zt%%g..t 5rrAmodelc4ddlm}m}t||rt |||}n |||}|drJt |ddr'td|dd dd d S|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_audio)rj max_file_sizerjsuccessrbr(z"Filtered Whisper hallucination: %rT)rprbfiltered) tools.transcription_toolsrlrm_should_chunk_for_transcription_transcribe_wav_in_chunksr>rirr)rArjrlrmr.s r transcribe_recordingrunsJIIIIIII&x??9*85P]^^^!!(%888zz)E!9&**\SU:V:V!W!WE 8&:NOOOrtDDD Mr file_pathrnc|dsdS tj||kS#t $rYdSwxYw)z@Return whether a CLI WAV recording needs to be split before STT.r8F)rjendswithr<rDrr)rvrns r rsrssg ??   % %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)rm)rnFr(zNo audio chunks were created)rprbr z+Transcribing oversized WAV in %d chunks: %srv)rrorpr zUnknown transcription errorzChunk /z failed: rbT provider)rprbr|chunksz'Chunked transcription failed for %s: %srzChunked transcription failed: N)rrrm_split_wav_for_transcriptionr<rDrrrrrrC enumerater>r@rirBrEr-r ) rArjrnrm chunk_paths transcripts chunk_pathindexr.r rbrs r rtrts;:::::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.Trirbrvz/STT max_file_size is too small for WAV chunkingr_chunk03drsr8F)prefixsuffixdirdeleter9N)r<rrr:rh getparamsr nchannels sampwidth ValueError readframestempfileNamedTemporaryFilerDsplitextbasenamenamerLr;r<r> framerate setcomptypecomptypecompnamer?rBr-rr)rArnrheader_reservesourceparams block_alignmax_data_bytesframes_per_chunkrrtemprchunks r r~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_lockrpoll terminaterrr-r r)procr rss r stop_playbackrs                    #  NN    KK4 5 5 5 5    D  A       s0 "".A// A<;A<%B'' B54B5cjtj|std|dS|dr t \}}tj|d5}| | }| ||j }| }dddn #1swxYwY|||t||z }t!j|zdz}|r|jrot!j|krXt!jd |r0|jrt!j|kX|d S#t,t.f$rYn1t0$r%} td | Yd} ~ nd} ~ wwxYwt5j} g} | d kr| d |g| ddddd|g| dkr| dd|g| D]} t;j| d} | rh t?j | t>j!t>j!t>j!}tD5|a#dddn #1swxYwY|$dtD5da#dddn #1swxYwYd S#t>j%$rntd| d|&|$tD5da#dddn #1swxYwYY.t0$rN} td| d| tD5da#dddn #1swxYwYYd} ~ d} ~ wwxYwtd|dS)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. zAudio file not found: %sFr8rrNrrrTzsounddevice playback failed: %sDarwinafplayffplayz-nodispz -autoexitz -loglevelquietLinuxaplayrr)r,rr'i,r+z+System player %s timed out, killing processzSystem player %s failed: %sz No audio player available for %s)'r<rDrrr.rxr r:rhr getnframes frombufferrw getframeraterrCrrrrrrrrr-rplatformsystemrBrrr)Popenr+rrwaitTimeoutExpiredkill)rvr r rBrr3 sample_rate duration_secsrrrplayerscmdexers r play_audio_filersD 7>>) $ $19===u&!!? ?"__FB9d++ 0rr}}77]]6]BB  oo//  0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 GGJ;G 7 7 7 OOk9M~''-7#=H--// !bmmoo&< !AQAQT\A\A\ 4   --// !bmmoo&< !AQAQT\A\A\ GGIII4W%    D ? ? ? LL:A > > > > > > > > ?_  FG ),--- NNHik7IVWWW y1222,,l3q6""  , ,!'J4FzOaisi{|||#,,'+$,,,,,,,,,,,,,,, # &&&#,,'+$,,,,,,,,,,,,,,,tt, , , ,LcRSfUUU  #,,'+$,,,,,,,,,,,,,,, , , , :CFAFFF#,,'+$,,,,,,,,,,,,,,, , ,( NN5yAAA 5s&G:AC GC""G%C"&C5GH0 H9HH/=M,K;/ M;K? ?MK?  M#L2& M2L6 6M9L6 :MAPN." P.N2 2P5N2 6P< P)P.O=1 P=P PP PPcddlm}m}m}|}||}||}|o|dk}g}t }t p|} | s|ddgt} | o |o| d} g} |r| dn=| r| dn%| d td |s| d ni|d kr| d nM|dkr| dn1|dkr| dn| d| dD]} | d| | dgD]}| d|| | ||d | | dS)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_configis_stt_enablednonerr rbz)Audio capture: OK (Termux:API microphone)zAudio capture: OKzAudio capture: MISSING (raz5STT provider: DISABLED in config (stt.enabled: false)localz'STT provider: OK (local faster-whisper)groqzSTT provider: OK (Groq)openaizSTT provider: OK (OpenAI)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)rcz Environment: rd )rbaudio_available stt_availablemissing_packagesr environment) rrrrrr2rextendrurBrr>rE)rrr stt_config stt_enabled stt_providerrmissingrp has_audio env_checkrb details_partsr.notices r check_voice_requirementsrdstZYYYYYYYYY!!##J .,,K =,,L:LF$:MG466N ""4nI 1 w/000)**IFmF +0FIMZHIIII Z01111X8S8U8UXXXYYY   TUUUU  FGGGG   67777  ! !89999 <   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. rrr8rvz"Cleaned up %d old voice recordings)r<rDisdirrrscandiris_filerrArxr;st_mtimerrrr)rdeletedrentryages r cleanup_temp_recordingsrs 7== # #qG )++CI&& ==?? uz44\BB uzGZGZ[aGbGb  EJJLL11((Iej)))qLG    D 97CCC Ns AC!! C.-C.)r|r}rvr1r)r)Drloggingr<rrerr)r&rrrr:typingrrrr getLoggerrrr rerrgrrrrrr/r2rSdictrurrr"r=rrrDrE gettempdirrrrrrrrFrecompile IGNORECASErfrirursrtr~rr__annotations__rrrrrrrrr rs       ,,,,,,,,,,,,  8 $ $$A@@@@@+S++++ 4HSM44444"TTTTT22222j@$@@@@J   GLL,,.. ? ? &4&4&4e&43&4t&4&4&4&4Xzzzzzzzz@[[[[[[[[| }/BB>&2:@ -      "3x}SRUX8s34// C=/ /  #s(^ ////d-3-#-$s)----j04(:+,333!!    (KsKtKKKKb=$sCx.====FSCr