Merge branch 'refactor/modularize' of https://github.com/kadurushil/refactor into refactor/modularize

steps/src/main.js

@@ -119,62 +119,65 @@ jsonFileInput.addEventListener("change", (event) => {
   calculateAndSetOffset();
   saveFileToDB("json", file); // Save the file object for the next session
 
-  const reader = new FileReader();
-
-  // 1. Show the modal immediately.
-  showModal("Loading large JSON file, this may take a moment...");
+  // 1. Show a loading modal immediately.
+  showModal("Parsing large JSON file, please wait...");
 
-  reader.onload = (e) => {
-    // 2. Use setTimeout to schedule the heavy work for the next event loop cycle.
-    // This gives the browser time to render the modal before it freezes.
-    setTimeout(() => {
-        const jsonString = e.target.result;
-        // Note: We don't need to save to DB here, as we saved the file object earlier.
-
-        const result = parseVisualizationJson(
-            jsonString,
-            appState.radarStartTimeMs,
-            appState.videoStartDate
-        );
+  // 2. Create a temporary URL for the streaming parser.
+  const fileURL = URL.createObjectURL(file);
 
-        if (result.error) {
-            showModal(result.error);
-            return;
-        }
+  // 3. Use the robust streaming parser.
+  parseJsonWithOboe(
+    fileURL,
+    async (parsedData) => {
+      // This is the success callback, running after the file is parsed.
+      // We make it async so we can `await` the next step.
+
+      const result = await parseVisualizationJson(
+        parsedData,
+        appState.radarStartTimeMs,
+        appState.videoStartDate
+      );
 
-        appState.vizData = result.data;
-        appState.globalMinSnr = result.minSnr;
-        appState.globalMaxSnr = result.maxSnr;
+      // Revoke the temporary URL to free up memory.
+      URL.revokeObjectURL(fileURL);
 
-        // Update UI
-        snrMinInput.value = appState.globalMinSnr.toFixed(1);
-        snrMaxInput.value = appState.globalMaxSnr.toFixed(1);
-        resetVisualization();
-        canvasPlaceholder.style.display = "none";
-        featureToggles.classList.remove("hidden");
+      if (result.error) {
+        showModal(result.error);
+        return;
+      }
 
-        if (!appState.p5_instance) {
-            appState.p5_instance = new p5(radarSketch);
-        }
+      appState.vizData = result.data;
+      appState.globalMinSnr = result.minSnr;
+      appState.globalMaxSnr = result.maxSnr;
 
-        if (appState.speedGraphInstance) {
-            appState.speedGraphInstance.setData(
-            appState.canData,
-            appState.vizData,
-            videoPlayer.duration
-            );
-        }
+      // Update UI with the correct, awaited data.
+      snrMinInput.value = appState.globalMinSnr.toFixed(1);
+      snrMaxInput.value = appState.globalMaxSnr.toFixed(1);
+      resetVisualization();
+      canvasPlaceholder.style.display = "none";
+      featureToggles.classList.remove("hidden");
 
-        // Close the loading modal
-        document.getElementById("modal-ok-btn").click();
-    }, 50); // A small 50ms delay is enough for the UI to update.
-  };
+      if (!appState.p5_instance) {
+        appState.p5_instance = new p5(radarSketch);
+      }
 
-  reader.onerror = () => {
-      showModal("Error reading the selected file.");
-  };
+      if (appState.speedGraphInstance) {
+        appState.speedGraphInstance.setData(
+          appState.canData,
+          appState.vizData,
+          videoPlayer.duration
+        );
+      }
 
-  reader.readAsText(file);
+      // Close the loading modal.
+      document.getElementById("modal-ok-btn").click();
+    },
+    (error) => {
+      // This is the error callback for the streaming parser.
+      showModal(error);
+      URL.revokeObjectURL(fileURL);
+    }
+  );
 });
 
 // Event listener for video file input change.