mirror of
https://github.com/langgenius/dify-plugin-daemon.git
synced 2026-07-23 02:05:27 -04:00
Yeuoly
5f8072c982
* refactor: update PluginManager to use configuration for various configurations - Replaced hardcoded values in PluginManager methods with values from the configuration. - Updated serverless plugin launch timeout and working paths to utilize the new configuration structure. - Enhanced local plugin runtime initialization to pull settings from the configuration, improving maintainability and flexibility. * refactor: clean up PluginManager by removing unused fields and updating platform check - Removed commented-out fields from PluginManager to enhance code clarity. - Updated platform check to utilize the configuration structure instead of a direct field reference, improving maintainability.
104 lines
3.1 KiB
Go
104 lines
3.1 KiB
Go
package plugin_manager
|
|
|
|
import (
|
|
"fmt"
|
|
"time"
|
|
|
|
"github.com/langgenius/dify-plugin-daemon/internal/core/plugin_manager/basic_runtime"
|
|
"github.com/langgenius/dify-plugin-daemon/internal/core/plugin_manager/serverless_runtime"
|
|
"github.com/langgenius/dify-plugin-daemon/internal/db"
|
|
"github.com/langgenius/dify-plugin-daemon/internal/types/models"
|
|
"github.com/langgenius/dify-plugin-daemon/internal/utils/cache"
|
|
"github.com/langgenius/dify-plugin-daemon/internal/utils/cache/helper"
|
|
"github.com/langgenius/dify-plugin-daemon/pkg/entities/plugin_entities"
|
|
)
|
|
|
|
const (
|
|
PLUGIN_SERVERLESS_CACHE_KEY = "serverless:runtime:%s"
|
|
)
|
|
|
|
func (p *PluginManager) getServerlessRuntimeCacheKey(
|
|
identity plugin_entities.PluginUniqueIdentifier,
|
|
) string {
|
|
return fmt.Sprintf(PLUGIN_SERVERLESS_CACHE_KEY, identity.String())
|
|
}
|
|
|
|
func (p *PluginManager) getServerlessPluginRuntime(
|
|
identity plugin_entities.PluginUniqueIdentifier,
|
|
) (plugin_entities.PluginLifetime, error) {
|
|
model, err := p.getServerlessPluginRuntimeModel(identity)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// FIXME: get declaration
|
|
declaration, err := helper.CombinedGetPluginDeclaration(identity, plugin_entities.PLUGIN_RUNTIME_TYPE_SERVERLESS)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// init runtime entity
|
|
runtimeEntity := plugin_entities.PluginRuntime{
|
|
Config: *declaration,
|
|
}
|
|
runtimeEntity.InitState()
|
|
|
|
// convert to plugin runtime
|
|
pluginRuntime := serverless_runtime.ServerlessPluginRuntime{
|
|
BasicChecksum: basic_runtime.BasicChecksum{
|
|
MediaTransport: basic_runtime.NewMediaTransport(p.mediaBucket),
|
|
InnerChecksum: model.Checksum,
|
|
},
|
|
PluginRuntime: runtimeEntity,
|
|
LambdaURL: model.FunctionURL,
|
|
LambdaName: model.FunctionName,
|
|
PluginMaxExecutionTimeout: p.config.PluginMaxExecutionTimeout,
|
|
}
|
|
|
|
if err := pluginRuntime.InitEnvironment(); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &pluginRuntime, nil
|
|
}
|
|
|
|
func (p *PluginManager) getServerlessPluginRuntimeModel(
|
|
identity plugin_entities.PluginUniqueIdentifier,
|
|
) (*models.ServerlessRuntime, error) {
|
|
// check if plugin is a serverless runtime
|
|
runtime, err := cache.Get[models.ServerlessRuntime](
|
|
p.getServerlessRuntimeCacheKey(identity),
|
|
)
|
|
if err != nil && err != cache.ErrNotFound {
|
|
return nil, fmt.Errorf("unexpected error occurred during fetch serverless runtime cache: %v", err)
|
|
}
|
|
|
|
if err == cache.ErrNotFound {
|
|
runtimeModel, err := db.GetOne[models.ServerlessRuntime](
|
|
db.Equal("plugin_unique_identifier", identity.String()),
|
|
)
|
|
|
|
if err == db.ErrDatabaseNotFound {
|
|
return nil, fmt.Errorf("plugin serverless runtime not found: %s", identity.String())
|
|
}
|
|
|
|
if err != nil {
|
|
return nil, fmt.Errorf("failed to load serverless runtime from db: %v", err)
|
|
}
|
|
|
|
cache.Store(p.getServerlessRuntimeCacheKey(identity), runtimeModel, time.Minute*30)
|
|
runtime = &runtimeModel
|
|
} else if err != nil {
|
|
return nil, fmt.Errorf("failed to load serverless runtime from cache: %v", err)
|
|
}
|
|
|
|
return runtime, nil
|
|
}
|
|
|
|
func (p *PluginManager) clearServerlessRuntimeCache(
|
|
identity plugin_entities.PluginUniqueIdentifier,
|
|
) error {
|
|
_, err := cache.Del(p.getServerlessRuntimeCacheKey(identity))
|
|
return err
|
|
}
|