Method executeBOFPackCustom

workflow/executor.go:1090–1147

executeBOFPackCustom executes a BOF with custom packed arguments

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

// executeBOFPackCustom executes a BOF with custom packed arguments
func (e *Executor) executeBOFPackCustom(ctx context.Context, client *csclient.Client, beaconID string, action Action) (string, error) {
	bofPath, ok := action.Parameters["bof"].(string)
	if !ok {
		return "", fmt.Errorf("bof parameter required")
	}

	bofData, err := os.ReadFile(bofPath)
	if err != nil {
		return "", fmt.Errorf("failed to read BOF file: %w", err)
	}

	bofBase64 := base64.StdEncoding.EncodeToString(bofData)

	// Parse arguments array
	var packedArgs []byte
	if argsInterface, ok := action.Parameters["arguments"].([]interface{}); ok {
		var bofArgs []BOFArgument
		for _, arg := range argsInterface {
			argMap, ok := arg.(map[string]interface{})
			if !ok {
				continue
			}

			argType, _ := argMap["type"].(string)
			bofArg := BOFArgument{
				Type:  argType,
				Value: argMap["value"],
			}
			bofArgs = append(bofArgs, bofArg)
		}

		// Pack arguments using custom packer
		packedArgs, err = PackBOFArguments(bofArgs)
		if err != nil {
			return "", fmt.Errorf("failed to pack arguments: %w", err)
		}
	}

	// Encode packed arguments as base64 string
	packedArgsBase64 := base64.StdEncoding.EncodeToString(packedArgs)

	req := csclient.InlineExecutePackedDto{
		BOF:       "@files/bof.o",
		Files:     map[string]string{"bof.o": bofBase64},
		Arguments: packedArgsBase64,
	}

	if ep, ok := action.Parameters["entrypoint"].(string); ok {
		req.Entrypoint = ep
	}

	resp, err := client.ExecuteBOFPacked(ctx, beaconID, req)
	if err != nil {
		return "", err
	}

	return e.waitForOutput(ctx, client, resp.TaskID)
}