refactor: nacos configstore component.

support level1 config functions.
support connect to nacos use acm mode.
fix error in filling in illegal characters when calling nacos set and delete parameters

components/configstores/nacos/change_listener.go

@@ -24,6 +24,7 @@ type subscriberHolder struct {
 type subscriberKey struct {
 	group string
 	key   string
+	label string
 }
 
 func newSubscriberHolder() *subscriberHolder {

components/configstores/nacos/change_listener_test.go

@@ -14,8 +14,9 @@
 package nacos
 
 import (
-	"github.com/stretchr/testify/assert"
 	"testing"
+
+	"github.com/stretchr/testify/assert"
 )
 
 func Test_newSubscriberHolder(t *testing.T) {

components/configstores/nacos/nacos_client.go → components/configstores/nacos/client.go

@@ -18,7 +18,7 @@ import (
 	"github.com/nacos-group/nacos-sdk-go/v2/vo"
 )
 
-type NacosConfigClient interface {
+type Client interface {
 	// GetConfig use to get config from nacos server
 	// dataId  require
 	// group   require

components/configstores/nacos/config.go

@@ -13,33 +13,37 @@
 
 package nacos
 
-const (
-	defaultNamespaceId = "" // if this is not set, then nacos will use the default namespaceId.
-	defaultGroup       = "default"
-	defaultLabel       = "default"
-	defaultLogDir      = "/tmp/layotto/nacos/log"
-	defaultCacheDir    = "/tmp/layotto/nacos/cache"
-	defaultLogLevel    = "debug"
-	defaultTimeout     = 10 // second
-)
-
 // map keys
 const (
 	namespaceIdKey = "namespace_id"
 	appNameKey     = "app_name"
+	userNameKey    = "username"
+	passwordKey    = "password"
+	endPointKey    = "end_point"
+	regionIdKey    = "region_id"
+	accessKey      = "access_key"
+	secretKey      = "secret_key"
 )
 
-type NacosMetadata struct {
+type Metadata struct {
 	AppName     string
 	NameSpaceId string
+	Username    string
+	Password    string
+	// ACM & KMS
+	Endpoint  string
+	RegionId  string
+	AccessKey string
+	SecretKey string
+	OpenKMS   bool
 }
 
-func ParseNacosMetadata(properties map[string]string) (*NacosMetadata, error) {
+func ParseNacosMetadata(properties map[string]string) (*Metadata, error) {
 	if properties == nil {
 		return nil, errConfigMissingField("metadata")
 	}
 
-	config := &NacosMetadata{}
+	config := &Metadata{}
 	config.AppName = properties[appNameKey]
 	if config.AppName == "" {
 		return nil, errConfigMissingField(appNameKey)
@@ -51,5 +55,34 @@ func ParseNacosMetadata(properties map[string]string) (*NacosMetadata, error) {
 		config.NameSpaceId = defaultNamespaceId
 	}
 
+	if v, ok := properties[userNameKey]; ok && v != "" {
+		config.Username = v
+	}
+
+	if v, ok := properties[passwordKey]; ok && v != "" {
+		config.Password = v
+	}
+
+	// ACM & KMS
+	if v, ok := properties[endPointKey]; ok && v != "" {
+		config.Endpoint = v
+		config.OpenKMS = true
+	}
+
+	if v, ok := properties[regionIdKey]; ok && v != "" {
+		config.RegionId = v
+		config.OpenKMS = true
+	}
+
+	if v, ok := properties[accessKey]; ok && v != "" {
+		config.AccessKey = v
+		config.OpenKMS = true
+	}
+
+	if v, ok := properties[secretKey]; ok && v != "" {
+		config.SecretKey = v
+		config.OpenKMS = true
+	}
+
 	return config, nil
 }

components/configstores/nacos/config_test.go

@@ -14,8 +14,9 @@
 package nacos
 
 import (
-	"github.com/stretchr/testify/assert"
 	"testing"
+
+	"github.com/stretchr/testify/assert"
 )
 
 func TestParseNacosMetadata(t *testing.T) {