mongo

type Admin interface {
	Mongo
	GetDatabase() *mongodriver.Database
	StartSession(ctx context.Context) (*mongodriver.Session, error)
}

type Config struct {
	ConnectionString string `koanf:"connection-string"`
	Host             string `koanf:"host"`
	Port             int    `koanf:"port"`
	ReplicaSet       string `koanf:"replica-set"`
	Username         string `koanf:"username"`
	Password         string `koanf:"password"`
	Database         string `koanf:"database"`
	DirectConnection bool   `koanf:"direct-connection"`

	// Connection Pool Settings
	MaxPoolSize         uint64        `koanf:"max-pool-size"`         // Максимальна кількість з'єднань у пулі
	MinPoolSize         uint64        `koanf:"min-pool-size"`         // Мінімальна кількість з'єднань у пулі
	MaxConnIdleTime     time.Duration `koanf:"max-conn-idle-time"`    // Час простою з'єднання перед закриттям
	ConnectTimeout      time.Duration `koanf:"connect-timeout"`       // Таймаут підключення
	ServerSelectTimeout time.Duration `koanf:"server-select-timeout"` // Таймаут вибору сервера

	// Query Timeout Settings
	QueryTimeout time.Duration `koanf:"query-timeout"` // Максимальний час виконання запиту до БД

	// Migration Settings
	Migrations MigrationConfig `koanf:"migrations"`
}

type EntityMapper[Domain any, Entity any] interface {
	// ToEntity converts domain model to MongoDB entity
	ToEntity(domain *Domain) *Entity

	// ToDomain converts MongoDB entity to domain model
	ToDomain(entity *Entity) *Domain

	// GetID extracts ID from entity (for queries)
	GetID(entity *Entity) string

	// GetVersion extracts version from entity (for optimistic locking)
	GetVersion(entity *Entity) int

	// SetVersion sets version on entity (for optimistic locking)
	SetVersion(entity *Entity, version int)
}

type GenericRepository[Domain any, Entity any] struct {
	// contains filtered or unexported fields
}

type MigrationConfig struct {
	// Disabled controls whether migrations are skipped on startup
	Disabled bool `koanf:"disabled"`
	// Path to migrations directory
	Path string `koanf:"path"`
}

type Mongo interface {
	GetCollection(collection string) *mongodriver.Collection
}

type Option func(*mongoOptions)

type PageResult[Domain any] struct {
	// Items is the list of domain objects for the current page
	Items []*Domain
	// Total is the total number of items matching the filter
	Total int64
	// Page is the current page number (1-based)
	Page int
	// Size is the number of items per page
	Size int
	// TotalPages is the total number of pages
	TotalPages int
}

type QueryOptions struct {
	// Filter is the MongoDB filter criteria (BSON)
	Filter bson.D
	// Page is the page number (1-based)
	Page int
	// Size is the number of items per page
	Size int
	// Sort is the MongoDB sort criteria (BSON)
	// Example: bson.D{{"createdAt", -1}} for descending order
	Sort bson.D
}

type TenantMigrationRunner interface {
	MigrateTenant(ctx context.Context, slug string) error
}

type TenantSlugsProvider interface {
	GetSlugs(ctx context.Context) ([]string, error)
}

type TxManager interface {
	WithTransaction(ctx context.Context, fn func(txCtx context.Context) (any, error)) (any, error)
}