Function withTimeoutAndAbort

services/cloud-agent-next/wrapper/src/utils.ts:300–324

(
  promise: Promise<T>,
  opts: TimeoutAbortOptions
)

    resetInactivityTimer();
    if (opts?.hardTimeoutMs !== undefined) {
      hardTimeoutTimer = setTimeout(() => terminate('hard_timeout'), opts.hardTimeoutMs);
    }

    if (opts?.rawOutput) {
      const captureBytes = (stream: ProcessOutputStream, bytes: Buffer): void => {
        const available = Math.max(0, maxOutputBytes - rawLengths[stream]);
        const retained = Math.min(available, bytes.length);
        if (retained > 0) {
          rawChunks[stream].push(Buffer.from(bytes.subarray(0, retained)));
          rawLengths[stream] += retained;
        }
        if (retained < bytes.length) {
          if (stream === 'stdout') stdoutTruncated = true;
          else stderrTruncated = true;
        }
        resetInactivityTimer();
      };
      stdoutStream.on('data', (output: Buffer) => captureBytes('stdout', output));
      stderrStream.on('data', (output: Buffer) => captureBytes('stderr', output));
    } else {
      stdoutStream.setEncoding('utf8');
      stderrStream.setEncoding('utf8');
      stdoutStream.on('data', (output: string) => captureOutput('stdout', output));
      stderrStream.on('data', (output: string) => captureOutput('stderr', output));
    }

    if (opts?.signal) {
      if (opts.signal.aborted) {