+ jHj*\aRVtG0tRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RIt ^RIHt^RIHt^RIHt^RIHtHt^RIHtHt^RIHtHtHt^RIHtH t H!t!H"t"H#t#^R I$H%t%H&t&H't']PP!R 4t)]!4t*]!R R 4t+]!R 4t,]!RR4t-RRRRRRRRRRRRRRRRRRR R!R"RR#RR$R!/ t.]^kRWt/RRRRR%RRRRR/t0R&R'lt1R(R)lt2R*R+lt3]*PiR,4RXR-R.ll4t5]*PmR/4RXR0R1ll4t7]*PmR24RXR3R4ll4t8]*PiR54RXR6R7ll4t9R8R9lt:]*PmR:4RXR;R<ll4t;]*PiR=4RXR>R?ll4t<]*PiR@4RXRARBll4t=!RCRD4t>RERFlt?RGRHlt@RIRJltARKRLltB]*PiRM4RXRNROll4tC]*PRP4RQRRl4tE]*PRS4RTRUl4tFR#)Ya&Audio dashboard routes: transcription upload + live transcribe-stream, voice config, ElevenLabs voices, TTS speak/lease and the speak-stream WebSocket. Extracted from ``hermes_cli.web_server``; helpers/state that tests monkeypatch on ``web_server`` stay there and are late-bound (cycle-safe). N) APIRouter) http_failure)late) _ws_auth_ok_ws_request_is_allowed)_read_dashboard_json_response_split_text_for_speak_stream) HTTPException WebSocketWebSocketDisconnect)AudioTranscriptionRequestSTTLeaseRequestTTSSpeakRequestTTSLeaseRequestVoiceLiveSessionRequest)AnyDictOptionalzhermes_cli.web_server_config_profile_scopezhermes_cli.web_server_profiles_voice_list_error_logged_onceload_envzhermes_cli.configz audio/aacz.aacz audio/flacz.flacz audio/m4az.m4az audio/mp3.mp3z audio/mp4z.mp4 audio/mpegz audio/oggz.oggz audio/wavz.wavz audio/wave audio/webm.webmz audio/x-m4az audio/x-wav video/webmz.opusc(V^8dQhR\RR/#)pathreturnNstr)formats"A/home/ubuntu/.hermes/hermes-agent/hermes_cli/web_routers/audio.py __annotate__r$9s  # $ cX\P!V4R# \dR#i;iN)osunlinkOSError)rs&r#_unlink_quietlyr+9s$  $    s  ))c:V^8dQhR\\,/#rprofilerr!)r"s"r#r$r$@s,,hsm,r%c\aa"VV3Rlp\P!V4GRjxL #L5i)aRun ``fn()`` on a worker thread under the config-only profile scope. Home-only contextvar scope, NOT ``_profile_scope``: these calls block for a provider round-trip and only need config/.env resolution, while ``_profile_scope`` holds a process-global skills lock for its entire body. cv<\S4;_uu_4S!4uuRRR4# +'giR#;ir'r)fnr.sr#_scoped#_run_config_scoped.._scopedGs" "7 + +4, + + +s' 8 N)asyncio to_thread)r.r3r4sff r#_run_config_scopedr8@s$""7+ ++ +s !,*,c0V^8dQhR\R\/#)r mime_typerr )r"s"r#r$r$Qs;;;;r%cT;'gRPR^4^,P4P4p\P VR4#);r)splitstriplower_AUDIO_MIME_EXTENSIONSget)r: normalizeds& r#_audio_extension_for_mimerDQsD//r((a0399;AACJ ! % %j' ::r%z/api/audio/transcribecFV^8dQhR\R\\,/#rpayloadr.)r rr!)r"s"r#r$r$Ws ;; &;19#;r%c `a a "VP;'gRP4pVPR4'dRV9d\RRR7hVP R^4wr4RV9d\RRR7hVP ;'g+VR,P R ^4^,;'gR P4pVP R ^4^,P 4pVPR 4'gVR 8Xg\RR R7h\P!VRR7pT'g\RRR7h\T4\8d\RRR7hRo \RRR4;_uu_4\P !R\#T4RR7;_uu_4pTP%T4TP&o RRR4^RIHo \-TT T 3Rl4GRjxL p RRR4S 'd \/S 4X P1R4'gUT P1R4;'gRp RT P 49dR RR!RR"T P1R"4/#\RT R7hR RR!\3T P1R!4;'gR4P4R"T P1R"4/# \P\3d\RRR7hi;i +'giEL);iEL +'giEL;i S 'd \/S 4ii;i5i)#r<data:,zInvalid audio payload status_codedetailz;base64z$Audio payload must be base64 encoded:NNr=rzaudio/rz"Payload must be an audio recordingT)validatez!Audio payload is not valid base64zAudio recording is emptyizAudio recording is too largez"Desktop voice transcription failedzTranscription failedzhermes-desktop-voice-F)prefixsuffixdeleteN)transcribe_recordingc<S!S4#r') temp_pathrUsr#)transcribe_audio_upload..s ?ST]?^r%successerrorzempty transcriptok transcriptprovider)data_urlr? startswithr r>r:r@base64 b64decodebinasciiError ValueErrorlen_MAX_TRANSCRIPTION_UPLOAD_BYTESrtempfileNamedTemporaryFilerDwritenametools.voice_moderUr8r+rBr!) rGr.r`headerencodedr:normalized_mime_type audio_bytestmpresulterrrXrUs && @@r#transcribe_audio_uploadruVs  &&B--/H   w ' '3h+>4KLLnnS!,OF4Z[[""QQfRj&6&6sA&>q&AQQ\XXZI$??3215;;= + +H 5 59MQ]9]4XYYY&&w>  4NOO ;994RSSI' >E[ \ \,,.7PQZ7[ +&HH  >-g7^__F]  I & ::i jj!;;%;  ,$ b*fjj>TU UC88 dL#fjj&>&D&D""E"K"K"MFJJz* M NNJ 'Y4WXXY`] \ \  I & s;L.AL.'L.7AL.L.J>3L.;0L.,L+L,K* "L,K>-L1L9)L.#L.;AL.'L.>)K''L.* K; 5 L L LL++L.z/api/audio/voice-configc:V^8dQhR\\,/#r-r/)r"s"r#r$r$s""8C="r%c "^RIHp\W4GRjxL pRR /TC#L \dh\d0\ P R4RRRR/pRR R TR \T4/u#i;i5i) uThe active profile's STT/TTS config for CLIENT-DIRECT voice. Lets the desktop cut the audio relay hop: mic audio goes straight to the profile's STT provider and reply text is synthesized on the client with the profile's TTS provider — the desktop↔gateway link carries only text. Providers that can only run on this host (local whisper, edge-tts, command/plugin providers) resolve to ``{"mode": "relay"}`` and the desktop keeps using the /api/audio/* relay endpoints. Same trust boundary as every profile-scoped route: the caller is an authenticated client that can already drive the agent. Keys in the response are held in client memory only, never persisted client-side. Gate: ``voice.client_direct`` in config.yaml (default true). )resolve_client_voice_configNz%Client voice-config resolution failedmoderelayreasonzresolution errorr]Tstttts)tools.voice_client_configrxr8r Exception_log exceptiondict)r.rxrsfallbacks& r#get_client_voice_configrs FD)'OO $ !& !!P  D >?GX/ABdE8UDNCCDs6A-%#%A-%A*-A*'A-)A**A-z/api/audio/voice-live/statusc:V^8dQhR\\,/#r-r/)r"s"r#r$r$s""#"r%c"^RIHp\RRR4;_uu_4\W4GRjxL pRRR4RR/XC#L +'giL;i5i)zWhich voice chat mode the profile selected (``chained`` | ``gpt-live``) and whether GPT-Live can start. Non-secret: the desktop decides which conversation engine to mount from this.)resolve_gpt_live_statusz!GPT-Live status resolution failedrQzGPT-Live status failedNr]T)tools.voice_liverrr8)r.rrss& r#get_voice_live_statusrsM9 93@X Y Y)'KK Z $ !& !!L Z Ys+AAAAAA A Az/api/audio/voice-live/sessioncFV^8dQhR\R\\,/#rF)rrr!)r"s"r#r$r$s ""-D"xX[}"r%cnaaa"^RIHoSP;'gRoSP4'g\ RRR7h\ VVVV3Rl4GRjxL pR R /TC#L \ dp\ R\T4R7hRp?i\dp\ R \T4R7hRp?ii;i5i) aFExchange the renderer's WebRTC SDP offer for a GPT-Live session answer. The project API key stays on this host; the renderer only receives the session id and the SDP answer. Client delegation is fixed at creation: every ``session.delegation.created`` the renderer receives becomes a Hermes turn on the session it belongs to. )create_webrtc_sessionr<rKzAn SDP offer is requiredrLc*<S!SSP4#r')history)rrGsdpsr#rY+create_voice_live_session..s;PQTV]VeVe;fr%Nir]T) rrrr?r r8rfr! RuntimeError)rGr.rsexcrrsf& @@r#create_voice_live_sessionrs7 ++  C 99;;4NOO>)'3fgg $ !& !! h >CH== >CH==>sR2B5 B5A(A&A( B5&A(( B23B  B2B2B--B22B5cRV^8dQhR\\\3,R\/#)rvoicerrr!r)r"s"r#r$r$s"884S>8c8r%c \VPR4;'gVPR4;'gR4P4p\VPR4;'gR4P4pV'd V RV R2#T#)rlvoice_idVoicecategoryr<z ())r!rBr?)rrlrs& r#_elevenlabs_voice_labelrsu uyy DDEIIj$9DDW E K K MD599Z(..B/557H%-dV2hZq !747r%z/api/audio/elevenlabs/voicesc:V^8dQhR\\,/#r-r/)r"s"r#r$r$sG1G1#G1r%c ba "\V4;_uu_4\4PR4;'gRP4pRRR4X'g+^RIHpHpV!R4;'gRP4pV'gRRR./#\PPRR R R V/R 7o R V 3Rllp\P!V4GRjxL p\%R4.pTPR4;'g.Fp\1T\24'gK\/TPR4;'gR4P4p T 'gKWTP5RT R\/TPR4;'gT 4R\7T4/4K TP9RR7RRRT/# +'giEL|;i Td<\PPR4;'gRP4pELi;i \dELi;iELN \PP dpTP"R9dB\%RTP" 24'd\&P)RT4RRR.RR/uRp?#\%RTP" 24'd\&P+RT4\-RRR7hRp?i\dCp\%\/T44'd\&P+RT4\-RRR7hRp?ii;i5i)zReturn ElevenLabs voices when an API key is configured. The desktop UI uses this for the ``tts.elevenlabs.voice_id`` dropdown. Only non-secret voice metadata is returned; the API key stays server-side. ELEVENLABS_API_KEYr<N)UnscopedSecretError get_secret availableFvoicesz#https://api.elevenlabs.io/v1/voicesAcceptzapplication/jsonz xi-api-key)headerscFV^8dQhR\\\3,/#rrr)r"s"r#r$+get_elevenlabs_voices..__annotate__s ? ?S#X ?r%c<\PPS^ R7;_uu_4p\V4uuRRR4# +'giR#;i) timeoutN)urllibrequesturlopenr)responsers r#_fetch%get_elevenlabs_voices.._fetchs6'''<<4X>=<<ElevenLabs voices unavailable: %s — check ELEVENLABS_API_KEYr\ unauthorizedz ElevenLabs voice list failed: %srz Could not load ElevenLabs voicesrLrrllabelcf\VPR4;'gR4P4#)rr<)r!rBr@)items&r#rY'get_elevenlabs_voices..!s#TXXg%6%<%<"!=!C!C!Er%)keyT)ii)rrrBr?agent.secret_scoperrr(environrrrRequestr6r7r\ HTTPErrorcoderrinfowarningr r! isinstancerappendrsort) r.api_keyrrrrGrrrrrs & @r#get_elevenlabs_voicesrs w ' ':>>"67==2DDF (    J O%&:;AArHHJ UHb11nn$$--|WE%G X ? ? ))&11""$' FX&,,",%&& uyy,22399;  &#eii.?.K.K8*L ,U3  - KKEKF x 00 ( ' '' O::>>*>?EE2LLN O   2 << ! ! X 88z !,uSXXJ-?@@ Z\_`"g~N N (5 ); < < LL;S A4VWW X (S 2 2 LL;S A4VWWXsL/2F< L/H#G2GL/ +L/7"H*H'H*$L/:L/>L/,L/4L/< G  L/,H=HHL/HH H$ L/#H$$L/'H**L, A KL,L/AK L,)L,*=L''L,,L/z/api/audio/speakcFV^8dQhR\R\\,/#rF)rrr!)r"s"r#r$r$&s55o5 5r%c a a a "VP;'gRP4o S 'g\RRR7h\RRR4;_uu_4^RIHo \ VV V 3R l4GR jxL pR R R 4\X\4'd\P!V4MTpTPR 4'g'\RTPR 4;'gRR7hTPR4o S 'd&\PPS 4'g\RRR7h\ P\PP#S 4^,P%4R4pRT 3Rllp\&P(!T4GR jxL p\,P.!T4P1R4pRRRRT RT 2RTRTPR4/#ELx +'giEL;i \d\RR R7hi;iL{ \*dp\RRT 2R7hR p?ii;i5i)zSynthesize speech and return audio as base64 data URL. Used by the desktop voice-conversation mode to play back assistant responses without exposing the on-disk file path; reuses the TTS provider chain configured under ``tts.`` in config.yaml. r<rKzText is requiredrLzDesktop voice TTS failedrQSpeech synthesis failedtext_to_speech_toolc<S!S4#r'rW)textrsr#rYspeak_text..6s @STX@Yr%NInvalid TTS responser[r\ file_pathAudio file missingrc$V^8dQhR\/#r)bytes)r"s"r#r$ speak_text..__annotate__Hs''e'r%c<\SR4;_uu_4pVP4uuRRR4\S4# +'giM;i\S4R# \S4i;i)rbN)openreadr+)fhrs r#_read_and_unlink$speak_text.._read_and_unlinkHsQ 'i&&"wwy'& I &'&& I &OI &sA= A A A A+zCould not read audio: asciir]Tr`rIz;base64,r:r_)rr?r rtools.tts_toolrr8rr!jsonloadsrrBr(risfile_SPEAK_MIME_BY_EXTsplitextr@r6r7r*rb b64encodedecode) rGr. result_jsonrsr:rrqrrorrrs && @@@r# speak_textr%s LL  B % % 'D 4FGG 0#7P Q Q6.w8YZZ  R L,6{C,H,HK(k ::i FJJw$7$T$T;T   ;'I BGGNN9554HII"&&rww'7'7 'B1'E'K'K'M|\I''T#--.>?? {+227;G dJ% {(7) DkS\FJJz* E[ R Q Q L4JKKL2@ T6LSE4RSSTs,H?"H?G*/G'0G*4H?=.G>+H?H? H?$H?&AH?HHH#AH?'G** G; 5 H?>HH?H H<'H77H<<H?z/api/audio/tts-leasecFV^8dQhR\R\\,/#rF)rrr!)r"s"r#r$r$_s""L"L_"Lx}"Lr%c aaa"SP;'gRP4oS'g\RRR7hVVV3Rlp\P!V4GRjxL pR R R SRSP/TC#L \dh\ d>p\ PRSSPT4RRR R R \T4/pRp?LdRp?ii;i5i)uDesktop TTS-output toggles as warm-up / release signals. ``active: true`` registers a lease on the TTS engine and pre-loads the configured provider (local model, lazily-installed SDK) so the first spoken reply doesn't pay the load as dead air; ``active: false`` drops the lease and, once no surface holds one, unloads resident local models. Blocking work runs off the event loop. Warm-up failures are reported in the body, never as an HTTP error — the toggle must succeed even when preload fails. r<rKlease is requiredrLcR<^RIHpHpSP'd'\ S4;_uu_4V!S4uuRRR4#\ S4;_uu_4V!S4uuRRR4# +'giL7;i +'giR#;i \ d T!S4u#i;i))acquire_tts_leaserelease_tts_leaseN)tools.tts_tool_lifecyclerractiverr )rrleaserGr.s r#_applytts_lease.._applymsxQ >>>&w//(/0/ ,&w//(/0/ 0/ 0// ,$U+ + ,s;A)BA< B) A9 < B B BB&%B&NzTTS lease %s (%s) failed: %sleasesactionr\r]Trr rr?r r6r7rrrrr!rGr.rrsrrsff @r# tts_leaser^s]] b ' ' )E 4GHH ,H((00 $'.. KF KK 1  H 3UGNNCPD(GWc#hGHL,CCA<!A:"A<&C:A<<CC3C C CCc>a]tRtRtoRtRt^tV3RlRltRtVt R#)_SyncSentencePCMStreameriaSpeak one sentence through the sync TTS tool and yield int16 mono PCM. Not a second provider: ``text_to_speech_tool`` is the same stack the CLI speaker uses for edge and every other non-chunked provider. The desktop socket only plays PCM, so the written file is decoded before it is sent. ``sample_rate`` is updated before the first yield, matching the chunked streamers whose rate is only final once synthesis has answered. ]c <V^8dQhRS[/#)rrr )r" __classdict__s"r#r$%_SyncSentencePCMStreamer.__annotate__s3r%c#`"\V4wr#V'dW0nV'dVxR#R#5ir')_sync_sentence_to_pcm sample_rate)selfrpcmrates&& r#stream_SyncSentencePCMStreamer.streams')$/  #  I s#..)rN) __name__ __module__ __qualname____firstlineno____doc__rchannelsr__static_attributes____classdictcell__)rs@r#rrs KHr%rc0V^8dQhR\R\/#)rrrr!tuple)r"s"r#r$r$s####r%c^RIHp\P!RR7wr#\P !V4RpV!WR7p\ V\4'd\P!V4MTp\ T\4'dTPR4'gR\ T\4'd%\TPR4;'gR 4MR p\T;'gR 4hTPR 4;'gTp \ T \4'dJ\PP!T 4'd%\PP#T 4^8:d \R 4h\PP%T 4\PP%T48wdT p\'T 4wrT 'g \R 4hY3\)T4T'd \)T4## \\3dp\R4ThRp?ii;i \)T4T'd \)T4ii;i)zCSynthesize *text* with the configured sync provider and return PCM.rr)rSN)r output_pathrr[r\r<rrrzTTS audio decoded to silence)rrrimkstempr(closerr!rr TypeErrorrfrrrBrrgetsizeabspath_audio_file_to_pcmr+) rrfdtmp_pathextrarawrGrrNwrittenrrs & r#rrs2##62LBHHRL E#!tB @)3C)=)=djjo3G'4(( I0F0F8B7D8Q8QSW-334WYFvBB)BC C++k*66h'3''rww~~g/F/F"''//ZaJbfgJg34 4 77??7 #rwwx'@ @E&w/ => >y!  E " !:& @56C ? @ !  E " sN H.G91,H2HH(H=HBH9H HHH!H?c0V^8dQhR\R\/#rrrr)r"s"r#r$r$s$$S$U$r%c4\VR4;_uu_4pVP^ 4pRRR4\X4^ 8d>VPR4'd'VR,R8Xd\ V4wr4V'dW43#\ V4# +'giLh;i)zNDecode *path* to int16 mono PCM. WAV via the stdlib; anything else via ffmpeg.rNsRIFF: NsWAVE)rrrgra_wav_s16le_mono_ffmpeg_s16le_mono)rrheadrrs& r#rrsr dD  Rwwr{  4yB4??733T g8M#D)  9  d ##  s B B c0V^8dQhR\R\/#rr)r"s"r#r$r$s  # % r%c^RIpVPVR4;_uu_4pVP4^8wg+VP4^8wgVP 4^8:d RuuRRR4#VP VP 44\VP 443uuRRR4# +'giR#;i TP\\3dRu#i;i)rNr)r%r) waver getsampwidth getnchannels getframerate readframes getnframesintreEOFErrorr*)rr(wfs& r#r#r#s YYtT " "b A%):a)?2??CTXYCY# "==13r7H3II# " " " JJ' * s;CAB.! C,7B.# C. B? 9C?CC#"C#c0V^8dQhR\R\/#rr)r"s"r#r$r$s  S U r%cb^RIp^RIHpVPR4pV'g \ R4hV!VRVRRRR R R R R R. ^p\ PRSSPT4RRR R R \T4/pRp?LdRp?ii;i5i)uiDesktop voice-input sessions as STT warm-up / release signals. ``active: true`` registers a lease and pre-loads the configured local STT model (first-use download + load) so the transcription request doesn't pay the cold cost inside its timeout; ``active: false`` drops the lease. The model stays resident after the last release — it is shared with the gateway/CLI surfaces in this process, and ``stt.local.unload_after_idle_seconds`` still governs eviction. Blocking work runs off the event loop. Warm-up failures are reported in the body, never as an HTTP error — recording must start even when preload fails. r<rKrrLc<^RIHpHpSP'd'\ S4;_uu_4V!S4uuRRR4#V!S4# +'giL;i)r)acquire_stt_leaserelease_stt_leaseN)tools.stt_leaserCrDrr)rCrDrrGr.s r#rstt_lease.._applys>H >>>&w//(/0/ ''0/s A  A NzSTT lease %s (%s) failed: %srrr\r]Trrrrsff @r# stt_leaserGs]] b ' ' )E 4GHH(H((00 $'.. KF KK 1  H 3UGNNCPD(GWc#hGHrz/api/audio/transcribe-streamc(V^8dQhR\RR/#rwsrNr )r"s"r#r$r$sII9IIr%c  aa a a "\S4'gSPRR7GRjxL R#\S4'gSPRR7GRjxL R#SP4GRjxL SPP R4;'gRP 4;'gRo \P!4o \P!4o V V V 3RlpRp\P!\4;_uu_4S PRV4GRjxL pRRR4Vfc\P!\4;_uu_4SPRR R R /4GRjxL SP4GRjxL RRR4R#V V3R lp\P!V!44pR p\ P"!SP%4GRjxL 4p\'VP R4;'g^4pRTu;8:dR8:gM\)RV 24hVP+V4SP-4GRjxL pVP R4R8XdMVP R4'dVP/VR,4KaVP R4'gKz\ P"!VR,4P R4'gKRpV'g#VP94VP94R#S PRVP:4GRjxL p \P<!^4GRjxL VP94\P!\4;_uu_4V P R4'dASPRRRV P RR4RV P RR4/4GRjxL M6SPRR R V P R 4;'gR/4GRjxL SP4GRjxL RRR4R#EL ELELEL +'giEL';iELEL +'giR#;iELEL( \0\(\23d"p \4P7RT 4Rp ? ELRp ? ii;iELELdLLL +'giR#;i5i)uULive STT for Desktop dictation: mic PCM in while the user speaks, partial + final text out. Protocol: client → ``{"sample_rate": N}`` first (8000-48000), then binary s16le mono PCM frames, ``{"eos": true}`` when the recording ends (disconnect = cancel) server → ``{"type": "partial", "text": ...}`` as speech is recognized, ``{"type": "final", "transcript": ..., "provider": ...}``, ``{"type": "error", "message": ...}`` — also when no live STT is available, so the client falls back to ``POST /api/audio/transcribe`` with its recorded blob. 1rN3r.r<c<^RIHp\S4;_uu_4V!VV3RlR7uuRRR4# +'giR#;i)r)open_streaming_sessionc<<SPSPV4#r')call_soon_threadsafe put_nowait)rlooppartialss&r#rY5transcribe_stream_ws.._open..s$B[B[\d\o\oquBvr%) on_partialN)tools.transcription_streamingrQr)rQrUrVr.s r#_open#transcribe_stream_ws.._opens)H "7 + +)5vw, + + +s 4 A typer\messagez'no live STT for the configured providerc<"SPRRRSP4GRjxL /4GRjxL K6LL5i)Tr\partialrN) send_jsonrB)rVrJsr#_forward_partials/transcribe_stream_ws.._forward_partials*s3,, 6;OPQ Q Q;O Qs#>: ><>>Fri@izunsupported sample_rate Tzwebsocket.disconnectrreosz(transcribe-stream client ended early: %sr[finalr^r_ztranscription failed)rrraccept query_paramsrBr?r6get_running_loopQueue contextlibsuppressrrun_in_executorr` ensure_futurerr receive_textr.rfset_input_ratereceive push_audior rrdebugcancelfinalizesleep)rJrZsessionra forwarderendedfirstrr]rrsrUrVr.sf @@@r#transcribe_stream_wsrys r??hhDh!!! !" % %hhDh!!! ))+""9-33::<DDG  # # %D%mmoHx G   Y ' ',,T599 (   + +,,? ?t$JJL(G{{6"&<<{{7##""77#34V$$GFO)D)H)H)O)O ''g.>.>? ?F --     Y ' ' ::i ,,vzz,XZ?[ *FJJz2,F HI I I,,FJJw._resolveusWB\\ "7 + +"$C1#6H*=+=sCC,c!! , +s A A! z'speak-stream provider resolution failedFc<"S'dR#RoSPRRRSPRSP/4GRjxL R#L5i)NTr\startrr )r`rr ) start_sentrrJsr# _send_start$speak_stream_ws.._send_startsC   ll WmX-A-A:xO`O` a   s;AAAcv<\S4;_uu_4S!4RRR4R# +'giR#;ir'r2) _synthesizer.sr#_produce!speak_stream_ws.._produces$#7 + + M, + + +s' 8 c< aa a ^RIHp^RIHpVP S 4oRo ^o VV V VV3RlpV!4FpV!V4pV'gK\ VS 4FppSP V4FXpSP4'd"SPS PR4R#RoSPS PV4KZ Kr K SPS PR4R# \d#p\PRT4RoRp?LFRp?ii;i SPS PR4i;i)r)SentenceChunker)_strip_markdown_for_ttsg?c3,<"^pSP4'gOSPSR7p^pTfSP4RjxL R#SPT4RjxL KdR# \PdT^, pSPP 4pT'd#RSP9dRSP9dKTP R4'gTS8dSP4RjxL EKi;iLL5i)rrzN).!?u…:) is_setrBqueueEmptybufr?endswithflushfeed) idle_pollsdeltabufferedchunkeridle_poll_secondsidle_polls_before_force_flushstoptext_qs r# _sentences8speak_stream_ws.._synthesize.._sentencessJkkmm "JJ/@JAE =&}}.."<<...${{!OJ&{{002H#GKK(?JV]VaVaDa (()DEEWtIt#*==?22/.scDA,DD D#D$D,?D ,"D D1D DD D D  DDNTz!speak-stream synthesis failed: %s) rrtools.tts_text_normalizer from_configrrrrSrTrrr)rrrsentencecleanedpiecechunkrrrrrrchunksrUproduced_audiorrsynthesis_failedrs @@@r#r$speak_stream_ws.._synthesizes7D!--c2 ()% / /& ?&L1(;9'3GE!)!7;;=="  % %f&7&7 > *.11&2C2CUK "8H )  % %f&7&7 >  $ LLs0AC/'*C// D:DDDDD=T)targetdaemonc<"\P!SP4GRjxL 4pVPR4'd"SP \ VR,44VPR4'dM,VPR4'gKSP R4KSP4SP R4R#L \ dL2i;i5i)TNrrdone)rrrmrBputr!rset)framerrrJs r# _pump_client%speak_stream_ws.._pump_clients  ):#:;99V$$JJs5=1299V$$99V$$JJt$   4$;   sPC$$CCC 7CC$CC.#C$C C!C$ C!!C$r\rend)rrrrerfrBr?r6rgr7rrrr threadingEventrrhThreadrrl send_bytesrr`r rrrrrrirj)rJrrrrpumprrrrrrUrr.rrrrrsf @@@@@@@@@@@@r#speak_stream_wsrQs* r??hhDh!!! !" % %hhDh!!! ))+ ""9-33::<DDG  # # %D")#*#4#4X#>>#s,- J  ?? DN++-F#MMOF2?2?hHT288:"   0D **,&E}-  --& & &{{}} llFJ#7888!m##llFE?333   4   + +((*  , +w " "&? ) @A!1b#s)^' & 9#3  .    , + +   4   + +((*  , + + +s'O$K!,O$#K$$O$=K'>%O$$O$<O$K-4K*5K-=B9O$7L* L L*L L*8L!9L*L*L*%L*;L$<L*M L* L& L*&L('L*+AO$>MMM O$$O$'O$*K--'LO$LO$L*L*!L*$L*&L*(L**L>;M=L>>MM M  O$AO!+O ?O O  O! O O!!O$cbV^8dQh/^\9d\\\3,;R&#)rrA)__conditional_annotations__rr!)r"s"r#r$r$s,RS#XSr%ir')Hrr rbrdriloggingrrirr6rr( urllib.parserurllib.requestfastapirhermes_cli.web_routers._commonrhermes_cli.web_depsrhermes_cli.web_server_chatrrhermes_cli.web_server_gatewayrrr r r hermes_cli.web_modelsr r rrrtypingrrr getLoggerrrouterrrrrArhrr+r8rDpostrurBrrrrrrrrrrr#r$rG websocketryrr$)rs@r#rs~   7$JeAA'&01 46VW $%D E  / 0w V[RXv{FKQW&, W]' *#3 L&+w V[ \  ,";  $%;&;| %&"'"8 *+"," ,-".",8 *+G1,G1T  5!5p #$"L%"LJ*#>$  & #$L%LB01I2IX+,q-qr%