Function execute

worker/src/components/security/abuseipdb.ts:149–254

({ inputs, params }, context)

    deprecated: false,
  },
  async execute({ inputs, params }, context) {
    const { ipAddress, apiKey } = inputs;
    const { maxAgeInDays, verbose } = params;

    if (!ipAddress) {
      throw new ValidationError('IP Address is required', {
        fieldErrors: { ipAddress: ['IP Address is required'] },
      });
    }
    if (!apiKey) {
      throw new ConfigurationError('AbuseIPDB API Key is required', {
        configKey: 'apiKey',
      });
    }

    const endpoint = 'https://api.abuseipdb.com/api/v2/check';
    const queryParams = new URLSearchParams({
      ipAddress,
      maxAgeInDays: String(maxAgeInDays),
    });
    if (verbose) {
      queryParams.append('verbose', 'true');
    }

    const url = `${endpoint}?${queryParams.toString()}`;

    context.logger.info(`[AbuseIPDB] Checking IP: ${ipAddress}`);

    const response = await context.http.fetch(url, {
      method: 'GET',
      headers: {
        Key: apiKey,
        Accept: 'application/json',
      },
    });

    if (response.status === 404) {
      context.logger.warn(`[AbuseIPDB] IP not found: ${ipAddress}`);
      return {
        ipAddress,
        results: [],
        abuseConfidenceScore: 0,
        full_report: { error: 'Not Found' },
      };
    }

    if (!response.ok) {
      const text = await response.text();
      throw fromHttpResponse(response, text);
    }

    const data = (await response.json()) as Record<string, unknown>;
    const info = (data.data || {}) as Record<string, unknown>;

    const abuseConfidenceScore = info.abuseConfidenceScore as number;

    context.logger.info(`[AbuseIPDB] Score for ${ipAddress}: ${abuseConfidenceScore}`);