feat(): bump ws to latest

package.json

@@ -25,7 +25,7 @@
   "dependencies": {
     "axios": "^1.6.6",
     "isomorphic-ws": "^4.0.1",
-    "ws": "^7.4.0"
+    "ws": "^8.16.0"
   },
   "devDependencies": {
     "@types/axios": "^0.14.0",

src/lib/BaseWSClient.ts

@@ -435,7 +435,15 @@ export abstract class BaseWebsocketClient<
     this.clearPongTimer(wsKey);
 
     this.logger.trace('Sending ping', { ...WS_LOGGER_CATEGORY, wsKey });
-    this.sendPingEvent(wsKey, this.wsStore.get(wsKey, true).ws);
+    const ws = this.wsStore.get(wsKey, true).ws;
+
+    if (!ws) {
+      this.logger.error(
+        `Unable to send ping for wsKey "${wsKey}" - no connection found`,
+      );
+      return;
+    }
+    this.sendPingEvent(wsKey, ws);
 
     this.wsStore.get(wsKey, true).activePongTimer = setTimeout(() => {
       this.logger.info('Pong timeout - closing socket to reconnect', {
@@ -570,8 +578,8 @@ export abstract class BaseWebsocketClient<
       wsKey,
     });
 
-    const agent = this.options.requestOptions?.agent;
-    const ws = new WebSocket(url, undefined, agent ? { agent } : undefined);
+    const ws = new WebSocket(url, undefined);
+
     ws.onopen = (event: any) => this.onWsOpen(event, wsKey);
     ws.onmessage = (event: any) => this.onWsMessage(event, wsKey);
     ws.onerror = (event: any) =>

src/types/websockets/client.ts

@@ -33,10 +33,7 @@ export interface WSClientConfigurableOptions {
   /** Delay in milliseconds before respawning the connection */
   reconnectTimeout?: number;
 
-  requestOptions?: {
-    /** override the user agent when opening the websocket connection (some proxies use this) */
-    agent?: string;
-  };
+  requestOptions?: {};
 
   wsUrl?: string;