tests: start adding quic test server utilities

Author: jasnell

deps/ngtcp2/ngtcp2.gyp

@@ -268,6 +268,11 @@
         'EV_STANDALONE=1',
       ],
       'conditions': [
+        ['OS==aix"', {
+          # AIX does not support some of the networking features used in
+          # the test server.
+          'type': 'none',  # Disable as executable on AIX
+        }],
         ['OS=="mac"', {
           'defines': [
             '__APPLE_USE_RFC_3542',
@@ -335,6 +340,11 @@
         'EV_STANDALONE=1',
       ],
       'conditions': [
+        ['OS=="aix"', {
+          # AIX does not support some of the networking features used in
+          # the test client.
+          'type': 'none',  # Disable as executable on AIX
+        }],
         ['OS=="mac"', {
           'defines': [
             '__APPLE_USE_RFC_3542',

test/common/quic/test-server.mjs

@@ -0,0 +1,66 @@
+import { resolve } from 'node:path';
+import { spawn } from 'node:child_process';
+
+export default class QuicTestServer {
+  #pathToServer;
+  #runningProcess;
+
+  constructor() {
+    this.#pathToServer = resolve(process.execPath, '../ngtcp2_test_server');
+    console.log(this.#pathToServer);
+  }
+
+  help(options = { stdio: 'inherit' }) {
+    const { promise, resolve, reject } = Promise.withResolvers();
+    const proc = spawn(this.#pathToServer, ['--help'], options);
+    proc.on('error', reject);
+    proc.on('exit', (code, signal) => {
+      if (code === 0) {
+        resolve();
+      } else {
+        reject(new Error(`Process exited with code ${code} and signal ${signal}`));
+      }
+    });
+    return promise;
+  }
+
+  run(address, port, keyFile, certFile, options = { stdio: 'inherit' }) {
+    const { promise, resolve, reject } = Promise.withResolvers();
+    if (this.#runningProcess) {
+      reject(new Error('Server is already running'));
+      return promise;
+    }
+    const args = [
+      address,
+      port,
+      keyFile,
+      certFile,
+    ];
+    this.#runningProcess = spawn(this.#pathToServer, args, options);
+    this.#runningProcess.on('error', (err) => {
+      this.#runningProcess = undefined;
+      reject(err);
+    });
+    this.#runningProcess.on('exit', (code, signal) => {
+      this.#runningProcess = undefined;
+      if (code === 0) {
+        resolve();
+      } else {
+        if (code === null && signal === 'SIGTERM') {
+          // Normal termination due to stop() being called.
+          resolve();
+          return;
+        }
+        reject(new Error(`Process exited with code ${code} and signal ${signal}`));
+      }
+    });
+    return promise;
+  }
+
+  stop() {
+    if (this.#runningProcess) {
+      this.#runningProcess.kill();
+      this.#runningProcess = undefined;
+    }
+  }
+};

test/parallel/test-quic-test-server.mjs

@@ -0,0 +1,27 @@
+// Flags: --experimental-quic
+import { hasQuic, isAIX, skip } from '../common/index.mjs';
+
+if (!hasQuic) {
+  skip('QUIC support is not enabled');
+}
+if (isAIX) {
+  skip('QUIC third-party tests are disabled on AIX');
+}
+
+const { default: QuicTestServer } = await import('../common/quic/test-server.mjs');
+const fixtures = await import('../common/fixtures.mjs');
+
+const server = new QuicTestServer();
+const fixturesPath = fixtures.path();
+
+// If this completes without throwing, the test passes.
+await server.help({ stdio: 'ignore' });
+
+setTimeout(() => {
+  server.stop();
+}, 100);
+
+await server.run('localhost', '12345',
+                 `${fixturesPath}/keys/agent1-key.pem`,
+                 `${fixturesPath}/keys/agent1-cert.pem`,
+                 { stdio: 'inherit' });