mirror of
https://github.com/langgenius/dify-plugin-daemon.git
synced 2026-07-23 02:05:27 -04:00
Maries
a0414b30e6
* feat(oauth): add RedirectURI field to OAuth request structures * feat(oauth): update OAuthSchema validation * feat: add Context field to request and session structures * feat: add CredentialType field to Credentials and InvokeToolRequest structures * fix: handle unhandled default case in basic_type.go * feat: add support for build branches in build-push.yml
52 lines
1.5 KiB
Go
52 lines
1.5 KiB
Go
package service
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"github.com/langgenius/dify-plugin-daemon/internal/core/plugin_daemon/access_types"
|
|
"github.com/langgenius/dify-plugin-daemon/internal/core/plugin_manager"
|
|
"github.com/langgenius/dify-plugin-daemon/internal/core/session_manager"
|
|
"github.com/langgenius/dify-plugin-daemon/pkg/entities/plugin_entities"
|
|
)
|
|
|
|
func createSession[T any](
|
|
r *plugin_entities.InvokePluginRequest[T],
|
|
access_type access_types.PluginAccessType,
|
|
access_action access_types.PluginAccessAction,
|
|
cluster_id string,
|
|
) (*session_manager.Session, error) {
|
|
manager := plugin_manager.Manager()
|
|
if manager == nil {
|
|
return nil, errors.New("failed to get plugin manager")
|
|
}
|
|
|
|
// try fetch plugin identifier from plugin id
|
|
|
|
runtime, err := manager.Get(r.UniqueIdentifier)
|
|
if err != nil {
|
|
return nil, errors.New("failed to get plugin runtime")
|
|
}
|
|
|
|
session := session_manager.NewSession(
|
|
session_manager.NewSessionPayload{
|
|
TenantID: r.TenantId,
|
|
UserID: r.UserId,
|
|
PluginUniqueIdentifier: r.UniqueIdentifier,
|
|
ClusterID: cluster_id,
|
|
InvokeFrom: access_type,
|
|
Action: access_action,
|
|
Declaration: runtime.Configuration(),
|
|
BackwardsInvocation: manager.BackwardsInvocation(),
|
|
IgnoreCache: false,
|
|
ConversationID: r.ConversationID,
|
|
MessageID: r.MessageID,
|
|
AppID: r.AppID,
|
|
EndpointID: r.EndpointID,
|
|
Context: r.Context,
|
|
},
|
|
)
|
|
|
|
session.BindRuntime(runtime)
|
|
return session, nil
|
|
}
|