feat(egress): persistent flag

cmd/egress.go

@@ -11,16 +11,16 @@ import (
 var EgressCmd = &cobra.Command{
 	Use:               "egress",
 	Short:             "Read from egress",
-	Run:               func(cmd *cobra.Command, args []string) { egress.Run(cmd, &args[0]) },
+	Run:               func(cmd *cobra.Command, args []string) {
+		egress.Run(cmd, &args[0])
+	},
 	Args:              cobra.ExactArgs(1), // the stream name
 	ValidArgsFunction: stream.ExistingNamesCompletion,
 }
 
 func init() {
 	flags := EgressCmd.Flags()
-	flags.String(egress.UrlFlag, "wss://out.strm.services/ws",
-		"where to retrieve the events")
 	flags.String(sims.ClientIdFlag, "", "client id to be used for sending data")
 	flags.String(sims.ClientSecretFlag, "", "client secret to be used for sending data")
 
-}
+}

cmd/root.go

@@ -137,6 +137,7 @@ func init() {
 	RootCmd.PersistentFlags().String(auth.ApiAuthUrlFlag, "https://api.streammachine.io/v1", "Auth URL for user logins")
 	RootCmd.PersistentFlags().StringVar(&auth.TokenFile, "token-file", "",
 		"config file (default is $HOME/.config/stream-machine/strm-creds-<api-auth-host>.json)")
+	RootCmd.PersistentFlags().String(egress.UrlFlag, "wss://out.strm.services/ws", "where to retrieve the events")
 	setupVerbs()
 }
 
@@ -206,4 +207,4 @@ func bindFlags(cmd *cobra.Command, v *viper.Viper) {
 			cobra.CheckErr(err)
 		}
 	})
-}
+}

egress/egress.go

@@ -12,7 +12,9 @@ import (
 	"streammachine.io/strm/utils"
 )
 
-const UrlFlag = "egress"
+const (
+	UrlFlag = "egress"
+)
 
 var BillingId string
 
@@ -47,4 +49,4 @@ func Run(cmd *cobra.Command, streamName *string) {
 		cobra.CheckErr(err)
 		fmt.Println(string(message))
 	}
-}
+}