jN*dZddlmZddlZddlZddlmZmZddlm Z ejjde e e jjddz d dZGd d Zy) u Live read-through adapter — §6 seam #1: data → engine. Production replacement for the demo's batch exporter (demo/export/export_team_race.py). Instead of pulling a fixed window of tracks from Firestore and scoring in one shot, this reads V2's live position feed for an in-progress start group and produces the SAME feed dict the engine consumes — `{meta, course, teams, frames}` — incrementally as positions arrive, so `core.score_race.enrich` (via StreamingScorer) is reused verbatim. The batch exporter stays for replays / off-season. Input (V2): the running backend exposes the live cache over HTTP — GET /api/viz/{instanceId}/positions -> {deviceId: {lat, lon, speed, course, timestampUtcMs, ...}} (see _legacy/app_viewregatta_com/routers/visualization.py + services/live_state.py). This adapter polls that endpoint and maps each device's latest fix into the engine's frame contract. Output contract (identical to the demo exporter, so the engine is unchanged): meta : {title, user, instanceId, groupId, openEnded, raceType, trackStartUtcMs, gunUtcMs, trackEndUtcMs, frameStepMs, windFromDeg, windKts} course : {name, center, startLine{port,starboard}, finishLine{port,starboard}, waypoints[]} teams : [{teamId, name, boats:[{deviceId, sailId, visualId, color, sternM}]}] frames : {"": {deviceId: {lat, lon, speed, course}}} sec = (timestampUtcMs - trackStartUtcMs)//1000 What is implemented vs. wired: * `positions_to_frames` — the pure GPS→frame transform (mirrors the exporter's `pull_frames` record shape: lat/lon 7 dp, speed 2 dp, course 1 dp). Fully unit-tested. * `poll_frames` — incremental streaming with de-dup, over an **injectable** position source (default: HTTP GET to the V2 endpoint via `requests`/`urllib`). Testable with a fake source. * `resolve_meta_course_teams` — needs V2 Firestore (raceInstances / startGroups / courses / deviceMounts, resolving the **time-scoped device→boat** assignment in effect at the gun). That requires V2 credentials, so it runs through an **injectable** `fetch_static` callable; the default raises with a pointer to the exporter logic to port (device_for_boat + course doc in demo/export/export_team_race.py). Wire this when running against a live V2 instance. Wind is manual / weather-station only (never motion-derived) — passed in via `wind`. Sub-phase: B-A (live scoring / live input). ) annotationsN)CallableIterator)Pathscoringc i}|xsijD]\}}|jd}|"|jd|jd": {dev: {lat,lon,speed,course}} }`. Pure: skips devices with no fix or a pre-start (negative-sec) timestamp; rounds like the exporter.timestampUtcMslatlonrspeedrcourse)r r rrr )itemsgetintround setdefaultstr) positionstrack_start_msoutdevptssecs ?/srv/vr/releases/25f455cc4e75/v3/broadcast/live/live_adapter.pypositions_to_framesr /sC?))+ Q UU# $ :u-u1E 2&4/0 7 51%eAeHa.@155!,115quuXWXGYG^]^`aAb! - s3x$S)  JcxeZdZdZd ddddd d dZd dZddZddejd dd Z dd Z y)LiveReadThroughAdapterzTStreams the broadcast feed for one live start group out of V2's live position cache.N)base_urlrfetch_positions fetch_staticc||_||_|xsi|_|r|jdnd|_||_|xs |j |_||_i|_ i|_ y)N/) instance_idgroup_idwindrstripr$r_http_fetch_positions_fetch_positions _fetch_static_latest_positions_latest_source_ms)selfr)r*r+r$rr%r&s r__init__zLiveReadThroughAdapter.__init__Hsi'  JB 08,d , / M43M3M) 35 :<r!c|j td|j\}}}|jd |d|_|||fS)u@Build the static feed parts at gun time. Delegates to the injected `fetch_static` (production wires this to the V2 Firestore reads — raceInstances/startGroups/courses/deviceMounts with the time-scoped device→boat assignment, as in the batch exporter). Caches trackStartUtcMs for frame timing.uProvide fetch_static (meta, course, teams) — port device_for_boat + course doc + the time-scoped deviceMounts from demo/export/export_team_race.py against the live V2 instance.trackStartUtcMs)r/NotImplementedErrorrr)r2metarteamss rresolve_meta_course_teamsz0LiveReadThroughAdapter.resolve_meta_course_teams_se    %%n #002fe 88% & 2"&'8"9D VU""r!cj tdtjj}g}|j D]\}}|j D]\}}|j d}j j |} t|ttfrt| ttfr|| krd|j|<t|ttfr|j |<|j||f|jt||siStfdjjD} t| t!jiS)uXONE poll: the frames that are new since `seen` (which this call updates). Split out of `poll_frames` so a producer that owns its own loop — one that can hand over to the NEXT race between ticks without restarting (`serve_v3_live.broadcast_following`) — shares this exact de-duplication rather than reimplementing it.uJtrack_start_ms unknown — call resolve_meta_course_teams() or pass it in.r c3K|]G}t|jdttfr t|djz dzIyw)r r N) isinstancerrfloatr).0rr2s r z3LiveReadThroughAdapter.poll_once..sNM$QUU+;%": {dev: {lat,lon,speed,course}} }` as new fixes land, de-duped by (device, sec) so each second is emitted once. `max_polls`/`sleep` are injectable for tests; in production leave them default and stop by breaking out of the generator.rNr)setrN)r2rOrPrQrFpollsnews r poll_framesz"LiveReadThroughAdapter.poll_framessd &)U59#4 QJE..&C  EI$5j! 59#4sAA A  A c|js td|jd|jd} ddl}|j |dj S#t $rmddl}ddl}|jj|d5}|j|jjdcdddcYS#1swYYyxYwwxYw)NuONo base_url set and no fetch_positions injected — cannot reach V2 live_state.z /api/viz/z /positionsr)timeoutzutf-8) r$r@r)requestsrjson ImportErrorurllib.requestrequesturlopenloadsreaddecode)r2urlrZr[urllibrs rr-z,LiveReadThroughAdapter._http_fetch_positionss}}pq qy)9)9(:*E < <<Q</446 6 <  !''Q'7 <1zz!&&(//'":; < < < BNR<%<>H<";< L<. #%=N25d59ZZ "2 "DR " rwsc"F# .3tH~--/77:YFGH,k<k