feat: support nacos configstore component (level1)

cmd/layotto/main.go

@@ -65,6 +65,7 @@ import (
 	"mosn.io/pkg/log"
 
 	"mosn.io/layotto/components/configstores/etcdv3"
+	"mosn.io/layotto/components/configstores/nacos"
 	"mosn.io/layotto/components/file"
 	"mosn.io/layotto/components/sequencer"
 	"mosn.io/layotto/pkg/runtime/bindings"
@@ -278,6 +279,7 @@ func NewRuntimeGrpcServer(data json.RawMessage, opts ...grpc.ServerOption) (mgrp
 		runtime.WithConfigStoresFactory(
 			configstores.NewStoreFactory("apollo", apollo.NewStore),
 			configstores.NewStoreFactory("etcd", etcdv3.NewStore),
+			configstores.NewStoreFactory("nacos", nacos.NewStore),
 		),
 
 		// RPC

cmd/layotto_multiple_api/main.go

@@ -85,6 +85,7 @@ import (
 	// Configuration
 	"mosn.io/layotto/components/configstores"
 	"mosn.io/layotto/components/configstores/apollo"
+	"mosn.io/layotto/components/configstores/nacos"
 
 	// Pub/Sub
 	dapr_comp_pubsub "github.com/dapr/components-contrib/pubsub"
@@ -288,6 +289,7 @@ func NewRuntimeGrpcServer(data json.RawMessage, opts ...grpc.ServerOption) (mgrp
 		runtime.WithConfigStoresFactory(
 			configstores.NewStoreFactory("apollo", apollo.NewStore),
 			configstores.NewStoreFactory("etcd", etcdv3.NewStore),
+			configstores.NewStoreFactory("nacos", nacos.NewStore),
 		),
 
 		// RPC

cmd/layotto_without_xds/main.go

@@ -63,6 +63,7 @@ import (
 	"mosn.io/pkg/log"
 
 	"mosn.io/layotto/components/configstores/etcdv3"
+	"mosn.io/layotto/components/configstores/nacos"
 	"mosn.io/layotto/components/file"
 	"mosn.io/layotto/components/sequencer"
 	"mosn.io/layotto/pkg/runtime/bindings"
@@ -261,6 +262,7 @@ func NewRuntimeGrpcServer(data json.RawMessage, opts ...grpc.ServerOption) (mgrp
 		runtime.WithConfigStoresFactory(
 			configstores.NewStoreFactory("apollo", apollo.NewStore),
 			configstores.NewStoreFactory("etcd", etcdv3.NewStore),
+			configstores.NewStoreFactory("nacos", nacos.NewStore),
 		),
 
 		// RPC

components/configstores/nacos/client.go

@@ -0,0 +1,65 @@
+// Copyright 2021 Layotto Authors
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package nacos
+
+import (
+	"github.com/nacos-group/nacos-sdk-go/v2/model"
+	"github.com/nacos-group/nacos-sdk-go/v2/vo"
+)
+
+type Client interface {
+	// GetConfig use to get config from nacos server
+	// dataId  require
+	// group   require
+	// tenant ==>nacos.namespace optional
+	GetConfig(param vo.ConfigParam) (string, error)
+
+	// PublishConfig use to publish config to nacos server
+	// dataId  require
+	// group   require
+	// content require
+	// tenant ==>nacos.namespace optional
+	PublishConfig(param vo.ConfigParam) (bool, error)
+
+	// DeleteConfig use to delete config
+	// dataId  require
+	// group   require
+	// tenant ==>nacos.namespace optional
+	DeleteConfig(param vo.ConfigParam) (bool, error)
+
+	// ListenConfig use to listen config change,it will callback OnChange() when config change
+	// dataId  require
+	// group   require
+	// onchange require
+	// tenant ==>nacos.namespace optional
+	ListenConfig(params vo.ConfigParam) (err error)
+
+	//CancelListenConfig use to cancel listen config change
+	// dataId  require
+	// group   require
+	// tenant ==>nacos.namespace optional
+	CancelListenConfig(params vo.ConfigParam) (err error)
+
+	// SearchConfig use to search nacos config
+	// search  require search=accurate--精确搜索  search=blur--模糊搜索
+	// group   option
+	// dataId  option
+	// tenant ==>nacos.namespace optional
+	// pageNo  option,default is 1
+	// pageSize option,default is 10
+	SearchConfig(param vo.SearchConfigParam) (*model.ConfigPage, error)
+
+	// CloseClient Close the GRPC client
+	CloseClient()
+}

components/configstores/nacos/config.go

@@ -0,0 +1,105 @@
+// Copyright 2021 Layotto Authors
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package nacos
+
+// map keys
+const (
+	namespaceIdKey = "namespace_id"
+	userNameKey    = "username"
+	passwordKey    = "password"
+	endPointKey    = "end_point"
+	regionIdKey    = "region_id"
+	accessKey      = "access_key"
+	secretKey      = "secret_key"
+	logDirKey      = "log_dir"
+	cacheDirKey    = "cache_dir"
+	logLevelKey    = "log_level" // support debug, info, warn, error
+)
+
+type Metadata struct {
+	NameSpaceId string
+	Username    string
+	Password    string
+	// ACM & KMS
+	Endpoint  string
+	RegionId  string
+	AccessKey string
+	SecretKey string
+	OpenKMS   bool
+	// log & cache files
+	LogDir   string
+	CacheDir string
+	LogLevel string
+}
+
+func ParseNacosMetadata(properties map[string]string) (*Metadata, error) {
+	if properties == nil {
+		return nil, errConfigMissingField("metadata")
+	}
+
+	config := &Metadata{}
+
+	// the namespace of config, not required
+	config.NameSpaceId = properties[namespaceIdKey]
+	if config.NameSpaceId == "" {
+		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
+	}
+
+	// log & cache files
+	config.LogDir = properties[logDirKey]
+	if config.LogDir == "" {
+		config.LogDir = defaultLogDir
+	}
+
+	config.LogLevel = properties[logLevelKey]
+	if config.LogLevel == "" {
+		config.LogLevel = defaultLogLevel
+	}
+
+	config.CacheDir = properties[cacheDirKey]
+	if config.CacheDir == "" {
+		config.CacheDir = defaultCacheDir
+	}
+
+	return config, nil
+}

components/configstores/nacos/config_test.go

@@ -0,0 +1,39 @@
+// Copyright 2021 Layotto Authors
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+// http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package nacos
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/assert"
+)
+
+func TestParseNacosMetadata(t *testing.T) {
+	// without metadata
+	_, err := ParseNacosMetadata(nil)
+	assert.Error(t, err)
+
+	properties := make(map[string]string)
+
+	// success
+	_, err = ParseNacosMetadata(properties)
+	assert.Nil(t, err)
+
+	// test set namespace
+	namespaceId := "namespace"
+	properties[namespaceIdKey] = namespaceId
+	metadata, err := ParseNacosMetadata(properties)
+	assert.Nil(t, err)
+	assert.Equal(t, namespaceId, metadata.NameSpaceId)
+}