Skip to content

Commit

Permalink
JS - Handle websocket errors
Browse files Browse the repository at this point in the history
  • Loading branch information
1aerostorm committed Mar 3, 2022
1 parent 4afbade commit e237f69
Showing 1 changed file with 12 additions and 2 deletions.
14 changes: 12 additions & 2 deletions golos-lib-js/src/api/transports/ws.js
Expand Up @@ -46,8 +46,7 @@ export default class WsTransport extends Transport {
resolve();
});

const releaseClose = this.listenTo(this.ws, 'close', () => {
debugWs('Closed WS connection with', url);
const errHandler = () => {
const wasOpen = this.isOpen;
this.isOpen = false;
delete this.ws;
Expand All @@ -67,6 +66,16 @@ export default class WsTransport extends Transport {
delete this.callbacks[id];
val.cb(err, null);
}
}

const releaseClose = this.listenTo(this.ws, 'close', () => {
debugWs('Closed WS connection with', url);
errHandler();
});

const releaseError = this.listenTo(this.ws, 'error', (error) => {
debugWs('Closed WS connection with', url, 'error is', error);
errHandler();
});

const releaseMessage = this.listenTo(this.ws, 'message', (message) => {
Expand All @@ -85,6 +94,7 @@ export default class WsTransport extends Transport {
this.releases = this.releases.concat([
releaseOpen,
releaseClose,
releaseError,
releaseMessage,
]);
});
Expand Down

0 comments on commit e237f69

Please sign in to comment.