set default value for client inbox

hooksie1 · Aug 16, 2024 · 9c934a4 · 9c934a4
1 parent ed8c2a7
commit 9c934a4
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 1 deletion.
diff --git a/cmd/client.go b/cmd/client.go
@@ -13,8 +13,10 @@ var clientCmd = &cobra.Command{
 func init() {
 	rootCmd.AddCommand(clientCmd)
 	natsFlags(clientCmd)
+	clientFlags(clientCmd)
 }
 
 func bindClientCmdFlags(cmd *cobra.Command, args []string) {
 	bindNatsFlags(cmd)
+	bindClientFlags(cmd)
 }
diff --git a/cmd/flags.go b/cmd/flags.go
@@ -31,6 +31,14 @@ func natsFlags(cmd *cobra.Command) {
 	cmd.PersistentFlags().Bool("use-traffic-shaping", false, "Local development connection")
 }
 
+func bindClientFlags(cmd *cobra.Command) {
+	viper.BindPFlag("inbox_prefix", cmd.Flags().Lookup("inbox-prefix"))
+}
+
+func clientFlags(cmd *cobra.Command) {
+	cmd.PersistentFlags().String("inbox-prefix", "PIGGYBANK.ADMIN", "subject prefix for replies")
+}
+
 // bindServiceFlags binds the secret flag values to viper
 func bindServiceFlags(cmd *cobra.Command) {
 	viper.BindPFlag("port", cmd.Flags().Lookup("port"))

diff --git a/cmd/nats.go b/cmd/nats.go
@@ -10,7 +10,7 @@ import (
 )
 
 func newNatsConnection(name string) (*nats.Conn, error) {
-	opts := []nats.Option{nats.Name(name)}
+	opts := []nats.Option{nats.Name(name), nats.CustomInboxPrefix(viper.GetString("inbox_prefix"))}
 
 	_, ok := os.LookupEnv("USER")