feat(kafka list): add search flag

Search flag has been added to kafka list to filter by text.

fixes #181

Author: rkpattnaik780

cmd/rhoas/pkged.go

@@ -23,6 +23,7 @@ rhoas kafka list [flags]
       --limit int       The maximum number of Kafka instances to be returned (default 100)
   -o, --output string   Format in which to display the Kafka instances. Choose from: "json", "yml", "yaml"
       --page int        Display the Kafka instances from the specified page number.
+      --search string   Text search to filter the Kafka instances
 ....
 
 === Options inherited from parent commands

docs/commands/rhoas_kafka_list.adoc

@@ -40,6 +40,10 @@ one = 'Display the Kafka instances from the specified page number.'
 description = 'Description for the --limit flag'
 one = 'The maximum number of Kafka instances to be returned'
 
+[kafka.list.flag.search]
+description = 'Description for the --search flag'
+one = 'Text search to filter the Kafka instances'
+
 [kafka.list.log.info.noKafkaInstances]
 description = 'Info message when no Kafkas were found'
 one = 'No Kafka instances were found.'

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

@@ -3,6 +3,7 @@ package list
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"os"
 	"strconv"
 
@@ -37,6 +38,7 @@ type options struct {
 	outputFormat string
 	page         int
 	limit        int
+	search       string
 
 	Config     config.IConfig
 	Connection func() (connection.Connection, error)
@@ -48,6 +50,7 @@ func NewListCommand(f *factory.Factory) *cobra.Command {
 	opts := &options{
 		page:       0,
 		limit:      100,
+		search:     "",
 		Config:     f.Config,
 		Connection: f.Connection,
 		Logger:     f.Logger,
@@ -75,6 +78,7 @@ func NewListCommand(f *factory.Factory) *cobra.Command {
 	}))
 	cmd.Flags().IntVarP(&opts.page, "page", "", 0, localizer.MustLocalizeFromID("kafka.list.flag.page"))
 	cmd.Flags().IntVarP(&opts.limit, "limit", "", 100, localizer.MustLocalizeFromID("kafka.list.flag.limit"))
+	cmd.Flags().StringVarP(&opts.search, "search", "", "", localizer.MustLocalizeFromID("kafka.list.flag.search"))
 
 	return cmd
 }
@@ -95,6 +99,7 @@ func runList(opts *options) error {
 	a := api.Kafka().ListKafkas(context.Background())
 	a = a.Page(strconv.Itoa(opts.page))
 	a = a.Size(strconv.Itoa(opts.limit))
+	a = a.Search(buildQuery(opts.search))
 	response, _, apiErr := a.Execute()
 
 	if apiErr.Error() != "" {
@@ -140,3 +145,18 @@ func mapResponseItemsToRows(kafkas []kasclient.KafkaRequest) []kafkaRow {
 
 	return rows
 }
+
+func buildQuery(search string) string {
+
+	var queryString string
+
+	if search != "" {
+		queryString = fmt.Sprintf(
+			"name like %%%[1]v%% or owner like %%%[1]v%% or cloud_provider like %%%[1]v%% or region like %%%[1]v%% or status like %%%[1]v%%",
+			search,
+		)
+	}
+
+	return queryString
+
+}