pass callbacks to client

dist/index.js

@@ -4,6 +4,12 @@ export class TetherClient {
     subscribedQueries = new Map();
     connect = (url) => {
         this.websocketHandler.startConnection(url);
+        this.websocketHandler.onQuery = (location, data) => {
+            if (location) {
+                const callback = this.subscribedQueries.get(location);
+                callback?.(data);
+            }
+        };
     };
     disconnect = () => {
         this.websocketHandler.close();

dist/utils/websocket.d.ts

@@ -1,9 +1,9 @@
 export declare class WebSocketHandler {
     private ws;
     private url;
-    private subscribedQueries;
+    onOpen: () => void;
-    private onOpen;
+    onQuery: (location: string | undefined, data: any) => void;
-    private onClose;
+    onClose: () => void;
     private reconnectAttempts;
     private maxReconnectAttempts;
     private reconnectInterval;

dist/utils/websocket.js

@@ -1,8 +1,8 @@
 export class WebSocketHandler {
     ws = null;
     url = '';
-    subscribedQueries = new Map();
     onOpen = () => { };
+    onQuery = () => { };
     onClose = () => { };
     reconnectAttempts = 0;
     maxReconnectAttempts = 5;
@@ -24,11 +24,7 @@ export class WebSocketHandler {
         ws.onmessage = (event) => {
             const data = JSON.parse(String(event.data));
             if (data.type === 'query') {
-                this.subscribedQueries.forEach((callback, query) => {
+                this.onQuery(data.location, data.data);
-                    if (data.query === query) {
-                        callback(data.data);
-                    }
-                });
             }
             else if (data.type === 'error') {
                 console.error(data.error);

src/index.ts

@@ -5,6 +5,12 @@ export class TetherClient {
 
     connect = (url: string) => {
         this.websocketHandler.startConnection(url);
+        this.websocketHandler.onQuery = (location, data) => {
+            if (location) {
+                const callback = this.subscribedQueries.get(location);
+                callback?.(data);
+            }
+        };
     };
     
     disconnect = () => {

src/utils/websocket.ts

@@ -1,9 +1,9 @@
 export class WebSocketHandler {
     private ws: WebSocket | null = null;
     private url: string = '';
-    private subscribedQueries = new Map<string, (data: any) => void>();
+    public onOpen: () => void = () => {};
-    private onOpen: () => void = () => {};
+    public onQuery: (location: string | undefined, data: any) => void = () => {};
-    private onClose: () => void = () => {};
+    public onClose: () => void = () => {};
     private reconnectAttempts: number = 0;
     private maxReconnectAttempts: number = 5;
     private reconnectInterval: number = 1000;
@@ -27,16 +27,12 @@ export class WebSocketHandler {
         ws.onmessage = (event: MessageEvent) => {
             const data = JSON.parse(String(event.data)) as {
                 type: string;
-                query?: string;
+                location?: string;
                 data?: unknown;
                 error?: string;
             };
             if (data.type === 'query') {
-                this.subscribedQueries.forEach((callback, query) => {
+                this.onQuery(data.location, data.data);
-                    if (data.query === query) {
-                        callback(data.data);
-                    }
-                });
             } else if (data.type === 'error') {
                 console.error(data.error);
             }