Function waitForStdoutLine

src/__tests__/daemon-entrypoint.test.ts:23–60

(
  stream: NodeJS.ReadableStream | null,
  pattern: RegExp,
  timeoutMs: number,
)

};

function waitForStdoutLine(
  stream: NodeJS.ReadableStream | null,
  pattern: RegExp,
  timeoutMs: number,
): Promise<string> {
  if (!stream) {
    return Promise.reject(new Error('Expected daemon stdout stream.'));
  }
  stream.setEncoding('utf8');
  let buffer = '';
  return new Promise((resolve, reject) => {
    const timeout = setTimeout(() => {
      cleanup();
      reject(new Error(`Timed out waiting for daemon stdout line matching ${pattern}.`));
    }, timeoutMs);
    const onData = (chunk: string) => {
      buffer += chunk;
      const line = buffer
        .split('\n')
        .map((entry) => entry.trim())
        .find((entry) => pattern.test(entry));
      if (!line) return;
      cleanup();
      resolve(line);
    };
    const onError = (error: unknown) => {
      cleanup();
      reject(error instanceof Error ? error : new Error(String(error)));
    };
    const cleanup = () => {
      clearTimeout(timeout);
      stream.off('data', onData);
      stream.off('error', onError);
    };
    stream.on('data', onData);
    stream.on('error', onError);
  });
}

test('daemon runtime starts HTTP transport in-process and shuts down cleanly', async () => {
  const stateDir = fs.mkdtempSync(path.join(os.tmpdir(), 'agent-device-daemon-runtime-'));