mailbackup

type BackupSpec struct {
	Runner Runner
	Sink   Sink
	// StagingHost and StagingContainer are the same directory seen from
	// the host and from inside the mail container.
	StagingHost      string
	StagingContainer string
	Recipients       []age.Recipient
	Now              func() time.Time
	// Fetch copies the container staging dir to the host one when they are
	// not the same directory (a Docker volume the control plane cannot see).
	Fetch func(ctx context.Context, containerDir, hostDir string) error
	// FetchConfig copies the mox config dir (DKIM keys, certificates) into
	// hostDir; nil leaves the config out of the archive.
	FetchConfig func(ctx context.Context, hostDir string) error
	// Cleanup removes the container staging dir; nil means host removal covers it.
	Cleanup func(ctx context.Context, containerDir string)
	// Progress reports each step by name.
	Progress func(step string)
}

type CapError struct {
	CapBytes  int64
	NeedBytes int64
}

type ChecksumError struct{ Want, Got string }

type DowngradeError struct{ Target, Backup string }

type LocalSink struct {
	Dir      string
	CapBytes int64
	MinKeep  int
}

type Manifest struct {
	ID          string    `json:"id"`
	MoxVersion  string    `json:"mox_version"`
	CreatedAt   time.Time `json:"created_at"`
	Files       int       `json:"files"`
	Bytes       int64     `json:"bytes"`
	SHA256      string    `json:"sha256"`
	ArchiveName string    `json:"archive_name"`
	Verified    bool      `json:"verified"`
}

type Pruner interface {
	Prune(ctx context.Context) ([]string, error)
}

type RestoreReport struct {
	Manifest Manifest
	Files    int
	Bytes    int64
	DryRun   bool
}

type RestoreSpec struct {
	Runner     Runner
	Sink       Sink
	ID         string
	DestDir    string
	Identities []age.Identity
}

type Runner interface {
	Run(ctx context.Context, args ...string) (string, error)
}

type Sink interface {
	Put(ctx context.Context, name string, r io.Reader) error
	Open(ctx context.Context, name string) (io.ReadCloser, error)
	List(ctx context.Context) ([]string, error)
	Delete(ctx context.Context, name string) error
}