jh* XdZddlmZddlZddlZddlmZddlmZee jjZ e jjdz Z ejjdee ejjdee ddlmZddlmZdd lmZmZdd lmZmZmZdd lmZdeed  dd Zdddd ddZdddd ddZ dddddeedd ddZ!y)uM V3 wiring for `LiveReadThroughAdapter` — the §6 seam #1 (data → engine) reading **V3 natively**. `LiveReadThroughAdapter` was designed DI-friendly from day one: it takes `fetch_positions` (live snapshot) + `fetch_static` (meta / course / teams) as injectable callables, with V2 HTTP as the default. This module is the V3 production wiring — both callables back into the V3 `Store` (`reads.boat_position_at` for live fixes, `broadcast_feed.build_feed` for static parts) so the broadcast pixel + interactive paths run end-to-end off V3 with **no V2 dependency**. The StreamingScorer, LiveFeedServer, and renderer downstream are unchanged. The boat-ref join key (`{userId}:boat:`) flows through as the engine's `deviceId` — exactly as `broadcast_feed.resolve_teams` already does — so the engine joins frames ↔ teams identically. ) annotationsN)Callable)Pathingest)resolve_static)LiveReadThroughAdapter)PRODUCER_READ_ENVPRODUCER_READ_HEADER)DEFAULT_MAX_AGE_MSDEFAULT_PRIMARY_MOUNTboat_position_at)Storenow_ms primary_mount max_age_msc2|xsddfd }|S)uZA `fetch_positions` that snapshots the V3 store at call time — the V3 analogue of the V2 `/api/viz/{i}/positions` polling. For each boat, returns its **canonical** position (primary mount + failover, §13.1) at `now_ms()` if it has a fresh fix within `max_age_ms`, else omits it. Output shape matches what `positions_to_frames` expects: `{boatRef: {lat, lon, speed, course, heel, timestampUtcMs}}`. `heel` is already derived into the boat frame by ingest, so renderers never infer heel from an uncalibrated device roll. `now_ms` is injectable for tests; default is wall-clock UTC.cBttjdzS)Ni)inttime=/srv/vr/releases/25f455cc4e75/v3/broadcast/live/v3_adapter.pyz$v3_fetch_positions../sc$))+"45rc}i}D]e}t||}||j|j|jxsd|jxsd|j |j d||<g|S)N)rrlatlonspeedcourseheeltimestampUtcMs)r latitude longituder r!heel_degt_ms) toutboatfix_nowboatsrrstores rfetchz!v3_fetch_positions..fetch1s} F! D"5$[efC{||CMM)cSZZ5F3 "%(( CI  rreturndictr)r.r-rrrr/r,s`` `` @rv3_fetch_positionsr3!s!  65D   Lr)tokenproducer_tokenrc ddl ddl}ddl |jd|}xs|jj dxs#|jj t xsdjxsdd  fd }|S)uA `fetch_positions` that polls the **gcloud read API** `GET /v3/view/{instance}/positions` instead of querying the store — Phase 0 of `docs/plans/live-broadcast-feed-in-gcloud.md`. That endpoint runs co-located with the DB + a warm `LiveStateCache`, so ONE cached HTTP call returns all boats fast, replacing the ~N cross-boundary SQL round-trips per tick that `v3_fetch_positions` does from the render PC. Output shape matches `positions_to_frames` (`{boatRef: {lat, lon, speed, course, timestampUtcMs}}`). A transient read miss yields `{}` (boats hold last position), same effect as a stale-fix omit. `token` reaches a non-public instance; a public one needs none. IT IS A PARAMETER, and `$VR_READ_TOKEN` is only the fallback, because the producer is given its credential on the COMMAND LINE (`--read-token`) and every other read on the plane — roster, course, wind, clips — takes it from there through `RestBackend`. Reading the environment only meant this one fetch ran anonymous while the rest authenticated, and its 401 is swallowed by the `except` below into the same empty dict a transient miss returns. Measured 2026-08-09: the producer took a race ON AIR (roster, course and wind all read fine) and then published nothing for the whole race, reporting "no positions from the read plane" — a credential fault wearing a network fault's clothes.rN/ VR_READ_TOKENc dd} jj|} r|jdd  r|jt  jj |d5}j |j jd}dddxsijDcic]\}}t|tr}|jdl||jd|jd |jd xsd |jd xsd |jd |jddc}}S#1swYxYw#t$ricYSwxYwcc}}w)Nz /v3/view/z /positions AuthorizationzBearer )timeoutzutf-8rrr rr!r"r#r) requestRequest add_headerr urlopenloadsreaddecode Exceptionitems isinstancer2get) urlreqrdatarefpbase instance_idjsonr5r4urllibs rr/z#http_fetch_positions..fetchbs_i }J7nn$$S)  NN?geW,= >  NN/ @ ''Q'7 <1zz!&&(//'":; < $zr002 ECa&155<+C QUU5\!%%, uuW~4h@VSVeeFm().>(?AAE E  < < I Es1E'2/E!E'BE8E$ E'' E54E5r0)rQosurllib.requestrstripenvironrHr strip) read_baserPr4r5rrS_r/rOrQrRs ``` @@@rhttp_fetch_positionsrZBsz0    C DA  4RZZ^^O4E$O 7H(IORVVX`\`NEEB Lr) team_config course_id wind_serialsc,dfd }|S)uxA `fetch_static` that returns `(meta, course, teams)` from V3 reads via `broadcast_feed.resolve_static` — the V3 replacement for the V2 Firestore resolution. The injected `meta` and `course` come from the management plane (§15.1); `teams` is derived from `entry_occupancy` at the gun. `course_id` enables wind merge into `meta`. Uses `resolve_static` (NOT `build_feed`) so the live path never materialises frames across the open-ended live window — that walks every second of a 24 h span and hangs against a real DB; live positions come from the separate `fetch_positions` poll, so frames here are unneeded.c jd}ddlm}|}t |}|d|d|dfS)Nr)_course_wind_from_deg)metar!r[r\wind_direction_fallback_degrar!teams)broadcast_feedr`r) fallbackr`feedr-r!r\rPrar.r[s rr/zv3_fetch_static..fetchsS  <,V4H ;f+(0  F|T(^T']::r)r1ztuple[dict, dict, list]r) r.rPr-rar!r[r\r]r/s ``````` rv3_fetch_staticrgs" ; ; Lr)r[r\r]windrrrrXc | rt| || nt||| | | }t||| |t||||||||S)uConstruct a `LiveReadThroughAdapter` wired to V3 reads — the production path replacing V2 polling. The downstream contract (StreamingScorer ← frames; LiveFeedServer ← deltas) is unchanged. Usage: adapter = build_v3_live_adapter(store, "flight-1", "g-day1", boats, meta=meta, course=course, team_config=cfg) meta_s, course_s, teams = adapter.resolve_meta_course_teams() scorer = StreamingScorer(meta_s, course_s, teams) for batch in adapter.poll_frames(interval_s=1.0): for sec, devs in batch.items(): scorer.push_frame(int(sec), devs) )rr)rar!r[r\r])rhfetch_positions fetch_static)rZr3rrg)r.rPgroup_idr-rar!r[r\r]rhrrrrXrjs rbuild_v3_live_adapterrmsbBHQY FC  5}Q[  "XD'$ ;D#y|  r) r.rr- list[str]rCallable[[], int] | Nonerstrrrr1Callable[[], dict]) rXrprPrpr4 str | Noner5rrrror1rq)r.rrPrpr-rnrar2r!r2r[ dict | Noner\rrr]list[str] | Noner1z%Callable[[], tuple[dict, dict, list]])r.rrPrprlrpr-rnrar2r!r2r[rsr\rrr]rtrhrsrrorrprrrXrrr1r)"__doc__ __future__rsysrcollections.abcrpathlibr__file__resolveparent_HERE_INGESTpathinsertrprdr live_adapterrproducer_read_authr r readsr r r r.rr3rZrgrmrrrrs6 # $ X '' ,,   (3u:3w< )/FMM(,.(    %     J!%'+ AAA  A  A % AAV $ %)      #+N $ %)'+.( - ---  -  - ---#- - %---- !-r