j^@dZddlmZddlZddlZddlZddlZddlmZddl m Z ejjde e ejj ddz ddlmZdd lmZdd lmZd ZGd d ZddZ ddZGddZy)u Streaming scorer — §6 seam #2: incremental scoring (re-run-on-prefix) `core.score_race.enrich(feed)` scores a whole feed in one pass (batch). Live broadcast needs the SAME logic fed frames as they arrive, emitting per-tick standings + event deltas. Rather than fork the scoring logic (enrich is a deliberately monolithic single-pass loop — see project notes), this re-runs the *unchanged* `enrich` on the frames accumulated so far each tick and reports what's new. There is therefore exactly ONE scoring implementation; this is a thin driver around it. Two facts about `enrich` (verified by the B-A parity test on the real race) shape the design: * **Standings are frontier-stable** — `standings[sec]` depends only on frames up to `sec`, so every tick we emit the live frontier standings (positions for the 3D render) and they already match batch. * **Commentary events settle with a short lag** — `_split_long_lines` and the margin/cadence smoothing revise an event for up to ~9 s after its `tSec` (they look a few beats ahead). So we only *finalise* (emit) an event once the frontier has passed `tSec + FINALISE_LAG_S`, by which point its text/focus equals the batch output. `finish()` flushes the tail (the last lag-seconds of events). The lag is invisible live: the broadcast already runs seconds behind wall-clock (OBS→RTMP→YouTube latency + the director's deliberate delay), which absorbs it — positions stay live, commentary trails by the lag. Cost: re-scoring the growing prefix is O(n^2), but a full enrich is milliseconds and live advances one tick per real second, so it's comfortably real-time for race-length feeds. Acceptance bar: test_streaming_parity — feeding a recorded race one tick at a time (then `finish()`) must accumulate to exactly the events + standings the batch `enrich` produced. Sub-phase: B-A (live scoring). Next: LiveFeedServer (B-B) fans `push_frame`'s delta to renderers, and the bounded-LLM editor (live `ai_director`) edits each tick's newly-finalised colour beats. ) annotationsN)Callable)Pathscoring) frame_raceenrich)StartProgressTracker c2eZdZdZdZeddZdddZy) CommentaryRotationLedgerajOne continuous wording rotation for a live programme or regatta. The ledger is deliberately held by the broadcast owner and shared with every race scorer. It advances only after a settled event crosses the streaming seam, never when `enrich` re-scores a provisional prefix. This means a long programme does not reset its wording at each race. c<i|_i|_i|_g|_yN)_order _remaining_last_recent_openingsselfs B/srv/vr/releases/25f455cc4e75/v3/broadcast/live/streaming_score.py__init__z!CommentaryRotationLedger.__init__9s,. 02%' 79ct|xsijdxsd}tjd|dd}t tj d|j dd S) zJComparable opening cadence, independent of punctuation and capitalization.enu[,;:—])maxsplitrz [a-z0-9]+N)strgetresplittuplefindalllower)optiontext first_clauses r_openingz!CommentaryRotationLedger._opening?s_FLb%%d+1r2xx TA>qA RZZ l.@.@.BCBQGHHrNc|dkry|jj|}|t||k7r[tdt |D|z}t t |}||d|d|z}||j|<g|j|<|jj|xs t |}|Dcgc]&}|r |j|||jvr|(}}|s t |}|d}|dkDr1||jj|k(rt|dkDr|d}|j|||j|<||j|<|r[|t|krM|j||} | r7|jj| |jdd|jdd|Scc}w)Nrc3DK|]\}}|dzt|zyw)rN)ord).0ichs r z2CommentaryRotationLedger.choose..Ns!Luq"!a%3r7*Ls ri) rr!lensum enumeratelistrangerr*rrremoveappend) rcategorycountoptionsorderoffset remainingindex candidatesopenings rchoosezCommentaryRotationLedger.chooseFs A: ) =CJ%/L (8KLLuTFu&E&'NU7F^3E$)DKK !(*DOOH %OO''1@T%[ *3d$ gen(ETMbMb(bd diJ1  19$**.."::s:QR?RqME$-!$ 8 us7|+mmGEN3G%%,,W5+/+@+@+E%%a( ds9+F<)r' dict | Nonereturnztuple[str, ...]r)r9r r:intr;z$list[dict] | tuple[dict, ...] | NonerDrE)__name__ __module__ __qualname____doc__r staticmethodr*rBrrrr1s': II rrc2tj|ddS)u\Stable identity for de-duping a (now-settled) event. Verbatim — settled events are unique.TF) sort_keys ensure_ascii)jsondumps)es r _event_keyrRis ::a4e <>#**W- . 8 8 :3B ??rceZdZdZedddddf ddZddZddZddZdddd Z dd Z dd Z dd Z dd Z ddZy)StreamingScoreruiIngest frames incrementally; emit {standings, events} deltas per tick by re-running `enrich` on the accumulated prefix. Standings are the live frontier; events trail by `lag` so they're final (== batch) when aired. Call `finish()` at race end to flush the last `lag` seconds of commentary. Reuses `enrich` verbatim — no forked scoring logic. FNc |||c|_|_|_||_||ng|_||_||_| |_|%|jddk(rddl m fd|_ n|xst|_ t|xsijd|_i|_|xsgD cgc]O} | jdxsgD]5} | jdr"| jd s| jd7Q} } } t!|xsijd xsd} t!|xsijd xs| }t#|| t%|| z d z  |_g|_g|_g|_t/|_t/|_t/|_d|_d|_i|_d|_ycc} } w)NobservedGeometryGuardrier)enrich_with_observed_geometryc|tSrr )feedrns rz*StreamingScorer.__init__..s*Gf*Ur programmeboatsdeviceId spectatortrackStartUtcMsrUgun_sec)rccourseteamslag race_signals capture_ai_on_scored_events_commentary_rotationr!v3.rie.enrich_geometry_guardrn _producerr bool_frame_programme_framesrEr round_start_tracker_events_beats_onboardset_emitted_emitted_beats_emitted_onboard_settled_through_result _standings _air_floor)rrcrzr{r|r~producerr}on_scored_eventscommentary_rotationteamboatrs track_startgunrns @rrzStreamingScorer.__init__s .265* 4;  -9,DL"$!1%8!  )@ AU J RUDN%/DN !%djb%5%5k%B C(* 38;BH$TXXV]M^MdbdHDHHZ(+1F*%H%HH4:2**+<=BC 4:2"":.=+>2 E5# *;t)C#DF    "%% (+*-%-1$( " '+5Hs(AGcJ|j|j|jdS)uThe enriched context the L4 live author needs beyond meta/course/teams — the full frontier standings, the result, and all events so far (for the per-beat fact sheet + run-up). Read-only.) standingsresultevents)rrrrs r ai_contextzStreamingScorer.ai_contexts "__ PTP\P\]]rc0||_|xsgDcgc]O}|jdxsgD]5}|jdr"|jds|jd7Q}}}t|jxsijdxsd}t|jxsijdxs|}t |j |t ||z dz |_|jj|jy cc}}w) zLAdopt a corrected live roster and replay observed start evidence against it.rsrtrurvrrUrwrxN) r{r!rErcr rzrrobserve_framesr)rr{rrrsrrs r replace_teamszStreamingScorer.replace_teamss 38;BH$TXXV]M^MdbdHDHHZ(+1F*%H%HH499?//0ABGaH 499?'' 3B{C2 KKs[/@D.H(IK **4<<8 HsADcg}|D]}|jddk(xrt|jd}|jddk(}|xs|}| |d|kDr|s[|j|d|jkr|s|t|} | |vs|j | |j |jdr|d} |jdxs|jdd} |j j | t| | } | | } |jDcic] \}}|d vr||}}}| |d <| jd |jd d |d <t| |d<| dz|d<t| |d<t|j|t| | | |d<|j||j||Scc}}w)zReturn not-yet-emitted items with tSec <= horizon (or all, if horizon is None), never any at/behind the mid-race-join air floor.rW race_open cardTitle countdownrV_commentaryVariants_commentaryVariantCategory commentary)rri18nrr(rcommentaryVariantCategoryrcommentaryVariantIndexcommentaryVariantCountcommentaryVariantId) r!rrrRaddrrBr2itemsr rhrcr8)rremittedhorizonoutrQrequired_race_openimmediate_countdownimmediate_signalkr;r9r?rekeyvalueaireds r _emit_throughzStreamingScorer._emit_throughs3 "A "#v+!=!Z$quu[GYBZ #$%%-;"> 1H5H "qy7':CS*qyDOO/KTf1 A A ,,8QUUCX=Y 56G uu%ABaaeeFT`FaH 55<": {boatRef: fix}}`) — a **mid-race join**: the broadcast switches to a race that has been sailing while another was on air (`race_queue.py` `OnAirQueue`). `enrich` is a single-pass whole-feed scorer, so the only way to give it that history is the raw frames: it then scores the whole prefix in ONE pass and the standings, leg/mark state and finish detection are exactly what following the race from the gun would have produced. `air_from` is the first second whose commentary MAY air — the viewer's COVERAGE START (`race_queue.coverage_window`). Default (None) keeps the original behaviour exactly: nothing seeded ever airs, because the seeded seconds are time that has already gone and the join must not dump a race's worth of settled commentary into the broadcast at once. A live driver passes the coverage start instead, because those last seconds are NOT time that has gone: the renderer presents a fixed delay behind the frontier, so they are precisely the seconds the viewer is about to watch. Safe only while `PRESENTATION_LAG_S > FINALISE_LAG_S` — by the first live tick every aired history event has had ≥`lag` seconds to settle and can no longer be rewritten (the revision window this air floor exists to guard). Returns `{"": standings}` for the seeded seconds, so the driver can put the history on the wire WITH its standings; the tiles, the running order and the margin graphic all read `standings[sec]` and would otherwise be blank for the whole window.c32K|]}t|ywrrE)r.ss rr1z.StreamingScorer.seed_frames..*s,SV,rc32K|]}t|ywrr)r.rs rr1z.StreamingScorer.seed_frames..1s:%3u::r) rrr maxrEr_scoresortedrobserver!dictr)rframesrsec positionslatestfloors r seed_frameszStreamingScorer.seed_framess,%lln /NC%.DLLS " /I,V,,"*H 0A#'??#:%DOOUZ@[ DLL!:6:; XC    ' 'VZZC&**SRTBU-V W XDOO$$rc`|j |jni|jd|ji}||j|j|d}|jr|j|d<|j rd|d<|j |}|jr t|}|d|_ |jdg|_ |jd|_ |d |_ |jd g|_|j&|j|j|j|S) zRun the producer over the accumulated prefix and adopt its output. The ONE place the feed is assembled and the producer is called, so a seeded prefix and a live tick cannot diverge.settledThroughSec)rcrzr{r raceSignalsTcaptureAiBeatsraiBeatsrrrieOnboardDirectives)rrcrzr{r}r~rrrrr!rrrrr)rrrcrpscoreds rrzStreamingScorer._score5s!119tyy@Eii@E,d.C.C@E djjTZ[   "&"3"3D  ??%)D! "%  'Fh' jjB/ zz(+  - #92>  ! ! -  " "4<< < rc$||jt|<||jz }||_|j |j}|j j ||||djt||j|j|j|d}|jr*|j|j|j||d<|j|j|j|}|r||d<|S)aAdvance one tick with `{deviceId: {lat,lon,speed,course}}`; return this tick's delta: `{sec, standings, events}` (plus `aiBeats` when capture_ai) where standings is the live frontier and events are the lines that became final this tick (tSec <= sec - lag).r)rrrrr)rr r|rrrrr!rrrr~rrrr)rrrrrdeltaonboards r push_framezStreamingScorer.push_frameTs"+ SX. 'T\\* ##C3&*=*A*A#c(*K--dllDMM7SU ??#11$++t?R?RT[\E) $$T]]D4I4I7S ,3E( ) rc|j|j|jd|jd}|jr*|j|j |j d|d<|S)zFlush the tail: emit every remaining (final-prefix) event not yet aired (plus aiBeats when capture_ai). Call once after the last frame. Returns `{events, result}`.N)rrr)rrrrr~rr)rrs rfinishzStreamingScorer.finishis[++DLL$--NZ^ZfZfg ??!// T=P=PRVWC N rc|jS)uNThe final `result` payload (winner/…) once the race has finished, else None.)rrs rrzStreamingScorer.resultqs ||rc6|jjS)zPLatest observed start-line progress, independent of whether a result exists yet.)rstaters rstart_progresszStreamingScorer.start_progressus""((**r)rcrrzrr{r5r|rEr~rrzCallable[[dict], dict] | Noner}z list | Nonerz/Callable[[list[dict], list[dict]], None] | NonerzCommentaryRotationLedger | None)rDr)r{r5rDNone)rr5rrr int | NonerDr5)rrrrrDr)rrrDr)rrErrrDr)rDrC)rFrGrHrIFINALISE_LAG_SrrrrrrrrrrrKrrrjrjsJX$)UY-1UYHL :+!:+5R:+*:+$S:+'F :+x^ 98tCG#%J>*+rrj)rQrrDr ) rcrrdrr9r r?rErerrDr )rI __future__rr_rOr"syscollections.abcrpathlibrpathinsertr __file__resolveparentsrrr score_racer rr rrrRrhrjrKrrrs:# $3tH~--/77:YFGH /55p= @%)@.1@(u+u+r