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

clear pong timer for any incoming data

Browse Source
This commit is contained in:
tiagosiebler
2021-12-31 00:45:50 +00:00
parent 5cd4ab2c36
commit 352f58e09a
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/websocket-client.ts
View File

@@ -544,6 +544,9 @@ export class WebsocketClient extends EventEmitter {
private onWsMessage(event, wsKey: WsKey) { private onWsMessage(event, wsKey: WsKey) {
try { try {
// any message can clear the pong timer - wouldn't get a message if the ws dropped
this.clearPongTimer(wsKey);
const msg = JSON.parse(event && event.data || event); const msg = JSON.parse(event && event.data || event);
if ('success' in msg || msg?.pong) { if ('success' in msg || msg?.pong) {
this.onWsMessageResponse(msg, wsKey); this.onWsMessageResponse(msg, wsKey);
@@ -579,7 +582,6 @@ export class WebsocketClient extends EventEmitter {
private onWsMessageResponse(response: any, wsKey: WsKey) { private onWsMessageResponse(response: any, wsKey: WsKey) {
if (isWsPong(response)) { if (isWsPong(response)) {
this.logger.silly('Received pong', { ...loggerCategory, wsKey }); this.logger.silly('Received pong', { ...loggerCategory, wsKey });
this.clearPongTimer(wsKey);
} else { } else {
this.emit('response', response); this.emit('response', response);
} }