Function execute

worker/src/components/security/httpx.ts:260–446

({ inputs, params }, context)

    description: 'Live HTTP endpoint probe and metadata collector (httpx).',
  },
  async execute({ inputs, params }, context) {
    const parsedParams = parameterSchema.parse(params);

    const trimmedPorts = parsedParams.ports?.trim();
    const trimmedStatusCodes = parsedParams.statusCodes?.trim();
    const trimmedPath = parsedParams.path?.trim();

    const runnerParams = {
      ...parsedParams,
      targets: inputs.targets,
      ports: trimmedPorts && trimmedPorts.length > 0 ? trimmedPorts : undefined,
      statusCodes:
        trimmedStatusCodes && trimmedStatusCodes.length > 0 ? trimmedStatusCodes : undefined,
      path: trimmedPath && trimmedPath.length > 0 ? trimmedPath : undefined,
      followRedirects: parsedParams.followRedirects ?? false,
      tlsProbe: parsedParams.tlsProbe ?? false,
      preferHttps: parsedParams.preferHttps ?? false,
    };

    if (runnerParams.targets.length === 0) {
      context.logger.info('[httpx] Skipping httpx probe because no targets were provided.');
      const emptyOutput: Output = {
        responses: [],
        results: [],
        rawOutput: '',
        targetCount: 0,
        resultCount: 0,
        options: {
          followRedirects: runnerParams.followRedirects ?? false,
          tlsProbe: runnerParams.tlsProbe ?? false,
          preferHttps: runnerParams.preferHttps ?? false,
          ports: runnerParams.ports ?? null,
          statusCodes: runnerParams.statusCodes ?? null,
          threads: runnerParams.threads ?? null,
          path: runnerParams.path ?? null,
        },
      };

      return outputSchema.parse(emptyOutput);
    }

    context.logger.info(
      `[httpx] Probing ${runnerParams.targets.length} target(s) with options: ports=${runnerParams.ports ?? 'default'}, statusCodes=${runnerParams.statusCodes ?? 'any'}, threads=${runnerParams.threads ?? 'auto'}, followRedirects=${runnerParams.followRedirects}, tlsProbe=${runnerParams.tlsProbe}, preferHttps=${runnerParams.preferHttps}, path=${runnerParams.path ?? 'none'}`,
    );

    context.emitProgress({
      message: 'Launching httpx probe…',
      level: 'info',
      data: { targets: runnerParams.targets.slice(0, 5) },
    });

    const tenantId = (context as any).tenantId ?? 'default-tenant';
    const volume = new IsolatedContainerVolume(tenantId, context.runId);

    try {
      const targets = Array.from(
        new Set(
          runnerParams.targets.map((target) => target.trim()).filter((target) => target.length > 0),