Function execute

worker/src/components/security/amass.ts:515–749

(
    {
      inputs,
      params,
    }: ExecutionPayload<z.infer<typeof inputSchema>, z.infer<typeof parameterSchema>>,
    context: ExecutionContext,
  )

    ],
  },
  async execute(
    {
      inputs,
      params,
    }: ExecutionPayload<z.infer<typeof inputSchema>, z.infer<typeof parameterSchema>>,
    context: ExecutionContext,
  ) {
    const parsedParams = parameterSchema.parse(params);
    const {
      passive,
      active,
      bruteForce,
      enableAlterations,
      recursive,
      minForRecursive,
      maxDepth,
      dnsQueryRate,
      includeIps,
      verbose,
      demoMode,
      timeoutMinutes,
      resolvers,
      dataSources,
      customFlags,
    } = parsedParams;

    const trimmedCustomFlags =
      typeof customFlags === 'string' && customFlags.length > 0 ? customFlags : null;
    const customFlagArgs = trimmedCustomFlags ? splitCliArgs(trimmedCustomFlags) : [];

    const effectiveDataSources = dataSources ?? DEFAULT_DATA_SOURCES_STRING;
    const effectiveResolvers = resolvers ?? DEFAULT_RESOLVERS_STRING;

    const optionsSummary = {
      passive: passive ?? true,
      active: active ?? false,
      bruteForce: bruteForce ?? false,
      enableAlterations: enableAlterations ?? false,
      includeIps: includeIps ?? false,
      recursive: recursive ?? false,
      minForRecursive: minForRecursive ?? null,
      maxDepth: maxDepth ?? null,
      dnsQueryRate: dnsQueryRate ?? null,
      verbose: verbose ?? false,
      demoMode: demoMode ?? false,
      timeoutMinutes: timeoutMinutes ?? 15,
      resolvers: effectiveResolvers,
      dataSources: effectiveDataSources,
      customFlags: trimmedCustomFlags,
    };

    // Normalize domains
    const normalisedDomains = inputs.domains
      .map((domain) => domain.trim())
      .filter((domain) => domain.length > 0);

    const domainCount = normalisedDomains.length;