qintUdZddlZddlZddlZddlmZmZddlmZddl m Z m Z m Z m Z mZmZmZddlZddlmZddlmZmZddlmZmZmZmZmZmZmZmZdd l m!Z!dd l"m#Z#dd l$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*m+Z+m,Z,dd l-m.Z.m/Z/ddl0m1Z1 ddl2m3Z4ddl5m6Z6Gdde;eZ<Gdde;eZ=Gdde;eZ>edGddZ?e?ddddd d!de@d"e=D#e?dddd$d%d&de@d'e>D#e?dddd$d%d&de@d(e>D#d)ZAe e;e?feBd*<d+e;d,ee;fd-ZCd.e.d,ee;fd/ZDeGd0d1e&ZEeGd2d3eEZFGd4d5e,ZGGd6d7e*ZHy#e7$r7Z8ejrde8ejrde:de8dZ8[8wwxYw)8avSarvam AI text-to-speech service implementation. This module provides TTS services using Sarvam AI's API with support for multiple Indian languages and two model variants: **Model Variants:** - **bulbul:v2** (default): Standard TTS model - Supports: pitch, loudness, pace (0.3-3.0) - Default sample rate: 22050 Hz - Speakers: anushka (default), abhilash, manisha, vidya, arya, karun, hitesh - **bulbul:v3-beta**: Advanced TTS model with temperature control - Does NOT support: pitch, loudness - Supports: pace (0.5-2.0), temperature (0.01-1.0) - Default sample rate: 24000 Hz - Preprocessing is always enabled - Speakers: aditya (default), ritu, priya, neha, rahul, pooja, rohan, simran, kavya, amit, dev, ishita, shreya, ratan, varun, manan, sumit, roopa, kabir, aayan, shubh, ashutosh, advait, amelia, sophia - **bulbul:v3**: Advanced TTS model with temperature control - Does NOT support: pitch, loudness - Supports: pace (0.5-2.0), temperature (0.01-1.0) - Default sample rate: 24000 Hz - Preprocessing is always enabled - Speakers: aditya (default), ritu, priya, neha, rahul, pooja, rohan, simran, kavya, amit, dev, ishita, shreya, ratan, varun, manan, sumit, roopa, kabir, aayan, shubh, ashutosh, advait, amelia, sophia See https://docs.sarvam.ai/api-reference-docs/text-to-speech/stream for full API details. N) dataclassfield)Enum)AnyAsyncGeneratorClassVarDictListOptionalTuple)logger) BaseModelField) CancelFrameEndFrame ErrorFrameFrameLLMFullResponseEndFrame StartFrameTTSAudioRawFrameTTSStoppedFrame)FrameDirection) sdk_headers) NOT_GIVEN TTSSettings _NotGiven_warn_deprecated_param)InterruptibleTTSServiceTextAggregationMode TTSService)Languageresolve_language) traced_tts)connect)Statez Exception: zEIn order to use Sarvam, you need to `pip install pipecat-ai[sarvam]`.zMissing module: ceZdZdZdZdZdZy)SarvamTTSModelaAvailable Sarvam TTS models. Attributes: BULBUL_V2: Standard TTS model with pitch/loudness control. - Supports pitch, loudness, pace (0.3-3.0) - Default sample rate: 22050 Hz BULBUL_V3_BETA: Advanced model with temperature control. - Does NOT support pitch/loudness - Pace range: 0.5-2.0 - Supports temperature parameter - Default sample rate: 24000 Hz - Preprocessing is always enabled bulbul:v2bulbul:v3-beta bulbul:v3N)__name__ __module__ __qualname____doc__ BULBUL_V2BULBUL_V3_BETA BULBUL_V3M/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/sarvam/tts.pyr'r'Ms I%NIr3r'c,eZdZdZdZdZdZdZdZdZ dZ y ) SarvamTTSSpeakerV2zAvailable speakers for bulbul:v2 model. Female voices: anushka, manisha, vidya, arya Male voices: abhilash, karun, hitesh anushkaabhilashmanishavidyaaryakarunhiteshN) r+r,r-r.ANUSHKAABHILASHMANISHAVIDYAARYAKARUNHITESHr2r3r4r6r6as, GHG E D E Fr3r6cteZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZy)SarvamTTSSpeakerV3zyAvailable speakers for bulbul:v3-beta model. Includes a wider variety of voices with different characteristics. adityaritupriyaneharahulpoojarohansimrankavyaamitdevishitashreyaratanvarunmanansumitroopakabiraayanshubhashutoshadvaitameliasophiaN)r+r,r-r.ADITYARITUPRIYANEHARAHULPOOJAROHANSIMRANKAVYAAMITDEVISHITASHREYARATANVARUNMANANSUMITROOPAKABIRAAYANSHUBHASHUTOSHADVAITAMELIASOPHIAr2r3r4rFrFqs F D E D E E E F E D C F F E E E E E E E EH F F Fr3rFT)frozencveZdZUdZeed<eed<eed<eed<eed<ee e fed<eed<eed fed <y ) TTSModelConfigabImmutable configuration for a Sarvam TTS model. Attributes: supports_pitch: Whether the model accepts pitch parameter. supports_loudness: Whether the model accepts loudness parameter. supports_temperature: Whether the model accepts temperature parameter. default_sample_rate: Default audio sample rate in Hz. default_speaker: Default speaker voice ID. pace_range: Valid range for pace parameter (min, max). preprocessing_always_enabled: Whether preprocessing is always enabled. speakers: Tuple of available speaker names for this model. supports_pitchsupports_loudnesssupports_temperaturedefault_sample_ratedefault_speaker pace_rangepreprocessing_always_enabled.speakersN) r+r,r-r.bool__annotations__intstrr floatr2r3r4r{r{sJ eUl##"&&CHor3r{Fi"Vr7)333333?@c#4K|]}|jywNvalue.0ss r4 r;1qww;)r|r}r~rrrrri]r[)g?g@c#4K|]}|jywrrrs r4rrrrc#4K|]}|jywrrrs r4rrrr)r(r)r*TTS_MODEL_CONFIGSmodelreturnc|tvrtt|jSttdjS)zGet the list of available speakers for a given model. Args: model: The model name (e.g., "bulbul:v2" or "bulbul:v3-beta"). Returns: List of speaker names available for the model. r()rlistr)rs r4get_speakers_for_modelrs; !!%e,5566 !+.77 88r3languagec itjdtjdtjdtjdtj dtj dtjdtjdtjdtjdtjdtjdtjdtjdtjdtj dtj"d tj$d tj&d tj(d tj*d tj,d i}t/||d S)zConvert Pipecat Language enum to Sarvam AI language codes. Args: language: The Language enum value to convert. Returns: The corresponding Sarvam AI language code, or None if not supported. zbn-INen-INzgu-INzhi-INzkn-INzml-INzmr-INzod-INzpa-INzta-INzte-INF) use_base_code)r!BNBN_INENEN_INGUGU_INHIHI_INKNKN_INMLML_INMRMR_INOROR_INPAPA_INTATA_INTETE_INr")r LANGUAGE_MAPs r4language_to_sarvam_languagersZ W  W    W     W   W   W   W   W !"  W#$  W W-L2 Hl% HHr3ceZdZUdZedZedzezed<edZ e dzezed<edZ e dzezed <ed Z e dzezed <ed Z e dzezed <y)SarvamHttpTTSSettingsaSettings for SarvamHttpTTSService. Parameters: enable_preprocessing: Whether to enable text preprocessing. Defaults to False. **Note:** Always enabled for bulbul:v3-beta (cannot be disabled). pace: Speech pace multiplier. Defaults to 1.0. - bulbul:v2: Range 0.3 to 3.0 - bulbul:v3-beta: Range 0.5 to 2.0 pitch: Voice pitch adjustment (-0.75 to 0.75). Defaults to 0.0. **Note:** Only supported for bulbul:v2. Ignored for v3 models. loudness: Volume multiplier (0.3 to 3.0). Defaults to 1.0. **Note:** Only supported for bulbul:v2. Ignored for v3 models. temperature: Controls output randomness for bulbul:v3-beta (0.01 to 1.0). Lower values = more deterministic, higher = more random. Defaults to 0.6. **Note:** Only supported for bulbul:v3-beta. Ignored for v2. ctSrrr2r3r4zSarvamHttpTTSSettings.sR[r3default_factoryNenable_preprocessingctSrrr2r3r4rzSarvamHttpTTSSettings.s9r3pacectSrrr2r3r4rzSarvamHttpTTSSettings.sIr3pitchctSrrr2r3r4rzSarvamHttpTTSSettings.syr3loudnessctSrrr2r3r4rzSarvamHttpTTSSettings.s)r3 temperature)r+r,r-r.rrrrrrrrrrr2r3r4rrs"5:J[4\$+ 1\%*;L%MD%$, "M&+*sIr3rNmin_buffer_sizectSrrr2r3r4rzSarvamTTSSettings.+sYr3max_chunk_length)r+r,r-r.rrr rrrrrrrr2r3r4rrsY +A*)MHhtCH~&M.3DU.VOS4Z)+V/4EV/WcDj9,Wr3rceZdZUdZeZeed<GddeZdddddddde d e jd e e d e e d e d e e de ede effdZdefdZdede e fdZdeffd Zede de deedffdZxZS)SarvamHttpTTSServiceaText-to-Speech service using Sarvam AI's API. Converts text to speech using Sarvam AI's TTS models with support for multiple Indian languages. Provides control over voice characteristics. **Model Differences:** - **bulbul:v2** (default): - Supports: pitch (-0.75 to 0.75), loudness (0.3 to 3.0), pace (0.3 to 3.0) - Default sample rate: 22050 Hz - Speakers: anushka, abhilash, manisha, vidya, arya, karun, hitesh - **bulbul:v3-beta**: - Does NOT support: pitch, loudness (will be ignored) - Supports: pace (0.5 to 2.0), temperature (0.01 to 1.0) - Default sample rate: 24000 Hz - Preprocessing is always enabled - Speakers: aditya, ritu, priya, neha, rahul, pooja, rohan, simran, kavya, amit, dev, ishita, shreya, ratan, varun, manan, sumit, roopa, kabir, aayan, shubh, ashutosh, advait, amelia, sophia Example:: # Using bulbul:v2 (default) tts = SarvamHttpTTSService( api_key="your-api-key", voice_id="anushka", model="bulbul:v2", aiohttp_session=session, params=SarvamHttpTTSService.InputParams( language=Language.HI, pitch=0.1, pace=1.2, loudness=1.5 ) ) # Using bulbul:v3-beta with temperature control tts_v3 = SarvamHttpTTSService( api_key="your-api-key", voice_id="aditya", # Use v3 speaker model="bulbul:v3-beta", aiohttp_session=session, params=SarvamHttpTTSService.InputParams( language=Language.HI, pace=1.2, # Range: 0.5-2.0 for v3 temperature=0.8 ) ) _settingsceZdZUdZej Zeeed<e ddddZ ee ed<e d d d d Z ee ed <e d d d dZ ee ed<e ddZeeed<e ddd dZee ed<y) SarvamHttpTTSService.InputParamsaInput parameters for Sarvam TTS configuration. .. deprecated:: 0.0.105 Use ``SarvamHttpTTSSettings`` directly via the ``settings`` parameter instead. Parameters: language: Language for synthesis. Defaults to English (India). pitch: Voice pitch adjustment (-0.75 to 0.75). Defaults to 0.0. **Note:** Only supported for bulbul:v2. Ignored for v3 models. pace: Speech pace multiplier. Defaults to 1.0. - bulbul:v2: Range 0.3 to 3.0 - bulbul:v3-beta: Range 0.5 to 2.0 loudness: Volume multiplier (0.3 to 3.0). Defaults to 1.0. **Note:** Only supported for bulbul:v2. Ignored for v3 models. enable_preprocessing: Whether to enable text preprocessing. Defaults to False. **Note:** Always enabled for bulbul:v3-beta (cannot be disabled). temperature: Controls output randomness for bulbul:v3-beta (0.01 to 1.0). Lower values = more deterministic, higher = more random. Defaults to 0.6. **Note:** Only supported for bulbul:v3-beta. Ignored for v2. r?+Voice pitch adjustment. Only for bulbul:v2.defaultgele descriptionr?rr&Speech pace. v2: 0.3-3.0, v3: 0.5-2.0.r&Volume multiplier. Only for bulbul:v2.rFzd jt!tj#} t%d | d| dt| |_||j&j(}|/||jt*ur|j&j,| _| j} |j&j.\}}| D| |ks| |kDr:t1j2d| d|d|dt5|t7|| | _|j&j8rd| _|j&j:s-| jdvrt1j2d| d| _|j&j<s-| jdvrt1j2d| d| _ |j&j>s-| jdvrt1j2d| d| _ tA|d|dd| d| ||_"||_#||_$y)aLInitialize the Sarvam TTS service. Args: api_key: Sarvam AI API subscription key. aiohttp_session: Shared aiohttp session for making requests. voice_id: Speaker voice ID. If None, uses model-appropriate default. .. deprecated:: 0.0.105 Use ``settings=SarvamHttpTTSSettings(voice=...)`` instead. model: TTS model to use. Options: - "bulbul:v2" (default): Standard model with pitch/loudness support - "bulbul:v3-beta": Advanced model with temperature control .. deprecated:: 0.0.105 Use ``settings=SarvamHttpTTSSettings(model=...)`` instead. base_url: Sarvam AI API base URL. Defaults to "https://api.sarvam.ai". sample_rate: Audio sample rate in Hz (8000, 16000, 22050, 24000). If None, uses model-specific default. params: Additional voice and preprocessing parameters. If None, uses defaults. .. deprecated:: 0.0.105 Use ``settings=SarvamHttpTTSSettings(...)`` instead. settings: Runtime-updatable settings. When provided alongside deprecated parameters, ``settings`` values take precedence. **kwargs: Additional arguments passed to parent TTSService. r(r7rFrN)rvoicerrrrrrrrrr, Unsupported model ''. Allowed values: .Pace  is outside model range (- ). Clamping.TNrpitch parameter is ignored for Nr"loudness parameter is ignored for Nr%temperature parameter is ignored for )rpush_stop_framespush_start_framerr2)%rrrrrlanguage_to_service_languagerrrrr apply_update isinstancer!rjoinsortedkeys ValueError_configrrrrr warningmaxminrr|r}r~super__init___api_key _base_url_session)selfrrrrrrrrkwargsdefault_settingsresolved_modelallowedrpace_minpace_max __class__s r4r zSarvamHttpTTSService.__init__s~V1!&     "7,A7 K%*  "   ":/Dg N%-  "   "8-B C??.99&//JUg%-..:2BBUV]U^^_`a a(8   ,,::K  !1X^^y5P%)\\%A%A  " $$!\\44(  D8O NNU4&(A(1XJVbc d$'#h2E$F  ! << 4 448  1||**/?/E/E[/X NN<^BRS T+/  (  #!!%      !' r3rcyzCheck if this service can generate processing metrics. Returns: True, as Sarvam service supports metrics generation. Tr2rs r4can_generate_metricsz)SarvamHttpTTSService.can_generate_metrics' r3rct|SzConvert a Language enum to Sarvam AI language format. Args: language: The language to convert. Returns: The Sarvam AI-specific language code, or None if not supported. rrrs r4rz1SarvamHttpTTSService.language_to_service_language/+844r3framec@Kt||d{y7wz~Start the Sarvam TTS service. Args: frame: The start frame containing initialization parameters. N)r startrr"rs r4r%zSarvamHttpTTSService.start:s gmE"""s text context_idcTKtj|d|d ||jj|jj|j |jj |jj|jj|jjndd}|jjr1|jj|jjnd|d<|jjr1|jj|jjnd|d<|jjr1|jj|jjnd |d <|j d d t#}|j$d }|j&j)|||4d{}|j*dk7rT|j-d{}t/d| dddd{|j1d{y|j3d{}dddd{|j5|d{dvs|ds)t/d |j1d{y|dd} t7j8| } t;| dkDr+| j=drtjd| dd} t?| |j d|} | |j1d{y7h7D7$777#1d{7swYxYw77#t@$r} t/d| | Yd} ~ cd} ~ wwxYw7W#|j1d{7wxYww)aGenerate speech from text using Sarvam AI's API. Args: text: The text to synthesize into speech. context_id: The context ID for tracking audio frames. Yields: Frame: Audio frames containing the synthesized speech. z: Generating TTS []Nr)r'rspeakerrrrrrrrrrzapplication/json)api-subscription-keyz Content-Typez/text-to-speech)jsonheaderszSarvam API error: erroraudioszNo audio data receivedr,sRIFFz+Stripping WAV header from Sarvam audio data)audior num_channelsr(zError generating TTS: )r1 exception)!r debugrrrrrrrrr|rr}rr~rr rrrpoststatusr'rstop_ttfb_metricsr-start_tts_usage_metricsbase64 b64decodelen startswithr Exception) rr'r(payloadr.urlresponse error_text response_data base64_audio audio_datar"es r4run_ttszSarvamHttpTTSService.run_ttsBsK  v/vQ78D +(,(?(?>>//#//(,(K(K--/3~~/B/B/N++TWG||**;?>>;O;O;[4>>#7#7ad ||--/3~~/F/F/RDNN++X[ #||0026..2L2L2XDNN..^a & )- 2-G ^^$O4C}}))#GW)M 6 6QY??c)'/}}!6J$-? |+LMM  6 6H((* * *='/mmo 5  6 6..t4 4 4},M(4K '?@@.((* * *))215L)),7J:# (=(=g(F JK'_ $  ,,% EK ((* * *I 6!6 6H +=!6  6 6 6 6 58 + N%;A3#?1M M M N +$((* * *s&N(F/ML6M#M5L96M ML<MN(0L?1N(6M M M MMM2M3MN(#M$N()A4MN(0N1N(6M9M<M?N(MMM M MMN( N(N;N NN N( N%N!N%%N()r+r,r-r.rSettingsrrrraiohttp ClientSessionr rr rrr!rrr%r#rrrJ __classcell__rs@r4rr.s1f%H$$2 i2 r#'#/%)(,48L(L(!.. L( 3- L( } L(L(c]L(%L(01L(\d 5X 5(3- 5##P+#P+3P+>%QU+;VP+P+r3rceZdZUdZeZeed<GddeZdddddddddde d e e d e e d e d e e d e e de e de ede effdZde fdZdede e fdZdeffd Zdeffd Zdeffd Zd-de e fdZej4fdedeffd Zdedeffd Zdedee e fffd Z!fd!Z"fd"Z#d#Z$d$Z%d%Z&d&Z'd'Z(d(Z)d)Z*d*e fd+Z+e,d*e de de-edffd,Z.xZ/S).SarvamTTSServicea>WebSocket-based text-to-speech service using Sarvam AI. Provides streaming TTS with real-time audio generation for multiple Indian languages. Uses WebSocket for low-latency streaming audio synthesis. **Model Differences:** - **bulbul:v2** (default): - Supports: pitch (-0.75 to 0.75), loudness (0.3 to 3.0), pace (0.3 to 3.0) - Default sample rate: 22050 Hz - Speakers: anushka, abhilash, manisha, vidya, arya, karun, hitesh - **bulbul:v3-beta** / **bulbul:v3**: - Does NOT support: pitch, loudness (will be ignored) - Supports: pace (0.5 to 2.0), temperature (0.01 to 1.0) - Default sample rate: 24000 Hz - Preprocessing is always enabled - Speakers: aditya, ritu, priya, neha, rahul, pooja, rohan, simran, kavya, amit, dev, ishita, shreya, ratan, varun, manan, sumit, roopa, kabir, aayan, shubh, ashutosh, advait, amelia, sophia **WebSocket Protocol:** The service uses a WebSocket connection for real-time streaming. Messages include: - config: Initial configuration with voice settings - text: Text chunks for synthesis - flush: Signal to process remaining buffered text - ping: Keepalive signal Example:: # Using bulbul:v2 (default) tts = SarvamTTSService( api_key="your-api-key", voice_id="anushka", model="bulbul:v2", params=SarvamTTSService.InputParams( language=Language.HI, pitch=0.1, pace=1.2, loudness=1.5 ) ) # Using bulbul:v3-beta with temperature control tts_v3 = SarvamTTSService( api_key="your-api-key", voice_id="aditya", # Use v3 speaker model="bulbul:v3-beta", params=SarvamTTSService.InputParams( language=Language.HI, pace=1.2, # Range: 0.5-2.0 for v3 temperature=0.8 ) ) See https://docs.sarvam.ai/api-reference-docs/text-to-speech/stream for API details. rceZdZUdZeddddZeeed<edd d d Z eeed <edd d d Z eeed<eddZ ee ed<eddZ eeed<eddZeeed<eddZeeed<eddZeeed<ej(Zeeed<ed d!dd"Zeeed#<y$)%SarvamTTSService.InputParamsa]Configuration parameters for Sarvam TTS WebSocket service. .. deprecated:: 0.0.105 Use ``SarvamTTSSettings`` directly via the ``settings`` parameter instead. Parameters: pitch: Voice pitch adjustment (-0.75 to 0.75). Defaults to 0.0. **Note:** Only supported for bulbul:v2. Ignored for v3 models. pace: Speech pace multiplier. Defaults to 1.0. - bulbul:v2: Range 0.3 to 3.0 - bulbul:v3-beta: Range 0.5 to 2.0 loudness: Volume multiplier (0.3 to 3.0). Defaults to 1.0. **Note:** Only supported for bulbul:v2. Ignored for v3 models. enable_preprocessing: Enable text preprocessing. Defaults to False. **Note:** Always enabled for bulbul:v3-beta. min_buffer_size: Minimum characters to buffer before generating audio. Lower values reduce latency but may affect quality. Defaults to 50. max_chunk_length: Maximum characters processed in a single chunk. Controls memory usage and processing efficiency. Defaults to 150. output_audio_codec: Audio codec format. Options: linear16, mulaw, alaw, opus, flac, aac, wav, mp3. Defaults to "linear16". output_audio_bitrate: Audio bitrate (32k, 64k, 96k, 128k, 192k). Defaults to "128k". language: Target language for synthesis. Supports Indian languages. temperature: Controls output randomness for bulbul:v3-beta (0.01 to 1.0). Lower = more deterministic, higher = more random. Defaults to 0.6. **Note:** Only supported for bulbul:v3-beta. Ignored for v2. **Speakers by Model:** bulbul:v2: - Female: anushka (default), manisha, vidya, arya - Male: abhilash, karun, hitesh bulbul:v3-beta: - aditya (default), ritu, priya, neha, rahul, pooja, rohan, simran, kavya, amit, dev, ishita, shreya, ratan, varun, manan, sumit, roopa, kabir, aayan, shubh, ashutosh, advait, amelia, sophia rrrrrrrrrrrrrFz8Enable text preprocessing. Always enabled for v3 models.rr2z3Minimum characters to buffer before TTS processing.rz&Maximum length for sentence splitting.rlinear16z>Audio codec: linear16, mulaw, alaw, opus, flac, aac, wav, mp3.output_audio_codec128kz)Audio bitrate: 32k, 64k, 96k, 128k, 192k.output_audio_bitraterrrrrN)r+r,r-r.rrr rrrrrrrrrrWrrYr!rrrr2r3r4rrSs<& P"'E " x !&@ ! huo %*@ % (5/ 05R0 htn */M* # +0@+ (3- -2X- HSM /4C/ hsm (0{{(8$2',U ( Xe_ r3rNz%wss://api.sarvam.ai/text-to-speech/ws)rrrCaggregate_sentencestext_aggregation_moderrrrrrrCrZr[rrrc ^tdddddddddd } |td td || _|td td || _d } d} |>tdt| s+|j$|j |jxsd| _|j |j | _|j|j| _|j|j| _|j |j} |j |j} |j|j| _ |j|j| _ |j|j| _ |j|j| _| | j| t!| jt"r |j | j| _| j}|t$vr>dj't)t$j+}t-d|d|dt$||_||j.j0}|/| | jt2ur|j.j4| _| j}|j.j6\}}|D||ks||kDr:t9j:d|d|d|dt=|t?||| _ |j.j@rd| _|j.jBs-| jdvrt9j:d|d| _ |j.jDs-| jdvrt9j:d|d| _ |j.jFs-| jdvrt9j:d|d| _tI|d!||dddd|| d| tM||_'| |_(| |_)|d ||_*||_+d|_,d|_-y)"acInitialize the Sarvam TTS service with voice and transport configuration. Args: api_key: Sarvam API key for authenticating TTS requests. model: TTS model to use. Options: - "bulbul:v2" (default): Standard model with pitch/loudness support - "bulbul:v3-beta": Advanced model with temperature control .. deprecated:: 0.0.105 Use ``settings=SarvamTTSSettings(model=...)`` instead. voice_id: Speaker voice ID. If None, uses model-appropriate default. .. deprecated:: 0.0.105 Use ``settings=SarvamTTSSettings(voice=...)`` instead. url: WebSocket URL for the TTS backend (default production URL). 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. sample_rate: Output audio sample rate in Hz (8000, 16000, 22050, 24000). If None, uses model-specific default. params: Optional input parameters to override defaults. .. deprecated:: 0.0.105 Use ``settings=SarvamTTSSettings(...)`` instead. settings: Runtime-updatable settings. When provided alongside deprecated parameters, ``settings`` values take precedence. **kwargs: Arguments forwarded to InterruptibleTTSService. See https://docs.sarvam.ai/api-reference-docs/text-to-speech/stream r(r7rFrTrUrN) rrrrrrrrrrrrrrVrXrrrrrrrrrTrrrrrr)rZr[push_text_framespause_frame_processingrrrrz?model=r2).rrrrrrrrrrWrYrrrrrrr!rrrrrrrrrrr rr r rr|r}r~r r r_speech_sample_rate_output_audio_codec_output_audio_bitrate_websocket_urlr  _receive_task_keepalive_task)rrrrrCrZr[rrrrrrWrYrrrrrrs r4r zSarvamTTSService.__init__+s;f-!&      "7,=w G%*  "   ":/@' J%-  "(%   "8-> ???.99&//JUg%-..:8O8O$5,,8)/)B)B&..:+1+F+F(;;*,2KK$)<<+-3\\$*??.06$-%%1393E3E$0    ) )( 3 &// :(,(I(IJZJcJc(d  %*// !2 2ii'8'='='? @AG2>2BBUV]U^^_`a a(8   ,,::K  !1X^^y5P%)\\%A%A  " $$!\\44(  D8O NNU4&(A(1XJVbc d$'#h2E$F  ! << 4 448  1||**/?/E/E[/X NN<^BRS T+/  (  3"7!#'!!#%  $'{#3 #5 %9""%W^,<= !#r3rcyrr2rs r4rz%SarvamTTSService.can_generate_metricsrr3rct|Srrr s r4rz-SarvamTTSService.language_to_service_languager!r3r"cKt||d{t|j|_|j d{y777wr$)r r%rrr__connectr&s r4r%zSarvamTTSService.startsJ gmE"""$'t'7'7#8 mmo # s!AA1AA AActKt||d{|jd{y77w)zVStop the Sarvam TTS service. Args: frame: The end frame. N)r stop _disconnectr&s r4rjzSarvamTTSService.stops6 gl5!!!    " 848688ctKt||d{|jd{y77w)z[Cancel the Sarvam TTS service. Args: frame: The cancel frame. N)r cancelrkr&s r4rnzSarvamTTSService.cancels6 gnU###    $ rlr(c K |jr;ddi}|jjtj|d{yy7#t$r)}|j d||d{7Yd}~yd}~wwxYww)z;Flush any pending audio synthesis by sending flush command.typeflushNzError sending flush to Sarvam:  error_msgr7) _websocketsendr-dumpsrA push_error)rr(msgrIs r4 flush_audiozSarvamTTSService.flush_audio su `w'oo**4::c?;;;; `//.MaS,Q]^/_ _ _ `sMBAAA A B A BA;0A31A;6B;BB directioncBKt|||d{y7w)zPush a frame downstream with special handling for stop conditions. Args: frame: The frame to push. direction: The direction to push the frame. N)r  push_framerr"rzrs r4r|zSarvamTTSService.push_framesg  222s cKt|||d{t|ttfr|j d{yy747w)zCProcess a frame and flush audio if it's the end of a full response.N)r  process_framerrrryr}s r4rzSarvamTTSService.process_framesQg#E9555 e5x@ A""$ $ $ B 6 %s!AA -AAAAdeltaczKt||d{}|r|jd{|S7 7w)z:Apply a settings delta and resend config if voice changed.N)r _update_settings _send_config)rrchangedrs r4rz!SarvamTTSService._update_settings's>077 ##% % % 8 &s;7;9;;c|Kt|d{|jd{|jr;|js/|j |j |j|_|jr2|js%|j |j|_yyy77w)z7Connect to Sarvam WebSocket and start background tasks.N) r rh_connect_websocketrtrc create_task_receive_task_handler _report_errorrd_keepalive_task_handlerrrs r4rhzSarvamTTSService._connect0sg   %%''' ??4#5#5!%!1!1$2L2LTM_M_2`!aD  ??4#7#7#'#3#3,,.$D $8? !'s B<B8B<B:B B<:B<cRKt|d{|jr*|j|jd{d|_|jr*|j|jd{d|_|j d{y77\7(7 w)z4Disconnect from Sarvam WebSocket and clean up tasks.N)r rkrc cancel_taskrd_disconnect_websocketrs r4rkzSarvamTTSService._disconnect>sg!###   ""4#5#56 6 6!%D    ""4#7#78 8 8#'D ((*** $ 7 9 +sEB'B.B'B!5B':B#;B'B%B'!B'#B'%B'c4K |jr'|jjtjuryd|jit }t |j|d{|_tjd|jd{|jdd{y7P7 7 #t$rL}|jd||d{7d|_|jd|d{7Yd}~yd}~wwxYww) z-Establish WebSocket connection to Sarvam API.Nr,)additional_headersz!Connected to Sarvam TTS Websocket on_connectedz*Error connecting to Sarvam TTS Websocket: rron_connection_error)rtstater%OPENr rwebsocket_connectrbr r8r_call_event_handlerrArw)rws_additional_headersrIs r4rz#SarvamTTSService._connect_websocketLs J4??#8#8EJJ#F' %-% ! %6###8%DO LL< =##% % %**>: : : & : J//FqcJVW"  #DO**+@QCI I I  JsD2CD2C)B:*1CB<C4B>5C9D:C<C>C D D"C%#"DDD DDDc K|js td|jj|jj|j |jj |jj|jj|j|j|jj|jjd }|jj|jj|d<|jj|jj|d<|jj|jj|d<t!j"d|d|d } |jj%t'j(|d{t!j"d y7#t$r%}|j+d || d{7d}~wwxYww) z#Send initial configuration message.zWebSocket not connected) rr+speech_sample_raterrrrWrYrrNrrrzConfig being sent is configrpdatazConfiguration sent successfullyUnknown error occurred: rr)rtrArrrr_rrrr`rarrrrrr r8rur-rvrw)r config_dataconfig_messagerIs r4rzSarvamTTSService._send_configfs56 6%)NN$;$;~~++"&":":$(NN$G$G#~~== $ ? ?"&":":$($>$>NN''^^))   >>   +#'>>#7#7K >> " " .&*nn&=&=K # >> % % 1)-)C)CK & ,[M:;"*K@ //&&tzz.'AB B B LL: ; C //.Fqc,JVW/X X X  sHE9G;<1G -G.G G;G G8G3,G/-G33G88G;cK |jd{|jr7tjd|jj d{d|_|jdd{y7h7'#t $r)}|j d||d{7Yd}~Rd}~wwxYw7>#d|_|jdd{7wxYww)z.Close WebSocket connection and clean up state.NzDisconnecting from SarvamzError closing websocket: rron_disconnected)stop_all_metricsrtr r8closerArwr)rrIs r4rz&SarvamTTSService._disconnect_websockets >'') ) ) 89oo++---#DO**+<= = = *. Z//.Gs,KWX/Y Y Y Z >#DO**+<= = =sC!BBABBBC!:B9;C!BB B6 B1&B)'B1,B;1B66B;9C!;CCCC!cH|jr |jStd)NzWebsocket not connected)rtrArs r4_get_websocketzSarvamTTSService._get_websockets ???? "122r3cK|j23d{}t|tstj|}|j ddk(rt|j d{tj|dd}t||jd|j}|j|d{|j ddk(s|dd}|jd | d{d |jvsd |jvrtj d |jt#d |d{R7N777l76yw)z3Receive and process messages from Sarvam WebSocket.Nrpr5rr4r(r1messagez TTS Error: )rsztoo longtimeoutz5Connection timeout detected, service may need restartr0)rrrr-loadsgetr;r=r>rrget_active_audio_context_idr|rwlowerr rr)rrrxr5r"rss r4_receive_messagesz"SarvamTTSService._receive_messagessR!002 W W''3'jj)776?g-00222",,S[-ABE,t//t?_?_?aE//%000WWV_/ #F I 6I//k)4M/NNN"Y__%66)yGX:X'^_//*[ ;T*UVVV' W 3 1O W'3szE2E0E%E0E2--0 0 0&&( ( ( 0 (sA<A>AAcK|jrc|jjtjk(r;ddi}|jj t j |d{yyy7w)z.Send keepalive message to maintain connection.rppingN)rtrr%rrur-rv)rrxs r4rz SarvamTTSService._send_keepalivesW ??t44 B6"C//&&tzz#7 7 7 C? 7sA)A5+A3,A5r'cK|jre|jjtjk(r>dd|id}|jj t j |d{ytjdy7w)z,Send text to Sarvam WebSocket for synthesis.r'rNz%WebSocket not ready, cannot send text) rtrr%rrur-rvr r)rr'rxs r4 _send_textzSarvamTTSService._send_textsb ??t44 B!FD>:C//&&tzz#7 7 7 NNB C 8sA,B .B /B crKtjd|d |jr&|jjtj ur|j d{ |j|d{|j|d{dy7=7%7#t$r]}td|t||jd{7|j d{7Yd}~yd}~wwxYw#t$r}td|Yd}~yd}~wwxYww)aGenerate speech audio frames from input text using Sarvam TTS. Sends text over WebSocket for synthesis and yields corresponding audio or status frames. Args: text: The text input to synthesize. context_id: The context ID for tracking audio frames. Yields: Frame objects including TTSStartedFrame, TTSAudioRawFrame(s, context_id=context_id), or TTSStoppedFrame. zGenerating TTS: [r*Nrr0r) r r8rtrr%CLOSEDrhrr<rArrrk)rr'r(rIs r4rJzSarvamTTSService.run_ttss   (a01 C??doo&;&;u||&Kmmo%% ood+++224888J&,8  )A!'EFF%<<&&(((mmo%%   C%=aS#AB B B CsD7AD"B #D(B&<B"=B&B$B&DD7 D"B&$B&& D /4D#C&$D<C?=DDD7D  D D4D/*D7/D44D7r)0r+r,r-r.rrKrrrrr rrrr rr!rrr%rrjrrnryr DOWNSTREAMrr|rrdictrrrhrkrrrrrrrrr#rrJrNrOs@r4rQrQs8t!H  U iU v $"&:.2?C%)(,04o$o$} o$ 3- o$  o$&d^o$ ((;<o$c]o$%o$,-o$bd 5X 5(3- 5  !!!+!`HSM`JXIbIb3e33%%>%KDcN  +J4B >3 W.)8 DSDC#C3C>%QU+;VCCr3rQ)Ir.rr=r- dataclassesrrenumrtypingrrrr r r r rLlogurur pydanticrrpipecat.frames.framesrrrrrrrr"pipecat.processors.frame_processorrpipecat.services.sarvam._sdkrpipecat.services.settingsrrrrpipecat.services.tts_servicerrr pipecat.transcriptions.languager!r"(pipecat.utils.tracing.service_decoratorsr#websockets.asyncio.clientr$rwebsockets.protocolr%ModuleNotFoundErrorrIr1rArr'r6rFr{tuplerrrrrrrrQr2r3r4rs(B (MMM%   >4__aaF?,F)S$( d  dB $2 "!!%*;(:;; %!!%);(:;;  !!%);(:;; +04^+,D 9# 9$s) 9"I("Ix}"IJ UKU U2 X-X X$e+:e+P N C.N C_,FLL;qc"#FLLXY &qc* ++,s E;;F72F22F7