executor

type Adapter interface {
	// Config 适配器配置
	Config(ctx context.Context, config map[string]any) error
}

type Bridge interface {
	// Conn 连接到环境中
	Conn(ctx context.Context, adapter Adapter) (Executor, error)
}

type CommandWrapper struct {
	StepName string            // 步骤名称
	Command  string            // 要执行的命令
	Env      map[string]string // 命令级环境变量（已渲染终值）：执行器尽量以真实进程
	// 环境变量注入；不支持时在命令前拼接单引号转义的 export 行
	// CaptureOutput 标记"输出必须完整送达"的步骤（节点声明了 extract）：
	// 输出块是下游节点的数据来源，一旦丢失会让下游报"缺参"而掩盖真因。
	// 仅 docker 执行器使用：它在容器内加 tee 兜底（落盘 + 断流后补齐尾部）。
	CaptureOutput bool
}

type Executor interface {
	// Prepare 准备环境
	Prepare(ctx context.Context) error
	// Destruction 销毁环境
	Destruction(ctx context.Context) error
	// Transfer 从 commandChan 接收命令执行，并将结果发送到 resultChan
	// inputChan 用于接收交互式输入数据，可为 nil（不需要输入时）
	Transfer(ctx context.Context, resultChan chan<- any, commandChan <-chan any, inputChan <-chan []byte)
}

type ExecutorInfoProvider interface {
	// GetRuntimeInfo 获取executor特定的运行时信息
	GetRuntimeInfo() map[string]any
	// GetInstanceId 获取executor实例ID (容器ID/Pod名称等)
	GetInstanceId() string
	// GetType 获取executor类型
	GetType() string
}

type ExecutorProvider interface {
	// GetExecutor 根据执行器名称返回对应的Executor实例
	GetExecutor(ctx context.Context, name string) (Executor, error)
}

type InputReadyEvent struct {
	StepName string // 步骤名称
}

type InputRequest struct {
	Prompt  string `json:"prompt"`  // 显示给用户的提示信息
	Type    string `json:"type"`    // 输入类型: text/password/confirm
	Timeout int    `json:"timeout"` // 等待超时（秒），0表示使用默认值
}

type InputRequestEvent struct {
	StepName string        // 步骤名称
	Request  *InputRequest // 输入请求详情
}

type StepResult struct {
	StepName   string
	Command    string
	Output     string
	Error      error
	StartTime  time.Time
	FinishTime time.Time
	// StreamTruncated 标记输出流曾被中断（已尽力重挂续读）。
	// docker 执行器专用：cpolar 等隧道下的 docker exec 流会被中途掐断，
	// 命令仍能跑完（ExitCode=0）但尾部输出丢失——节点输出块往往就在尾部，
	// 丢失会让下游报“缺参”（exec 364 事故）。宿主可据此提示“输出可能不完整”。
	StreamTruncated bool
}