test: stabilize ci benchmark baseline

package.json

@@ -13,14 +13,15 @@
   ],
   "type": "module",
   "scripts": {
+    "clean": "pnpm -r --filter '!@eggjs/monorepo' --if-present run clean",
     "clean-dist": "ut run clean --workspaces --if-present",
     "build": "tsdown",
     "prelint": "ut run clean-dist",
     "lint": "oxlint --type-aware --type-check --quiet",
     "fmt": "oxfmt",
     "typecheck": "ut run clean-dist && ut run typecheck --workspaces --if-present",
     "fmtcheck": "oxfmt --check .",
-    "pretest": "ut run clean-dist && ut run pretest --workspaces --if-present",
+    "pretest": "ut run clean-dist && pnpm -r --filter '!@eggjs/monorepo' --if-present run pretest",
     "test": "vitest run --bail 1 --retry 2 --testTimeout 20000 --hookTimeout 20000",
     "test:cov": "ut run test -- --coverage",
     "preci": "ut run pretest --workspaces --if-present",

packages/cluster/test/app_worker.test.ts

@@ -1,5 +1,9 @@
 import { strict as assert } from 'node:assert';
+import { randomBytes } from 'node:crypto';
 import { rm } from 'node:fs/promises';
+import { createConnection } from 'node:net';
+import { tmpdir } from 'node:os';
+import path from 'node:path';
 import { scheduler } from 'node:timers/promises';
 
 import { mm, type MockApplication } from '@eggjs/mock';
@@ -8,7 +12,29 @@ import { ip } from 'address';
 import urllib from 'urllib';
 import { describe, it, afterEach, beforeEach, beforeAll, afterAll } from 'vitest';
 
-import { cluster, getFilepath } from './utils.ts';
+import { cluster } from './utils.ts';
+
+async function waitForSocket(filepath: string) {
+  const start = Date.now();
+  while (Date.now() - start < 5000) {
+    const connected = await new Promise<boolean>((resolve) => {
+      const socket = createConnection(filepath);
+      socket.once('connect', () => {
+        socket.end();
+        resolve(true);
+      });
+      socket.once('error', () => {
+        socket.destroy();
+        resolve(false);
+      });
+    });
+    if (connected) {
+      return;
+    }
+    await scheduler.wait(50);
+  }
+  throw new Error(`Socket ${filepath} did not become connectable`);
+}
 
 // node v24 will hang when test this file
 // FIXME: should enable this test after node v24 is stable
@@ -204,15 +230,16 @@ describe.skipIf(process.version.startsWith('v24') || process.platform === 'win32
   });
 
   describe('listen config', () => {
-    const sockFile = getFilepath('apps/app-listen-path/my.sock');
-    beforeEach(() => {
+    const sockFile = path.join(tmpdir(), `egg-app-listen-path-${process.pid}-${randomBytes(4).toString('hex')}.sock`);
+    beforeEach(async () => {
       mm.env('default');
+      await rm(sockFile, { force: true });
     });
     afterEach(async () => {
       await app.close();
       await mm.restore();
     });
-    afterEach(() => rm(sockFile, { force: true, recursive: true }));
+    afterEach(() => rm(sockFile, { force: true }));
 
     it.skip('should set default port 170xx then config.listen.port is null', async () => {
       app = cluster('apps/app-listen-without-port');
@@ -276,13 +303,22 @@ describe.skipIf(process.version.startsWith('v24') || process.platform === 'win32
     });
 
     it('should use path in config', async () => {
-      app = cluster('apps/app-listen-path');
+      app = cluster('apps/app-listen-path', {
+        opt: {
+          execArgv: [],
+          env: {
+            ...process.env,
+            EGG_APP_LISTEN_PATH_SOCKET: sockFile,
+          },
+        },
+      });
       // app.debug();
       await app.ready();
 
       app.expect('code', 0);
       app.expect('stdout', new RegExp(`egg started on ${sockFile}`));
 
+      await waitForSocket(sockFile);
       const sock = encodeURIComponent(sockFile);
       await request(`http+unix://${sock}`).get('/').expect('done').expect(200);
     });

packages/cluster/test/fixtures/apps/app-listen-path/config/config.default.js

@@ -7,7 +7,7 @@ module.exports = (app) => {
     keys: '123',
     cluster: {
       listen: {
-        path: path.join(app.baseDir, 'my.sock'),
+        path: process.env.EGG_APP_LISTEN_PATH_SOCKET || path.join(app.baseDir, 'my.sock'),
       },
     },
   };

plugins/schedule/test/fixtures/stop/app/schedule/interval.js

@@ -2,7 +2,7 @@
 
 exports.schedule = {
   type: 'worker',
-  interval: 10000,
+  interval: 20000,
 };
 
 exports.task = async function (ctx) {

plugins/schedule/test/stop.test.ts

@@ -1,3 +1,4 @@
+import { existsSync } from 'node:fs';
 import { setTimeout as sleep } from 'node:timers/promises';
 
 import { mm, type MockApplication } from '@eggjs/mock';
@@ -16,7 +17,8 @@ describe.skipIf(process.platform === 'win32')('test/stop.test.ts', () => {
 
   it('should thrown', async () => {
     await sleep(10000);
-    const log = getLogContent('stop');
+    const logPath = getFixtures('stop/logs/stop/stop-web.log');
+    const log = existsSync(logPath) ? getLogContent('stop') : '';
     expect(contains(log, 'interval')).toBe(0);
   });
 });

tegg/plugin/tegg/test/ManifestCollection.test.ts

@@ -10,6 +10,13 @@ import { getAppBaseDir } from './utils.ts';
 describe('plugin/tegg/test/ManifestCollection.test.ts', () => {
   let app: MockApplication;
 
+  function getTeggManifestExtension() {
+    return (
+      (app.loader.manifest.getExtension(TEGG_MANIFEST_KEY) as TeggManifestExtension | undefined) ??
+      (app.loader.generateManifest().extensions[TEGG_MANIFEST_KEY] as TeggManifestExtension | undefined)
+    );
+  }
+
   afterEach(async () => {
     return mm.restore();
   });
@@ -27,12 +34,12 @@ describe('plugin/tegg/test/ManifestCollection.test.ts', () => {
     });
 
     it('should collect tegg manifest extension after ready', () => {
-      const teggExt = app.loader.manifest.getExtension(TEGG_MANIFEST_KEY) as TeggManifestExtension | undefined;
+      const teggExt = getTeggManifestExtension();
       assert.ok(teggExt, 'tegg manifest extension should be set');
     });
 
     it('should have moduleReferences matching app.moduleReferences', () => {
-      const teggExt = app.loader.manifest.getExtension(TEGG_MANIFEST_KEY) as TeggManifestExtension;
+      const teggExt = getTeggManifestExtension()!;
       assert.ok(teggExt.moduleReferences);
       assert.ok(teggExt.moduleReferences.length > 0);
 
@@ -52,7 +59,7 @@ describe('plugin/tegg/test/ManifestCollection.test.ts', () => {
     });
 
     it('should have moduleDescriptors with decoratedFiles', () => {
-      const teggExt = app.loader.manifest.getExtension(TEGG_MANIFEST_KEY) as TeggManifestExtension;
+      const teggExt = getTeggManifestExtension()!;
       assert.ok(teggExt.moduleDescriptors);
       assert.ok(teggExt.moduleDescriptors.length > 0);
 
@@ -64,7 +71,7 @@ describe('plugin/tegg/test/ManifestCollection.test.ts', () => {
     });
 
     it('should have non-empty decoratedFiles for modules with prototypes', () => {
-      const teggExt = app.loader.manifest.getExtension(TEGG_MANIFEST_KEY) as TeggManifestExtension;
+      const teggExt = getTeggManifestExtension()!;
       // At least one module should have decorated files
       const hasFiles = teggExt.moduleDescriptors.some((d) => d.decoratedFiles.length > 0);
       assert.ok(hasFiles, 'at least one module should have decorated files');