Method executePortScan

workflow/executor_network.go:153–232

executePortScan runs a portscan against the specified hosts

(ctx context.Context, client *csclient.Client, beaconID string, action Action)

// executePortScan runs a portscan against the specified hosts
func (e *Executor) executePortScan(ctx context.Context, client *csclient.Client, beaconID string, action Action) (string, error) {
	// Extract required parameters
	targetsRaw, ok := action.Parameters["targets"]
	if !ok {
		return "", fmt.Errorf("portscan requires 'targets' parameter")
	}

	portsRaw, ok := action.Parameters["ports"]
	if !ok {
		return "", fmt.Errorf("portscan requires 'ports' parameter")
	}

	// Convert targets to []string
	var targets []string
	switch v := targetsRaw.(type) {
	case []interface{}:
		for _, t := range v {
			if str, ok := t.(string); ok {
				targets = append(targets, str)
			}
		}
	case []string:
		targets = v
	case string:
		targets = []string{v}
	default:
		return "", fmt.Errorf("targets must be a string or array of strings")
	}

	if len(targets) == 0 {
		return "", fmt.Errorf("targets must contain at least one host")
	}

	// Convert ports to []string
	var ports []string
	switch v := portsRaw.(type) {
	case []interface{}:
		for _, p := range v {
			if str, ok := p.(string); ok {
				ports = append(ports, str)
			} else if num, ok := p.(int); ok {
				ports = append(ports, fmt.Sprintf("%d", num))
			} else if num, ok := p.(float64); ok {
				ports = append(ports, fmt.Sprintf("%.0f", num))
			}
		}
	case []string:
		ports = v
	case string:
		ports = []string{v}
	case int:
		ports = []string{fmt.Sprintf("%d", v)}
	case float64:
		ports = []string{fmt.Sprintf("%.0f", v)}
	default:
		return "", fmt.Errorf("ports must be a string, number, or array")
	}