Function startCallbackServer

services/cloud-agent-next/test/e2e/callback-server.ts:67–153

(opts?: { host?: string })

}

export async function startCallbackServer(opts?: { host?: string }): Promise<CallbackServerHandle> {
  const host = opts?.host ?? '127.0.0.1';
  const received: CallbackRecord[] = [];
  type Listener = {
    predicate: (record: CallbackRecord) => boolean;
    resolve: (record: CallbackRecord | null) => void;
  };
  const listeners: Listener[] = [];

  const server: Server = createServer((req, res) => {
    readBody(req)
      .then(raw => {
        const contentType = req.headers['content-type'] ?? '';
        let body: unknown = raw;
        if (contentType.includes('application/json') && raw.length > 0) {
          try {
            body = JSON.parse(raw);
          } catch {
            // Keep raw body on parse failure — the driver may still want to inspect.
          }
        }
        const record: CallbackRecord = {
          method: req.method ?? 'GET',
          path: req.url ?? '/',
          headers: headersToObject(req.headers),
          body,
          receivedAt: Date.now(),
        };
        received.push(record);

        res.writeHead(200, { 'Content-Type': 'application/json' });
        res.end('{"ok":true}');

        for (let i = listeners.length - 1; i >= 0; i--) {
          const listener = listeners[i];
          if (listener && listener.predicate(record)) {
            listener.resolve(record);
            listeners.splice(i, 1);
          }
        }
      })
      .catch(err => {
        console.error('callback-server read error:', err);
        res.writeHead(500);
        res.end();
      });
  });

  await new Promise<void>((resolve, reject) => {
    server.once('error', reject);
    server.listen(0, host, () => resolve());
  });

  const address = server.address() as AddressInfo;
  const port = address.port;
  const url = `http://${host}:${port}`;
  const callbackUrl = `${url}/callback`;