WIP: convert to local runner

Author: wesleytodd

package-lock.json

@@ -0,0 +1,122 @@
+import { dirname } from 'node:path';
+import { execFile } from 'node:child_process';
+import { fileURLToPath } from 'node:url';
+
+function runInstall (opts) {
+  const { cwd, signal } = opts;
+  return new Promise((resolve, reject) => {
+    // TODO: apply overerides
+    const cp = execFile(process.execPath, ['--run', 'setup'], {
+      cwd
+    });
+
+    signal?.addEventListener('abort', () => {
+      cp.kill('SIGINT');
+      reject(new Error('aborted'));
+    });
+    cp.on('error', reject);
+    cp.on('close', resolve);
+    cp.stdout.on('data', (d) => {
+      process.stdout.write(d);
+    });
+    cp.stderr.on('data', (d) => {
+      process.stderr.write(d);
+    });
+  });
+}
+
+export function startServer (opts = {}) {
+  return new Promise((resolve, reject) => {
+    const test = fileURLToPath(import.meta.resolve(opts.test));
+    const testDir = dirname(test);
+    return runInstall({
+      cwd: testDir,
+      signal: opts.signal
+    }).then(() => {
+      const cp = execFile(process.execPath, [ test ], {
+        cwd: opts.cwd
+      });
+
+      const server = {
+        metadata: {
+          url: new URL('http://localhost:3000'),
+        },
+        status: 'starting',
+        close: () => {
+          return new Promise((closeResolve) => {
+            cp.on('exit', () => {
+              closeResolve();
+            });
+            cp.kill('SIGINT');
+          });
+        },
+        result: async () => {
+          return { };
+        }
+      };
+
+      opts?.signal.addEventListener('abort', () => {
+        server.status = 'aborted';
+        cp.kill('SIGINT');
+        reject(new Error('aborted'));
+      });
+      cp.on('error', reject);
+      cp.stdout.on('data', (d) => {
+        process.stdout.write(d);
+        if (server.status === 'starting' && d.toString('utf8').includes("Running")) {
+          server.status = 'started';
+          resolve(server);
+        }
+      });
+      cp.stderr.on('data', (d) => {
+        process.stderr.write(d);
+      });
+    }, reject);
+  });
+}
+
+export async function startClient (_opts = {}, server) {
+  const opts = {
+    ..._opts
+  };
+  if (opts?.signal.aborted) {
+    return;
+  }
+
+
+  return {
+    metadata: {},
+    close: async () => {
+
+    },
+    results: () => {
+      return {};
+    }
+  };
+}
+
+export default async function runner (_opts = {}) {
+  // Start up the server, then the client
+  const opts = {
+    ..._opts
+  };
+
+  console.warn('warning: many options ignored with local runner: repo, repoRef, node');
+
+  const server = await startServer(opts);
+  // const client = await startClient(opts, server); 
+
+  // Wait for the client to finish, then the server
+  // const clientResults = await client.results();
+  const serverResults = await server.results();
+
+  // await client.close();
+  await server.close();
+
+  return {
+    serverMetadata: server.metadata,
+    // clientMetadata: client.metadata,
+    serverResults,
+    // clientResults
+  };
+}

packages/runner-local/index.mjs

@@ -0,0 +1,13 @@
+{
+  "name": "@expressjs/perf-runner-local",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.mjs",
+  "devDependencies": {},
+  "scripts": {
+    "test": "echo \"Error: no test specified\" && exit 1"
+  },
+  "keywords": [],
+  "author": "",
+  "license": "ISC"
+}