Function readToolResponseBody

apps/sim/tools/index.ts:782–816

(
  response: {
    ok?: boolean
    headers?: { get(name: string): string | null }
    body?: ReadableStream<Uint8Array> | null
    arrayBuffer?: () => Promise<ArrayBuffer>
    text?: () => Promise<string>
  },
  options: {
    requestId: string
    toolId: string
    signal?: AbortSignal
  }
)

}

async function readToolResponseBody(
  response: {
    ok?: boolean
    headers?: { get(name: string): string | null }
    body?: ReadableStream<Uint8Array> | null
    arrayBuffer?: () => Promise<ArrayBuffer>
    text?: () => Promise<string>
  },
  options: {
    requestId: string
    toolId: string
    signal?: AbortSignal
  }
): Promise<Buffer> {
  try {
    return await readResponseToBufferWithLimit(response, {
      maxBytes: MAX_TOOL_RESPONSE_BODY_BYTES,
      label: `${options.toolId} response body`,
      signal: options.signal,
      allowNoBodyFallback: true,
    })
  } catch (error) {
    if (isPayloadSizeLimitError(error) || response.ok !== false) {
      throw error
    }

    logger.warn(
      `[${options.requestId}] Failed to read non-OK response body for ${options.toolId}`,
      {
        error: toError(error).message,
      }
    )
    return Buffer.alloc(0)
  }
}

/**
 * System parameters that should be filtered out when extracting tool arguments