[DDW-812] Remove interval and watch for new log file lines

Author: Lucas Araujo

package.json

@@ -271,6 +271,7 @@
     "shasum": "1.0.2",
     "source-map-support": "0.5.19",
     "spectron-fake-dialog": "0.0.1",
+    "tail": "2.2.4",
     "tcp-port-used": "1.0.1",
     "trezor-connect": "8.2.4-extended",
     "unorm": "1.6.0",

source/main/config.ts

@@ -172,8 +172,6 @@ export const DISK_SPACE_RECOMMENDED_PERCENTAGE = 15; // 15% of the total disk sp
 
 export const DISK_SPACE_CHECK_TIMEOUT = 9 * 1000; // Timeout for checking disks pace
 
-export const BLOCK_REPLAY_PROGRESS_CHECK_INTERVAL = 1 * 1000; // 1 seconds | unit: milliseconds
-
 // Used if token metadata server URL is not defined in launcher config
 export const FALLBACK_TOKEN_METADATA_SERVER_URL =
   'https://metadata.cardano-testnet.iohkdev.io';

source/main/index.ts

@@ -248,7 +248,7 @@ const onAppReady = async () => {
   };
 
   mainErrorHandler(onMainError);
-  await handleCheckBlockReplayProgress(mainWindow, launcherConfig.logsPrefix);
+  handleCheckBlockReplayProgress(mainWindow, launcherConfig.logsPrefix);
   await handleCheckDiskSpace();
 
   if (isWatchMode) {

source/main/utils/blockSyncProgressHelpers.ts

@@ -1,8 +1,7 @@
 import moment, { Moment } from 'moment';
 
 export function isItFreshLog(applicationStartDate: Moment, line: string) {
-  const [, logDate] = line.match(
-    /\[(\d{4}-\d{2}-\d{2}\s\d{2}:\d{2}:\d{2}\.\d+) UTC]/
-  );
+  const [, logDate] =
+    line.match(/\[(\d{4}-\d{2}-\d{2}\s\d{2}:\d{2}:\d{2}\.\d+) UTC]/) || [];
   return applicationStartDate.isBefore(moment.utc(logDate));
 }

source/main/utils/handleCheckBlockReplayProgress.ts

@@ -1,11 +1,10 @@
 import { BrowserWindow } from 'electron';
 import fs from 'fs';
-import moment, { Moment } from 'moment';
-import readline from 'readline';
+import moment from 'moment';
 import path from 'path';
+import { Tail } from 'tail';
 import { getBlockSyncProgressChannel } from '../ipc/get-block-sync-progress';
 import type { GetBlockSyncProgressType } from '../../common/ipc/api';
-import { BLOCK_REPLAY_PROGRESS_CHECK_INTERVAL } from '../config';
 import { BlockSyncType } from '../../common/types/cardano-node.types';
 import { isItFreshLog } from './blockSyncProgressHelpers';
 
@@ -44,34 +43,29 @@ function getProgressType(line: string): GetBlockSyncProgressType | null {
 
 const applicationStartDate = moment.utc();
 
-export const handleCheckBlockReplayProgress = (
+export const handleCheckBlockReplayProgress = async (
   mainWindow: BrowserWindow,
   logsDirectoryPath: string
 ) => {
-  const checkBlockReplayProgress = async () => {
-    const filename = 'node.log';
-    const logFilePath = `${logsDirectoryPath}/pub/`;
-    const filePath = path.join(logFilePath, filename);
-    if (!fs.existsSync(filePath)) return;
-    const fileStream = fs.createReadStream(filePath);
-    const rl = readline.createInterface({
-      input: fileStream,
-    });
-    const progress = [];
+  const filename = 'node.log';
+  const logFilePath = `${logsDirectoryPath}/pub/`;
+  const filePath = path.join(logFilePath, filename);
+  if (!fs.existsSync(filePath)) return;
 
-    for await (const line of rl) {
-      if (
-        containProgressKeywords(line) &&
-        isItFreshLog(applicationStartDate, line)
-      ) {
-        progress.push(line);
-      }
+  const tail = new Tail(filePath);
+
+  tail.on('line', (line) => {
+    if (
+      !(
+        isItFreshLog(applicationStartDate, line) &&
+        containProgressKeywords(line)
+      )
+    ) {
+      return;
     }
 
-    if (!progress.length) return;
-    const finalProgress = progress.slice(-1).pop();
-    const percentage = finalProgress.match(/Progress:([\s\d.,]+)%/)?.[1];
-    const progressType = getProgressType(finalProgress);
+    const percentage = line.match(/Progress:([\s\d.,]+)%/)?.[1];
+    const progressType = getProgressType(line);
     if (!percentage || !progressType) {
       return;
     }
@@ -81,22 +75,5 @@ export const handleCheckBlockReplayProgress = (
       { progress: finalProgressPercentage, type: progressType },
       mainWindow.webContents
     );
-
-    if (
-      finalProgressPercentage === 100 &&
-      progressType === BlockSyncType.pushingLedger
-    ) {
-      clearInterval(checkBlockReplayProgressInterval);
-    }
-  };
-
-  const setBlockReplayProgressCheckingInterval = () => {
-    return setInterval(async () => {
-      checkBlockReplayProgress();
-    }, BLOCK_REPLAY_PROGRESS_CHECK_INTERVAL);
-  };
-
-  // Start default interval
-  const checkBlockReplayProgressInterval = setBlockReplayProgressCheckingInterval();
-  return checkBlockReplayProgress;
+  });
 };

yarn.lock

@@ -16456,6 +16456,10 @@ table@^6.0.1:
     slice-ansi "^4.0.0"
     string-width "^4.2.0"
 
+[email protected]:
+  version "2.2.4"
+  resolved "https://registry.yarnpkg.com/tail/-/tail-2.2.4.tgz#90dd4c5a174a3fa39dcb65a1df1950a4a0093a41"
+
 tapable@^0.1.8:
   version "0.1.10"
   resolved "https://registry.yarnpkg.com/tapable/-/tapable-0.1.10.tgz#29c35707c2b70e50d07482b5d202e8ed446dafd4"