From 331a6e0919e65118a45abd6a3a0c1eefdab52074 Mon Sep 17 00:00:00 2001
From: emad-salah <emads14@gmail.com>
Date: Fri, 10 Jul 2020 13:37:42 +0100
Subject: [PATCH] onNewInvoice/onNewTransaction stack overflow exception fix

---
 src/sockets.js | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/src/sockets.js b/src/sockets.js
index fef09ed4..6bb7abd6 100644
--- a/src/sockets.js
+++ b/src/sockets.js
@@ -121,7 +121,8 @@ module.exports = (
     })
     stream.on('end', () => {
       logger.info('New invoice stream ended, starting a new one...')
-      onNewInvoice(socket)
+      // Prevents call stack overflow exceptions
+      process.nextTick(() => onNewInvoice(socket))
     })
     stream.on('error', err => {
       logger.error('New invoice stream error:', err)
@@ -129,7 +130,8 @@ module.exports = (
     stream.on('status', status => {
       logger.warn('New invoice stream status:', status)
       if (status.code === 14) {
-        onNewInvoice(socket)
+        // Prevents call stack overflow exceptions
+        process.nextTick(() => onNewInvoice(socket))
       }
     })
   }
@@ -144,7 +146,7 @@ module.exports = (
     })
     stream.on('end', () => {
       logger.info('New invoice stream ended, starting a new one...')
-      onNewTransaction(socket)
+      process.nextTick(() => onNewTransaction(socket))
     })
     stream.on('error', err => {
       logger.error('New invoice stream error:', err)
@@ -152,7 +154,7 @@ module.exports = (
     stream.on('status', status => {
       logger.error('New invoice stream status:', status)
       if (status.code === 14) {
-        onNewTransaction(socket)
+        process.nextTick(() => onNewTransaction(socket))
       }
     })
   }