fix format

Author: keyvankhademi

lazer/sdk/js/examples/index.ts

@@ -7,18 +7,22 @@ import { PythLazerClient } from "../src/index.js";
 console.debug = () => {};
 
 const client = await PythLazerClient.create({
-    urls: ["wss://pyth-lazer-0.dourolabs.app/v1/stream", "wss://pyth-lazer-1.dourolabs.app/v1/stream"],
-    token: "you-access-token-here", // Replace with your actual access token
-    numConnections: 4, // Optionally specify number of parallel redundant connections to reduce the chance of dropped messages. The connections will round-robin across the provided URLs. Default is 4.
-    logger: console, // Optionally log socket operations (to the console in this case.)
-    onError: (error) => {
-      console.error("WebSocket error:", error);
-    },
-    rwsConfig: { // Optional configuration for resilient WebSocket connections
-      heartbeatTimeoutDurationMs: 5000, // Optional heartbeat timeout duration in milliseconds
-      maxRetryDelayMs: 1000, // Optional maximum retry delay in milliseconds
-      logAfterRetryCount: 10, // Optional log after how many retries
-    }
+  urls: [
+    "wss://pyth-lazer-0.dourolabs.app/v1/stream",
+    "wss://pyth-lazer-1.dourolabs.app/v1/stream",
+  ],
+  token: "you-access-token-here", // Replace with your actual access token
+  numConnections: 4, // Optionally specify number of parallel redundant connections to reduce the chance of dropped messages. The connections will round-robin across the provided URLs. Default is 4.
+  logger: console, // Optionally log socket operations (to the console in this case.)
+  onError: (error) => {
+    console.error("WebSocket error:", error);
+  },
+  // Optional configuration for resilient WebSocket connections
+  rwsConfig: {
+    heartbeatTimeoutDurationMs: 5000, // Optional heartbeat timeout duration in milliseconds
+    maxRetryDelayMs: 1000, // Optional maximum retry delay in milliseconds
+    logAfterRetryCount: 10, // Optional log after how many retries
+  },
 });
 
 // Read and process messages from the Lazer stream

lazer/sdk/js/src/client.ts

@@ -2,8 +2,8 @@ import WebSocket from "isomorphic-ws";
 
 import type { ParsedPayload, Request, Response } from "./protocol.js";
 import { BINARY_UPDATE_FORMAT_MAGIC_LE, FORMAT_MAGICS_LE } from "./protocol.js";
-import type {WebSocketPoolConfig} from "./socket/websocket-pool.js";
-import { WebSocketPool  } from "./socket/websocket-pool.js";
+import type { WebSocketPoolConfig } from "./socket/websocket-pool.js";
+import { WebSocketPool } from "./socket/websocket-pool.js";
 
 export type BinaryResponse = {
   subscriptionId: number;
@@ -34,9 +34,7 @@ export class PythLazerClient {
    * @param numConnections - The number of parallel WebSocket connections to establish (default: 3). A higher number gives a more reliable stream. The connections will round-robin across the provided URLs.
    * @param logger - Optional logger to get socket level logs. Compatible with most loggers such as the built-in console and `bunyan`.
    */
-  static async create(
-    config: WebSocketPoolConfig
-  ): Promise<PythLazerClient> {
+  static async create(config: WebSocketPoolConfig): Promise<PythLazerClient> {
     const wsp = await WebSocketPool.create(config);
     return new PythLazerClient(wsp);
   }

lazer/sdk/js/src/socket/resilient-websocket.ts

@@ -16,7 +16,7 @@ export type ResilientWebSocketConfig = {
   heartbeatTimeoutDurationMs?: number;
   maxRetryDelayMs?: number;
   logAfterRetryCount?: number;
-}
+};
 
 export class ResilientWebSocket {
   private endpoint: string;
@@ -49,17 +49,14 @@ export class ResilientWebSocket {
   onMessage: (data: WebSocket.Data) => void;
   onReconnect: () => void;
 
-  constructor(
-    config: ResilientWebSocketConfig,
-  ) {
+  constructor(config: ResilientWebSocketConfig) {
     this.endpoint = config.endpoint;
     this.wsOptions = config.wsOptions;
     this.logger = config.logger ?? dummyLogger;
     this.heartbeatTimeoutDurationMs =
       config.heartbeatTimeoutDurationMs ??
       DEFAULT_HEARTBEAT_TIMEOUT_DURATION_MS;
-    this.maxRetryDelayMs =
-      config.maxRetryDelayMs ?? DEFAULT_MAX_RETRY_DELAY_MS;
+    this.maxRetryDelayMs = config.maxRetryDelayMs ?? DEFAULT_MAX_RETRY_DELAY_MS;
     this.logAfterRetryCount =
       config.logAfterRetryCount ?? DEFAULT_LOG_AFTER_RETRY_COUNT;
 
@@ -90,7 +87,7 @@ export class ResilientWebSocket {
   startWebSocket() {
     if (this.wsUserClosed) {
       this.logger.error("Connection was explicitly close. Won't reconnect.");
-      return
+      return;
     }
 
     if (this.wsClient !== undefined) {
@@ -119,7 +116,9 @@ export class ResilientWebSocket {
 
     this.wsClient.addEventListener("close", (e) => {
       if (this.wsUserClosed) {
-        this.logger.info(`WebSocket connection to ${this.endpoint} closed by user`);
+        this.logger.info(
+          `WebSocket connection to ${this.endpoint} closed by user`,
+        );
       } else {
         if (this.shouldLogRetry()) {
           this.logger.warn(
@@ -161,7 +160,9 @@ export class ResilientWebSocket {
 
   private handleReconnect() {
     if (this.wsUserClosed) {
-      this.logger.info("WebSocket connection closed by user, not reconnecting.");
+      this.logger.info(
+        "WebSocket connection closed by user, not reconnecting.",
+      );
       return;
     }
 
@@ -173,7 +174,6 @@ export class ResilientWebSocket {
       clearTimeout(this.retryTimeout);
     }
 
-   
     this.wsFailedAttempts += 1;
     this.wsClient = undefined;
 
@@ -189,7 +189,7 @@ export class ResilientWebSocket {
 
     this.retryTimeout = setTimeout(() => {
       this.startWebSocket();
-    }, this.retryDelayMs());    
+    }, this.retryDelayMs());
   }
 
   closeWebSocket(): void {

lazer/sdk/js/src/socket/websocket-pool.ts

@@ -5,8 +5,8 @@ import type { Logger } from "ts-log";
 import { dummyLogger } from "ts-log";
 
 import type { Request, Response } from "../protocol.js";
-import type {ResilientWebSocketConfig} from "./resilient-websocket.js";
-import { ResilientWebSocket  } from "./resilient-websocket.js";
+import type { ResilientWebSocketConfig } from "./resilient-websocket.js";
+import { ResilientWebSocket } from "./resilient-websocket.js";
 
 const DEFAULT_NUM_CONNECTIONS = 4;
 
@@ -15,7 +15,7 @@ export type WebSocketPoolConfig = {
   token: string;
   numConnections?: number;
   logger?: Logger;
-  rwsConfig?: Omit<ResilientWebSocketConfig, 'logger' | 'endpoint'>;
+  rwsConfig?: Omit<ResilientWebSocketConfig, "logger" | "endpoint">;
   onError?: (error: ErrorEvent) => void;
 };
 
@@ -49,9 +49,7 @@ export class WebSocketPool {
    * @param numConnections - Number of parallel WebSocket connections to maintain (default: 3)
    * @param logger - Optional logger to get socket level logs. Compatible with most loggers such as the built-in console and `bunyan`.
    */
-  static async create(
-    config: WebSocketPoolConfig,
-  ): Promise<WebSocketPool> {
+  static async create(config: WebSocketPoolConfig): Promise<WebSocketPool> {
     if (config.urls.length === 0) {
       throw new Error("No URLs provided");
     }
@@ -75,7 +73,7 @@ export class WebSocketPool {
         ...config.rwsConfig,
         endpoint: url,
         wsOptions,
-        logger
+        logger,
       });
 
       // If a websocket client unexpectedly disconnects, ResilientWebSocket will reestablish
@@ -115,7 +113,7 @@ export class WebSocketPool {
 
     pool.logger.info(
       `At least one WebSocket connection is established. WebSocketPool is ready.`,
-    )
+    );
 
     return pool;
   }