From 18affeba7257f2f09b40ec11e4d44b13f80de6fa Mon Sep 17 00:00:00 2001
From: Sivaanand Murugesan <sivaanand.m@gmail.com>
Date: Sat, 21 Oct 2023 21:34:17 +0530
Subject: [PATCH] set limit as zero

---
 client/cluster.go | 57 ++++++++++-------------------------------------
 1 file changed, 12 insertions(+), 45 deletions(-)

diff --git a/client/cluster.go b/client/cluster.go
index 29e823c1..4c3acb5d 100644
--- a/client/cluster.go
+++ b/client/cluster.go
@@ -102,33 +102,10 @@ func (h *V1Client) SearchClusterSummaries(clusterContext string, filter *models.
 	return resp.Payload.Items, nil
 }
 
-func (h *V1Client) listClusters(clusterContext string) ([]*models.V1SpectroCluster, string, error) {
+func (h *V1Client) listClusters(clusterContext string) ([]*models.V1SpectroCluster, error) {
 	client, err := h.GetClusterClient()
 	if err != nil {
-		return nil, "", err
-	}
-
-	var params *clusterC.V1SpectroClustersListParams
-	switch clusterContext {
-	case "project":
-		params = clusterC.NewV1SpectroClustersListParamsWithContext(h.Ctx)
-	case "tenant":
-		params = clusterC.NewV1SpectroClustersListParams()
-	}
-
-	resp, err := client.V1SpectroClustersList(params)
-	if e, ok := err.(*transport.TransportError); ok && e.HttpCode == 404 {
-		return nil, "", nil
-	} else if err != nil {
-		return nil, "", err
-	}
-	return resp.Payload.Items, resp.Payload.Listmeta.Continue, nil
-}
-
-func (h *V1Client) listClustersWithPagination(clusterContext string, ContinueToken string) ([]*models.V1SpectroCluster, string, error) {
-	client, err := h.GetClusterClient()
-	if err != nil {
-		return nil, "", err
+		return nil, err
 	}
 
 	var params *clusterC.V1SpectroClustersListParams
@@ -138,21 +115,21 @@ func (h *V1Client) listClustersWithPagination(clusterContext string, ContinueTok
 	case "tenant":
 		params = clusterC.NewV1SpectroClustersListParams()
 	}
-	params.Continue = &ContinueToken
+	var limit int64 = 0
+	params.Limit = &limit
 	resp, err := client.V1SpectroClustersList(params)
-
 	if e, ok := err.(*transport.TransportError); ok && e.HttpCode == 404 {
-		return nil, "", nil
+		return nil, nil
 	} else if err != nil {
-		return nil, "", err
+		return nil, err
 	}
-	return resp.Payload.Items, resp.Payload.Listmeta.Continue, nil
+	return resp.Payload.Items, nil
 }
 
-func (h *V1Client) ListClusters(clusterContext string) ([]*models.V1SpectroCluster, string, error) {
-	allClusters, continueToken, err := h.listClusters(clusterContext)
+func (h *V1Client) ListClusters(clusterContext string) ([]*models.V1SpectroCluster, error) {
+	allClusters, err := h.listClusters(clusterContext)
 	if err != nil {
-		return nil, "", err
+		return nil, err
 	}
 	clusters := make([]*models.V1SpectroCluster, 0)
 	for _, c := range allClusters {
@@ -160,7 +137,7 @@ func (h *V1Client) ListClusters(clusterContext string) ([]*models.V1SpectroClust
 			clusters = append(clusters, c)
 		}
 	}
-	return clusters, continueToken, nil
+	return clusters, nil
 }
 
 func (h *V1Client) GetClusterWithoutStatus(scope, uid string) (*models.V1SpectroCluster, error) {
@@ -194,25 +171,15 @@ func (h *V1Client) GetClusterWithoutStatus(scope, uid string) (*models.V1Spectro
 }
 
 func (h *V1Client) GetClusterByName(name, clusterContext string) (*models.V1SpectroCluster, error) {
-	clusters, continueToken, err := h.listClusters(clusterContext)
+	clusters, err := h.listClusters(clusterContext)
 	if err != nil {
 		return nil, err
 	}
-	// Finding out in page one with the limit of 50
 	for _, cluster := range clusters {
 		if cluster.Metadata.Name == name && cluster.Status.State != "Deleted" {
 			return cluster, nil
 		}
 	}
-	// Pagination loop till continueToken becomes = ""
-	for continueToken != "" {
-		clusters, continueToken, err = h.listClustersWithPagination(clusterContext, continueToken)
-		for _, cluster := range clusters {
-			if cluster.Metadata.Name == name && cluster.Status.State != "Deleted" {
-				return cluster, nil
-			}
-		}
-	}
 	return nil, nil
 }