feat(kafka): add interactive prompt for kafka use

locales/cmd/kafka/common/active.en.toml

@@ -11,11 +11,19 @@ description = "Description for --output flag"
 one = 'Format in which to display the Kafka instance. Choose from: "json", "yml", "yaml"'
 other = 'Format in which to display the Kafka instances. Choose from: "json", "yml", "yaml"'
 
-[kafka.common.error.idFlagRequired]
-one = '--id flag is required when name argument is not provided'
-
 [kafka.common.error.idAndNameCannotBeUsed]
 one = 'name argument and --id flag cannot be used at the same time'
 
+[kafka.common.error.couldNotFetchKafkas]
+description = 'Error message when list of Kafka instances could not be fetched'
+one = 'unable to list Kafka instances'
+
+[kafka.common.input.instanceName.message]
+one = 'Select Kafka instance to connect:'
+
+[kafka.common.log.info.noKafkaInstances]
+description = 'Info message when no Kafka instances were found'
+one = 'No Kafka instances were found.'
+
 [kafka.topic.common.error.topicNotFoundError]
 one = 'topic "{{.TopicName}}" does not exist in Kafka instance "{{.InstanceName}}"'

locales/cmd/kafka/list/active.en.toml

@@ -46,8 +46,4 @@ one = 'Text search to filter the Kafka instances by name, owner, cloud_provider,
 
 [kafka.list.log.debug.filteringKafkaList]
 description = 'Debug message when filtering the list of Kafka instances'
-one = 'Filtering Kafka instances with the query "{{.Search}}"'
-
-[kafka.list.log.info.noKafkaInstances]
-description = 'Info message when no Kafkas were found'
-one = 'No Kafka instances were found.'
+one = 'Filtering Kafka instances with the query "{{.Search}}"'

pkg/cmd/kafka/list/list.go

@@ -123,7 +123,7 @@ func runList(opts *options) error {
 	}
 
 	if response.Size == 0 {
-		logger.Info(localizer.MustLocalizeFromID("kafka.list.log.info.noKafkaInstances"))
+		logger.Info(localizer.MustLocalizeFromID("kafka.common.log.info.noKafkaInstances"))
 		return nil
 	}
 

pkg/cmd/kafka/use/use.go

@@ -20,17 +20,18 @@ import (
 	"github.com/bf2fc6cc711aee1a0c2a/cli/pkg/logging"
 )
 
-type options struct {
-	id   string
-	name string
+type Options struct {
+	id          string
+	name        string
+	interactive bool
 
 	Config     config.IConfig
 	Connection factory.ConnectionFunc
 	Logger     func() (logging.Logger, error)
 }
 
 func NewUseCommand(f *factory.Factory) *cobra.Command {
-	opts := &options{
+	opts := &Options{
 		Config:     f.Config,
 		Connection: f.Connection,
 		Logger:     f.Logger,
@@ -53,7 +54,7 @@ func NewUseCommand(f *factory.Factory) *cobra.Command {
 			if len(args) > 0 {
 				opts.name = args[0]
 			} else if opts.id == "" {
-				return errors.New(localizer.MustLocalizeFromID("kafka.common.error.idFlagRequired"))
+				opts.interactive = true
 			}
 
 			if opts.name != "" && opts.id != "" {
@@ -69,7 +70,16 @@ func NewUseCommand(f *factory.Factory) *cobra.Command {
 	return cmd
 }
 
-func runUse(opts *options) error {
+func runUse(opts *Options) error {
+
+	if opts.interactive {
+		// run the use command interactively
+		err := runInteractivePrompt(opts)
+		if err != nil {
+			return err
+		}
+	}
+
 	logger, err := opts.Logger()
 	if err != nil {
 		return err
@@ -126,3 +136,26 @@ func runUse(opts *options) error {
 
 	return nil
 }
+
+func runInteractivePrompt(opts *Options) error {
+	logger, err := opts.Logger()
+	if err != nil {
+		return err
+	}
+
+	connection, err := opts.Connection(connection.DefaultConfigSkipMasAuth)
+	if err != nil {
+		return err
+	}
+
+	logger.Debug(localizer.MustLocalizeFromID("common.log.debug.startingInteractivePrompt"))
+
+	selectedKafka, err := kafka.InteractiveSelect(connection, logger)
+	if err != nil {
+		return err
+	}
+
+	opts.name = selectedKafka.GetName()
+
+	return nil
+}

pkg/kafka/kafka.go

@@ -7,21 +7,26 @@ import (
 	kasclient "github.com/bf2fc6cc711aee1a0c2a/cli/pkg/api/kas/client"
 
 	"github.com/AlecAivazis/survey/v2"
+	"github.com/bf2fc6cc711aee1a0c2a/cli/internal/localizer"
 	"github.com/bf2fc6cc711aee1a0c2a/cli/pkg/connection"
 	"github.com/bf2fc6cc711aee1a0c2a/cli/pkg/logging"
 )
 
+const (
+	queryLimit = "1000"
+)
+
 func InteractiveSelect(connection connection.Connection, logger logging.Logger) (*kasclient.KafkaRequest, error) {
 	api := connection.API()
 
-	response, _, apiErr := api.Kafka().ListKafkas(context.Background()).Execute()
+	response, _, apiErr := api.Kafka().ListKafkas(context.Background()).Size(queryLimit).Execute()
 
 	if apiErr.Error() != "" {
-		return nil, fmt.Errorf("Unable to list Kafka instances: %w", apiErr)
+		return nil, fmt.Errorf("%v: %w", localizer.MustLocalizeFromID("kafka.common.error.couldNotFetchKafkas"), apiErr)
 	}
 
 	if response.Size == 0 {
-		logger.Info("No Kafka instances")
+		logger.Info(localizer.MustLocalizeFromID("kafka.common.log.info.noKafkaInstances"))
 		return nil, nil
 	}
 
@@ -31,8 +36,9 @@ func InteractiveSelect(connection connection.Connection, logger logging.Logger)
 	}
 
 	prompt := &survey.Select{
-		Message: "Select Kafka cluster to connect",
-		Options: kafkas,
+		Message:  localizer.MustLocalizeFromID("kafka.common.input.instanceName.message"),
+		Options:  kafkas,
+		PageSize: 10,
 	}
 
 	var selectedKafkaIndex int