Fix video playback race condition, local file protocol, and backend worker crash

frontend/js/core/video.js

@@ -246,7 +246,7 @@ APP.core.video.fetchDepthVideo = async function () {
             throw new Error(`Failed to fetch depth video: ${resp.statusText}`);
         }
 
-        const nullOrigin = (window.location && window.location.origin) === "null";
+        const nullOrigin = (window.location && window.location.origin) === "null" || (window.location && window.location.protocol === "file:");
         if (nullOrigin) {
             state.hf.depthBlob = null;
             state.hf.depthVideoUrl = `${state.hf.depthVideoUrl}?t=${Date.now()}`;
@@ -311,7 +311,7 @@ APP.core.video.fetchProcessedVideo = async function () {
         throw new Error(`Failed to fetch video: ${resp.statusText}`);
     }
 
-    const nullOrigin = (window.location && window.location.origin) === "null";
+    const nullOrigin = (window.location && window.location.origin) === "null" || (window.location && window.location.protocol === "file:");
     if (nullOrigin) {
         state.hf.processedBlob = null;
         state.hf.processedUrl = `${state.hf.videoUrl}?t=${Date.now()}`;

frontend/js/main.js

@@ -470,21 +470,27 @@ document.addEventListener("DOMContentLoaded", () => {
                 log("Video processing complete.", "g");
                 // Stop streaming mode once video is ready
                 stopStreamingMode();
+
+                state.hasReasoned = true;
+                setStatus("good", "READY · Reason complete (you can Engage)");
+                log("Reason complete. Ready to Engage.", "g");
+
+                // Seed tracks for Tab 2
+                seedTracksFromTab1();
+                renderFrameRadar();
+
+                // Generate intel summary (async)
+                computeIntelSummary();
             }).catch(err => {
                 log(`Polling error: ${err.message}`, "e");
                 stopStreamingMode();
             });
 
-            state.hasReasoned = true;
-            setStatus("good", "READY · Reason complete (you can Engage)");
-            log("Reason complete.", "g");
+            // Initial status (processing in background)
+            setStatus("warn", "PROCESSING · Analysing video...");
+            log("Reasoning started (processing in background)...", "t");
 
-            // Seed tracks for Tab 2
-            seedTracksFromTab1();
-            renderFrameRadar();
 
-            // Generate intel summary (async)
-            computeIntelSummary();
 
         } catch (err) {
             setStatus("bad", "ERROR · Reason failed");
@@ -614,6 +620,14 @@ document.addEventListener("DOMContentLoaded", () => {
             return;
         }
 
+        if (state.hf.asyncJobId) {
+            log("Processing still in progress. Please wait.", "w");
+            // If we are streaming, make sure we are on the engage tab to see it
+            const engageTab = $(`.tabbtn[data-tab="engage"]`);
+            if (engageTab) engageTab.click();
+            return;
+        }
+
         // Switch to engage tab
         const engageTab = $(`.tabbtn[data-tab="engage"]`);
         if (engageTab) engageTab.click();
@@ -621,7 +635,9 @@ document.addEventListener("DOMContentLoaded", () => {
         // Set video source
         if (videoEngage) {
             videoEngage.src = state.hf.processedUrl || state.videoUrl;
-            videoEngage.play();
+            videoEngage.play().catch(err => {
+                log(`Video playback failed: ${err.message}`, "e");
+            });
         }
 
         state.tracker.running = true;

inference.py

@@ -1328,6 +1328,11 @@ def run_inference(
             queue_in.put((frames_fed, frame)) # Blocks if full
             frames_fed += 1
             
+        # Update total_frames to actual count so writer knows when to stop
+        if frames_fed != total_frames:
+            logging.info("Updating total_frames from %d to %d (actual fed)", total_frames, frames_fed)
+            total_frames = frames_fed
+            
         # Signal workers to stop
         for _ in range(num_workers):
             try:
@@ -1565,6 +1570,11 @@ def run_segmentation(
             queue_in.put((frames_fed, frame))
             frames_fed += 1
             
+        # Update total_frames to actual count
+        if frames_fed != total_frames:
+             logging.info("Updating total_frames from %d to %d (actual fed)", total_frames, frames_fed)
+             total_frames = frames_fed
+            
         for _ in workers:
             try: queue_in.put(None, timeout=5.0)
             except Full: pass
@@ -1899,6 +1909,11 @@ def run_depth_inference(
             queue_in.put((frames_fed, frame))
             frames_fed += 1
         
+        # Update total_frames to actual count
+        if frames_fed != total_frames:
+             logging.info("Updating total_frames from %d to %d (actual fed)", total_frames, frames_fed)
+             total_frames = frames_fed
+
         for _ in workers:
             try: queue_in.put(None, timeout=5.0)
             except Full: pass