j*dZddlmZddlZddlZddlmZddlmZm Z ddZ dZ dZ d Z d Zd Zddd Zdd ZeGddZGddZy)uWhat the renderers say about themselves, kept for as long as they keep saying it. Each renderer posts a small sample every few seconds (`core/web/client_beacon.js`). This holds the newest one per renderer and forgets any that stops reporting. Deliberately small and deliberately dumb: it stores what was said and computes nothing about the competition. **It is a REGISTRY, not a controller.** Nothing here is ever read back by a renderer, and the server has no way to answer a beacon with an instruction — the channel is one-way by construction, so it cannot quietly become a route for telling the picture what to do. The broadcast presents; it never decides, and that includes not being decided at. Two properties worth stating because they are load-bearing: * **A renderer is present because it is TALKING, not because it once connected.** Entries expire on age. A partner's box that was unplugged stops appearing, rather than being listed for ever as one of the three outputs that are fine. * **Untrusted input.** The beacon is a public POST from a browser we do not control — under the World Sailing arrangement, from a browser on someone else's premises. Every field is clamped, the id is truncated, the roster is capped, and nothing posted is ever interpolated into a page without escaping. A monitor that can be filled with junk by anyone who can reach the producer is a monitor that gets ignored. ) annotationsN)Callable) dataclassfieldcRtjdtjS)zThe venue operator's own date. Local, not UTC: the person reading the board asks "how many today", and their today ends at their midnight.z%Y-%m-%d)timestrftime localtimeD/srv/vr/releases/25f455cc4e75/v3/broadcast/live/renderer_registry.py _local_dayrs ==T^^%5 66r g0@@i)rolelangworldrace audioBackendworldRequested)fps longFramesframeswindowSupSwh feedAgeMs cursorSec frontierSecpresentationLagS frameMaxMs workMaxMshitch250 hitch1000raceAgeS raceFramesraceLongFramesraceMaxFrameMs raceHitch250 raceHitch1000sceneGeometries sceneTextures sceneCallssceneTrianglesjsHeapMB feedHandoversfeedLastHandoverAgeMsct|tsydjd|Dd|j}|xsdS)Nc3BK|]}|js|ywN) isprintable).0chs r z_clean_str..Ms9(8"9s) isinstancestrjoinstrip)valuelimitouts r _clean_strrAJs= eS ! ''9u9 9&5 A G G IC ;$r ct|ts|y t|}||k7s|tdtdfvry|S#ttf$rYywxYw)zA finite number, or `None`. Guards the boundary the same way the ingest does: a string, a null or a NaN must never reach an average or a threshold, where it would either raise or produce a plausible-looking figure from nothing.Ninfz-inf)r:boolfloat TypeError ValueError)r>r@s r _clean_numrHQsa%%-El czSU5\5=99 J z "s AAAcFeZdZUded<ded<eeZded<d dZy ) Rendererr;idrEat_s)default_factorydictfieldsc~|jttd||jz dzd|jS)Ngi)rKageMs)rKintmaxrLrO)selfnow_ss r to_wirezRenderer.to_wirefs9ggCUTYY5F,G$,N(O_SWS^S^__r N)rUrEreturnrN)__name__ __module__ __qualname____annotations__rrNrOrVr r r rJrJ`s! G K.FD.`r rJcXeZdZdZeedd d dZddd dZd dZddZ dddd Z dd Z y)RendererRegistryzNewest sample per renderer, expiring on silence. Thread-safe: beacons arrive on handler threads while the monitor reads on another.N)expiry_s max_renderersday_fnctj|_i|_||_||_|xst |_|j|_t|_ i|_ d|_ y)NF) threadingLock_lock_rows _expiry_s_maxr_day_fn_dayset_counted_loads_counted_capped)rTr^r_r`s r __init__zRendererRegistry.__init__qsX^^% *, !! + LLN "%% &( $r )rUct|tsyt|jdd}|sy|t j n|}i}t D]$}t|j|}| |||<&tD].}t|j|}| t|d||<0t|jd|d<|j5|j|||jvr,t|j|jk\r dddyt!||||j|<|j#||jddddy #1swYy xYw) zTake one beacon. Returns False for anything unusable, so the caller can answer 400 rather than silently accepting junk.FrKNstale)rKrLrOrT)r:rNrAgetr monotonic _STR_FIELDS _NUM_FIELDSrHroundrDrd_expirerelenrgrJ _count_load)rTpayloadrUridrOkeyr>s r recordzRendererRegistry.recordsP'4(T*B/$)M u $Cw{{3/0E #s  $ .Cw{{3/0E #E1os  .w{{734w ZZ 7 LL $**$TZZDII)E 7 7'#E&IDJJsO   S&**W"5 6  7   7 sAE(#z+RendererRegistry.snapshot..s3AEE%L3PU,1Wu]a!"4!*r )r})rrtrdrxrevaluesrVsort)rTrUrrowss r snapshotzRendererRegistry.snapshots$)M u ZZ C LL .2jj.?.?.ABAIIe$BDB C *  + C C Cs.BB +B BBc|jjDcgc]$\}}||jz |jkDs#|&}}}|D]}|j|=ycc}}wr5)reitemsrLrf)rTrUr|rowdeads r rxzRendererRegistry._expiresZ$(JJ$4$4$6\S%#((:JT^^:[\\ C 3 ]s $AA)r^rEr_rRr`zCallable[[], str] | None)r{objectrU float | NonerWrD)r|r;r str | NonerWNone)rWrN)rUrrWz list[dict])rUrErWr) rXrYrZ__doc__EXPIRY_S MAX_RENDERERSrnr~rzrrrxr r r r]r]msC3-5=48%1%&@D67( 915 r r])rWr;)()r>rr?rRrWr)r>rrWr)r __future__rrbrcollections.abcr dataclassesrrrrrrrurvrArHrJr]r r r rsv,# $(7  R      ` `  `_ _ r