split telemetry messages

Author: zendive

src/api-monitor-cs-main.ts

@@ -35,7 +35,7 @@ const tick = new Timer(
 
       if (delta) {
         windowPost({
-          msg: EMsg.TELEMETRY,
+          msg: EMsg.TELEMETRY_DELTA,
           timeOfCollection: now,
           telemetryDelta: delta,
         });

src/api/communication.ts

@@ -96,6 +96,7 @@ export enum EMsg {
   START_OBSERVE,
   STOP_OBSERVE,
   TELEMETRY,
+  TELEMETRY_DELTA,
   TELEMETRY_ACKNOWLEDGED,
   MEDIA_COMMAND,
   RESET_WRAPPER_HISTORY,
@@ -122,8 +123,12 @@ export interface TMsgLoaded {
 export interface TMsgTelemetry {
   msg: EMsg.TELEMETRY;
   timeOfCollection: number;
-  telemetry?: TTelemetry;
-  telemetryDelta?: Delta;
+  telemetry: TTelemetry;
+}
+export interface TMsgTelemetryDelta {
+  msg: EMsg.TELEMETRY_DELTA;
+  timeOfCollection: number;
+  telemetryDelta: Delta;
 }
 export interface TMsgTelemetryAcknowledged {
   msg: EMsg.TELEMETRY_ACKNOWLEDGED;
@@ -141,6 +146,7 @@ export interface TMsgMediaCommand {
 }
 export type TMsgOptions =
   | TMsgTelemetry
+  | TMsgTelemetryDelta
   | TMsgTelemetryAcknowledged
   | TMsgStartObserve
   | TMsgStopObserve

src/view/App.svelte

@@ -32,20 +32,13 @@
         }
       });
     } else if (o.msg === EMsg.TELEMETRY) {
-      if (o.telemetry) {
-        telemetryProgressive = structuredClone(o.telemetry);
-        telemetry = o.telemetry;
-      } else if (o.telemetryDelta) {
-        diff.patch(telemetryProgressive, o.telemetryDelta);
-        telemetry = structuredClone(telemetryProgressive);
-      }
-
-      portPost({
-        msg: EMsg.TELEMETRY_ACKNOWLEDGED,
-        timeOfCollection: o.timeOfCollection,
-      });
-
-      spinnerEl?.tick();
+      telemetryProgressive = structuredClone(o.telemetry);
+      telemetry = o.telemetry;
+      acknowledgeTelemetry(o.timeOfCollection);
+    } else if (o.msg === EMsg.TELEMETRY_DELTA) {
+      diff.patch(telemetryProgressive, o.telemetryDelta);
+      telemetry = structuredClone(telemetryProgressive);
+      acknowledgeTelemetry(o.timeOfCollection);
     }
   });
 
@@ -59,6 +52,15 @@
     });
   });
 
+  function acknowledgeTelemetry(timeOfCollection: number) {
+    portPost({
+      msg: EMsg.TELEMETRY_ACKNOWLEDGED,
+      timeOfCollection,
+    });
+
+    spinnerEl?.tick();
+  }
+
   function onTogglePause() {
     paused = !paused;
     setSettings({ paused });