From 61e512b8f708ef19b41bd125bcc1e05a20896ef8 Mon Sep 17 00:00:00 2001
From: nymkappa <vialjoris@hotmail.com>
Date: Mon, 8 Aug 2022 09:00:11 +0200
Subject: [PATCH] Refactor the LN backend and add more logs

---
 .../tasks/lightning/network-sync.service.ts   | 57 ++++++++++++++++++-
 .../tasks/lightning/stats-updater.service.ts  |  1 -
 .../sync-tasks/funding-tx-fetcher.ts          |  2 +-
 3 files changed, 57 insertions(+), 3 deletions(-)

diff --git a/backend/src/tasks/lightning/network-sync.service.ts b/backend/src/tasks/lightning/network-sync.service.ts
index 857ebceb2..83c6f21cc 100644
--- a/backend/src/tasks/lightning/network-sync.service.ts
+++ b/backend/src/tasks/lightning/network-sync.service.ts
@@ -73,7 +73,7 @@ class NetworkSyncService {
     logger.info(`${progress} nodes updated`);
 
     // If a channel if not present in the graph, mark it as inactive
-    // nodesApi.$setNodesInactive(graphNodesPubkeys);
+    nodesApi.$setNodesInactive(graphNodesPubkeys);
 
     if (config.MAXMIND.ENABLED) {
       $lookupNodeLocation();
@@ -107,6 +107,61 @@ class NetworkSyncService {
     } catch (e) {
       logger.err(`Cannot update channel list. Reason: ${(e instanceof Error ? e.message : e)}`);
     }
+
+    setTimeout(() => { this.$runTasks(); }, 1000 * config.LIGHTNING.STATS_REFRESH_INTERVAL);
+  }
+
+  /**
+   * Update the `nodes` table to reflect the current network graph state
+   */
+  private async $updateNodesList(nodes: ILightningApi.Node[]): Promise<void> {
+    let progress = 0;
+
+    const graphNodesPubkeys: string[] = [];
+    for (const node of nodes) {
+      await nodesApi.$saveNode(node);
+      graphNodesPubkeys.push(node.pub_key);
+      ++progress;
+
+      const elapsedSeconds = Math.round((new Date().getTime() / 1000) - this.loggerTimer);
+      if (elapsedSeconds > 10) {
+        logger.info(`Updating node ${progress}/${nodes.length}`);
+        this.loggerTimer = new Date().getTime() / 1000;
+      }
+    }
+    logger.info(`${progress} nodes updated`);
+
+    // If a channel if not present in the graph, mark it as inactive
+    // nodesApi.$setNodesInactive(graphNodesPubkeys);
+
+    if (config.MAXMIND.ENABLED) {
+      $lookupNodeLocation();
+    }
+  }
+
+  /**
+   * Update the `channels` table to reflect the current network graph state
+   */
+  private async $updateChannelsList(channels: ILightningApi.Channel[]): Promise<void> {
+    let progress = 0;
+
+    const graphChannelsIds: string[] = [];
+    for (const channel of channels) {
+      await channelsApi.$saveChannel(channel);
+      graphChannelsIds.push(channel.channel_id);
+      ++progress;
+
+      const elapsedSeconds = Math.round((new Date().getTime() / 1000) - this.loggerTimer);
+      if (elapsedSeconds > 10) {
+        logger.info(`Updating channel ${progress}/${channels.length}`);
+        this.loggerTimer = new Date().getTime() / 1000;
+      }
+    }
+
+    logger.info(`${progress} channels updated`);
+
+    // If a channel if not present in the graph, mark it as inactive
+    channelsApi.$setChannelsInactive(graphChannelsIds);
   }
 
   // This method look up the creation date of the earliest channel of the node
diff --git a/backend/src/tasks/lightning/stats-updater.service.ts b/backend/src/tasks/lightning/stats-updater.service.ts
index ab5b3cccb..ecb056859 100644
--- a/backend/src/tasks/lightning/stats-updater.service.ts
+++ b/backend/src/tasks/lightning/stats-updater.service.ts
@@ -24,7 +24,6 @@ class LightningStatsUpdater {
   private async $logStatsDaily(): Promise<void> {
     const date = new Date();
     Common.setDateMidnight(date);
-
     const networkGraph = await lightningApi.$getNetworkGraph();
     LightningStatsImporter.computeNetworkStats(date.getTime() / 1000, networkGraph);
     
diff --git a/backend/src/tasks/lightning/sync-tasks/funding-tx-fetcher.ts b/backend/src/tasks/lightning/sync-tasks/funding-tx-fetcher.ts
index 6ee50b8e9..9dbc21c72 100644
--- a/backend/src/tasks/lightning/sync-tasks/funding-tx-fetcher.ts
+++ b/backend/src/tasks/lightning/sync-tasks/funding-tx-fetcher.ts
@@ -115,4 +115,4 @@ class FundingTxFetcher {
   }
 }
 
-export default new FundingTxFetcher;
\ No newline at end of file
+export default new FundingTxFetcher;