epj'jUdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlmZmZddlmZmZddlmZddlmZmZmZmZmZddlm Z m!Z!ddl"m#Z#dd l$m%Z%ej&e'Z(dd Z)d e*d e*d e*fdZ+ddl,m-Z-ddl.m/Z/m0Z0m1Z1m2Z2ddl3m4Z4dZ5dZ6dee*efd ee*effdZ7dZ8dZ9dZ:dZ;dZdZ?dZ@dZAd ZBeCd hZDd!ZEd"ZFd#ZGd$ZHd%ZId&ZJd'ZKd(ZLd)ZMd*ZNd+ZOd,ZPd-ZQd.ZRd/ZSd0ZTd1ZUd2ZVd3ZWd4ZXdZYd0ZZd5Z[d6Z\d7Z]d0Z^d8Z_d9Z`d.Zad:Zbd;ZcdZfefZgd?d@dAdBdCdDdBdEdEd?dF Zhee*eifejdG<d?d?dBdBdBdBdHdIdJZkee*eifejdK<ddLed9eld elfdMZmdNed elfdOZndNed dfdPZoddQdNedRe*dSeeid epfdTZqddQdNedRe*dSeeid ee*effdUZrddQdNedVe*dRe*dSeeid df dWZsdCZtetZu ddXee*dYeee*efd eifdZZvd ee*effd[ZwdYee*efd e*fd\Zxed]^Gd_d`ZydYee*efd eyfdaZzeChdbZ{dcZ|ddZ}eChdeZ~d?ZeChdfZdYee*efdge*d ee*effdhZdYee*efdge*d ee*effdiZdjee*efd elfdkZdXe*dYee*efd eee*effdlZdme*dVe*dXe*dYee*efd ee*f dnZdXe*d elfdoZdYee*effdpZdjee*efd efdqZ ddjee*efdVee*d e*fdrZdjee*efd elfdsZdte*dueid ee*fdvZdLe*dwee*d e*fdxZdte*dyee*e*fd e*fdzZd{e jd dfd|Zdjee*efd efd}Z dd~e*dedeed e jfdZdedjee*efd efdZdme*dVe*de*djee*efdYee*efd e*f dZddYeee*efd elfdZd elfdZde*d ee*fdZde*de*d ee*fdZde*d e*fdZde*d e*fdZdme*dVe*dYee*efd e*fdZdme*dVe*dYee*efd e*fdZdVe*d e*fdZddddddddme*dVe*dYee*efdee*dee*dee*dee*deedee*d e*fdZdme*dVe*dYee*efd e*fdZdZdZe jddezdzdezdze jZe jde jZddLed9eld elfdZdme*d e*fdZdme*dVe*dYee*efd e*fdZdme*dVe*dYee*efd e*fdZdme*dVe*dYee*efd e*fdZeaebecfdepdeideideid epf dZdee*efd eefdZdee*efd e*fdZde*d elfdZdee*efde*d elfdZde*d e*fdZdNed e*fdZddme*de*d e*fdZ ddme*dee*efdee*d e*fdZdme*dVe*dYee*efd e*fdZd elfdZd elfdZd e*fdZd e*fdZdme*dVe*dYee*efd e*fdZdZdee*efde*degefd efdĄZiZee*efejd<d elfdƄZd efdDŽZde*ded e*fdɄZdme*dVe*dYee*efd e*fdʄZiZee*efejd<dme*dVe*dYee*efd e*fd̄Z ddme*dVee*deedee*dXee*d e*f d̈́Zd elfd΄Zd ee*e*elffdτZd elfdЄZe jdѦZe jdҦZe jdӦZe jdԦZe jdզZe jd֦Ze jde jZe jde jZe jd٦Ze jdڦZe jdۦZe jde jZdme*d e*fd݄ZGdބdߦZ ddejdejdejdeee*gdfdXee*f dZe'dkr^ededdZededee5drdndedee6drdndede+ddrdndedee8drdndede2rdndewZ ezeZdejdejdZn#e$rZdedZYdZ[ndZ[wwxYwedeederdndeސderdndeސdegexeZeސdeddlmZmZdddd d d d d e%d d ddd d dd d dd ddmgddZejddedeȐddS(a Text-to-Speech Tool Module Built-in TTS providers: - Edge TTS (default, free, no API key): Microsoft Edge neural voices - ElevenLabs (premium): High-quality voices, needs ELEVENLABS_API_KEY - OpenAI TTS: Good quality, needs OPENAI_API_KEY - MiniMax TTS: High-quality with voice cloning, needs the selected region's key - Mistral (Voxtral TTS): Multilingual, native Opus, needs MISTRAL_API_KEY - Google Gemini TTS: Controllable, 30 prebuilt voices, needs GEMINI_API_KEY - xAI TTS: Grok voices, uses xAI Grok OAuth credentials or XAI_API_KEY - NeuTTS (local, free, no API key): On-device TTS via neutts - KittenTTS (local, free, no API key): On-device 25MB model - Piper (local, free, no API key): OHF-Voice/piper1-gpl neural VITS, 44 languages Custom command providers: - Users can declare any number of named providers with ``type: command`` under ``tts.providers.`` in ``~/.hermes/config.yaml``. Hermes writes the input text to a temp file and runs the configured shell command, which must produce the audio file at the expected path. See the Local Command section of ``website/docs/user-guide/features/tts.md``. Output formats: - Opus (.ogg) for Telegram voice bubbles (requires ffmpeg for Edge TTS) - MP3 (.mp3) for everything else (CLI, Discord, WhatsApp) Configuration is loaded from ~/.hermes/config.yaml under the 'tts:' key. The user chooses the provider and voice; the model just sends text. Usage: from tools.tts_tool import text_to_speech_tool, check_tts_requirements result = text_to_speech_tool(text="Hello world") N)FutureThreadPoolExecutor) dataclassfield)Path)CallableDictAnyIteratorOptional)urljoinurlparse)windows_hide_flags)display_hermes_homec~ ddlm}n%#t$rtj||cYSwxYw||}||n|S)aRead env values through the live config module. Tests may monkeypatch and later restore ``hermes_cli.config.get_env_value`` before this module is imported. Resolve the helper at call time so TTS does not keep a stale imported function for the rest of the test process. r) get_env_value)hermes_cli.configr ImportErrorosgetenv)namedefault_get_env_valuevalues 4/home/thesage/.hermes/hermes-agent/tools/tts_tool.pyrr?sl(EEEEEEE (((yw'''''( N4 Em77.s  ++env_var provider_idreturnc ddlm}n@#t$r3tt |pdcYSwxYw|||tS)u}Resolve a TTS provider API key via the shared voice-key resolver. Delegates to ``tools.tool_backend_helpers.resolve_provider_secret`` — the single owner of STT/TTS key resolution (config > env/.env > the credential pool populated by ``hermes auth add ``). Resolved at call time so tests that reload the helpers module see the live function. r)resolve_provider_secret) env_getter)tools.tool_backend_helpersr rstrrstrip)rrr s r_resolve_provider_keyr&Ns|9FFFFFFF 999=))/R0066888889 " "7KM R R RRs :AA)resolve_managed_tool_gateway)managed_nous_tools_enabled%nous_tool_gateway_unavailable_messageprefers_gatewayresolve_openai_audio_api_key)hermes_xai_user_agentcn ddlm}|ddn#t$rYnt$rYnwxYwddl}|S)z?Lazy import edge_tts. Returns the module or raises ImportError.rensureztts.edgeFpromptN)tools.lazy_depsr/r Exceptionedge_tts) _lazy_ensurer4s r_import_edge_ttsr6ksv :::::: Z.....           OOO O . ..cv ddlm}m}|ddn#t$rYnt$rYnwxYwddlm}|S)aLazy import ElevenLabs client. Returns the class or raises ImportError. Calls :func:`tools.lazy_deps.ensure` first so the SDK gets installed on demand if the user picked ElevenLabs as their TTS provider but never ran the post-setup hook (e.g. enabled it by editing config.yaml directly). Raises ``ImportError`` on lazy-install failure so existing callers' error-handling paths keep working. r)FeatureUnavailabler/ztts.elevenlabsFr0) ElevenLabs)r2r9r/rr3elevenlabs.clientr:)r9r/r:s r_import_elevenlabsr<ws >>>>>>>>.....           ,,,,,, s 0 00 el_configc |dpdd}|siS|dpdd}|stjdd|}ddlm}d ||| iS) arBuild ElevenLabs client kwargs honoring config base_url/wss_url. ``tts.elevenlabs.base_url`` (and optionally ``wss_url``) redirect the SDK to a self-hosted / proxy endpoint via an ``ElevenLabsEnvironment``. When neither is set the SDK default environment is used. ``wss_url`` defaults to the ``base_url`` host with a ``wss://`` scheme when omitted. base_urlr!/wss_urlz^httpwsr)ElevenLabsEnvironment environment)basewss)getrstripresubelevenlabs.environmentrC)r=r?rArCs r_elevenlabs_environment_kwargsrLs j))/R77<1onyestrueenabledT>0noofffalsedisabledF) isinstanceboolintfloatr$r%lower)rr normalizeds r _config_boolr,s%  }%#u&&E{{%[[]]((** > > >4 @ @ @5 NrMresponsect|dd}t|sdSt|}|jdrdSdt |vS)N iter_contentFz requests.T)getattrcallabletype __module__ startswithvars)rr response_types r_response_has_explicit_streamr=sd8^T::L L ! !uNNM**;77t T-00 00rMct|dd}t|r |dS#t$rYdSwxYwdS)Nclose)rrr3)rrs r_close_responserGsa Hgt , ,E  EGGGGG    DD s . <<)limitlabelrc(|tn|}g}d} t|r|t}nt |dt t|dd}t|tr| dd}t|ttfr|fnd }|D]}|st|tr| dd}t|}|t|z }||kr$t|t|d |d ||d|t|S#t|wxYw) z3Read an upstream TTS response with a hard byte cap.Nr) chunk_sizecontentrMutf-8replaceerrorsz response exceeds z bytes)TTS_RESPONSE_BODY_LIMIT_BYTESrrTTS_RESPONSE_BODY_CHUNK_BYTESrrGrrrr$encodebytes bytearraylenr RuntimeErrorappendjoin)rrrchunkstotaliteratorrchunks r_read_tts_response_bytesrPs.3] ) )EF E" ( 2 2 U,,8U,VVHH8nn((GDNNIWZ4[4[\\G'3'' D!...CC%/%9K%L%LTzzRTH ! !E %%% @ WY ??%LLE SZZ Eu}})))"e#L#Lu#L#L#LMMM MM% xx!!!!!!!!s EFFc t|||}|r'tj|dSt |sCt |dd}t |r#|}t|tr|niSiS)Nrrrjson) rrloadsdecoderrrrdict)rrrraw json_readerparseds r_read_tts_response_jsonrss #85 F F FC /z#**W--... ) 2 2>h55 K  > []]F'55=662 = IrM output_pathct|||}t|d5}||ddddS#1swxYwYdS)Nrwb)ropenwrite)rrrr audio_bytesfs r_write_tts_response_to_filers+85NNNK k4 A  sAA  A provider tts_configcl|stS|}|pi}t||t r||ni}|r|dnd}t|t rd}t|tr|dkr|S|dkr[|pidpt}tt|}|r|S|tvr t|S|tvrot||}t|rP|d} t| t rd} t| tr| dkr| StStS)aReturn the input-character cap for *provider*. Resolution order: 1. ``tts..max_text_length`` (user override in config.yaml) 2. ``tts.providers..max_text_length`` for user-declared command providers 3. ElevenLabs model-aware table (keyed on configured ``model_id``) 4. ``PROVIDER_MAX_TEXT_LENGTH`` default 5. ``DEFAULT_COMMAND_TTS_MAX_TEXT_LENGTH`` when the provider is a command-type user provider without an explicit cap 6. ``FALLBACK_MAX_TEXT_LENGTH`` (4000) Non-positive or non-integer overrides fall through to the default so a broken config can't accidentally disable truncation entirely. max_text_lengthNrrmodel_id)FALLBACK_MAX_TEXT_LENGTHrr%rrGrrrDEFAULT_ELEVENLABS_MODEL_IDrr$rBUILTIN_TTS_PROVIDERS_get_named_provider_config_is_command_provider_config#DEFAULT_COMMAND_TTS_MAX_TEXT_LENGTH) rrkeycfgprov_cfgoverridermappednamednamed_overrides r_resolve_max_text_lengthrs& ('' ..   " "C  C *#''#,,==Eswws|||2H2:Dx||-...H(D!!(C  X\\ lN'' 33R7R155c(mm6I6I6K6KLL  M &&&',, '''*344 &u - - 7"YY'899N.$// &!%.#.. &>A3E3E%%6 6 ##rMc  ddlm}|}|dpiS#t$rtdicYSt $r)}td|dicYd}~Sd}~wwxYw) z Load TTS configuration from ~/.hermes/config.yaml. Returns a dict with provider settings. Falls back to defaults for any missing fields. r) load_configttsz9hermes_cli.config not available, using default TTS configzFailed to load TTS config: %sTexc_infoN)rrrGrloggerdebugr3warning)rconfiges r_load_tts_configrs 111111zz%  &B&  PQQQ 6DIII s!&)&B BA>8B>Bc|dptS)a'Get the explicitly configured TTS provider or the free default. Inference credentials do not imply consent to paid speech generation. Users opt into cloud TTS by setting ``tts.provider`` (normally through ``hermes tools``); otherwise the historical Edge backend remains active. r)rGDEFAULT_PROVIDERrr%)rs r _get_providerrs4 NN: & & :*: A A C C I I K KKrMT)frozencTeZdZUdZeed<eed<eed<edZeed<dS) _MiniMaxTTSRuntimezA region-bound MiniMax endpoint and credential. The credential is excluded from ``repr`` so diagnostics cannot expose it accidentally. regionendpointcredential_sourceF)reprapi_keyN)__name__r __qualname____doc__r$__annotations__rrrrMrrrsY KKKMMM5e$$$GS$$$$$rMrc|di}t|tsi}dtt ddpdfdtt ddpdfd}t td}t|dpd}|r||vrtd|r|}n$|dd rd}n|d d rd }nd}||\}}|st|d |t|d p||}t|j pd} td dhtdhd} |dkrd nd} | | | vrtd| d|t||||S)aSelect MiniMax TTS region, endpoint, and credential atomically. An explicit ``tts.minimax.region`` wins. Without one, the legacy global credential wins when present; a China credential is selected only when it is the sole configured MiniMax credential. rMINIMAX_API_KEYr!MINIMAX_CN_API_KEY)globalcnrz+tts.minimax.region must be 'global' or 'cn'rrtrz not set for MiniMax TTS region r?zapi.minimax.iozapi.minimax.chatzapi.minimaxi.comz#tts.minimax.base_url points to the z MiniMax endpoint but region is )rrrr)rGrrr$r&r%DEFAULT_MINIMAX_BASE_URLDEFAULT_MINIMAX_CN_BASE_URLr ValueErrorrhostname frozensetr) r mm_config credentials endpointsconfigured_regionrrrr endpoint_hostofficial_region_hosts other_regions r_resolve_minimax_tts_runtimersy"--I i & &   %&7CCIr J J P P R R ! %&:IFFL" M M S S U U  K+)I IMM(339r::@@BBHHJJH.i??FGGG" X q ! T 1 !,V!4w   L L& L L   9==,,A &0ABBHHJJHh''06B==??M-/ABCC+,--"X--448L-l;;; (, ( (# ( (   +    rM> r~rercrrrPrr deepinfrar^rxmp3>aacamrm4aroggwavflacopus>feishumatrixsignaltelegramwhatsapprct|tsiS||}t|tr|niS)zBReturn a provider config block if it's a dict, else an empty dict.)rrrG)rrsections r_get_provider_sectionr&sC j$ ' ' nnT""G $// 777R7rMc t|d}t|tr||nd}t|tr|S|t vrt||}|r|SiS)aReturn the config dict for a user-declared provider. Looks up ``tts.providers.`` first (the canonical location), and falls back to ``tts.`` so users who followed the built-in layout still work. Returns an empty dict when the provider is not declared. providersN)r&rrrGrr)rrr(r%legacys rrrs&j+>>I%/ 4%@%@JimmD!!!dG'4   zz||000&z488  M IrMrcjt|tsdSt|dpd}|r|dkrdS|d}t|to t |S)z;Return True when *config* declares a command-type provider.Frr!command)rrr$rGr%rr)rptyper+s rrrs fd # #u  6""(b ) ) / / 1 1 7 7 9 9E )##ujj##G gs # # =W]]__(=(==rMc|sdS|}|tvrdSt||}t |r|SdS)zReturn the provider config if *provider* resolves to a command type. Built-in provider names are rejected (they have native handlers). Returns None when the name is a built-in, unknown, or not a command type. N)rr%rrr)rrrrs r _resolve_command_provider_configr.sf t ..   " "C ###t ' C 8 8F"6** 4rMtextc |sdS|}|tvrdStt ||rdS ddlm}ddlm}|||}||d||}n3#t$r&}t d|Yd}~dSd}~wwxYw|dSt|tr|dnd} t|tr|d nd} t|tr|d nd} t|tr|d tnt} td ||||t| t$r| r| ndt| t$r| r| ndt| t&t(frt)| nd| r!t%| nd } t| t$r| r| n|S)u Route the call to a plugin-registered TTS provider, or return None. Returns the path to the written audio file on dispatch, or ``None`` to fall through to the next resolution layer (built-in dispatch or Edge TTS default). Resolution invariants enforced here (matches issue #30398): 1. Built-in provider names short-circuit — never reach the plugin registry. The caller is responsible for the elif chain that handles ``edge``/``openai``/etc.; this function explicitly rejects those names defensively. 2. Command-type providers declared under ``tts.providers.: type: command`` (PR #17843) win over a plugin with the same name. The caller passes us only when its own command-provider check returned None — we re-verify here so a refactor of the caller can't silently break the invariant. 3. Plugin dispatch fires only when ``provider`` matches a registered :class:`TTSProvider` whose ``name`` equals the configured value. Unknown names return None (caller falls through to Edge default). Plugin exceptions are caught and re-raised — the outer ``text_to_speech_tool`` try/except converts them to the standard error envelope, matching how command-provider failures surface. Nr get_provider_ensure_plugins_discoveredT)forcez2tts plugin dispatch skipped (discovery failed): %svoicemodelspeed output_formatz2Generating speech with plugin TTS provider '%s'...r)r6r7r8format)rr%rrragent.tts_registryr2hermes_cli.pluginsr4r3rrrrrG!DEFAULT_COMMAND_TTS_OUTPUT_FORMATinfo synthesizer$rr)r/rrrrr2r4plugin_providerexcr6r7r8fmtwrittens r_dispatch_to_plugin_providerrDs> t ..   " "C ###t##=j##N#NOOt333333AAAAAA""$$$&,s++  " ' &T 2 2 2 2*l3//O  I3OOOtttttt (2*d'C'C MJNN7 # # #E'1*d'C'C MJNN7 # # #E'1*d'C'C MJNN7 # # #E j$ ' ' / (IJJJ .  KK>Io2,,..  c dC  TZZ\\9N%N%N*3// Ci  rMc|d|dt} t|}n+#ttf$rttcYSwxYw|dkrttS|S)z5Return timeout in seconds, falling back when invalid.timeouttimeout_secondsr)rG#DEFAULT_COMMAND_TTS_TIMEOUT_SECONDSr TypeErrorr )rrrs r_get_command_tts_timeoutrPEs **Y +<>a b b c cC:c  z ":::899999: zz8999 LsA%A)(A)c|rVt|jd}|t vr|S|dp|dpt}t|d}|t vr|ntS)z6Return the validated output format (mp3/wav/ogg/flac)..r:r9) rsuffixrr%lstripCOMMAND_TTS_OUTPUT_FORMATSrGr=r$)rrrSrrBs r_get_command_tts_output_formatrVQs k"")//117799@@EE / / /M 8 - ::o & & - , c((..   " " ) )# . .C333339ZZrMc|dd}t|tr(|dvSt |S)zEReturn True only when the user explicitly opted in to voice delivery.rFF>rrrr)rGrr$r%rr)rrs r _is_command_tts_voice_compatiblerXcsU JJ)5 1 1E%C{{}}""$$(BBB ;;rMcommand_templatepositioncd}d}d}||kr\||}|dkr |dkrd}n:|dkr|rd}n/|dkrd}n&|dkrd}n|dkrd}n|dkrd}n |dkr|dz }|dz }||k\|S) zReturn the shell quote character active right before *position*. Returns ``"'"`` / ``'"'`` when inside a single- / double-quoted region of the template, ``None`` for bare context. NFr'"\Trtr)rYrZquoteescapedichars r_shell_quote_contextrcks  EG A h,," C<<s{{ c\\  S[[EE S[[EE T\\ FA Q% h,,& LrM quote_contextc\|dkr|ddS|dkrR|ddddddd d Stjd krtj|gSt j|S) zGQuote a placeholder value for its position in a shell command template.r\z'\''r]r^z\\z\"$z\$`z\`nt)rrr subprocess list2cmdlineshlexr_)rrds r_quote_command_tts_placeholderrls}}S'***  WT6 " " WS% WS% WS%   w$&w/// ;u  rM placeholderscddD}tjd|d|d}gdtjtdtffd }||}|d d d d }D]\}}|||}|S) z@Replace supported placeholders while preserving ``{{`` / ``}}``.|c3>K|]}tj|VdSN)rIescape).0rs r z/_render_command_tts_template..s*>>RYt__>>>>>>rMz(?z)\}\}|\{(?Pz)\})matchrc |dp|d}dtd}|t|t |f|S)Ndoublesingle__HERMES_TTS_PLACEHOLDER___)grouprrrlrcstart)rurtokenrYrm replacementss r replace_matchz3_render_command_tts_template..replace_matchs{{8$$= H(=(=AC ,=,=AAA  *T"$%5u{{}}EE       rMz{{{z}}})rrIcompileMatchr$rJr) rYrmnamespatternrrenderedr}rr~s `` @r_render_command_tts_templaters HH>>>>> > >EjPuPPEPPPG+-L RXc] s        {{=*:;;Hc**224==H$22 u##E511 OrMprocc |dStjdkrv tjddddt |jgtjtjdtjn$#t$r| YnwxYwdSd dl } | |j}| d D]'} | #|j$rY$wxYw| n0#|j$rYdSt$r| YnwxYw |d dS#tj$rYnwxYw | |j}| d D]'} | #|j$rY$wxYw| dS#|j$rYdSt$r| YdSwxYw)zCBest-effort termination of a shell process and all of its children.Nrhtaskkillz/Fz/Tz/PID)stdoutstderrrLstdinrT) recursiverurL)pollrrrirunr$pidDEVNULLr3killpsutilProcesschildren terminate NoSuchProcesswaitTimeoutExpired)rrparentchilds r#_terminate_command_tts_process_treers yy{{ w$  NT4TX?!)!) (          IIKKKKK MMM ))__t_44  E !!!!'          !   $      ))__t_44  E  '        sAA77BB"2DC*)D* C74D6C77D D<D<;D<EE*)E*.2G!F65G6 GGGG H )H  H c|d}t|ttfsgSd|DS)aReturn the provider's ``env_passthrough`` allowlist (opt-out of scrub). Command providers legitimately reference their own API keys in the shell template (curl one-liners). The child env is scrubbed of Hermes secrets by default; ``env_passthrough: [MY_API_KEY, ...]`` copies the named variables back from the parent environment so a trusted template keeps working. env_passthroughcg|]D}t|#t|ESr)r$r%)rsitems r z5_command_provider_env_passthrough..s= C C C$T1B1B CCIIOO   C C CrM)rGrlisttuple)rrs r!_command_provider_env_passthroughrsE **& ' 'C cD%= ) ) C C# C C CCrMr+rLrc ddlm}ddlm}|d}|pgD](}tj|}||||<)dtjtjddd ||d }tj d krttd d|d <nd|d<tj |fi|dtj i} tjggd} ddh} dtdt ddffd } t#j| d| jfdt#j| d| jfdg} | D]}|t-j|z}d}| r|t-jz }|dkrd}n t1d|\}}n#tj$rY[wxYw|| |w| ||t-j|z}| |sQ | t;d|t-jz n#tj$rd}YnwxYw|rt?| | D]}| d !\}}n#tj$rYn"wxYw|r| ||Ld | d}d | d} tj||#tj$r}tj|||||d}~wwxYwd | d}d | d}| j"rtj#| j"|||tj$|| j"||S)zRun a command-provider shell command with process-tree idle cleanup. Child env is scrubbed of Hermes secrets (salvage of #56332) while still propagating delegated-child lineage markers when applicable. r)delegated_child_subprocess_env)hermes_subprocess_envF)inherit_credentialsNTrr)shellrrr/encodingrenvrhCREATE_NEW_PROCESS_GROUP creationflagsstart_new_sessionr)rrrrrstreamrct|ddpd}tt|dddd} ||d}n"|d}||d}|sn||fU |dfdS#|dfwxYw) Nrrbufferread1Trvrr)rreadrput)rrrrrdata output_queues r read_streamz%_run_command_tts..read_stream"s6:t44?$77$GG + 0="KK..EE 5<>>>>>$$???H$""" s##  !HSM//--h77 $ $L w$(/ >I  &**3tY3G3G*HHKD%%{    H  =   & & & t E""">##g-  .   IIc#x$.2B2B'BCCI D D D D(   III +D111 % %F KKK $ $ $ $ + *5577 ee;     +t ##E***  +)**)** +GW== =(   +     WWVH% & &F WWVH% & &F  + O       &w P PPsN>'F&&F87F8 8IIIJJ10J1 LM -MM pathcPt|}|d|S)zKReturn an output path whose extension matches the provider's output_format.rR)rV with_suffix)rrrBs r#_configured_command_tts_output_pathr|s) ( 0 0C   III & &&rM provider_namec t|dpd}|std|dt |}|jdd|r| t|}t|t|}|d|dd} tj 5} t | dz } | |d t| t| t||t|d dt|d dt| d } t|| } t!| |t#|n#t$j$r}t)d|d|dd|d}~wt$j$r}g}|jr/|d|j|jr/|d|jd|pd}t)d|d|jd||d}~wwxYw dddn #1swxYwY|r|jdkrt)d|d|t|S)a Generate speech by running a user-configured shell command. Returns the absolute path of the audio file the command wrote. Raises ``ValueError`` when the provider config is invalid, and ``RuntimeError`` for timeouts / non-zero exits / empty output. r+r!ztts.providers.z.command is not configuredTparentsexist_okr8z input.txtrrr6r7) input_path text_pathrr:r6r7r8)rzTTS provider 'z' timed out after gsNzstderr: zstdout: z; zno command outputz' exited with code z: rz' produced no output at )r$rGr%r r expanduserrmkdirexistsunlinkrPrVtempfileTemporaryDirectory write_textrrrrirrrrrrrrstatst_size)r/rrrrrYrrLr9r8tmpdirrrmr+rA detail_partsdetails r_generate_command_ttsrs6::i006B77==??   F] F F F   +   ) ) + +F Mt444 }} &v..G263v;;GGM JJw w ; ; < ..%+..   !###############J ==?? fkkmm3q88 L] L LF L L    v;;sDB:K&G54K&5KHK.B#KKK&&K*-K*cT|t}t|D]\}}dSdS)z=Return True when any command-type TTS provider is configured.NTF)rrJ)r_name_cfgs r_has_any_command_tts_providerrs:%'' .z:: ttt 5rMc.tjdduS)z+Check if ffmpeg is available on the system.ffmpegN)shutilwhichrrMr _has_ffmpegrs < ! ! --rMmp3_pathctsdS|ddddz}t||S)z Convert an audio file (MP3/WAV/anything ffmpeg reads) to OGG Opus format for Telegram voice bubbles. Args: mp3_path: Path to the input audio file. Returns: Path to the .ogg file, or None if conversion fails. NrRrtr.ogg)rrsplit_ffmpeg_transcode_to_opus)rogg_paths r_convert_to_opusrsB ==tsA&&q)F2H $Xx 8 88rMrrctsdStj|tj|k}|r|dzn|} t jdd|ddddd d d d d ddddd|dgddtjt}|jdkrt d|j|j dddd |rGtj |r* tj|dS#t$rYdSwxYwdSdStj |rtj|dkra|rtj||||rEtj |r' tj|S#t$rYSwxYwSSn#tj$rt dYnXt&$rt dYn3t($r'}t d|d Yd}~nd}~wwxYw|rEtj |r& tj|n^#t$rYnRwxYwnM#|rEtj |r' tj|w#t$rYwwxYwwwxYwdS)!zTranscode *input_path* to real Ogg/Opus at *ogg_path* via ffmpeg. Safe when ``input_path == ogg_path`` (writes to a temp file, then replaces). Returns the output path on success, None on failure. Nz.tmp.oggr-i-acodeclibopus-acr-b:a48k-vbrr -applicationvoip-compression_level10z-fr-yTcapture_outputrLrrrz0ffmpeg conversion failed with return code %d: %srignorerz)ffmpeg OGG conversion timed out after 30szffmpeg not found in PATHz ffmpeg OGG conversion failed: %sr)rrrabspathrirrrrrrrrrremoveOSErrorgetsizerrFileNotFoundErrorr3)rrin_place work_pathresultrs rrrs ==twz**bgooh.G.GGH)1?:%%xI tZI C V%94u   $,..      ! ! NNM +V]-A-A'RZ-A-[-[\`]`\`-a c c c  y11   )$$$$$         7>>) $ $ )C)Ca)G)G 0 9h///  y11   )$$$$        $DDDBCCCCC 333122222 MMM91tLLLLLLLLM  y11   )$$$$      y11   )$$$$       4sBGD$$ D21D29AG5G  GGJ()IJ(#I+J(- I6IJ(IJ(J J$#J$("K2 K K2 K-*K2,K--K2cddlm} t|d5}|d}dddn #1swxYwYn#t$rYdSwxYw||pdS)a Return a container id ('ogg', 'wav', 'mp3', 'flac', ...) or 'unknown'. Delegates to the shared magic-byte sniffer in ``tools.audio_container`` (one module owns container detection for both this outbound repair and the inbound gateway audio cache). r)sniff_containerrb Nunknown)tools.audio_containerr#rrr)rr#fhheads r_sniff_audio_containerr*#s655555 $   772;;D                yy ?4 -I-s.A: A>A>A AAfile_strcf|ds|St|}|dvr|Std||t ||}|r|S|dddz|z} t j||td|||S#t$r|cYSwxYw)aEnsure a path claiming ``.ogg`` actually contains an Ogg container. When the bytes are MP3/WAV/FLAC (a backend ignored the opus request), transcode in place to real Ogg/Opus. On any failure, rename to the sniffed real extension so downstream players/platforms at least get an honest file instead of a 0-second voice bubble. Returns the (possibly updated) path. r)rr&uITTS wrote %s bytes into a .ogg path (%s) — transcoding to real Ogg/OpusNrRubCould not transcode %s to Ogg/Opus — renamed to %s so the file is delivered with its real format) endswithr*rr>rrrrr)r+ containerrepairedhonests r_repair_ogg_containerr24s   V $ $&x00I&&& KKS8)8<    s.2B!! B0/B0c Kt}|dpi}|dt}t|d|dd}d|i}|dkrt |dz dz}|dd|d<|j|fi|} | |d {V|S) z Generate audio using Edge TTS. Args: text: Text to convert. output_path: Where to save the MP3 file. tts_config: TTS config dict. Returns: Path to the saved audio file. rer6r8rqdz+d%rateN)r6rGDEFAULT_EDGE_VOICErround Communicatesave) r/rr _edge_tts edge_configr6r8kwargspct communicates r_generate_edge_ttsr@[s!""I..((.BK OOG%7 8 8E +//':>>'3+G+GHH I IEu F ||US[C'((v')'7777K   ; ' '''''''' rMc&tddpd}|std|dpi}|dt}|dt}|drd}nd }t }|dd |it|} | j |||| } t|d 5} | D]} | |  d d d n #1swxYwY|S)z Generate audio using ElevenLabs. Args: text: Text to convert. output_path: Where to save the audio file. tts_config: TTS config dict. Returns: Path to the saved audio file. ELEVENLABS_API_KEYrr!z=ELEVENLABS_API_KEY not set. Get one at https://elevenlabs.io/voice_idrr opus_48000_64 mp3_44100_128r)r/rCrr9rNr) r&r rGDEFAULT_ELEVENLABS_VOICE_IDrr.r<rLtext_to_speechconvertrr) r/rrrr=rCrr9r:clientaudio_generatorrrs r_generate_elevenlabsrKys{%%9<HHNBG ZXYYY|,,2I}}Z)DEEH}}Z)DEEHF##(' ' #%%J Z U U U+I)+T+T U UF+33 # 4O k4 A$  E GGENNNN  sDD  D c|drdS|drdS|drdSdS)zHPick an OpenAI-compatible TTS response format from the output extension.rr.wavr.flacrr)r.)rs r_tts_response_format_from_pathrOsXF##vF##uG$$v 5rM)rr?r7r6r8 instructionsrr?r7r6r8rPc d} d} |du} |t\}} } t|tr|dndpi} || dt}|| dt }| d} | | p| pt }|Pt|tr|ddnd}t| d|}| d }| r6| s4| s2|tvr)t d |t|t}t|}t}||| } ||||d ttjid }|dkr!t!dt#d||d<|r||d<|rd|i|d<|jjjdi|}|||t-|dd}t/|r |SS#t-|dd}t/|r |wwxYw)uJGenerate audio via the OpenAI ``audio.speech.create`` SDK shape. Optional kwargs let OpenAI-compatible backends (DeepInfra etc.) reuse this function — they resolve credentials/model themselves and pass them through, skipping the OpenAI-only ``_resolve_openai_audio_client_config``. Args: text: Text to convert. output_path: Where to save the audio file. tts_config: TTS config dict (used for ``tts.openai`` sub-block and the global ``speed`` default). api_key: Bearer token. When None, resolved from the OpenAI auth chain (config → env → managed gateway). base_url: API base URL. When None, falls back to ``tts.openai.base_url`` then the OpenAI default. model: Model id. When None, reads ``tts.openai.model``. voice: Voice id. When None, reads ``tts.openai.voice``. speed: Playback speed. When None, reads ``tts.openai.speed`` / ``tts.speed``. instructions: Optional voice-design guidance (tone, emotion, pacing, accent, whispering). Forwarded to `audio.speech.create` when truthy; omitted otherwise so ``tts-1``/``tts-1-hd`` and strict OpenAI-compatible servers that reject unknown kwargs are unaffected. Returns: Path to the saved audio file. NFrPr7r6r?r8rqlanguagezTTS: managed OpenAI audio gateway does not support model %r; falling back to %s. Set VOICE_TOOLS_OPENAI_KEY or OPENAI_API_KEY to use %r directly.)rr?zx-idempotency-key)r7r6inputresponse_format extra_headers?@rP lang_code extra_bodyrr)#_resolve_openai_audio_client_configrrrGDEFAULT_OPENAI_MODELDEFAULT_OPENAI_VOICEDEFAULT_OPENAI_BASE_URLrMANAGED_OPENAI_TTS_MODELSrrrOrRr$uuiduuid4rraudiospeechcreatestream_to_filerr)r/rrrr?r7r6r8rP fallback_base is_managedexplicit_base_url oai_configconfig_base_url speed_defaultrRrTrQrI create_kwargsrrs r_generate_openai_ttsrlsV$(MJ ,-P-R-R* /9T.J.JT*..***PT[Y[J }w(<== }w(<== nnZ00O #NmN7N }8B:t8T8T] w444Z] jnnWm<<==~~j))H  %! %  % 2 2 2 " '    %4[AAO(**L \'H = = =F.13tz||3D3DE ) )  C<<%(s3%?%?M' "  9,8M. )  B+6*AM, '-6<&->> >> ,,,.. E??  EGGGG .. E??  EGGGG s 1B H))-Icztdd}|stdt|tr|dnd}t|tsi}ddlm}m}|d}t|tr| s$|d}|std |d}t||||||||d tt|d |d d  S)uResolve DeepInfra credentials/model, then delegate to the OpenAI handler. DeepInfra's audio endpoint is OpenAI-compatible, so there's no need to duplicate the SDK call — we just pass an explicit api_key / base_url / model / voice through. Model ids and the base URL come from the shared ``hermes_cli.models`` helpers so every DeepInfra surface resolves them identically. DEEPINFRA_API_KEYrzXDEEPINFRA_API_KEY not set. Run `hermes setup` to configure, or set the env var directly.Nr)deepinfra_base_urldeepinfra_model_idsr7rzNo DeepInfra TTS model available. Pin one in config.yaml under tts.deepinfra.model, or check connectivity to api.deepinfra.com so the live catalog can be fetched.r6r8rq)rr?r7r6r8) r&r rrrGhermes_cli.modelsrorpr$r%rlDEFAULT_DEEPINFRA_TTS_VOICEr) r/rrr di_configrorpr7 candidatess r_generate_deepinfra_ttsru0sd$$7EEG   +   0:*d/K/KU {+++QUI i & & IIIIIIII MM' " "E eS ! !((//  H  1   ##I..mmG%@AAIMM':>>'3+G+GHHII    rM)pausez long-pausezhum-tunelaughchucklegigglecrytskz tongue-clickz lip-smackbreathinhaleexhalesigh) softwhisperloudzbuild-intensityzdecrease-intensityz higher-pitchz lower-pitchslowfastz sing-songsingingz laugh-speakemphasisz(\[(?:roz )\]|)flagsu^(.{12,120}?[.!?…])\s+(?=\S)c$t||S)Nr)r)rrs r_xai_bool_configrs w / / //rMc|}|s|S|}tjdd|}tjdd|}t|st d|d}tjdd|}t|r|Sd t}d t}d |zd z|zd z} d dl m }|dd|ddd|dgd}t|}tj d|tj } | r'| d}|p|S#t$r'} t d| |cYd} ~ Sd} ~ wwxYw)aAdd xAI speech tags for more natural voice-mode replies. First applies a conservative local transform (inserts [pause] between paragraphs and after the first sentence). Then, if the result contains no explicit user/model speech tags, asks the configured auxiliary model to rewrite the transcript with a richer set of xAI-supported tags (laughs, sighs, whispers, soft/loud, slow/fast, etc.) so the voice output sounds more expressive. Falls back to the local result on any auxiliary-model failure. z\n\s*\n+z [pause] z\s*\n\s* z \1 [pause] rt)countz\s{2,}, zYou rewrite transcripts for the xAI /v1/tts endpoint by inserting expressive speech tags. Valid inline tags (use as `[tag]`): z1. Valid wrapping tags (use as `[tag]...[/tag]`): u. Rules: - Preserve the spoken words, order, and meaning. - Do not add new spoken sentences or remove existing spoken words. - Use inline `[tag]` for short modifiers (laughs, sighs, pause, etc.). - Use wrapping `[tag]...[/tag]` for sustained effects (whisper, soft, slow, fast, loud, etc.). - Do not use angle-bracket tags like `...` — xAI uses BBCode-style closing tags with `[/tag]`. - Do not use SSML. - Do not explain or comment. - Return only the tagged TTS script.rcall_llmrssystemroleruserzTRANSCRIPT TO TAG: rptaskmessages temperature$```(?:[A-Za-z0-9_-]+)?\s*(.*?)\s*```rz?xAI TTS audio tag rewrite failed; using locally-tagged text: %sN)r%rIrJ_XAI_SPEECH_TAG_REsearch_XAI_FIRST_SENTENCE_REr_XAI_INLINE_SPEECH_TAGS_XAI_WRAPPING_SPEECH_TAGSagent.auxiliary_clientr"_extract_auxiliary_message_content fullmatchDOTALLr{r3rr) r/cleanlocalinlinewrapping system_promptrrtaggedfencerAs r_apply_xai_auto_speech_tagsrs JJLLE   E F; U 3 3E F;U + +E  $ $U + +K&**>5*JJ F9c5 ) ) / / 1 1E  '' YY. / /Fyy233H /17 8;: :=E E H/ /3333338!!m<<,J5,J,JKK    4H==CCEE DfTVT]^^^  ,[[^^))++F  VX[\\\ sB F GF?9G?Gcddl}ddlm}|}t|dpd}|st d|dpi}t|dtpt}t|d tpt} t|d t} t|d t} t|d |d t} |d|d} | 0| dkr* t| } n#tt f$rd} YnwxYw| (t!t"t%t&| } |d|d}|0|dkr* t|}n#tt f$rd}YnwxYw|t!dt%d|}t|dt(}| rt+|}|ddkrOt|dpt,d}nrt|dp*|dpt1dpt,d}|drdnd}||| d}|dks| tks|dkr(| tkrd|i}| r| |d <|dkr| r| |d <||d<| | t4kr| |d<||t6kr||d<|rd|d<||dd|d t;d!|d"d#}|t?||d$%|S)&z Generate audio using xAI TTS. xAI exposes a dedicated /v1/tts endpoint instead of the OpenAI audio.speech API shape, so this is implemented as a separate backend. rNresolve_xai_http_credentialsrr!zSNo xAI credentials found. Configure xAI OAuth in `hermes model` or set XAI_API_KEY.r~rCrR sample_ratebit_rateauto_speech_tags speech_tagsr8optimize_streaming_latencyrutext_normalizationrz xai-oauthr?r@ XAI_BASE_URLrMrr)r/rCrRcodecr9Tz/ttsBearer application/json) Authorization Content-Typez User-Agent<)headersrrLrzxAI TTSr) requeststools.xai_httprr$rGr%r DEFAULT_XAI_VOICE_IDDEFAULT_XAI_LANGUAGErDEFAULT_XAI_SAMPLE_RATEDEFAULT_XAI_BIT_RATErDEFAULT_XAI_AUTO_SPEECH_TAGSrrOrDEFAULT_XAI_SPEED_MINrDEFAULT_XAI_SPEED_MAX&DEFAULT_XAI_TEXT_NORMALIZATION_DEFAULTrDEFAULT_XAI_BASE_URLrHrr.DEFAULT_XAI_SPEED_DEFAULT.DEFAULT_XAI_OPTIMIZE_STREAMING_LATENCY_DEFAULTpostr,raise_for_statusr)r/rrrrcredsr xai_configrCrRrrrr8rrr?rpayloadr9rs r_generate_xai_ttsrsOOO;;;;;; ( ( * *E%))I&&,"--3355G pnooo&&,"J:>>*.BCCDDJJLLdPdH:>>*.BCCDDJJLLdPdHjnn]4KLLMMK:>>*.BCCDDH'):>>-+H+HII$ NN7JNN7$;$; < >h>(0M* %#0  U&???  #. &*X X X0J,--(,$%}} 0w00./11    H +YGGGG s$3GGG8IIIc .ddl}t|}|di}t|tsi}|dt }|dt }|j}|dd} |dd} |d d} |d d } |d d } |dd}t|dpd p"tdpd }|rd|vrd|vrdnd}||d|}dd|j d}d|v}|r|||| | | | d| |dddd}n|||d}| |||d d!"}|r| t|d#$}|d%i}|d&d'}|dkr+|d(d)}td*|d+||d,id-d}|std.t |}t%|d/5}||dddn #1swxYwY|S|jd0d}d1|vrt+||d#$|S t-|d#$}|r't/j|d2ni}|d%i}|d&d'}|dkr+|d(d)}td*|d+|ni#t.jt6t8f$rJ| td3|d4d5t;vrt=|ndd6wxYwtd7)8a Generate audio using MiniMax TTS API. Supports two endpoints: - v1/text_to_speech: simple payload, returns raw audio (Content-Type: audio/mpeg) - v1/t2a_v2: nested voice_setting/audio_setting, returns JSON with hex-encoded audio Args: text: Text to convert (max 10,000 characters). output_path: Where to save the audio file. tts_config: TTS config dict. Returns: Path to the saved audio file. rNrr7rCr8rqvolpitchemotionneutralrr}bitraterogroup_idr!MINIMAX_GROUP_IDzGroupId=?&rr)rrt2a_v2)rCr8rrrrrt)rrr:channel)r7r/ voice_setting audio_setting)r7r/rCrT)rrrLrz MiniMax TTSr base_resp status_code status_msg unknown errorzMiniMax TTS API error (code ): rraz%MiniMax TTS returned empty audio datarrzaudio/rz.MiniMax TTS returned unexpected Content-Type 'z' (raw_bodyz bytes)z"MiniMax TTS returned no audio data)rrrGrrDEFAULT_MINIMAX_MODELDEFAULT_MINIMAX_VOICE_IDrr$r%rrrrrrrfromhexrrrrrrrrJSONDecodeErrorUnicodeDecodeErrorrOlocalsr)r/rrrruntimer r7rCr?r8rrrrrrsepr is_t2a_v2rrr!rrr hex_audiorr content_typers r_generate_minimax_ttsrLs OOO*:66Gy"--I i & & MM'#8 9 9E}}Z)ABBHH MM'3 ' 'E --s # #C MM'1 % %EmmIy11G-- u55KmmIv..G IMM* % % +,,2244 = , - - 3 : : < < 8Jh..H__cc#777X77+47?44G H$I $"  +"   (    }}  H,A!!###(GGGJJ{B// mmM266 !  "|_EEJZkZZjZZ[[ [JJvr**..w;;  HFGG GmmI.. +t $ $ ! GGK  ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! '++NB?? | # # '+] S S S S  / NNNH=EMTZ 8 89992F ;33I#-- r::Ka&]]<II "#^+#^#^R\#^#^___ $&8)D     % % ' ' 'LLL%/688%;%;CMMMLLL  ?@@@s "KK KBNA&Pctddpd}|std|dpi}|dt}|dpt}|d}|drd }n2|d rd }n|d rd }nd}t } d|i} |r|| d< | di| 5} | jj ||||} tj | j } dddn #1swxYwYn^#t$rt$rG}td|dt!dt#|j|d}~wwxYwt'|d5}|| dddn #1swxYwY|S)zGenerate audio using Mistral Voxtral TTS API. The API returns base64-encoded audio; this function decodes it and writes the raw bytes to *output_path*. Supports native Opus output for Telegram voice bubbles. MISTRAL_API_KEYrr!z?MISTRAL_API_KEY not set. Get one at https://console.mistral.ai/r7rCr?rrrMrrNrrr server_url)r7rSrCrTNzMistral TTS failed: %sTrzMistral TTS failed: rr)r&r rGDEFAULT_MISTRAL_TTS_MODELDEFAULT_MISTRAL_TTS_VOICE_IDr.rVrarbcompletebase64 b64decode audio_datar3rerrorrrrrr)r/rrr mi_configr7rCr?rTrT client_kwargsrIrrrrs r_generate_mistral_ttsrs%%6 BBHbG \Z[[[y))/RI MM'#< = =E}}Z((H,HH}}Z((HF##     f % %    g & &  $&&G%.$8M/&. l# M W % %} % % @|*33! / 4H !*8+>??K @ @ @ @ @ @ @ @ @ @ @ @ @ @ @  MMM -q4 @@@D$q''2BDDEE1LM k4 A   sO+E3=D<0 E<EEEEF#AFF#6GGG pcm_bytesrchannels sample_widthc @ddl}||z|z}||z}t|}|dddd|||||dz }|dd |} d t|zt| z|z} |d d | d } | |z| z|zS)aWrap raw signed-little-endian PCM with a standard WAV RIFF header. Gemini TTS returns audio/L16;codec=pcm;rate=24000 -- raw PCM samples with no container. We add a minimal WAV header so the file is playable and ffmpeg can re-encode it to MP3/Opus downstream. rNz <4sIHHIIHHsfmt rtz<4sIsdataz<4sI4ssRIFFsWAVE)structrpack) rrrrr byte_rate block_align data_size fmt_chunkdata_chunk_header riff_size riff_headers r_wrap_pcm_as_wavr sMMMh&5I\)KII   q  I FGY??C NN"S):%;%;;iGI++hGDDK  "%6 6 BBrM gemini_configc|d}t|tr|sdStj|}t|}| s; ddl m }||z }n&#t$rtj |z }YnwxYw|S)z7Return the configured persona prompt file path, if any.persona_prompt_fileNr)get_hermes_home)rGrr$r%rr expandvarsrr is_absoluter{rr3cwd)rrexpandedrrs r#_resolve_gemini_persona_prompt_pathr/s   1 2 2C c3  syy{{tw!!#))++..H >> $ $ & &D     % % 8 8 8 8 8 8"?$$t+DD % % %8::$DDD % Ks(B<< CCct|}|dS |dS#ttf$r'}t d||Yd}~dSd}~wwxYw)zERead the Gemini persona prompt file, failing soft on config mistakes.Nr!rrz4Gemini TTS persona prompt file unavailable at %s: %s)r read_textr%rrrr)rrrAs r_read_gemini_persona_promptr@s .} = =D |r~~w~//55777 ' ( B     rrrrr s'=A5A00A5c|pdddd}d|vod|vS)zIReturn True for Gemini TTS models known to support expressive audio tags.r!r@rtrz gemini-3.1r)r%rr)r7rs r!_gemini_model_supports_audio_tagsrPsM+2$$&&,,..55c1==bAJ : % =%:*==rMc|d}t|tr|d}t|t}|sdSt |st d|dSdS)N audio_tagsrrFzrGemini TTS audio_tags enabled, but model %s is not known to support Gemini audio tags; skipping hidden tag rewriteT)rGrrrDEFAULT_GEMINI_AUDIO_TAGSrrr)rr7rrs r_gemini_audio_tags_enabledr!Vs   L ) )C#t!ggi  3(ABBBG u ,U 3 3 =    u 4rMrc|pd}tjd|tj}|r'|d}|S)Nr!rrrt)r%rIrrr{)rrrs r_clean_gemini_audio_tag_rewriter#gsX ] ! ! # #E L@%ry Y Y YE ' A$$&& LrMc |jd}t|dd}t|tr$t |dpdSt t|ddpdS#t $rYdSwxYw)Nrmessagerr!)choicesrrrr$rGr3)rchoicer%s rrros!!$&)T22 gt $ $ 5w{{9--344 477Ir228b999 rrsAA9A99 BBr!persona_promptc^|}|s|Sd}|pd}d|d|} ddlm}|td|dd |dgd }t t |}|p|S#t $r'} td | |cYd } ~ Sd } ~ wwxYw)z?Use the configured auxiliary model to insert Gemini audio tags.aYou rewrite transcripts for Gemini 3.1 Flash TTS by inserting expressive audio tags. Audio tags are inline square-bracket modifiers such as [whispers], [excitedly], [very slow], [sarcastically], [laughs], [sighs], or [gasp]. There is no fixed allowlist. Use creative freeform tags generously but naturally to control tone, pace, emotional vibe, emphasis, section-level delivery, and non-verbal sounds. Use English audio tags even when the spoken transcript is not English. Rules: - Preserve the spoken words, order, and meaning. - Do not add new spoken sentences or remove existing spoken words. - Use square brackets for every audio tag. - Do not use SSML or XML tags. - Do not explain or comment. - Return only the tagged TTS script.z(none)zPERSONA AND DIRECTOR CONTEXT: z TRANSCRIPT TO TAG: rrrrrrprz>& ! ! 5[[V44F,,F,,2244 4 4 4 5 M MN M M M M S S U UUrMc6 ddl}tddptdd}|std|dpi}t |t r|ni}t |dtpt}t |dtpt}t |d ptd pt d } t|} |} t||rt|| } t!| || } t#d|} t%| | kr3t&d t%| | | d| } dd| igigdgddd|iiidd}ddi}t+| jdkr4 ddl}t |j}n#t2$rd}YnwxYwd||d<| d|d}||d|i||dd !}|jd"kr&t9|d#$} |r|!d?d@dAdBdCdDdEdFdGdHdIdJdKdLd&|g}#n |"d>|!dKdLd&|g}#tkj6|#d dMtjj7tqN}$|$j9dkr6|$j:d%dO*dd+}%tGdP|%n0t&dQ|tgj;|!| tyj=|!n:#t|$rYn.wxYw# tyj=|!w#t|$rYwwxYwxYw|S)RaGenerate audio using Google Gemini TTS. Gemini's generateContent endpoint with responseModalities=["AUDIO"] returns raw 24kHz mono 16-bit PCM (L16) as base64. We wrap it with a WAV RIFF header to produce a playable file, then ffmpeg-convert to MP3 / Opus if the caller requested those formats (same pattern as NeuTTS). Args: text: Text to convert (prompt-style; supports inline direction like "Say cheerfully:" and audio tags like [whispers]). output_path: Where to save the audio file (.wav, .mp3, or .ogg). tts_config: TTS config dict. Returns: Path to the saved audio file. rNGEMINI_API_KEYrGOOGLE_API_KEYzIGEMINI_API_KEY not set. Get one at https://aistudio.google.com/app/apikeyr7r6r?GEMINI_BASE_URLr@)r(z@Gemini TTS composed prompt too long (%d chars), truncating to %dpartsr/AUDIO voiceConfigprebuiltVoiceConfig voiceName)responseModalities speechConfig)contentsgenerationConfigrrz!generativelanguage.googleapis.comz0.0.0z hermes-agent/zX-Goog-Api-Clientz/models/z:generateContentrrT)paramsrrrLrrz Gemini TTSrrrrr%rr,zGemini TTS API error (HTTP rrtrc3*K|]}d|vsd|v |VdS) inlineData inline_dataNr)rsps rrtz'_generate_gemini_tts..5 s7WW|q/@/@MUVDVDV1DVDVDVDVWWrMz+Gemini TTS response contained no audio datarErFrr!z#Gemini TTS response was malformed: z$Gemini TTS returned empty audio datarMrFrSdeleterrr r r r rr rrrrrrrr -loglevelrrrzffmpeg conversion failed: zEffmpeg not found; writing raw WAV to %s (extension may be misleading))?rr&r rGrrr$DEFAULT_GEMINI_TTS_MODELr%DEFAULT_GEMINI_TTS_VOICErDEFAULT_GEMINI_TTS_BASE_URLrHrr!r.r4rrrrrr  hermes_cli __version__r3rrrrrrrrrrrnextKeyError IndexErrorrOrrrrr.rrrNamedTemporaryFilerrrrirrrrrcopyfilerrr)&r/rrrrraw_gemini_configrr7r6r?r( tts_script prompt_textmax_lenrr _hermes_cli_hermes_versionrrrerrrrr9 audio_partr audio_b64rr wav_bytesrtmpwav_pathrcmdr!rs& r_generate_gemini_ttsrbsB"OOO .99 = !18 < <    W   #x006B)34Et)L)LT%%RTM  !!'+CDD E E K K M M iQiE  !!'+CDD E E K K M M iQiE*%% ' * + + ' & eggffSkk  1??NJ!-77Y3DXXX ,%K 'x<>wKK28<< 'RZ\bdhJiJiAjAj mmoo))'266WWY''[8??79?+U+UVZWZVZ+[FF F F F__WY_??EFFF F K(*> K K6 K K    M&x|DDD\"1%i09WWeWWWY]^^  LMM M --T 1N1NTRTJJvr** j) ,MMMDDDEE1LM CABBB ++I ++I##F++ +t $ $  GGI                    $F5 A A AS )8h''  3  ""++F33 XD(y%E64"F,@$+w tXt[';W^CbPZPbsEsGsGHHHF A%%--gh-GGM"#H#H#HIII& NNW    OHk 2 2 2  Ih        D   Ih        D  sH** H98H9C M)M>=M>BP55Q$ QQ$S44S8;S8UUU C=Y/ Y Y,+Y,/Z1ZZ ZZZZcf ddl}|jdduS#t$rYdSwxYw)z=Check if the neutts engine is importable (installed locally).rNrFimportlib.utilutil find_specr3 importlibs r_check_neutts_availablerjy sP~''11== uu " 00cf ddl}|jdduS#t$rYdSwxYw)z@Check if the kittentts engine is importable (installed locally).rNr^Frdrhs r_check_kittentts_availablerm sP~'' 44D@@ uurkcZtttjdz dz S)z9Return path to the bundled default voice reference audio.neutts_sampleszjo.wavr$r__file__rrrMr_default_neutts_ref_audiorr $ tH~~$'77(B C CCrMcZtttjdz dz S)z>Return path to the bundled default voice reference transcript.rozjo.txtrprrMr_default_neutts_ref_textru rsrMc>ddl}|dpi}|ddp t}|ddp t}|dd}|d d }|} |d s|d d dd z} t ttj dz } |j | d|d| d|d|d|d|g} tj | dddddtj } | jdkrk| j} d| D}t%dt'd|pd| |krxt+jd}|rM|d| d d!d"|g}tj |dd#tj t/$t1j| nt1j| ||S)%aGenerate speech using the local NeuTTS engine. Runs synthesis in a subprocess via tools/neutts_synth.py to keep the ~500MB model in a separate process that exits after synthesis. Outputs WAV; the caller handles conversion for Telegram if needed. rNr ref_audior!ref_textr7zneuphonic/neutts-air-q4-ggufdevicecpurMrRrtzneutts_synth.pyz--textz--outz --ref-audioz --ref-textz--modelz--deviceTrrrrr/rrrLrc<g|]}|d|S)zOK:)r)rsls rrz$_generate_neutts.. s)QQQQQ\\%=P=PQqQQQrMzNeuTTS synthesis failed: rrr rrJrrcheckrLrr)sysrGrrrur.rr$rrqr executablerirrrrr% splitlinesrchrrrrrrrrename)r/rrr neutts_configrwrxr7ryr` synth_scriptrar!r error_linesrconv_cmds r_generate_neuttsr sDJJJNN8,,2M!!+r22Q6O6Q6QI  R00N4L4N4NH   g'E F FE   x / /FH    ' ':%%c1--a069tH~~,/@@AAL  $yh5F C^C4'ZcmpyCyKLLLF A$$&&QQ&"3"3"5"5QQQ es2ww||K7P7P7cTceefff;h''  -hk7KXH N84:CUeweyey z z z z Ih     Ih , , , rMcacherloadc,||vr ||||<||S|}|||<t|tkrH|tt |dt|tkH|S)ajGet ``key`` from ``cache`` or load it, keeping the cache LRU-bounded. Refreshes recency on a hit (insertion-ordered dict: pop + reinsert), loads on a miss, then evicts least-recently-used entries beyond the cap. An entry evicted while a caller still holds its returned reference stays alive for that caller; only the cache slot is released. N)popr_TTS_MODEL_CACHE_MAXrPiter)rrrrs r_tts_cache_get_or_loadr s e||YYs^^c Sz DFFEE#J e**+ + + $tE{{##T*** e**+ + + LrM_piper_voice_cachecf ddl}|jdduS#t$rYdSwxYw)z2Check whether the piper-tts package is importable.rNrcFrdrhs r_check_piper_availabler sP~''00<< uurkcrddlm}t|dd}|dd|S)zReturn the directory where Hermes caches Piper voice models. Resolves to ``~/.hermes/cache/piper-voices/`` under the active HERMES_HOME so voice downloads follow profile boundaries. rrxzcache/piper-voicespiper_voices_cacheTr)r{ryrr)ryroots r_get_piper_voices_dirr sL 0///// 35IJJ K KDJJtdJ+++ KrM download_dirc j|st}t|}|jdkr#|rt |S||dz }|r)||dz rt |Sddl}t d|| tj |j dd|dt |gd d d d d tj }n+#tj$r}td|d|d}~wwxYw|jdkr:|jpdpd}td|d|dd|std|dt |S)a}Resolve *voice* (a model name or path) to a concrete .onnx file path. Accepts any of: - Absolute / expanded path to an .onnx file the user already has - A voice *name* like ``en_US-lessac-medium`` (downloads to ``download_dir`` on first use via ``python -m piper.download_voices``) Raises RuntimeError if the model can't be located or downloaded. z.onnxz .onnx.jsonrNz0[Piper] Downloading voice '%s' to %s (first use)z-mzpiper.download_voicesz--download-dirTrrrCr{z/Piper voice download timed out after 300s for 'r\r!zno stderr outputz!Piper voice download failed for 'z': iz#Piper voice download completed but uh is missing — check voice name (see: https://github.com/OHF-Voice/piper1-gpl/blob/main/docs/VOICES.md))DEFAULT_PIPER_VOICErrrSrrr$rrr>rirrrrrrrr%)r6r candidatecached_sysr!rArs r_resolve_piper_voice_pathr s  $#U &&((I7**y/?/?/A/A*9~~uOOO +F }}Le+?+?+??GGII6{{ KKBE<XXX  _d$;U s<00 2dWYX[$      $ Fe F F F    A-%2,,..D2D H H H&#, H H    ==??  )& ) ) )   v;;s=DD7D22D7c tddl}t|tr|dpinidpt }t dp t}| ddtdd t||d d}t|tst|tsd}n|}d }fd } tt|| } d} tfd dD} | r ddlm} | t%ddt%ddt%ddt%ddtdd|} n*#t&$rt(dYnwxYw|}|ds|ddddz}||d5}| | ||| n| ||dddn #1swxYwY||krt5jd}|r^|d|d d!d"|g}t9j|dd#t8jt?$ tAj!|n%#tD$rYnwxYwtAj#|||S)%zGenerate speech using the local Piper engine. Loads the voice model once per process (cached by absolute path) and writes a WAV file. Caller is responsible for converting to MP3/Opus via ffmpeg when a different output format is required. rNrcr6 voices_dirTruse_cudaF speaker_idz::cuda=ctd}td|S)Nz[Piper] Loading voice: %s)rz[Piper] Voice loaded)rr>r)vrb model_pathrs r_load_piper_voicez._generate_piper_tts.._load_piper_voiceX sE /<<< OOJO : : *+++rMc3 K|]}|vV dSrqr)rsk piper_configs rrtz&_generate_piper_tts..d s<    \      rM) length_scale noise_scale noise_w_scalevolumenormalize_audior)SynthesisConfigrrqrgMbX?rg?rruZ[Piper] SynthesisConfig not available in this piper-tts version — advanced knobs ignoredrMrRrtr) syn_configrr rrJrrr)$rdwaverrrGrrrrrrrrrranyrcrrrrrr.rrsynthesize_wavrrrirrrrrrr)r/rrr voice_namer _raw_speakerr cache_keyrr6r has_advancedrr`wav_filerrrbrrrs @@@@r_generate_piper_ttsr8 s6JKKK4>z44P4PX:>>'**0bVXL!!'**A.AJ ((66Q:O:Q:QRR]]__Ltd333L$$Z7788H*:|DDJ  ##L!44L,%%"Z c-J-J" ! 00h00I ##5yBS T TE J          L  - - - - - -("<#3#3NC#H#HII!,"2"2=%"H"HII#L$4$4_c$J$JKK\--h<<== $\%5%56G%N%N O O% JJ    NN5      H    ' ':%%c1--a069 8T " "1h  !  xJ G G G G  x 0 0 0 111111111111111;h''  -hk7KXH N84:CUeweyey z z z z  (####     Ih , , , s76B)mr] model_names r_load_kittentts_modelz2_generate_kittentts.._load_kittentts_model s? 3Z@@@ Ij ! ! ;<<<rM)r6r8rrNrMrRrtrnrr rrJrrr)r_rGDEFAULT_KITTENTTS_MODELDEFAULT_KITTENTTS_VOICErrgenerate soundfiler.rrrrrirrrrrr)r/rr kt_configr6r8rrr7rasfr`rrr]rs @@r_generate_kittenttsr s"##I{B//Iw(?@@J MM'#: ; ;E MM'3 ' 'E|T22J ##9:G\ ] ]E NN4uEjN Q QEH    ' ':%%c1--a069HHXue$$$;h''  -hk7KXH N84:CUeweyey z z z z Ih     Ih , , , rMc &rstddS ddlm}|dn$#t$rYnwxYwstddSt |?t d td t|}t|d <|r'| }nt}t|}t|}t|kr4td |t|d|dd lm} | dd } | t&v} |rddlm} | |rt-jdd|dddSt1|} |t5| |} ddlm}|t;| rt-jdd| dddSnt<j d}t1tB}|"dd|tG|}|d|d|z } n| r|dvr |d|dz } n |d|dz } | j$"ddt;|  |0t%d |tM||n|tNvrtQ|x} |n|d!krf tSn)#tT$rt-jdd"ddcYSwxYwt%d#tWn@|d$krh tYn)#tT$rt-jdd%ddcYSwxYwt%d&t[|'n|d(krf tYn)#tT$rt-jdd)ddcYSwxYwt%d*t]nf|d+kr-t%d,t_n3|d-kr-t%d.tan|d/krf tcn)#tT$rt-jdd0ddcYSwxYwt%d1ten|d2kr-t%d3tgna|d4krTtist-jdd5ddSt%d6tkn|d7krf tmn)#tT$rt-jdd8ddcYSwxYwt%d9ton|d:krf tqn)#tT$rt-jdd;ddcYSwxYwt%d<tsn/d} tun#tT$rd}YnwxYw|rt%d= ddl;}|j<=d>?5}|>fd@?dABdddn #1swxYwYn#t$r&tjBtYnYwxYwtir.t%dCd4}tknt-jddDddStjEFr#tjEGdkrt-jddE|dFddStd}|Mt|r=Jdst}|r|Jd}n|tNvrOt|}|r=Jdst}|r|Jd}nL| r/|dGvr+Jdst}|r|d}n|dvr| oJd}tjEG}t%dH|dI|dJ}|rdK|}t-jd|||dLdS#t$r>}dM|dN|}tNdO|t|dcYd}~Sd}~wt$r@}dP|dN|}tNdO|dQt|dcYd}~Sd}~wt$r@}dR|dN|}tNdO|dQt|dcYd}~Sd}~wwxYw)Sa Convert text to speech audio. Reads provider/voice config from ~/.hermes/config.yaml (tts: section). The model sends text; the user configures voice and provider. On messaging platforms, the returned MEDIA: tag is intercepted by the send pipeline and delivered as a native voice message. In CLI mode, the file is saved to ~/voice-memos/. Args: text: The text to convert to speech. output_path: Optional custom save path. Defaults to ~/voice-memos/.mp3 speed: Optional playback speed multiplier (0.25-4.0). Overrides config.yaml. instructions: Optional voice-design guidance (tone, emotion, pacing, accent, whispering). Forwarded to the OpenAI backend (gpt-4o-mini-tts and OpenAI-compatible servers). Silently ignored by backends that don't support it. provider: Optional TTS provider override. When set, bypasses the configured ``tts.provider`` and uses this provider instead. Accepts built-in names (``edge``, ``openai``, ``elevenlabs``, ``minimax``, ``xai``, ``mistral``, ``gemini``, ``neutts``, ``kittentts``, ``piper``), user-declared command provider names from ``tts.providers.``, or plugin-registered provider names. When ``None`` (the default), the configured provider from ``tts.provider`` in config.yaml is used. Returns: str: JSON result with success, file_path, and optionally MEDIA tag. zText is requiredF)successrprepare_spoken_textN max_charszText is empty after TTS cleanuprVrWr8z>TTS text too long for provider %s (%d chars), truncating to %d)get_session_envHERMES_SESSION_PLATFORMr!)has_traversal_componentz/output_path contains '..' traversal component: zM. Use an absolute path or one relative to the current directory without '..'.)rr) ensure_ascii)is_write_deniedz;output_path targets a protected credential or system path: z(. Choose a normal audio output location.z%Y%m%d_%H%M%S_%fTrtts_rR>rrPrrr.mp3z3Generating speech with command TTS provider '%s'...rz`ElevenLabs provider selected but 'elevenlabs' package not installed. Run: pip install elevenlabsz$Generating speech with ElevenLabs...rPzz%text_to_speech_tool.. sGK0B4S]0^0^$_$_rMrrz9Edge TTS not available, falling back to NeuTTS (local)...zhNo TTS provider available. Install edge-tts (pip install edge-tts) or set up NeuTTS for local synthesis.z-TTS generation produced no output (provider: )>r~rercrrr^z,TTS audio saved: %s (%s bytes, provider: %s),zMEDIA:z[[audio_as_voice]] )r file_path media_tagrrFzTTS configuration error (rz%szTTS dependency missing (rzTTS generation failed ()Pr% tool_errortools.tts_text_normalizerr3rrrrrrrr.rrrrgateway.session_contextrOPUS_VOICE_PLATFORMStools.path_securityrrdumpsrrragent.file_safetyrr$datetimenowstrftimeDEFAULT_OUTPUT_DIRrrVrr>rrrDr<rrKrRrlrurrrVrrbrjrr_rrdrr6concurrent.futuresfuturesrsubmitr!rrrr@rrrrr2rXr.rrGr rr)r/rr8rPrrclampedcommand_provider_configrXrplatform want_opusrrr timestampout_dirrB _plugin_pathedge_available concurrentpoolrF opus_pathplugin_voice_compatible file_sizerr error_msgr+rs` @@rtext_to_speech_toolr sZJ =tzz||=,e<<<<@@@@@@""44888 zz|| L;UKKKK!##J dCU5\\2233*%% % 7->>##))++ ,, ?xTT'x<> * * #: K KKK " ### # #%))++445GHH )** dT 222 " .01HIIC":":":S":"::II 98'TTT"8"8"8"88II"8"8"8"88I4$7779~~Hg4 " . KKEx   -h*A:HH2 2 28h* L 8 $HH  % % '"$$$$ ' ' 'z$##!&'''''' ' KK> ? ? ? x < < < <  ! ! '%'''' ' ' 'z$[##!&'''''' ' KK> ? ? ? x, W W W W W  $ $ '%'''' ' ' 'z$Z##!&'''''' ' KKA B B B #D(J ? ? ? ?  " " KK? @ @ @ !$* = = = =    KK; < < < dHj 9 9 9 9  " " '&(((( ' ' 'z$N##!& '''''' ' KKG H H H !$* = = = =  ! ! KKE F F F x < < < <  ! !*,, 'z$F##!& '''' KKB C C C T8Z 8 8 8 8  $ $ '!#### ' ' 'z$J## !& '''''' ' KKL M M M h ; ; ; ;   ' ' ' 'z$5## !& '''''' ' KKA B B B h ; ; ; ;"N ' """" ' ' '!& ' ' @AAAP----#+>>1>MM-QU ______ &&,,,---------------$PPPK 24: N NOOOOOP(** ' WXXX# x<<<<z$E##!& ''''w~~h'' #27??8+D+D+I+I: TTTT"### #)22 ! " .00GHH =((00- 0 : :I -#,#+#4#4V#<#< 2 2 2 'K8&T&T #& =((00- 0 : :I -#,#+#4#4V#<#<  GVVV%%f--W)22I ($#' F F F(FX->->v-F-F GOOH--  BHQZN^N^`hiii(X''  ;:y::Iz!" 0      444@@@Q@@  T9%%%)U333333333 444?x??A??  T9t 444)U333333333 444>h>>1>>  T9t 444)U333333333 4sAA! A!/Af8 Mf8#M?<f8>M??6f86Of8#O+(f8*O++8f8$P32f83#Qf8QBf86Tf8#T+(f8*T++Bf8;3f8/W>=f8>#X$!f8#X$$6f8Y*)f8*#Z f8Z2f8[f8 [!f8 [!!f8]' /] ]']]'"]#]'&f8'-^f8^Af8/Af8E)f88 j3g;5j; j5i=j j5j j jc>t}t|}t||}|dS|dkr/ tdS#t$rt cYSwxYw|dkr> t n#t$rYdSwxYwttddS|dkr/ tn#t$rYdSwxYwtS|dkr> tn#t$rYdSwxYwttd dS|d kr$ t|n#t$rYdSwxYwdS|d krB d d l m}t|dS#t $rYdSwxYw|dkr-ttddptddS|dkr> t#n#t$rYdSwxYwttddS|dkrt S|dkrt%S|dkrt'S d dlm}d dlm}|||}t|o|S#t $rYdSwxYw)aReturn whether the explicitly resolved TTS provider can run. Availability must mirror :func:`text_to_speech_tool` dispatch. Unrelated cloud credentials do not make the default Edge backend usable, and an explicitly selected backend is checked on its own requirements. NTrerFrBrPrrnrr~rrrrr6r7rrrr^rcr1r3)rrr.r6rrjr<rr&rR_has_openai_audio_backendrr rrrGr3rVrmrr;r2r<r4 is_available)rrcommand_configrr2r4plugins rcheck_tts_requirementsr[ s"##JZ((H5h KKN!t6 -    4 - - -*,, , , , -<      55 )*> MMNNN8  ! # # # #   55 (***;  ! # # # #   55 )*={KKLLL9  ( 4 4 4 4   55 t5  C C C C C C4466::9EEFF F   55 8 !"2H = = A$%5x@@   9  " $ $ $ $   55 )*;YGGHHH8&(((;)+++7%'''333333AAAAAA""$$$h''F4v2244555 uusA A$#A$.A== B  B 2C CC'C66 DD+D;; E E /F FFG G-,G- AJ JJctt}t|tr|dndpi}|dpd}|dpd}|rt ds ||pt dfSt }|rt ds ||pt dfStd}|Cd }tst dr|d td zz }t||j t|j d d d dfS)aReturn ``(api_key, base_url, is_managed)`` for the OpenAI audio client. ``is_managed`` is True when the config resolves to the Nous managed audio gateway (a restricted proxy), so callers can coerce the request to what the gateway supports. When ``tts.use_gateway`` is set the gateway is preferred even if direct OpenAI credentials are present. Resolution order (mirrors the STT resolver): 1. ``tts.openai.api_key`` / ``tts.openai.base_url`` from ``config.yaml`` 2. ``VOICE_TOOLS_OPENAI_KEY`` / ``OPENAI_API_KEY`` environment variables (still honoring ``tts.openai.base_url`` when set) 3. Managed OpenAI audio tool gateway rPNrr!r?rF openai-audiozUNeither tts.openai.api_key in config nor VOICE_TOOLS_OPENAI_KEY/OPENAI_API_KEY is setz. zmanaged OpenAI audio for TTSr@v1T)rrrrGr*r]r+r'r(r)r nous_user_tokenr gateway_originrH)r openai_cfg cfg_api_key cfg_base_urldirect_api_keymanaged_gatewayr%s rrZrZ st"##J.8T.J.JT*..***PT[Y[J..++1rK>>*--3LM?511M\D-DuLL133NPoe44P G0G%OO2>BBO ;  & ' ' ?5+A+A  72 G !!! '?188==@@@$GG  rMctdpi}|drdSttpt dS)zTReturn True when OpenAI audio can use config/env credentials or the managed gateway.rPrTr)rrGrr+r')rs rrr s\"$$((228bJ~~i  t ,..^2N~2^2^ _ __rMz```[\s\S]*?```z\[([^\]]+)\]\([^)]+\)z https?://\S+z \*\*(.+?)\*\*z \*(.+?)\*z`(.+?)`z^#+\s*z ^\s*[-*]\s+z---+z\n{3,}u"[🀀-🫿☀-➿️‍󠀠-󠁿]+z].*?c ddlm}||dS#t$rYnwxYwtd|}t d|}t d|}td|}td|}td|}td|}td|}td|}td|}td|}td|}|S) aPrepare text for speech via the shared cleaner in tts_text_normalize. One cleaner for every TTS path (tool, gateway auto-TTS, voice-mode streaming, web dashboard): strips reasoning blocks, the file-mutation verifier footer, markdown, and emoji; expands units and symbols; and flattens newlines to sentence breaks so newline-sensitive providers (Kokoro) speak the whole script. Falls back to the legacy regex pipeline if the normalizer ever fails. rrNrrz\1r!r0)rrr3 _THINK_BLOCKrJ_MD_CODE_BLOCK_MD_LINK_MD_URL_MD_BOLD _MD_ITALIC_MD_INLINE_CODE _MD_HEADER _MD_LIST_ITEM_MD_HR_EMOJI _MD_EXCESS_NLr%)r/rs r_strip_markdown_for_ttsr sK @@@@@@""448888        C & &D   c4 ( (D <<t $ $D ;;r4 D <<t $ $D >>% & &D   ud + +D >>"d # #D   R & &D ::b$  D ::c4 D   VT * *D ::<<s  ""cneZdZdZdddejdefdZdedd fd Z dd Z dede efd Z dd Z d S)_SyncSentencePipelineuOverlap per-sentence synthesis with playback for non-streaming providers. The universal sync fallback used to run strictly serially per sentence — synthesize, play, and only then start synthesizing the next sentence — so every sentence boundary added a full synthesis-time of dead air. For local model providers that cost dominates the conversation: a provider at real-time-factor ~1 spends as long silent between sentences as it does speaking. Chunked streamers already avoid this; this closes the same gap for everyone else (edge, piper, plugin providers, …) without touching the provider contract. Shape: one synthesis worker (single-threaded executor, so sentences are synthesized FIFO and providers never see concurrent calls from this loop — same effective concurrency as the serial path) feeding one playback worker through a small bounded queue. While sentence *n* plays, sentence *n+1* is already synthesizing. The bound keeps lookahead — and the temp files it implies — small, and gives natural backpressure to the caller. ``synthesize``/``play`` are resolved late (module global / import inside the worker) so tests that monkeypatch ``text_to_speech_tool`` or ``tools.voice_mode`` keep working unchanged. ru) lookahead stop_eventrc||_tjtd||_t dd|_tj|j dd|_ |j dS)Nrtmaxsizeztts-sync-synth)rthread_name_prefixz tts-sync-playT)rrr) _stoprrr_queuer _executorrr_drain_playerr|)selfrrs r__init__z_SyncSentencePipeline.__init__0 s CH;9%%D D D  ,.>   !';_T     rMcleanedrNc|jrdS|j|j|}|j||fdS)zAQueue one sentence. Blocks only when the lookahead bound is full.N)r#is_setr%r_synthesize_to_tmpr$r)r(r*futures rspeakz_SyncSentencePipeline.speak= sV :      F&&t'>HH &)*****rMc|jd|j|jddS)z@Flush queued sentences in order (skipped if stopped), then join.NT)r)r$rr'rr%shutdown)r(s rrz_SyncSentencePipeline.closeD sI   T*****rMcr|jrdSd} tjd\}}t j|t |||S#t$rN}t d||r& t j |n#t$rYnwxYwYd}~dSd}~wwxYw)Nr)rS)r/rz*Sync per-sentence TTS synthesis failed: %s) r#r,rmkstemprrrr3rrrr)r(r*tmp_pathfdrAs rr-z(_SyncSentencePipeline._synthesize_to_tmpJ s :     4 #+6:::LB HRLLL W( C C C CO    NNG M M M Ih''''D44444 s;>A B6(B1BB1 B(%B1'B((B11B6ch |j}|dS|\}}d} |}|rl|jsSt j|r4t j|dkrddl m }||n2#t$r%}t d|Yd}~nd}~wwxYw|r& t j|n>#t$rYn2wxYwn-#|r& t j|w#t$rYwwxYwwxYw2)NTrplay_audio_filez Sync per-sentence TTS failed: %s)r$rGr!r#r,rrisfilertools.voice_moder8r3rrrr)r(r _sentencer.r4r8rAs rr&z_SyncSentencePipeline._drain\ s ;??$$D| $ IvH !==??.TZ%6%6%8%8.GNN844.GOOH5599@@@@@@#OH--- H H HA3GGGGGGGG H (++++"8 (++++"! sfBB*)D* C4CDCDC44 DDD/ DD/ D+(D/*D++D/rN)rrrrrEventrr)r$r/rr r-r&rrMrrr s.IJ   9? #    +S+T++++++++ #(3-$rMr text_queuertts_done_eventdisplay_callbackc  !|d! dd d}dgt}ddlm}m}||| t nd!d t |pt||n#t$rdYnwxYwtj dkrdn t} | j jdnj#t t"f$r'} t$d| dYd} ~ n7d} ~ wt$r'} t$d | dYd} ~ nd} ~ wwxYw|} d } d } gt+jgt/jd d  fddt2t4ddddffd fdd# fd }dt6ddf fd d} *t/j|d}|dt6f!fd }dd$fd s || }nO#t*j$r=tA| j!| kr"| "D] }||YwwxYw|#| "D] }||n7| #|D] }|| |$n#t*j$rYnwxYw,n2#t$r%} t$d | Yd} ~ nd} ~ wwxYw!& !%n#t$rYnwxYw -|+&d|'d!D]}|'d": (%n#t$rYnwxYw|)dS#!& !%n#t$rYnwxYw -|+&d|'d!D]}|'d": (%n#t$rYnwxYw|)wxYw)%upConsume text deltas from *text_queue*, buffer them into sentences, and speak each sentence the moment it's ready — the conversational path. Provider-agnostic. A registered streaming provider (ElevenLabs, OpenAI, …) plays chunked PCM through one sounddevice stream for the lowest latency; every other provider (edge, the default) is spoken per-sentence via the sync ``text_to_speech_tool`` path, so audio still starts on sentence one instead of after the whole reply. Protocol: * The producer puts ``str`` deltas onto *text_queue*. * A ``None`` sentinel signals end-of-text (flush remaining buffer). * *stop_event* can be set to abort early (barge-in / user interrupt). * *tts_done_event* is **set** in the ``finally`` block so callers waiting on it (continuous voice mode) know playback is finished. Nr)SentenceChunkerresolve_streaming_provider) preferredDarwinint16 sampleraterdtypeu2sounddevice not available, streamer→tempfile: %sz#sounddevice OutputStream failed: %sr4rr@ct}|jjd}||S)z0Create and start a fresh PortAudio OutputStream.rFrG)rZ OutputStreamrrr|)rY new_streamstreamers r_create_output_streamz4stream_tts_to_speaker.._create_output_stream sO$&&B#/!*)J       rM audio_iter chunk_queuezqueue.Queue[Optional[bytes]]rc |D]I}rtdn||dJn2#t$r%}td|Yd}~nd}~wwxYw|ddS#|dwxYw)z-Consume a generator into a thread-safe queue.uPTTS CUT: prefetch cancelled (stop_event set mid-sentence) — partial audio onlyg>@rzLTTS CUT: streaming TTS prefetch failed mid-sentence (partial audio only): %sN)r,rr>rr3rrelease)rPrQrrA _prefetch_semrs r_consume_to_queuez0stream_tts_to_speaker.._consume_to_queue s  ('99E!((** COOE4O8888   / %%%%%'''''%%%%%''''s0A AB- A?A:5B-:A??B--+Cc8: n#t$rYnwxYw }|td|S#t$r(}td|dYd}~dSd}~wwxYw)z@Close the broken PortAudio stream and try to create a fresh one.Nz6TTS: PortAudio output stream reinitialized after errorz'TTS: PortAudio stream reinit failed: %s)stoprr3rr>r)rMrArO output_streams r_reinit_output_streamz4stream_tts_to_speaker.._reinit_output_stream s(!&&(((!'')))) D 2244 *  L"!   =s!% ttttt  s#(. ;;'A'' B1BBcJ}ddl} ddlm}n#t$rd}YnwxYw|d d}d}} }|nr.|Pg} |}|n||- t|jd} |}|nrn{||z} t| t| dzz } | dkr, | | | d| d  d d n#t$r} td | ||kr|d z }}|} | | | d| d  d d n#t$rYnwxYw| t| kr | | dnd}Yd} ~ ^ntd|d}Yd} ~ n)d} ~ wwxYw| t| kr | | dnd}- |ddS#|dwxYw }|dSr.g} |}|n||- t|j})z=Single consumer: play audio segments from the queue in order.Nr)mark_audio_output_activecdSrqr)_actives rr[zQstream_tts_to_speaker.._playback_worker..mark_audio_output_actives#trMTrrMruz._playback_worker sT'''(####$IIIIIII $$$$$$$$$)(...L4"#K$%M&3OF&2&6&6&8&8 &.!%,,..%$*2&(G6(3(9(9#(=$) 'u 5 5 5 6 /. $W z8;O%(+ 4$/OO$5$5E$} %)0022& %#05#8D+.t99D A +FL+q00(!*$3$9$9(+,0,,?u)7)*)**1'"a..%&%&%&%& (1"!*"!*"!*$*NN)<(1%&%&%& (5{'B'B(5(: :O:O:Q:Q+:+F-50?0E0E47NN8<]l]8K>C5C56567>gb!nn 12121212 4=-5-5-504-54@#d))3K3K15\]]0C0C58-: -5HHHH,G")/-8-8 )*)*)*;?$)EEEEE"!*H8Dc$ii7O7O\]] 3 3UX*e4%F"J-,U33333,,U3333"."2"2"4"4K"*!((**!  G. + 1 1 =!u--- . '&W z83Gst %%C%I6AE! I6! I+2H=AG%$H=% G2/H=1G22"H=I6H=8I6=I&I66 J text_to_speakc J |}n3#t$r&}td|Yd}~dSd}~wwxYwt j}|tj ||fd} || dS)z=Synthesize *text_to_speak* and start prefetching immediately.Nz"Streaming TTS synthesis failed: %sr Tr) rr3rracquirerrrrrrr|) rmrPrArQt_CHUNK_QUEUE_MAXrjrUrT_prefetch_threadsrNs r_enqueue_audioz-stream_tts_to_speaker.._enqueue_audiovs''' %__];;    CSIII   ! ! # # #:?+N^:_:_:_K   [ ) ) ) ( +.A  $ $Q ' ' ' GGIIIIIs A AA T)rrsentencecrdSt|}|sdS|d}D]0}|d|krdS1| |  |dSrt|kr |d}|dS)z9Display sentence and route to the appropriate audio path.Nz.!,)r,rr%rrHrr/r) rtr* cleaned_lowerprevrs_spoken_sentencesr@rstream_max_len sync_pipelines r_speak_sentencez.stream_tts_to_speaker.._speak_sentences#  "" -h77==??G #MMOO22599M)  ::<<&&u-->>FF?  $ $W - - -+  ***(##G,,, 3#g,,"?"?!/>/2 N7 # # # # #rMc3Kd}|D]p}|rnY||z}t|t|dzz }|dkr |d|V|t|kr ||dnd}q|rdVdSdS)z1Yield int16-aligned byte chunks from an iterable.rMruN)r,r)rstop_evtleftoverrbuf aligned_lens r_align_int16_chunksz2stream_tts_to_speaker.._align_int16_chunkssH P P??$$E&!#hh#c((Q,7 !##l{l++++0;c#hh0F0F3{||,,C    rMrncvd}d} ddl}tjdd}|j}||d5}|d|d|| ||D]}|| dddn #1swxYwY| dd l m }||n2#t$r%} td | Yd} ~ nd} ~ wwxYw|& | n#t$rYnwxYw|r( tj|dS#t"$rYdSwxYwdS#|& | n#t$rYnwxYw|r& tj|w#t"$rYwwxYwwxYw) z0Write PCM chunks to a temp WAV file and play it.NrrMFrHrrtrur7z!Temp-file TTS fallback failed: %s)rrrSrr setnchannels setsampwidth setframerate writeframesrr:r8r3rrrrr) rPr~rr_r4rwfalignedr8rArs rrkz1stream_tts_to_speaker.._play_via_tempfilesCH  1NNN8YYsD))0ROOA&&&OOA&&&OOK000#6#6z8#L#L00w////0 000000000000000 <<<<<<)))) I I IBCHHHHHHHH I? $ (+++++" ? $ (++++"s7C A$B/# C /B33C 6B37(C E& D*D E& DE&D** D76D7=E E! E!&F8*E?>F8? F  F8 F  F8F'&F8' F41F83F44F8rz Streaming TTS pipeline error: %sgr@g$@r<)rn)*clearrtools.tts_streamingrBrCrrrr3rrrZrLrrr|rrrrrrrr Semaphorer rr$rr,rGrrrflushfeedrrrrrWset)"r>rr?r@r_worker_threadrrBrCrYrAchunkerlong_flush_len queue_timeoutrlr{deltartrprqrrjrUrOrsrkrTrrrYrxrXryrNrzs" ` ` @@@@@@@@@@@@@@@rstream_tts_to_speakerrt s.59MG  %''  TSSSSSSS--jHMMM >F=M-j999SW    #!99 j 9 9:"" # # #!" #  H,, $  ),..B$&OO#+#7!)!2%%4%%M "''))))#W-)))LL!UWZ[[[$(MMMMMM )))NN#H#NNN$(MMMMMM)"/## ')MRKMM 46!+A..       (  (7 ( ( ( ( ( ( ( (0      .i i i i i i i i i i i V # $           &6:  &-5EdSSSN  " " " $c $ $ $ $ $ $ $ $ $ $ $<   # # # # # # J##%% * "}==;   w{##n44$+MMOO22'1111  } ' ..H#OH----#LL// * *))))%##%% **  %%'''';      @@@93????????@  $ ##%%%%      N$>   T " " "     . . ." ! !A FF4F  $ ""$$$##%%%%    '  $ ##%%%%      N$>   T " " "     . . ." ! !A FF4F  $ ""$$$##%%%%    sIAL:.B L: BL:BL:;AD?L:E'D3.L:3 E'E"L:"E''C"L: I! L:!A J-*L:,J--A L:L#"L:#L52L:4L55L:9P0: M)M$P0$M))P0/N NN!(P PP0S44Q S4 QS4QAS4&(SS4 SS4SS4__main__u🔊 Text-to-Speech Tool Modulez2==================================================c> |dS#t$rYdSwxYw)NTF)r)importerrs r_checkrs9  HJJJ4   55 s  z Provider availability:z Edge TTS: installedz$not installed (pip install edge-tts)z ElevenLabs: elz¬ installed (pip install elevenlabs)z API Key: rBrrznot setz OpenAI: oaiz not installedz2not set (VOICE_TOOLS_OPENAI_KEY or OPENAI_API_KEY)z API key set (rrz unavailable (z MiniMax: z Piper: z%not installed (pip install piper-tts)z ffmpeg: u ✅ foundu(❌ not found (needed for Telegram Opus)z Output dir: z Configured provider: )registryrrGaConvert text to speech audio. Returns a MEDIA: path that the platform delivers as native audio. Compatible providers render as a voice bubble on Telegram; otherwise audio is sent as a regular attachment. In CLI mode, saves to ~/voice-memos/. Voice and provider are user-configured (built-in providers like edge/openai or custom command providers under tts.providers.), not model-selected.objectstringzThe text to convert to speech. Provider-specific character caps apply and are enforced automatically (OpenAI 4096, xAI 15000, MiniMax 10000, ElevenLabs 5k-40k depending on model); over-long input is truncated.)r descriptionz9Optional custom file path to save the audio. Defaults to z/audio_cache/.mp3numberzPlayback speed multiplier. 1.0 = normal, 0.5 = very slow (language learning), 2.0 = fast. Range: 0.25-4.0. Overrides the speed configured in config.yaml.aOptional voice-design guidance: tone, emotion, pacing, accent, whispering, impressions (e.g. 'Speak in a cheerful, excited whisper'). Forwarded to the OpenAI backend (gpt-4o-mini-tts and OpenAI-compatible voice-design servers). Silently ignored by backends that don't support it.a+Optional TTS provider override. Accepts built-in names (edge, openai, elevenlabs, minimax, xai, mistral, gemini, neutts, kittentts, piper), user-declared command provider names from tts.providers., or plugin-registered names. When omitted, the configured tts.provider from config.yaml is used.r/rr8rPr)r propertiesrequired)rr parametersrc t|dd|d|d|d|dS)Nr/r!rr8rPrr)rrG)rkws rrrtsc2 XXfb ! !HH]++hhwXXn--*%%  ' ' 'rMu🔊)rtoolsetschemahandlercheck_fnemojirq)F)r!)NNNN)NN)rrrrrloggingrrrrIrkrrirrrr_rrr dataclassesrrpathlibrtypingrr r r r urllib.parser rhermes_cli._subprocess_compatrr{r getLoggerrrrr$r&tools.managed_tool_gatewayr'r#r(r)r*r+rr,r6r<rLrRrVrZr_rdrr7rFr%DEFAULT_ELEVENLABS_STREAMING_MODEL_IDr[r r^rrrr\r]rrrr rrrrrrrrrrrrrrKrLrMr r*rrGEMINI_TTS_SAMPLE_RATEGEMINI_TTS_CHANNELSGEMINI_TTS_SAMPLE_WIDTHrrr|rrrrrrrrrrrrrrMAX_TEXT_LENGTHrrrrrrrNr=rUrrr&rrr.rDrGrJrrPrVrXrcrlrrrrrrrrrrrrrr*r2r@rKrOrlrurrrrr1rrrrrrrrrrrrr!r#rr.r4rbrjrmrrrurrrrrrrrrrrrrrZrrrrrrr MULTILINErrrrrrrrrr=rprintrrminimax_runtimerrminimax_statusr rArtools.registryrr TTS_SCHEMAregisterrrMrrs!!!F     99999999((((((((::::::::::::::********<<<<<<000000  8 $ $ / / / / S3 SS SS S S S SDCCCCC 100000   ,Nd38nNc3hNNNN" $    '46(;%( &I'8&9::="+5&8=B3E$,23.*/&9!P! 0' 0 )=====-,..    , ,$sCx.   ##"" 4 4 $sCx.   dt"1C1D1111cd " " " "  " C= "  " " " "N   C=   #s(^ 4        C=       + ,05$5$sm5$c3h(5$ 5$5$5$5$v$sCx.&Ld38nLLLLL $ % % % % % % % %AS#XAAAAAF" # # #  '*#$)!&Y>>>'+# !y"""8d38n8C8DcN8888S#X  #s(^0>S#X>4>>>>S#Xd38n*XL XLXLXLS#X XL c] XLXLXLXLv344 S#X     T#s(^     "&[[ cN[#[ [[[[$T#s(^3#(3->#hsmPS"sCx. <1j.>141111h Dd38n D D D D D"'+~Q~Q ~Q ~Qd^~Q ~Q~Q~Q~QB'd'DcN't'''' E EEE cN E S#X E  EEEEPhtCH~.FRV.T.... 9s9x}9999$)#))#))))l......"!C!C!!!!N3Sd3PS8nY\<(s(($sCx.(UX((((V(""!"&ooo ooS#Xo c] o sm o C=o C=o E?o3-o ooooz,#,C,T#s(^,X[,,,,d  RZ 0111MACHHMfDgDggjpp -$$ERYWWW00C0$040000AcAcAAAAHvCvcvtCH~vRUvvvvxDADA#DA4S>DAVYDADADADAT11#14S>1VY1111r.'/ CCCCC C  CCCCDtCH~(SW." tCH~ #     >S>T>>>> d38nST"SS---c-3----f%)VV VS>VSMV VVVV>isii$sCx.iUXiiii`DD3DDDD D#DDDD 232S2d38n2QT2222|$sCx.s(2s7BSX[*&(DcN''' t    2S222222jacaac3haTWaaaaR*,S#X+++4c44c3h4TW4444x"&!"&" w4w4 w4#w4 E?w43- w4 sm w4  w4w4w4w4z LLLLL^,U3T>-B,,,,^`4````-.. 2:. / / "*_ % % 2:& ' ' RZ % % "*Z(( RZ  6 6 6  >>>> G   9%%  L   rz329EEE ##> 4O2 4 40 4 4 4  000////0 E +> + +,,, E q*@*@*B*Bo;;Ho q qrrr E i++--g;;=g i ijjj E 1/ 1 1222}V$$H E .H . ./// 0/////// `! s ! O[n[n[p[p O O O ! { !a!Z  -   BHG$$(( T    ' ' $       s*d ddd