Function execute

worker/src/components/core/http-request.ts:216–320

({ inputs, params }, context)

    return { inputs: inputs(inputShape) };
  },
  async execute({ inputs, params }, context) {
    const { method, contentType, timeout, failOnError, authType } = params;
    const { url, body, headers = {} } = inputs;
    const dynamicInputs = inputs as Record<string, unknown>;
    const authHeaderNameValue =
      typeof dynamicInputs.authHeaderName === 'string' ? dynamicInputs.authHeaderName : undefined;
    const authHeaderValueValue =
      typeof dynamicInputs.authHeaderValue === 'string' ? dynamicInputs.authHeaderValue : undefined;

    context.logger.info(`[HTTP] ${method} ${url}`);

    // Merge headers
    const finalHeaders = new Headers(headers);
    if (contentType !== 'custom' && !finalHeaders.has('Content-Type')) {
      finalHeaders.set('Content-Type', contentType);
    }

    // Handle Auth
    if (authType === 'bearer' && dynamicInputs.bearerToken) {
      finalHeaders.set('Authorization', `Bearer ${dynamicInputs.bearerToken}`);
    } else if (authType === 'basic' && dynamicInputs.username && dynamicInputs.password) {
      const b64 = btoa(`${dynamicInputs.username}:${dynamicInputs.password}`);
      finalHeaders.set('Authorization', `Basic ${b64}`);
    } else if (authType === 'custom' && authHeaderNameValue && authHeaderValueValue) {
      finalHeaders.set(authHeaderNameValue, authHeaderValueValue);
    }

    const controller = new AbortController();
    const timeoutId = setTimeout(() => controller.abort(), timeout);

    try {
      context.emitProgress(`Requesting ${method} ${url}...`);

      const sensitiveHeaders = authHeaderNameValue
        ? Array.from(new Set([...DEFAULT_SENSITIVE_HEADERS, authHeaderNameValue]))
        : DEFAULT_SENSITIVE_HEADERS;

      const response = await context.http.fetch(
        url,
        {
          method: method,
          headers: finalHeaders,
          body: method !== 'GET' && method !== 'HEAD' ? body : undefined,
          signal: controller.signal,
        },
        { sensitiveHeaders },
      );

      clearTimeout(timeoutId);

      const rawText = await response.text();
      let parsedData: unknown = rawText;

      // Try parsing JSON
      try {
        if (
          rawText &&
          (response.headers.get('content-type')?.includes('application/json') ||