Add retryTimeoutMs param

src/BasicClient.ts

@@ -6,7 +6,7 @@ import { Watcher } from "./Watcher";
 import { Market } from "./Market";
 
 export type MarketMap = Map<string, Market>;
-export type WssFactoryFn = (path: string) => SmartWss;
+export type WssFactoryFn = (path: string, retryTimeoutMs?: number) => SmartWss;
 export type SendFn = (remoteId: string, market: Market) => void;
 
 /**
@@ -42,6 +42,7 @@ export abstract class BasicClient extends EventEmitter implements IClient {
         readonly name: string,
         wssFactory?: WssFactoryFn,
         watcherMs?: number,
+        retryTimeoutMs?: number,
     ) {
         super();
         this._tickerSubs = new Map();
@@ -61,7 +62,7 @@ export abstract class BasicClient extends EventEmitter implements IClient {
         this.hasLevel2Updates = false;
         this.hasLevel3Snapshots = false;
         this.hasLevel3Updates = false;
-        this._wssFactory = wssFactory || (path => new SmartWss(path));
+        this._wssFactory = wssFactory || (path => new SmartWss(path, retryTimeoutMs));
     }
 
     //////////////////////////////////////////////

src/ClientOptions.ts

@@ -2,6 +2,7 @@ export type ClientOptions = {
     wssPath?: string;
     watcherMs?: number;
     throttleMs?: number;
+    retryTimeoutMs?: number;
     l2UpdateDepth?: number;
     throttleL2Snapshot?: number;
 };

src/SmartWss.ts

@@ -11,9 +11,9 @@ export class SmartWss extends EventEmitter {
     private _connected: boolean;
     private _wss: any;
 
-    constructor(readonly wssPath: string) {
+    constructor(readonly wssPath: string, retryTimeoutMs = 15000) {
         super();
-        this._retryTimeoutMs = 15000;
+        this._retryTimeoutMs = retryTimeoutMs;
         this._connected = false;
     }
 

src/exchanges/DigifinexClient.ts

@@ -20,8 +20,8 @@ import * as zlib from "../ZlibUtils";
 export class DigifinexClient extends BasicClient {
     public id: number;
 
-    constructor({ wssPath = "wss://openapi.digifinex.com/ws/v1/", watcherMs }: ClientOptions = {}) {
-        super(wssPath, "Digifinex", undefined, watcherMs);
+    constructor({ wssPath = "wss://openapi.digifinex.com/ws/v1/", watcherMs, retryTimeoutMs }: ClientOptions = {}) {
+        super(wssPath, "Digifinex", undefined, watcherMs, retryTimeoutMs);
         this.hasTickers = true;
         this.hasTrades = true;
         this.hasLevel2Updates = true;