qi (dZddlZddlZddlZddlmZmZddlmZddl m Z m Z m Z ddl mZddlmZddlmZdd lmZdd lmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"dd l#m$Z$dd l%m&Z&m'Z'm(Z(m)Z)dd l*m+Z+ddl,m-Z-ddl.m/Z/m0Z0ddl1m2Z2 ddl3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@eGddeEeZFeGdde'ZGGdde-ZHy#eA$r7ZBejdeBejdeDdeBdZB[BwwxYw)z%Speechmatics STT service integration.N) dataclassfield)Enum)AnyAsyncGeneratorClassVar) load_dotenv)logger) BaseModel)version) BotStartedSpeakingFrameBotStoppedSpeakingFrame CancelFrameEndFrame ErrorFrameFrameInterimTranscriptionFrame StartFrameTranscriptionFrameUserStartedSpeakingFrameUserStoppedSpeakingFrameVADUserStoppedSpeakingFrame)FrameDirection) NOT_GIVEN STTSettings _NotGiven_warn_deprecated_param)SPEECHMATICS_TTFS_P99) STTService)Languageresolve_language) traced_stt) AdditionalVocabEntryAgentClientMessageTypeAgentServerMessageType AudioEncodingEndOfUtteranceModeOperatingPointSpeakerFocusConfigSpeakerFocusModeSpeakerIdentifierSpeechSegmentConfigVoiceAgentClientVoiceAgentConfigVoiceAgentConfigPresetz Exception: zQIn order to use Speechmatics, you need to `pip install pipecat-ai[speechmatics]`.zMissing module: c eZdZdZdZdZdZdZy)TurnDetectionModeaEndpoint and turn detection handling mode. How the STT engine handles the endpointing of speech. If using Pipecat's built-in endpointing, then use `TurnDetectionMode.EXTERNAL` (default). To use the STT engine's built-in endpointing, then use `TurnDetectionMode.ADAPTIVE` for simple voice activity detection or `TurnDetectionMode.SMART_TURN` for more advanced ML-based endpointing. fixedexternaladaptive smart_turnN)__name__ __module__ __qualname____doc__FIXEDEXTERNALADAPTIVE SMART_TURNS/opt/pipecat/venv/lib/python3.12/site-packages/pipecat/services/speechmatics/stt.pyr1r1Es EHHJr?r1ceZdZUdZedZeezed<edZ e ezed<edZ eezed<ed Z eezed <ed Z eeezed <ed Zeeezed<edZeezed<edZeeezed<edZeeezed<edZeezed<edZeezed<edZeezed<edZeezed<edZeeefezed<edZe ezed <ed!Z!e ezed"<ed#Z"e ezed$<ed%Z#eezed&<ed'Z$e%ezed(<ed)Z&e ezed*<ed+Z'eeefezed,<e(hd-Z)e*e(eed.<e(dd hZ+e*e(eed/<y0)1SpeechmaticsSTTSettingsaSettings for SpeechmaticsSTTService. See ``SpeechmaticsSTTService.InputParams`` for detailed descriptions of each field. Parameters: domain: Domain for Speechmatics API. turn_detection_mode: Endpoint handling mode. speaker_active_format: Formatter for active speaker ID. speaker_passive_format: Formatter for passive speaker ID. focus_speakers: List of speaker IDs to focus on. ignore_speakers: List of speaker IDs to ignore. focus_mode: Speaker focus mode for diarization. known_speakers: List of known speaker labels and identifiers. additional_vocab: List of additional vocabulary entries. operating_point: Operating point for accuracy vs. latency. max_delay: Maximum delay in seconds for transcription. end_of_utterance_silence_trigger: Maximum delay for end of utterance trigger. end_of_utterance_max_delay: Maximum delay for end of utterance. punctuation_overrides: Punctuation overrides. include_partials: Include partial segment fragments. split_sentences: Emit finalized sentences mid-turn. enable_diarization: Enable speaker diarization. speaker_sensitivity: Diarization sensitivity. max_speakers: Maximum number of speakers to detect. prefer_current_speaker: Prefer current speaker ID. extra_params: Extra parameters for the STT engine. ctSNrr>r?r@z SpeechmaticsSTTSettings.tsIr?)default_factorydomainctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.usW`r?turn_detection_modectSrDrEr>r?r@rFz SpeechmaticsSTTSettings.v9r?speaker_active_formatctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.wsIr?speaker_passive_formatctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.xs)r?focus_speakersctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.yrLr?ignore_speakersctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.zYr? focus_modectSrDrEr>r?r@rFz SpeechmaticsSTTSettings.{Xar?known_speakersctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.}s r?additional_vocabctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.sPYr?operating_pointctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.sr? max_delayctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.rXr? end_of_utterance_silence_triggerctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.sR[r?end_of_utterance_max_delayctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.sV_r?punctuation_overridesctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.syr?include_partialsctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.sir?split_sentencesctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.sr?enable_diarizationctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.rLr?speaker_sensitivityctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.s)r? max_speakersctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.rUr?prefer_current_speakerctSrDrEr>r?r@rFz SpeechmaticsSTTSettings.rUr? extra_params>rVrQrS HOT_FIELDS LOCAL_FIELDSN),r6r7r8r9rrHstrr__annotations__rJr1rMrOrQlistrSrVr*rYr+r[r#r]r(r_floatrarcredictrrgboolrirkrmrointrqrs frozensetrtrrur>r?r@rBrBVs>8$4EFFC)OF9>O`9a*Y6a-2CT-U3?U.3DU.VC)OV,1BS,TNDI )T-2CT-UOT#Y*U/4EV/WJ 9,W:?Pa:bND*+i7b?D)@d/09<38HY2ZO^i/Z#(9J#KIuy K:?Pa:b$ei&7b49J[4\ 1\8=N_8`4S>I5`).?P)QdY&Q(->O(POTI%P+0AR+Sy(S-2CT-U*U$):K$LL# /L/4EV/WD9,W/4EV/WL$sCx.9,W,5 ,J3(.7 # $ .L(9S>*r?rBceZdZUdZeZeed<eZeZe Z e Z e Z e Z e Z GddeZGddeZdddej"ddded d edzd edzd edzd ededzdededzdedzffdZdeffd Zdedeeefffd Zdeffd Zdeffd Z d9dZ!d9dZ"d9dZ#dede$fdZ%deddfdZ&deeefddfd Z'deeefddfd!Z(deeefddfd"Z)deeefddfd#Z*deeefddfd$Z+deeefddfd%Z,de-d&e.ffd' Z/d:d(e0eeefd)eddfd*Z1de2ezd+eddfd,Z3defd-Z4e5d.ed/ed0e6fd1Z7d2e8de9e-dffd3Z:d0e6defd4Z;d5ed6e6dedzfd7ZS);SpeechmaticsSTTServicea$Speechmatics STT service implementation. This service provides real-time speech-to-text transcription using the Speechmatics API. It supports partial and final transcriptions, multiple languages, various audio formats, and speaker diarization. Event handlers available (in addition to STTService events): - on_speakers_result(service, speakers): Speaker diarization results received Example:: @stt.event_handler("on_speakers_result") async def on_speakers_result(service, speakers): ... _settingsceZdZUdZdZedzed<ejZ eezed<e jZ e ed<dZ edzed<dZedzed<gZeeed<gZeeed <ej&Zeed <gZeeed <gZeeed <ej4Zeed <dZedzed<dZedzed<dZ edzed<dZ!edzed<dZ"e#dzed<dZ$e%dzed<dZ&e%dzed<dZ'e%dzed<dZ(edzed<dZ)e*dzed<dZ+e%dzed<dZ,e#dzed<y)"SpeechmaticsSTTService.InputParamsaConfiguration parameters for Speechmatics STT service. Parameters: domain: Domain for Speechmatics API. Defaults to None. language: Language code for transcription. Defaults to `Language.EN`. turn_detection_mode: Endpoint handling, one of `TurnDetectionMode.FIXED`, `TurnDetectionMode.EXTERNAL`, `TurnDetectionMode.ADAPTIVE` and `TurnDetectionMode.SMART_TURN`. Defaults to `TurnDetectionMode.EXTERNAL`. speaker_active_format: Formatter for active speaker ID. This formatter is used to format the text output for individual speakers and ensures that the context is clear for language models further down the pipeline. The attributes `text` and `speaker_id` are available. The system instructions for the language model may need to include any necessary instructions to handle the formatting. Example: `@{speaker_id}: {text}`. Defaults to None. speaker_passive_format: Formatter for passive speaker ID. As with the speaker_active_format, the attributes `text` and `speaker_id` are available. Example: `@{speaker_id} [background]: {text}`. Defaults to None. focus_speakers: List of speaker IDs to focus on. When enabled, only these speakers are emitted as finalized frames and other speakers are considered passive. Words from other speakers are still processed, but only emitted when a focussed speaker has also said new words. A list of labels (e.g. `S1`, `S2`) or identifiers of known speakers (e.g. `speaker_1`, `speaker_2`) can be used. Defaults to []. ignore_speakers: List of speaker IDs to ignore. When enabled, these speakers are excluded from the transcription and their words are not processed. Their speech will not trigger any VAD or end of utterance detection. By default, any speaker with a label starting and ending with double underscores will be excluded (e.g. `__ASSISTANT__`). Defaults to []. focus_mode: Speaker focus mode for diarization. When set to `SpeakerFocusMode.RETAIN`, the STT engine will retain words spoken by other speakers (not listed in `ignore_speakers`) and process them as passive speaker frames. When set to `SpeakerFocusMode.IGNORE`, the STT engine will ignore words spoken by other speakers and they will not be processed. Defaults to `SpeakerFocusMode.RETAIN`. known_speakers: List of known speaker labels and identifiers. If you supply a list of labels and identifiers for speakers, then the STT engine will use them to attribute any spoken words to that speaker. This is useful when you want to attribute words to a specific speaker, such as the assistant or a specific user. Labels and identifiers can be obtained from a running STT session and then used in subsequent sessions. Identifiers are unique to each Speechmatics account and cannot be used across accounts. Refer to our examples on the format of the known_speakers parameter. Defaults to []. additional_vocab: List of additional vocabulary entries. If you supply a list of additional vocabulary entries, the this will increase the weight of the words in the vocabulary and help the STT engine to better transcribe the words. Defaults to []. audio_encoding: Audio encoding format. Defaults to AudioEncoding.PCM_S16LE. operating_point: Operating point for transcription accuracy vs. latency tradeoff. It is recommended to use OperatingPoint.ENHANCED for most use cases. Default to enhanced. max_delay: Maximum delay in seconds for transcription. This forces the STT engine to speed up the processing of transcribed words and reduces the interval between partial and final results. Lower values can have an impact on accuracy. end_of_utterance_silence_trigger: Maximum delay in seconds for end of utterance trigger. The delay is used to wait for any further transcribed words before emitting the final word frames. The value must be lower than max_delay. end_of_utterance_max_delay: Maximum delay in seconds for end of utterance delay. The delay is used to wait for any further transcribed words before emitting the final word frames. The value must be greater than end_of_utterance_silence_trigger. punctuation_overrides: Punctuation overrides. This allows you to override the punctuation in the STT engine. This is useful for languages that use different punctuation than English. See documentation for more information. include_partials: Include partial segment fragments (words) in the output of AddPartialSegment messages. Partial fragments from the STT will always be used for speaker activity detection. This setting is used only for the formatted text output of individual segments. split_sentences: Emit finalized sentences mid-turn. When enabled, as soon as a sentence is finalized, it will be emitted as a final segment. This is useful for applications that need to process sentences as they are finalized. Defaults to False. enable_diarization: Enable speaker diarization. When enabled, the STT engine will determine and attribute words to unique speakers. The speaker_sensitivity parameter can be used to adjust the sensitivity of diarization. speaker_sensitivity: Diarization sensitivity. A higher value increases the sensitivity of diarization and helps when two or more speakers have similar voices. max_speakers: Maximum number of speakers to detect. This forces the STT engine to cluster words into a fixed number of speakers. It should not be used to limit the number of speakers, unless it is clear that there will only be a known number of speakers. prefer_current_speaker: Prefer current speaker ID. When set to true, groups of words close together are given extra weight to be identified as the same speaker. extra_params: Extra parameters to pass to the STT engine. This is a dictionary of additional parameters that can be used to configure the STT engine. Default to None. NrHlanguagerJrMrOrQrSrVrYr[audio_encodingr]r_rarcrergrirkrmrorqrs)-r6r7r8r9rHrvrwr ENrr1r;rJrMrOrQrxrSr*RETAINrVrYr+r[r#r& PCM_S16LErr]r(r_ryrarcrerzrgr{rirkrmror|rqrsr>r?r@ InputParamsrszh V"d !#+;;(S..2C1K1K.K-1sTz0-1d 1%'S &%'c''7'>'> $>24./48:$349)6(?(? ?26$.5"& 54<&9=(%$,=37"EDL7-1td{1(,$+,'+++/D4K.,0UT\0#' cDj'.2t 2%) dTk(r?rc\eZdZUdZgZeeed<gZeeed<e jZ e ed<y)#SpeechmaticsSTTService.UpdateParamsaCUpdate parameters for Speechmatics STT service. .. deprecated:: 0.0.104 Use ``SpeechmaticsSTTSettings`` with ``STTUpdateSettingsFrame`` instead. Parameters: focus_speakers: List of speaker IDs to focus on. When enabled, only these speakers are emitted as finalized frames and other speakers are considered passive. Words from other speakers are still processed, but only emitted when a focussed speaker has also said new words. A list of labels (e.g. `S1`, `S2`) or identifiers of known speakers (e.g. `speaker_1`, `speaker_2`) can be used. Defaults to []. ignore_speakers: List of speaker IDs to ignore. When enabled, these speakers are excluded from the transcription and their words are not processed. Their speech will not trigger any VAD or end of utterance detection. By default, any speaker with a label starting and ending with double underscores will be excluded (e.g. `__ASSISTANT__`). Defaults to []. focus_mode: Speaker focus mode for diarization. When set to `SpeakerFocusMode.RETAIN`, the STT engine will retain words spoken by other speakers (not listed in `ignore_speakers`) and process them as passive speaker frames. When set to `SpeakerFocusMode.IGNORE`, the STT engine will ignore words spoken by other speakers and they will not be processed. Defaults to `SpeakerFocusMode.RETAIN`. rQrSrVN) r6r7r8r9rQrxrvrwrSr*rrVr>r?r@ UpdateParamsrVs6 6%'S &%'c''7'>'> $>r?rNT)api_keybase_url sample_rateencodingparamsshould_interruptsettingsttfs_p99_latencyrrrrrrrrc |xstjd|_|xstjdxsd|_|js t d|js t d||_|xst j} |j| | td$idddtjd dd tjd d d d dgdgdtjdgdgdddddddddddddddddddddddd} |t!dt|s| j"| _| j$| _| j&| _| j(} | | j*rd nd } | | _| j,xs| | _| j.| _| j0| _| j2| _| j4| _| j6| _| j8}| j:| _| j<| _| j>| _| j@| _ | jB| _!| jD| _"| jF| _#| j*| _| jH| _$| jJ| _%| jL| _&| jN| _'|| jQ|d|_)||_*|jW| |_,|jXj:jZ| _.t_ |d$||| d!| tcjd|_3|jXjhtjjltjjfv|_7tcjd|_8d|_9d"|_:d"|_;| j*r|jyd#yy)%aInitialize the Speechmatics STT service. Args: api_key: Speechmatics API key for authentication. Uses environment variable `SPEECHMATICS_API_KEY` if not provided. base_url: Base URL for Speechmatics API. Uses environment variable `SPEECHMATICS_RT_URL` or defaults to `wss://eu2.rt.speechmatics.com/v2`. sample_rate: Optional audio sample rate in Hz. encoding: Audio encoding format. Defaults to ``AudioEncoding.PCM_S16LE``. params: Input parameters for the service. .. deprecated:: 0.0.105 Use ``settings=SpeechmaticsSTTSettings(...)`` instead. should_interrupt: Determine whether the bot should be interrupted when Speechmatics turn_detection_mode is configured to detect user speech. settings: Runtime-updatable settings. When provided alongside deprecated ``params``, ``settings`` values take precedence. ttfs_p99_latency: P99 latency from speech end to final transcript in seconds. Override for your deployment. See https://github.com/pipecat-ai/stt-benchmark **kwargs: Additional arguments passed to STTService. SPEECHMATICS_API_KEYSPEECHMATICS_RT_URLz wss://eu2.rt.speechmatics.com/v2zMissing Speechmatics API keyzMissing Speechmatics base URLmodelNrrHrJrMz{text}rOrQrSrVrYr[r]r_rarcrergrirkrmrorqrsrz@{speaker_id}: {text})rrrFon_speakers_resultr>)=osgetenv_api_key _base_url ValueError_should_interruptrr_check_deprecated_argsrBr rr1r;r*rrrrHrJrMrkrOrQrSrVrYr[rr]r_rarcrergrirmrorqrs apply_update_client_audio_encoding _build_config_configvaluersuper__init__asyncioQueue_outbound_framesend_of_utterance_moder'r: _enable_vad_stt_msg_queue _stt_msg_task _is_speaking _bot_speaking_register_event_handler)selfrrrrrrrrkwargs_paramsdefault_settingsrM __class__s r@rzSpeechmaticsSTTService.__init__vs.F%I 2H(I  ^ "78 ^<^  }};< <~~<= =!1@2>>@ ##FG43  [[  !2 : :  #+  $,    (..    !  .2 (, #'! ""# $!% & $' (!%) *+ ,$(- ./ :   "8-D E,3,<,< )*1.. '7>7R7R 4(/(E(E%(03:3M3M/S[*:O 622K6K!73:2H2H /3:3J3J 0.5.@.@ +292H2H /4;4L4L 1"113:3J3J 0-4->-> *<<!A?F>`>` ;9@9V9V 64;4L4L 13:3J3J 06=6P6P 37>7R7R 4070D0D -:A:X:X 7070D0D -    ) )( 315 ')-););mmo"&!C!C  $ $  ' 'L "  >E]]_26#(#(  . .  ( ()= > /r?framectKt||d{|jd{y77w)z#Called when the new session starts.N)rstart_connectrrrs r@rzSpeechmaticsSTTService.starts1gmE"""mmo #848688deltareturncKt||d{}|s|Stjtjz}t |j |z }|rztj|d|j |j|j|_ |jd{|jd{|S|j tjzr3tj|d|j |jjr|jj|jj _|jj"|jj _|jj$|jj _|j&rZ|j&j)|jj |Stj|d|j d|S|j tjzr(tj|d|j |S7b77w)uApply settings delta, reconnecting only when necessary. Fields are classified into three categories (see ``SpeechmaticsSTTSettings``): * **HOT_FIELDS** – diarization speaker settings that can be pushed to a live Speechmatics connection without reconnecting. * **LOCAL_FIELDS** – formatting templates evaluated locally; no reconnect or API call needed. * Everything else – baked into ``VoiceAgentConfig`` at connection time and therefore require a full disconnect / reconnect. Args: delta: A settings delta. Returns: Dict mapping changed field names to their previous values. Nz% settings update requires reconnect: z applying hot settings update: z3 hot settings updated but diarization not enabled: z . ignoring.z4 local settings update, no special action required: )r_update_settingsrBrtrur{keysr debugrrr _disconnectrrkrQspeaker_configrSrVrupdate_diarization_config)rrchanged no_reconnectneeds_reconnectrs r@rz'SpeechmaticsSTTService._update_settingss&077N.99Bnn>\>\ ++;9=9R9R ++6<<LL::4<<;V;VW fOPWP\P\P^O__jk\\^5BB B LL&LW\\^L\]  K8 % !s5JI8B"J9I;:JI>F'J;J>JctKt||d{|jd{y77w)zCalled when the session ends.N)rstoprrs r@rzSpeechmaticsSTTService.stopVs4gl5!!!    " rctKt||d{|jd{y77w)z%Called when the session is cancelled.N)rcancelrrs r@rzSpeechmaticsSTTService.cancel[s4gnU###    $ rcKtjdjj_t j j dtj_dtttfffd }jjtj|jjtj|j rTjjtj"|jjtj$|jj&r*jjtj(|jjtj*|jjtj,|jjtj.|jjtj0|jjtj2| jj5d{tjdj:s%j=j?_yy7N#t6$r0}d_j9d|| d{7Yd}~hd}~wwxYww) zConnect to the STT service. - Create STT client - Register handlers for messages - Connect to the client - Start message processing task z' connecting to Speechmatics STT servicezpipecat/)rurlappconfigmessagec<jj|yrD)r put_nowait)rrs r@ add_messagez4SpeechmaticsSTTService._connect..add_messagews    * *7 3r?Nz connectedz!Error connecting to STT service:  error_msg exception) r rrrr-rrpipecat_versionrrzrvronr%ADD_PARTIAL_SEGMENT ADD_SEGMENTr START_OF_TURN END_OF_TURNrkSPEAKERS_RESULTERRORWARNINGINFOEND_OF_TURN_PREDICTIONEND_OF_UTTERANCEconnect Exception push_errorr create_task_process_stt_messages)rres` r@rzSpeechmaticsSTTService._connect`s&  vDEF$(#3#3  *:MM?,-.<< *   4c3h 4 .BBKP .::KH    LLOO2@@+ N LLOO2>> L << * * LLOO2BBK P .44kB .66 D .33[A .EE{S .??M b,,&&( ( ( LLD6, - !!!%!1!1$2L2L2N!OD " ) bDL//.OPQs,S_`/a a a bsNIK>K1K2K2K>K K; K6+K.,K61K>6K;;K>c`K|jr*|j|jd{d|_tj|d |jr"|jj d{d|_|jdd{y7s7'#t j$rtj|dYRt$r)}|jd||d{7Yd}~~d}~wwxYw7j#d|_|jdd{7wxYww)zDisconnect from the STT service. - Cancel message processing task - Disconnect the client - Emit on_disconnected event handler for clients Nz, disconnecting from Speechmatics STT servicez5 timeout while closing Speechmatics client connectionz#Error closing Speechmatics client: ron_disconnected) r cancel_taskr rr disconnectr TimeoutErrorwarningrr_call_event_handler)rrs r@rz"SpeechmaticsSTTService._disconnects   ""4#5#56 6 6!%D   vIJK >||ll--///  DL**+<= = = 70## [ NNdV#XY Z d//.QRSQT,Uab/c c c d > DL**+<= = =s+D.B!#D.)B%;B#<B%D.DD.#B%%+DDDC>3C64C>9D>DDD.D+$D'%D++D.cK |jjd{}|j|d{<77#tj$rYywxYww)zProcess messages from the STT client. Messages from the STT client are processed in a separate task to avoid blocking the main thread. They are handled in strict order in which they are received. N)rget_handle_messagerCancelledErrorrrs r@rz,SpeechmaticsSTTService._process_stt_messagess\   $ 3 3 7 7 99**733393%%   s<AAAAAAAAAAAc|}tj|jj}|j|_|j }|j||_|j |jnd|_|j|j ||_ t|j |jng|j |jng|j |jntj |_|j$ |j$ng|_|j& |j&ng|_dD]}t)||}|t+||| t-|j.t0r<|j.j3D]\}}t5||st+|||!|j6 |j6nd} t9| xsd|_|S)a8Build a ``VoiceAgentConfig`` from the given settings. Used both at init time (with explicit settings, before ``super().__init__`` has run) and before reconnecting so the connection always reflects the latest settings. Args: settings: Settings to build from. N)rQrSrV) r]r_rarcrergrirkrmrorqF)emit_sentences)r/loadrJrrrr"_language_to_speechmatics_languagerH_locale_to_speechmatics_locale output_localer)rQrSrVr*rrrYr[getattrsetattr isinstancersrzitemshasattrrir,speech_segment_config) rrsrrparamvalkeyrsplits r@rz$SpeechmaticsSTTService._build_configs (,,Q-B-B-H-HI!% 4 4::AA(K$%HH$8d #BB6??T\]!3/0/?/?/K1++QS121B1B1NA--TV'(||'?q||EUE\E\!  564D4D4P 0 0VX9:8J8J8V!"4"4\^   ,E!U#Cs+ ,$ annd +nn224 0 U63'FC/ 0 &'%6%6%B!!':%.SX'Y$ r?ctj5tjdtjdtddd|j j s td|j%|j|j j_|j%|j|j j_ |j%|j|j j_ |jr0|jj|j jyy#1swYxYw)aUpdates the speaker configuration. .. deprecated:: 0.0.104 Use ``STTUpdateSettingsFrame`` with ``SpeechmaticsSTTSettings(...)`` instead. This can update the speakers to listen to or ignore during an in-flight transcription. Only available if diarization is enabled. Args: params: Update parameters for the service. alwayszdupdate_params() is deprecated. Use STTUpdateSettingsFrame with SpeechmaticsSTTSettings(...) instead.NzDiarization is not enabled)warningscatch_warnings simplefilterwarnDeprecationWarningrrkrrQrrSrVrr)rrs r@ update_paramsz$SpeechmaticsSTTService.update_paramss  $ $ &   ! !( + MM8"  ||..9: :  ,9?9N9NDLL ' ' 6  ! ! -:@:P:PDLL ' ' 7    (5;5F5FDLL ' ' 2 << LL 2 24<<3N3N O )  s 0D>>ErcJK|jdd}|xtjk(r|j|d{yxtjk(r|j |d{yxtj k(r|j|d{yxtjk(r|j|d{ytjk(r|j|d{y tj|d|d|y7777V7,w)z%Handle a message from the STT client.rN z -> )rr%r_handle_partial_segmentr_handle_segmentr_handle_start_of_turnr_handle_end_of_turnr_handle_speakers_resultr r)rrevents r@rz&SpeechmaticsSTTService._handle_message0s Ir*;';;227;;;3'33**73335'55009993'33..w777'77227;;; vQugT';<<397;sW)rrrMrOformat)r*r/rs r@attr_from_segmentz>SpeechmaticsSTTService._send_frames..attr_from_segments;;{D144^^::f  #*++lD"A#KK3!++k2#KK 3  D";;|4:$[[5#KK 3!++i4  r?c3@K|]}|jddyw)is_eouFN)r).0r*s r@ z6SpeechmaticsSTTService._send_frames..sIWGKK%0Is|r/Trr)is_finalrz finalized transcript: z interim transcript: r>)rzrvrany_finalize_requestedconfirm_finalizerjoin_handle_transcriptionr rr/r push_frame) rrrframesr7r*rfinalized_textfrs ` r@rz#SpeechmaticsSTTService._send_framess ! tCH~ $sCx. 2 III,,%%' W_`G)G,=g,FG` `F!XX(&CQqy&CDN,, J8O-   LLD6!8&9QQ!&&9Q8RS T W_LS)G,=g,FG F LLD6!67O17O6PQ R )E//%( ( ( )-a'D  :R  8P )s`A'F*E3F E8"$FE=F!E? 4FFF6F "F+F,F?FrcK d|i}|j|tj|d||j|jj |y#t $r}t|d|d}~wwxYww)aSend a message to the STT service. This sends a message to the STT service via the underlying transport. If the session is not running, this will raise an exception. Messages in the wrong format will also cause an error. Args: message: Message to send to the STT service. **kwargs: Additional arguments passed to the underlying transport. rz sending message to STT: z error sending message to STT: N)updater rrr send_messager RuntimeError)rrrpayloadrs r@rIz#SpeechmaticsSTTService.send_messages L '*G NN6 " LLD6!:7)D E   T\\66w? @ L$'FqcJK K Ls)A?AAA? A<'A77A<<A?cy)zCheck if this service can generate processing metrics. Returns: True, as Speechmatics STT supports generation of metrics. Tr>)rs r@can_generate_metricsz+SpeechmaticsSTTService.can_generate_metricss r? transcriptr=rc Kyw)z'Record transcription event for tracing.Nr>)rrNr=rs r@rBz,SpeechmaticsSTTService._handle_transcription s  saudiocK |jr#|jj|d{dy7 #t$r4}td||j d{7Yd}~yd}~wwxYww)z/Adds audio to the audio buffer and yields None.NzSpeechmatics error: )r send_audiorrr)rrPrs r@run_sttzSpeechmaticsSTTService.run_stt%sh %||ll--e444J5 %3A378 8""$ $ $ %sCA;*;9 ;A;; A8$A3(A+)A3.A;3A88A;cxitjdtjdtjdtjdtj dtj dtjdtjdtjd tjd tjd tjd tjd tjdtjdtj dtj"ditj$dtj&dtj(dtj*dtj,dtj.dtj0dtj2dtj4dtj6dtj8dtj:dtj<dtj>dtj@d tjBd!tjDd"itjFd#tjHd$tjJd%tjLd&tjNd'tjPd(tjRd)tjTd*tjVd+tjXd,tjZd-tj\d.tj^d/tj`d0tjbd1tjdd2tjfd3tjhd4tjjd5tjld6i}to||d78}|stqd9||S):zConvert a Language enum to a Speechmatics language code. Args: language: The Language enum to convert. Returns: str: The Speechmatics language code, if found. arbaeubebgbnyuecahrcsdanleneoetfafifrgldeelhehihuitidgajakolvltmsmtcmnmrmnnoplptroruskslessvswtathtrugukurvicyT) use_base_codezUnsupported language: )9r ARBAEUBEBGBNYUECAHRCSDANLrEOETFAFIFRGLDEELHEHIHUITIDGAJAKOLVLTMSMTCMNMRMNNOPLPTRORUSKSLESSVSWTATHTRUGUKURVICYr!r)rrBASE_LANGUAGESr5s r@rz9SpeechmaticsSTTService._language_to_speechmatics_language3s7 KK7 KK7  KK7  KK 7 KK 7 KK 7  LL%7  KK7  KK7  KK7  KK7  KK7  KK7  KK7  KK7 KK!7 " KK#7 $ KK%7 & KK'7 ( KK)7 * KK+7 , KK-7 . KK/7 0 KK17 2 KK37 4 KK57 6 KK77 8 KK97 : KK;7 < KK=7 > KK?7 @ KKA7 B KKC7 D LL%E7 F KKG7 H KKI7 J KKK7 L KKM7 N KKO7 P KKQ7 R KKS7 T KKU7 V KKW7 X KKY7 Z KK[7 \ KK]7 ^ KK_7 ` KKa7 b KKc7 d KKe7 f KKg7 h KK KK KKm7 t"(N$O5hZ@A A r? base_codelocalecdtjdtjdtjdii}dt |vs||vry|j |j |d}|st j|d|d||S) aConvert a Language enum to a Speechmatics language / locale code. Args: base_code: The language code. locale: The Language enum to convert. Returns: str: The Speechmatics language code, if found. razen-GBzen-USzen-AU-Nz Unsupported output locale: z, defaulting to )r EN_GBEN_USEN_AUrvrr r)rrrLOCALESr5s r@rz5SpeechmaticsSTTService._locale_to_speechmatics_locales   c&k !Yg%=Y'++FD9 NNdV#?xGWXaWbc d r?cddtdtdzddfd}dddd d d d d ddddhdddddg}|D];\}}||vs ||||j|d'|j|||=y)aCheck arguments for deprecation and update params if necessary. This function will show deprecation warnings for deprecated arguments and migrate them to the new location in the params object. If the new location is None, the argument is not used. Args: kwargs: Keyword arguments passed to the constructor. params: Input parameters for the service. Noldnewrcddl}|j5|jd|r d|d|d}nd|d}|j|tdddy#1swYyxYw)Nrr`z"` is deprecated, use `InputParams.z` is deprecated and not used)r r r r r )rrr rs r@_deprecation_warningzKSpeechmaticsSTTService._check_deprecated_args.._deprecation_warningsp (((* ;%%%h/ !#&HQOG !#&BCG g'9:  ; ; ;s [?t[?* [? 4Z [?  [?d"[?[?*D0[? $,[?B 8,C8SRUX8t!! !+! 8Pt>2 "?&=?BR?B%P%P %PV=T#s(^==& .T#s(^ . . >T#s(^ > >04S>0d0*=c3h=D=& FT#s(^ F F ((>(4H)4S#X+?H)DH)]aH)\L*@3*FLRULZ^L.d c T U]  %5%^E4K-H%K8KKZXRUX\R\B19T19;19419r?r)Ir9rrr  dataclassesrrenumrtypingrrrdotenvr logurur pydanticr pipecatr rpipecat.frames.framesr rrrrrrrrrrr"pipecat.processors.frame_processorrpipecat.services.settingsrrrrpipecat.services.stt_latencyrpipecat.services.stt_servicerpipecat.transcriptions.languager r!(pipecat.utils.tracing.service_decoratorsr"speechmatics.voicer#r$r%r&r'r(r)r*r+r,r-r.r/ModuleNotFoundErrorrerrorrrvr1rBrr>r?r@rs, (00.    >__>3F?,. T" FkF FRr9Zr9M,FLL;qc"#FLL[ &qc* ++ ,sCD2D  D