storage

type MigrateStorageReq struct {
	// TargetType 目标后端类型（local / s3 / webdav / …）。
	TargetType string
	// TargetPath 目标本地目录（仅 TargetType=local 时有意义；缺省 = 沿用现配置的 storage_path）。
	TargetPath string
	// DryRun 只算计划不搬（先看再动）。
	DryRun bool
}

type MigrateStorageResult struct {
	// Switched 是否已切换到目标后端。
	Switched bool
	// Copied 本次复制成功的对象数。
	Copied int64
	// Skipped 目标已存在而跳过的对象数（续跑）。
	Skipped int64
	// Failed 复制失败的对象数（>0 ⇒ 未切换）。
	Failed int64
	// Bytes 复制字节数。
	Bytes int64
	// Objects 计划涉及的对象总数。
	Objects int64
	// FromType 源后端类型。
	FromType string
	// ToType 目标后端类型。
	ToType string
	// Message 人类可读结论（失败摘要 / dry-run 计划）。
	Message string
}

type NFSConfig struct {
	Server     string `json:"server"`
	Path       string `json:"path"`
	MountPoint string `json:"mount_point"`
	Version    string `json:"version"`
	Options    string `json:"options"`
	Timeout    int32  `json:"timeout"`
	AutoMount  int32  `json:"auto_mount"`
	RetryCount int32  `json:"retry_count"`
	SubPath    string `json:"sub_path"`
}

type ObjectLister interface {
	// ListReferencedObjectPaths 返回全部被引用的对象路径（去重）。
	// 必须含**软删**记录：软删分享可恢复 ⇒ 它的对象也得搬过去。
	ListReferencedObjectPaths(ctx context.Context) ([]string, error)
}

type ObjectReader interface {
	// GetFileReader 打开对象读取器；同时给出对象大小（远端驱动写流需确切 size）。
	GetFileReader(ctx context.Context, filePath string) (io.ReadCloser, int64, error)
	// FileExists 对象是否已存在（续跑跳过判定）。
	FileExists(ctx context.Context, filePath string) bool
}

type Runtime interface {
	Reload(cfg *corestorage.StorageConfig) error
	EffectiveType() corestorage.StorageType
}

type RuntimePersister interface {
	LoadRuntimeStorage(ctx context.Context) *conf.StorageConfig
	SaveRuntimeStorage(ctx context.Context, cfg *conf.StorageConfig) error
}

type S3Config struct {
	AccessKeyID     string `json:"access_key_id"`
	SecretAccessKey string `json:"secret_access_key"`
	BucketName      string `json:"bucket_name"`
	EndpointURL     string `json:"endpoint_url"`
	RegionName      string `json:"region_name"`
	Hostname        string `json:"hostname"`
	Proxy           string `json:"proxy"`
}

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

type StorageConfig struct {
	Type        string        `json:"type"`
	StoragePath string        `json:"storage_path"`
	WebDAV      *WebDAVConfig `json:"webdav,omitempty"`
	S3          *S3Config     `json:"s3,omitempty"`
	NFS         *NFSConfig    `json:"nfs,omitempty"`
}

type StorageDetail struct {
	Type         string `json:"type"`
	Available    bool   `json:"available"`
	StoragePath  string `json:"storage_path"`
	UsagePercent int32  `json:"usage_percent"`
	Error        string `json:"error,omitempty"`
}

type StorageInfo struct {
	Current        string                    `json:"current"`
	Effective      string                    `json:"effective"` // 实际生效后端（降级时与 current 不同）
	Available      []string                  `json:"available"`
	StorageDetails map[string]*StorageDetail `json:"storage_details"`
	StorageConfig  *StorageConfig            `json:"storage_config"`
}

type UpdateConfigRequest struct {
	Type string `json:"type"`
	// 扁平形态：内嵌 conf.StorageConfig，JSON 字段同名绑定
	conf.StorageConfig
}

type WebDAVConfig struct {
	Hostname string `json:"hostname"`
	Username string `json:"username"`
	Password string `json:"password"`
	RootPath string `json:"root_path"`
	URL      string `json:"url"`
}