From 3f2aac1ac01e08e45096f0bb3c52cd770678785c Mon Sep 17 00:00:00 2001 From: Daniel Lugo Date: Thu, 10 Dec 2020 17:31:56 -0400 Subject: [PATCH] remove unused service --- services/lnd/lnd.js | 80 --------------------------------------------- src/server.js | 9 +++-- 2 files changed, 4 insertions(+), 85 deletions(-) delete mode 100644 services/lnd/lnd.js diff --git a/services/lnd/lnd.js b/services/lnd/lnd.js deleted file mode 100644 index da5ffe51..00000000 --- a/services/lnd/lnd.js +++ /dev/null @@ -1,80 +0,0 @@ -// app/lnd.js - -const logger = require("winston"); - -// TODO -module.exports = function(lightning) { - const module = {}; - - const invoiceListeners = []; - - let lndInvoicesStream = null; - - const openLndInvoicesStream = function() { - if (lndInvoicesStream) { - logger.debug("Lnd invoices subscription stream already opened."); - } else { - logger.debug("Opening lnd invoices subscription stream..."); - lndInvoicesStream = lightning.subscribeInvoices({}); - logger.debug("Lnd invoices subscription stream opened."); - lndInvoicesStream.on("data", function(data) { - logger.debug("SubscribeInvoices Data", data); - for (let i = 0; i < invoiceListeners.length; i++) { - try { - invoiceListeners[i].dataReceived(data); - } catch (err) { - logger.warn(err); - } - } - }); - lndInvoicesStream.on("end", function() { - logger.debug("SubscribeInvoices End"); - lndInvoicesStream = null; - openLndInvoicesStream(); // try opening stream again - }); - lndInvoicesStream.on("error", function(err) { - logger.debug("SubscribeInvoices Error", err); - }); - lndInvoicesStream.on("status", function(status) { - logger.debug("SubscribeInvoices Status", status); - if (status.code == 14) { - // Unavailable - lndInvoicesStream = null; - openLndInvoicesStream(); // try opening stream again - } - }); - } - }; - - // register invoice listener - module.registerInvoiceListener = function(listener) { - invoiceListeners.push(listener); - logger.debug( - "New lnd invoice listener registered, " + - invoiceListeners.length + - " listening now" - ); - }; - - // unregister invoice listener - module.unregisterInvoiceListener = function(listener) { - invoiceListeners.splice(invoiceListeners.indexOf(listener), 1); - logger.debug( - "Lnd invoice listener unregistered, " + - invoiceListeners.length + - " still listening" - ); - }; - - // open lnd invoices stream on start - openLndInvoicesStream(); - - // check every minute that lnd invoices stream is still opened - setInterval(function() { - if (!lndInvoicesStream) { - openLndInvoicesStream(); - } - }, 60 * 1000); - - return module; -}; diff --git a/src/server.js b/src/server.js index 7a0c2a4c..5de6dbd7 100644 --- a/src/server.js +++ b/src/server.js @@ -164,10 +164,6 @@ const server = program => { await LightningServices.init() } - // init lnd module ================= - const lnd = require('../services/lnd/lnd')( - LightningServices.services.lightning - ) await new Promise((resolve, reject) => { LightningServices.services.lightning.getInfo({}, (err, res) => { if (err && err.code !== 12) { @@ -216,7 +212,10 @@ const server = program => { next() }) - const storageDirectory = Path.resolve(rootFolder, `${program.rootPath ? '.' : '..'}/.storage`); + const storageDirectory = Path.resolve( + rootFolder, + `${program.rootPath ? '.' : '..'}/.storage` + ) await Storage.init({ dir: storageDirectory