fix: round 6 — upstream nodes array format, secret_providers path, PUT for plugin-metadata, credential name, skip unsupported resources

moonming · moonming · commit 81241dce7ee0 · 2026-03-24T08:01:58.000+08:00
- upstream nodes: map format → array format in all test fixtures (API7 EE only accepts arrays)
- secret paths: /apisix/admin/secrets → /apisix/admin/secret_providers (matches API7 EE SDK)
- skip consumer_group and plugin_config e2e tests (no REST API endpoint in API7 EE)
- plugin-metadata create: POST → PUT (API7 EE uses PUT for create)
- credential type: add Name field required by API7 EE
- gateway group CRUD: use timestamp-based unique name to avoid conflicts
diff --git a/pkg/api/types_credential.go b/pkg/api/types_credential.go
@@ -4,6 +4,7 @@ package api
 // Credentials are scoped to a consumer (path: /consumers/{username}/credentials).
 type Credential struct {
 	ID      string                 `json:"id,omitempty" yaml:"id,omitempty"`
+	Name    string                 `json:"name,omitempty" yaml:"name,omitempty"`
 	Desc    string                 `json:"desc,omitempty" yaml:"desc,omitempty"`
 	Plugins map[string]interface{} `json:"plugins,omitempty" yaml:"plugins,omitempty"`
 	Labels  map[string]string      `json:"labels,omitempty" yaml:"labels,omitempty"`
diff --git a/pkg/cmd/config/configutil/configutil.go b/pkg/cmd/config/configutil/configutil.go
@@ -157,7 +157,7 @@ func FetchRemoteConfig(client *api.Client, gatewayGroup string) (*api.ConfigFile
 	if err != nil {
 		return nil, err
 	}
-	secrets, err := fetchPaginated[api.Secret](client, "/apisix/admin/secrets", query)
+	secrets, err := fetchPaginated[api.Secret](client, "/apisix/admin/secret_providers", query)
 	if err != nil {
 		return nil, err
 	}
diff --git a/pkg/cmd/config/diff/diff_test.go b/pkg/cmd/config/diff/diff_test.go
@@ -46,7 +46,7 @@ func registerEmptyResources(reg *httpmock.Registry, skip map[string]bool) {
 		"/apisix/admin/consumer_groups",
 		"/apisix/admin/stream_routes",
 		"/apisix/admin/protos",
-		"/apisix/admin/secrets",
+		"/apisix/admin/secret_providers",
 	}
 	for _, path := range resources {
 		if skip != nil && skip[path] {
diff --git a/pkg/cmd/config/dump/dump_test.go b/pkg/cmd/config/dump/dump_test.go
@@ -47,7 +47,7 @@ func registerEmptyResources(reg *httpmock.Registry, skip map[string]bool) {
 		"/apisix/admin/consumer_groups",
 		"/apisix/admin/stream_routes",
 		"/apisix/admin/protos",
-		"/apisix/admin/secrets",
+		"/apisix/admin/secret_providers",
 	}
 	for _, path := range resources {
 		if skip != nil && skip[path] {
@@ -107,10 +107,10 @@ func TestConfigDump_RoutesOnly(t *testing.T) {
 func TestConfigDump_MultipleResources(t *testing.T) {
 	reg := &httpmock.Registry{}
 	registerEmptyResources(reg, map[string]bool{
-		"/apisix/admin/routes":       true,
-		"/apisix/admin/services":     true,
-		"/apisix/admin/secrets":      true,
-		"/apisix/admin/plugins/list": true,
+		"/apisix/admin/routes":           true,
+		"/apisix/admin/services":         true,
+		"/apisix/admin/secret_providers": true,
+		"/apisix/admin/plugins/list":     true,
 	})
 
 	reg.Register(http.MethodGet, "/apisix/admin/routes", httpmock.JSONResponse(`{
@@ -121,7 +121,7 @@ func TestConfigDump_MultipleResources(t *testing.T) {
 		"total": 1,
 		"list": [{"id":"1","name":"svc-1","upstream_id":"1"}]
 	}`))
-	reg.Register(http.MethodGet, "/apisix/admin/secrets", httpmock.JSONResponse(`{
+	reg.Register(http.MethodGet, "/apisix/admin/secret_providers", httpmock.JSONResponse(`{
 		"total": 1,
 		"list": [{"id":"vault/my-vault","uri":"https://vault.example.com"}]
 	}`))
diff --git a/pkg/cmd/config/sync/sync.go b/pkg/cmd/config/sync/sync.go
@@ -223,7 +223,7 @@ func putPathAndBody(resourceType, key string, payload map[string]interface{}) (s
 	case "protos":
 		return fmt.Sprintf("/apisix/admin/protos/%s", key), payload, nil
 	case "secrets":
-		return fmt.Sprintf("/apisix/admin/secrets/%s", key), payload, nil
+		return fmt.Sprintf("/apisix/admin/secret_providers/%s", key), payload, nil
 	case "plugin_metadata":
 		delete(payload, "plugin_name")
 		return fmt.Sprintf("/apisix/admin/plugin_metadata/%s", key), payload, nil
@@ -255,7 +255,7 @@ func deletePath(resourceType, key string) (string, error) {
 	case "protos":
 		return fmt.Sprintf("/apisix/admin/protos/%s", key), nil
 	case "secrets":
-		return fmt.Sprintf("/apisix/admin/secrets/%s", key), nil
+		return fmt.Sprintf("/apisix/admin/secret_providers/%s", key), nil
 	case "plugin_metadata":
 		return fmt.Sprintf("/apisix/admin/plugin_metadata/%s", key), nil
 	default:
diff --git a/pkg/cmd/config/sync/sync_test.go b/pkg/cmd/config/sync/sync_test.go
@@ -45,7 +45,7 @@ func registerEmptyResources(reg *httpmock.Registry, skip map[string]bool) {
 		"/apisix/admin/consumer_groups",
 		"/apisix/admin/stream_routes",
 		"/apisix/admin/protos",
-		"/apisix/admin/secrets",
+		"/apisix/admin/secret_providers",
 	}
 	for _, path := range resources {
 		if skip != nil && skip[path] {
diff --git a/pkg/cmd/plugin-metadata/create/create.go b/pkg/cmd/plugin-metadata/create/create.go
@@ -83,7 +83,7 @@ func actionRun(opts *Options) error {
 		}
 
 		client := api.NewClient(httpClient, cfg.BaseURL())
-		body, err := client.Post("/apisix/admin/plugin_metadata/"+pluginName+"?gateway_group_id="+ggID, payload)
+		body, err := client.Put("/apisix/admin/plugin_metadata/"+pluginName+"?gateway_group_id="+ggID, payload)
 		if err != nil {
 			return fmt.Errorf("%s", cmdutil.FormatAPIError(err))
 		}
@@ -113,7 +113,7 @@ func actionRun(opts *Options) error {
 	bodyReq := api.PluginMetadata{Metadata: metadata}
 
 	client := api.NewClient(httpClient, cfg.BaseURL())
-	body, err := client.Post("/apisix/admin/plugin_metadata/"+opts.PluginName+"?gateway_group_id="+ggID, bodyReq)
+	body, err := client.Put("/apisix/admin/plugin_metadata/"+opts.PluginName+"?gateway_group_id="+ggID, bodyReq)
 	if err != nil {
 		return fmt.Errorf("%s", cmdutil.FormatAPIError(err))
 	}
diff --git a/pkg/cmd/plugin-metadata/create/create_test.go b/pkg/cmd/plugin-metadata/create/create_test.go
@@ -33,7 +33,7 @@ func (m *mockConfig) Save() error                                     { return n
 func TestCreatePluginMetadata_JSON(t *testing.T) {
 	ios, _, out, _ := iostreams.Test()
 	registry := &httpmock.Registry{}
-	registry.Register(http.MethodPost, "/apisix/admin/plugin_metadata/key-auth", httpmock.JSONResponse(`{"id":"key-auth","metadata":{"header":"x-api-key"}}`))
+	registry.Register(http.MethodPut, "/apisix/admin/plugin_metadata/key-auth", httpmock.JSONResponse(`{"id":"key-auth","metadata":{"header":"x-api-key"}}`))
 
 	opts := &Options{
 		IO:     ios,
diff --git a/pkg/cmd/secret/create/create.go b/pkg/cmd/secret/create/create.go
@@ -80,9 +80,9 @@ func actionRun(opts *Options) error {
 		client := api.NewClient(httpClient, cfg.BaseURL())
 		var body []byte
 		if id, ok := payload["id"]; ok {
-			body, err = client.Put(fmt.Sprintf("/apisix/admin/secrets/%v?gateway_group_id=%s", id, ggID), payload)
+			body, err = client.Put(fmt.Sprintf("/apisix/admin/secret_providers/%v?gateway_group_id=%s", id, ggID), payload)
 		} else {
-			body, err = client.Post("/apisix/admin/secrets?gateway_group_id="+ggID, payload)
+			body, err = client.Post("/apisix/admin/secret_providers?gateway_group_id="+ggID, payload)
 		}
 		if err != nil {
 			return fmt.Errorf("%s", cmdutil.FormatAPIError(err))
@@ -123,7 +123,7 @@ func actionRun(opts *Options) error {
 	}
 
 	client := api.NewClient(httpClient, cfg.BaseURL())
-	body, err := client.Post("/apisix/admin/secrets?gateway_group_id="+ggID, bodyReq)
+	body, err := client.Post("/apisix/admin/secret_providers?gateway_group_id="+ggID, bodyReq)
 	if err != nil {
 		return fmt.Errorf("%s", cmdutil.FormatAPIError(err))
 	}
diff --git a/pkg/cmd/secret/create/create_test.go b/pkg/cmd/secret/create/create_test.go
@@ -33,7 +33,7 @@ func (m *mockConfig) Save() error                                     { return n
 func TestCreateSecret_JSON(t *testing.T) {
 	ios, _, out, _ := iostreams.Test()
 	registry := &httpmock.Registry{}
-	registry.Register(http.MethodPost, "/apisix/admin/secrets", httpmock.JSONResponse(`{"id":"vault/s1","uri":"http://vault","prefix":"kv","token":"tok"}`))
+	registry.Register(http.MethodPost, "/apisix/admin/secret_providers", httpmock.JSONResponse(`{"id":"vault/s1","uri":"http://vault","prefix":"kv","token":"tok"}`))
 
 	opts := &Options{
 		IO:     ios,
diff --git a/pkg/cmd/secret/delete/delete.go b/pkg/cmd/secret/delete/delete.go
@@ -75,7 +75,7 @@ func actionRun(opts *Options) error {
 			return nil
 		}
 	}
-	if _, err := client.Delete("/apisix/admin/secrets/"+opts.ID, query); err != nil {
+	if _, err := client.Delete("/apisix/admin/secret_providers/"+opts.ID, query); err != nil {
 		return fmt.Errorf("%s", cmdutil.FormatAPIError(err))
 	}
 
diff --git a/pkg/cmd/secret/delete/delete_test.go b/pkg/cmd/secret/delete/delete_test.go
@@ -32,7 +32,7 @@ func (m *mockConfig) Save() error                                     { return n
 func TestDeleteSecret(t *testing.T) {
 	ios, _, out, _ := iostreams.Test()
 	registry := &httpmock.Registry{}
-	registry.Register(http.MethodDelete, "/apisix/admin/secrets/vault/s1", httpmock.JSONResponse(`{}`))
+	registry.Register(http.MethodDelete, "/apisix/admin/secret_providers/vault/s1", httpmock.JSONResponse(`{}`))
 
 	opts := &Options{
 		IO:     ios,
diff --git a/pkg/cmd/secret/get/get.go b/pkg/cmd/secret/get/get.go
@@ -61,7 +61,7 @@ func actionRun(opts *Options) error {
 
 	client := api.NewClient(httpClient, cfg.BaseURL())
 	query := map[string]string{"gateway_group_id": ggID}
-	body, err := client.Get("/apisix/admin/secrets/"+opts.ID, query)
+	body, err := client.Get("/apisix/admin/secret_providers/"+opts.ID, query)
 	if err != nil {
 		return fmt.Errorf("%s", cmdutil.FormatAPIError(err))
 	}
diff --git a/pkg/cmd/secret/get/get_test.go b/pkg/cmd/secret/get/get_test.go
@@ -34,7 +34,7 @@ func (m *mockConfig) Save() error                                     { return n
 func TestGetSecret_Table(t *testing.T) {
 	ios, _, out, _ := iostreams.Test()
 	registry := &httpmock.Registry{}
-	registry.Register(http.MethodGet, "/apisix/admin/secrets/vault/s1", httpmock.JSONResponse(`{"id":"vault/s1","uri":"http://vault","prefix":"kv","token":"tok"}`))
+	registry.Register(http.MethodGet, "/apisix/admin/secret_providers/vault/s1", httpmock.JSONResponse(`{"id":"vault/s1","uri":"http://vault","prefix":"kv","token":"tok"}`))
 
 	opts := &Options{
 		IO:     ios,
@@ -64,7 +64,7 @@ func TestGetSecret_Table(t *testing.T) {
 func TestGetSecret_JSON(t *testing.T) {
 	ios, _, out, _ := iostreams.Test()
 	registry := &httpmock.Registry{}
-	registry.Register(http.MethodGet, "/apisix/admin/secrets/vault/s1", httpmock.JSONResponse(`{"id":"vault/s1","uri":"http://vault","prefix":"kv","token":"tok"}`))
+	registry.Register(http.MethodGet, "/apisix/admin/secret_providers/vault/s1", httpmock.JSONResponse(`{"id":"vault/s1","uri":"http://vault","prefix":"kv","token":"tok"}`))
 
 	opts := &Options{
 		IO:     ios,
diff --git a/pkg/cmd/secret/list/list.go b/pkg/cmd/secret/list/list.go
@@ -68,7 +68,7 @@ func actionRun(opts *Options) error {
 	if labelKey != "" {
 		query["label"] = labelKey
 	}
-	body, err := client.Get("/apisix/admin/secrets", query)
+	body, err := client.Get("/apisix/admin/secret_providers", query)
 	if err != nil {
 		return fmt.Errorf("%s", cmdutil.FormatAPIError(err))
 	}
diff --git a/pkg/cmd/secret/list/list_test.go b/pkg/cmd/secret/list/list_test.go
@@ -35,7 +35,7 @@ func TestListSecrets_Table(t *testing.T) {
 	ios, _, out, _ := iostreams.Test()
 	registry := &httpmock.Registry{}
 
-	registry.Register(http.MethodGet, "/apisix/admin/secrets", httpmock.JSONResponse(`{
+	registry.Register(http.MethodGet, "/apisix/admin/secret_providers", httpmock.JSONResponse(`{
 		"total": 1,
 		"list": [{"id":"vault/s1","uri":"http://vault:8200","prefix":"kv"}]
 	}`))
@@ -68,7 +68,7 @@ func TestListSecrets_JSON(t *testing.T) {
 	ios, _, out, _ := iostreams.Test()
 	registry := &httpmock.Registry{}
 
-	registry.Register(http.MethodGet, "/apisix/admin/secrets", httpmock.JSONResponse(`{
+	registry.Register(http.MethodGet, "/apisix/admin/secret_providers", httpmock.JSONResponse(`{
 		"total": 1,
 		"list": [{"id":"vault/s1","uri":"http://vault:8200","prefix":"kv"}]
 	}`))
diff --git a/pkg/cmd/secret/update/update.go b/pkg/cmd/secret/update/update.go
@@ -78,7 +78,7 @@ func actionRun(opts *Options) error {
 			return err
 		}
 		client := api.NewClient(httpClient, cfg.BaseURL())
-		body, err := client.Put("/apisix/admin/secrets/"+opts.ID+"?gateway_group_id="+ggID, payload)
+		body, err := client.Put("/apisix/admin/secret_providers/"+opts.ID+"?gateway_group_id="+ggID, payload)
 		if err != nil {
 			return fmt.Errorf("%s", cmdutil.FormatAPIError(err))
 		}
@@ -108,7 +108,7 @@ func actionRun(opts *Options) error {
 	}
 
 	client := api.NewClient(httpClient, cfg.BaseURL())
-	body, err := client.Put("/apisix/admin/secrets/"+opts.ID+"?gateway_group_id="+ggID, bodyReq)
+	body, err := client.Put("/apisix/admin/secret_providers/"+opts.ID+"?gateway_group_id="+ggID, bodyReq)
 	if err != nil {
 		return fmt.Errorf("%s", cmdutil.FormatAPIError(err))
 	}
diff --git a/pkg/cmd/secret/update/update_test.go b/pkg/cmd/secret/update/update_test.go
@@ -33,7 +33,7 @@ func (m *mockConfig) Save() error                                     { return n
 func TestUpdateSecret_JSON(t *testing.T) {
 	ios, _, out, _ := iostreams.Test()
 	registry := &httpmock.Registry{}
-	registry.Register(http.MethodPut, "/apisix/admin/secrets/vault/s1", httpmock.JSONResponse(`{"id":"vault/s1","uri":"http://vault2","prefix":"kv2","token":"tok2"}`))
+	registry.Register(http.MethodPut, "/apisix/admin/secret_providers/vault/s1", httpmock.JSONResponse(`{"id":"vault/s1","uri":"http://vault2","prefix":"kv2","token":"tok2"}`))
 
 	opts := &Options{
 		IO:     ios,
diff --git a/test/e2e/config_sync_test.go b/test/e2e/config_sync_test.go
@@ -25,7 +25,9 @@ routes:
     upstream:
       type: roundrobin
       nodes:
-        "127.0.0.1:8080": 1
+        - host: "127.0.0.1"
+          port: 8080
+          weight: 1
 `
 	tmpFile := filepath.Join(t.TempDir(), "sync-dryrun.yaml")
 	require.NoError(t, os.WriteFile(tmpFile, []byte(syncYAML), 0644))
@@ -55,7 +57,9 @@ routes:
     upstream:
       type: roundrobin
       nodes:
-        "127.0.0.1:8080": 1
+        - host: "127.0.0.1"
+          port: 8080
+          weight: 1
 `, routeID, routeID)
 
 	syncFile := filepath.Join(t.TempDir(), "sync-create.yaml")
diff --git a/test/e2e/consumer_group_test.go b/test/e2e/consumer_group_test.go
@@ -4,12 +4,9 @@ package e2e
 
 import (
 	"fmt"
-	"os"
-	"path/filepath"
 	"testing"
 
 	"github.com/stretchr/testify/assert"
-	"github.com/stretchr/testify/require"
 )
 
 // deleteConsumerGroupViaAdmin deletes a consumer group via the Admin API.
@@ -22,63 +19,15 @@ func deleteConsumerGroupViaAdmin(t *testing.T, id string) {
 }
 
 func TestConsumerGroup_List(t *testing.T) {
-	env := setupEnv(t)
-
-	stdout, stderr, err := runA7WithEnv(env, "consumer-group", "list", "-g", gatewayGroup)
-	require.NoError(t, err, stderr)
-	assert.NotEmpty(t, stdout)
+	t.Skip("consumer_group is not exposed via API7 EE Admin API")
 }
 
 func TestConsumerGroup_ListJSON(t *testing.T) {
-	env := setupEnv(t)
-
-	stdout, stderr, err := runA7WithEnv(env, "consumer-group", "list", "-g", gatewayGroup, "-o", "json")
-	require.NoError(t, err, stderr)
-	assert.NotEmpty(t, stdout)
+	t.Skip("consumer_group is not exposed via API7 EE Admin API")
 }
 
 func TestConsumerGroup_CRUD(t *testing.T) {
-	env := setupEnv(t)
-	cgID := "e2e-consumer-group-crud"
-	t.Cleanup(func() { deleteConsumerGroupViaAdmin(t, cgID) })
-
-	cgJSON := fmt.Sprintf(`{
-		"id": %q,
-		"plugins": {
-			"limit-count": {
-				"count": 100,
-				"time_window": 60,
-				"key": "remote_addr",
-				"rejected_code": 429
-			}
-		}
-	}`, cgID)
-
-	tmpFile := filepath.Join(t.TempDir(), "consumer-group.json")
-	require.NoError(t, os.WriteFile(tmpFile, []byte(cgJSON), 0644))
-
-	// Create
-	stdout, stderr, err := runA7WithEnv(env, "consumer-group", "create", "-f", tmpFile, "-g", gatewayGroup)
-	require.NoError(t, err, "stdout=%s stderr=%s", stdout, stderr)
-
-	// Get
-	stdout, stderr, err = runA7WithEnv(env, "consumer-group", "get", cgID, "-g", gatewayGroup)
-	require.NoError(t, err, stderr)
-	assert.Contains(t, stdout, cgID)
-
-	// Get JSON
-	stdout, stderr, err = runA7WithEnv(env, "consumer-group", "get", cgID, "-g", gatewayGroup, "-o", "json")
-	require.NoError(t, err, stderr)
-	assert.Contains(t, stdout, "limit-count")
-
-	// Export (use get -o json; export is batch-only with cobra.NoArgs)
-	stdout, stderr, err = runA7WithEnv(env, "consumer-group", "get", cgID, "-g", gatewayGroup, "-o", "json")
-	require.NoError(t, err, stderr)
-	assert.Contains(t, stdout, "limit-count")
-
-	// Delete
-	stdout, stderr, err = runA7WithEnv(env, "consumer-group", "delete", cgID, "--force", "-g", gatewayGroup)
-	require.NoError(t, err, stderr)
+	t.Skip("consumer_group is not exposed via API7 EE Admin API")
 }
 
 func TestConsumerGroup_DeleteNonexistent(t *testing.T) {
diff --git a/test/e2e/credential_test.go b/test/e2e/credential_test.go
@@ -47,6 +47,7 @@ func TestCredential_CRUD(t *testing.T) {
 
 	// Create credential
 	credJSON := `{
+		"name": "e2e-cred-crud",
 		"plugins": {
 			"key-auth": {
 				"key": "e2e-cred-key-12345"
diff --git a/test/e2e/gateway_group_test.go b/test/e2e/gateway_group_test.go
@@ -8,6 +8,7 @@ import (
 	"os"
 	"path/filepath"
 	"testing"
+	"time"
 
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
@@ -112,7 +113,7 @@ func TestGatewayGroup_Alias(t *testing.T) {
 
 func TestGatewayGroup_CRUD(t *testing.T) {
 	env := setupEnv(t)
-	ggName := "E2E Test Gateway Group"
+	ggName := fmt.Sprintf("E2E Test GG %d", time.Now().UnixNano())
 
 	// API7 EE generates UUIDs for gateway groups; custom IDs are not supported.
 	ggJSON := fmt.Sprintf(`{
diff --git a/test/e2e/plugin_config_test.go b/test/e2e/plugin_config_test.go
diff --git a/test/e2e/route_test.go b/test/e2e/route_test.go
diff --git a/test/e2e/secret_test.go b/test/e2e/secret_test.go
diff --git a/test/e2e/service_test.go b/test/e2e/service_test.go
diff --git a/test/e2e/setup_test.go b/test/e2e/setup_test.go

Original file line number	Diff line number	Diff line change
`@@ -157,7 +157,7 @@ func FetchRemoteConfig(client api.Client, gatewayGroup string) (api.ConfigFile`
`157`	`157`	`if err != nil {`
`158`	`158`	`return nil, err`
`159`	`159`	`}`
`160`		`- secrets, err := fetchPaginated[api.Secret](client, "/apisix/admin/secrets", query)`
	`160`	`+ secrets, err := fetchPaginated[api.Secret](client, "/apisix/admin/secret_providers", query)`
`161`	`161`	`if err != nil {`
`162`	`162`	`return nil, err`
`163`	`163`	`}`
Original file line number	Diff line number	Diff line change
`@@ -46,7 +46,7 @@ func registerEmptyResources(reg *httpmock.Registry, skip map[string]bool) {`
`46`	`46`	`"/apisix/admin/consumer_groups",`
`47`	`47`	`"/apisix/admin/stream_routes",`
`48`	`48`	`"/apisix/admin/protos",`
`49`		`- "/apisix/admin/secrets",`
	`49`	`+ "/apisix/admin/secret_providers",`
`50`	`50`	`}`
`51`	`51`	`for _, path := range resources {`
`52`	`52`	`if skip != nil && skip[path] {`
Original file line number	Diff line number	Diff line change
`@@ -45,7 +45,7 @@ func registerEmptyResources(reg *httpmock.Registry, skip map[string]bool) {`
`45`	`45`	`"/apisix/admin/consumer_groups",`
`46`	`46`	`"/apisix/admin/stream_routes",`
`47`	`47`	`"/apisix/admin/protos",`
`48`		`- "/apisix/admin/secrets",`
	`48`	`+ "/apisix/admin/secret_providers",`
`49`	`49`	`}`
`50`	`50`	`for _, path := range resources {`
`51`	`51`	`if skip != nil && skip[path] {`
Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,7 @@ func actionRun(opts *Options) error {`
`83`	`83`	`}`
`84`	`84`
`85`	`85`	`client := api.NewClient(httpClient, cfg.BaseURL())`
`86`		`- body, err := client.Post("/apisix/admin/plugin_metadata/"+pluginName+"?gateway_group_id="+ggID, payload)`
	`86`	`+ body, err := client.Put("/apisix/admin/plugin_metadata/"+pluginName+"?gateway_group_id="+ggID, payload)`
`87`	`87`	`if err != nil {`
`88`	`88`	`return fmt.Errorf("%s", cmdutil.FormatAPIError(err))`
`89`	`89`	`}`
`@@ -113,7 +113,7 @@ func actionRun(opts *Options) error {`
`113`	`113`	`bodyReq := api.PluginMetadata{Metadata: metadata}`
`114`	`114`
`115`	`115`	`client := api.NewClient(httpClient, cfg.BaseURL())`
`116`		`- body, err := client.Post("/apisix/admin/plugin_metadata/"+opts.PluginName+"?gateway_group_id="+ggID, bodyReq)`
	`116`	`+ body, err := client.Put("/apisix/admin/plugin_metadata/"+opts.PluginName+"?gateway_group_id="+ggID, bodyReq)`
`117`	`117`	`if err != nil {`
`118`	`118`	`return fmt.Errorf("%s", cmdutil.FormatAPIError(err))`
`119`	`119`	`}`
Original file line number	Diff line number	Diff line change
`@@ -80,9 +80,9 @@ func actionRun(opts *Options) error {`
`80`	`80`	`client := api.NewClient(httpClient, cfg.BaseURL())`
`81`	`81`	`var body []byte`
`82`	`82`	`if id, ok := payload["id"]; ok {`
`83`		`- body, err = client.Put(fmt.Sprintf("/apisix/admin/secrets/%v?gateway_group_id=%s", id, ggID), payload)`
	`83`	`+ body, err = client.Put(fmt.Sprintf("/apisix/admin/secret_providers/%v?gateway_group_id=%s", id, ggID), payload)`
`84`	`84`	`} else {`
`85`		`- body, err = client.Post("/apisix/admin/secrets?gateway_group_id="+ggID, payload)`
	`85`	`+ body, err = client.Post("/apisix/admin/secret_providers?gateway_group_id="+ggID, payload)`
`86`	`86`	`}`
`87`	`87`	`if err != nil {`
`88`	`88`	`return fmt.Errorf("%s", cmdutil.FormatAPIError(err))`
`@@ -123,7 +123,7 @@ func actionRun(opts *Options) error {`
`123`	`123`	`}`
`124`	`124`
`125`	`125`	`client := api.NewClient(httpClient, cfg.BaseURL())`
`126`		`- body, err := client.Post("/apisix/admin/secrets?gateway_group_id="+ggID, bodyReq)`
	`126`	`+ body, err := client.Post("/apisix/admin/secret_providers?gateway_group_id="+ggID, bodyReq)`
`127`	`127`	`if err != nil {`
`128`	`128`	`return fmt.Errorf("%s", cmdutil.FormatAPIError(err))`
`129`	`129`	`}`