qix8dZddlZddlZddlZddlmZmZddlmZm Z m Z ddl Z ddl m Z ddlmZddlmZddlmZmZmZmZmZmZmZdd lmZdd lmZmZm Z m!Z!dd l"m#Z#dd l$m%Z% dd l&m'Z'ddl(m)Z)m*Z*m+Z+ddl,m-Z-dZ2dedZ3eGddeZ4Gdde#Z5y#e.$r7Z/e j`de/e j`de1de/dZ/[/wwxYw)z+Hume Text-to-Speech service implementation.N) dataclassfield)AnyAsyncGeneratorOptional)logger) BaseModel)version) CancelFrameEndFrameFrameInterruptionFrame StartFrameTTSAudioRawFrameTTSStoppedFrame)FrameDirection) NOT_GIVEN TTSSettings _NotGiven_warn_deprecated_param) TTSService) traced_tts)AsyncHumeClient) FormatPcmPostedUtterancePostedUtteranceVoiceWithId)TimestampMessagez Exception: zAIn order to use Hume, you need to `pip install pipecat-ai[hume]`.zMissing module: ipipecat)zX-Hume-Client-NamezX-Hume-Client-VersionceZdZUdZedZedzezed<edZ e dzezed<edZ e dzezed <y) HumeTTSSettingszSettings for HumeTTSService. Parameters: description: Natural-language acting directions (up to 100 characters). speed: Speaking-rate multiplier (0.5-2.0). trailing_silence: Seconds of silence to append at the end (0-5). ctSNrK/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/hume/tts.pyzHumeTTSSettings.=s r%)default_factoryN descriptionctSr"r#r$r%r&r'zHumeTTSSettings.>sIr%speedctSr"r#r$r%r&r'zHumeTTSSettings.?syr%trailing_silence) __name__ __module__ __qualname____doc__rr)strr__annotations__r+floatr-r$r%r&r r 3sU+0@Q*RKti'R&+r?returnc h|xstjd}|s td|tk7rt j dtd|t dddddd}|tdt d||_|Etd t |s3|j|_ |j|_ |j|_ ||j|t|8d|d d d |d |tj t" |_t'||j$|_d|_d|_y)asInitialize the HumeTTSService. Args: api_key: Hume API key. If omitted, reads the ``HUME_API_KEY`` environment variable. voice_id: ID of the voice to use. Only voice IDs are supported; voice names are not. .. deprecated:: 0.0.105 Use ``settings=HumeTTSSettings(voice=...)`` instead. params: Optional synthesis controls (acting instructions, speed, trailing silence). .. deprecated:: 0.0.105 Use ``settings=HumeTTSSettings(...)`` instead. sample_rate: Output sample rate for emitted PCM frames. Defaults to 48_000 (Hume). settings: Runtime-updatable settings. When provided alongside deprecated parameters, ``settings`` values take precedence. **kwargs: Additional arguments passed to the parent class. HUME_API_KEYzAHumeTTSService requires an API key (env HUME_API_KEY or api_key=)zHume TTS streams at z Hz; configured sample_rate=N)modelvoicelanguager)r+r-r<rDr=FT)r>push_text_framespush_stop_framespush_start_framer?)headers)r; httpx_clientr%r$)osgetenv ValueErrorHUME_SAMPLE_RATErwarningr rrDr)r+r- apply_updatesuper__init__httpx AsyncClientDEFAULT_HEADERS _http_clientr_client _audio_bytes_cumulative_time) selfr;r<r=r>r?kwargsdefault_settings __class__s r&rSzHumeTTSService.__init__dsI:6RYY~6`a a * * NN&'7&88TU`Tab  +!     ": H%-  "   "8_ =/5/A/A ,)/ &4:4K4K 1    ) )( 3  #"!!%    "--oF&wTEVEVW !$r%cy)zoCan generate metrics. Returns: True if metrics can be generated, False otherwise. Tr$r[s r&can_generate_metricsz#HumeTTSService.can_generate_metricss r%framec`Kt||d{|jy7w)zNStart the service. Args: frame: The start frame. N)rRstart _reset_stater[rbr^s r&rdzHumeTTSService.starts, gmE"""  #s .,.cd|_y)zReset internal state variables.rKN)rZr`s r&rezHumeTTSService._reset_states #r%cKt||d{t|dr0|jr#|jj d{yyy7A7 w)zaStop the service and cleanup resources. Args: frame: The end frame. NrW)rRstophasattrrWacloserfs r&rizHumeTTSService.stopsV gl5!!! 4 (T->->##**, , ,.? ( " ,!AA9AAAAcKt||d{t|dr0|jr#|jj d{yyy7A7 w)zfCancel the service and cleanup resources. Args: frame: The cancel frame. NrW)rRcancelrjrWrkrfs r&rnzHumeTTSService.cancelsV gnU### 4 (T->->##**, , ,.? ( $ ,rl directioncKt|||d{t|ttfr<|j t|tr|j dgd{yyy7W7 w)zPush a frame and handle state changes. Args: frame: The frame to push. direction: The direction to push the frame. N)Resetr)rR push_frame isinstancerrreadd_word_timestamps)r[rbror^s r&rrzHumeTTSService.push_framespg  222 e/A B    %1.. ~>>>2 C 3 ?s"A3A/AA3'A1(A31A3keyvaluecKtj5tjdtjdtdddd|xsdj }hd}||vri}|dvrt ||d <nG|d k(r|dn t ||d <n/|d k(r|dn t||d <n|d k(r|dn t||d <|jtd i|d{yy#1swYxYw7w)aRuntime updates via key/value pair. .. deprecated:: 0.0.104 Use ``TTSUpdateSettingsFrame(delta=HumeTTSSettings(...))`` instead. Args: key: The name of the setting to update. Recognized keys are: - "voice_id" - "description" - "speed" - "trailing_silence" value: The new value for the setting. alwaysza'update_setting' is deprecated, use 'TTSUpdateSettingsFrame(delta=HumeTTSSettings(...))' instead.) stacklevelN>r+rDr<r)r-)r<rDrDr)r+r-r$) warningscatch_warnings simplefilterwarnDeprecationWarninglowerr2r4_update_settingsr )r[rurvkey_l known_keysr\s r&update_settingzHumeTTSService.update_settings $ $ &   ! !( + MMP"   !!#V J %'F--"%e*w-'05 3u:}%'!*/-$U5\w,,5:]Te )*''(A&(AB B B   , Cs)C;2C- BC;&C9'C;-C62C;text context_idcKtj|d|d|t|jjd}|jj |jj |d<|jj |jj |d<|jj|jj|d<tdi|}td }|j|d{ d |_ |jj d nd }d}|jjj|g|d|dg23d{}t|dd} | r|j!d{t#j$| } |xj| z c_ t'|j|j(k\r/t+|j|j,d|} | d |_ t/|t0s|j2} | j4dk(s|j6| j8j:dz z} |j6| j8j<dz z}t?||}|jA| jB| fg|d{Y77X7476|jr/t+|j|j,d|} | d |_ |dkDr||_n5#tD$r)}|jGd||d{7Yd}~nd}~wwxYw|j!d{7y#|j!d{7wxYww)aGenerate speech from text using Hume TTS with word timestamps. Args: text: The text to be synthesized. context_id: Unique identifier for this TTS context. Returns: An async generator that yields `Frame` objects, including `TTSStartedFrame`, `TTSAudioRawFrame`, `ErrorFrame`, and `TTSStoppedFrame`. z: Generating Hume TTS: [])id)rrDNr)r+r-pcm)typer%12rKTword) utterancesformat instant_moder include_timestamp_typesaudio)rr> num_channelsrg@@rzUnknown error occurred: ) error_msg exceptionr$)$rdebugrr7rDr)r+r-rrstart_tts_usage_metricsrYrXttssynthesize_json_streaminggetattrstop_ttfb_metricsbase64 b64decodelen chunk_sizerr>rsr timestamprrZtimebeginendmaxrtr Exception push_error)r[rrutterance_kwargs utterancepcm_fmtr utterance_durationchunk audio_b64 pcm_bytesrbrword_start_time word_end_timees r&run_ttszHumeTTSService.run_ttss@  v5dV1=>/4>>3G3GH,  >> % % 1.2nn.H.H ] + >>   +(,(<(< W % >> * * 637>>3R3R / 0#7&67 '**4000K +!$D "^^77CcG"% #||//II%;!)/ J ' ' e$E7D9 00222 & 0 0 ;I%%2%4,,-@ 0"&"3"3(,(8(8)*'1 ! $ ,/)e%56 %I ~~/*.*?*?9>>CWCWZ`C`*a(,(=(=ASASV\A\(] .11C]-S*#66'nno>?i 1' 36K T  (++ $ 0 0!")  $'!"A%(:% Y//.Fqc,JVW/X X X Y((* * *$((* * *sC7M(9J':M(?AK;J2J*J2#K;9J-:BK; K;&A:K; J0!K;'M(*J2-K;0K;2AK;:M ; L-L(L L(#M (L--M 0M(MM( M%M!M%%M()!r.r/r0r1r Settingsr3r r:rOrr2intrSboolrarrdrer rir rnr DOWNSTREAMr rrrrrrr __classcell__)r^s@r&r6r6BsR H1i1&"&"&(,%5.2S$#S$3- S$ % S$ c] S$?+S$ S$jd$--T--+-$-JXIbIb ?e ? ?$C$CC$CD$CLl+#l+3l+>%QU+;Vl+l+r%r6)6r1rrLr| dataclassesrrtypingrrrrTlogururpydanticr rr pipecat_versionpipecat.frames.framesr r r rrrr"pipecat.processors.frame_processorrpipecat.services.settingsrrrrpipecat.services.tts_servicer(pipecat.utils.tracing.service_decoratorsrhumerhume.ttsrrrhume.tts.typesrModuleNotFoundErrorrerrorrrOrVr r6r$r%r&rs 2 (00 .>__3?,$OO/$,.   Zk Z  ZB+ZB+=,FLL;qc"#FLLTU &qc* ++,s(B&&C"+2CC"