runner

type ApprovalConfig struct {
	Title      string   `json:"title"`        // 审批标题（必填）
	Content    string   `json:"content"`      // 审批内容（支持Markdown）
	Context    string   `json:"context"`      // 审批上下文（JSON格式，包含相关数据）
	UserIDs    []string `json:"user_ids"`     // 审批人用户ID列表
	AIAgentIDs []string `json:"ai_agent_ids"` // AI审批实体ID列表
	RequireAll bool     `json:"require_all"`  // 是否需要所有人都审批（默认false，任意一人即可）
	Timeout    int      `json:"timeout"`      // 审批超时时间（秒，可选，默认使用Task.Timeout，若Task.Timeout也为空则为3600）
	Metadata   string   `json:"metadata"`     // 扩展元数据（JSON格式）
}

type ApprovalRunner struct {
	BaseRunner // 🔥 嵌入基类
	// contains filtered or unexported fields
}

type BaseRunner struct {
	// 🔥 公共字段 - 子类可直接访问
	Task      *core.Task         // 任务对象
	Status    core.Status        // 当前状态
	Result    *core.Result       // 执行结果
	Apiserver core.Apiserver     // API Server 客户端
	Ctx       context.Context    // 执行上下文
	Cancel    context.CancelFunc // 取消函数
	StartTime time.Time          // 开始时间
	// contains filtered or unexported fields
}

type CommandRunner struct {
	BaseRunner // 🔥 嵌入基类
	// contains filtered or unexported fields
}

type CommandSecurity struct {
	// contains filtered or unexported fields
}

type ContainerConfig struct {
	Action string `json:"action"` // build/run/push/pull/stop/restart/remove/logs/exec/inspect/prune/stats

	// ========== 运行时配置 ==========
	Runtime    string `json:"runtime"`    // docker/containerd (默认 docker)
	Connection string `json:"connection"` // unix/tcp (默认 unix)

	// Unix Socket 连接（本地）
	Socket string `json:"socket"` // /var/run/docker.sock 或 /run/containerd/containerd.sock

	// TCP 连接（远程，仅 Docker）
	Host    string `json:"host"`     // docker-proxy:2376
	TLS     bool   `json:"tls"`      // 是否启用 TLS
	TLSCred string `json:"tls_cred"` // TLS 凭证 ID（key_value 类型）

	// containerd 特定
	Namespace    string `json:"namespace"`     // containerd namespace（默认 default）
	BuildkitAddr string `json:"buildkit_addr"` // buildkit 地址（镜像构建）

	// ========== build 字段 ==========
	Dockerfile string            `json:"dockerfile"` // Dockerfile 路径
	Context    string            `json:"context"`    // 构建上下文
	Tags       []string          `json:"tags"`       // 镜像标签
	BuildArgs  map[string]string `json:"build_args"` // 构建参数
	NoCache    bool              `json:"no_cache"`   // 不使用缓存
	Pull       bool              `json:"pull"`       // 拉取最新基础镜像

	// ========== run 字段 ==========
	Image      string   `json:"image"`      // 镜像名称
	Name       string   `json:"name"`       // 容器名称
	Ports      []string `json:"ports"`      // 端口映射 ["80:80", "443:443"]
	Volumes    []string `json:"volumes"`    // 卷挂载 ["/host:/container"]
	Env        []string `json:"env"`        // 环境变量 ["KEY=VALUE"]
	Network    string   `json:"network"`    // 网络
	Restart    string   `json:"restart"`    // 重启策略
	Detach     bool     `json:"detach"`     // 后台运行
	Remove     bool     `json:"remove"`     // 退出后删除
	Command    []string `json:"command"`    // 覆盖 CMD
	Entrypoint []string `json:"entrypoint"` // 覆盖 ENTRYPOINT

	// ========== push/pull 字段 ==========
	Registry     string `json:"registry"`      // 镜像仓库
	RegistryCred string `json:"registry_cred"` // Registry 凭证 ID（username_password）
	TagLatest    bool   `json:"tag_latest"`    // 同时推送 latest 标签

	// ========== stop/start/restart 字段 ==========
	Container string `json:"container"` // 容器名或 ID
	Timeout   int    `json:"timeout"`   // 停止超时（秒）

	// ========== remove 字段 ==========
	Force         bool `json:"force"`          // 强制删除
	RemoveVolumes bool `json:"remove_volumes"` // 删除关联卷

	// ========== prune 字段 ==========
	Type    string            `json:"type"`    // image/container/volume/network/all
	Filters map[string]string `json:"filters"` // dangling=true, until=24h

	// ========== logs 字段 ==========
	Lines      int  `json:"lines"`      // 显示行数
	Follow     bool `json:"follow"`     // 持续输出
	Timestamps bool `json:"timestamps"` // 显示时间戳
	Tail       int  `json:"tail"`       // 从末尾开始

	// ========== exec 字段 ==========
	ExecCommand []string `json:"exec_command"` // 要执行的命令
	Interactive bool     `json:"interactive"`  // 交互模式
	TTY         bool     `json:"tty"`          // 分配 TTY

	// ========== inspect 字段 ==========
	CheckHealth bool `json:"check_health"` // 检查健康状态
}

type ContainerRunner struct {
	BaseRunner // 🔥 嵌入基类
	// contains filtered or unexported fields
}

type DatabaseConfig struct {
	DBType       string        `json:"db_type"`       // 数据库类型：mysql/postgresql/redis
	CredentialID string        `json:"credential_id"` // 凭证ID（username_password类型）
	Host         string        `json:"host"`          // 主机地址
	Port         int           `json:"port"`          // 端口
	Database     string        `json:"database"`      // 数据库名（MySQL/PostgreSQL）或 DB序号（Redis，0-15）
	SQL          string        `json:"sql"`           // SQL语句（MySQL/PostgreSQL）
	Command      string        `json:"command"`       // Redis命令（Redis专用）
	Args         []string      `json:"args"`          // Redis命令参数（Redis专用）
	Params       []interface{} `json:"params"`        // SQL参数（可选，用于参数化查询）
	MaxRows      int           `json:"max_rows"`      // 最大返回/导出行数，默认10000
	ExportExcel  bool          `json:"export_excel"`  // 是否导出Excel（仅SELECT有效）

}

type DatabaseRunner struct {
	BaseRunner // 🔥 嵌入基类
	// contains filtered or unexported fields
}

type EmailSender struct{}

type FeishuBotSender struct {
	// contains filtered or unexported fields
}

type FileConfig struct {
	Action string `json:"action"` // cleanup/backup/compress/stat

	// 远程连接（可选，为空则本地操作）
	Host       string `json:"host"`       // 远程主机地址
	Port       int    `json:"port"`       // SSH 端口（默认 22）
	Credential string `json:"credential"` // 凭证 ID
	Username   string `json:"username"`   // SSH 用户名（默认 root）

	// 通用字段
	Path      string `json:"path"`      // 目标路径
	Pattern   string `json:"pattern"`   // 文件匹配模式
	Recursive bool   `json:"recursive"` // 递归子目录

	// cleanup 专用
	OlderThan  string   `json:"older_than"`  // 7d, 30d, 90d
	LargerThan string   `json:"larger_than"` // 100M, 1G
	DryRun     bool     `json:"dry_run"`     // 试运行模式
	Exclude    []string `json:"exclude"`     // 排除路径

	// backup 专用
	Source      string `json:"source"`      // 源路径
	Target      string `json:"target"`      // 目标路径
	Compress    bool   `json:"compress"`    // 是否压缩
	Incremental bool   `json:"incremental"` // 增量备份
	KeepDays    int    `json:"keep_days"`   // 保留天数

	// compress 专用
	Format       string `json:"format"`        // tar.gz, zip
	RemoveSource bool   `json:"remove_source"` // 压缩后删除源
	Level        int    `json:"level"`         // 压缩级别

	// stat 专用
	SortBy string `json:"sort_by"` // size/time/name
	Limit  int    `json:"limit"`   // 返回数量
}

type FileRunner struct {
	BaseRunner // 🔥 嵌入基类
	// contains filtered or unexported fields
}

type GitConfig struct {
	// URL 仓库地址（必填）
	// 支持 SSH: git@github.com:user/repo.git
	// 支持 HTTPS: https://github.com/user/repo.git
	URL string `json:"url"`

	// Branch 分支名（可选，默认 main）
	Branch string `json:"branch"`

	// Credential 凭证 ID（必填）
	// 支持类型：ssh_private_key, username_password, api_token
	Credential string `json:"credential"`

	// Clean 清空模式（可选，默认 false）
	// false: 智能 sync（不存在就 clone，存在就 pull）✅ 推荐
	// true:  强制重来（删除后 clone）⚠️ 慎用
	Clean bool `json:"clean"`
}

type GitResult struct {
	// Action 操作类型（clone/pull）
	Action string `json:"action"`

	// Repository 仓库信息
	Repository string `json:"repository"` // 仓库 URL
	Branch     string `json:"branch"`     // 分支名
	Commit     string `json:"commit"`     // 当前提交哈希

	// ChangedFiles 变更统计（pull 时有效）
	ChangedFiles int `json:"changed_files,omitempty"` // 变更文件数
	Insertions   int `json:"insertions,omitempty"`    // 新增行数
	Deletions    int `json:"deletions,omitempty"`     // 删除行数

	// ExecuteInfo 执行信息
	WorkDir   string  `json:"work_dir"`  // 工作目录
	Duration  float64 `json:"duration"`  // 执行时长（秒）
	Timestamp string  `json:"timestamp"` // 执行时间
}

type GitRunner struct {
	BaseRunner // 🔥 嵌入基类
	// contains filtered or unexported fields
}

type HTTPAuth struct {
	Username string
	Password string
}

type HTTPConfig struct {
	URL            string            `json:"url"`             // 必填：请求URL
	Method         string            `json:"method"`          // 选填：请求方法，默认GET
	Headers        map[string]string `json:"headers"`         // 选填：请求头
	Query          map[string]string `json:"query"`           // 选填：URL参数
	Body           interface{}       `json:"body"`            // 选填：请求体（仅JSON对象）
	ExpectedStatus []int             `json:"expected_status"` // 选填：预期状态码，默认[200]
}

type HTTPResponse struct {
	StatusCode int
	Headers    http.Header
	Body       string
	Log        string
}

type HTTPRunner struct {
	BaseRunner // 🔥 嵌入基类
	// contains filtered or unexported fields
}

type MessageConfig struct {
	Type         string   `json:"type"`          // 消息类型：email/wechat_work/wechat_work_bot/feishu_bot
	CredentialID string   `json:"credential_id"` // 凭证ID（引用凭证管理）
	To           []string `json:"to"`            // 接收人列表（邮件地址或用户ID）
	Subject      string   `json:"subject"`       // 邮件主题（email专用）
	Content      string   `json:"content"`       // 消息内容
	ContentType  string   `json:"content_type"`  // 内容类型：text/markdown/html（默认text）

	// 企业微信应用专用
	ToUser  string `json:"to_user,omitempty"`  // 成员ID列表（用|分隔）
	ToParty string `json:"to_party,omitempty"` // 部门ID列表（用|分隔）
	ToTag   string `json:"to_tag,omitempty"`   // 标签ID列表（用|分隔）

	// 机器人 @人 专用
	AtMobiles []string `json:"at_mobiles,omitempty"`  // @的手机号列表
	AtUserIds []string `json:"at_user_ids,omitempty"` // @的用户ID列表
	IsAtAll   bool     `json:"is_at_all,omitempty"`   // 是否@所有人
}

type MessageRunner struct {
	BaseRunner // 🔥 嵌入基类
	// contains filtered or unexported fields
}

type MessageSender interface {
	// Send 发送消息
	//
	// 参数：
	//   - ctx: 上下文（支持超时和取消）
	//   - cred: 凭证信息（已解密）
	//   - config: 消息配置
	//   - logChan: 日志通道
	//
	// 返回：
	//   - *core.Result: 执行结果
	//   - error: 错误信息
	Send(ctx context.Context, cred *core.Credential, config MessageConfig, logChan chan<- string) (*core.Result, error)
}

type ScriptConfig struct {
	Language    string   `json:"language"`    // 必填：python/nodejs/shell
	Type        string   `json:"type"`        // 必填：file（文件）或 inline（内联）
	File        string   `json:"file"`        // type=file时必填：脚本文件绝对路径
	Code        string   `json:"code"`        // type=inline时必填：脚本内容
	Args        []string `json:"args"`        // 选填：脚本参数
	Interpreter string   `json:"interpreter"` // 选填：自定义解释器路径，留空则使用默认
}

type ScriptRunner struct {
	BaseRunner // 🔥 嵌入基类
	// contains filtered or unexported fields
}

type SecurityConfig struct {
	// 是否启用安全检查
	Enabled bool `json:"enabled"`

	// 允许的命令白名单（如果为空则允许所有）
	AllowedCommands []string `json:"allowed_commands"`

	// 禁止的命令黑名单
	BlockedCommands []string `json:"blocked_commands"`

	// 禁止的命令模式（正则表达式）
	BlockedPatterns []string `json:"blocked_patterns"`

	// 禁止的路径模式
	BlockedPaths []string `json:"blocked_paths"`

	// 最大参数长度
	MaxArgsLength int `json:"max_args_length"`
}

type WechatWorkBotSender struct {
	// contains filtered or unexported fields
}

type WechatWorkSender struct {
	// contains filtered or unexported fields
}