Function readExecuteRequestBody

apps/sim/app/api/workflows/[id]/execute/route.ts:148–161

(req: NextRequest)

}

async function readExecuteRequestBody(req: NextRequest): Promise<unknown> {
  assertContentLengthWithinLimit(
    req.headers,
    MAX_WORKFLOW_EXECUTE_BODY_BYTES,
    'Workflow execution request body'
  )
  const buffer = await readStreamToBufferWithLimit(req.body, {
    maxBytes: MAX_WORKFLOW_EXECUTE_BODY_BYTES,
    label: 'Workflow execution request body',
    signal: req.signal,
  })
  if (buffer.byteLength === 0) return {}
  return JSON.parse(buffer.toString('utf-8'))
}

function clientCancelledResponse(): NextResponse {
  return NextResponse.json({ success: false, error: 'Client cancelled request' }, { status: 499 })