objstore

type Clients interface {
	AsS3(ctx context.Context, storage, user string) (s3client.Client, error)
	AsSwift(ctx context.Context, storage, user string) (*gophercloud.ServiceClient, error)
	// contains filtered or unexported methods
}

type Common interface {
	BucketExists(ctx context.Context, bucket string) (bool, error)
	IsBucketVersioned(ctx context.Context, bucket string) (bool, error)
	ListBuckets(ctx context.Context) ([]string, error)
	CreateBucket(ctx context.Context, bucket string) error
	RemoveBucket(ctx context.Context, bucket string) error
	EnableBucketVersioning(ctx context.Context, bucket string) error
	PutObject(ctx context.Context, bucket string, name string, reader io.Reader, len uint64) error
	ObjectInfo(ctx context.Context, bucket string, name string, opts ...func(o *commonObjectOptions)) (*CommonObjectInfo, error)
	ObjectExists(ctx context.Context, bucket string, name string, opts ...func(o *commonObjectOptions)) (bool, error)
	RemoveObject(ctx context.Context, bucket string, name string, opts ...func(o *commonObjectOptions)) error
	RemoveObjects(ctx context.Context, bucket string, names []string) error
	ListObjects(ctx context.Context, bucket string, opts ...func(o *commonListOptions)) iter.Seq2[CommonObjectInfo, error]
}

type CommonConfig struct {
	Type      dom.StorageType     `yaml:"type"`
	RateLimit ratelimit.RateLimit `yaml:"rateLimit"`
}

type CommonObjectInfo struct {
	LastModified time.Time
	Key          string
	VersionID    string
	Etag         string
	Size         uint64
}

type Config = StoragesConfig[*s3.Storage, *swift.Storage]

type CredsService interface {
	FindS3Credentials(storage, accessKey string) (user string, cred s3.CredentialsV4, err error)
	MainStorage() string
	Storages() map[string]dom.StorageType
	GetS3Address(storage string) (s3.StorageAddress, error)
	GetSwiftAddress(storage string) (swift.StorageAddress, error)
	ValidateReplicationID(id entity.UniversalReplicationID) error
	HasUser(storage, user string) error
	ListUsers(storage string) []string

	GetSwiftCredentials(storage, user string) (swift.Credentials, error)
	GetS3Credentials(storage, user string) (s3.CredentialsV4, error)

	SetSwiftCredentials(ctx context.Context, storage, user string, cred swift.Credentials) error
	SetS3Credentials(ctx context.Context, storage, user string, cred s3.CredentialsV4) error
}

type DynamicCredentialsConfig struct {
	MasterPassword    string        `yaml:"masterPassword"`
	PollInterval      time.Duration `yaml:"pollInterval"`
	Enabled           bool          `yaml:"enabled"`
	DisableEncryption bool          `yaml:"disableEncryption"`
}

type GenericStorage[
	S3Config StorageConfig,
	SwiftConfig StorageConfig,
] struct {
	S3    S3Config
	Swift SwiftConfig
	CommonConfig
}

type Storage = GenericStorage[*s3.Storage, *swift.Storage]

type StorageConfig interface {
	Validate() error
	UserList() []string
	HasUser(user string) bool
	comparable
}

type StoragesConfig[
	S3Config StorageConfig,
	SwiftConfig StorageConfig,
] struct {
	Storages           map[string]GenericStorage[S3Config, SwiftConfig] `yaml:"storages"`
	Main               string                                           `yaml:"main"`
	DynamicCredentials DynamicCredentialsConfig                         `yaml:"dynamicCredentials"`
}