j!*|dZddlmZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z m Z mZmZGddZy) aAhead-of-air neural TTS cache for trusted live commentary events. The browser can safely use a clip only when its rendered text is an exact match. This cache receives events from the scoring process, which already knows the upcoming pre-start script, and prepares those clips before their air time. A synthesis failure is deliberately non-fatal: the live player keeps its browser-voice fallback and the race never waits on a cloud request. ) annotationsN) make_engine) AUDIO_DIR LANG_CODERATEto_ssmlc^eZdZdZddedd dZd dZeddZeddZ dd Z d d Z y )LiveNeuralTtsCachez?Prepare exact-match neural clips in bounded background workers.rg?)workersmin_request_interval_son_logc||_tj|_t j |_t|_i|_ d|_ d|_ d|_ tdt||_d|_t"dz |_ t'j(|j$j+d|_t3td|D]8}t j4|j6dd|dz j9:y#t.t&j0f$r i|_YswxYw) NFz index.jsonutf-8encodingrTzlive-neural-tts-)targetdaemonname)_logqueueQueue_queue threadingLock_lockset _scheduled_voices_unavailable_until_unavailable_reason_unavailable_loggedmaxfloat_min_request_interval_s_next_request_atr _index_pathjsonloads read_text_indexFileNotFoundErrorJSONDecodeErrorrangeThread_runstart)selfr r rns A/srv/vr/releases/25f455cc4e75/v3/broadcast/live/tts/live_cache.py__init__zLiveNeuralTtsCache.__init__s bgbmbmbo ^^% 58U24 #&/3 #( (+36L0M'N$ #$|3 **T%5%5%?%?%?%QRDKs1g' eA   DIIdCSTUXYTYSZA[ \ b b d e"4#7#78 DK s4D D=<D=c |j5tj}td|j|z }t||j|j z|_dddrtj |yy#1swY"xYw)zUPace calls against the project quota, shared even if a caller opts into more workers.rN)rtime monotonicr$r'r&sleep)r3nowwait_ss r5_wait_for_request_slotz)LiveNeuralTtsCache._wait_for_request_slot6s{ ZZ c.."Cd33c9:F$'T-B-B$CdFbFb$bD ! c  JJv    c cs ABB cz|jd}|dvr|Sddddj|jddS)NcommentaryRole>leadrulestacticalr@rBrA)mfrvoiceget)eventroles r5_rolezLiveNeuralTtsCache._role?sCyy)* 0 0K*7;?? '@RT^__c |jdg}|j|jdxsgg}t}|D]}t|ts|j Dcic]7\}}t |xsdjrt |t |9}}}|sitt|j }||vs|j||j||Scc}}w)aReturn the source line plus every approved on-air wording alternative. ``StreamingScorer`` deliberately selects a wording only once the event crosses its settled live seam. The TTS cache sees the event earlier, so it must prepare the whole approved bank rather than only the producer's default wording. Otherwise a rotated line reaches air without a neural clip and the player falls back to a browser voice. i18n_commentaryVariants) rHextendr isinstancedictitemsstrstriptuplesortedaddappend) rI candidatesoptionsseen candidatelangtextoptionkeys r5_spoken_i18n_optionsz'LiveNeuralTtsCache._spoken_i18n_optionsFsii'( %))$9:@bA 14# 'Ii.=F__=N2ztTTZR..0$iT*2F2v||~./C$ v& '2s,z,LiveNeuralTtsCache.submit..qsLGRS"#%%-AEE*4E!"& 1Z=!%%,:L"MGsA A )rr8r9r!r"r#rWrXrKrcrTrVrr,rHrrYrput) r3eventsteamsr;foreignrIrJrar_r`rbs r5submitzLiveNeuralTtsCache.submit`sZZ 1.."CT,,, 1 1 &&*-'+/(+0( 1GW\GGH AE::e$D33E: A"(,,. AJD$::( :F ((.="MM$/E).DLL& dD9#*4g#G "4[   AdV1WI&F&M&M&OPZZ\]`^`a ax 7"S ##D4#@}}//1"--4RY5; Y]._E ,,V4COOE*KK'ZZ5=@DKK**44T: $ 0 0 < .FD+/23xD,%)%=%=!=J/3D, 444 II-WVVU-K,LM 445Q8  "DDD//tT0BCDDD %%'s M"L* M2L74E=M1BM M'O8*L4/M7MM  M O5 O0%AN/& O0/N8 46O0*P0O55P8PQ"P;2 Q";Q "Q"N)r intr r%)returnNone)rIrSrrU)rIrSr list[dict])rlrrmrrr) __name__ __module__ __qualname____doc__printr6r= staticmethodrKrcror1rLr5r r sOI)*DY^e<`` 2ABG(rLr )r __future__rrr)rrrr8enginesrsynthrrrr r rrLr5rs6#  66s(s(rL