diff --git a/packages/backend/src/Feed.ts b/packages/backend/src/Feed.ts index 48ee35b..d6a02c2 100644 --- a/packages/backend/src/Feed.ts +++ b/packages/backend/src/Feed.ts @@ -120,7 +120,13 @@ export default class Feed { } public sendData(data: FeedMessage.Data) { - this.socket.send(data); + try { + this.socket.send(data); + } catch (err) { + console.error('Failed to send data to a Feed', err); + + this.disconnect(); + } } public sendMessage(message: FeedMessage.Message) { @@ -139,7 +145,14 @@ export default class Feed { return; } this.waitingForPong = true; - this.socket.ping(noop); + + try { + this.socket.ping(noop); + } catch (err) { + console.error('Failed to send ping to Feed', err); + + this.disconnect(); + } } private sendMessages = () => { diff --git a/packages/backend/src/Node.ts b/packages/backend/src/Node.ts index 5c4b495..40637a1 100644 --- a/packages/backend/src/Node.ts +++ b/packages/backend/src/Node.ts @@ -243,7 +243,14 @@ export default class Node { // } this.pingStart = now; - this.socket.ping(noop); + + try { + this.socket.ping(noop); + } catch (err) { + console.error('Failed to send ping to Node', err); + + this.disconnect(); + } } private updateBestBlock(update: BestBlock) {