Fixed initial lines amount for local:file sources (#39)

mishankov · Aug 8, 2022 · b4fcb5b · b4fcb5b
1 parent d5967d1
commit b4fcb5b
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 59 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -50,7 +50,7 @@
     "express-rate-limit": "^6.2.0",
     "open": "^8.4.0",
     "ssh2": "^1.5.0",
-    "tail-file": "^1.4.15",
+    "tail": "^2.2.4",
     "ws": "^8.4.2"
   }
 }
diff --git a/src/server/models/sources/local.ts b/src/server/models/sources/local.ts
@@ -1,4 +1,4 @@
-const Tail = require("tail-file");
+const Tail = require("tail").Tail;
 const { spawn, ChildProcess } = require("child_process");
 
 import type { SourceConfig } from "../config";
@@ -13,7 +13,7 @@ class LocalFileSource extends Source {
     newLineCallback: CallableFunction
   ) {
     super(config, initialLinesAmount, newLineCallback);
-    this.tail = new Tail(this.config.path, { force: true });
+    this.tail = new Tail(this.config.path, { nLines: initialLinesAmount });
   }
 
   configConnection() {
@@ -27,11 +27,11 @@ class LocalFileSource extends Source {
   }
 
   startReading() {
-    this.tail.start();
+    this.tail.watch();
   }
 
   closeConnection() {
-    this.tail.stop();
+    this.tail.unwatch();
   }
 }