Update backend/api.py (#8)

- Update backend/api.py (3d7732c7acf648b7fd830ded7c62408a4a543e78)


Co-authored-by: Munirah <munals@users.noreply.huggingface.co>

backend/api.py

@@ -239,23 +239,59 @@ def _serialize_state() -> dict:
 
 def _pipeline_loop():
     cap = pipeline.get_video_capture()
-    print('🎥 [API] Video loop started')
+    # ~10 FPS: fast enough to look real-time, slow enough for LLM to keep up
+    TARGET_FPS  = 10
+    frame_delay = 1.0 / TARGET_FPS
+    print(f'🎥 [API] Video loop started (target {TARGET_FPS} FPS, {frame_delay*1000:.0f}ms/frame)')
     while True:
+        t0 = time.time()
         ret, frame = cap.read()
         if not ret:
-            # Loop video — reset EMA so score doesn't carry stale HIGH into next loop
+            # Loop video — full reset so next loop plays fresh
             cap.set(cv2.CAP_PROP_POS_FRAMES, 0)
-            pipeline.risk._peak_ema = 0.0
-            pipeline.risk._occ_ema  = 0.0
-            pipeline.state['risk_score']  = 0.0
-            pipeline.state['risk_level']  = 'LOW'
-            pipeline.state['density_pct'] = 0.0
-            print('🔁 [API] Video loop restarted — peak_ema + occ_ema reset to 0')
+
+            # Reset risk agent (clip state + EMA)
+            pipeline.risk._reset_clip(0, 'video loop restart')
+            pipeline.risk._peak_ema        = 0.0
+            pipeline.risk._occ_ema         = 0.0
+            pipeline.risk._prev_count      = 0
+            pipeline.risk._prev_density_sc = 0.0
+            pipeline.risk._boundary_buf    = 0
+            pipeline.risk._in_boundary     = False
+
+            # Reset perception frame counter
+            pipeline.perception.frame_id = 0
+
+            # Reset effective level tracker so first level change fires correctly
+            pipeline._last_effective_risk_level = 'LOW'
+
+            # Reset P0 rate-limit so previous loop's cooldown doesn't block
+            from datetime import datetime as _dt
+            pipeline.operations._boot_time = _dt.now()
+
+            # Reset pipeline state (scores + decisions)
+            pipeline.state['risk_score']       = 0.0
+            pipeline.state['risk_level']       = 'LOW'
+            pipeline.state['density_pct']      = 0.0
+            pipeline.state['frame_id']         = 0
+            pipeline.state['decisions_log']    = []
+            pipeline.state['latest_decision']  = None
+            pipeline.state['arabic_alert']     = ''
+            pipeline.state['coordinator_plan'] = None
+
+            # Clear frame buffer so frontend shows fresh frames
+            pipeline._frame_buffer.clear()
+
+            print('🔁 [API] Video loop restarted — full state reset')
             continue
         try:
             pipeline.process_one_frame(frame)
         except Exception as exc:
             print(f'[API] Frame error: {exc}')
+        # Pace to match real video FPS
+        elapsed = time.time() - t0
+        if elapsed < frame_delay:
+            time.sleep(frame_delay - elapsed)
 
 
 # ── Startup ────────────────────────────────────────────────────────────
@@ -326,13 +362,16 @@ def reset_pipeline():
     # Reset video to start
     cap = pipeline.get_video_capture()
     cap.set(cv2.CAP_PROP_POS_FRAMES, 0)
-    # Reset risk EMA
-    pipeline.risk._peak_ema = 0.0
-    pipeline.risk._occ_ema  = 0.0
-    pipeline.state['risk_score']  = 0.0
-    pipeline.state['risk_level']  = 'LOW'
-    pipeline.state['density_pct'] = 0.0
-    pipeline.state['frame_id']    = 0
+    # Reset risk — full clip state + EMA
+    pipeline.risk._reset_clip(0, 'API reset')
+    pipeline.risk._peak_ema        = 0.0
+    pipeline.risk._occ_ema         = 0.0
+    pipeline.risk._prev_count      = 0
+    pipeline.risk._prev_density_sc = 0.0
+    pipeline.state['risk_score']   = 0.0
+    pipeline.state['risk_level']   = 'LOW'
+    pipeline.state['density_pct']  = 0.0
+    pipeline.state['frame_id']     = 0
     # Reset perception agent
     pipeline.perception.frame_id = 0
     # Clear frame buffer