executor

type BackupManifest struct {
	Version    int             `json:"version"`
	Generated  time.Time       `json:"generated"`
	BackupDir  string          `json:"backup_dir"`
	EntryCount int             `json:"entry_count"`
	TotalSize  int64           `json:"total_size"`
	MerkleRoot string          `json:"merkle_root"`
	Entries    []ManifestEntry `json:"entries"`
}

type BundleInfo struct {
	Name     string    `json:"name"`
	Path     string    `json:"path"`
	Size     int64     `json:"size"`
	ModTime  time.Time `json:"mod_time"`
	TaskKey  string    `json:"task_key,omitempty"`
	Valid    bool      `json:"valid,omitempty"`
	RefSpecs []string  `json:"ref_specs,omitempty"`
}

type Destination struct {
	Type DestinationType `yaml:"type" json:"type"`
	Name string          `yaml:"name" json:"name"`
	// S3(含 MinIO/阿里 OSS)
	Endpoint  string `yaml:"endpoint,omitempty" json:"endpoint,omitempty"`
	Region    string `yaml:"region,omitempty" json:"region,omitempty"`
	Bucket    string `yaml:"bucket,omitempty" json:"bucket,omitempty"`
	Prefix    string `yaml:"prefix,omitempty" json:"prefix,omitempty"`
	AccessKey string `yaml:"access_key,omitempty" json:"access_key,omitempty"`
	SecretKey string `yaml:"secret_key,omitempty" json:"secret_key,omitempty"`
	PathStyle bool   `yaml:"path_style,omitempty" json:"path_style,omitempty"`
	// WebDAV
	URL      string `yaml:"url,omitempty" json:"url,omitempty"`
	Username string `yaml:"username,omitempty" json:"username,omitempty"`
	Password string `yaml:"password,omitempty" json:"password,omitempty"`
	// Azure Blob
	AccountName string `yaml:"account_name,omitempty" json:"account_name,omitempty"`
	AccountKey  string `yaml:"account_key,omitempty" json:"account_key,omitempty"`
	Container   string `yaml:"container,omitempty" json:"container,omitempty"`
	// Enabled 默认 true;false 时跳过
	Enabled *bool `yaml:"enabled,omitempty" json:"enabled,omitempty"`
}

type DestinationType string

type DrillHistoryEntry struct {
	Report   *DrillReport `json:"report"`
	PrevHash string       `json:"prev_hash"`
	Hash     string       `json:"hash"`
}

type DrillReport struct {
	BundleName   string            `json:"bundle_name"`
	StartedAt    time.Time         `json:"started_at"`
	FinishedAt   time.Time         `json:"finished_at"`
	DurationMS   int64             `json:"duration_ms"`
	Success      bool              `json:"success"`
	RefSpecs     []string          `json:"ref_specs"`
	RestoredRefs []string          `json:"restored_refs"`
	MissingRefs  []string          `json:"missing_refs"`
	ExtraRefs    []string          `json:"extra_refs"`
	FsckOK       bool              `json:"fsck_ok"`
	FsckOutput   string            `json:"fsck_output,omitempty"`
	CommitCount  int               `json:"commit_count"`
	EstRTO       string            `json:"est_rto"` // 人类可读,如 "12s"
	BundleSize   int64             `json:"bundle_size"`
	Errors       []string          `json:"errors,omitempty"`
	CheckedAt    time.Time         `json:"checked_at"`
	Details      map[string]string `json:"details,omitempty"`
}

type Executor struct {

	// Approver 可选：force_push_policy=block 时查询是否已获人工放行。
	// 由壳层注入（如 force-push-approvals 审批表）；nil=始终未放行。
	Approver ForcePushApprover
	// contains filtered or unexported fields
}

type ForcePushApprover interface {
	// IsForcePushApproved 查询放行是否生效。
	// targetRef 是**当前**目标分支的 HEAD SHA:放行只对它被批准时的目标状态有效
	// (目标侧此后又变了 ⇒ 旧放行不再适用,必须重新审批)。
	IsForcePushApproved(taskKey, branch, targetRef string) bool
	// RequestApproval 产生一条 pending 审批（best-effort，失败不影响主流程）。
	// targetRef 记录申请时的目标分支 HEAD SHA,用于上面的绑定判定。
	RequestApproval(taskKey, branch, reason, targetRef string)
	// ConsumeForcePushApproval 消费掉一次放行。
	// 放行是**一次性**的:一次成功的强推之后就要用掉,下次同任务同分支
	// 再出现分歧必须重新审批(否则一次人工放行变成常驻后门)。
	//
	// targetRef 是**判定时用的那个目标状态**:消费必须精确落在判定通过的那条上,
	// 否则被消费掉的可能是另一条放行,真正授权的那条仍可反复使用。
	ConsumeForcePushApproval(taskKey, branch, targetRef string)
}

type ManifestEntry struct {
	Name     string    `json:"name"`
	Size     int64     `json:"size"`
	SHA256   string    `json:"sha256"`
	ModTime  time.Time `json:"mod_time"`
	TaskKey  string    `json:"task_key,omitempty"`
	LeafHash string    `json:"leaf_hash"`
}

type ManifestVerifyResult struct {
	OK           bool     `json:"ok"`
	MerkleRoot   string   `json:"merkle_root"`
	StoredRoot   string   `json:"stored_root,omitempty"`
	CheckedCount int      `json:"checked_count"`
	MissingFiles []string `json:"missing_files,omitempty"`
	HashMismatch []string `json:"hash_mismatch,omitempty"`
	ExtraFiles   []string `json:"extra_files,omitempty"`
	Message      string   `json:"message"`
}

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

type PlatformProvider interface {
	GetPlatformByID(ctx context.Context, id uint) (*model.Platform, error)
}

type RepoProvider interface {
	GetRepoByKey(key string) (*model.Repo, error)
}

type RunContext struct {
	Task        *model.SyncTask // 本地副本(分支已回退,不回写 DB)
	SourceRepo  *model.Repo
	TargetRepo  *model.Repo
	Platforms   map[uint]*model.Platform
	WorkDir     string
	RepoDir     string
	Details     *strings.Builder
	Run         *model.SyncRun
	Exec        *Executor
	BundlesPath string
}

type RunManager interface {
	CreateRun(task *model.SyncTask, trigger string, webhookEventID *uint) (*model.SyncRun, error)
	CreateRunStep(step *model.SyncRunStep) error
	UpdateRunStep(step *model.SyncRunStep) error
	CompleteRun(run *model.SyncRun) error
	UpdateTaskLastRun(task *model.SyncTask, run *model.SyncRun) error
	CompleteRunWithTaskUpdate(run *model.SyncRun, task *model.SyncTask) error
}

type S3Config struct {
	Endpoint  string `yaml:"endpoint"` // https://s3.amazonaws.com 或 https://oss-cn-hangzhou.aliyuncs.com
	Region    string `yaml:"region"`   // us-east-1 等
	Bucket    string `yaml:"bucket"`
	Prefix    string `yaml:"prefix"` // 对象 key 前缀
	AccessKey string `yaml:"access_key"`
	SecretKey string `yaml:"secret_key"`
	// PathStyle true=MinIO/部分兼容端点
	PathStyle bool `yaml:"path_style"`
}

type Service interface {
	GetTempDir(taskKey string) string
	GetConfig() *model.Config
	RunManager
	RepoProvider
	PlatformProvider
}

type Stage interface {
	Name() string
	// IsOptional 可选阶段失败不中止流水线(如 wiki/冷备)。
	IsOptional() bool
	Run(ctx context.Context, rc *RunContext) error
}

type UploadResult struct {
	Destination string `json:"destination"`
	Type        string `json:"type"`
	OK          bool   `json:"ok"`
	Error       string `json:"error,omitempty"`
	ObjectKey   string `json:"object_key,omitempty"`
	Bytes       int64  `json:"bytes,omitempty"`
}

type Uploader interface {
	Type() DestinationType
	// Upload 返回 object key;失败返回 error。
	Upload(ctx context.Context, d Destination, objectKey string, data []byte) (string, error)
}