Function execute

worker/src/components/security/dnsx.ts:522–1095

({ inputs, params }, context)

    deprecated: false,
  },
  async execute({ inputs, params }, context) {
    const parsedParams = parameterSchema.parse(params);
    const { domains } = inputs;
    const {
      recordTypes,
      resolvers,
      retryCount,
      rateLimit,
      outputMode,
      threads,
      includeResponses,
      responsesOnly,
      statusCodeFilter,
      showCdn,
      showAsn,
      includeStats,
      verbose,
      includeRawDns,
      omitRawInJson,
      wildcardThreshold,
      wildcardDomain,
      proxy,
      customFlags,
    } = parsedParams;

    const trimmedStatusCodeFilter =
      typeof statusCodeFilter === 'string' && statusCodeFilter.length > 0
        ? statusCodeFilter
        : undefined;
    const trimmedWildcardDomain =
      typeof wildcardDomain === 'string' && wildcardDomain.length > 0 ? wildcardDomain : undefined;
    const trimmedProxy = typeof proxy === 'string' && proxy.length > 0 ? proxy : undefined;
    const customFlagArgs =
      typeof customFlags === 'string' && customFlags.length > 0 ? splitCliArgs(customFlags) : [];

    const normalisedDomains = domains
      .map((domain) => domain.trim())
      .filter((domain) => domain.length > 0);
    const domainCount = normalisedDomains.length;

    const resolverList = resolvers
      .map((resolver) => resolver.trim())
      .filter((resolver) => resolver.length > 0);

    const ensureUnique = (values: string[]) =>
      Array.from(new Set(values.filter((value) => value && value.length > 0)));

    const requestedRecordTypes = ensureUnique(recordTypes);
    const requestedResolvers = ensureUnique(resolverList);

    if (domainCount === 0) {
      context.logger.info('[DNSX] Skipping dnsx execution because no domains were provided.');
      return outputSchema.parse({
        dnsRecords: [],
        results: [],
        rawOutput: '',
        domainCount: 0,
        recordCount: 0,