Fix saving files PromiseQueue

Author: Yadro

src/base/repositories/AbstractFileRepository.ts

@@ -1,15 +1,19 @@
+import PromiseQueue from '../../helpers/PromiseQueueHellper';
+
 const fs = require('fs');
 const path = require('path');
 
 import FsHelper from '../../helpers/FsHelper';
 
-const APP_FOLDER = 'YadroTimeTracker';
+const APP_FOLDER = 'YadroTimeTracker_test';
 const PROFILE_FOLDER = 'profile1';
 
 export default abstract class AbstractFileRepository<T = any> {
   folderWithProfile: string = 'profile1';
   fileName: string = 'defaultFileName.json';
 
+  writeFileQueue = new PromiseQueue();
+
   private static get appDataFolder() {
     return process.env.APPDATA || '';
   }
@@ -37,6 +41,13 @@ export default abstract class AbstractFileRepository<T = any> {
 
   public save(data: T) {
     FsHelper.mkdirIfNotExists(AbstractFileRepository.profileFolder);
-    return FsHelper.writeFile(this.filePath, data);
+    this.writeFileQueue.add(() =>
+      FsHelper.writeFile(this.filePath, data).catch(() => {
+        console.error(
+          `AbstractFileRepository: can't save file ${this.fileName} ${this.filePath}`
+        );
+      })
+    );
+    this.writeFileQueue.run();
   }
 }

src/helpers/PromiseQueueHellper.ts

@@ -0,0 +1,46 @@
+interface PromiseQueueItem {
+  execute: () => Promise<any>;
+  resolve: (value: any) => void;
+  reject: <T extends Error>(err: T) => void;
+}
+
+export default class PromiseQueue {
+  private queue: PromiseQueueItem[] = [];
+  private pendingPromise: boolean = false;
+
+  add(promise: () => Promise<any>) {
+    return new Promise((resolve, reject) => {
+      this.queue.push({
+        execute: promise,
+        resolve,
+        reject,
+      });
+    });
+  }
+
+  run() {
+    if (this.pendingPromise) {
+      return;
+    }
+
+    const item = this.queue.shift();
+
+    if (!item) {
+      return;
+    }
+
+    this.pendingPromise = true;
+    item
+      ?.execute()
+      .then((value) => {
+        item.resolve(value);
+      })
+      .catch((err) => {
+        item?.reject(err);
+      })
+      .finally(() => {
+        this.pendingPromise = false;
+        this.run();
+      });
+  }
+}

src/modules/tasks/TaskStore.ts

@@ -183,7 +183,7 @@ export default class TaskStore {
   }
 
   private setupReminder(task?: TaskModel) {
-    if (this.interval) {
+    if (this.interval !== undefined) {
       clearInterval(this.interval);
     }
     if (task) {