Merge pull request #308 from ripienaar/kv_add_trace

ensure kv add API interactions are traced
nats-io · Dec 2, 2021 · 08df7c7 · 08df7c7
2 parents 334223b + 3a72d58
commit 08df7c7
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 11 deletions.
diff --git a/cli/kv_command.go b/cli/kv_command.go
@@ -326,12 +326,7 @@ func (c *kvCommand) deleteAction(_ *kingpin.ParseContext) error {
 }
 
 func (c *kvCommand) addAction(_ *kingpin.ParseContext) error {
-	nc, _, err := prepareHelper("", natsOpts()...)
-	if err != nil {
-		return err
-	}
-
-	js, err := nc.JetStream()
+	_, js, err := prepareJSHelper()
 	if err != nil {
 		return err
 	}

diff --git a/cli/stream_command.go b/cli/stream_command.go
@@ -1894,8 +1894,6 @@ func (c *streamCmd) validateCfg(cfg *api.StreamConfig) (bool, []byte, []string,
 func (c *streamCmd) addAction(pc *kingpin.ParseContext) (err error) {
 	cfg := c.prepareConfig(pc)
 
-	fmt.Printf("cfg: %#v\n", cfg)
-
 	switch {
 	case c.validateOnly:
 		valid, j, errs, err := c.validateCfg(&cfg)
@@ -1923,12 +1921,9 @@ func (c *streamCmd) addAction(pc *kingpin.ParseContext) (err error) {
 		return ioutil.WriteFile(c.outFile, j, 0644)
 	}
 
-	log.Printf("options: %#v\n", opts)
-	log.Printf("preparing helper %#v\n", natsOpts())
 	_, mgr, err := prepareHelper("", natsOpts()...)
 	kingpin.FatalIfError(err, "could not create Stream")
 
-	log.Printf("mgr: %v\n", mgr)
 	str, err := mgr.NewStreamFromDefault(c.stream, cfg)
 	kingpin.FatalIfError(err, "could not create Stream")