jحFdZddlmZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z e ejj Zej$j'deeej$j'deej j dz ej$j'deej j j ddlZddlmZmZddlmZdd lmZmZdd lmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&dd l'm(Z(m)Z)dd l*m+Z+dd l,m-Z-dldZ.dmdZ/dndZ0dddd dodZ1dpdZ2dqdZ3drdsdZ4drdsdZ5dtdZ6GddZ7GddZ8GddZ9GddZ:dud Z;dvd!Zdxd$Z?dyd%Z@dzd&ZAd{d'ZBddd( d|d)ZCd}d*ZDdd+ d~d,ZEdd-ZFGd.d/ZGdd0ZHGd1d2ZIdd3dd4ZJdd5ZKdd6ZLdd7ZMd8ZNdd9ZOGd:d;ZPdZSGd?d@ZTdAZUdBZVdCdDdEZWddFZXddGZYGdHdIZZddddddJdeje\dK ddLZ]ddMZ^ddNZ_ddOZ`dPddddddddddJddQddRdddddddddejeje\dS ddTZbdddddddddJddRddddejdU ddVZcdddWddXddRddddddRdRde\dY ddZZdd[dPddddd\ dd]ZedddXdJddRejdd^ dd_ZfdddWdXdJdRdd` ddaZgdb\ZhZidcejzddz Zkde\ZlZmZnddfZodgZpddhZqddiZrddjZsetdkk(reqyy)u Live **V3** broadcast driver — broadcast the live V3 `Store` to the 3D scene over SSE. The production counterpart to `serve_live.py` (which replays a recorded feed file): this reads live nav out of the V3 `Store` via `build_v3_live_adapter` (§6 seam #1 — `v3_adapter.py`), scores it incrementally through `StreamingScorer`, and publishes `init`/`delta` over `LiveFeedServer` — the same renderer, the same BroadcastFeed contract, unchanged. It closes the gap that `build_v3_live_adapter` had no driver wiring it to the live feed. Two modes: * ``--seed`` (default): an in-memory store seeded with a **moving two-boat race** around Stockholm, so the entire 3D pipeline (scene + standings + commentary, plus the optional AIS overlay) runs on a laptop with **no rig** — the 3D analogue of `v3/ingest/demo_serve.py` (which drives the 2D map). * production: pass a Postgres-backed store + the management-plane ``meta``/``course``/``team_config`` (call ``run(...)`` directly), and live nav from the boats drives the broadcast. Run: .venv-demo/Scripts/python v3/broadcast/live/serve_v3_live.py # seeded offline demo # open http://localhost:8765/core/web/index.html?feed=live AISSTREAM_API_KEY=… .venv-demo/Scripts/python v3/broadcast/live/serve_v3_live.py --ais ) annotationsN)Callable)Pathingest) REPLAY_WORTHYcue_kind)overlay_event_config)LiveFeedServer program_state)PRESENTATION_LAG_S OnAirQueue StartedRacescoverage_windowfinish_handover_secprogramme_metaprogramme_return_commentaryselect_start_camera_status)CommentaryRotationLedgerStreamingScorer)StartProgressTracker)build_v3_live_adapterctjjdttj ddz ddlm}||||S)uBuild the streaming factual (team-racing-free) commentator (`--simple`) for non-team-race formats — e.g. the GSYS Aug-2 sprint. Lazily imported so the v3/scoring path is only needed when used.rscoring)SimpleCommentator)syspathinsertstr_HEREparentssimple_commentaryr)metateamscoursers ./srv/vr/app/v3/broadcast/live/serve_v3_live.py_simple_commentatorr'?s;HHOOAs5==+i7893 T5& 11c|jDcgc].}|jd|jd |d|df0}}|sytd|Dt|z td|Dt|z fScc}w)uWMean `(lat, lon)` of a tick's boat positions — the point the AIS overlay box follows.latNlonc3&K|] \}}| ywN).0la_s r& z_centroid..Ms$ur1$c3&K|] \}}| ywr-r.)r/r1los r&r2z_centroid..Ms4IEArR4Ir3)valuesgetsumlen) positionspptss r& _centroidr=Gs)2)9)9); EAeeEl&155<+C eHah  EC E  $$ $s3x /4IS4I1ICPSH1T UU  Es3Bc>ddlm}ddlm}||j ||||}t |j |ijDchc] }|D]}| c}}} | Dcgc]}|j|x} | } }|| |Scc}}wcc}w)uMMSIs to hide as the tracked boats' own vessels — the instance's boats' `boat_meta` resolved against `candidates` (live AIS targets or replay observations) via `ais_feed.resolve_own_mmsis`.r)resolve_own_mmsisresolve_roster instance_id) ais_feedr? attributionrAentries_covering_instancesortedr7r6 boat_meta_for) storerCt_ms candidatesr?rArosterteambboatsmmetass r& _own_mmsisrRPs+*  '' T: +'F &**[""="D"D"FU$PTU1AUAU VE K1u':':1'="=!!JQ KE K UJ //V KsB ,BBsince_msfrom_msuntil_mscddlm}|Dcic]}||j|} }||D cic]C}|| |D cgc]/} |j| ||D]} | j|| f1c} } Ec} } }|||} t |dd} |t | rddlm}m}|D]}g}| | |jD]R} ||jjdd jd d d \}}|d k(sB|j|Tt|d d}|||nd}|s| j|gjd|dd|j xs |jt#td|j xs |j|z dz dd| Scc}wcc} } wcc} } }w#|$rYwxYw)uThe PRODUCTION live boat-cam media map — derived from the store's `video_segments` (§19.10), not from any driver-side bookkeeping. `clip_url(segment) -> str | None` maps a segment's `gcs_path` to a URL the renderer can fetch — a v4-signed GCS URL in production (`gcs_clip_url`), a static-root relative path in the local demo; `None` skips the clip. (Video only — stills live in the photos table and are not part of the live tile timeline.) The SHAPE is `media_map`'s, shared with the REST producer so the two cannot drift; this function is only the store's way of finding the clips. `since_ms` bounds the scan to THIS RACE's window, the same one the REST producer already asks `clips.json` for. Unbounded, every tick re-read every slot's entire history — and the tick runs once a second while the history grows all day, so the producer's own cadence decayed as the day went on. That cadence is the frontier the renderers present against, and a producer whose tick slips past a second is what a presentation clock has to absorb (`presentation_clock.js`). Fixing the renderer is the fix; this stops manufacturing the condition. Default `None` = the whole history, which is what replay and backfill want.r) media_map)rTrV)rUrVlatest_video_for_manyN) MediaErrorparse_media_filename\/rfrontc|jSr-)start_ms)segments r&z"media_from_store..s G4D4Dr()keydefaultT)tSecfilevideo lastFrame capturedAtMs sourceEndSec)rX slots_of_boatvideo_segments_forragetattrcallablemediarZr[r6gcs_pathreplacersplitappendmax setdefaultend_msround)rIrOtrack_start_msclip_urlrTrUrV_mapboatslotsslotsegmapped latest_manyrZr[r_rb_tcameralatesturls r&media_from_storer]s%&,:? ?T5&&t, , ?E ?  % && &+DkR"%*%=%=dXGO&>&QR!<<#7R7RR&(6wQY [F%!8$?KH[1: DE&uT{3::< *!5((00s;BB3J2N"PJBW$LL) *$DdSF&,&8(6"dC!!$+22sT$*MM$DV__$)#cV]]5Ufoo7E5FIM4N+OPQ%S4 & M= @R& "s-F2F= 4F70F= 8G7F= G  G c`djdt|jDS)uA fingerprint of the media map, for deciding whether the feed needs republishing. This used to be a COUNT, compared with `>`, which quietly assumed a clip set only ever grows. It does not. The read plane answers `clips.json` over a WINDOW, and a local uploader sweeps clips past its retention — so an hour into a race the map is a rolling set whose size is flat while its contents move. Under `n > published`, the count reached its plateau, the comparison never fired again, and the renderer kept the last map it was handed while the presentation cursor walked off the end of it. The tiles played for a minute or two and then went dark for the rest of the race, which reads as the cameras stopping rather than as the producer never sending anything again. Identity, not size: the newest and oldest clip of each boat plus how many, which changes whenever the window slides, a clip lands, or an old one is swept — and is cheap on a per-second tick.|c 3K|]@\}}|r9|dt|d|ddd|dddtd|Dd Byw):rrir^c3|K|]4}|jdst|jdxsd6yw)rlrmrN)r7intr/rows r&r2z'_media_key...s.ZcSWW[EYCGGN+0q1Zs<#<reN)r9rx)r/rrowss r&r2z_media_key..sg9 D$4 &#d)Ad1gfo.aR0@/A ZTZde f g i9sAA)joinrGitemsrss r& _media_keyrs/ 889!/9 99r(cttdt|t|z }tdt||z S)a(Rest only for the unused part of a polling interval. The cadence is measured between poll *starts*, not as a fixed delay after all work completes. Scoring a delayed multi-second phone batch can take most of a second. Sleeping another complete second after it creates the next delayed batch and a self-reinforcing stop/burst picture. A slow tick therefore rests for zero and catches up; an ordinary short tick retains the configured cadence. A backwards injected clock is treated as no elapsed work rather than a negative rest. rf)rxfloat) interval_s started_s finished_selapseds r& _poll_rest_srs6#uZ(5+;;1onyestrueosenvironrr7striplowerenvsources r&_camera_media_disabledrsI ;RZZCF vzz3R8 9 ? ? A G G IN r(c|tjn|}t|jddj j dvS)aWhether live telemetry must use the current-position cache without rolling history. This is an availability circuit breaker for a degraded ``/tracks`` read plane. It leaves the fast fleet-wide ``/positions`` path enabled and prevents a successful-but-empty history response from becoming authoritative over fresh positions. The trade-off is losing intermediate fixes from delayed cellular batches until the history path is healthy again. VR_DISABLE_TRACK_TAILr>rrrrrrs r&_track_tail_disabledrsI;RZZCF vzz126 7 = = ? E E GL r(c&|rdSt|dS)zQBuild the optional live camera channel without touching its loader when disabled.ciSr-r.)_args_kwargss r&rcz%_live_media_channel..sr($@ refresh_s)_NonBlockingMedia)loaddisableds r&_live_media_channelrs++ TT 22r(creZdZdZdej ed d dZedZ e d dZ d dZ d dZ y )raoRefresh optional camera media off the producer's single picture thread. A media endpoint is allowed to be slow or absent; boat positions are not. Calls return the last completed value immediately and start at most one daemon refresh for each race/fleet window. The next picture tick adopts a completed value and republishes the header if it changed. rr monotonicon_logc||_t||_||_||_t j |_i|_i|_ t|_ yr- _loadr _refresh_s _monotonic_on_log threadingLock_lock_values_refresh_afterset_runningselfrrrrs r&__init__z_NonBlockingMedia.__init__sK  *# ^^% *, 24$'E r(ct|tr)ttd|j DSt|t tfrtd|DSt|t rttd|DS|S)Nc3PK|]\}}|tj|f ywr-r_freeze)r/kvs r&r2z,_NonBlockingMedia._freeze..s%\da$5$=$=a$@ A\s$&c3FK|]}tj|ywr-rr/rs r&r2z,_NonBlockingMedia._freeze..sE!*2215E!c3FK|]}tj|ywr-rrs r&r2z,_NonBlockingMedia._freeze..sL 1 9 9! <Lr) isinstancedicttuplerGrlistr)values r&rz_NonBlockingMedia._freezesl eT "\ekkm\\] ] edE] +EuEE E eS !LeLLM M r(cH|j||j|zSr-)r)clsargskwargss r&_keyz_NonBlockingMedia._keys{{4 3;;v#666r(c|j||}|j}|j5|jj |i}||j j |dk\}|ry||j vrk|j j|||jz|j |<tj|j|||fddjddd|S#1swYSxYw)Nrfzlive-media-refreshTtargetrnamedaemon) rrrrr7rraddrrThread_refreshstart)rrrrdnowrdues r&__call__z_NonBlockingMedia.__call__siif%oo ZZ QLL$$S"-E,,00c::Cs$--/ !!#&+.+@##C(   S$B26..16 */ *. *;? *77  +r(rcXeZdZdZdej ed ddZ d dZd dZ y) _NonBlockingFrameTailaJRecover cellular catch-up samples without putting a history read on the picture thread. ``/positions`` intentionally exposes only each boat's newest fix. A phone can upload several one-second fixes between producer polls, so that endpoint alone discards the intermediate motion anchors and the delayed picture holds, then jumps. A short rolling ``/tracks`` read recovers those anchors while the presentation delay can still absorb them. The completed tail is returned from memory; one bounded daemon read per race/fleet runs at a low cadence in the background. @rc||_t||_||_||_t j |_i|_i|_ t|_ yr-rrs r&rz_NonBlockingFrameTail.__init__!sO  *# ^^% FH MO?Bu r(ct|ttd|Dt|f}|j }|j 5|j j|}||jj|dk\r||jvr|jj|||jz|j|<|t|t|t|t|f} tj|j|| fddj!ddd|S#1swYSxYw)Nc32K|]}t|ywr-)rr/rs r&r2z1_NonBlockingFrameTail.__call__..4s-JDc$i-Jrfzlive-track-tail-refreshTr)rrrGrrrrr7rrrrrrrrr) rrCrOt_fromt_tor|rdrrrs r&rz_NonBlockingFrameTail.__call__2s ;v-JE-J'J!KSQ_M`aoo ZZ VLL$$S)Ed))--c377Ct}}P>P=QQSTWSXXYZ [ [ \ + + +$(-DLL%LL$$S$/+/??+A26..16E/E.E;?E" !$ )4 +r(rcPeZdZdZdej ed ddZd dZd dZ y) _LiveWindaPrime once, then refresh wind away from the producer's single picture thread. The first read is bounded and synchronous so an on-air ``init`` contains real conditions instead of making the renderer fall back to a northerly. Later reads hold the last completed value and refresh on a daemon thread: a slow weather/read endpoint can cost an update, never boat motion. g@rc||_t||_||_||_t j |_i|_i|_ t|_ yr-rrs r&rz_LiveWind.__init__ZK  *# ^^% 46 <>.1e r(c|siS||f}|j}d}|j5||jvr,||jvr|jj |d}n||j j |dk\rw||jvri|jj |||jz|j |<tj|j|fddj|jj |i}ddd|rD|j||j5|jj |i}ddd|SS#1swYQxYw#1swYSxYw)NFTrfzlive-wind-refreshr) rrrrrrr7rrrrr)rrC course_idrdrprimers r&rz_LiveWind.__call__fsGII&oo ZZ .$,,&3dmm+C !!#&++//S99c>V !!#&+.+@##C(   SF&9$HHMLL$$S"-E .  MM#  2 ((b1 2 u  . . 2 sC-E$;E0$E-0E:cd} |j|xsi}|j 5|||j |<|j|jz|j|<|jj|dddy#t$r5}|jdt|jd|dYd}~d}~wwxYw#1swYyxYw#|j 5|||j |<|j|jz|j|<|jj|dddw#1swYwxYwxYw)Nz[live] wind refresh failed (rrrrrdrrs r&rz_LiveWind._refresh}s* +DJJ$*E +$(-DLL%+/??+idfd }|xsi}dD]P\}}|j|xsi}||d|jd||d|jdRt|jdxsgd D]-\}}|t|jd xsd ||/t|jd xsgd D]\}}|d ||t|jdxsgd D]\}}|d||S)axFlatten resolved course geometry to the renderer's live ``marks`` channel. Role names are the stable identity shared by course resolution and ``scene.updateMarks``. This remains deliberately independent of device ids: the same mechanism follows a GNSS phone on a committee vessel, a MarkSetBot, a conventional buoy tracker, or a static fallback at any event. ct|tsy|jd|jd}}t|ttzrt|ttzrpt j |rZt j |rDd|cxkrdkr8nyd|cxkrdkr)ny|dk(r|dk(st |t |d|<yyyyyyyy) Nr*r+iZiLrr*r+)rrr7rrmathisfinite)rolepointr*r+outs r&rz#_course_role_positions..adds%& 99U#UYYu%5S sC%K (ZS5[-IMM#&4==+=3$"$););cQh %c 5:>CI'/*<$,>&.J (r())r startLine)finish finishLine_portport_stbd starboard waypointsr)rrM contestAreacontest boundaryBuoysbuoy)r0rrr)r7 enumerater) r%rgeoprefixrdlineindexr1r2s @r&_course_role_positionsrEs6(*C? ,BCI5 wws|!r vhe dhhv./ vhe dhh{345"#''+"6"<"AF: u C &!0q[ 159:!#''-"8">BaH& u geW u%&!#''/":"@bJ# u d5'NE"# Jr(cRddlm} ||jS#t$rYywxYw)zProduction `clip_url`: a short-lived signed HTTPS URL for a `gs://` clip (the renderer's plain