Function executeHttpRequest

src/main/ipc/handlers/http.ts:382–504

(
  payload: HttpExecutePayload,
)

}

async function executeHttpRequest(
  payload: HttpExecutePayload,
): Promise<HttpExecuteResult> {
  const variables = resolveEnvironmentVariables(payload.environmentId)
  const interpolated = interpolateRequest(payload.request, variables)

  const headersWithAuth = applyAuth(interpolated.auth, interpolated.headers)
  const headersObj = toHeadersObject(headersWithAuth)
  const built = buildBody(
    interpolated.bodyType,
    interpolated.body,
    interpolated.formData,
  )

  const hasContentType = Object.keys(headersObj).some(
    k => k.toLowerCase() === 'content-type',
  )
  if (!hasContentType && built.contentType) {
    headersObj['Content-Type'] = built.contentType
  }

  let finalUrl: string
  try {
    finalUrl = buildUrl(interpolated.url, interpolated.query)
  }
  catch (error) {
    return {
      status: null,
      statusText: '',
      headers: [],
      body: '',
      bodyKind: 'text',
      durationMs: 0,
      sizeBytes: 0,
      truncated: false,
      error: error instanceof Error ? error.message : 'Invalid URL',
    }
  }

  const timeoutMs = payload.timeoutMs ?? DEFAULT_TIMEOUT_MS
  const controller = new AbortController()
  const timer = setTimeout(() => controller.abort(), timeoutMs)
  const startedAt = Date.now()
  const startedAtPerf = performance.now()

  try {
    const response = await undiciRequest(finalUrl, {
      method: interpolated.method,
      headers: headersObj,
      body: built.body as Dispatcher.DispatchOptions['body'],
      signal: controller.signal,
      maxRedirections: 5,
      ...(payload.skipCertificateVerification
        ? { dispatcher: insecureCertificateDispatcher }
        : {}),
    })

    const { buffer, sizeBytes, truncated } = await readBodyCapped(