Merge pull request #402 from OpenAPI-Qraft/fix/flaky-asyncapi-test

fix: flaky asyncapi tests

Author: radist2s

.github/actions/spelling/expect.txt

@@ -113,6 +113,7 @@ TSignal
 TValue
 TVariables
 typesafe
+unionfs
 unpkg
 Unpublishing
 URLTo

packages/asyncapi-plugin/package.json

@@ -45,7 +45,7 @@
     "@types/js-yaml": "^4.0.9",
     "@types/node": "^20.16.5",
     "eslint": "^9.39.1",
-    "memfs": "^4.11.1",
+    "memfs": "^4.56.10",
     "rimraf": "^6.1.2",
     "rollup": "~4.22.5",
     "rollup-plugin-rename-node-modules": "^1.3.1",

packages/asyncapi-typescript-plugin/package.json

@@ -48,7 +48,7 @@
     "@qraft/test-utils": "workspace:*",
     "@types/node": "^20.16.5",
     "eslint": "^9.39.1",
-    "memfs": "^4.11.1",
+    "memfs": "^4.56.10",
     "rimraf": "^6.1.2",
     "vitest": "^3.2.4"
   },

packages/asyncapi-typescript-plugin/src/plugin.test.ts

@@ -5,7 +5,7 @@ import { createFileHeader } from '@qraft/cli-utils';
 import { describe, expect, it, test } from 'vitest';
 import { asyncapiTypesFileNameOptionParser } from './plugin.js';
 
-describe.skip('asyncapi-typescript types generation', () => {
+describe('asyncapi-typescript types generation', () => {
   const asyncAPIDocumentFixturePath = createRequire(process.cwd()).resolve(
     '@openapi-qraft/test-fixtures/asyncapi.json'
   );

packages/asyncapi-typescript-plugin/vitest.config.ts

@@ -0,0 +1,12 @@
+import { defineConfig } from 'vitest/config';
+
+export default defineConfig({
+  test: {
+    // Increased timeout is required because AsyncAPI schema parsing with @asyncapi/parser
+    // is CPU-intensive and slow on CI runners (typically 2 vCPU GitHub Actions).
+    // The first few tests pay the full cost of parser initialization (~4-5s on CI),
+    // while subsequent tests benefit from internal caching (~600ms).
+    // Default Vitest timeout (5000ms) is too tight for CI, causing flaky failures.
+    testTimeout: 30_000,
+  },
+});

packages/openapi-plugin/package.json

@@ -49,7 +49,7 @@
     "@types/node": "^20.16.5",
     "@vitest/coverage-v8": "^3.2.4",
     "eslint": "^9.39.1",
-    "memfs": "^4.11.1",
+    "memfs": "^4.56.10",
     "rimraf": "^6.1.2",
     "typescript": "^5.6.2",
     "vitest": "^3.2.4"

packages/openapi-typescript-plugin/package.json

@@ -49,7 +49,7 @@
     "@qraft/test-utils": "workspace:*",
     "@types/node": "^20.16.5",
     "eslint": "^9.39.1",
-    "memfs": "^4.11.1",
+    "memfs": "^4.56.10",
     "rimraf": "^6.1.2",
     "vitest": "^3.2.4"
   },

packages/tanstack-query-react-plugin/package.json

@@ -52,7 +52,7 @@
     "@qraft/test-utils": "workspace:*",
     "camelcase": "^8.0.0",
     "eslint": "^9.39.1",
-    "memfs": "^4.11.1",
+    "memfs": "^4.56.10",
     "rimraf": "^6.1.2",
     "vitest": "^3.2.4"
   },

packages/test-utils/package.json

@@ -15,9 +15,10 @@
     "@openapi-qraft/eslint-config": "workspace:*",
     "@types/node": "^20.16.5",
     "eslint": "^9.39.1",
-    "memfs": "^4.11.1",
+    "memfs": "^4.56.10",
     "rimraf": "^6.1.2",
     "typescript": "^5.6.2",
+    "unionfs": "^4.6.0",
     "vitest": "^3.2.4"
   },
   "files": [

packages/test-utils/src/vitestFsMock.ts

@@ -1,23 +1,49 @@
 import { vi } from 'vitest';
 
-const createMemFs = vi.hoisted(
-  () => async (_fsOriginal: typeof import('node:fs')) => {
+const createUnionFs = vi.hoisted(
+  () => async (fsOriginal: typeof import('node:fs')) => {
     const { Volume, createFsFromVolume } = await import('memfs');
+    const { ufs } = await import('unionfs');
 
-    return createFsFromVolume(Volume.fromJSON({}));
+    const memFs = createFsFromVolume(Volume.fromJSON({}));
+    const union = ufs.use(memFs as never).use(fsOriginal as never);
+
+    if (union.promises && typeof fsOriginal.promises?.rm === 'function') {
+      const memFsPromises = (
+        memFs as {
+          promises?: { rm?: (path: string, options?: object) => Promise<void> };
+        }
+      ).promises;
+      (
+        union.promises as {
+          rm: (path: string, options?: object) => Promise<void>;
+        }
+      ).rm = async (path, options) => {
+        if (typeof memFsPromises?.rm === 'function') {
+          try {
+            return await memFsPromises.rm(path, options);
+          } catch {
+            return await fsOriginal.promises.rm(path, options);
+          }
+        }
+        return await fsOriginal.promises.rm(path, options);
+      };
+    }
+
+    return union;
   }
 );
 
 vi.mock('node:fs', async (importOriginal) => {
   return {
-    default: await createMemFs(
+    default: await createUnionFs(
       await importOriginal<typeof import('node:fs')>()
     ),
   };
 });
 
 vi.mock('fs', async (importOriginal) => {
   return {
-    default: await createMemFs(await importOriginal<typeof import('fs')>()),
+    default: await createUnionFs(await importOriginal<typeof import('fs')>()),
   };
 });