Merge pull request #31 from stakwork/bugfix-subscribe-reconnect-lnd

Bugfix subscribe reconnect lnd

api/grpc/index.ts

@@ -9,6 +9,8 @@ import * as moment from 'moment'
 import * as path from 'path'
 
 const constants = require(path.join(__dirname,'../../config/constants.json'))
+const ERR_CODE_UNAVAILABLE = 14
+const ERR_CODE_STREAM_REMOVED = 2
 
 // VERIFY PUBKEY OF SENDER
 async function parseAndVerifyPayload(data){
@@ -171,11 +173,20 @@ function subscribeInvoices(actions) {
 		});
 		call.on('status', function(status) {
 			console.log("Status", status);
-			resolve(status)
+			// The server is unavailable, trying to reconnect.
+			if (status.code == ERR_CODE_UNAVAILABLE || status.code == ERR_CODE_STREAM_REMOVED) {
+				reconnectToLND();
+			} else {
+				resolve(status);
+			}
 		})
 		call.on('error', function(err){
 			console.error(err)
-			reject(err)
+			if (err.code == ERR_CODE_UNAVAILABLE || err.code == ERR_CODE_STREAM_REMOVED) {
+				reconnectToLND();
+			} else {
+				reject(err)
+			}
 		})
 		call.on('end', function() {
 			const now = moment().format('YYYY-MM-DD HH:mm:ss').trim();

dist/api/grpc/index.js

@@ -19,6 +19,8 @@ const controllers = require("../controllers");
 const moment = require("moment");
 const path = require("path");
 const constants = require(path.join(__dirname, '../../config/constants.json'));
+const ERR_CODE_UNAVAILABLE = 14;
+const ERR_CODE_STREAM_REMOVED = 2;
 // VERIFY PUBKEY OF SENDER
 function parseAndVerifyPayload(data) {
     return __awaiter(this, void 0, void 0, function* () {
@@ -182,11 +184,22 @@ function subscribeInvoices(actions) {
         });
         call.on('status', function (status) {
             console.log("Status", status);
-            resolve(status);
+            // The server is unavailable, trying to reconnect.
+            if (status.code == ERR_CODE_UNAVAILABLE || status.code == ERR_CODE_STREAM_REMOVED) {
+                reconnectToLND();
+            }
+            else {
+                resolve(status);
+            }
         });
         call.on('error', function (err) {
             console.error(err);
-            reject(err);
+            if (err.code == ERR_CODE_UNAVAILABLE || err.code == ERR_CODE_STREAM_REMOVED) {
+                reconnectToLND();
+            }
+            else {
+                reject(err);
+            }
         });
         call.on('end', function () {
             const now = moment().format('YYYY-MM-DD HH:mm:ss').trim();