+
Wi] R t ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIt^ RIH t ^ RI
H t ^ RI H
t
^ RIHtHtHtHtHtHtHtHt ^ RIHtHt ^ RIt^ RIt^ RI H t ^RI H t H t H!t!H"t"H#t#H$t$ ^R I%H&t& ^R
I'H(t( ^R I)H*t*H+t+H,t,H-t- ^R IH.t.H/t/ ]P` ! ]Pb ! 4 R
7 t2R R lt3R R lt4R R lt5R R lt6R R lt7R R lt8R R lt9R R lt:R R lt;R R! lt< ! R" R#4 t=R# )$zCommunicate with the service. Only the Communicate class should be used by
end-users. The other classes and functions are for internal use only.N) nullcontext)
TextIOWrapperQueue)AsyncGeneratorContextManagerDict GeneratorListOptionalTupleUnion)escapeunescape)Literal)
DEFAULT_VOICEMP3_BITRATE_BPSSEC_MS_GEC_VERSIONTICKS_PER_SECOND WSS_HEADERSWSS_URL) TTSConfig)DRM)NoAudioReceivedUnexpectedResponseUnknownResponseWebSocketError)CommunicateStateTTSChunk)cafilec V ^8 d QhR\ R\ R\ \ \ \ 3, \ 3, /# ) data
header_lengthreturn)bytesintr r )formats "S/home/ubuntu/hermes-agent/venv/lib/python3.14/site-packages/edge_tts/communicate.py __annotate__r) 2 s7 . .
. #.
4u u $%. c \ V \ 4 ' g \ R4 h/ pV RV P R4 F pVP R^4 w rEWRV& K W V^, R 3# )z
Returns the headers and data from the given data.
Args:
data (bytes): The data to be parsed.
header_length (int): The length of the header.
Returns:
tuple: The headers and data to be used in the request.
zdata must be bytesNs
:)
isinstancer% TypeErrorsplit)r" r# headerslinekeyvalues && r( get_headers_and_datar4 2 so dE " ",--G^m$**73ZZa(
4 *,- --r* c R V ^8 d QhR\ \ \ 3, R\ /# )r! stringr$ )r
strr% )r' s "r( r) r) J s# 5e+< r* c ~ \ V \ 4 ' d V P R4 p \ V \ 4 ' g \ R4 h\ V 4 p\
V4 FK w r#\ V4 p^ Tu;8: d ^8: g) M ^ Tu;8: d ^ 8: g M ^Tu;8: d
^ 8: g KC M KG RW& KM RP V4 # )a/
The service does not support a couple character ranges.
Most important being the vertical tab character which is
commonly present in OCR-ed PDFs. Not doing this will
result in an error from the service.
Args:
string (str or bytes): The string to be cleaned.
Returns:
str: The cleaned string.
utf-8zstring must be str or bytes ) r- r% decoder7 r. list enumerateordjoin)r6 charsidxcharcodes & r( remove_incompatible_charactersrE J s &% w' fc " "566F|E u% I
NNd 0b 0bD6FB6F6F EJ &
775>r* c $ V ^8 d QhR\ /# r! r$ r7 )r' s "r( r) r) f s C r* c @ \ P ! 4 P # )zJ
Returns a UUID without dashes.
Returns:
str: A UUID without dashes.
)uuiduuid4hex r* r(
connect_idrN f s ::< r* c < V ^8 d QhR\ R\ R\ /# )r! textlimitr$ r% r& )r' s "r( r) r) p s! 5 r* c ` V P R^ V4 pV^ 8 d V P R^ V4 pV# )a
Finds the index of the rightmost preferred split character (newline or space)
within the initial `limit` bytes of the text.
This helps find a natural word or sentence boundary for splitting, prioritizing
newlines over spaces.
Args:
text (bytes): The byte string to search within.
limit (int): The maximum index (exclusive) to search up to.
Returns:
int: The index of the last found newline or space within the limit,
or -1 if neither is found in that range.
)rfind)rP rQ split_ats && r( (_find_last_newline_or_space_within_limitrX p s4 " zz%E*H!|::dAu- Or* c 0 V ^8 d QhR\ R\ /# )r! text_segmentr$ rR )r' s "r( r) r) s e r* c \ V 4 pV^ 8 d V RV P R4 V# V# \ d T^, p K7 i ; i)a
Finds the rightmost possible byte index such that the
segment `text_segment[:index]` is a valid UTF-8 sequence.
This prevents splitting in the middle of a multi-byte UTF-8 character.
Args:
text_segment (bytes): The byte segment being considered for splitting.
Returns:
int: The index of the safe split point. Returns 0 if no valid split
point is found (e.g., if the first byte is part of a multi-byte
sequence longer than the limit allows).
Nr9 )lenr< UnicodeDecodeError)rZ rW s & r( _find_safe_utf8_split_pointr^ sU < H
Q, ( # * *7 3O
O " MH s , AAc < V ^8 d QhR\ R\ R\ /# )r! rP rW r$ rR )r' s "r( r) r) s! U c c r* c V^ 8 d< RV RV 9 d2 V P R^ V4 pV P RW!4 R8w d V# TpKB V# )aq
Adjusts a proposed split point backward to prevent splitting inside an XML entity.
For example, if `text` is `b"this & that"` and `split_at` falls between
`&` and `;`, this function moves `split_at` to the index before `&`.
Args:
text (bytes): The text segment being considered.
split_at (int): The proposed split point index, determined by whitespace
or UTF-8 safety.
Returns:
int: The adjusted split point index. It will be moved to the '&'
if an unterminated entity is detected right before the original `split_at`.
Otherwise, the original `split_at` is returned.
&N ;)rindexfind)rP rW ampersand_indexs && r( "_adjust_split_point_for_xml_entityrg sS " Q,44 ?2 ++dAx8 99T? 5 ;
O # Or* c z V ^8 d QhR\ \ \ 3, R\ R\ \ RR3, /# )r! rP byte_lengthr$ N)r
r7 r% r& r )r' s "r( r) r) s> B B
U
B *-B udD !B r* c # " \ V \ 4 ' d V P R4 p \ V \ 4 ' g \ R4 hV^ 8: d \ R4 h\
V 4 V8 di \ W4 pV^ 8 d \ V 4 p\ W4 pV^ 8 d \ R4 hV RV P 4 pV' d Vx Y^ 8 d TM^R p Kx V P 4 pV' d Vx R# R# 5i)a
Splits text into chunks, each not exceeding a maximum byte length.
This function prioritizes splitting at natural boundaries (newlines, spaces)
while ensuring that:
1. No chunk exceeds `byte_length` bytes.
2. Chunks do not end with an incomplete UTF-8 multi-byte character.
3. Chunks do not split XML entities (like `&`) in the middle.
Args:
text (str or bytes): The input text. If str, it's encoded to UTF-8.
byte_length (int): The maximum allowed byte length for any yielded chunk.
Must be positive.
Yields:
bytes: Text chunks (UTF-8 encoded, stripped of leading/trailing whitespace)
that conform to the byte length and integrity constraints.
Raises:
TypeError: If `text` is not str or bytes.
ValueError: If `byte_length` is not positive, or if a split point
cannot be determined (e.g., due to extremely small byte_length
relative to character/entity sizes).
r9 ztext must be str or bytesz"byte_length must be greater than 0zTMaximum byte length is too small or invalid text structure near '&' or invalid UTF-8N) r- r7 encoder% r.
ValueErrorr\ rX r^ rg strip)rP ri rW chunkremaining_chunks && r( split_text_by_byte_lengthrp s 6 $ {{7# dE " "344a=>>
d)k
!;DN a<248H 6dE a< C
Yh%%' K 1 H!56 jjlO s B?C5*C5-C5c ^ V ^8 d QhR\ R\ \ \ 3, R\ /# )r! tc escaped_textr$ )r r
r7 r% )r' s "r( r) r) s* y c5j(9 c r* c \ V\ 4 ' d VP R4 pRV P RV P RV P
RV P RV R2 # )z
Creates a SSML string from the given parameters.
Args:
tc (TTSConfig): The TTS configuration.
escaped_text (str or bytes): The escaped text. If bytes, it must be UTF-8 encoded.
Returns:
str: The SSML string.
r9 z_z)r- r% r< voicepitchratevolume)rr rs s &&r( mkssmlry sg ,&&#**73 z " 88*HRWWIZ {" . r* c $ V ^8 d QhR\ /# rG rH )r' s "r( r) r) s
r* c V \ P ! R\ P ! 4 4 # )zW
Return Javascript-style date string.
Returns:
str: Javascript-style date string.
z:%a %b %d %Y %H:%M:%S GMT+0000 (Coordinated Universal Time))timestrftimegmtimerM r* r( date_to_stringr s ==Ddkkm r* c H V ^8 d QhR\ R\ R\ R\ /# )r!
request_id timestampssmlr$ rH )r' s "r( r) r) 0 s( s s # # r* c RV RV RV 2# )z|
Returns the headers and data to be used in the request.
Returns:
str: The headers and data to be used in the request.
z X-RequestId:z1
Content-Type:application/ssml+xml
X-Timestamp:zZ
Path:ssml
rM )r r r s &&&r( ssml_headers_plus_datar 0 s) zl # k " & r* c a ] tR tRt o Rt]3RRRRRRRR R
R R R R
^
R^ Kr* c T a a
" R V V
3R llpR V V
3R llpRp\ P ! S P RS P R7 ;_uu_4 GRj xL
qDP \
R\
4 R \ P ! 4 R
\ 2^S P \ P ! \ 4 \ R 7 ;_uu_4 GRj xL
o
V! 4 G Rj xL
V! 4 G Rj xL
S
Rj xL
pVP \ P P 8X d VP" P% R 4 p\' WfP) R
4 4 w rxVP+ RR4 p V R8X d= S P- V4 p
V
5x V
R, V
R, , S P. R& K V R8X d S P1 4 EMV R%9 d \3 R4 hK VP \ P P4 8X EdB \7 VP" 4 ^8 d \9 R4 h\: P= VP" R, R4 p V \7 VP" 4 8 d \9 R4 h\' VP" V 4 w rxVP+ R4 R8w d \9 R4 hVP+ RR4 p V R&9 d \9 R 4 hV f \7 V4 ^ 8X d EK \9 R 4 h\7 V4 ^ 8X d \9 R 4 hRpS P. R ;;, \7 V4 ,
uu& R R!R"V/5x EKX VP \ P P> 8X g EK \A VP" ' d VP" 4 hR#4 hV' g \C R$4 hRRR4 GRj xL
RRR4 GRj xL
R# EL EL EL EL ELEDLG L( + GRj xL
' g i L?; i L6 + GRj xL
' g i R# ; i5i)'c V ^8 d QhRR/# r rM )r' s "r( r) *Communicate.__stream..__annotate__ s D r* c <" SP P R8H p V ' d RMRpV ' g RMRpSP R\ 4 RV RV R24 G Rj xL
R# L5i) z)Sends the command request to the service.r truefalsez X-Timestamp:z
Content-Type:application/json; charset=utf-8
Path:speech.config
{"context":{"synthesis":{"audio":{"metadataoptions":{"sentenceBoundaryEnabled":"z","wordBoundaryEnabled":"z9"},"outputFormat":"audio-24khz-48kbitrate-mono-mp3"}}}}
N)r r send_strr )
word_boundarywdsqr websockets r( send_command_request2Communicate.__stream..send_command_request sm OO 4 4 FM(gB ,'B$$ ~ / 0 1. /1T1J2$ O
s -A$*A$A" A$c V ^8 d QhRR/# r rM )r' s "r( r) r s r* c <" SP \ \ 4 \ 4 \ S P
S P R, 4 4 4 G Rj xL
R# L5i)z&Sends the SSML request to the service.r N)r r rN r ry r r )r r s r( send_ssml_request/Communicate.__stream..send_ssml_request sL $$& L"$
>2
s AA!A A!FT)r trust_envtimeoutNz&ConnectionId=z &Sec-MS-GEC=z&Sec-MS-GEC-Version=)compressr r0 sslr9 s
s Paths audio.metadatar r r s turn.endzUnknown path receivedzBWe received a binary message, but it is missing the header length.:Nr! Nbigz9The header length is greater than the length of the data.s audioz3Received binary message, but the path is not audio.s Content-Typez=Received binary message, but with an unexpected Content-Type.z*>w*GL';$&7&7 &D($J &>>'48D 00*.*?*?*E -- ,H 5
8S S
#9: , 002 %AA -.E FF B ]]g&7&7&>&>>8==)A- 0 `
%(NN8==3De$LM$s8=='99 0 W
(<
}($J
"~~g.(: 0 Q $.>>/4#HL#+@@ 0 [
$+ t9> $ 1 Z
4yA~ 0 X
*.&JJ 23s4y@3!7FD99 ]]g&7&7&=&==()1
IIg0 NN4(
) /...XXXXsc 'DC<C C
CC
=C C ))C C
C C< C/
*C<2
D< D
Dc 6 < V ^8 d QhRS[ S[RR3, /# r )r r )r' r s "r( r) r o s Yxt'; < r* c # a " R V 3R llp\ 4 p\ P P 4 ;_uu_ 4 pVP W4 VP 4 pVf MVx K RRR4 R# + ' g i R# ; i5i)z-Synchronous interface for async stream methodc ( V ^8 d QhR\ RR/# )r! queuer$ Nr )r' s "r( r) -Communicate.stream_sync..__annotate__r s U t r* c <a R V V3R llp\ P ! 4 p\ P ! V4 VP V! 4 4 VP 4 R# )c V ^8 d QhRR/# r rM )r' s "r( r) HCommunicate.stream_sync..fetch_async_items..__annotate__s s
T
r* c <" SP 4 R j xL
p SP V 4 K LDSP R 4 R # 5iN)r put)itemr r s r( get_itemsECommunicate.stream_sync..fetch_async_items..get_itemss s8 "&++- $ $$IIdO$- $s A313A3AN)asyncionew_event_loopset_event_looprun_until_completeclose)r r loopr s f r( fetch_async_items2Communicate.stream_sync..fetch_async_itemsr sD
))+D " "4 ( # #IK 0 JJLr* N)r
concurrentfuturesThreadPoolExecutorsubmitr )r r r executorr s f r( stream_syncCommunicate.stream_synco sf w
2
2
4
4 OO - 5 yy{<
5
4
4
4s :B .A5+
B 5 B B c f < V ^8 d QhRS[ S[S[3, RS[S[ S[S[3, , RR/# r r )r' r s "r( r) r s@
3:&
!sEz!23
r* c
\ P P 4 ;_uu_ 4 pVP \ P
V P
W4 4 pVP 4 RRR4 R# + ' g i R# ; i)z,Synchronous interface for async save method.N)r" r# r$ r% r runr
result)r r r r& futures &&& r( save_syncCommunicate.save_sync sU
2
2
4
4 __ TYY{ CF
MMO 5
4
4
4s A A11 B )r r r r r r r )__name__
__module__ __qualname____firstlineno____doc__r r r r r r r
r' r. __static_attributes____classdictcell__)r s @r( r r A s #9
9
9
9
AS9
6:9
$9
*,9
*,9
9
vC C&, ,(K KZ " "B) )0 2
r* r )>r4 r concurrent.futuresr" r r r| rJ
contextlibr ior r r typingr r r r r
r r r
xml.sax.saxutilsr r r certifityping_extensionsr constantsr r r r r r data_classesr drmr
exceptionsr r r r r r create_default_contextwherer r4 rE rN rX r^ rg rp ry r r r rM r* r( rD s I
" . % $ / % %W]]_ =.08 08