fs

type CopyTaskOption struct {
	SrcPath  string `json:"src_path"`
	DstPath  string `json:"dst_path"`
	Override bool   `json:"override"`
}

type DownloadTask struct {
	Path   string    `json:"path"`
	Writer io.Writer `json:"file"`
}

type FS interface {
	driver.FS
	GetFS(string) (driver.FS, string, error)
	GetRepo(string) *pb.Repo
	CreateRepo(*pb.Repo)
	UpdateRepo(*pb.Repo, *pb.Repo)
	DeleteRepo(*pb.Repo)
	SubmitTask(TaskOption) runner.Task
}

type MoveTaskOption struct {
	SrcPath  string `json:"src_path"`
	DstPath  string `json:"dst_path"`
	Override bool   `json:"override"`
}

type RemoveTaskOption struct {
	Path string `json:"path"`
}

type Task interface {
	Run() error
}

type TaskOption interface {
	String() string
	Execute(runner.Task, FS) error
}

type UploadTask struct {
	Path     string    `json:"path"`
	Size     int64     `json:"size"`
	Filename string    `json:"filename"`
	Reader   io.Reader `json:"reader"`
}