transfer

type Backend interface {
	ReadBackend
	MultipartBackend
	ObjectDeleter
	Validator
}

type Chunk struct {
	Index  int
	Offset int64
	Length int64
	Status ChunkStatus
}

type ChunkStatus string

type Downloader interface {
	Service
	ResolveDownloadURL(ctx context.Context, guid string, accessID string) (string, error)
	Download(ctx context.Context, url string, rangeStart, rangeEnd *int64) (*http.Response, error)
}

type ExponentialBackoff struct {
	MaxWaitSeconds int64
}

type MultipartBackend interface {
	WriteBackend
	MultipartInit(ctx context.Context, guid string) (string, error)
	MultipartPart(ctx context.Context, guid string, uploadID string, partNum int, body io.Reader) (string, error)
	MultipartComplete(ctx context.Context, guid string, uploadID string, parts []MultipartPart) error
}

type MultipartPart struct {
	PartNumber int32
	ETag       string
}

type NoOpLogger struct{}

type ObjectDeleter interface {
	Delete(ctx context.Context, guid string) error
}

type ObjectMetadata struct {
	Size         int64
	Checksums    []hash.HashInfo
	MD5          string
	AcceptRanges bool
	Provider     string
}

type PartSigner interface {
	GetDownloadPartURL(ctx context.Context, id string, start, end int64) (*SignedURL, error)
	Logger() TransferLogger
}

type Planner interface {
	PlanDownload(ctx context.Context, obj ResolvedObject) (*TransferPlan, error)
	PlanUpload(ctx context.Context, obj ResolvedObject) (*TransferPlan, error)
}

type Provider interface {
	GetStorageLocation(ctx context.Context, guid string) (bucket, key string, err error)
}

type ReadBackend interface {
	Service
	Stat(ctx context.Context, guid string) (*ObjectMetadata, error)
	GetReader(ctx context.Context, guid string) (io.ReadCloser, error)
	GetRangeReader(ctx context.Context, guid string, offset, length int64) (io.ReadCloser, error)
}

type ResolvedObject struct {
	Id           string
	Name         string
	Size         int64
	Checksums    hash.HashInfo
	ProviderURL  string
	AccessMethod string
}

type Resolver interface {
	Resolve(ctx context.Context, id string) (*ResolvedObject, error)
}

type RetryStrategy interface {
	WaitTime(retryCount int) time.Duration
}

type Service interface {
	Name() string
	Logger() TransferLogger
}

type SignedURL struct {
	URL     string
	Headers map[string]string
}

type TransferLogger interface {
	Slog() *slog.Logger
	Info(msg string, args ...any)
	InfoContext(ctx context.Context, msg string, args ...any)
	Error(msg string, args ...any)
	ErrorContext(ctx context.Context, msg string, args ...any)
	Warn(msg string, args ...any)
	WarnContext(ctx context.Context, msg string, args ...any)
	Debug(msg string, args ...any)
	DebugContext(ctx context.Context, msg string, args ...any)
	Printf(format string, v ...any)
	Println(v ...any)
	Failed(filePath, filename string, metadata common.FileMetadata, guid string, retryCount int, multipart bool)
	FailedContext(ctx context.Context, filePath, filename string, metadata common.FileMetadata, guid string, retryCount int, multipart bool)
	Succeeded(filePath, guid string)
	SucceededContext(ctx context.Context, filePath, guid string)
	GetSucceededLogMap() map[string]string
	GetFailedLogMap() map[string]common.RetryObject
	DeleteFromFailedLog(path string)
	Scoreboard() *logs.Scoreboard
}

type TransferPlan struct {
	Strategy       TransferStrategy
	TotalSize      int64
	Chunks         []Chunk
	CheckpointPath string
}

type TransferRequest struct {
	SourcePath     string
	ObjectKey      string
	GUID           string
	Bucket         string
	Metadata       common.FileMetadata
	ForceMultipart bool
}

type TransferStrategy string

type Uploader interface {
	Service
	ResolveUploadURL(ctx context.Context, guid string, filename string, metadata common.FileMetadata, bucket string) (string, error)
	InitMultipartUpload(ctx context.Context, guid string, filename string, bucket string) (uploadID string, key string, err error)
	GetMultipartUploadURL(ctx context.Context, key string, uploadID string, partNumber int32, bucket string) (string, error)
	CompleteMultipartUpload(ctx context.Context, key string, uploadID string, parts []internalapi.InternalMultipartPart, bucket string) error
	Upload(ctx context.Context, url string, body io.Reader, size int64) error
	UploadPart(ctx context.Context, url string, body io.Reader, size int64) (string, error)
	DeleteFile(ctx context.Context, guid string) (string, error)
	CanonicalObjectURL(signedURL, bucketHint, fallbackDID string) (string, error)
}

type Validator interface {
	Validate(ctx context.Context, bucket string) error
}

type WriteBackend interface {
	Service
	Upload(ctx context.Context, guid string, body io.Reader, size int64) error
}