Function readBodyCapped

src/main/ipc/handlers/http.ts:333–368

(
  body: NodeJS.ReadableStream,
  cap: number,
)

}

async function readBodyCapped(
  body: NodeJS.ReadableStream,
  cap: number,
): Promise<{ buffer: Buffer, sizeBytes: number, truncated: boolean }> {
  const chunks: Buffer[] = []
  let received = 0
  let truncated = false

  for await (const chunk of body as AsyncIterable<Buffer>) {
    const buf = Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk)
    if (received + buf.length > cap) {
      const remaining = cap - received
      if (remaining > 0) {
        chunks.push(buf.subarray(0, remaining))
        received += remaining
      }
      truncated = true
      break
    }
    chunks.push(buf)
    received += buf.length
  }

  if (truncated) {
    const maybeDestroyable = body as unknown as { destroy?: () => void }
    if (typeof maybeDestroyable.destroy === 'function') {
      maybeDestroyable.destroy()
    }
  }

  return {
    buffer: Buffer.concat(chunks),
    sizeBytes: received,
    truncated,
  }
}

function resolveEnvironmentVariables(
  environmentId: number | null,