fix up encryption logger: instead if logging when init() to createCon…

…figClient
nacos-group · Dec 1, 2023 · 8646fe2 · 8646fe2
1 parent 355c2fd
commit 8646fe2
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/clients/config_client/config_client.go b/clients/config_client/config_client.go
@@ -131,6 +131,8 @@ func NewConfigClient(nc nacos_client.INacosClient) (*ConfigClient, error) {
 	}
 
 	if clientConfig.OpenKMS {
+		filter.RegisterDefaultConfigEncryptionFilter()
+		nacos_inner_encryption.RegisterConfigEncryptionKmsPlugins()
 		var kmsClient *nacos_inner_encryption.KmsClient
 		switch clientConfig.KMSVersion {
 		case constant.KMSv1, constant.DEFAULT_KMS_VERSION:

diff --git a/common/encryption/kms_plugins.go b/common/encryption/kms_plugins.go
@@ -22,7 +22,7 @@ import (
 	"strings"
 )
 
-func init() {
+func RegisterConfigEncryptionKmsPlugins() {
 	if err := GetDefaultHandler().RegisterPlugin(&KmsAes128Plugin{}); err != nil {
 		logger.Errorf("failed to register encryption plugin[%s] to defaultHandler", KmsAes128AlgorithmName)
 	} else {

diff --git a/common/filter/config_filter.go b/common/filter/config_filter.go
@@ -41,7 +41,7 @@ type IConfigFilter interface {
 	GetFilterName() string
 }
 
-func init() {
+func RegisterDefaultConfigEncryptionFilter() {
 	err := RegisterConfigFilter(GetDefaultConfigFilterChainManager(), GetDefaultConfigEncryptionFilter())
 	if err != nil {
 		logger.Errorf("failed to register configFilter[%s] to DefaultConfigFilterChainManager",