feature(cli): adding support for the all flag when listing resources (#…

…2501)

* feature(cli): adding support for the all flag when listing resources

* fixing unit tests

api/config.yaml

@@ -36,6 +36,15 @@ components:
           type: string
         error:
           type: string
+    ConfigurationResourceList:
+      type: object
+      properties:
+        count:
+          type: integer
+        items:
+          type: array
+          items:
+            $ref: "#/components/schemas/ConfigurationResource"
     ConfigurationResource:
       type: object
       description: "Represents a configuration structured into the Resources format."
@@ -64,6 +73,15 @@ components:
               description: "Flag telling if a user allow Tracetest to send analytics about its usage."
           required:
             - analyticsEnabled
+    PollingProfileList:
+      type: object
+      properties:
+        count:
+          type: integer
+        items:
+          type: array
+          items:
+            $ref: "#/components/schemas/PollingProfile"
     PollingProfile:
       type: object
       description: "Represents a polling profile structured into the Resources format."

api/dataStores.yaml

@@ -1,6 +1,15 @@
 openapi: 3.0.0
 components:
   schemas:
+    DataStoreList:
+      type: object
+      properties:
+        count:
+          type: integer
+        items:
+          type: array
+          items:
+            $ref: "#/components/schemas/DataStoreResource"
     DataStoreResource:
       type: object
       description: "Represents a data store structured into the Resources format."
@@ -158,7 +167,20 @@ components:
           type: string
     SupportedDataStores:
       type: string
-      enum: [jaeger, opensearch, tempo, signalfx, otlp, elasticapm, newrelic, lightstep, datadog, awsxray, honeycomb]
+      enum:
+        [
+          jaeger,
+          opensearch,
+          tempo,
+          signalfx,
+          otlp,
+          elasticapm,
+          newrelic,
+          lightstep,
+          datadog,
+          awsxray,
+          honeycomb,
+        ]
     SupportedClients:
       type: string
       enum: [http, grpc]

api/openapi.yaml

@@ -713,6 +713,30 @@ paths:
             application/json:
               schema:
                 $ref: "./config.yaml#/components/schemas/TestConnectionResponse"
+  /configs:
+    get:
+      tags:
+        - resource-api
+      parameters:
+        - $ref: "./parameters.yaml#/components/parameters/take"
+        - $ref: "./parameters.yaml#/components/parameters/skip"
+        - $ref: "./parameters.yaml#/components/parameters/switchableResourceSortBy"
+        - $ref: "./parameters.yaml#/components/parameters/sortDirection"
+      summary: "List Tracetest configuration"
+      description: "List Tracetest configuration"
+      operationId: listConfiguration
+      responses:
+        200:
+          description: successful operation
+          content:
+            application/json:
+              schema:
+                $ref: "./config.yaml#/components/schemas/ConfigurationResourceList"
+            text/yaml:
+              schema:
+                $ref: "./config.yaml#/components/schemas/ConfigurationResourceList"
+        500:
+          description: "problem getting the configuration list"
   /configs/{configId}:
     get:
       tags:
@@ -762,7 +786,31 @@ paths:
                 $ref: "./config.yaml#/components/schemas/ConfigurationResource"
         500:
           description: "problem updating configuration"
-
+
+  /pollingprofiles:
+    get:
+      tags:
+        - resource-api
+      parameters:
+        - $ref: "./parameters.yaml#/components/parameters/take"
+        - $ref: "./parameters.yaml#/components/parameters/skip"
+        - $ref: "./parameters.yaml#/components/parameters/switchableResourceSortBy"
+        - $ref: "./parameters.yaml#/components/parameters/sortDirection"
+      summary: "List Polling Profile Configuration"
+      description: "List Polling Profile configuration"
+      operationId: listPollingProfile
+      responses:
+        200:
+          description: successful operation
+          content:
+            application/json:
+              schema:
+                $ref: "./config.yaml#/components/schemas/PollingProfileList"
+            text/yaml:
+              schema:
+                $ref: "./config.yaml#/components/schemas/PollingProfileList"
+        500:
+          description: "problem getting the polling profile list"
   # Polling Profile
   /pollingprofiles/{pollingProfileId}:
     get:
@@ -953,6 +1001,31 @@ paths:
         500:
           description: "problem deleting a demo"
 
+  /datastores:
+    get:
+      tags:
+        - resource-api
+      parameters:
+        - $ref: "./parameters.yaml#/components/parameters/take"
+        - $ref: "./parameters.yaml#/components/parameters/skip"
+        - $ref: "./parameters.yaml#/components/parameters/switchableResourceSortBy"
+        - $ref: "./parameters.yaml#/components/parameters/sortDirection"
+      summary: "List Data Store"
+      description: "List Data Store"
+      operationId: listDataStore
+      responses:
+        200:
+          description: successful operation
+          content:
+            application/json:
+              schema:
+                $ref: "./dataStores.yaml#/components/schemas/DataStoreList"
+            text/yaml:
+              schema:
+                $ref: "./dataStores.yaml#/components/schemas/DataStoreList"
+        500:
+          description: "problem getting the data store list"
+
   # Data Stores
   /datastores/{dataStoreId}:
     get:

cli/actions/config.go

@@ -2,7 +2,6 @@ package actions
 
 import (
 	"context"
-	"fmt"
 
 	"github.com/kubeshop/tracetest/cli/file"
 	"github.com/kubeshop/tracetest/cli/openapi"
@@ -52,7 +51,7 @@ func (config configActions) Get(ctx context.Context, ID string) (*file.File, err
 }
 
 func (config configActions) List(ctx context.Context, listArgs utils.ListArgs) (*file.File, error) {
-	return nil, fmt.Errorf("Config does not support listing. Try `tracetest get config` instead")
+	return config.resourceClient.List(ctx, listArgs)
 }
 
 func (config configActions) Delete(ctx context.Context, ID string) (string, error) {

cli/actions/datastore.go

@@ -2,7 +2,6 @@ package actions
 
 import (
 	"context"
-	"fmt"
 
 	"github.com/kubeshop/tracetest/cli/file"
 	"github.com/kubeshop/tracetest/cli/openapi"
@@ -51,7 +50,7 @@ func (d *dataStoreActions) Apply(ctx context.Context, fileContent file.File) (re
 }
 
 func (d *dataStoreActions) List(ctx context.Context, args utils.ListArgs) (*file.File, error) {
-	return nil, fmt.Errorf("DataStore does not support listing. Try `tracetest get datastore`")
+	return d.resourceClient.List(ctx, args)
 }
 
 func (d *dataStoreActions) Get(ctx context.Context, id string) (*file.File, error) {

cli/actions/polling.go

@@ -50,7 +50,7 @@ func (polling pollingActions) Apply(ctx context.Context, fileContent file.File)
 }
 
 func (polling pollingActions) List(ctx context.Context, listArgs utils.ListArgs) (*file.File, error) {
-	return nil, ErrNotSupportedResourceAction
+	return polling.resourceClient.List(ctx, listArgs)
 }
 
 func (polling pollingActions) Delete(ctx context.Context, ID string) (string, error) {

cli/cmd/list_cmd.go

@@ -17,6 +17,7 @@ var (
 	listSkip          int32
 	listSortBy        string
 	listSortDirection string
+	listAll           bool
 )
 
 var listCmd = &cobra.Command{
@@ -47,6 +48,7 @@ var listCmd = &cobra.Command{
 			Skip:          listSkip,
 			SortDirection: listSortDirection,
 			SortBy:        listSortBy,
+			All:           listAll,
 		}
 
 		resource, err := resourceActions.List(ctx, listArgs)
@@ -76,6 +78,7 @@ func init() {
 	listCmd.Flags().Int32Var(&listSkip, "skip", 0, "Skip number")
 	listCmd.Flags().StringVar(&listSortBy, "sortBy", "", "Sort by")
 	listCmd.Flags().StringVar(&listSortDirection, "sortDirection", "desc", "Sort direction")
+	listCmd.Flags().BoolVar(&listAll, "all", false, "All")
 
 	rootCmd.AddCommand(listCmd)
 }

cli/formatters/config.go

@@ -35,7 +35,23 @@ func (f ConfigFormatter) ToTable(file *file.File) (*simpletable.Header, *simplet
 }
 
 func (f ConfigFormatter) ToListTable(file *file.File) (*simpletable.Header, *simpletable.Body, error) {
-	return nil, nil, nil
+	rawConfigList, err := f.ToListStruct(file)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	body := simpletable.Body{}
+	for _, rawConfig := range rawConfigList {
+		configResource := rawConfig.(openapi.ConfigurationResource)
+		row, err := f.getTableRow(configResource)
+		if err != nil {
+			return nil, nil, err
+		}
+
+		body.Cells = append(body.Cells, row)
+	}
+
+	return f.getTableHeader(), &body, nil
 }
 
 func (f ConfigFormatter) ToStruct(file *file.File) (interface{}, error) {
@@ -51,7 +67,20 @@ func (f ConfigFormatter) ToStruct(file *file.File) (interface{}, error) {
 }
 
 func (f ConfigFormatter) ToListStruct(file *file.File) ([]interface{}, error) {
-	return nil, nil
+	var ConfigResourceList openapi.ConfigurationResourceList
+	nullableList := openapi.NewNullableConfigurationResourceList(&ConfigResourceList)
+
+	err := nullableList.UnmarshalJSON([]byte(file.Contents()))
+	if err != nil {
+		return nil, err
+	}
+
+	items := make([]interface{}, len(ConfigResourceList.Items))
+	for i, item := range ConfigResourceList.Items {
+		items[i] = item
+	}
+
+	return items, nil
 }
 
 func (f ConfigFormatter) getTableHeader() *simpletable.Header {

cli/formatters/datastore.go

@@ -33,7 +33,23 @@ func (f DatastoreFormatter) ToTable(file *file.File) (*simpletable.Header, *simp
 }
 
 func (f DatastoreFormatter) ToListTable(file *file.File) (*simpletable.Header, *simpletable.Body, error) {
-	return nil, nil, nil
+	rawList, err := f.ToListStruct(file)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	body := simpletable.Body{}
+	for _, raw := range rawList {
+		resource := raw.(openapi.DataStoreResource)
+		row, err := f.getTableRow(resource)
+		if err != nil {
+			return nil, nil, err
+		}
+
+		body.Cells = append(body.Cells, row)
+	}
+
+	return f.getTableHeader(), &body, nil
 }
 
 func (f DatastoreFormatter) ToStruct(file *file.File) (interface{}, error) {
@@ -49,7 +65,20 @@ func (f DatastoreFormatter) ToStruct(file *file.File) (interface{}, error) {
 }
 
 func (f DatastoreFormatter) ToListStruct(file *file.File) ([]interface{}, error) {
-	return nil, nil
+	var dataStoreList openapi.DataStoreList
+	nullableList := openapi.NewNullableDataStoreList(&dataStoreList)
+
+	err := nullableList.UnmarshalJSON([]byte(file.Contents()))
+	if err != nil {
+		return nil, err
+	}
+
+	items := make([]interface{}, len(dataStoreList.Items))
+	for i, item := range dataStoreList.Items {
+		items[i] = item
+	}
+
+	return items, nil
 }
 
 func (f DatastoreFormatter) getTableHeader() *simpletable.Header {

cli/formatters/polling.go

@@ -33,7 +33,23 @@ func (f PollingFormatter) ToTable(file *file.File) (*simpletable.Header, *simple
 }
 
 func (f PollingFormatter) ToListTable(file *file.File) (*simpletable.Header, *simpletable.Body, error) {
-	return nil, nil, nil
+	rawPollingList, err := f.ToListStruct(file)
+	if err != nil {
+		return nil, nil, err
+	}
+
+	body := simpletable.Body{}
+	for _, rawPolling := range rawPollingList {
+		pollingResource := rawPolling.(openapi.PollingProfile)
+		row, err := f.getTableRow(pollingResource)
+		if err != nil {
+			return nil, nil, err
+		}
+
+		body.Cells = append(body.Cells, row)
+	}
+
+	return f.getTableHeader(), &body, nil
 }
 
 func (f PollingFormatter) ToStruct(file *file.File) (interface{}, error) {
@@ -49,7 +65,20 @@ func (f PollingFormatter) ToStruct(file *file.File) (interface{}, error) {
 }
 
 func (f PollingFormatter) ToListStruct(file *file.File) ([]interface{}, error) {
-	return nil, nil
+	var pollingProfileList openapi.PollingProfileList
+	nullableList := openapi.NewNullablePollingProfileList(&pollingProfileList)
+
+	err := nullableList.UnmarshalJSON([]byte(file.Contents()))
+	if err != nil {
+		return nil, err
+	}
+
+	items := make([]interface{}, len(pollingProfileList.Items))
+	for i, item := range pollingProfileList.Items {
+		items[i] = item
+	}
+
+	return items, nil
 }
 
 func (f PollingFormatter) getTableHeader() *simpletable.Header {