mirror of
https://github.com/langgenius/dify-plugin-daemon.git
synced 2026-07-23 02:05:27 -04:00
Yeuoly
31d7c7417e
* feat: introduce 'run' command for local plugin execution - Added a new command `run` to launch plugins locally, allowing communication through stdin/stdout. - Removed the previous `test` command and its associated functionality to streamline the plugin testing process. * feat: enhance 'run' command with TCP support - Introduced a new `RunPluginPayload` structure to encapsulate plugin execution parameters. - Added TCP communication mode to the `run` command, allowing multiple client connections. - Updated command flags to configure run mode and logging options. - Implemented client handling and server creation for both stdin/stdout and TCP modes. * docs: improve comments in RunPlugin function for clarity - Enhanced comments to provide clearer explanations of the plugin decoding process and the creation of client streams for both stdin/stdout and TCP modes. - Updated comments to reflect the functionality and behavior of the plugin execution flow. * refactor: update command structure and enhance plugin invocation handling - Changed the command structure to add `runPluginCommand` under `pluginCommand` for better organization. - Introduced `InvokePluginPayload` type to encapsulate plugin invocation details. - Enhanced `RunPlugin` function to handle responses and errors more effectively, including logging to stdout. - Updated client handling to support session management and improved error handling during plugin invocation. - Renamed TCP server creation function for consistency. * feat: enhance plugin response handling and logging capabilities - Added a new flag `--response-format` to specify the output format (text or json) for plugin responses. - Introduced a `logger` to manage logging output to stdout with timestamps and file information. - Updated `logResponse` and `systemLog` functions to handle different response formats. - Enhanced `handleClient` and `RunPlugin` functions to utilize the new response format feature. - Implemented signal handling to clean up temporary directories on shutdown. * feat: enhance plugin response structure and logging - Added `InvokeID` to `InvokePluginPayload` and `GenericResponse` for better tracking of plugin invocations. - Updated `logResponse` to include `InvokeID` in error responses for improved debugging. - Enhanced client handling in `handleClient` to log plugin readiness and received requests. - Refactored client stream creation for better readability and consistency. * feat: add plugin invoke end response type and logging - Introduced `GENERIC_RESPONSE_TYPE_PLUGIN_INVOKE_END` to enhance response tracking for plugin invocations. - Updated `handleClient` to log the end of plugin invocation, improving visibility into the plugin lifecycle. * chore: remove fullfeature tags
58 lines
1.3 KiB
Go
58 lines
1.3 KiB
Go
package run
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
|
|
"github.com/langgenius/dify-plugin-daemon/internal/core/plugin_daemon/access_types"
|
|
)
|
|
|
|
type RunMode = string
|
|
|
|
const (
|
|
RUN_MODE_STDIO RunMode = "stdio"
|
|
RUN_MODE_TCP RunMode = "tcp"
|
|
)
|
|
|
|
type RunPluginPayload struct {
|
|
PluginPath string
|
|
RunMode RunMode
|
|
EnableLogs bool
|
|
|
|
TcpServerPort int
|
|
TcpServerHost string
|
|
|
|
ResponseFormat string
|
|
}
|
|
|
|
type client struct {
|
|
reader io.ReadCloser
|
|
writer io.WriteCloser
|
|
cancel context.CancelFunc
|
|
}
|
|
|
|
type InvokePluginPayload struct {
|
|
InvokeID string `json:"invoke_id"`
|
|
Type access_types.PluginAccessType `json:"type"`
|
|
Action access_types.PluginAccessAction `json:"action"`
|
|
|
|
Request map[string]any `json:"request"`
|
|
}
|
|
|
|
type GenericResponseType = string
|
|
|
|
const (
|
|
GENERIC_RESPONSE_TYPE_INFO GenericResponseType = "info"
|
|
GENERIC_RESPONSE_TYPE_PLUGIN_READY GenericResponseType = "plugin_ready"
|
|
GENERIC_RESPONSE_TYPE_ERROR GenericResponseType = "error"
|
|
GENERIC_RESPONSE_TYPE_PLUGIN_RESPONSE GenericResponseType = "plugin_response"
|
|
GENERIC_RESPONSE_TYPE_PLUGIN_INVOKE_END GenericResponseType = "plugin_invoke_end"
|
|
)
|
|
|
|
type GenericResponse struct {
|
|
InvokeID string `json:"invoke_id"`
|
|
Type GenericResponseType `json:"type"`
|
|
|
|
Response map[string]any `json:"response"`
|
|
}
|