qiKdZddlZddlmZmZddlmZmZmZm Z m Z ddl Z ddl m Z ddlmZddlmZmZmZmZddlmZmZmZmZdd lmZdd lmZmZdd lm Z d ed e e!fdZ"eGddeZ#GddeZ$y)zMiniMax text-to-speech service implementation. This module provides integration with MiniMax's T2A (Text-to-Audio) API for streaming text-to-speech synthesis. N) dataclassfield)AnyAsyncGeneratorMappingOptionalSelf)logger) BaseModel) ErrorFrameFrame StartFrameTTSAudioRawFrame) NOT_GIVEN TTSSettings _NotGiven_warn_deprecated_param) TTSService)Languageresolve_language) traced_ttslanguagereturnc nitjdtjdtjdtjdtj dtj dtjdtjdtjd tjd tjd tjd tjd tjdtjdtj dtj"ditj$dtj&dtj(dtj*dtj,dtj.dtj0dtj2dtj4dtj6dtj8dtj:dtj<dtj>dtj@d tjBd!tjDd"tjFd#tjHd$tjJd%tjLd&tjNd'tjPd(i}tS||d)*S)+zConvert a Language enum to MiniMax language format. Args: language: The Language enum value to convert. Returns: The corresponding MiniMax language name, or None if not supported. AfrikaansArabic BulgarianCatalanCzechDanishGermanGreekEnglishSpanishPersianFinnishFilipinoFrenchHebrewHindiCroatian Hungarian IndonesianItalianJapaneseKoreanMalay NorwegianNynorskDutchPolish PortugueseRomanianRussianSlovak SlovenianSwedishTamilThaiTurkish Ukrainian Vietnamesez Chinese,YueChineseF) use_base_code)*rAFARBGCACSDADEELENESFAFIFILFRHEHIHRHUIDITJAKOMSNBNNNLPLPTRORUSKSLSVTATHTRUKVIYUEZHr)r LANGUAGE_MAPs N/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/minimax/tts.pylanguage_to_minimax_languagerm!s|) [) X)  [)  Y )  W )  X )  X)  W)  Y)  Y)  Y)  Y)  j)  X)  X)  W!)"  Z#)$  [%)&  \')(  Y))*  Z+),  X-).  W/)0  [1)2  Y3)4  W5)6  X7)8  \9):  Z;)<  Y=)>  X?)@  [A)B  YC)D  WE)F  V Y [ \ m YQ)LV Hl% HHcheZdZUdZedZedzezed<edZ edzezed<edZ e dzezed <ed Z e dzezed <ed Zedzezed <edZedzezed<edZe dzezed<edee efdeffd ZxZS)MiniMaxTTSSettingsaSettings for MiniMaxHttpTTSService. Parameters: speed: Speech speed (range: 0.5 to 2.0). volume: Speech volume (range: 0 to 10). pitch: Pitch adjustment (range: -12 to 12). emotion: Emotional tone (options: "happy", "sad", "angry", "fearful", "disgusted", "surprised", "calm", "fluent"). text_normalization: Enable text normalization (Chinese/English). latex_read: Enable LaTeX formula reading. language_boost: Language boost string for multilingual support. ctSNrrnrlzMiniMaxTTSSettings.gIrn)default_factoryNspeedctSrrrsrtrnrlruzMiniMaxTTSSettings.hsYrnvolumectSrrrsrtrnrlruzMiniMaxTTSSettings.is)rnpitchctSrrrsrtrnrlruzMiniMaxTTSSettings.jrvrnemotionctSrrrsrtrnrlruzMiniMaxTTSSettings.ksPYrntext_normalizationctSrrrsrtrnrlruzMiniMaxTTSSettings.ls rn latex_readctSrrrsrtrnrlruzMiniMaxTTSSettings.ms9rnlanguage_boostsettingsrct|}|jdd}t|tr|jd|j d|jd|j d|jd|j d|jd|j d|jd|j d|jd |j d t ||S) uConstruct settings from a plain dict, destructuring legacy nested dicts. Handles ``voice_setting`` (with ``vol`` → ``volume`` rename) and ``audio_setting`` (with prefixed field mapping). voice_settingNrxrzvolr|r~rr)dictpop isinstance setdefaultgetsuper from_mapping)clsrflatvoice __class__s rlrzMiniMaxTTSSettings.from_mappingosH~$/ eT " OOGUYYw%7 8 OOHeii&6 7 OOGUYYw%7 8 OOIuyy'; < OO0%)) H%*  "   ":/A7 K%-  "   "8-? @)/ &*0-- ')/ &.4.?.? +??#'#D#DV__#UL#:F(7>> *&~~);;39>>(03FNN3CCYZlYmn //;#!002 --h7 Y. ;A:V:V$7,,8:@:S:S$7    ) )( 3  #!!%      ! $:Yxj9' %""#As (HHrcy)zCheck if this service can generate processing metrics. Returns: True, as MiniMax service supports metrics generation. Trt)rs rlcan_generate_metricsz*MiniMaxHttpTTSService.can_generate_metricsDs rnrct|S)zConvert a Language enum to MiniMax service language format. Args: language: The language to convert. Returns: The MiniMax-specific language name, or None if not supported. )rm)rrs rlrz2MiniMaxHttpTTSService.language_to_service_languageLs,H55rnframecKt||d{|j|_t j d|jy78w)zStart the MiniMax TTS service. Args: frame: The start frame containing initialization parameters. Nz*MiniMax TTS initialized with sample_rate: )rstartrrr debug)rrrs rlrzMiniMaxHttpTTSService.startWsI gmE""""&"2"2 A$BRBRASTU #sAA9Atext context_idc  Ktj|d|dddd|jd}|jj|jj |jj |jjd}|jj|jj|d <|jj|jj|d <|jj|jj|d <|j|j|j|jd }|j|||jj |d }|jj"|jj"|d< |j$j'|j(||4d{}|j*dk7rHd|j*}t-| dddd{|j/d{y|j1|d{t3} |j4} |j6j9| 23d{} | s | j;| d| vs"| j=d} | j=d| dz} | dk(r | dkDr| | d} X| | | }| | d} t?j@|ddjCd}d|vrtjd|jEdi}|s|jEd}|stGdtI|| dzD]\}|||| dzz}|s tJjM|}|r4|j/d{tO||jPd|^ d| vr*N77777V7:#tR$r"}tjTd|Yd}~d}~wwxYw#t>jV$r)}tjTd |d!|dd"Yd}~d}~wwxYw6dddd{7n#1d{7swYnxYwn)#tX$r}t-d#||$Yd}~nd}~wwxYw|j/d{7y#|j/d{7wxYww)%aGenerate TTS audio from text using MiniMax's streaming 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 []z!application/json, text/plain, */*zapplication/jsonzBearer )acceptz Content-Type Authorization)rrxrr|Nr~rr)bitrateformatchannelr)rr audio_settingrrr)headersjsonzMiniMax TTS error: HTTP )errorsdata:rzutf-8 extra_infoz$Received final chunk with extra infodataaudior)rr num_channelsrz Error converting hex to binary: zError decoding JSON: z, data: dzUnknown error occurred: )r exception)-r rrrrrxrzr|r~rrrrrrrrrrpostrstatusr stop_ttfb_metricsstart_tts_usage_metrics bytearray chunk_sizecontent iter_chunkedextendfindrloadsdecoderrangelenbytesfromhexrr ValueErrorrJSONDecodeError Exception)rrrrrrpayloadresponse error_messagebuffer CHUNK_SIZEchunkr next_start data_blockr chunk_data audio_datai hex_chunk audio_chunkes rlrun_ttszMiniMaxHttpTTSService.run_ttsas  v/vQ78:.&t}}o6 ,,^^))>>((^^))  >> ! ! -'+~~'='=M) $ >> , , 826..2S2SM. / >> $ $ 0*...*C*CM, '**((**22  ll**^^))   >> ( ( 4(,(E(EG$ %U +}}))g*O %O %??c)&>x>O$PM$=99 O %O %h((* * *Y224888#!__ #+#3#3#@#@#L@%@%%  MM%(#f, & H 5%+[[519%E %+$qy)/!&,E*%= !' !4+%#'::jn.C.CG.L#MD+t3 & -S T ()-&")=J#- ()3)@J#- (&+1c*ozA~%N-,6q1zA~;M,N '0$,!-27-- 2JK'2.2.D.D.F(F(F.>2=8<8H8H9:7A /*)*-=#f,-O %O %h +Y9@%^)G(2!-$*LL*J1#(N%&%- !- $33%"LL"7s(:dsCSBT U% %y$MO %O %O %O %O %b P%=aS#AQO O O P((* * *$((* * *sFS,Q!N:Q! /Q 9 Q!N=Q! SOS"Q 6O75Q ,P80O1P84Q AQ AO9Q O9$Q %O98Q 9*O9$*O O  O /O91Q 8Q :Q!=Q!SQ P8 O  O6 O1 ,O91O6 6O99P5 P0*Q 0P55Q 9 Q!QQ! QQ QQ! R$! R*R=R$RR$ SR S$R?8R;9R??S)rrrrrpSettingsrr rrraiohttp ClientSessionrrrrrrrrrrr rrrs@rlrrs4"H!!!8i!8N;#"&%)(,15M$M$ M$  M$ } M$3-M$!..M$c]M$M$%M$-.M$^d 6X 6(3- 6VVH+#H+3H+>%QU+;VH+H+rnr)%rr dataclassesrrtypingrrrrr rlogurur pydanticr pipecat.frames.framesr r rrpipecat.services.settingsrrrrpipecat.services.tts_servicerpipecat.transcriptions.languagerr(pipecat.utils.tracing.service_decoratorsrrrmrprrtrnrlr$s  (?? `_3F?4I84I 4In (*(* (*Vf+Jf+rn