code/bybit-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Rest to Inverse Name Changes

Browse Source
This commit is contained in:
peepopoggers
2021-01-21 22:22:09 +00:00
committed by GitHub
parent fe71e256fd
commit aca8136fe1
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/websocket-client.ts
View File

@@ -1,6 +1,5 @@
import { EventEmitter } from 'events'; import { EventEmitter } from 'events';
import { InverseClient } from './inverse-client';
import { RestClient } from './rest-client';
import { DefaultLogger } from './logger'; import { DefaultLogger } from './logger';
import { signMessage, serializeParams } from './util/requestUtils'; import { signMessage, serializeParams } from './util/requestUtils';
// import WebSocket from 'ws'; // import WebSocket from 'ws';
@@ -37,7 +36,7 @@ export class WebsocketClient extends EventEmitter {
private readyState: number; private readyState: number;
private pingInterval?: number | undefined; private pingInterval?: number | undefined;
private pongTimeout?: number | undefined; private pongTimeout?: number | undefined;
private client: RestClient; private client: InverseClient;
private _subscriptions: Set<unknown>; private _subscriptions: Set<unknown>;
private ws: WebSocket; private ws: WebSocket;
private options: WebsocketClientOptions; private options: WebsocketClientOptions;
@@ -59,7 +58,7 @@ export class WebsocketClient extends EventEmitter {
...options ...options
}; };
this.client = new RestClient(undefined, undefined, this.options.livenet, this.options.restOptions, this.options.requestOptions); this.client = new InverseClient(undefined, undefined, this.options.livenet, this.options.restOptions, this.options.requestOptions);
this._subscriptions = new Set(); this._subscriptions = new Set();
this._connect(); this._connect();
@@ -161,7 +160,8 @@ export class WebsocketClient extends EventEmitter {
this.logger.silly('Sending ping', { category: 'bybit-ws' }); this.logger.silly('Sending ping', { category: 'bybit-ws' });
this.ws.send(JSON.stringify({op: 'ping'})); this.ws.send(JSON.stringify({op: 'ping'}));
this.pongTimeout = setTimeout(() => {
this.pongTimeout = <any>setTimeout(() => {
this.logger.info('Pong timeout', { category: 'bybit-ws' }); this.logger.info('Pong timeout', { category: 'bybit-ws' });
this._teardown(); this._teardown();
// this.ws.terminate(); // this.ws.terminate();
@@ -190,7 +190,7 @@ export class WebsocketClient extends EventEmitter {
this.readyState = READY_STATE_CONNECTED; this.readyState = READY_STATE_CONNECTED;
this._subscribe([...this._subscriptions]); this._subscribe([...this._subscriptions]);
this.pingInterval = setInterval(this._ping.bind(this), this.options.pingInterval); this.pingInterval = <any>setInterval(this._ping.bind(this), this.options.pingInterval);
} }
_wsMessageHandler(message) { _wsMessageHandler(message) {