feat(scripts): salvage single-mode, IPC readiness, framework resolver and esbuild plugins

tools/scripts/package.json

@@ -31,7 +31,10 @@
     "./baseCommand": "./src/baseCommand.ts",
     "./commands/start": "./src/commands/start.ts",
     "./commands/stop": "./src/commands/stop.ts",
+    "./esm-polyfill": "./src/esm-polyfill.ts",
+    "./file-url-resolver": "./src/file-url-resolver.ts",
     "./helper": "./src/helper.ts",
+    "./resolve-framework-entry": "./src/resolve-framework-entry.ts",
     "./types": "./src/types.ts",
     "./package.json": "./package.json"
   },
@@ -42,7 +45,10 @@
       "./baseCommand": "./dist/baseCommand.js",
       "./commands/start": "./dist/commands/start.js",
       "./commands/stop": "./dist/commands/stop.js",
+      "./esm-polyfill": "./dist/esm-polyfill.js",
+      "./file-url-resolver": "./dist/file-url-resolver.js",
       "./helper": "./dist/helper.js",
+      "./resolve-framework-entry": "./dist/resolve-framework-entry.js",
       "./types": "./dist/types.js",
       "./package.json": "./package.json"
     }
@@ -56,9 +62,11 @@
   "dependencies": {
     "@eggjs/utils": "workspace:*",
     "@oclif/core": "catalog:",
+    "esbuild": "catalog:",
     "node-homedir": "catalog:",
     "runscript": "catalog:",
     "source-map-support": "catalog:",
+    "tsx": "catalog:",
     "utility": "catalog:"
   },
   "devDependencies": {

tools/scripts/scripts/start-single.cjs

@@ -0,0 +1,83 @@
+const http = require('node:http');
+const { debuglog } = require('node:util');
+
+const { importModule } = require('@eggjs/utils');
+
+const debug = debuglog('egg/scripts/start-single/cjs');
+
+async function main() {
+  debug('argv: %o', process.argv);
+  const options = JSON.parse(process.argv[2]);
+  debug('start single options: %o', options);
+  const exports = await importModule(options.framework);
+  let startEgg = exports.start ?? exports.startEgg;
+  if (typeof startEgg !== 'function') {
+    startEgg = exports.default?.start ?? exports.default?.startEgg;
+  }
+  if (typeof startEgg !== 'function') {
+    throw new Error(`Cannot find start/startEgg function from framework: ${options.framework}`);
+  }
+  const app = await startEgg({
+    baseDir: options.baseDir,
+    framework: options.framework,
+    env: options.env,
+    mode: 'single',
+  });
+
+  const port = options.port ?? 7001;
+  const server = http.createServer(app.callback());
+  app.emit('server', server);
+
+  await new Promise((resolve, reject) => {
+    server.listen(port, () => {
+      resolve(undefined);
+    });
+    server.once('error', reject);
+  });
+
+  const address = server.address();
+  const url = typeof address === 'string' ? address : `http://127.0.0.1:${address.port}`;
+
+  debug('server started on %s', url);
+
+  // notify parent process (daemon mode)
+  if (process.send) {
+    process.send({
+      action: 'egg-ready',
+      data: { address: url, port: address.port ?? port },
+    });
+  }
+
+  // graceful shutdown
+  const shutdown = async (signal) => {
+    debug('receive signal %s, closing server', signal);
+    server.close(() => {
+      debug('server closed');
+      if (typeof app.close === 'function') {
+        app
+          .close()
+          .then(() => {
+            process.exit(0);
+          })
+          .catch(() => {
+            process.exit(1);
+          });
+      } else {
+        process.exit(0);
+      }
+    });
+    // force exit after timeout
+    setTimeout(() => {
+      process.exit(1);
+    }, 10000).unref();
+  };
+
+  process.once('SIGTERM', () => shutdown('SIGTERM'));
+  process.once('SIGINT', () => shutdown('SIGINT'));
+  process.once('SIGQUIT', () => shutdown('SIGQUIT'));
+}
+
+main().catch((err) => {
+  console.error(err);
+  process.exit(1);
+});

tools/scripts/scripts/start-single.mjs

@@ -0,0 +1,80 @@
+import http from 'node:http';
+import { debuglog } from 'node:util';
+
+import { importModule } from '@eggjs/utils';
+
+const debug = debuglog('egg/scripts/start-single/esm');
+
+async function main() {
+  debug('argv: %o', process.argv);
+  const options = JSON.parse(process.argv[2]);
+  debug('start single options: %o', options);
+  const framework = await importModule(options.framework);
+  const startEgg = framework.start ?? framework.startEgg;
+  if (typeof startEgg !== 'function') {
+    throw new Error(`Cannot find start/startEgg function from framework: ${options.framework}`);
+  }
+  const app = await startEgg({
+    baseDir: options.baseDir,
+    framework: options.framework,
+    env: options.env,
+    mode: 'single',
+  });
+
+  const port = options.port ?? 7001;
+  const server = http.createServer(app.callback());
+  app.emit('server', server);
+
+  await new Promise((resolve, reject) => {
+    server.listen(port, () => {
+      resolve(undefined);
+    });
+    server.once('error', reject);
+  });
+
+  const address = server.address();
+  const url = typeof address === 'string' ? address : `http://127.0.0.1:${address.port}`;
+
+  debug('server started on %s', url);
+
+  // notify parent process (daemon mode)
+  if (process.send) {
+    process.send({
+      action: 'egg-ready',
+      data: { address: url, port: address.port ?? port },
+    });
+  }
+
+  // graceful shutdown
+  const shutdown = async (signal) => {
+    debug('receive signal %s, closing server', signal);
+    server.close(() => {
+      debug('server closed');
+      if (typeof app.close === 'function') {
+        app
+          .close()
+          .then(() => {
+            process.exit(0);
+          })
+          .catch(() => {
+            process.exit(1);
+          });
+      } else {
+        process.exit(0);
+      }
+    });
+    // force exit after timeout
+    setTimeout(() => {
+      process.exit(1);
+    }, 10000).unref();
+  };
+
+  process.once('SIGTERM', () => shutdown('SIGTERM'));
+  process.once('SIGINT', () => shutdown('SIGINT'));
+  process.once('SIGQUIT', () => shutdown('SIGQUIT'));
+}
+
+main().catch((err) => {
+  console.error(err);
+  process.exit(1);
+});