߲jM UdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl m Z ddlmZddlmZmZmZmZmZddlmZddlmZmZmZmZej:d Zd Zd>d Z d Z!d dddd ddddd d Z"de#d<d d dddddddZ$de#d<d?dZ%d@dAdZ&d\Z'Z(Z)gdZ*e dGd d!Z+d"d#d$d%d#d$d"d#d$d&Z,d'e#d(< d@ dBd)Z-d*d+dCd,Z.dDd-Z/dEd.Z0dFd/Z1d0d*dd1 dGd2Z2dHd3Z3dId4Z4dJd5Z5e'e(e)f dKd6Z6dLd7Z7dMd8Z8dNd9Z9dOd:Z:d*d;dPd<Z;d*d; dQd=Z`` as a dict (``null``/non-dict sections read as empty).N) isinstancedictget) tts_configkeysections r_sectionr&s/%/ D%AjnnS!tG $/77R7riiii:i'i}i) edgeopenaixaiminimaxmistralgemini elevenlabsneutts kittenttspiperzDict[str, int]PROVIDER_MAX_TEXT_LENGTHi0ui@) eleven_v3 eleven_ttv_v3eleven_multilingual_v2eleven_multilingual_v1eleven_english_sts_v2eleven_english_sts_v1eleven_flash_v2eleven_flash_v2_5 ELEVENLABS_MODEL_MAX_TEXT_LENGTHcTt|trt|ts|dkDr|SdS)z6*value* when it is a positive non-bool int, else None.rN)rintbool)values r _positive_intr7Ds'uc*:eT3JuWXy5b^bbrc|stS|jj}|xsi}t||}t |j d}|r|S|dk(rKddlm}|j dxs|}tj t|j}|r|S|tvr t|S|tvr9t||} t| r"t | j dxstStS)aaInput-character cap for *provider*: ``tts..max_text_length`` > ElevenLabs model table > ``PROVIDER_MAX_TEXT_LENGTH`` > command provider's own ``max_text_length`` (else ``DEFAULT_COMMAND_TTS_MAX_TEXT_LENGTH``) > ``FALLBACK_MAX_TEXT_LENGTH``. Non-positive / non-int overrides fall through so a broken config can't disable truncation.max_text_lengthr%r)DEFAULT_ELEVENLABS_MODEL_IDmodel_id)FALLBACK_MAX_TEXT_LENGTHlowerstriprr7rtools.tts_tool_providersr:r2strr)r rrr ) providerrrcfgprov_cfgoverrider:r;mappednameds r_resolve_max_text_lengthrGIs '' ..  "C  CS!HX\\*;<=H lH<< +J/J155c(m6I6I6KL M &&',, ''*34 &u - +eBe e ##r)i]) z-acodeclibopus-ac1-b:a48k-vbronz -applicationvoipz-compression_level10T)frozencFeZdZUdZded<ded<dZded<ed d Zy ) AudioDeliveryProfilez9Destination-platform constraints for generated TTS audio.r@platformr4max_file_bytes333333?float safety_ratiocZtdt|j|jzS)z:Conservative packing target below the platform hard limit.rH)maxr4rWrZ)selfs rtarget_file_bytesz&AudioDeliveryProfile.target_file_bytesws'1c$--0A0AABCCrN)returnr4)__name__ __module__ __qualname____doc____annotations__rZpropertyr^rrrUrUos.CML% DDrrUirX)rWrZi )discordtelegramdefaultzDict[str, Dict[str, Any]]_PLATFORM_AUDIO_DEFAULTScP|xsdjjxsd}ttj |xs td}t t |d|}|j |jDcic] \}}| || c}}t|j dxs tdd}|j dd}t|ts#t|ttfr d|cxkrdksnd}t||t|Scc}}w) zSResolve upload constraints, including optional ``tts.delivery_profiles`` overrides.ridelivery_profilesrWrZrXrrH)rVrWrZ)r=r>rrjrrupdateitemsr7rr5r4rYrU) rVrrdefaults overrideskvrWrZs r_resolve_audio_delivery_profilerss  y ' ' ) / / 1 >YC,005\9QR[9\]H*.ABCHI OOioo&7Ida1=QTIJ#HLL1A$BCO1)<=MN<<5L<&jU|.T|(q( ^Z_`lZm nnJs  D" D" Fslice_oversizedc fg}d}|D]|rStkDrE|r|j|d}|jfdtdtDX|dj }|r"t|kDr|j|}|}|r|j||S)aGreedily join *pieces* with single spaces, starting a new chunk past *max_chars*. With ``slice_oversized`` an over-long piece flushes the running chunk and emits its hard slices as their own chunks (the tail slice is not merged with following pieces).c3.K|] }||zywNrf).0i max_charspieces r z"_pack_under_cap..sZQ%!i-0Zsr )lenappendextendranger>)piecesr|ruchunkscurrent candidater}s ` @r_pack_under_caprsFG   s5zI5 g& MMZ%3u:y:YZ Z iq(..0 s9~ 1 MM' "GG   g Mrc:t|j|dS)zGSplit one over-limit sentence on word boundaries, then hard boundaries.Trt)rsplit)sentencer|s r_split_oversized_sentencers 8>>+Y MMrcr|dkrt}dj|xsdj}|sgSt||kr|gSg}t ddt jd|DD]=}t||kr|j |#|jt||?t||S)zDSplit text under a provider cap without dropping normalized content.rrrwNc3<K|]}|jywry)r>)rzss rr~z&_split_text_for_tts..s!_!'')!_sz(?<=[.!?;:,])\s+) r<joinrrfilterrerrrr)textr| normalizedexpandedrs r_split_text_for_ttsrsA~, 4:2,,./J   :)#|H4!_RXX>QS]5^!_`L x=I % OOH % OO5h J K L 8Y //rcNg}g}d\}}|D]}t|jjt|jj }}|r,||z|j kDs||k7r|j |gd}}|j |||z|}}|r||gzS|S)z[Group final-encoded chunks under the size target; never mixes suffixes (can't concat-copy).)rrwr)rstatst_sizesuffixr=r^r) audio_pathsprofilegroupsr current_sizecurrent_suffixpathsizers r_pack_audio_files_for_deliveryrs FG#( L.CDz(00$t*2C2C2I2I2Kf  t+g.G.GG6UcKc MM' "$&\Gt'3d':Fn C")6WI 4f4r)timeoutcheckcapturec jtj|g||||tjtS)zDRun ``ffmpeg `` headless (no stdin, hidden window on Windows).)capture_outputrrstdin creationflags) subprocessrunDEVNULLr )ffmpegargsrrrs r _ffmpeg_runrs5 >>6/D/'X_ * 2 2BTBV XXrcT|r tj|yy#t$rYywxYw)zGBest-effort unlink (missing/locked files are ignored); None is a no-op.N)osremoveOSError)rs r_remove_quietlyrs.   IIdO    s  ''cX|jdr|S|jddddzS)zOPath a WAV-native engine writes to before conversion to *output_path*'s format..wav.rHr)endswithrsplit) output_paths r_wav_sidecar_pathrs4%..v6;bK.^s0[!E%++bggooa.@"A!B"E[sAAr)encodingrrrz-fconcatz-safe0rz-vn>.opusr)-c:arJrKrLrM64krOoff.mp3c3hK|]*}t|jjdk(,yw)r N)rrr=)rzrs rr~z&_concat_audio_files..ds(%bdd4j&7&7&=&=&?6&I%bs02rcopyx)rzffmpeg audio combine failed: %srri)% ValueErrorrrrrrrrrparentmkdir with_nameruuiduuid4hexstemrr write_textr@r=allrrexistsrrrrrrrrrrTimeoutExpired) rrrr destination concat_path temp_outputentriesrrrrexcs r_concat_audio_filesr5Ls 566 ;1 77??;q> *bggook.J J OOKNK 8 \\( #F {#KTD9''!K,<,<+=Qtzz|?O?O>PP[(\]K''!K,<,<+=Qtzz|?O?O>PPZ[f[m[mZn(opK"''[{[[w9k7D(GS$PST_P`bgh##))+ v):: Q QD v #%bVa%b"b VV$ $DV%>t%>S-=%>L    !k&8&8&:{?O?O?Q?Y?Y\]?] JJ{K 0{# !+. "D D ! " 8&--:N:Nw_g:N:himjm:no!+. "D D ! "  Z.. /?8#>>?!+. "D D ! "s1C=J4JK6K KKKK/c t|s td|D]_}t|jj}|jkDs6tdj d|djd|t|gd\dfd t |}|Dcgc]}|D]}|}}}g} t|d D](\} } } t|dkDrDjjd | d t| jxs j} tjj| tjj| k7r3| jj!d d tj"| | | jjjkDrtdj d| | j%t'| + | fD]} | | vst)| Scc}}w#D]} | | vst)| wxYw)aqPack final-encoded chunks under the hard upload limit -> ``(final_paths, combined_any)``. Groups are packed against the conservative target, then each combined artifact is checked at its real size; an over-limit group is split in half and retried. A failed combine returns the constituent files separately. A single chunk above the hard limit fails closed.z!No final-encoded TTS audio chunksz Final-encoded TTS chunk exceeds z delivery limit (z > z bytes): )Frc "t|dk(r t|Sdz jdjdddt j j j}t|t| }|s t|S j|t|jjjkrd|gSt|t!dt|dz}|d|||dzS)NrHrz .delivery03dr TrI)rlistr'r+r(r)r*rr5r@rrrrrWrr\) groupscratchcombinedmidpointbase combine_index combined_anyemitrscratch_outputsrs rrAz)_build_audio_delivery_files..emits u:?;  ..1TYYKys8K1TZZ\M]M]L^_c_j_j^k!lm&uc'lM]^; x( >   ( (G,B,B BL: !q#e*/*E)8$%U89-=(>>>rrH)startz.part02dTrzFinal TTS deliverable exceeds z delivery limit: )r: List[str]r_rE)r$rrrrWrVr enumeraterr'r+rrrrr%r&rrr@r)rrrrrrrr:packed final_pathsindexsourcer0r;r>r?r@rArBs `` @@@@@r_build_audio_delivery_filesrKss: <==LDz (( '(( (273C3C2DEs7#9#9":)D6KL LL  D!#O"*L-?? ,K AF & ?u4; ?4d ?d ?F ?K"63 - v v;?..DII;eE#;tF|GZGZGi^b^i^iFj)klK 77??6 "bggook&B B    $ $TD $ A JJv{ +     % %(>(> >=g>N>N=OO`al`mno o3{+, -)L(& )Gk)( )@' )Gk)( )s(H=H H7)H7)rrrr@r_zDict[str, Any])r6rr_z Optional[int]ry)rA Optional[str]rOptional[Dict[str, Any]]r_r4)rVrLrrMr_rU)rrEr|r4rur5r_rE)rr@r|r4r_rE)rr@r|r4r_rE)rrErrUr_zList[List[str]]) rr@rrErr4rr5rr5r_zsubprocess.CompletedProcess)rrLr_None)rr@r_r@)rr@rr@r_r@) rbytesrr4rr4rr4r_rO)rrOrr@r_r@)rr@r_rL)rr@r_r@)rr@r_r@)rrErr@rr5r_rL) rrErr@rrUrr5r_zTuple[List[str], bool])=rc __future__rloggingrrrrrrrr( dataclassesrpathlibrtypingrrrr r hermes_cli._subprocess_compatr tools.tts_command_providerr r rr getLoggerrrrr<r)rdr2r7rGGEMINI_TTS_SAMPLE_RATEGEMINI_TTS_CHANNELSGEMINI_TTS_SAMPLE_WIDTHrrUrjrsrrrrrrrrrrrrr r5rKrfrrr[s`#  !33<!!   + , 8      ,. #u"U5 4: .:c $:HSD+-D8  $ D D D#3DI#3TJ"2DI7K3KEI o o)A oMa o SX0N 0$ 5"57e]aX X X.1X?CXVZX Xc  *@'=T C C#& C C7: CY^ C:w,_d$Pjo6)6)),6)7K6)bf6)6)r