refactor(plugin): improved initialization of the KV storage plugin

Author: sosyz

internal/service/plugin_common/plugin_common_service.go

@@ -135,9 +135,13 @@ func (ps *PluginCommonService) GetUserPluginConfig(ctx context.Context, req *sch
 }
 
 func (ps *PluginCommonService) initPluginData() {
-	plugin.SetKVStorageDB(&plugin.Data{
-		DB:    ps.data.DB,
-		Cache: ps.data.Cache,
+	_ = plugin.CallKVStorage(func(k plugin.KVStorage) error {
+		k.SetOperator(plugin.NewKVOperator(
+			ps.data.DB,
+			ps.data.Cache,
+			k.Info().SlugName,
+		))
+		return nil
 	})
 
 	// init plugin status

plugin/kv_storage.go

@@ -323,22 +323,16 @@ type KVStorage interface {
 }
 
 var (
-	_,
-	registerPluginKVStorage = func() (CallFn[KVStorage], RegisterFn[KVStorage]) {
-		callFn, registerFn := MakePlugin[KVStorage](false)
-		return callFn, func(p KVStorage) {
-			registerFn(p)
-			kvStoragePluginStack.plugins = append(kvStoragePluginStack.plugins, p)
-		}
-	}()
-	kvStoragePluginStack = &Stack[KVStorage]{}
+	CallKVStorage,
+	registerKVStorage = MakePlugin[KVStorage](true)
 )
 
-func SetKVStorageDB(data *Data) {
-	for _, p := range kvStoragePluginStack.plugins {
-		p.SetOperator(&KVOperator{
-			data:           data,
-			pluginSlugName: p.Info().SlugName,
-		})
+// NewKVOperator creates a new KV storage operator with the specified database engine, cache and plugin name.
+// It returns a KVOperator instance that can be used to interact with the plugin's storage.
+func NewKVOperator(db *xorm.Engine, cache cache.Cache, pluginSlugName string) *KVOperator {
+	return &KVOperator{
+		data:           &Data{DB: db, Cache: cache},
+		pluginSlugName: pluginSlugName,
+		cacheTTL:       30 * time.Minute,
 	}
 }

plugin/plugin.go

@@ -124,7 +124,7 @@ func Register(p Base) {
 	}
 
 	if _, ok := p.(KVStorage); ok {
-		registerPluginKVStorage(p.(KVStorage))
+		registerKVStorage(p.(KVStorage))
 	}
 }