3h\ ( S r SSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSK
J r SSK J
r
SSKJrJrJrJrJrJrJrJr SSKJrJr SSKrSSKrSS K J r J r J r J r SS
K!J"r" SS K#J$r$ SS K%J&r&J'r'J(r(J)r) SS
KJ*r*J+r+ S\,S\-S\\\,\,4 \,4 4S jr.S\\/\,4 S\/4S jr0S\/4S jr1S\,S\-S\-4S jr2S\,S\-4S jr3S\,S\-S\-4S jr4S\\/\,4 S \-S\\,SS4 4S jr5S \"S \\/\,4 S\/4S jr6S\/4S! jr7S"\/S#\/S$\/S\/4S% jr8S&\"S\-4S' jr9 " S( S)5 r:g)*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)
TextIOWrapper)Queue)AsyncGeneratorContextManagerDict GeneratorListOptionalTupleUnion)escapeunescape )
DEFAULT_VOICESEC_MS_GEC_VERSION WSS_HEADERSWSS_URL) TTSConfig)DRM)NoAudioReceivedUnexpectedResponseUnknownResponseWebSocketError)CommunicateStateTTSChunkdata
header_lengthreturnc [ U [ 5 ( d [ S5 e0 nU SU R S5 H nUR SS5 u pEXRU' M X US- S 4$ )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
:r )
isinstancebytes TypeErrorsplit)r r headerslinekeyvalues L/var/www/auris/envauris/lib/python3.13/site-packages/edge_tts/communicate.pyget_headers_and_datar, ( so dE " ",--G^m$**73ZZa(
4 *,- -- stringc n [ U [ 5 ( a U R S5 n [ U [ 5 ( d [ S5 e[ U 5 n[
U5 HE u p#[ U5 nSUs=:: a S:: d$ O SUs=:: a S:: d O SUs=:: a S:: d M= O MA S X' MG S
R U5 $ ) 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 bytesr ) r# r$ decodestrr% list enumerateordjoin)r. charsidxcharcodes r+ remove_incompatible_charactersrB @ s &% w' fc " "566F|E u% I
NNd 0b 0bD6FB6F6F EJ &
775>r- c ^ [ [ R " 5 5 R SS5 $ )zJ
Returns a UUID without dashes.
Returns:
str: A UUID without dashes.
-r7 )r9 uuiduuid4replace r- r+
connect_idrI \ s" tzz| $ $S" --r- textlimitc ^ U R SSU5 nUS: a U R SSU5 nU$ )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.
r )rfind)rJ rK split_ats r+ (_find_last_newline_or_space_within_limitrQ f s4 " zz%E*H!|::dAu- Or- text_segmentc [ U 5 nUS: a U SU R S5 U$ U$ ! [ a US- n Of = fUS: a M6 N )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).
r Nr0 r )lenr8 UnicodeDecodeError)rR rP s r+ _find_safe_utf8_split_pointrV ~ s^ < H
Q, ( # * *7 3O
O " MH Q,s + ==rP c US: aH SU SU ; a? U R SSU5 nU R SX!5 S:w a U$ UnUS: a SU SU ; a M? U$ )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.
r &N ;)rindexfind)rJ rP ampersand_indexs r+ "_adjust_split_point_for_xml_entityr^ sk " Q,44 ?2 ++dAx8 99T? 5 ;
O # Q,44 ?2 Or- byte_lengthc # # [ U [ 5 ( a U R S5 n [ U [ 5 ( d [ S5 eUS:: a [ S5 e[
U 5 U: as [ X5 nUS: a [ U 5 n[ X5 nUS: a [ S5 eU SU R 5 nU( a Uv XS: a UOSS n [
U 5 U: a Ms U R 5 nU( a Uv gg7f)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).
r0 ztext must be str or bytesr z"byte_length must be greater than 0zTMaximum byte length is too small or invalid text structure near '&' or invalid UTF-8Nr ) r# r9 encoder$ r%
ValueErrorrT rQ rV r^ strip)rJ r_ rP chunkremaining_chunks r+ split_text_by_byte_lengthrf s 6 $ {{7# dE " "344a=>>
d)k
!;DN a<248H 6dE a< C
Yh%%' K 1 H!565 d)k
!: jjlO s CC9 C9tc escaped_textc [ U[ 5 ( a UR S5 nSU R SU R SU R
SU R SU S3 $ )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.
r0 z_z)r# r$ r8 voicepitchratevolume)rg rh s r+ mkssmlrn sg ,&&#**73 z " 88*HRWWIZ {" . r- c V [ R " S[ R " 5 5 $ )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))timestrftimegmtimerH r- r+ date_to_stringrs s ==Ddkkm r-
request_id timestampssmlc SU SU SU 3$ )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
rH )rt ru rv s r+ ssml_headers_plus_datarx & s) zl # k " & r-
tts_configc
t Sn[ [ [ 5 [ 5 [ U S5 5 5 S- nX-
$ )zxCalculates the maximum message size for the given voice, rate, and volume.
Returns:
int: The maximum message size.
i r7 2 )rT rx rI rs rn )ry websocket_max_sizeoverhead_per_messages r+ calc_max_mesg_sizer~ 7 sI $ " z2&
44r- c T \ rS rSrSr\4SSSSSSSS.S \S
\S \S \S
\S\\R S\\ S\\
S\\
4S jjjr S\ S\
4S jrS\\
S4 4S jrS\\
S4 4S jr S S\\\ 4 S\\\\ 4 SS4S jjrS\\
SS4 4S jr S S\\\ 4 S\\\\ 4 SS4S jjrS rg) CommunicateiK z
Communicate with the service.
z+0%z+0HzN
< )rl rm rk connectorproxyconnect_timeoutreceive_timeoutrJ rj rl rm rk r r r r c Z [ X#XE5 U l [ U[ 5 ( d [ S5 e[ [
[ U5 5 [ U R 5 5 U l Ub [ U[ 5 ( d [ S5 eXpl
[ U[ 5 ( d [ S5 e[ U [ 5 ( d [ S5 e[ R " S S UU S9U l Ub* [ U[ R 5 ( d [ S5 eX`l SSSS S
.U l g ) Nztext must be strzproxy must be strzconnect_timeout must be intzreceive_timeout must be int)totalconnect sock_connect sock_readz'connector must be aiohttp.BaseConnectorr- r F) partial_textoffset_compensationlast_duration_offsetstream_was_called)r ry r# r9 r% rf r rB r~ textsr intaiohttp
ClientTimeoutsession_timeout
BaseConnectorr state)
selfrJ rj rl rm rk r r r r s
r+ __init__Communicate.__init__P s $E? $$$ ./ / / 1$7 8 t /
Zs%;%; /0 0$)
/3// 9: :/3// 9: : & 4 4(%
Iw?T?T)U)U EF F:C #$$%!& (
r- r r c [ R " U5 S H] nUS nUS:X a; US S U R S - nUS S nUUU[ US S S 5 S
.s $ US ; a MQ [ S U 35 e [ S
5 e)NMetadataType WordBoundaryDataOffsetr DurationrJ Text)typeoffsetdurationrJ )
SessionEndzUnknown metadata type: z No WordBoundary metadata found)jsonloadsr r r r )r r meta_obj meta_typecurrent_offsetcurrent_durations r+ __parse_metadata Communicate.__parse_metadata s
4(4H (IN* V$X.# T R S[ 5 S35 I Sh vN g N7f)z)Sends the command request to the service.z X-Timestamp:z
Content-Type:application/json; charset=utf-8
Path:speech.config
{"context":{"synthesis":{"audio":{"metadataoptions":{"sentenceBoundaryEnabled":"false","wordBoundaryEnabled":"true"},"outputFormat":"audio-24khz-48kbitrate-mono-mp3"}}}}
N)send_strrs ) websockets r+ send_command_request2Communicate.__stream..send_command_request s3 $$ ~ / 0 1
s !,*,c ># TR [ [ 5 [ 5 [ T R
T R S 5 5 5 I Sh vN g N7f)z&Sends the SSML request to the service.r N)r rx rI rs rn ry r )r r s r+ send_ssml_request/Communicate.__stream..send_ssml_request sL $$& L"$
>2
s AA AA F)cafileT)r trust_envtimeoutz &Sec-MS-GEC=z&Sec-MS-GEC-Version=z&ConnectionId= )compressr r' sslr0 s
s Paths audio.metadatar r r s turn.endr i )s responses
turn.startzUnknown path receivedr" zBWe received a binary message, but it is missing the header length.bigz9The header length is greater than the length of the data.s audioz3Received binary message, but the path is not audio.s Content-Type)s
audio/mpegNz=Received binary message, but with an unexpected Content-Type.r z"#5"6 Z\N
, ** )
&( ( (#% % %"+ Z
h==G$5$5$:$::*2--*>*>w*GL';$&7&7 &D($J &>>'48D 00*.*?*?*E -- ,H 5
8S S
#9: ,<@JJ 2=
#89
#89YF9 %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
*.&#*D99 ]]g&7&7&=&==()1
N; ON9O O1"O#O1+O.N;1N;4N77N;9O;O O O OO1O. O O.*O1c # U R S ( a [ S5 eSU R S' U R H/ U R S' U R 5 Sh vN nU7v M g N
M9 ! [ R
aT nUR S:w a e [ R " U5 U R 5 Sh vN nU7v M
SnAM SnAff = f7f)a=
Streams audio and metadata from the service.
Raises:
NoAudioReceived: If no audio is received from the service.
UnexpectedResponse: If the response from the service is unexpected.
UnknownResponse: If the response from the service is unknown.
WebSocketError: If there is an error with the websocket.
r z stream can only be called once.Tr Ni ) r RuntimeErrorr _Communicate__streamr ClientResponseErrorstatusr handle_client_response_error)r messagees r+ streamCommunicate.stream. s ::) * @A A*.
&' +/**DJJ~ &
"%)]]_ "'!M +5"_..
"88s?003%)]]_ " "'!M &5
"sr A C!A6 A3"A1#A3&A6.C!1A33A64C!6C
7CCC
C
CC!C C! audio_fnamemetadata_fnamec # Ub [ USSS9O [ 5 nU [ US5 nU R 5 Sh vN nUS S:X a UR US 5 M( [ U[
5 ( d M? US S :X d MJ [ R " XS5 UR S
5 Ms Nn
SSS5 O! , ( d f O= fSSS5 g! , ( d f g= f7f) z5
Save the audio and metadata to the specified files.
Nwr0 )encodingwbr r r r
)openr r writer# r r dump)r r r metadatar r s r+ saveCommunicate.saveM s )
w 7
tK.%!%
)g6?g-KK0 x 77 >9IIg0 NN4(
) /..XXXsa C%
CB:B0B.
B03B::B:)B:.B00B:1 C:
C C C%
C" C%c #
^ # S[ SS4U 4S jjn[ 5 n[ R R 5 nUR X5 UR 5 nUc OUv M SSS5 g! , ( d f g= f7f)z-Synchronous interface for async stream methodqueuer Nc >^ SU U4S jjn[ R " 5 n[ R " U5 UR U" 5 5 UR 5 g )Nc ># TR 5 S h vN n TR U 5 M N
TR S 5 g 7fN)r put)itemr r s r+ get_itemsECommunicate.stream_sync..fetch_async_items..get_itemsi s3 "&++- $$IIdO$- $s A202A2Ar )asyncionew_event_loopset_event_looprun_until_completeclose)r r loopr s ` r+ fetch_async_items2Communicate.stream_sync..fetch_async_itemsh sD
))+D " "4 ( # #IK 0 JJLr- )r
concurrentfuturesThreadPoolExecutorsubmitr )r r r executorr s ` r+ stream_syncCommunicate.stream_synce sn U t w
2
2
4 OO - 5 yy{<
5
4
4s 9B-A2) B2
B <Bc [ R R 5 nUR [ R
U R
X5 5 nUR 5 SSS5 g! , ( d f g= f)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~ sO
2
2
4 __ TYY{ CF
MMO 5
4
4s A A((
A6)r r r r r ry r )__name__
__module__ __qualname____firstlineno____doc__r r9 r r r r r r$ r r r r r r
r r r r __static_attributes__rH r- r+ r r K sy #6
59 #)+)+6
6
6
6
6
6
G 1 126
}6
"# 6
"# 6
pCU Cx C&Qx~ > Qf " $ ' "D 7;)3:&) !sEz!23)
)0Yxt'; < 8 7;
3:&
!sEz!23
r- r );r r concurrent.futuresr r r rp rE
contextlibr ior r r typingr r r r r
r r r
xml.sax.saxutilsr r r r constantsr r r r data_classesr drmr
exceptionsr r r r r r r$ r r, r9 rB rI rQ rV r^ rf rn rs rx r~ r rH r- r+ r s I
" . N N # /.
. #.
4u u $%.05e+< 8.C .5 0e 8U c c