FIXUP

Author: vio

packages/cli-utils/__mocks__/fs.ts

@@ -1 +1,3 @@
-export { fs } from 'memfs';
+import { vol } from 'memfs';
+
+export const { createReadStream } = vol;

packages/cli-utils/__mocks__/fs/promises.ts

@@ -1,3 +1,3 @@
-import { fs } from 'memfs';
+import { vol } from 'memfs';
 
-export default fs.promises;
+export const { stat, writeFile } = vol.promises;

packages/cli-utils/src/__tests__/reports.test.ts

@@ -24,7 +24,7 @@ const SOURCE_BASELINE = {
   ],
 };
 
-describe('generateAssets', () => {
+describe('generateReports', () => {
   test('should generate reports with default options', async () => {
     const reports = await generateReports(SOURCE_CURRENT, {});
 

packages/cli-utils/src/fs.ts

@@ -1,17 +1,28 @@
-import { createReadStream, promises } from 'fs';
+import { createReadStream } from 'fs';
+import { writeFile, stat } from 'fs/promises';
 import { parser } from 'stream-json';
 import { chain } from 'stream-chain';
 import Asm from 'stream-json/Assembler';
 
-export const readJSONStream = <T = unknown>(filepath: string): Promise<T> => {
-  const pipeline = chain([createReadStream(filepath), parser()]);
+export const readJSONStream = async <T = unknown>(filepath: string): Promise<T> => {
+  // Check if the file exists and throw error before creating a stream
+  await stat(filepath);
+
+  const readStream = createReadStream(filepath);
+  const pipeline = chain([readStream, parser()]);
   const asm = Asm.connectTo(pipeline);
 
-  return new Promise((fulfill) => {
-    asm.on('done', (data) => fulfill(data.current));
+  return new Promise((resolve, reject) => {
+    asm.on('done', (data) => {
+      if (data.current) {
+        resolve(data.current);
+      } else {
+        reject(new Error('Invalid JSON file'));
+      }
+    });
   });
 };
 
 export async function writeJSON(filepath: string, data: Record<string, unknown>): Promise<void> {
-  return promises.writeFile(filepath, JSON.stringify(data));
+  return writeFile(filepath, JSON.stringify(data));
 }