qi:3DUdZddlmZmZddlmZmZmZmZddl m Z ddl m Z ddl mZddlmZmZddlmZmZmZmZdd lmZmZmZmZdd lmZdd lmZm Z dd l!m"Z"d dd dZ#ee$e%fe&d<dedee$fdZ'de(de)e(e(ffdZ*eGddeZ+GddeZ,y)aCamb.ai MARS text-to-speech service implementation. This module provides TTS functionality using Camb.ai's MARS model family, offering high-quality text-to-speech synthesis with streaming support. Features: - MARS models: mars-flash (fast), mars-pro (high quality) - 140+ languages supported - Real-time streaming via official SDK - Model-specific sample rates: mars-pro (48kHz), mars-flash (22.05kHz) ) dataclassfield)AnyAsyncGeneratorDictOptional)StreamTtsOutputConfiguration) AsyncCambAI)logger) BaseModelField) ErrorFrameFrame StartFrameTTSAudioRawFrame) NOT_GIVEN TTSSettings _NotGiven_warn_deprecated_param) TTSService)Languageresolve_language) traced_tts"Vi) mars-flashzmars-pro mars-instructMODEL_SAMPLE_RATESlanguagereturncTitjdtjdtjdtjdtj dtj dtjdtjdtjdtjdtjdtjdtjd tjd tjd tj d tj"d itj$d tj&dtj(dtj*dtj,dtj.dtj0dtj2dtj4dtj6dtj8dtj:dtj<dtj>dtj@dtjBdtjDditjFdtjHdtjJdtjLd tjNd!tjPd"tjRd#tjTd$tjVd%tjXd&tjZd'tj\d(tj^d)tj`d*tjbd+tjdd,tjfd-tjhd.tjjd/tjld0tjnd1tjpd2tjrd3tjtd4tjvd5tjxd6tjzd7tj|d8i }t||d9:S);zConvert a Pipecat Language enum to Camb.ai language code. Args: language: The Language enum value to convert. Returns: The corresponding Camb.ai language code (BCP-47 format), or None if not supported. en-uszen-gbzen-auzes-eszes-mxzfr-frzfr-cazde-dezit-itzpt-ptzpt-brznl-nlzpl-plzru-ruzja-jpzko-krzzh-cnzzh-twzar-sazhi-inztr-trzvi-vnzth-thzid-idzms-myzsv-sezda-dkzno-nozfi-fizcs-czzel-grzhe-ilzhu-huzro-rozsk-skzuk-uazbg-bgzhr-hrzsr-rszsl-sizca-eszeu-eszgl-eszaf-zazsw-kezta-inzte-inzbn-inzmr-inzgu-inzkn-inzml-inzpa-inzur-pkzfa-irztl-phT) use_base_code)@rENEN_USEN_GBEN_AUESES_ESES_MXFRFR_FRFR_CADEDE_DEITPTPT_BRPT_PTNLPLRUJAKOZHZH_CNZH_TWARHITRVITHIDMSSVDANOFICSELHEHUROSKUKBGHRSRSLCAEUGLAFSWTATEBNMRGUKNMLPAURFATLr)r LANGUAGE_MAPs K/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/camb/tts.pylanguage_to_camb_languagerc.s? W?? ?  ?  W ?  ? ?  W? ? ?  W? ?  W?  W? ? !?"  W#?$  W%?&  W'?(  W)?*  W+?,  W-?. /?0 1?2  W3?4  W5?6  W7?8  W9?:  W;?<  W=?>  W??@  WA?B  WC?D  WE?F  WG?H  WI?J  WK?L  WM?N  WO?P  WQ?R  WS?T  WU?V  WW?X  WY?Z  W[?\  W]?^  W_?`  Wa?b  Wc?d  We?f  Wg?h  W W W W W W W W W W W}?LB Hl$ GGbufferc8t|dzdz}|d|||dfS)zSplit buffer into aligned audio (2-byte samples) and remainder. Args: buffer: Raw audio bytes to align. Returns: Tuple of (aligned audio bytes, remaining bytes). N)len)re aligned_sizes rb_get_aligned_audiorj{s0K1$)L -< &"7 77rdc<eZdZUdZedZedzezed<y)CambTTSSettingszSettings for CambTTSService. Parameters: user_instructions: Custom instructions for mars-instruct model only. Ignored for other models. Max 1000 characters. ctS)N)rrdrbzCambTTSSettings.sird)default_factoryNuser_instructions) __name__ __module__ __qualname____doc__rrqstrr__annotations__rnrdrbrlrls#16FW0XsTzI-XrdrlceZdZUdZeZeed<GddeZdddddddde d e e d e e d e d e e d e ede effdZ defdZdede e fdZdeffd Zede de deedffdZxZS)CambTTSServiceaTCamb.ai MARS text-to-speech service using the official SDK. Converts text to speech using Camb.ai's MARS TTS models with support for multiple languages. Models: - mars-flash: Fast inference, 22.05kHz output (default) - mars-pro: High quality, 48kHz output Example:: # Basic usage with mars-flash (fast) tts = CambTTSService(api_key="your-api-key", model="mars-flash") # High quality with mars-pro tts = CambTTSService( api_key="your-api-key", voice_id=12345, model="mars-pro", ) _settingsc`eZdZUdZej Zeeed<e dddZ ee ed<y)CambTTSService.InputParamsaInput parameters for Camb.ai TTS configuration. .. deprecated:: 0.0.105 Use ``settings=CambTTSSettings(...)`` instead. Parameters: language: Language for synthesis (BCP-47 format). Defaults to English. user_instructions: Custom instructions for mars-instruct model only. Ignored for other models. Max 1000 characters. rNiztCustom instructions for mars-instruct model only. Use to control tone, style, or pronunciation. Max 1000 characters.)default max_length descriptionrq) rrrsrtrurr#rrrwr rqrvrnrdrb InputParamsr|s> (0{{(8$2+0Q, 8C= rdrNgN@)voice_idmodeltimeout sample_rateparamssettingsapi_keyrrrrrrc vtdddd} |tdtd|| _|tdtd|| _|_td t|sM|j$|j |jxsd| _|j |j | _|| j|| j} |rJ|tj| k7r2tjd | d tj| d |d t |4d|dd| d|||_||_d|_y)a?Initialize the Camb.ai TTS service. Args: api_key: Camb.ai API key for authentication. voice_id: Voice ID to use. .. deprecated:: 0.0.105 Use ``settings=CambTTSSettings(voice=...)`` instead. model: TTS model to use. Options: "mars-flash" (fast), "mars-pro" (high quality). .. deprecated:: 0.0.105 Use ``settings=CambTTSSettings(model=...)`` instead. timeout: Request timeout in seconds. Defaults to 60.0 (minimum recommended by Camb.ai). sample_rate: Audio sample rate in Hz. If None, uses model-specific default. params: Additional voice parameters. If None, uses defaults. .. deprecated:: 0.0.105 Use ``settings=CambTTSSettings(...)`` instead. settings: Runtime-updatable settings. When provided alongside deprecated parameters, ``settings`` values take precedence. **kwargs: Additional arguments passed to parent TTSService. rix?r!N)rvoicerrqrrrrz Camb.ai's z model only supports z Hz sample rate. Current rate of zHz may cause issues.T)rpush_start_framepush_stop_framesrrn)rlrrrrlanguage_to_service_languagerq apply_updatergetr warningsuper__init___api_key_timeout_client) selfrrrrrrrkwargsdefault_settings_model __class__s rbrzCambTTSService.__init__sfN+"     "7OW E%*  "   ": H%-  "   "8_ =??.99&//JUg%-++79?9Q9Q$6    ) )( 3"'' ;*<*@*@*HH NNVH$9:L:P:PQW:X9YZ00;}A(Btext context_idcKtj|d|dt|dkDrtjd|dd} ||jj |jj |jjtdd}|jjd k(r/|jjr|jj|d <|j|d{|jJd d }|jjjdi|23d{}|s |jd{||z }t|\}}|s:t!||j"d |W77T7;6t|dk\r.t|\}}|rt!||j"d |yyy#t$$r}t'd|Yd}~yd}~wwxYww)a,Generate speech from text using Camb.ai's TTS API. Args: text: The text to synthesize into speech (max 3000 characters). context_id: The context ID for tracking audio frames. Yields: Frame: Audio frames containing the synthesized speech. z: Generating TTS []i z:Text too long for Camb.ai TTS (max 3000 chars), truncatingN pcm_s16le)format)rrr speech_modeloutput_configurationrrqz#Camb.ai TTS service not initializedrd)audior num_channelsrrgzCamb.ai TTS error: )errorrn)r debugrhrrzrrrr rqstart_tts_usage_metricsrtext_to_speechttsstop_ttfb_metricsrjrr Exceptionr) rrr tts_kwargs audio_bufferchunk aligned_audio_es rbrun_ttszCambTTSService.run_tts=s  v/vQ78 t9t  NNW X;D1 > NN00 NN33 $ 4 4(DK(X *J~~##64>>;[;[26..2R2R ./..t4 4 4<<+ R-R R+L ?t||::>>LL  e00222 E)L3E\2R/M<$."/(,(8(8)*'1 ! 5 2 M < A%#5l#C q *+$($4$4%&#- !& >%8#<= = = >sAG4B*G 1F2?G 1F5F 6F9G =G F G +G F G ;G G4 G1G,'G4,G11G4)rrrsrtrurlSettingsrwr rrvrintfloatrboolrrrrrrrrr __classcell__)rs@rbryrys,H i 0#'#%)(,.2XX3- X } X  Xc]X%X?+Xtd 3X 3(3- 3 T TB>#B>3B>>%QU+;VB>B>rdryN)-ru dataclassesrrtypingrrrrcambr camb.clientr logurur pydanticr r pipecat.frames.framesrrrrpipecat.services.settingsrrrrpipecat.services.tts_servicerpipecat.transcriptions.languagerr(pipecat.utils.tracing.service_decoratorsrrrvrrwrcbytestuplerjrlryrnrdrbrs )66-#% `_3F?&DcNJHJHXc]JHZ 8u 8ue|)< 8 YkY Yl>Zl>rd