From 1a1912aaf90fbe63c12a05dbddace0490a810c6a Mon Sep 17 00:00:00 2001
From: Boyang Lyu <boyangly@gmail.com>
Date: Fri, 9 Aug 2024 14:29:22 +0800
Subject: [PATCH] do some experiments

Signed-off-by: Boyang Lyu <boyangly@gmail.com>
---
 tests/integrations/client/http_client_test.go | 50 +++++++++++++------
 1 file changed, 36 insertions(+), 14 deletions(-)

diff --git a/tests/integrations/client/http_client_test.go b/tests/integrations/client/http_client_test.go
index fae42b4d047..3c1cc995318 100644
--- a/tests/integrations/client/http_client_test.go
+++ b/tests/integrations/client/http_client_test.go
@@ -113,6 +113,35 @@ func (suite *httpClientTestSuite) SetupSuite() {
 	suite.endpoints = endpoints
 	suite.cluster = cluster
 
+	list := &api.ListServiceGCSafepoint{
+		ServiceGCSafepoints: []*endpoint.ServiceSafePoint{
+			{
+				ServiceID: "AAA",
+				ExpiredAt: time.Now().Unix() + 10,
+				SafePoint: 1,
+			},
+			{
+				ServiceID: "BBB",
+				ExpiredAt: time.Now().Unix() + 10,
+				SafePoint: 2,
+			},
+			{
+				ServiceID: "CCC",
+				ExpiredAt: time.Now().Unix() + 10,
+				SafePoint: 3,
+			},
+		},
+		GCSafePoint:           1,
+		MinServiceGcSafepoint: 1,
+	}
+
+	storage := suite.cluster.GetLeaderServer().GetServer().GetStorage()
+	for _, ssp := range list.ServiceGCSafepoints {
+		err := storage.SaveServiceGCSafePoint(ssp)
+		re.NoError(err)
+	}
+	storage.SaveGCSafePoint(1)
+
 	if suite.withServiceDiscovery {
 		// Run test with specific service discovery.
 		cli := setupCli(suite.ctx, re, suite.endpoints)
@@ -844,6 +873,13 @@ func (suite *httpClientTestSuite) TestGetGCSafePoint() {
 	ctx, cancel := context.WithCancel(suite.ctx)
 	defer cancel()
 
+	l, err := client.GetGCSafePoint(ctx)
+	re.NoError(err)
+
+	re.Equal(uint64(1), l.GCSafePoint)
+	re.Equal(uint64(1), l.MinServiceGcSafepoint)
+	re.Len(l.ServiceGCSafepoints, 3)
+
 	list := &api.ListServiceGCSafepoint{
 		ServiceGCSafepoints: []*endpoint.ServiceSafePoint{
 			{
@@ -866,20 +902,6 @@ func (suite *httpClientTestSuite) TestGetGCSafePoint() {
 		MinServiceGcSafepoint: 1,
 	}
 
-	storage := suite.cluster.GetLeaderServer().GetServer().GetStorage()
-	for _, ssp := range list.ServiceGCSafepoints {
-		err := storage.SaveServiceGCSafePoint(ssp)
-		re.NoError(err)
-	}
-	storage.SaveGCSafePoint(1)
-
-	l, err := client.GetGCSafePoint(ctx)
-	re.NoError(err)
-
-	re.Equal(uint64(1), l.GCSafePoint)
-	re.Equal(uint64(1), l.MinServiceGcSafepoint)
-	re.Len(l.ServiceGCSafepoints, 3)
-
 	for i, val := range l.ServiceGCSafepoints {
 		re.Equal(list.ServiceGCSafepoints[i].ServiceID, val.ServiceID)
 		re.Equal(list.ServiceGCSafepoints[i].SafePoint, val.SafePoint)