PR feedback

Author: peteski22

cmd/config/plugins/add.go

@@ -85,7 +85,10 @@ in the category, the command fails with an error. To update an existing plugin,
 		&c.flows,
 		flagFlow,
 		nil,
-		"Flow to execute plugin in: request, response (can be repeated)",
+		fmt.Sprintf(
+			"Flow during which, the plugin should execute (%s) (can be repeated)",
+			strings.Join(OrderedFlowNames(), ", "),
+		),
 	)
 	_ = cobraCmd.MarkFlagRequired(flagFlow)
 
@@ -128,16 +131,14 @@ func (c *AddCmd) run(cmd *cobra.Command, args []string) error {
 		)
 	}
 
-	flowsMap := config.ParseFlows(c.flows)
-	if len(flowsMap) == 0 {
-		return fmt.Errorf("at least one valid flow is required (must be 'request' or 'response')")
+	flows := config.ParseFlowsDistinct(c.flows)
+	if len(flows) == 0 {
+		return fmt.Errorf("at least one valid flow is required (%s)", strings.Join(OrderedFlowNames(), ", "))
 	}
 
-	parsedFlows := slices.Sorted(maps.Keys(flowsMap))
-
 	entry := config.PluginEntry{
 		Name:  pluginName,
-		Flows: parsedFlows,
+		Flows: slices.Sorted(maps.Keys(flows)),
 	}
 
 	// Set optional fields only if they were provided.
@@ -162,3 +163,15 @@ func (c *AddCmd) run(cmd *cobra.Command, args []string) error {
 
 	return nil
 }
+
+// OrderedFlowNames returns the names of allowed flows in order.
+func OrderedFlowNames() []string {
+	flows := slices.Sorted(maps.Keys(config.Flows()))
+
+	flowNames := make([]string, len(flows))
+	for i, f := range flows {
+		flowNames[i] = string(f)
+	}
+
+	return flowNames
+}

cmd/config/plugins/add_test.go

@@ -358,3 +358,10 @@ func TestAddCmd_RequiredFalseExplicitlySet(t *testing.T) {
 	require.NotNil(t, authPlugins[0].Required)
 	require.False(t, *authPlugins[0].Required)
 }
+
+func TestAddCmd_OrderedFlowNames(t *testing.T) {
+	flows := OrderedFlowNames()
+	require.Len(t, flows, 2)
+	require.Equal(t, "request", flows[0])
+	require.Equal(t, "response", flows[1])
+}

internal/config/plugin_config.go

@@ -99,10 +99,10 @@ func (f Flow) IsValid() bool {
 	return ok
 }
 
-// ParseFlows validates and reduces flow strings to a distinct set.
+// ParseFlowsDistinct validates and reduces flow strings to a distinct set.
 // Flow strings are normalized before validation.
 // Invalid flows are silently ignored. Returns an empty map if no valid flows are found.
-func ParseFlows(flags []string) map[Flow]struct{} {
+func ParseFlowsDistinct(flags []string) map[Flow]struct{} {
 	valid := make(map[Flow]struct{}, len(flows))
 
 	for _, s := range flags {

internal/config/plugin_config_test.go

@@ -866,7 +866,7 @@ func TestParseFlows(t *testing.T) {
 		t.Run(tc.name, func(t *testing.T) {
 			t.Parallel()
 
-			result := ParseFlows(tc.input)
+			result := ParseFlowsDistinct(tc.input)
 			require.Equal(t, tc.expected, result)
 		})
 	}