feat(sim): added demo schema random simulator

cmd/strm/main.go

@@ -110,7 +110,7 @@ func setupVerbs() {
 	RootCmd.AddCommand(cmd.DeleteCmd)
 	RootCmd.AddCommand(cmd.ListCmd)
 	RootCmd.AddCommand(cmd.CompletionCmd)
-	RootCmd.AddCommand(cmd.SimCmd)
+	RootCmd.AddCommand(cmd.SimCmd())
 	RootCmd.AddCommand(cmd.EgressCmd)
 	RootCmd.AddCommand(cmd.AuthCmd)
 	RootCmd.AddCommand(cmd.VersionCmd)

pkg/cmd/sim.go

@@ -2,15 +2,28 @@ package cmd
 
 import (
 	"github.com/spf13/cobra"
+	"streammachine.io/strm/pkg/sim"
 	"streammachine.io/strm/pkg/sim/randomsim"
 )
 
-// SimCmd represents the create command
-var SimCmd = &cobra.Command{
-	Use:   "sim",
-	Short: "Simulate events",
+func SimCmd() (cmd *cobra.Command) {
+	// SimCmd represents the create command
+	simCmd := &cobra.Command{
+		Use:   "sim",
+		Short: "Simulate events",
+	}
+
+	flags := simCmd.PersistentFlags()
+	flags.String(sim.SchemaFlag, "streammachine/demo/1.0.2", "what schema to simulate")
+	_ = simCmd.RegisterFlagCompletionFunc(sim.SchemaFlag, schemaCompletion)
+	simCmd.AddCommand(randomsim.RunCmd())
+	return simCmd
 }
 
-func init() {
-	SimCmd.AddCommand(randomsim.RunCmd())
+func schemaCompletion(_ *cobra.Command, _ []string, _ string) ([]string, cobra.ShellCompDirective) {
+	keys := make([]string, 0, len(randomsim.EventGenerators))
+	for key := range randomsim.EventGenerators {
+		keys = append(keys, key)
+	}
+	return keys, cobra.ShellCompDirectiveDefault
 }