feat(AtomicFileAdapter): Add support for fsync

Belphemur · Aug 1, 2022 · 4a51239 · 4a51239
1 parent 002a72a
commit 4a51239
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/adapter/file/AtomicFileAdapter.ts b/src/adapter/file/AtomicFileAdapter.ts
@@ -3,9 +3,11 @@ import {readFile, writeFile} from "atomically";
 
 export class AtomicFileAdapter implements IFileAdapter<string> {
     public readonly filename: string;
+    private fsync: boolean;
 
-    constructor(filename: string) {
+    constructor(filename: string, fsync: boolean) {
         this.filename = filename;
+        this.fsync = fsync;
     }
 
     async readAsync(): Promise<string | null> {
@@ -23,7 +25,8 @@ export class AtomicFileAdapter implements IFileAdapter<string> {
 
     writeAsync(data: string): Promise<void> {
         return writeFile(this.filename, data, {
-            encoding: 'utf-8'
+            encoding: 'utf-8',
+            fsync: this.fsync
         })
     }
 }