o ҵi@sdZddlmZddlZddlZddlZddlZddlZddlZ ddl Z ddl Z ddl m Z ddlmZmZmZddlmZmZmZz ddlZddlmZWn eyYedwdd lmZmZmZmZd Zd Z d Z!d Z"dZ#dZ$ dXdYddZ%dZddZ&d[d!d"Z'd\d#d$Z(d]d&d'Z)d^d)d*Z*d_d.d/Z+d`d2d3Z,dad7d8Z-e$dd9dbd=d>Z.e"e$dd?d@dcdCdDZ/dddFdGZ0dedHdIZ1dfdKdLZ2dMZ3dNZ4dOZ5GdPdQdQZ6GdRdSdSZ7GdTdUdUZ8GdVdWdWZ9dS)gz:Orpheus TTS Client - Stream speech from the Orpheus model.) annotationsN)Path) AsyncIteratorIteratorOptional)quoteurlparse urlunparse)ConnectionClosedzEwebsockets package is required. Install with: pip install orpheus-tts)AuthenticationErrorConnectionError OrpheusErrorStreamingErrorORPHEUS_TTS_MULTIPLEX_WS_URLdemozhttp://35.232.65.178i@$@urlstrheadersOptional[dict[str, str]]c stddddd}z8|r5ztj|fd|i|IdHWWSty4tj|fd|i|IdHYWSwtj|fi|IdHWStyu}z(t|}|d vrZtd |d ||d krctd ||durptd|d|d}~ww)zBCreate websocket connection across websockets version differences.i )max_size ping_interval ping_timeout close_timeoutadditional_headersN extra_headersiizOAuthentication failed while connecting to the Orpheus streaming endpoint (HTTP z). Please verify your API key.zdThe Orpheus streaming endpoint was not found (HTTP 404). Please verify the configured websocket URL.zGThe Orpheus streaming endpoint rejected the websocket connection (HTTP z:). Please verify endpoint availability and service health.)dict websocketsconnect TypeError Exception_extract_websocket_status_coder r )rrkwargsexc status_coder+F/home/ubuntu/.local/lib/python3.10/site-packages/orpheus_tts/client.py_connect_websocket(sT  "r-voicevoice_endpoint_mapdict[str, str]returncCsL|}z||WSty%dt|}td|d|w)zyResolve a voice name to its WebSocket endpoint URL. Raises: ValueError: If the voice is not recognized. z, zUnknown voice 'z'. Valid voices: )striplowerKeyErrorjoinsortedkeys ValueError)r.r/normalized_voicevalidr+r+r, _get_endpointNs   r;datar"local_config_pathrNonecCs.|jjddd|jtj|ddddddS)NT)parentsexist_ok)indent sort_keysutf-8encoding)parentmkdir write_textjsondumps)r<r=r+r+r,_write_local_config^srLcCs|s td|t|jddpd}t|tr(t|dtr(|d}n|}t|ts7td|di}|D]\}}t | }t | }|rS|sTq=|||<q=|sbtd||S) NzLocal config file not found: rDrE{}r/zInvalid local config at z$: expected voice mapping JSON objectz$No voice endpoint mappings found in ) existsr8rJloads read_text isinstancer"getitemsrr2r3)r=r<r/ normalized voice_name endpoint_url voice_keyendpoint_valuer+r+r,*_load_voice_endpoint_map_from_local_configcs(     rY config_hostcCs|}|s tdd|vrd|}t|}|js"td|d|j}|s/td|dd|vr>|ds>d|d }|jdurF|jn|dt}|j d }t |j pXd ||d d d fS) NzConfig host must not be emptyz://zhttp://zInvalid config host 'z/'. Expected something like http://35.232.65.178':[]/http) r2r8rnetlochostname startswithport_DEFAULT_CONFIG_SERVICE_PORTpathrstripr scheme)rZvalueparsedrcrb base_pathr+r+r,_normalize_config_host~s$    rmprovidercCs8t|}ttdd}t|dd}|d|d|S)Nra)safer_)rmr_DEFAULT_CLIENT_NAMEr2)rZrnbase_urlclient_segmentprovider_segmentr+r+r,_build_config_service_urls rtr*int service_urlcCs@|dvr d|d|dS|dkrd|dSd|d |d S) Nr z[Unable to load voice configuration from the config service because access was denied (HTTP z) for provider zH. Please verify your SDK credentials and service authorization settings.r!z/Voice configuration was not found for provider zZ (HTTP 404). Please verify the provider value and confirm this configuration is published.z0Unable to load voice configuration for provider z (HTTP z=). Please try again or contact support if the issue persists.r+r*rvrnr+r+r,!_format_config_service_http_errors rxws_urlwebsocket_countcCs d|dS)NzIUnable to establish a connection to the Orpheus streaming endpoint using z[ websocket(s). Please verify your API key, endpoint availability, and network connectivity.r+ryrzr+r+r,"_format_multiplex_connection_errorsr|r)r& Optional[int]c Cs|t|dd}t|dd}t|tr|St|dd}t|tr |St|dd}|dursrc@sbeZdZdZd%d&ddZd'd d Zd'd dZd'ddZd(ddZd)ddZ d*ddZ d+d#d$Z dS),_MultiplexedWebSocketConnectionz=Single websocket that can carry many concurrent TTS requests.NryrrrcCsH||_||_d|_d|_d|_t|_t|_d|_ i|_ i|_ dS)NFr) ryrws _connected_request_counterrLock _send_lock _state_lock_receiver_task_states_server_to_client)rryrr+r+r,rJs   z(_MultiplexedWebSocketConnection.__init__r1r>cs2t|j|jIdH|_d|_t||_dS)NT) r-ryrrrr create_task _receive_looprrr+r+r,r$Vsz'_MultiplexedWebSocketConnection.connectcsd|_|jdur$|jz|jIdHWn tjy Ynwd|_|jdurBz |jIdHWn ty<Ynwd|_dSdSNF)rrcancelrCancelledErrorrcloser&rr+r+r,r[s$     z%_MultiplexedWebSocketConnection.closec sz$|j2z3dHW}t|tr||IdHq||IdHq6WdStjy.tyM}z|t d|IdHWYd}~dSd}~ww)NzMultiplex receive failed: ) rrQbytes_handle_binary_message_handle_json_messagerrr&_fail_all_requestsr )rmessageer+r+r,rks (z-_MultiplexedWebSocketConnection._receive_looprrc st|dkr dSt|ddd}|dd}|sdS|j4IdH=|j|}|durKt|j}|j D]}||vrJ|}||j|<nq;|durU|j|nd}WdIdHn 1IdHsgwY|dur{|j |IdHdSdS)Nbig) lenru from_bytesrrrRsetvaluesrr7rput)rrserver_request_idaudiormapped_request_idscandidate_request_idstater+r+r,rws,    ( z6_MultiplexedWebSocketConnection._handle_binary_messagec s8zt|}Wn tjyYdSw|d}|d}|d}|dur4t|dtr4|d}|dkri|duri|duri|j4IdHt||jt|<WdIdHdS1IdHsbwYdSd}|durtt|}n7t|dtr|d}n)|dur|j4IdH|jt|}WdIdHn 1IdHswY|durdS|j4IdH|j |}WdIdHn 1IdHswY|durdS|dr t|d}d| vsd| vrt ||_ nt ||_ |jdIdHdS|d r|jdIdHdSdS) Ntyperclient_request_idracceptedrauthkeydone)rJrOrrRrQrurrrrr3r rrrr) rrr<msg_typerrrr error_messager+r+r,rsX      ((    z4_MultiplexedWebSocketConnection._handle_json_messagerr&c sz|j4IdHt|j}WdIdHn 1IdHs wY|D]}|jdur1||_|jdIdHq'dSr)rlistrrrrr)rrstatesrr+r+r,rs( z2_MultiplexedWebSocketConnection._fail_all_requeststextr. max_tokensru temperaturerrepetition_penaltyAsyncIterator[bytes]c s|jr |jdur td|j4IdHdtjt}||j<WdIdHn 1IdHs6wY|||||d}z|j 4IdH|j t |IdHWdIdHn 1IdHshwY |j IdH}|dur{n|Vqn|jdur|jW|j4IdH+|jdfdd|jD} | D] } |j| dqWdIdHdS1IdHswYdS|j4IdH*|jdfdd|jD} | D] } |j| dqWdIdHw1IdHswYw)Nz$Multiplex websocket is not connectedreq_)rpromptr.rrrTcsg|] \}}|kr|qSr+r+).0 server_id client_idrr+r, s zB_MultiplexedWebSocketConnection.stream_request..)rrr ruuiduuid4hexrrrsendrrrRrpoprrS) rrr.rrrrritemstale_server_idsrr+rr,stream_requestsZ ( (  > *z._MultiplexedWebSocketConnection.stream_requestr)ryrrrr1r>)rrr1r>)rrr1r>)rr&r1r> rrr.rrrurrrrr1r) rrrrrr$rrrrrrr+r+r+r,rGs     -rc@s\eZdZdZ  d%d&d d Zd'ddZd'ddZd(ddZd)ddZd*ddZ d+d#d$Z dS),_MultiplexWebSocketPoolz?Pool of multiplex-capable websockets with load-aware selection.Nrryrrzrurrmax_inflight_per_socketcCs>||_td||_||_td||_g|_i|_t|_ dS)Nrr) rymaxrzrr_clients _inflightr Condition_cond)rryrzrrr+r+r,rs  z _MultiplexWebSocketPool.__init__r1r>csfddtjfddtjDIdH}d}|D]\}}|dur1j|dj|<q|dur;|dur;|}qjsO|durE|ttj jddS)Nc sVtjj}z |IdH|dfWSty*}z d|fWYd}~Sd}~wwr)rryrr$r&)clientr)rr+r, _create_ones z7_MultiplexWebSocketPool.initialize.._create_onecsg|]}qSr+r+)r_)rr+r,rsz6_MultiplexWebSocketPool.initialize..rr{) rgatherrangerzrappendrr r|ry)rcreated first_errorrrr+)rrr, initializes* $   z"_MultiplexWebSocketPool.initializec s|j4IdHt|j}|j|j|jWdIdHn 1IdHs-wY|D] }|IdHq4dSr)rrrclearr notify_allr)rclientsrr+r+r,r!s    (z_MultiplexWebSocketPool.closercCs t|jS)z3Return whether at least one websocket is connected.)rrrr+r+r,has_connections*s z'_MultiplexWebSocketPool.has_connectionsrc sj4IdHH jstdtjfddd}|D](}j|d}jdkr2|jkr2q|dj|<|WdIdHSjIdHq 1IdHsVwYdS)NTz,No multiplex websocket connections availablecsj|dSNr)rrR)crr+r,6sz9_MultiplexWebSocketPool._acquire_client..)rrr)rrr r6rrRrwait)r candidatesrinflightr+rr,_acquire_client.s& z'_MultiplexWebSocketPool._acquire_clientrc sp|j4IdH#||jvrtd|j|d|j|<|jWdIdHdS1IdHs1wYdS)Nrr)rrrnotify)rrr+r+r,_release_client@s   .z'_MultiplexWebSocketPool._release_clientrr.rrrrrc Csd|IdH}z |j|||||d2z 3dHW}|Vq6W||IdHdS||IdHw)Nrr.rrr)r rr)rrr.rrrrchunkr+r+r,rFs& z&_MultiplexWebSocketPool.stream_requestr)ryrrzrurrrrur)r1r)r1r)rrr1r>r) rrrrrrrrr rrr+r+r+r,rs    rc@s eZdZdZ    dJddddKddZdLddZefddddddMdd ZdNd!d"ZdOd$d%Z dPd'd(Z dQd)d*Z d+d,Z d-d.Z d/d0Zd1d2ZdRd6d7Z 8dSdddd9dTd;d<ZdTd=d>ZdUd?d@Z 8dSdddd9dRdAdBZdVdCdDZ 8dSdWdFdGZ 8dSdWdHdIZdS)X OrpheusClienta- Client for streaming speech from the Orpheus TTS model. Example: >>> from orpheus_tts import OrpheusClient >>> >>> # Option 1: Auto-connect (includes connection time in first request) >>> client = OrpheusClient(provider="PROVIDER_NAME") >>> for chunk in client.stream("Hello!", voice="josh"): ... audio_player.write(chunk) >>> >>> # Option 2: Pre-connect for lowest latency (recommended) >>> client = OrpheusClient(provider="PROVIDER_NAME") >>> client.connect() # Pool of 16 connections per endpoint >>> for chunk in client.stream("Hello!", voice="josh"): ... audio_player.write(chunk) # TTFA excludes handshake! >>> client.close() >>> >>> # Option 3: Async usage (same pool, same connect) >>> client = OrpheusClient(provider="PROVIDER_NAME") >>> client.connect() >>> async for chunk in client.stream_async("Hello!", voice="josh"): ... audio_player.write(chunk) >>> client.close() N ?皙?)rnr/api_keyrrrurrrrnr/rcCs||_||_||_||_|durdd|D|_n |r$t|d|_ntdi|_g|_ d|_ d|_ d|_ d|_ d|_d|_d|_dS)a Initialize the Orpheus TTS client. Args: api_key: API key for authentication (optional for now). max_tokens: Maximum tokens to generate (default: 3000). temperature: Sampling temperature (default: 1.0). repetition_penalty: Repetition penalty (default: 1.1). provider: Provider used to load the voice configuration (for example "PROVIDER_NAME"). voice_endpoint_map: Explicit voice->url mapping override. NcSs&i|]\}}t|t|qSr+)rr2r3)rkvr+r+r, sz*OrpheusClient.__init__..)rnz=A provider is required unless voice_endpoint_map is provided.rF)rrrrrS_voice_endpoint_maprr8_pools_all_connections_multiplex_pool_multiplex_ws_url_websocket_count_max_inflight_per_socket_loop_threadr)rrrrrrnr/r+r+r,rws0   zOrpheusClient.__init__r1cCs|jsdSdd|jiS)z;Build websocket auth headers when an API key is configured.N AuthorizationzApi-Key )rrr+r+r,_get_auth_headersszOrpheusClient._get_auth_headersr)ryr.rzr pool_sizeryr.rzr}rr>c sVjrdS|dur|durtd|}|dur!|dur!t|j}|dur*tt}|_td|dur5|n|_ td|_ t _ fdd}tj|dd_jt j|d j }z#|jd d tj} jduowj} | s| std d_WdSttfyty} z td | | d} ~ ww)aY Pre-establish WebSocket connections for lowest latency. Multiplex mode (recommended): - Pass ws_url, or pass voice, or set ORPHEUS_TTS_MULTIPLEX_WS_URL. - Creates websocket_count multiplex sockets to a single endpoint. - A single socket can serve many concurrent requests. Legacy mode (compat): - If ws_url/voice/env are not provided, uses per-voice endpoint pools. - Creates pool_size connections per unique endpoint. Args: pool_size: Legacy per-endpoint pool size. ws_url: Multiplex gateway websocket URL. voice: Voice name to resolve to a multiplex endpoint URL. websocket_count: Number of multiplex sockets (default: pool_size). max_inflight_per_socket: Optional cap per socket (0 = unlimited). Example: >>> client = OrpheusClient(provider="PROVIDER_NAME") >>> client.connect() # 16 connections per endpoint >>> for chunk in client.stream("Hello!", voice="josh"): ... process(chunk) Nz3Pass either ws_url or voice to connect(), not both.rrcstjjdSr)rset_event_loopr  run_foreverr+rr+r,run_loops z'OrpheusClient.connect..run_loopTtargetdaemon)r$g>@rz!Failed to connect to any endpointzFailed to connect: )rr8r;rosgetenv_DEFAULT_MULTIPLEX_WS_ENVrrrrrnew_event_loopr  threadingThreadr!startrun_coroutine_threadsafe _create_poolsresultrrrrr r rr&) rr$ryr.rzrresolved_ws_urlr'futurehas_legacy_connectionshas_multiplex_connectionsrr+rr,r$sF"         zOrpheusClient.connectc sjr}tjj|jd_jIdHdStj }d fdd }|D] }t j |<q.g}|D]}t |D] }||||qBq.create_connection)rrr9ru)rr#rrrrrrrrrrrrrrrr) rr$r endpointsr:rtasksiresultsrrrr+rr,r3s@  zOrpheusClient._create_poolsrcsHt||j}|j|}|durtd|d|IdH}||fS)z7Acquire a connection from the pool for the given voice.NzNo connection pool for voice 'z,'. Call connect() first or check voice name.)r;rrrRr )rr.rpoolrr+r+r,_acquire-s   zOrpheusClient._acquirercszt|dr |j n|j}Wn tyd}Ynw|j|}|dur'dS|r3||IdHdSzt||IdH}||IdHWdStyRYdSw)z._close_allrrrg@F)r rrrr2r4r&rrrrrcall_soon_threadsafestopr!r5r)rrKr6r+rr,rNs(       zOrpheusClient.closecCs|Srr+rr+r+r, __enter__|szOrpheusClient.__enter__cCs |dSrrrexc_typeexc_valexc_tbr+r+r,__exit__szOrpheusClient.__exit__cs|Srr+rr+r+r, __aenter__szOrpheusClient.__aenter__cs|dSrrOrPr+r+r, __aexit__szOrpheusClient.__aexit__rOptional[float]rc Cs |||dur |n|j|dur|n|j|dur|n|jd}|t|IdHztt||j}t dt |Wn t yDYnw|2zE3dHW} t | trV| VqGz,t| } d| vrx| d} d| vspd| vrtt| t| | drWdSWqGtjyYqGw6dS)z;Internal: stream audio on an existing WebSocket connection.N)rr.rrrrrrr)rrrrrrr;rrget_running_looprun_in_executorrr&rQrrJrOr3r rrRr) rrrr.rrr request_body health_urlrr< error_msgr+r+r,_stream_on_connectionsB      z#OrpheusClient._stream_on_connectionjosh)rrrIterator[bytes]ccs|}t||j}|jr7|jdur7|jdur(||||||EdHdS|||||||EdHdS| ||||||EdHdS)aV Stream audio synchronously from the Orpheus TTS model. If connect() was called first, uses a pooled connection for lowest latency. Otherwise, creates a new connection per request. Args: text: The text to convert to speech. voice: Voice to use. See orpheus_tts.VOICES for options. max_tokens: Override default max_tokens. temperature: Override default temperature. repetition_penalty: Override default repetition_penalty. Yields: bytes: Raw PCM audio chunks (int16, 48kHz, mono). Raises: ValueError: If voice is not recognized. AuthenticationError: If API key is invalid. ConnectionError: If connection to service fails. StreamingError: If an error occurs during streaming. N) r2r3r;rrr r_stream_from_multiplex_pool_stream_from_pool_stream_with_new_connection)rrr.rrrrr+r+r,streams      zOrpheusClient.streamc #stgfddfdd}t|j} }|dur-n|Vq$z|jddWntyR} z sH| WYd} ~ nd} ~ wwrYd dS) z*Stream using the multiplex websocket pool.csrjdur tdjjdurnjdurnjdur%njd2z 3dHW}|q*6dS)Nz!Multiplex pool is not initializedr)rr rrrrr)r) chunk_queuerrrrrr.r+r,_runs  z7OrpheusClient._stream_from_multiplex_pool.._runc pz0zIdHWnty!}z |WYd}~n d}~wwWddSWddSdwrr&rrrrerd error_holderr+r, _run_wrapperz?OrpheusClient._stream_from_multiplex_pool.._run_wrapperTNr@rr rrrr2r rRr4r&r) rrr.rrrrkr6rrr+) rerdrjrrrrrr.r,r`s,  z)OrpheusClient._stream_from_multiplex_poolc #stg fddfdd}t|j} } | dur.n| Vq%z|jddWntyS} z sI| WYd} ~ nd} ~ wwrZd dS) z2Stream using a pooled connection (lowest latency).c sd}t|D]j}d}z.IdH\}}|2z 3dHW}|q 6|IdHWdSty]|durM|IdH||dkrUYqtd|dtyq|durp|IdHwdS)Nr%Connection closed unexpectedly after  retries)rr@r]rrFr r r&) max_retriesattemptrrrrdrrrrrrr.r+r,re)s:      z-OrpheusClient._stream_from_pool.._runc rfrrgrhrir+r,rkDrlz5OrpheusClient._stream_from_pool.._run_wrapperTNrmrrrn) rrrr.rrrrkr6rrr+ rerdrrjrrrrrr.r,ras,  zOrpheusClient._stream_from_poolc s0  t jjrzjdurztg fddfdd}t |j}t } | dj IdH} | durLn| Vq=z|j ddWntyq} z sg| WYd} ~ nd} ~ wwrxd dSd} zz!tIdH} |  2z 3dHW} | Vq6WnCty} ztd | | d} ~ wty} ztd | | d} ~ wttfyty} ztd | | d} ~ wwW| durz | IdHWdStyYdSwdS| durz | IdHWwtyYwww) aW Stream audio asynchronously from the Orpheus TTS model. If connect() was called first, uses a pooled connection for lowest latency. Otherwise, creates a new connection per request. Args: text: The text to convert to speech. voice: Voice to use. See orpheus_tts.VOICES for options. max_tokens: Override default max_tokens. temperature: Override default temperature. repetition_penalty: Override default repetition_penalty. Yields: bytes: Raw PCM audio chunks (int16, 48kHz, mono). Raises: ValueError: If voice is not recognized. AuthenticationError: If API key is invalid. ConnectionError: If connection to service fails. StreamingError: If an error occurs during streaming. Nc sPjdur5jjdurnjdurnjdur!njd2z 3dHW}|q&6dSd}t|D]j}d}z.IdH\}}|2z 3dHW}|qT6 |IdHWdSt y|dur |IdH||dkrYq;t d|dt y|dur |IdHwdS)Nrrorrprq) rrrrrrrr@r]rFr r r&)rrrrsrrrtr+r,resV         z(OrpheusClient.stream_async.._runc rfrrgrhrir+r,rkrlz0OrpheusClient.stream_async.._run_wrapperT@rrz Connection closed unexpectedly: z"Failed to connect to TTS service: zUnexpected error: )r2r3r;rrr rrrr2rXrYrRr4r&rr-r#r]r r OSErrorr rr r) rrr.rrrrkr6looprrrr+rur, stream_async]s  +   zOrpheusClient.stream_asyncc #stg f ddfdd}tj|dd}| } | dur0n| Vq'|jdd r@d dS) z?Stream with a fresh connection (includes handshake in latency).csd}zZz#tIdH}|2z 3dHW}|q6Wnty>}z |WYd}~nd}~wwW|durWz |IdHWn tyVYnwddS|duruz |IdHWn tytYnwdwr)r-r#r]rr&rr)rrr) rdrrjrrrrrr.r+r,collects:     z:OrpheusClient._stream_with_new_connection..collectc sTt}t|z|W|||dS|||wr)rr.r%run_until_completeshutdown_asyncgensr)rx)rzr+r, run_asyncs   z.run_asyncTr(Nrvrr)rrr/r0r1rRr5) rrr.rrrrr}threadrr+) rdrzrrjrrrrrr.r,rbs"    z)OrpheusClient._stream_with_new_connectionrcKs"t|j||fi|}d|S)ak Generate complete audio and return as bytes. Convenience method that collects all streamed chunks. Args: text: The text to convert to speech. voice: Voice to use. **kwargs: Additional arguments passed to stream(). Returns: bytes: Complete PCM audio (int16, 48kHz, mono). )rrcr5)rrr.r(chunksr+r+r,stream_to_bytess zOrpheusClient.stream_to_bytescs>g}|j||fi|2z 3dHW}||q 6d|S)aA Generate complete audio asynchronously and return as bytes. Args: text: The text to convert to speech. voice: Voice to use. **kwargs: Additional arguments passed to stream_async(). Returns: bytes: Complete PCM audio (int16, 48kHz, mono). Nr)ryrr5)rrr.r(rrr+r+r,stream_to_bytes_async3s    z#OrpheusClient.stream_to_bytes_async)Nrrr) rrrrurrrrrnrr/r)r1r) r$ruryrr.rrzr}rrur1r>)r$rur1r>)r.r)rrr) rrr.rrr}rrWrrWr1r)r^) rrr.rrr}rrWrrWr1r_)rrrrr.rrr}rrWrrWr1r_)rrr.rrrrr}rrWrrWr1r_)rrr.rr1r)rrrrrr#_DEFAULT_POOL_SIZEr$r3r@rFrrNrTrUrVr]rcr`raryrbrrr+r+r+r,r\s^ 3 P - . 0 0 5D : rr)rrrr)r.rr/r0r1r)r<r"r=rr1r>)r=rr1r0)rZrr1r)rZrrnrr1r)r*rurvrrnrr1r)ryrrzrur1r)r)r&r1r}) rnrrZrrrr=rr1r0) rnrrZrrrr=rrrr1r0)rrr1r)rrr1r>)rr"r1r):r __future__rrrJr+rr/ urllib.errorrurllib.requestrpathlibrtypingrrr urllib.parserrr r#websockets.exceptionsr ImportErrororpheus_tts.exceptionsr r r rrr-rp_DEFAULT_CONFIG_SERVICE_HOSTrf'_DEFAULT_CONFIG_REQUEST_TIMEOUT_SECONDSr-r;rLrYrmrtrxr|r'rrrrr SAMPLE_RATE SAMPLE_WIDTHCHANNELSrrrrr+r+r+r,sr    &       9    .h