+ TV-j)aRvt0tRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI t ^RI t ^RI t ^RI Ht^RIHtHtHt^RIHt^RIHtHtHtHt^RIHt^RIHt^RIt ^RI!t!^RI"t"^RI#H$t$H%t%H&t&H't'H(t(H)t)H*t*H+t+H,t,^RI-H.t.^R I/H0t0H1t1H2t2^R I3H4t4^R I5H6t6^R I7H8t9^R I7H:t;^RIt>H?t?H@t@HAtAHBtB^RICHDtDHEtEHFtFHGtGHHtH^RIIHJtJHKtK^RILHMtMRRltN!RR4tO]$!4tPRRltQ]P!R4tS]S'd/]SPR4Uu.uFqP4NK upMR.tV]Q!]P]V4]RRl4tW]W]PPnY!RR]64tZ!RR ]64t[!R!R"]64t\]O!4t]]P!4t_Rs`]^k]!R#R$44ta]!R%R&44tb]!R'R(44tcR)R*ltdR+R,lteR-R.0tf!R/R0]D4tg!R1R24th!R3R4]D4ti!R5R6]D4tjR7R8ltkR9R:ltlR;R<ltmR=R>ltn]PPR?4R@4tp]PPRA4RB4tq]PPRA4RCRDl4ts]PPRA4RERFl4tu]PPRG4RHRIl4tv]PPRJ4RwRKRLll4tw]PPRM4]%!RN4]&!RN4]&!R4]&!RO4]&!RP4]&!RQ4]&!^4]&!RO4]&!R4]&!RR4]&!R4]&!RS4]&!RO4]&!R43RTRUll4tx]PPRV4]%!RN4]&!RW4]&!RX4]&!RY4]&!^43RZR[ll4tyRxR\R]lltz]PPR^4R_R`l4t|Rat}RbRclt~RdReltRfRgltRhRiltRjt]^k/t]^kRkRlltRmRnlt]PPRo4RpRql4t!RrRs4tRtt]Ru8Xd ]!4R#R#uupi)yaMain module for MLX Audio API server. This module provides a FastAPI-based server for hosting MLX Audio models, including Text-to-Speech (TTS), Speech-to-Text (STT), and Speech-to-Speech (S2S) models. It offers an OpenAI-compatible API for Audio completions and model management. N)asynccontextmanager)asdict dataclass is_dataclass)Path)AnyDictListOptional)unquote) FastAPIFileForm HTTPExceptionRequestResponse UploadFile WebSocketWebSocketDisconnect)CORSMiddleware) JSONResponsePlainTextResponseStreamingResponse)RepositoryNotFoundError) BaseModel)read)write)VAD_SAMPLE_RATEServerVadConfig StreamingVadTurnDetectionError TurnEventKindparse_turn_detection)BaseModelExecutionAdapterInferenceBrokerInferenceHandleInferenceRequestInferenceResultChunk) TTSBatchItemTTSBatchOptions) load_modelc0V^8dQhR\R\/#)objreturn)r)formats"a/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/mlx_audio/server.py __annotate__r1Bs33c\V4'd"\V\4'g \V4p\V\4'd/VP 4UUu/uFwrV\ V4bK upp#\V\4'dVUu.uFp\ V4NK up#\V\4'd?\P!V4'dR#\P!V4'dR#V#\V\P4'dH\P!V4'dR#\P!V4'dR#\V4#V#uuppiuupi)zPRecursively sanitize NaN, Infinity, and -Infinity values for JSON serialization.N) r isinstancetyperdictitemssanitize_for_jsonlistfloatnpisnanisinffloating)r-kvitems& r0r8r8BsCC!6!6Sk#t47IIK@KDA$Q''K@@ C  478CD!$'C88 C   88C== XXc]] C % % 88C== XXc]]Sz !A8s E%E+cPa]tRt^\toRtV3RlRltV3RlRltRtRtVt R#) ModelProvidercH/Vn\P!4VnR#N)modelsasyncioLocklockselfs&r0__init__ModelProvider.__init__]s13 LLN r2c <V^8dQhRS[/#r, model_namestr)r/ __classdict__s"r0r1ModelProvider.__annotate__as''S'r2cxWP9d\V4VPV&VPV,#rE)rFr*rKrPs&&r0r*ModelProvider.load_modelas. [[ (&0&@c<V^8dQh/S[;R&S[R,;R&S[;R&S[;R&S[;R&S[;R&S[;R&S[R,;R &S[;R &S[R,;R &S[;R &S[S[,;R &#)r,rNlanguagerrchunk_durationframe_thresholdrcontextprefill_step_sizetextword_timestampstimestamp_granularities)rRrYrr:r )r/rSs"r0r1!TranscriptionRequest.__annotate__s JDj      4Z! *!&c]1r2r)rbrcrdrerrrrrrrrrrrrrfrgrhs@r0rrsEHGJ NOFG!D!O-1r2rc,a]tRt^toV3RltRtVtR#)SeparationResponsec><V^8dQh/S[;R&S[;R&S[;R&#)r,targetresidual sample_rate)rRr)r/rSs"r0r1SeparationResponse.__annotate__s& KMr2rNrbrcrdrerrfrgrhs@r0rrr2rc,a]tRt^toV3RltRtVtR#)SpeechTaskPayloadc&<V^8dQh/S[;R&#r,request)r)r/rSs"r0r1SpeechTaskPayload.__annotate__s r2rNrrhs@r0rrrr2rc,a]tRt^toV3RltRtVtR#)TranscriptionTaskPayloadc^<V^8dQh/S[;R&S[;R&S[P;R&S[;R&#)r,rfilenameaudior)rrRr;ndarrayr)r/rSs"r0r1%TranscriptionTaskPayload.__annotate__s: !!M ::   r2rNrrhs@r0rrrr2rc,a]tRt^toV3RltRtVtR#)SeparationTaskPayloadcv<V^8dQh/S[;R&S[P;R&S[;R&S[;R&S[;R&S[;R&#)r,rPrr descriptionmethodsteps)rRr;rr)r/rSs"r0r1"SeparationTaskPayload.__annotate__sRO ::    K  Jr2rNrrhs@r0rrrr2rc$V^8dQhR\/#rOrQ)r/s"r0r1r1s11#1r2c,\PV4#rEmodel_providerr*rPs&r0_load_model_for_inferencers  $ $Z 00r2c(V^8dQhR\RR/#)r,rPr.NrQ)r/s"r0r1r1sCDr2c"\P!\V4GRjxL R#L \dh\dp\RRT: R2R7ThRp?i\ dp\RRT: RT 2R7ThRp?ii;i5i) aLoad ``model_name`` synchronously and translate failures into HTTPException. Routes that return a ``StreamingResponse`` commit the HTTP status + headers before the body generator runs, so any failure inside the inference worker surfaces as 200 OK with an empty body. Pre-flighting the load here lets the framework's exception handlers turn the failure into a real HTTP error response. Warm models are a no-op (``ModelProvider.load_model`` is cached). NzModel not found: z. is not a known HuggingFace repo or local path status_codedetailizFailed to load model z: )rG to_threadrrr Exception)rPexcs& r0_preflight_model_loadrs  9:FFF  "&zn4bc   *:.3%@  sIA?+)+A?+A<A<A A<!A<"A77A<<A?rrc2a]tRtRtoV3RlRltRtVtR#)STTExecutionAdapteric$<V^8dQhRS[RR/#r,rr.Nr&)r/rSs"r0r1 STTExecutionAdapter.__annotate__s.."2.t.r2c&VPp\PPVP;'gR4wr4T;'gRpR\ P !4 RVP V 2p\WbPVP4\VP4pVPPR0RR7p\P!VP 4p VP#4U U u/uF$wrWP$9gV \&9gK"WbK& pp p VP !V3/VBp \)V R4'd\)V R4'dRp V FpVP*P-4'dM\/V\04'dW, p R VR V /pMBR VP2R \5VR R 4R\5VRR 4R\5VRR 4R\5VRR 4/pVP7\8P:!\=V44R,4K MUVP*P-4'g6VP7\8P:!\=V 44R,4\PP?V4'd\P@!V4TPC4R #uup p i \PP?T4'd\P@!T4ii;i).mp3z/tmp/_rTexclude exclude_none__iter____next__r accumulatedstart start_timeNendend_timeis_finalr )"payloadospathsplitextrtime request_id audio_writerrrrPr model_dumpinspect signaturegenerater7 parameters_STT_EXTRA_KWARGShasattr cancel_eventis_setr4rRrgetattr emit_datajsondumpsr8existsremove emit_done)rKrrrextsuffixtmp_path stt_model gen_kwargsrkeyvalueresultaccumulated_textchunk chunk_datas&& r0 run_serialSTTExecutionAdapter.run_serials,3OO!!'"2"2"8"8b9499;-q););(v-F"G$"NOww~~h'' (#C<ww~~h'' (#(s,A&K<K  K &D#K 5K K>LrN)rbrcrdrerrfrgrhs@r0rrs..r2rca]tRtRtoV3RlRlt]V3RlRl4tV3RlRltV3RlR ltV3R lR lt V3R lR lt Rt Vt R#)_TTSAdapterContinuousSessioniAc<V^8dQhRR/#)r,adapterTTSExecutionAdapterr)r/rSs"r0r1)_TTSAdapterContinuousSession.__annotate__Bs # #' #r2cXWnW n/Vn\4Vn^VnR#)N)r model_session _requestsset_emitted_audio_next_sequence_id)rKrrs&$$r0rL%_TTSAdapterContinuousSession.__init__Bs(  *68(+!"r2c <V^8dQhRS[/#r,r.)rY)r/rSs"r0r1rOs>>d>r2c`VPP;'dVP'*#rE)ridlerrJs&r0r#!_TTSAdapterContinuousSession.idleNs#!!&&==t~~+==r2c$<V^8dQhRS[RR/#rr)r/rSs"r0r1rRs  . 4 r2cVPP4'dVP4R#VPpVPpVP pV;P ^, unWP V&VPP\VVPVPVPVPVPVPVP VP"R7 .4R#)N) sequence_idrrrrrrrr)rrrrrrrraddr(rrrrrrrr)rKrrspeech_requestr's&& r0submit#_TTSAdapterContinuousSession.submitRs    & & ( (     %,__ ,,  !#&-{#  +'--(..+44(..)00(..,66+44   r2c<V^8dQhRR/#r,r.Nr)r/rSs"r0r1rls(?(?d(?r2cFVP4VPP4pVEFopVPP VP 4pVfK/VP eyVPVP 4VP4VPPVP R4VPPVP 4KVPEeVP^8dVPPpVP fyVP\#R44VP4VPPVP R4VPPVP 4EKqVP$P'VVVPVP 4VPP)VP 4VP*'gEKVP VP9dVP\-RRR74VP4VPPVP R4VPPVP 4EKr R#)Nz2TTS batch event included audio without sample_rateNo audio generatedr)_cancel_disconnected_requestsrsteprgetr'error emit_errorrpoprdiscardrsamplesrrr ValueErrorr _emit_audior(doner)rKeventseventrr)s& r0r2!_TTSAdapterContinuousSession.stepls **,##((*Enn(():):;G{{&""5;;/!!#""5#4#4d;##++E,=,=>{{&5==1+<070G0G$$,&&"#WX%%'NN&&u'8'8$?''//0A0AB (("KK%%  ##''(9(9:zzz$$D,?,??&&%#>RS!!#""5#4#4d;##++E,=,=>Kr2c$<V^8dQhRS[RR/#)r,r4r.N) BaseException)r/rSs"r0r1rs$$-$D$r2c\VPP44F$pVPV4VP 4K& VPP 4VP P 4R#rE)r9rvaluesr5rclearr)rKr4rs&& r0fail!_TTSAdapterContinuousSession.fails\DNN1134G   u %    5  !!#r2c<V^8dQhRR/#r-r)r/rSs"r0r1rs55t5r2cf\VPP44FwrVPP 4'gK'VP P V4VP4VPPVR4VPPV4K R#rE) r9rr7rrrcancelrr6rr7)rKr'rs& r0r1:_TTSAdapterContinuousSession._cancel_disconnected_requestss$()=)=)?$@ K''..00    % %k 2     NN  {D 1    ' ' 4 %Ar2)rrrrrN) rbrcrdrerLpropertyr#r*r2rDr1rfrgrhs@r0rrAsL # #>>  4(?(?T$$55r2rc8a]tRtRtoRtRtV3RlRltV3RlRltV3RlR ltV3R lR lt V3R lR lt V3RlRlt V3RlRlt V3RlRlt V3RlRltV3RlRltV3RlRltV3RlRltV3RlRltV3RlRltV3R lR!ltR"tVtR##)$ri_mlx_audio_loaded_modelc\P!RR4p\^\V44VnR# \ d ^TnR#i;i)MLX_AUDIO_TTS_MAX_BATCH_SIZE8N)rgetenvmaxrmax_batch_sizer9)rKraw_max_batch_sizes& r0rLTTSExecutionAdapter.__init__sEYY'EsK $"%a-?)@"AD  $"#D  $s5A  A c <V^8dQhRS[/#rr)r/rSs"r0r1 TTSExecutionAdapter.__annotate__s.>r2c\WPR4pVf,\VP4p\ WPV4V#rE)r_REQUEST_MODEL_ATTRrrPsetattrrKrrs&& r0_get_model_for_request*TTSExecutionAdapter._get_model_for_requests>!9!94@ =-g.@.@AE G55u = r2c&<V^8dQhRS[RS[/#r,rr.)r&r))r/rSs"r0r1rVs   ,<    r2c  VPPp\VPVPVP VP VPVPVPVPVPVPR7 #)) rrrrrrrrrRr) rrr)rrrrrrrrrRrrKrr)s&& r0_build_batch_options(TTSExecutionAdapter._build_batch_optionssx(/(?(?&22 && &&-@@%00$..!((-@@.."**  r2c<<V^8dQhRS[RS[S[S[3,/#r^)r&r6rRr)r/rSs"r0r1rVs(OO'7ODcNOr2cVVPPpVPR0RR7#)rTr)rrrr`s&& r0_request_kwargs#TTSExecutionAdapter._request_kwargss)(/(?(?(('(NNr2c <V^8dQhRS[/#r,namerQ)r/rSs"r0r1rVs  C r2c\WR4p\V4'gR#\V4PR8XdV\ V49dR#V#)Nz unittest.mock)rcallabler5rcvars)rKrrir s&&& r0_get_callable_model_attr,TTSExecutionAdapter._get_callable_model_attrsAT* ; ! !_ 4T%[9P r2c,<V^8dQhRS[RS[RS[/#)r,r continuousr.r&rY)r/rSs"r0r1rVs+"    r2c VPPpV'dRMRpVPW4p\V4'd!\ V!R/VP V4B4#VP 'dR#VP'gVP'dR#VPR9dR#VPR9dR#VPR9dR#R#)supports_tts_continuous_batchsupports_tts_batchFTrNrNr) rrrmrkrYrerrrrrr)rKrrrpr) hook_namehooks&&&$ r0_model_supports_request+TTSExecutionAdapter._model_supports_requests)0(?(?/9 +?S ,,U> D>>=t33G<=> >    # # #~'>'>'>   6   { 2   { 2r2c&<V^8dQhRS[RS[/#r^rq)r/rSs"r0r1rVs7GDr2cVPVR4pVfR#VPWRR7'gR#VPPpVP'dR#\ P !V4pVPpRV9dR#VP'd RV9dR#VP'd RV9dR#VPR 9d RV9dR#VPR 9d RV9dR#VPR 9d RV9dR#VP'd R V9dR#VP'd R V9dR#R #)batch_generateFrptextsvoices instructsgendersspeedspitches ref_audios ref_textsTrurv)rmryrrrrrrrrrrrrr)rKrrr}r)rparamss&&& r0_can_call_batch_generate,TTSExecutionAdapter._can_call_batch_generates66u>NO  !++Eu+MM(/(?(?  %%n5 %% &     HF$:  " " "{&'@   69F;R   { 2xv7M   { 2y7N  # # # F(B  " " "{&'@r2c&<V^8dQhRS[RS[/#r^rq)r/rSs"r0r1rVs  ;K PT r2cdVPVR4pVRJ;'dVPWRR7#)create_tts_batch_sessionNTr~)rmry)rKrrcreate_sessions&&& r0_can_call_continuous_session0TTSExecutionAdapter._can_call_continuous_sessionsI66  & T)  d.J.J t/K/  r2c&<V^8dQhRS[RS[/#r^rq)r/rSs"r0r1rVs==&6=4=r2cFVPV4pVPW!4#rE)r[rrZs&& r0supports_batch"TTSExecutionAdapter.supports_batchs#++G4,,U<3/V BFp VP@PC4'd)\DPF!4VPI4R#VP4'd+VPKVVV PLV P4KVPOV PL4V eKV Pp K VP4'dVPI4R#V'g\RRR7h\PPR!V4p VPKWW4VPI4R#)r/ Reference audio file not found: r) load_audio model_typespark)rvolume_normalizeNrrrrrrrrrrrrrrrrr0)*rrr[rr4rRrrrrmlx_audio.tts.generaterrrrrrrrrrrrrrrrrrrrrrrmx clear_cacherr:rappendr; concatenate) rKrrr)rrr normalize audio_chunksrgenerate_kwargsr concatenated_audios && r0rTTSExecutionAdapter.run_serialSs%,__ ++G4",, Is3377>>),,# #=i[I :|4TT9I9IW9TI"!--!*I    ^)) ^))  n++  ^))  //  11     //  >55  ^))  ^))  !."C"C  n++  !."C"C  .33 ~--! &nn^%9%9M_MF##**,, !!#$$$  "LL&& ##FLL1&"("4"4K!N$      C8LM M^^L9 2DRr2c4<V^8dQhRS[S[,RR/#)r,requestsr.N)r9r&)r/rSs"r0r1rVs%V V $'7"8V TV r2c aa\V4^8XdSPV^,4R#SPV^,4o\;QJd VV3RlV4F 'dK RM RM!VV3RlV44'gVFpSPV4K R#V^,PP pVUu.uF"q"PP P NK$ ppVUu.uF"q"PP PNK$ ppVUu.uF"q"PP PNK$ ppVUu.uF"q"PP PNK$ ppVUu.uF"q"PP PNK$ ppVUu.uF"q"PP PNK$ p pVUu.uF"q"PP PNK$ p pVUu.uF"q"PP PNK$ p pSPSR4p V fVFpSPV4K R#\P !V 4p /RVbRVbRVbR VbR VbR V bR V bR V bRVP"bRVP$bRVP&bRVP(bRVP*bRVP,bRRbRVP.bpVP14UUu/uFwppWP29gKVVbK pppVUu.uFp.NK ppVUu.uFpRNK ppV !R/VBFpVP4pV^8gV\V48dK(VV,pVP6P94'dKSVV,P;VP<4VP>VV&K \AV4FwppVP6P94'dVPC4K8VV,pVV,pV'dVf/VPE\GRRR74VPC4K\V4^8Xd V^,M\HPJ!V4pSPMVVPP VV4VPC4K R#uupiuupiuupiuupiuupiuupiuupiuupiuuppiuupiuupi)Nc3H<"TFpSPSV4xK R#5irE)r).0rrrKs& r0 0TTSExecutionAdapter.run_batch..s$ IQgD ) )% 9 9s"FTr}rrrrrrrrrrrrrrrrr/r0rr)'lenrr[allrrrrrrrrrrrmrrrrrrrrrr7r sequence_idxrrrrr enumeraterr5rr;rr:)rKrrfirst_speech_requestrrrrrrrrr}rkwargsr r raudio_chunks_by_sequence sample_ratesr rchunksrrrsf& @r0 run_batchTTSExecutionAdapter.run_batchs x=A  OOHQK ( ++HQK8s IQ sss IQ   $($ .6qk.A.A.I.I>FGh7((..hG?GHxG//))//xHEMNX'__,,55X N?GHxG//))//xHAIJg??**11J@HIW??**00IGOPxGoo--77x PEMNX'__,,55X N66u>NO  !#($ %%n5  U f    f  w  w   *    /;;  -77  .99  )//  )//  !"6"I"I  e +33! &*0 )7:33BVBV;VJCJ  BJ4JAR 4J8@)A1$ )A$.v.F!..La<3x=#@|,G##**,, $\ 2 9 9&,, G)/););L &/&/x%8 !L'##**,,!!#-l;F&|4K[0""!c:NO!!#!$V!1F1Ir~~f7ME   ''      +&9gHHNHJIPN6 5K)AsH(S2(S (S(S$<(S)*(S.(S3(S8S=S=+ T< T)rRN)rbrcrdrerXrLr[rarermryrrrrrrrr:rrrfrgrhs@r0rrs3$   OO  6>  ==AA  "''   -- FFPV V r2rcJa]tRtRtoRtV3RlRltV3RlRltRtVtR#) SeparationExecutionAdapteric0RVnRVnRVnR#rE) _model_name_model _processorrJs&r0rL#SeparationExecutionAdapter.__init__s'+ r2c <V^8dQhRS[/#rOrQ)r/rSs"r0r1'SeparationExecutionAdapter.__annotate__s , , ,r2cVPV8Xd'VPeVPVP3#^RIHpHpVP V4VnVP V4VnWnVPVP3#)N)SAMAudioSAMAudioProcessor)rrr mlx_audio.stsrrfrom_pretrained)rKrPrrs&& r0_get_resources)SeparationExecutionAdapter._get_resourcessl   z )dkk.E;;/ /=+;;JG..z: %{{DOO++r2c$<V^8dQhRS[RR/#rr)r/rSs"r0r1rs//"2/t/r2c 2VPpR\P!4 RVP R2p\W2PVP 4VP VP4wrEV!VP.V.R7p^VP^,, pRVPRV/pVPVPVPVPVPV^2R7p \ P"!4\$P&!V P(^,4p \$P&!V P*^,4p VP p Rp VP-\/V !W4V !W4V R74\0P2P5V4'd\0P6!V4TP94R # \0P2P5T4'd\0P6!T4ii;i) z/tmp/separation_rz.wav) descriptionsaudiosr step_size)rr anchor_idsanchor_alignmentode_optode_decode_chunk_sizec\P!4p\W VRR7VP^4\P !VP 44PR4#)wavrutf-8)rrrseekbase64 b64encoderdecode) audio_arraysrrs&& r0audio_to_base64>SeparationExecutionAdapter.run_serial..audio_to_base64#sFFEB A'' 6==gFFr2)rrrN)rrrrrrrrPrrr separate_longrrrrrrr;arrayrrrrrrrrr)rKrrrr processorbatchrrr  target_audioresidual_audiorrs&& r0r%SeparationExecutionAdapter.run_serials)0%diik]!G4F4F3GtLHmmW-@-@A( $#2273E3EF E%112 zE W]]Q./IiHG((||"// ++!&!7!7&( )F NN 88FMM!$45LXXfooa&89N++K G   "*<E,^I + ww~~h'' (#ww~~h'' (#(s D7G>H)rrrN) rbrcrdrerLrrrfrgrhs@r0rrs , ,//r2rc$V^8dQhR\/#r!)r$)r/s"r0r1r17sor2c\f[\4pVPR\44VPR\ 44VPR\ 44Vs\#)Nsttr separation)r{r$register_adapterrrr)brokers r0get_inference_brokerr7sX "':'<=':'<= .H.JK! r2c0V^8dQhR\R\/#)r,handler.)r%r')r/s"r0r1r1Bs<<<Generate speech audio following the OpenAI text-to-speech API.r/rrNr)rrTr endpoint_kindrPrnormalized_kwargsrzaudio/zContent-Dispositionzattachment; filename=speech.) media_typeheaders)rr4rRrrrrrrrr*rrrrrr)rrrs&& r0 tts_speechr1sZ(9(93??ww~~g//009':K:K9LM   ... ! # * *==!'2!,,gYT,R~~ +F !&2G3345 !%A'BYBYAZ#[  /sA!D$2DDBDz/v1/audio/voicesc:V^8dQhR\\,/#)r,rr rR)r/s"r0r1r1sHSMr2c "V'g\RRR7h^RIHpV!VR.R7p\ T4R , pTP 4'g RRR TR ./#\RTPR444pRRR TR TUu.uF pRTRT/NK up/# \dpRRR TR .R \ T4/uR p?#R p?ii;iuupi5i)a]List available voices for a TTS model. Resolves the model's HF snapshot directory and enumerates ``voices/*.safetensors`` files (the convention used by Kokoro and similar voice-pack-based TTS models). Returns an empty ``data`` list for models that don't ship per-voice packs so callers can fall back to whatever defaults make sense for that model. r/z!model query parameter is requiredr)snapshot_downloadzvoices/*.safetensors)repo_idallow_patternsrr9rrr4Nrc38"TFqPxK R#5irE)stem)rps& r0rtts_voices..sE$DqFF$Dsz *.safetensorsrri) rhuggingface_hubr5rrRris_dirsortedglob)rr5snapshote voices_dirrr@s& r0 tts_voicesrCs 4WXXO5$+A*B  h(*J     &'5&"== EJOOO$DE EF&v6v!$61%v6  O&'5&"gs1vNNO7s@CBACCC B?"B:4B?5C:B??Cz/v1/audio/transcriptions.Frrrndjsonc$V^8dQhR\R\R\R\\,R\R\ R\ R\ R \R \\,R \ R \\,R \R\R\\,/#)r,rfilerrrrrrrrrrrrr)rrrRr rYrr:)r/s"r0r1r1soo o o osm o  o  ooo oc]oo 3-ooo&c]or2c "\VVVVVVVV V V V VR7 pVP4GRjxL p\P!V4p\ VRR7wppVP 4\ VP4GRjxL \4PRVP\TVP;'gRVVR7VPR0R R 7VPR 7pV R9EdRpRp\V4GRjxL pVPR8XdEMVPR8Xd VP hVP"p\%V\&4'dVP)RRR7p\+V4P-4FpVP/4pV'gK\0P2!V4p\%T\64'dRT9gRT9dTpK\\%T\64'gKtR T9gK}TTP9R 4;'gR, pK EK8VP;4VfR V/pV R 8Xd3\=VP9R 4;'gRP/44#V R 8Xd5\?R VP9R 4;'gRP/4/4#\?V4#\A\CVV4RR7#ELEL`EL \4dEKli;i TP;4i;i5i)aTranscribe audio using an STT model. The default ``response_format`` (``ndjson``) preserves mlx-audio's native ``application/x-ndjson`` streaming transport, where each line is a JSON object emitted by the underlying STT model (text deltas while streaming, or the full whisper segment payload for batch transcription). For OpenAI Audio API compatibility, ``response_format`` also accepts: * ``text`` -- ``text/plain`` body with the final transcript only. * ``json`` -- ``application/json`` body shaped ``{"text": "..."}``. * ``verbose_json`` -- ``application/json`` body with the full payload from the underlying model (``text``, ``segments``, ``language``, ...), passed through unchanged. See https://platform.openai.com/docs/api-reference/audio/createTranscription ) rrrrrrrrrrrrNF always_2drz audio.mp3)rrrrrTrr,rrrr;r4rreplace)errorssegmentsrzapplication/x-ndjson)r/)rr verbose_json)"rrrr audio_readcloserrrr*rrrrr r r4rr4bytesrrR splitlinesr(rloadsrr6r3rHrrrr)rrFrrrrrrrrrrrrrrrtmprrrfullrrlinerawr-s&&&&&&&&&&&&&&& r0stt_transcriptionsrWsF#%'+ ' 7 G D **T C3%0IE2IIK  ... ! # * *==(]]11k  ",,gYT,R~~+ F::#  3F;;::'::(++%}}dE**;;wy;ADt9//1C))+C !"jjo"#t,,"c)Z3->"#C..6S=#swwv'<'<"< 2 MMO <K(D f $$dhhv&6&<&<"%C%C%EF F f $$((6*:*@*@b)G)G)I JK KD!! !&'2) y  /(<%! ! MMOs+LKALK ;L=9L7K9K#BK9'K&=;K9=K9K9K9/;L+9L%9L L#K9& K61K95K66K99L  Lz/v1/audio/separationsz"mlx-community/sam-audio-large-fp16speechmidpointc TV^8dQhR\R\R\R\R\/#)r,rFrrrr)rrRr)r/s"r0r1r1Vs:)1)1 )1 )1)1  )1  )1r2c 6"VP4GRjxL p\P!V4p\VRR7wrxVP 4\ 4P RV\VVVVVVR7RVRVRV/R 7p \V 4GRjxL #L~L5i) aSeparate audio using SAM Audio model. Args: file: Audio file to process model: SAM Audio model name (default: mlx-community/sam-audio-large-fp16) description: Text description of what to separate (e.g., "speech", "guitar", "drums") method: ODE solver method - "midpoint" or "euler" (default: midpoint) steps: Number of ODE steps - 2, 4, 8, 16, or 32 (default: 16) Returns: JSON with base64-encoded target and residual audio, plus sample rate NFrHr)rPrrrrrrrr)r-rPrr.) rrrrNrOrr*rr) rFrrrrrrSrrrs &&&&& r0audio_separationsr\Us( D **T C3%0IEIIK ! # * *"%#   ; f U +F")0 00- , 1s"BBA9BBBBc V^8dQhR\R\PR\R\\ ,R\ R\ /#)r, websocketrrr is_partial streaming)rr;rrr rRrY)r/s"r0r1r1sVC$C$C$C$ C$ sm C$  C$C$r2c x"R\P!VP4P9pV'dV'dVP\P !V4RVRR7pRp Tp VFqp \ V \4'dT M\V R\V 44p W, p \V RR4p V 'dV fT p VPR R R V /4GRjxL Ks VPR R RV R RRV R V/4GRjxL R#R\P!4 R2p\WV4VPWRR7p\VR 4'd(VP'd\VP4MRpVPRVPR VR\VRV4R V/4GRjxL \ P"P%V4'd\ P&!V4R#R#ELLLH \ P"P%T4'd\ P&!T4ii;i5i)aHandle both streaming and non-streaming model inference over WebSocket. Streaming models (whose generate() accepts a ``stream`` parameter) receive the audio as an ``mx.array`` and yield token deltas sent as ``{"type": "delta", "delta": "..."}`` messages, followed by a ``{"type": "complete", ...}`` message. Non-streaming models fall back to temp-file + batch generate, sending the legacy ``{"text": ..., "is_partial": ...}`` format. rTF)rrrrrrNr5deltacompleterLr_z/tmp/realtime_r)rr)rrrrrrr4rRr send_jsonrrrrLr8rrrrr)r^rrrrr_r`supports_stream result_iterrdetected_languagerrb chunk_langrr rLs&&&&&&& r0_stream_transcriptionris&'"3"3I4F4F"G"R"RRO9(( HH[ !$5)  $ E#E3//WUFCPUJ5W   K  D9J/7$.!%%vw&GH H H!!!  D-j     $DIIK=5H;7 $''U'SF6:..6???"&//2  %%FKK H E *   ww~~h'' (#(= I & ww~~h'' (#(s\=H:BH:G2&H:G5+H:/6G9&AG9.G7/G93AH:5H:7G99>H77H:z!/v1/audio/transcriptions/realtimec$V^8dQhR\/#r,r^r)r/s"r0r1r1sdddr2c 6"VP4GRjxL VP4GRjxL pVPRR4pVPRR4pVPRR4pVPRR4p\R V R V R V R V 24\R 4\P V4p\R4\ P!^4p^p\WH,R, 4p \RV RV RV R24.p \VR,4p \VR,4p \VR,4p ^p^p\P!4pRpRpVPRRRR/4GRjxL \R4VP4GRjxL pRT9Ed9\P!TR,\PR7p\!T4T ,pRp^p\#T4F`pTT ,pTT ,pTTTp\!T4T 8XgK,TP%TP'4T4'dRpT^, pK`Kb \P!4pT'dTP-\P.4R, pT P1T4T^, p^pTp\!T 4T^,,\!T48d3\R T R!T R"\!T 4 R\!T 4T, R# R$2 4M&T^, pT^,^8Xd\R%T R&24TT, pRp Rp!\!T 4^8dT'gF\!T 4T 8d6T'd.Rp \R'Y, R# R(\!T 4T, R# R)24MpTT8d8\!T 4T 8d(Rp!\R*TR# R+\!T 4T, R# R)24M2\!T 4T 8d#Rp!\R,\!T 4T, R# R)24T 'dI\!T 4T 8d9T p"\P2!T RT"4p#Rp\5TTT#TTRTR-7GRjxL T!'dq\!T 4^8d^\!T 4p"\P2!T 4p#\5TTT#TTRTR-7GRjxL .p Rp\R0T" RT"T, R# R124EKTEKWEKZR3T9gEKd\<P>!TR3,4p&T&PR44R58XdMEKTPC4GRjxL R#EL!EL ELEL \dK5i;i \(\*3d&p\RT 24RpT^, pRp?EKRp?ii;iEL4 \dWp^RIp$\9T4p%T$P;4\R.T% 24TPR/T%RR//4GRjxL Rp?ELRp?ii;iELG \dXp^RIp$\9T4p%T$P;4\R2T% 24TPR/T%RR//4GRjxL Rp?EKRp?ii;i \dEKi;i \@dELb\dJpTPR/\9T4RR//4GRjxL Rp?EL \d Rp?ELi;iRp?ii;iEL \dR#i;i TPC4GRjxL i \dii;i;i5i)6z%Realtime transcription via WebSocket.Nrz-mlx-community/whisper-large-v3-turbo-asr-fp16rri>r`TzConfiguration received: model=z , language=z, sample_rate=z , streaming=zLoading STT model...zSTT model loaded successfullyizVAD initialized: frame_size=z samples (zms at zHz)g?g?g@Fr"readyrzReady to transcriberPdtypezVAD error (assuming speech): @zSpeech detected (rz frames): buffer z.2fzs)zSilence detected: skipped z chunksz1Processing initial chunk for real-time feedback: zs, total buffer: szProcessing due to silence gap: zs silence, buffer: z#Processing due to max buffer size: )r_r`z$Error during initial transcription: r4zProcessed final chunk: zs), buffer clearedzError during transcription: ractionstop)"accept receive_jsonr3printrr* webrtcvadVadrrrdreceiverr; frombufferint16rrange is_speechtobytesr9OSErrorastypefloat32extendrri tracebackrR print_excrrRrrO)'r^configrPrrr`rvadvad_frame_duration_msvad_frame_size audio_buffermin_chunk_sizeinitial_chunk_sizemax_chunk_sizesilence_skip_countspeech_chunk_countlast_speech_timesilence_threshold_secondsinitial_chunk_processedraudio_chunk_int16 num_frames has_speech speech_framesi frame_start frame_endframerA current_timeaudio_chunk_floattime_since_last_speechshould_process_initialshould_process_final process_sizerr error_msgrs'& r0stt_realtime_transcriptionsrs    ` --//ZZ D ::j$/jj6 JJ{D1  ,ZL H:^\g[hhtu~t A $%"--j9  -.mm  !#[@4GH *>*:*EZD[[abmannq r  [3./ #   #  99;$'!"'!!8WiAV"WXXX #$  ) 1 1 33'!$&MM''2B"(($S! !!23~E " ! z*A"#n"4K +n TUX=YYlmpq}m~@KnKLOmPPQR\*n[[ !Z6*Z-+Z60[)6 [ [ [)[  [  [[)[ [&"\%[&&\)\+\>\?\\ \\\\\i]c:V^8dQhR\\,/#r!)r r)r/s"r0r1r1s#r2c~\P!R4pV'gR#\V4# \dR#i;i))MLX_AUDIO_REALTIME_TRANSCRIPTION_DELAY_MSN)rrPrr9)rVs r0_default_transcription_delay_msrs7 ))? @C 3x s - <<cFV^8dQhR\R\\,/#)r,rdelay_ms)r:r r)r/s"r0r1r1s 4 45 4HSM 4r2cRV/pVe6\P!VP4pRVP9dW#R&VP!R/VB#)zkOpen a streaming session, forwarding ``transcription_delay_ms`` only to models that declare the parameter. rtranscription_delay_msr)rrcreate_streaming_sessionr)rrrrsigs&$$ r0_open_streaming_sessionrsS";/F > >? #s~~ 5/7+ ,  ) ) 3F 33r2cpV^8dQhR\PR\R\R\P/#)r,pcm16 from_rateto_rater.)r;rr)r/s"r0r1r1s4?? ::?"%?03?ZZ?r2cNVP\P4R, pW8XgVP^8XdV#\ \ VPV,V, 44pV^8:d%VRVP\PRR7#\P !RRVPR\PR7p\P !RRVR\PR7p\P!WeV4P\P4#)zLinear resample int16 PCM to ``to_rate``. Returns float32 samples in [-1, 1]. If the rates already match, this is a plain dtype cast. rqNF)copyr)numendpointrp) rr;rsizerroundlinspacefloat64interp)rrrr8n_outsrc_xdst_xs&&& r0_resample_pcm16_to_ratersll2::&0Gw||q0 gllW,y89 :E zv%%bjju%== KKSgllU"** UE KKSee2:: NE 99U7 + 2 22:: >>r2c\V^8dQhR\\,R\\,/#)r,requested_modelr.r3)r/s"r0r1r1s"  (3- HSM r2cT;'gRP4pV'dV#\P!R4;'gRP4pT;'gR#)u<Return the requested model ID, or the server-configured default. The default is read from ``$MLX_AUDIO_REALTIME_MODEL`` (settable via the ``--realtime-model`` CLI flag). Returns ``None`` when neither the client nor the server supplies a model — the caller is expected to reject the connection with a clear error. rMLX_AUDIO_REALTIME_MODELN)r(rrP)r normalized configureds& r0_resolve_realtime_model_namersQ"''R..0J))67==2DDFJ   r2zmlx-community/silero-vadc$V^8dQhR\/#r!rQ)r/s"r0r1r1s---r2cz\P!R4;'gRP4;'g\#)zReturn the VAD model used for server-side turn detection. Read at request time from ``$MLX_AUDIO_VAD_MODEL`` (settable via the ``--vad-model`` CLI flag), defaulting to Silero. MLX_AUDIO_VAD_MODELr)rrPr(_REALTIME_VAD_MODEL_DEFAULTrr2r0_resolve_vad_model_namers2 '(..B eg - -,-r2c$V^8dQhR\/#rhrQ)r/s"r0r1r1s  3 r2cf\PV4pVf^RIHpV!V4pV\V&V#)zLoad and cache a streaming VAD model for server-side turn detection. Kept behind a module-level indirection so the realtime endpoint can be exercised with a fake VAD model in tests without hitting Hugging Face. )load)_realtime_vad_modelsr3 mlx_audio.vadr)rirload_vads& r0_load_realtime_vad_modelrs5 ! $ $T *E }2%*T" Lr2z /v1/realtimec$V^8dQhR\/#rkrl)r/s"r0r1r1sOOOr2cDaaaaaaaa a!a"a#a$a%a&a'"SP4GRjxL RRloRVV3Rllo"RV"3RllpSPPR4p\V4o S f+V!R 4GRjxL SP 4GRjxL R#\ P S 4o\SR 4'g0T!R S : R 24GRjxL SP 4GRjxL R#Ro%\4o&\SS%S&R7o#.oRo\oRo'RpRRlpR!T4\8P@R47p\CTSS#PD4p\*;_uu_4GRjxL S#PGT4RRR4GRjxL S!^R57GRjxL TEe\CTS\H4p\*;_uu_4GRjxL TPKT4pRRR4GRjxL XFpTPL\NPPJdOSf)T!4oS"!RR*R+R,SR-R.RR/R0R1R2RR3/.//4GRjxL S"!RR6R7TPRR8S/4GRjxL KoS"!RR9R:TPRR8S/4GRjxL T!4GRjxL TPU4K EKEKT R;8XgEK$Sf)T!4oS"!RR*R+R,SR-R.RR/R0R1R2RR3/.//4GRjxL T!4GRjxL TfEKfTPU4EKyELELEL \d9pT!R T 24GRjxL SP 4GRjxL Rp?R#Rp?ii;iELELvELEL \ P$dT!R4GRjxL EKi;i \d!pT!R T 24GRjxL Rp?EK(Rp?ii;iELELEL +GRjxL 'giEL;i \.d'pT!\1T44GRjxL Rp?EKRp?ii;i \d%pRo'RpT!R'T 24GRjxL Rp?EKRp?ii;iELELLELEL +GRjxL 'giEL;iELELEL +GRjxL 'giEL;iELaELDEL%ELELEL \VdM[\dOp^RI,pTP[4T!\1T44GRjxL Rp?M \dRp?M i;iRp?ii;iSP 4GRjxL M \dMi;i\\P^!4R# SP 4GRjxL M \dMi;i\\P^!4i;i5i)=uOpenAI Realtime API-compatible WebSocket endpoint. Works with any STT model whose ``load_model`` result exposes the streaming-session protocol. A streaming session must provide: - ``feed(samples: np.ndarray[float32])`` - ``close()`` - ``step(max_decode_tokens: int) -> list[str]`` - ``done: bool`` - ``input_sample_rate: int`` (the native rate expected by ``feed``) Models that support an adjustable transcription-delay / latency knob should accept ``transcription_delay_ms: Optional[int]`` on ``create_streaming_session``; models without the concept can ignore it. Client → server events follow OpenAI Realtime (subset): ``session.update``, ``input_audio_buffer.append``, ``input_audio_buffer.commit``. Server → client events: ``session.created`` / ``session.updated``, ``conversation.item.added``, ``input_audio_buffer.committed``, ``conversation.item.input_audio_transcription.delta`` / ``.completed``, and ``error``. Turn detection follows OpenAI's ``turn_detection`` on ``session.audio.input``. With ``{"type": "server_vad"}`` the server runs a streaming VAD (Silero by default, see ``--vad-model``), emits ``input_audio_buffer.speech_started`` / ``input_audio_buffer.speech_stopped`` and auto-commits each turn — the client never sends ``input_audio_buffer.commit``. With ``null`` (the default) the client drives commits manually. ``semantic_vad`` is not implemented yet. Model is selected via ``?model=`` or ``session.update.model``; defaults to ``$MLX_AUDIO_REALTIME_MODEL``. Nc$V^8dQhR\/#r!rQ)r/s"r0r1!realtime_ws..__annotate__1s0030r2cTR\P!4PR, 2#)event_NNuuiduuid4hexrr2r0 _new_event_id"realtime_ws.._new_event_id1s! ((-.//r2c$V^8dQhR\/#)r,rr6)r/s"r0r1r4s++$+r2c\<"RS!4/VCpSPV4GRjxL R#L5i)event_idN)rd)rrr^s&r0 send_eventrealtime_ws..send_event4s+}:':!!'***s ,*,c$V^8dQhR\/#)r,rrQ)r/s"r0r1r8sKK#Kr2c@<"S!RRRRV//4GRjxL R#L5i)r5r4rNr)rrs&r0 send_errorrealtime_ws..send_error8s"&'7Y4HIJJJs rzsno realtime model configured: pass ?model=, set session.update.model, or start the server with --realtime-modelz load failed: rzmodel z does not support streamingrrrc$V^8dQhR\/#r!rQ)r/s"r0r1r[s//#/r2cTR\P!4PR, 2#)item_rrrr2r0 _new_item_id!realtime_ws.._new_item_id[s!tzz|'',-..r2c0V^8dQhR\R\/#)r,max_decode_tokensr.)rrY)r/s"r0r1r^sc$r2c ><"\;_uu_4GRjxL SPVR7pRRR4GRjxL XF,pSPV4S!RRRSR^RV/4GRjxL K. SP#LdLD +GRjxL 'giL[;iL45i)u0Run one session.step, ship deltas. Returns session.done. MLX runs inline on the event-loop thread (not via a worker thread): MLX streams are thread-bound, so all realtime MLX work — the transcription step and the VAD — must share one thread, otherwise you hit "no Stream(gpu, N) in current thread". Nrr5z1conversation.item.input_audio_transcription.deltaitem_id content_indexrb)REALTIME_INFERENCE_LOCKr2rr;)rdeltasrbcurrent_item_idfull_text_partsrsessions& r0 drain_deltas!realtime_ws..drain_deltas^s+**\\4E\FF+*E  " "5 )O#QU   ||+*** sSBA;BA? BA=-B&B'B=B?B B B B  Bc f<"RPS4pS!RRRSR^RV/4GRjxL R#L5i)rr5z5conversation.item.input_audio_transcription.completedrr transcriptN)join)rrrrs r0 send_donerealtime_ws..send_donets@ww'O?d     s %1/1cV^8dQhRR/#r-r)r/s"r0r1rsr2c< "S!RRRSRR/4GRjxL \;_uu_4GRjxL SP4RRR4GRjxL S!^R7GRjxL 'gKS!4GRjxL \;_uu_4GRjxL \SSSR7oRRR4GRjxL .oRoR#LLLk +GRjxL 'giL;iLxLcLNL2 +GRjxL 'giLI;i5i)zCommit the current turn: emit ``committed``, drain the remaining transcription, emit ``completed``, then reopen a fresh session. Shared by the manual ``input_audio_buffer.commit`` path and the server-VAD auto-commit path. r5zinput_audio_buffer.committedrprevious_item_idNrr)rrOr) rrrrrrrrrs r0 finalize_turn"realtime_ws..finalize_turns6?"D    +** MMO+*$r::: k***-;9OG+*# +***:****sC:B4C:B6C:B: C: B8 C:C C:( C:4C5C: C C:C C:)C* C:6C:8C::C C C C  C:C:C:C:C7 $C'% C7 0C7 2C:sess_rc$V^8dQhR\/#r!r)r/s"r0r1rs   t  r2cn<RSRRRRRSRRRRR R S/RRS/R S'dSP4///#R ///#) rrzrealtime.sessionr5 transcriptionrrrr/z audio/pcmrateturn_detectionN)to_dict)client_input_raterP session_id turn_configsr0_session_snapshot&realtime_ws.._session_snapshotsv * ( O Z v{FJ N   oo))*5 54 5 56*/JKLLLooK<>% ;1GG"$O%)O5-1K,0M/,  6))#./0J    f/.&0(.0I(.,0/,4o,2I,2F,58O7P 1* %& '" !" !"#-$*,O$4j6I6I$-!"##-$*,O$2J4G4G$-!"##0/11)446A'2-T88"*&2nO$"$=" $o (/ & & )V],C+D %    $o%% ,!,,.{   =,---oo M|R1''  000 *%!(=)<=== ! 7666.!(Q000 ! )%*.K,0M",/@-D"EEE$ %  32228 7666 !"2 &    SV$ $ $     //# # #      //# # #    s"b X Ab 8X9b Xb X-"b Yb 'Y(B$b  Y  b ^/&Y#'^/,Y&1^/4^/^/(^/^/)^/A ^/Z+"^/ [^/)[*^/-[ < ^/[^/[(2^/:\ ^/-].(^/.^/]A'^/-].^/1] ^/]^/]7 ,^/ ]: ^/^" ^/-]=.A^/<^=^/^ !^/>^#?^/ ^&"^/6'^/^)^/,^,-^/8^/ b b b  YY-X0.YY Y b Yb b  b #^/& ZZ Z ^/Z^/ Z?Z:-Z0.Z:3^/:Z??^/^/^/ [% [ [% [%  ^/( \3\\ \ ^/\^/ ] ']9\<:]?^/]  ^/^/^/^/]4 ]#! ]4 ,]4 . ^/:^/=^/^ ^  ^ ^  ^/ ^/#^/&^/)^/,^// `:a<```_:/_20_:5a: ` `a `  ``a`2+`.,`21b 2 a=b ?ab ba6/a20a65b6 bbbbb c:a]tRtRtoRRltRtRRltRtVtR#) MLXAudioStudioServeri`cxWnRVn\V4VnVPP RR7R#)NT)exist_ok)start_ui ui_processrlog_dirmkdir)rKr:r<s&&&r0rLMLXAudioStudioServer.__init__as. G}  D)r2c \\4PR, p\P!RR.\ V4\P \PRR7\TPR , R 4p\P!.RO\ T4T\PR 7Tn\!R TP R 24R# \d \R4h\Pdp\RT4hRp?ii;i \d \R4h\dp\RT 24hRp?ii;i)z%Start UI with logs redirected to fileuinpminstallT)cwdstdoutstderrcheckuJ✗ Error: 'npm' is not installed or not found in PATH. UI will not start.u!✗ Error running 'npm install': Nui.logw)rCrDrEu✓ UI started (logs: z/ui.log)uN✗ Error: 'npm' is not installed or not found in PATH. UI server not started.u✗ Failed to start UI: )rArundev)r__file__parent subprocessrIrRDEVNULLPIPEFileNotFoundErrorrCalledProcessErroropenr<PopenSTDOUTr;rw)rKui_pathrAui_logs& r0start_ui_background(MLXAudioStudioServer.start_ui_backgroundgs$x.''$. E NN "L!))!   <$,,137F(..%L!(( DO *4<<.A B!! \ ,, E@!D D E! `  <6qc:; ; D? D  DE2E3EEc |VP'deVP4\P!^4\P !R4\ RV RV 24\ R4\ R4M$V'd\ RV RV 24\ R4\P!RVVV^R R 7VP'd&VPP4\ R 4VPR , pVP4'd!VP4\ R V 24R#R# TP'd&TPP4\ R 4TPR , pTP4'd TP4\ R T 24ii;i)r,zhttp://localhost:3000u"✓ API server starting on http://:u0✓ Studio UI available at http://localhost:3000z" Press Ctrl+C to stop both serversu'✓ Realtime server starting on http://uA✓ Standard endpoints remain mounted; prefer realtime endpoints.zmlx_audio.server:apprG)hostportreloadworkersloopu✓ UI server stoppedrGu✓ UI logs deleted from N)r:rWrr  webbrowserrRrwuvicornrIr; terminater<runlink)rKr[r\r]realtime ui_log_paths&&&&& r0 start_server!MLXAudioStudioServer.start_serversc ===  $ $ & JJqM OO3 4 6tfAdVD E D E 7 8  ;D64&I J U V A KK&  ))+-.,,1K!!##""$1+?@$ ))+-.,,1K!!##""$1+?@$sD::A F; F;)r<r:r;N)Flogs) localhost@FF) rbrcrdrerLrWrfrfrgrhs@r0r7r7`s* #? ~~~,0NN () *589P9P5Q 12sD(() !4==$,, OF  YY YY{{ r2__main__cV^8dQh/^\9d\\,;R&^\9d \;R&^\9d\\\ 3,;R&#)r,r{rr)__conditional_annotations__r r$rRrr)r/s"r0r1r1sUh32(?+2i\/>=S=]/^/*)d38n)_/r2rE)T)r__doc__rqrGrrrrrrMrrr` contextlibr dataclassesrrrpathlibrtypingrrr r urllib.parser mlx.corecorernumpyr;rarxfastapir r rrrrrrrfastapi.middleware.corsrfastapi.responsesrrrhuggingface_hub.errorsrpydanticrmlx_audio.audio_iorrNrrmlx_audio.realtime_vadrrrr r!r"mlx_audio.server_inferencer#r$r%r&r'mlx_audio.tts.continuousr(r)mlx_audio.utilsr*r8rCrjrvrPallowed_origins_envsplitr(default_originsr}routerlifespan_contextrrrrrHrr{rrrrrrrrrrrr rrr3rrpostr$deleter\r1rCrWr\rir^rrrrrrrrrrr5r7r|rbr1)originrs0@r0rsH   *77,,    3PP:13C&4,,.i *ii ;<#6";";C"@A"@\\^"@A  3 $$+ I, 29 2!,,..22      12'(AB/3/dc5c5LJ 3J Z @!:@F<"  33$, V VLWW* 6 B $%Cyc"4jK4j J8;!$Z!$Zt*> K-1$Zo&od !"Cy:;H~z"b )1#)1XC$L23d4dV!& 4?& $>='))- ~OOd IAIAXaH zFE<Bs#P