qiCdZddlZddlZddlZddlZddlmZmZddlm Z m Z m Z m Z m Z mZmZmZmZmZddlZddlZddlmZddlmZdeZddlmZdd lmZmZm Z m!Z! dd l"m#Z$dd l%m&Z&ddl+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4ddl5m6Z6ddl7m8Z8m9Z9m:Z:ddl;mGdde:Z?y#e'$r7Z(ejRd e(ejRd e*de(dZ([(wwxYw)uInworld AI Text-to-Speech Service Implementation. Contains two TTS services: - InworldTTSService: WebSocket-based TTS service. - InworldHttpTTSService: HTTP-based TTS service. Inworld’s text-to-speech (TTS) models offer ultra-realistic, context-aware speech synthesis and precise voice cloning capabilities, enabling developers to build natural and engaging experiences with human-like speech quality at an accessible price point. N) dataclassfield) AnyAsyncGeneratorClassVarDictListLiteralMappingOptionalSelfTuple)logger)versionzpipecat/) BaseModel) NOT_GIVEN TTSSettings _NotGiven_warn_deprecated_param)connect)Statez Exception: zLIn order to use Inworld WebSocket TTS, you need to `pip install websockets`.zMissing module: ) CancelFrameEndFrame ErrorFrameFrameInterruptionFrame StartFrameTTSAudioRawFrameTTSStartedFrameTTSStoppedFrame)FrameDirection)TextAggregationMode TTSServiceWebsocketTTSService) traced_ttsceZdZUdZedZeezed<edZ eezed<ddd Z e e e e fed <ed ee efd effd ZxZS)InworldTTSSettingszSettings for InworldTTSService and InworldHttpTTSService. Parameters: speaking_rate: Speaking rate for speech synthesis. temperature: Temperature for speech synthesis. ctSNrN/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/inworld/tts.pyzInworldTTSSettings.NsYr,)default_factory speaking_ratectSr)r*r+r,r-r.zInworldTTSSettings.Os9r, temperaturevoicemodel)voiceIdmodelId_aliasessettingsreturnct|}|jdd}t|tr!|jd|j dt ||S)zRConstruct settings from a plain dict, destructuring legacy nested ``audioConfig``. audioConfigNr0 speakingRate)dictpop isinstance setdefaultgetsuper from_mapping)clsr8flatnested __class__s r-rCzInworldTTSSettings.from_mappingVsOH~-. fd # OOOVZZ-G Hw#D))r,)__name__ __module__ __qualname____doc__rr0floatr__annotations__r2r7rrstr classmethodr rr rC __classcell__rGs@r-r'r'Es(-=N'OM59$O%*;L%MK"M*HhtCH~& *GCH$5*$**r,r'ceZdZUdZeZeed<GddeZddddddddd d e d e jd e e d e e de de ede de edde ede effdZde fdZdeffd Zej*fdedeffd Zdee efdeeee efeffdZede de deedffd Z d!e jBde deedffd"Z"d!e jBde deedffd#Z#d$e$de deedffd%Z%xZ&S)&InworldHttpTTSServicezInworld AI HTTP-based TTS service. Supports both streaming and non-streaming modes via the `streaming` parameter. Outputs LINEAR16 audio at configurable sample rates with word-level timestamps. _settingscTeZdZUdZdZeeed<dZeeed<dZ ee ded<y)!InworldHttpTTSService.InputParamsaInput parameters for Inworld TTS configuration. .. deprecated:: 0.0.105 Use ``InworldTTSSettings`` directly via the ``settings`` parameter instead. Parameters: temperature: Temperature for speech synthesis. speaking_rate: Speaking rate for speech synthesis. timestamp_transport_strategy: The strategy to use for timestamp transport. Nr2r0ASYNCrWSYNCtimestamp_transport_strategy) rHrIrJrKr2r rLrMr0rZr r+r,r- InputParamsrVjs: (, Xe_+)- x-KR$hw/G&HRr,r[NTLINEAR16rW)voice_idr4 streaming sample_rateencodingrZparamsr8api_keyaiohttp_sessionr]r4r^r_r`rZrXrar8c <tddddd} |tdtd|| _|tdtd|| _| dtdt| sR| j| j| _| j | j | _| j | j }| | j| t |$dd d d || d | ||_ ||_ ||_ d |_ |rd |_nd|_d|_||_d|_||_y)aInitialize the Inworld TTS service. Args: api_key: Inworld API key. aiohttp_session: aiohttp ClientSession for HTTP requests. voice_id: ID of the voice to use for synthesis. .. deprecated:: 0.0.105 Use ``settings=InworldTTSSettings(voice=...)`` instead. model: ID of the model to use for synthesis. .. deprecated:: 0.0.105 Use ``settings=InworldTTSSettings(model=...)`` instead. streaming: Whether to use streaming mode. sample_rate: Audio sample rate in Hz. encoding: Audio encoding format. timestamp_transport_strategy: Strategy for timestamp transport ("ASYNC" or "SYNC"). Defaults to "ASYNC". params: Input parameters for Inworld TTS configuration. .. deprecated:: 0.0.105 Use ``settings=InworldTTSSettings(...)`` instead. settings: Runtime-updatable settings. When provided alongside deprecated parameters, ``settings`` values take precedence. **kwargs: Additional arguments passed to the parent class. inworld-tts-1.5-maxAshleyNr4r3languager0r2r]r3r4raFT)push_text_framespush_stop_framespush_start_framer_r8WORDz*https://api.inworld.ai/tts/v1/voice:streamz#https://api.inworld.ai/tts/v1/voicerr+)r'rr3r4r0r2rZ apply_updaterB__init___api_key_session _streaming_timestamp_type _base_url_cumulative_time_audio_encoding_audio_sample_rate_timestamp_transport_strategy)selfrbrcr]r4r^r_r`rZrar8kwargsdefault_settingsrGs r-rozInworldHttpTTSService.__init__zsQZ.'     ":/A7 K%-  "   "7,> H%*  "   "8-? @''35;5I5I$2%%1393E3E$066B393V3V0    ) )( 3  "!!#%      ' #% IDNBDN # ("#-I*r,r9cy)zCheck if this service can generate processing metrics. Returns: True, as Inworld TTS service supports metrics generation. Tr+rys r-can_generate_metricsz*InworldHttpTTSService.can_generate_metrics r,framecbKt||d{|j|_y7w)zZStart the Inworld TTS service. Args: frame: The start frame. N)rBstartr_rwryrrGs r-rzInworldHttpTTSService.starts. gmE""""&"2"2 #s /-/ directioncKt|||d{t|ttfr3d|_t|tr|j dgd{yyy7N7 w)Push a frame and handle state changes. Args: frame: The frame to push. direction: The direction to push the frame. NrmResetr)rB push_framer?rr ruadd_word_timestampsryrrrGs r-rz InworldHttpTTSService.push_frameslg  222 e/A B$'D !%1.. ~>>>2 C 3?s"A*A&AA*A(A*(A*timestamp_infocrg}d}|jdi}|jdg}|jdg}|jdg}|rf|rdt|t|k(rMt|D]*\}} |j||z} |j | | f,|rt|dkDr|d}||fS)aCalculate word timestamps from Inworld HTTP API word-level response. Note: Inworld HTTP provides timestamps that reset for each request. We track cumulative time across requests to maintain continuity. Args: timestamp_info: The timestamp information from Inworld API. Returns: Tuple of (word_times, chunk_end_time) where chunk_end_time is the end time of the last word in this chunk (not cumulative). rm wordAlignmentwordswordStartTimeSecondswordEndTimeSecondsr)rAlen enumerateruappend) ryr word_timeschunk_end_time alignmentr start_times end_timesiword word_starts r-_calculate_word_timesz+InworldHttpTTSService._calculate_word_timess /1 "&&;  gr*mm$:B? MM"6; [SZ3{3C%C$U+ 64!22[^C !!4"45 6 S^a/!*2N++r,text context_idcKtj|d|d|jd|j|jd}|j j |j j |d<||j j|j j|d}|j j|j j|d<|j|d <|j|j|d <ttj}d |jd t |d } |j"j%|j&||4d{}|j(dk7ro|j+d{}tj,d|d|t/d| dddd{|j1d{y|jr!|j3||23d{} | |j5||23d{} | 777o7Y736n76dddd{7n#1d{7swYnxYw|j7|d{7n5#t8$r)} |j;d| | d{7Yd} ~ nd} ~ wwxYw|j1d{7y#|j1d{7wxYww)zGenerate TTS audio for the given text. Args: text: The text to generate TTS audio for. context_id: Unique identifier for this TTS context. Returns: An asynchronous generator of frames. z: Generating TTS [z ] (streaming=) audioEncodingsampleRateHertzNr<)rr5r6r;r2 timestampTypetimestampTransportStrategyBasic zapplication/json) Authorizationz Content-Type X-User-Agent X-Request-Id)jsonheaderszInworld API error (request_id=z): Inworld API error: errorUnknown error occurred:  error_msg exception)rdebugrrrvrwrTr0r3r4r2rsrxrNuuiduuid4rp USER_AGENTrqpostrtstatusrrrstop_all_metrics_process_streaming_response_process_non_streaming_responsestart_tts_usage_metrics Exception push_error) ryrr audio_configpayload request_idrresponse error_textres r-run_ttszInworldHttpTTSService.run_tts!s  v/v]4??BSSTUV"11#66  >> ' ' 3+/>>+G+GL (~~++~~++'   >> % % 1%)^^%?%?GM "$(#7#7  - - 9484V4VG0 1& %dmm_5.&&   *}}))Wg* $ $??c)'/}}!6JLL#A*SQ[P\!]^$-@ +MNN $ $,'') ) )??'+'G'GR\']$$e# '+'K'KHV`'a$$e#  $"7  $, *$']$'a $ $ $ $ $ ..t4 4 4 Y//.Fqc,JVW/X X X Y'') ) )$'') ) )sDD.K,1,I?H.I?!#IH02I7 I?H2I?K,H4K, I>H8H6H8IH<#H:$H<'I.I?0I2I?4K,6H88I:H<<I= I?I  I?I!I I!I?8I;9I?>K? J1J,!J$"J,'K,J11K4K,K K,K)"K%#K))K,rcKd}d}|jjd23d{}||jdz }d|vs"|jdd\}}|j }|s- t j |}d|vrYd |dvrR|jd{|jtj|dd |23d{} | d|vrKd |dvrD|dd } |j| \} } | r|j| |d{t|| }d|vr777e6_7 #t j$rYwxYw6|d kDr|xj|z c_yyw) aProcess a streaming response from the Inworld API. Args: response: The response from the Inworld API. context_id: Unique identifier for this TTS context. Yields: An asynchronous generator of frames. rmiNzutf-8 result audioContent timestampInfor)content iter_chunkeddecodesplitstriprloadsstop_ttfb_metrics_process_audio_chunkbase64 b64decoderrmaxJSONDecodeErrorru) ryrrbufferutterance_durationchunklineline_str chunk_datarrrrs r-rz1InworldHttpTTSService._process_streaming_responsees #++88>  % ell7+ +F&.%||D!4 f::<!%H!5J:-.JxDX2X"44666+/+D+D",,Z-A.-QRT^,((%#(K:-/ZPXEY2Y)3H)=o)N595O5OP^5_2 N%"&":"::z"RRR-01C^-T*/&. 7(,S++9?B  !  ! !%7 7 ! "s E7ED5EE7(E7-3E D8!/ED<D:D<AED>E.E73E75E8E:D<<E>EEE7E E7cK|jd{}d|vr%tjdtdyd}d|vr7|d}|j |\}}|r|j ||d{|}t j|d}t|dkDr|jd r|dd}|j} td t|| D]A} || | | z} | s|jd{t| |jd | C|d kDr|xj|z c_yy7)77Cw) a Process a non-streaming response from the Inworld API. Args: response: The response from the Inworld API. context_id: Unique identifier for this TTS context. Returns: An asynchronous generator of frames. Nrz'No audioContent in Inworld API responsezNo audioContent in responserrmr,RIFFrraudior_ num_channelsr)rrrrrrrrr startswith chunk_sizerangerrr_ru) ryrr response_datarrrr audio_datarrrs r-rz5InworldHttpTTSService._process_non_streaming_responsesY'mmo-  . LLB C#@A A   m +*?;N)-)C)CN)S &J..z:FFF!/ %%mN&CD z?R J$9$9'$B#BCJ__ q#j/:6 Aq1z>2E,,...&T-=-=AZd    !  ! !%7 7 ! "=.G/s;ED?A#E:E;A1E-EE?EEE audio_chunkcK|sy|}t|dkDr|jdr|dd}|rt||jd|yyw)zProcess an audio chunk from the Inworld API. Args: audio_chunk: The audio chunk to process. context_id: Unique identifier for this TTS context. Returns: An asynchronous generator of frames. Nrrrr)rrrr_)ryrrrs r-rz*InworldHttpTTSService._process_audio_chunks`  { b [%;%;G%D$RS)J "  ,,%   sA A )'rHrIrJrKr'SettingsrMrr[rNaiohttp ClientSessionr boolintr ror~rrr! DOWNSTREAMrrrrrr rLrr%rrClientResponserrbytesrrPrQs@r-rSrS`s  "H!!SiS*#'#%)"KR(,15dJdJ!.. dJ 3- dJ } dJdJc]dJdJ'/w/G&HdJ%dJ-.dJLd33JXIbIb ?e ? ?!,S#X!, tE#u*%&- .!,FA*#A*3A*>%QU+;VA*A*F28..28(KR$hw/G&HRr,r[Nz5wss://api.inworld.ai/tts/v1/voice:streamBidirectionalr\rWT) r]r4urlr_r`rrrZrar8aggregate_sentencestext_aggregation_modeappend_trailing_spacerbr]r4rr_r`rrrZrXrar8rrrrzc || dn| }tddddd}|tdtd||_|tdtd||_d}d}| td t| s| j| j|_| j | j |_| j | j }| j | j} | j | j}| j}| j}| |j| t|4dd dd|| | ||d |||_||_d |_||d |_d|_d|_d|_d|_||_d|_||_||_| |_y)aInitialize the Inworld WebSocket TTS service. Args: api_key: Inworld API key. voice_id: ID of the voice to use for synthesis. .. deprecated:: 0.0.105 Use ``settings=InworldTTSSettings(voice=...)`` instead. model: ID of the model to use for synthesis. .. deprecated:: 0.0.105 Use ``settings=InworldTTSSettings(model=...)`` instead. url: URL of the Inworld WebSocket API. sample_rate: Audio sample rate in Hz. encoding: Audio encoding format. auto_mode: Whether to use auto mode. When enabled, the server controls flushing of buffered text. If None (default), automatically set based on ``aggregate_sentences``. apply_text_normalization: Whether to apply text normalization. timestamp_transport_strategy: Strategy for timestamp transport ("ASYNC" or "SYNC"). Defaults to "ASYNC". params: Input parameters for Inworld WebSocket TTS configuration. .. deprecated:: 0.0.105 Use ``settings=InworldTTSSettings(...)`` instead. settings: Runtime-updatable settings. When provided alongside deprecated parameters, ``settings`` values take precedence. aggregate_sentences: Deprecated. Use text_aggregation_mode instead. .. deprecated:: 0.0.104 Use ``text_aggregation_mode`` instead. text_aggregation_mode: How to aggregate text before synthesis. append_trailing_space: Whether to append a trailing space to text before sending to TTS. **kwargs: Additional arguments passed to the parent class. NTrerfrgr]r3r4raF)rirjpause_frame_processingr_rrrr8rl)maxBufferDelayMsbufferCharThresholdrmrr+)r'rr3r4r0r2rrZrrrrnrBrorp_urlrs_buffer_settings _receive_task_keepalive_taskru_generation_end_timervrw _auto_mode_apply_text_normalizationrx)ryrbr]r4rr_r`rrrZrar8rrrrzr{_buffer_max_delay_ms_buffer_char_thresholdrGs r-rozInworldTTSService.__init__ sv   3 ;ATI.'     ":/A7 K%-  "   "7,> H%*  " $!%   "8-? @''35;5I5I$2%%1393E3E$022>/5/N/N,66B393V3V0##/ & 0 0I#)#=#= %+%A%A "    ) )( 3  "!#'# 3"7"7%     %!5#9!  "# !$$'! ("##)A&-I*r,r9cy)zCheck if this service can generate processing metrics. Returns: True, as Inworld WebSocket TTS service supports metrics generation. Tr+r}s r-r~z&InworldTTSService.can_generate_metricsrr,rcKt||d{|j|_|j d{y7.7w)zdStart the Inworld WebSocket TTS service. Args: frame: The start frame. N)rBrr_rw_connectrs r-rzInworldTTSService.startsA gmE""""&"2"2mmo #s A A(A AA A ctKt||d{|jd{y77w)zaStop the Inworld WebSocket TTS service. Args: frame: The end frame. N)rBstop _disconnectrs r-rzInworldTTSService.stops6 gl5!!!    " 848688ctKt||d{|jd{y77w)zfCancel the Inworld WebSocket TTS service. Args: frame: The cancel frame. N)rBcancelrrs r-rzInworldTTSService.cancels6 gnU###    $ rrcK|xs|j}|r?|jr2tjd||j |d{yyy7w)aFlush any pending audio without closing the context. This triggers synthesis of all accumulated text in the buffer while keeping the context open for subsequent text. The context is only closed on interruption, disconnect, or end of session. zFlushing audio for context N)get_active_audio_context_id _websocketrtrace _send_flush)ryrflush_ids r- flush_audiozInworldTTSService.flush_audiosVC!A!A!C  LL6xjA B""8, , ,(8 ,sAAAArcZKt|||d{t|ttfrtt j |dt|jd|jd|_ d|_ t|tr|jdgd{yyy77 w)rNz&: Resetting timestamp tracking due to z - cumulative_time was rmr) rBrr?r rrrtyperHrur rrs r-rzInworldTTSService.push_framesg  222 eo/@A B LL&>tE{?S?S>TU''+'<'<&=? %(D !(+D %%1.. ~>>>2 C 3?s"B+B'BB+B) B+)B+rc.g}|jdi}|jdg}|jdg}|jdg}|r|rt|t|k(rt|D]*\}}|j||z} |j || f,|r%t|dkDr|j|dz|_t j|d|d|jd |D cgc]\} } |  c} } d |j |Scc} } w) aCalculate word timestamps from Inworld WebSocket API response. Adds cumulative time offset to maintain monotonically increasing timestamps across multiple generations within an agent turn. Also tracks the generation end time for updating cumulative time on flush. Args: timestamp_info: The timestamp information from Inworld API. Returns: List of (word, timestamp) tuples with cumulative offset applied. rrrrrrz$: Word timestamps - raw_start_times=z, cumulative_offset=z, adjusted_times=z, generation_end_time=)rArrrurr rr) ryrrrrrrrrr_ts r-rz'InworldTTSService._calculate_word_timess0/1 "&&;  gr*mm$:B? MM"6; [SZ3{3C%C$U+ 64!22[^C !!4"45 6 S^a/,0,A,AIbM,Q) LL&<[MJ%%)%:%:$;<"1;"<A1"''+'@'@&AC  #=s, DcK|rA|jr5tj|d|d |j|d{d|_d|_y7#t$r)}|j d||d{7Yd}~>d}~wwxYww)Nz: Closing context z" due to interruption or completionrrrm)rrinfo_send_close_contextrrrur )ryrrs r-_close_contextz InworldTTSService._close_contexts $// KK4& 2:,>`a b ]..z:::!$$'! ; ]oo2J1#0NZ[o\\\ ]sL*B AAAB A B  B9A<:B?B B  B cBK|j|d{y7w)z: : :] : J//.Fqc,JVW/X X X"DO**+@QCI I I JsuD#2C D#A,C #C$C C C D#C C D D-C0."DDDD#D  D#cK |jd{|jr~tjd|j }|r |D]}|j |d{|jj d{tjd|jd{d|_d|_ d|_ |jdd{y777d#t$r)}|jd||d{7Yd}~zd}~wwxYw7n7B#|jd{7d|_d|_ d|_ |jdd{7wxYww)r<Nz(Disconnecting from Inworld WebSocket TTSz'Disconnected from Inworld WebSocket TTSrrrmon_disconnected) rrrrget_audio_contextsr'closerrremove_active_audio_contextrur rJ)ryaudio_contextsctx_idrs r-r>z'InworldTTSService._disconnect_websocketdsT  >'') ) ) GH!%!8!8!:!"0?"66v>>>?oo++--- FG224 4 4"DO$'D !(+D %**+<= = =# *?- Y//.Fqc,JVW/X X X Y 5 > 224 4 4"DO$'D !(+D %**+<= = =sE9C3C-AC3(C/)#C3 C1 C3&E99D(:-E9'D*(E9-C3/C31C33 D%<D DD D, D%%D,(E9*E9,E6E.E6/E20E66E9ctK|j23d{} tj|}|j di}|j dxs|j d}dDcgc]}||vr| }}t j|d|d||j d i}|j d d d k7rv|j d d }|j d } | dk(r/d|jvrt j|d|d|jd|d{"d|vr(|jt|dd{N|rD|j|s3t j|d||j|d{|j di} | j d} | rt j|d|tj| } t!| dkDr| j#dr| dd} t%| |j&d|} |r|j)|| d{| j d}|r-|j+|}|r|j-||d{d|vrt j|d|d |vrBt j|d!|j.d"|j0|j0|_d#|vst j|d$||j3d{|j-d%d&g|d{|j5|d{T7P#tj$rt j |dYwxYwcc}w7s7J77[777j7S6yw)'z0Handle incoming WebSocket messages from Inworld.Nz received non-JSON messager contextIdr)contextCreated audioChunkflushCompleted contextClosedz: Received message types=z , ctx_id=rcodermessagez Unknown errorz not foundz : Context z not found.r)rrz0: Recreating audio context for current context: rUrz%: Processing audio chunk for context rrrrrrTz: Context created on server: rVz3: Generation completed - updating cumulative_time: z -> rWz: Context closed on server: )r rr)r2rrrrwarningrArlowerrrrNaudio_context_availablecreate_audio_contextrrrrrr_append_to_audio_contextrrrur rremove_audio_context)ryrYmsgrrQk msg_typesrr error_coder audio_b64rrrrs r-_receive_messagesz#InworldTTSService._receive_messages~s!002Q 8Q 8' jj) WWXr*FZZ ,H <0HF ];I LLD6!:9+YvhW XZZ"-Fzz&!$)"JJy/B #ZZ/ ?{ioo6G'GLLD6F8;!GHoo2Ei[0QoRRR#~ooCL0AoBBBd::6B v%UV\U]^_//777!**\26K#7I v%J6(ST((3u:?u'7'7'@!"#JE(0@0@!PVW66vuEEE)___=N!77G 22:vFFF 6) v%B6(KL 6) fO,,-T$2K2K1LN)-(A(A%&( v%A&JK,,.....0F /UW]^^^//777cQ 8'' $'ABC (SC 8FG"/^7c3sN8N6M'N6N8M*:N8, N9B5N8.N!/+N8N$AN8"N'#B,N8N*?N8N-A,N8>-N8+N0,N8N2N8 N4!N8'N6*+NN8N N8$N8'N8*N8-N80N82N84N86N8c4Kd} tj|d{ |jr|jjtj ur|j }|r ddi|d}tjd|ndddii}tjd|jjtj|d{77#tj$r$}tj|d |Yd}~yd}~wwxYww) zBSend periodic keepalive messages to maintain WebSocket connection.<Nrr send_textrSzSending keepalive for context rkz!Sending keepalive without contextz keepalive error: )asynciosleeprrGrrHrrrsendrdumps websocketsConnectionClosedr\)ryKEEPALIVE_SLEEPrkeepalive_messagers r-r9z)InworldTTSService._keepalive_task_handlers--0 0 0 ??t'<'< 'J!%!A!A!CJ!*0")3-) 'Ej\%RS-862,,G) %HI//..tzz:K/LMMM 0N.. $'9!=> sKDCDB0CCCDCD1D DDDcK|j|jd}|jj|jj|d<|jj|jj |d}|jj |jj |d<|j|j|d<|j|j|d<|j|j|d<|jd xsd |d <|jd xsd |d <|j|d <||d}tj|d||jtj ||j"d{y7w)ztSend a context to the Inworld WebSocket TTS service. Args: context_id: The context ID. rNr<)r5r6r;r2applyTextNormalizationautoModerri rr)createrSz: Sending context create: )rvrwrTr0r3r4r2r r rxrrsrrsend_with_retryrror8)ryrr create_configrbs r- _send_contextzInworldTTSService._send_contextsw"11#66  >> ' ' 3+/>>+G+GL (~~++~~++') >> % % 1+/>>+E+EM- (  ) ) 56:6T6TM2 3 ?? &(,M* %  - - 9:>:\:\M6 7-1,A,ABT,U,]Y] ()/3/D/DEZ/[/b_b +,)-)=)= o&&Z@ v7 GH""4::c?D4F4FGGGsFF F F rcKd|i|d}|jtj||jd{y7w)zSend text to the Inworld WebSocket TTS service. Args: context_id: The context ID. text: The text to send. rrjNryrror8)ryrrrbs r- _send_textzInworldTTSService._send_texts:$TND""4::c?D4F4FGGGs:AAAcKi|d}|jtj||jd{y7w)zrSend a flush to the Inworld WebSocket TTS service. Args: context_id: The context ID. ) flush_contextrSNr}ryrrbs r-rzInworldTTSService._send_flush6 !#<""4::c?D4F4FGGG8AAAcKi|d}|jtj||jd{y7w)zzSend a close context to the Inworld WebSocket TTS service. Args: context_id: The context ID. ) close_contextrSNr}rs r-r'z%InworldTTSService._send_close_context#rrcKtj|d|d |jr&|jjtj ur|j d{ |j|sY|j|d{|jd{t||j|d{|j||d{|j|d{dy777i7C7+7#t$r+}td|t!|Yd}~yd}~wwxYw#t$r}td|Yd}~yd}~wwxYww)aGenerate TTS audio for the given text using the Inworld WebSocket TTS service. Args: text: The text to generate TTS audio for. context_id: Unique identifier for this TTS context. Returns: An asynchronous generator of frames. z: Generating WebSocket TTS []Nr[rr)rrrrGrCLOSEDrr^r_start_ttfb_metricsrr{r~rrrr )ryrrrs r-rzInworldTTSService.run_tts,sO  v9$qAB C??doo&;&;u||&Kmmo%% 33J?33J???11333)Z@@,,Z888ooj$777224888 J!&@3878  )A!'EFF%<<   C%=aS#AB B B CsE8AE$D %E*%DDD'D('DDD)D*DDDE E8 EDDDDD E "!EEE8E  E E5E0+E80E55E8r))7rHrIrJrKr'rrMrr[rNr rrr r"rror~rrrrrrrr!rrrrr rrLrr(r,r0r2rrrr=rAr5r>rgr9r{r~rr'r%rrrPrQs@r-rrs"H!!SiS@#'#J%)"$(26KR(,15.2?C&*!KJKJ3- KJ } KJ  KJc]KJKJD>KJ#+3-KJ'/w/G&HKJ%KJ-.KJ&d^KJ ((;<KJ $!KJ"#KJZd!!!+! -HSM -JXIbIb?e??$$DcN$tERUW\R\L]G^$L(s(.S..3.3T +$ K DcN J0>4S8j,%Hc%HNH3HcHHCHHCH C# C3 C>%QU+;V C Cr,r)@rKrlrrr dataclassesrrtypingrrrrr r r r r rrrplogururpipecatrpipecat_versionrpydanticrpipecat.services.settingsrrrrwebsockets.asyncio.clientrrIwebsockets.protocolrModuleNotFoundErrorrrrpipecat.frames.framesrrrrrrrrr "pipecat.processors.frame_processorr!pipecat.services.tts_servicer"r#r$(pipecat.utils.tracing.service_decoratorsr%r'rSrr+r,r-rs (   .)* + __,F)   >]]? ** *4@J@F j C+j Cg ,FLL;qc"#FLL_` &qc* ++,s$ CC?2C::C?