Realtime Data API

.envrc

@@ -0,0 +1 @@
+use flake

.gitignore

@@ -1,3 +1,4 @@
 node_modules
 dist
-*~
+*~
+.direnv

backend/app.ts

@@ -84,7 +84,7 @@ export function createFrontend(
   app.post<any, { status: string }>("/fake-update", (req, res) => {
     const instanceId = Array.from(instances.instances.keys())[0];
     const instance = instances.instances.get(instanceId);
-    instance?.webXdc.sendUpdate({ payload: req.body }, "fake update");
+    instance?.webXdc.sendUpdate({ payload: req.body }, "");
     res.json({
       status: "ok",
     });

backend/instance.ts

@@ -22,6 +22,11 @@ type SendUpdateMessage = {
   descr: string;
 };
 
+type SendRealtimeMessage = {
+  type: "sendRealtime";
+  data: Uint8Array
+};
+
 type SetUpdateListenerMessage = {
   type: "setUpdateListener";
   serial: number;
@@ -125,7 +130,13 @@ export class Instances {
         const parsed = JSON.parse(msg);
         // XXX should validate parsed
         if (isSendUpdateMessage(parsed)) {
-          instance.webXdc.sendUpdate(parsed.update, parsed.descr);
+          instance.webXdc.sendUpdate(parsed.update, "");
+        } else if (isSendRealtimeMessage(parsed)) {
+          instance.webXdc.sendRealtimeData(parsed.data);          
+        } else if (isSetRealtimeListenerMessage(parsed)) {
+          instance.webXdc.connectRealtime((data) => {
+            return broadcast(wss, JSON.stringify({ type: "sendRealtime", data }));
+          });          
         } else if (isSetUpdateListenerMessage(parsed)) {
           instance.webXdc.connect(
             (updates) => {
@@ -217,6 +228,14 @@ function isSendUpdateMessage(value: any): value is SendUpdateMessage {
   return value.type === "sendUpdate";
 }
 
+function isSendRealtimeMessage(value: any): value is SendRealtimeMessage {
+  return value.type === "sendRealtime";
+}
+
+function isSetRealtimeListenerMessage(value: any): value is { type: "setRealtimeListener" } {
+  return value.type === "setRealtimeListener";
+}
+
 function isSetUpdateListenerMessage(
   value: any,
 ): value is SetUpdateListenerMessage {