From 56c17ce0d142c5393955eb8fa22fe3f603691e48 Mon Sep 17 00:00:00 2001
From: Adhiraj Singh <adhirajsingh1001@gmail.com>
Date: Mon, 8 Nov 2021 00:18:12 +0530
Subject: [PATCH] feat: implement stream:error events

---
 src/Socket/socket.ts | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/src/Socket/socket.ts b/src/Socket/socket.ts
index 67db00c..ff2bc3a 100644
--- a/src/Socket/socket.ts
+++ b/src/Socket/socket.ts
@@ -465,6 +465,12 @@ export const makeSocket = ({
 
         ev.emit('connection.update', { connection: 'open' })
     })
+    ws.on('CB:stream:error', (node: BinaryNode) => {
+        logger.error({ error: node }, `stream errored out`)
+
+        const statusCode = +(node.attrs.code || DisconnectReason.restartRequired)
+        end(new Boom('Stream Errored', { statusCode, data: node }))
+    })
     // logged out
     ws.on('CB:failure,reason:401', () => {
         end(new Boom('Logged Out', { statusCode: DisconnectReason.loggedOut }))