mirror of
https://github.com/langgenius/dify-plugin-daemon.git
synced 2026-07-23 02:05:27 -04:00
Harry
27f3d3ad8d
- Renamed TriggerInvoke function and associated request/response types to TriggerInvokeEvent for improved clarity. - Updated routing and controller methods to reflect the new naming convention. - Ensured all references to the trigger invoke functionality are consistent with the new event terminology.
88 lines
2.2 KiB
Go
88 lines
2.2 KiB
Go
// Code generated by controller generator. DO NOT EDIT.
|
|
|
|
package plugin_daemon
|
|
|
|
import (
|
|
"github.com/langgenius/dify-plugin-daemon/internal/core/session_manager"
|
|
"github.com/langgenius/dify-plugin-daemon/internal/utils/stream"
|
|
"github.com/langgenius/dify-plugin-daemon/pkg/entities/requests"
|
|
)
|
|
|
|
func TriggerInvokeEvent(
|
|
session *session_manager.Session,
|
|
request *requests.TriggerInvokeEventRequest,
|
|
) (
|
|
*stream.Stream[requests.TriggerInvokeEventResponse], error,
|
|
) {
|
|
return GenericInvokePlugin[requests.TriggerInvokeEventRequest, requests.TriggerInvokeEventResponse](
|
|
session,
|
|
request,
|
|
512,
|
|
)
|
|
}
|
|
|
|
func TriggerValidateProviderCredentials(
|
|
session *session_manager.Session,
|
|
request *requests.TriggerValidateProviderCredentialsRequest,
|
|
) (
|
|
*stream.Stream[requests.TriggerValidateProviderCredentialsResponse], error,
|
|
) {
|
|
return GenericInvokePlugin[requests.TriggerValidateProviderCredentialsRequest, requests.TriggerValidateProviderCredentialsResponse](
|
|
session,
|
|
request,
|
|
1,
|
|
)
|
|
}
|
|
|
|
func TriggerDispatchEvent(
|
|
session *session_manager.Session,
|
|
request *requests.TriggerDispatchEventRequest,
|
|
) (
|
|
*stream.Stream[requests.TriggerDispatchEventResponse], error,
|
|
) {
|
|
return GenericInvokePlugin[requests.TriggerDispatchEventRequest, requests.TriggerDispatchEventResponse](
|
|
session,
|
|
request,
|
|
512,
|
|
)
|
|
}
|
|
|
|
func TriggerSubscribe(
|
|
session *session_manager.Session,
|
|
request *requests.TriggerSubscribeRequest,
|
|
) (
|
|
*stream.Stream[requests.TriggerSubscribeResponse], error,
|
|
) {
|
|
return GenericInvokePlugin[requests.TriggerSubscribeRequest, requests.TriggerSubscribeResponse](
|
|
session,
|
|
request,
|
|
1,
|
|
)
|
|
}
|
|
|
|
func TriggerUnsubscribe(
|
|
session *session_manager.Session,
|
|
request *requests.TriggerUnsubscribeRequest,
|
|
) (
|
|
*stream.Stream[requests.TriggerUnsubscribeResponse], error,
|
|
) {
|
|
return GenericInvokePlugin[requests.TriggerUnsubscribeRequest, requests.TriggerUnsubscribeResponse](
|
|
session,
|
|
request,
|
|
1,
|
|
)
|
|
}
|
|
|
|
func TriggerRefresh(
|
|
session *session_manager.Session,
|
|
request *requests.TriggerRefreshRequest,
|
|
) (
|
|
*stream.Stream[requests.TriggerRefreshResponse], error,
|
|
) {
|
|
return GenericInvokePlugin[requests.TriggerRefreshRequest, requests.TriggerRefreshResponse](
|
|
session,
|
|
request,
|
|
1,
|
|
)
|
|
}
|