From ac3f47e99d7aa6ca8d7169f7af453e47b2a0bdf5 Mon Sep 17 00:00:00 2001
From: hatim boufnichel <boufni95@gmail.com>
Date: Mon, 14 Sep 2020 14:00:45 +0200
Subject: [PATCH] fix function name, more log fix

---
 src/routes.js  |  7 +++++--
 src/sockets.js | 20 +++++++++++++++++++-
 2 files changed, 24 insertions(+), 3 deletions(-)

diff --git a/src/routes.js b/src/routes.js
index f4933ffa..81588e1b 100644
--- a/src/routes.js
+++ b/src/routes.js
@@ -654,7 +654,7 @@ module.exports = async (
                   'Channel backup LND locked, new registration in 60 seconds'
                 )
                 process.nextTick(() =>
-                  setTimeout(() => onNewTransaction(socket, subID), 60000)
+                  setTimeout(() => onNewChannelBackup(), 60000)
                 )
                 break
               }
@@ -668,10 +668,13 @@ module.exports = async (
                   'Channel backup LND disconnected, sockets reconnecting in 30 seconds...'
                 )
                 process.nextTick(() =>
-                  setTimeout(() => onNewTransaction(socket, subID), 30000)
+                  setTimeout(() => onNewChannelBackup(), 30000)
                 )
                 break
               }
+              default: {
+                logger.error('[event:transaction:new] UNKNOWN LND error')
+              }
             }
           })
         }
diff --git a/src/sockets.js b/src/sockets.js
index fd317c61..2fd93ecc 100644
--- a/src/sockets.js
+++ b/src/sockets.js
@@ -134,6 +134,12 @@ module.exports = (
           logger.info('[event:invoice:new] stream ok')
           break
         }
+        case 1: {
+          logger.info(
+            '[event:invoice:new] stream canceled, probably socket disconnected'
+          )
+          break
+        }
         case 2: {
           logger.warn('[event:invoice:new] got UNKNOWN error status')
           break
@@ -161,6 +167,9 @@ module.exports = (
           )
           break
         }
+        default: {
+          logger.error('[event:invoice:new] UNKNOWN LND error')
+        }
       }
     })
     return () => {
@@ -184,12 +193,18 @@ module.exports = (
       logger.error('New transactions stream error:' + subID, err)
     })
     stream.on('status', status => {
-      logger.error('New transactions stream status:' + subID, status)
+      logger.info('New transactions stream status:' + subID, status)
       switch (status.code) {
         case 0: {
           logger.info('[event:transaction:new] stream ok')
           break
         }
+        case 1: {
+          logger.info(
+            '[event:transaction:new] stream canceled, probably socket disconnected'
+          )
+          break
+        }
         case 2: {
           //Happens to fire when the grpc client lose access to macaroon file
           logger.warn('[event:transaction:new] got UNKNOWN error status')
@@ -218,6 +233,9 @@ module.exports = (
           )
           break
         }
+        default: {
+          logger.error('[event:transaction:new] UNKNOWN LND error')
+        }
       }
     })
     return () => {