dify-plugin-daemon/cmd/commandline/run/entities.go

package run

import (
	"context"
	"io"

	"github.com/langgenius/dify-plugin-daemon/internal/core/io_tunnel/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"`
}