feat(node-fs): writeFile under asyncQueue

Author: alimd

packages/node-fs/src/logger.ts packages/node-fs/src/common.ts

@@ -1,5 +1,8 @@
+import {AsyncQueue} from '@alwatr/async-queue';
 import {definePackage} from '@alwatr/logger';
 
 import type {} from '@alwatr/nano-build';
 
 export const logger = definePackage('@alwatr/node-fs', __package_version__);
+
+export const asyncQueue = new AsyncQueue();

packages/node-fs/src/json.ts

@@ -1,4 +1,4 @@
-import {logger} from './logger';
+import {logger} from './common';
 
 /**
  * Parse json string.

packages/node-fs/src/make-file.ts

@@ -1,6 +1,6 @@
 import {open} from 'node:fs/promises';
 
-import {logger} from './logger.js';
+import {logger} from './common';
 
 /**
  * Make empty file.

packages/node-fs/src/read-file.ts

@@ -3,8 +3,8 @@ import {readFile as readFile_} from 'node:fs/promises';
 
 import {flatString} from '@alwatr/flat-string';
 
+import {logger} from './common';
 import {parseJson} from './json';
-import {logger} from './logger';
 
 import type {MaybePromise} from '@alwatr/type-helper';
 

packages/node-fs/src/write-file.ts

@@ -2,7 +2,7 @@ import {writeFileSync as writeFileSync_, existsSync, mkdirSync, renameSync} from
 import {mkdir, rename, writeFile as writeFile_} from 'node:fs/promises';
 import {dirname} from 'node:path';
 
-import {logger} from './logger';
+import {asyncQueue, logger} from './common';
 
 /**
  * Enhanced write file (Synchronous).
@@ -57,26 +57,28 @@ export function writeFileSync(path: string, content: string): void {
  * writeFile('./file.txt', 'Hello World!');
  * ```
  */
-export async function writeFile(path: string, content: string): Promise<void> {
+export function writeFile(path: string, content: string): Promise<void> {
   logger.logMethodArgs?.('writeFile', '...' + path.slice(-32));
-  try {
-    logger.logOther?.('writeFile start', '...' + path.slice(-32));
-    const pathExists = existsSync(path);
-    if (!pathExists) {
-      const dir = dirname(path);
-      if (!existsSync(dir)) {
-        await mkdir(dir, {recursive: true});
+  return asyncQueue.push(path, async () => {
+    try {
+      logger.logOther?.('writeFile start', '...' + path.slice(-32));
+      const pathExists = existsSync(path);
+      if (!pathExists) {
+        const dir = dirname(path);
+        if (!existsSync(dir)) {
+          await mkdir(dir, {recursive: true});
+        }
+      }
+      await writeFile_(path + '.tmp', content, {encoding: 'utf-8', flag: 'w'});
+      if (pathExists) {
+        await rename(path, path + '.bak');
       }
+      await rename(path + '.tmp', path);
+      logger.logOther?.('writeFile success', '...' + path.slice(-32));
     }
-    await writeFile_(path + '.tmp', content, {encoding: 'utf-8', flag: 'w'});
-    if (pathExists) {
-      await rename(path, path + '.bak');
+    catch (err) {
+      logger.error('writeFile', 'write_file_failed', {path}, err);
+      throw new Error('write_file_failed', {cause: (err as Error).cause});
     }
-    await rename(path + '.tmp', path);
-    logger.logOther?.('writeFile success', '...' + path.slice(-32));
-  }
-  catch (err) {
-    logger.error('writeFile', 'write_file_failed', {path}, err);
-    throw new Error('write_file_failed', {cause: (err as Error).cause});
-  }
+  });
 }

packages/node-fs/src/write-json.ts

@@ -1,8 +1,8 @@
 import {flatString} from '@alwatr/flat-string';
 
+import {logger} from './common';
 import {jsonStringify} from './json';
-import {logger} from './logger';
-import {writeFile, writeFileSync} from './write-file.js';
+import {writeFile, writeFileSync} from './write-file';
 
 import type {MaybePromise} from '@alwatr/type-helper';