refactor(topics): validate user session earlier (#224)

redhat-developer · Jan 14, 2021 · 49a6a66 · 49a6a66
1 parent c5d4c3f
commit 49a6a66
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 0 deletions.
diff --git a/pkg/cmd/kafka/topics/create/create.go b/pkg/cmd/kafka/topics/create/create.go
@@ -58,6 +58,11 @@ func NewCreateTopicCommand(f *factory.Factory) *cobra.Command {
 }
 
 func createTopic(opts *Options) error {
+	_, err := opts.Connection()
+	if err != nil {
+		return err
+	}
+
 	logger, err := opts.Logger()
 	if err != nil {
 		return err

diff --git a/pkg/cmd/kafka/topics/delete/delete.go b/pkg/cmd/kafka/topics/delete/delete.go
@@ -46,6 +46,11 @@ func NewDeleteTopicCommand(f *factory.Factory) *cobra.Command {
 }
 
 func deleteTopic(opts *Options) error {
+	_, err := opts.Connection()
+	if err != nil {
+		return err
+	}
+
 	logger, err := opts.Logger()
 	if err != nil {
 		return err

diff --git a/pkg/cmd/kafka/topics/list/list.go b/pkg/cmd/kafka/topics/list/list.go
@@ -43,6 +43,11 @@ func NewListTopicCommand(f *factory.Factory) *cobra.Command {
 }
 
 func listTopic(opts *Options) error {
+	_, err := opts.Connection()
+	if err != nil {
+		return err
+	}
+
 	logger, err := opts.Logger()
 	if err != nil {
 		return err