Refactor GetApplicationEnvironments function and add unit tests

Author: chenzhiguo

go.mod

@@ -10,6 +10,7 @@ require (
 	github.com/lestrrat-go/file-rotatelogs v2.4.0+incompatible
 	github.com/spf13/cobra v1.8.0
 	github.com/spf13/viper v1.18.2
+	github.com/stretchr/testify v1.8.4
 	go.uber.org/zap v1.27.0
 	gomodules.xyz/jsonpatch/v2 v2.4.0
 	gopkg.in/natefinch/lumberjack.v2 v2.2.1
@@ -49,6 +50,7 @@ require (
 	github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
 	github.com/pelletier/go-toml/v2 v2.1.0 // indirect
 	github.com/pkg/errors v0.9.1 // indirect
+	github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
 	github.com/sagikazarmark/locafero v0.4.0 // indirect
 	github.com/sagikazarmark/slog-shim v0.1.0 // indirect
 	github.com/sourcegraph/conc v0.3.0 // indirect

pkg/resource/control.go

@@ -20,8 +20,8 @@ type ApplicationEnvResponse struct {
 
 func GetApplicationEnvironments(namespace, application string) (map[string]string, error) {
 	url := fmt.Sprintf(
-		"%s/v1/getApplicationEnvironment?application=%s&namespace=%s",
-		config.ControlPlaneUrl, application, namespace,
+		"%s/v1/ns/%s/application/%s/environments",
+		config.ControlPlaneUrl, namespace, application,
 	)
 	resp, err := http.Get(url)
 	if err != nil {

pkg/resource/control_test.go

@@ -0,0 +1,51 @@
+package resource
+
+import (
+	"fmt"
+	"github.com/jd-opensource/joylive-injector/pkg/config"
+	"github.com/stretchr/testify/assert"
+	"net/http"
+	"net/http/httptest"
+	"testing"
+)
+
+func TestGetApplicationEnvironments(t *testing.T) {
+	// 模拟 HTTP 服务器
+	mockServer := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		assert.Equal(t, "/v1/ns/test-namespace/application/test-application/environments", r.URL.Path)
+		w.WriteHeader(http.StatusOK)
+		w.Write([]byte(`{
+			"data": {
+				"ENV_VAR1": "value1",
+				"ENV_VAR2": "value2"
+			}
+		}`))
+	}))
+	defer mockServer.Close()
+
+	// 替换配置中的 ControlPlaneUrl
+	originalURL := config.ControlPlaneUrl
+	config.ControlPlaneUrl = mockServer.URL
+	defer func() { config.ControlPlaneUrl = originalURL }()
+
+	// 调用被测试函数
+	data, err := GetApplicationEnvironments("test-namespace", "test-application")
+
+	// 验证结果
+	assert.NoError(t, err)
+	assert.Equal(t, map[string]string{
+		"ENV_VAR1": "value1",
+		"ENV_VAR2": "value2",
+	}, data)
+}
+
+func TestGetApplicationEnvironments2(t *testing.T) {
+	config.ControlPlaneUrl = "http://localhost:8000"
+
+	// 调用被测试函数
+	data, err := GetApplicationEnvironments("default1", "showcase-agent-a1")
+
+	// 验证结果
+	assert.NoError(t, err)
+	fmt.Print(data)
+}