package.json

@@ -1,6 +1,6 @@
 {
    "name": "@hibas123/nodelogging",
-   "version": "3.0.6",
+   "version": "3.0.4",
    "description": "",
    "main": "out/index.js",
    "types": "out/index.d.ts",
@@ -32,7 +32,7 @@
       "typescript": "^4.2.4"
    },
    "dependencies": {
-      "@hibas123/logging": "^3.0.6",
+      "@hibas123/logging": "^3.0.3",
       "@hibas123/utils": "^2.2.18"
    }
 }

src/filewriter.ts

@@ -7,7 +7,12 @@ const MAX_FILE_SIZE = 500000000;
 
 export class LoggingFiles implements Adapter {
    file: Files;
-   constructor(private filename: string, private maxFileSize = MAX_FILE_SIZE) {}
+   constructor(
+      private filename: string,
+      private error = false,
+      private maxFileSize = MAX_FILE_SIZE,
+      private noPrefix = false
+   ) {}
 
    init() {
       if (!this.file) {
@@ -33,21 +38,6 @@ export class LoggingFiles implements Adapter {
 
 //TODO: Optimise write path
 
-const Debounce = (callback: () => void, iv = 500) => {
-   let to: any;
-
-   return {
-      trigger: () => {
-         if (!to) {
-            to = setTimeout(() => {
-               to = undefined;
-               callback();
-            }, iv);
-         }
-      },
-   };
-};
-
 export class Files {
    private open = 0;
 
@@ -67,22 +57,21 @@ export class Files {
    private size: number = 0;
    private stream: fs.WriteStream = undefined;
    private lock = new Lock();
-   private debounce = Debounce(() => this.checkQueue);
 
-   #initialized = false;
+   private $initialized = false;
 
    public get initlialized() {
-      return this.#initialized;
+      return this.$initialized;
    }
 
    private constructor(private file: string) {}
 
    public async init(maxFileSize: number) {
-      if (this.#initialized) return;
+      if (this.$initialized) return;
       let lock = await this.lock.getLock();
       this.maxFileSize == maxFileSize;
       await this.initializeFile();
-      this.#initialized = true;
+      this.$initialized = true;
       lock.release();
       this.checkQueue();
    }
@@ -115,7 +104,7 @@ export class Files {
          this.size = size;
       } catch (e) {
          console.log(e);
-         //TODO: is this the right behavior?
+         //ToDo is this the right behavior?
          process.exit(1);
       }
    }
@@ -140,7 +129,6 @@ export class Files {
          Files.files.delete(this.file);
       }
    }
-
    public flush(sync: boolean) {
       if (sync) {
          // if sync flush, the process most likely is in failstate, so checkQueue stopped its work.
@@ -177,7 +165,7 @@ export class Files {
 
    public write(data: Buffer) {
       this.queue.push(data);
-      this.debounce.trigger();
+      this.checkQueue();
    }
 
    public dispose() {}