vidZddlmZddlZddlmZmZmZmZm Z m Z m Z m Z ejeZeeeegeeedffZGddZy)umFR Temporal Analyzer — watches face recognition detections for patterns. Accumulates face recognition detections over a sliding window and identifies when a face is consistently detected (same identity or 'unknown') for a configurable threshold duration. When a consistent detection is found, triggers an async callback so the orchestrator can reason about it. ) annotationsN)AnyCallable CoroutineDictListOptionalSetTuplecteZdZdZdZdZ d d dZ d dZ ddZddZ ddZ dd Z y )FRTemporalAnalyzeraUWatches FR detection stream for temporal patterns. Accumulates detections over a sliding window and identifies when a face is consistently detected (same identity or ``'unknown'``) for a configurable threshold duration. When a consistent detection is found, triggers a callback so the orchestrator can reason about it. g333333?cZ||_||_g|_t|_d|_yN) _threshold_window_detection_historyset_notified_identities_on_consistent_detection)selfconsistency_threshold_swindow_ss H/home/nelsen/Projects/kognitive/orchestrator/src/services/fr_analyzer.py__init__zFRTemporalAnalyzer.__init__&s, 2 LN.1e!OS%c||_y)z@Register callback: ``async fn(identity, confidence, duration)``.N)r)rcallbacks ron_consistent_detectionz*FRTemporalAnalyzer.on_consistent_detection5s )1%rcK|jj||f||jz }|jDcgc]\}}||kDs ||fc}}|_|j|}|D]X\}}} ||jvs|jj ||j >|j ||| d{Zycc}}w7 w)a=Feed a new set of FR detections. Called on every ``fr_detections`` message from the edge proxy. Args: detections: List of detection dicts (each with at least ``identity`` and ``confidence`` keys). timestamp: Unix epoch seconds of the detection frame. N)rappendr_find_consistentraddr) r detections timestampcutofftd consistentidentity confidencedurations rfeedzFRTemporalAnalyzer.feed;s && :'>?T\\)#66# q!!f*QF#  **95 .8  *Hj(t888))--h700<77 *h   # s.Reset all state. Call when the robot moves to a new location.N)rclearr)rs rresetzFRTemporalAnalyzer.reset[s& %%' !!'')rc:|jj|y)zAAllow re-notification for *identity* (after it has been handled).N)rdiscard)rr*s rclear_identityz!FRTemporalAnalyzer.clear_identity`s !!))(3rc|jsgS||jz }|jDcgc]\}}||k\s ||f}}}t||jkrgSi}|D]V\}}|D]L} | j dxsd} | j dd} |j | gj || fNXg} t|} |jD]z\}}t|| z |jk\s"td|Dt|z }td|D}||z }||jk\sg| j |||f|| Scc}}w)uFind identities present consistently for ≥ threshold seconds. Returns: List of ``(identity, avg_confidence, duration_seconds)``. r*unknownr+gc3&K|] \}}| ywr).0_cs r z6FRTemporalAnalyzer._find_consistent..s4TQq4c3&K|] \}}| ywrr7)r8r'r9s rr;z6FRTemporalAnalyzer._find_consistent..s 6tq! 6r<) rrlen MIN_FRAMESget setdefaultr!itemsPRESENCE_RATIOsummin)rnow window_startr'r(relevantidentity_framestsdetsdetidentconfresults total_framesr*framesavg_conf first_seenr,s rr"z#FRTemporalAnalyzer._find_consistenths{&&IT__, #66 q!!|:KQF   x=4?? *IAC  IHB I WWZ0=I!gglC8**5"5<rbs`#MMM   8 $'%3T>22 wwr