cystore

type BucketInfo struct {
	Name         string    // Name of the bucket
	CreationDate time.Time // Creation date of the bucket
}

type Config struct {
	// Provider type (minio, local, etc.)
	Provider ProviderType `json:"provider" yaml:"provider"`

	// Common settings
	Region  string        `json:"region" yaml:"region"`
	Secure  bool          `json:"secure" yaml:"secure"`
	Timeout time.Duration `json:"timeout" yaml:"timeout"`

	// Unified storage settings
	// These fields are used across different providers
	Endpoint     string `json:"endpoint" yaml:"endpoint"`
	AccessKey    string `json:"access_key" yaml:"access_key"`
	SecretKey    string `json:"secret_key" yaml:"secret_key"`
	SessionToken string `json:"session_token,omitempty" yaml:"session_token,omitempty"`
	UseSSL       bool   `json:"use_ssl" yaml:"use_ssl"`

	// Provider-specific settings that don't fit in the common fields
	// Local storage specific
	BasePath string `json:"base_path,omitempty" yaml:"base_path,omitempty"`

	// SFTP specific settings
	SSHPort        int    `json:"ssh_port,omitempty" yaml:"ssh_port,omitempty"`                 // SSH port (default: 22)
	SSHUser        string `json:"ssh_user,omitempty" yaml:"ssh_user,omitempty"`                 // SSH username
	SSHPassword    string `json:"ssh_password,omitempty" yaml:"ssh_password,omitempty"`         // SSH password
	SSHPrivateKey  string `json:"ssh_private_key,omitempty" yaml:"ssh_private_key,omitempty"`   // SSH private key path or content
	SSHKeyPassword string `json:"ssh_key_password,omitempty" yaml:"ssh_key_password,omitempty"` // SSH private key password
}

type FuncNewStore func(config *Config) (Provider, error)

type GetObjectOptions struct {
	Range        string // Range of bytes to download
	MatchETag    string // Download object if ETag matches
	NotMatchETag string // Download object if ETag doesn't match
}

type ObjectInfo struct {
	Bucket       string            // Bucket name
	Name         string            // Object name
	ETag         string            // ETag of the object
	Size         int64             // Size of the object
	LastModified time.Time         // Last modified time of the object
	ContentType  string            // Content type of the object
	Metadata     map[string]string // User-defined metadata
}

type Option func(*Store)

type Provider interface {
	// Bucket operations
	BucketExists(ctx context.Context, bucketName string) (bool, error)
	CreateBucket(ctx context.Context, bucketName string) error
	RemoveBucket(ctx context.Context, bucketName string) error
	ListBuckets(ctx context.Context) ([]BucketInfo, error)

	// Object operations
	PutObject(ctx context.Context, bucketName, objectName string, reader io.Reader, objectSize int64, opts PutObjectOptions) (ObjectInfo, error)
	GetObject(ctx context.Context, bucketName, objectName string, opts GetObjectOptions) (io.ReadCloser, ObjectInfo, error)
	StatObject(ctx context.Context, bucketName, objectName string) (ObjectInfo, error)
	RemoveObject(ctx context.Context, bucketName, objectName string) error
	ListObjects(ctx context.Context, bucketName, prefix string, recursive bool) <-chan ObjectInfo

	// Batch operations
	RemoveObjects(ctx context.Context, bucketName string, objectNames []string) <-chan RemoveObjectError

	// Copy/Rename operations
	CopyObject(ctx context.Context, srcBucket, srcObject, dstBucket, dstObject string) (ObjectInfo, error)

	// Presigned URL operations
	PresignedGetObject(ctx context.Context, bucketName, objectName string, expires time.Duration) (string, error)
	PresignedPutObject(ctx context.Context, bucketName, objectName string, expires time.Duration) (string, error)
}

type ProviderType string

type PutObjectOptions struct {
	ContentType string            // Content type of the object
	Metadata    map[string]string // User-defined metadata
}

type RemoveObjectError struct {
	ObjectName string // Name of the object
	Error      error  // Error that occurred during removal
}

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