WIP: admin_panel: add featurefeature/admin_panel

1 files changed, 79 insertions, 0 deletions

diff --git a/admin-panel/src/client/lib/ws.ts b/admin-panel/src/client/lib/ws.ts
new file mode 100644
index 0000000..14e0cec
--- /dev/null
+++ b/admin-panel/src/client/lib/ws.ts
@@ -0,0 +1,79 @@
+type EventHandler = (data: unknown) => void;
+
+class WsClient {
+  private ws: WebSocket | null = null;
+  private handlers = new Map<string, Set<EventHandler>>();
+  private reconnectTimer: ReturnType<typeof setTimeout> | null = null;
+  private subscribedProjects = new Set<string>();
+
+  connect(): void {
+    if (this.ws?.readyState === WebSocket.OPEN) return;
+
+    const protocol = location.protocol === 'https:' ? 'wss:' : 'ws:';
+    this.ws = new WebSocket(`${protocol}//${location.host}/ws`);
+
+    this.ws.onopen = () => {
+      // Re-subscribe to projects
+      for (const project of this.subscribedProjects) {
+        this.send({ type: 'subscribe', project });
+      }
+    };
+
+    this.ws.onmessage = (event) => {
+      try {
+        const data = JSON.parse(event.data);
+        const handlers = this.handlers.get(data.type);
+        if (handlers) {
+          for (const handler of handlers) {
+            handler(data);
+          }
+        }
+        // Also fire wildcard handlers
+        const wildcardHandlers = this.handlers.get('*');
+        if (wildcardHandlers) {
+          for (const handler of wildcardHandlers) {
+            handler(data);
+          }
+        }
+      } catch {
+        // ignore
+      }
+    };
+
+    this.ws.onclose = () => {
+      this.reconnectTimer = setTimeout(() => this.connect(), 3000);
+    };
+  }
+
+  disconnect(): void {
+    if (this.reconnectTimer) clearTimeout(this.reconnectTimer);
+    this.ws?.close();
+    this.ws = null;
+  }
+
+  subscribe(project: string): void {
+    this.subscribedProjects.add(project);
+    this.send({ type: 'subscribe', project });
+  }
+
+  unsubscribe(project: string): void {
+    this.subscribedProjects.delete(project);
+    this.send({ type: 'unsubscribe', project });
+  }
+
+  on(event: string, handler: EventHandler): () => void {
+    if (!this.handlers.has(event)) {
+      this.handlers.set(event, new Set());
+    }
+    this.handlers.get(event)!.add(handler);
+    return () => this.handlers.get(event)?.delete(handler);
+  }
+
+  private send(data: unknown): void {
+    if (this.ws?.readyState === WebSocket.OPEN) {
+      this.ws.send(JSON.stringify(data));
+    }
+  }
+}
+
+export const wsClient = new WsClient();