db

type Alias = string

type Argument = any

type BaseRepositoryI interface {
	Name() Table // Name of table/repo (repo obj)

	GetRowsByQuery(ctx context.Context, qb SelectBuilder) (*sql.Rows, error)
	CountByQuery(ctx context.Context, qb SelectBuilder) (uint64, error)

	Insert(context.Context, []Column, []Argument) (int64, error)
	UpdateCustom(context.Context, map[string]any, Condition) (int64, error)
}

type Column = string

type Condition = squirrel.Sqlizer // squirrel.Eq or squirrel.Gt or squirrel.And and etc

type Config = interface {
	IsEnableValidationRepoNames() bool
	IsEnableReposCache() bool
	PlaceholderFormat() PlaceholderFormat // squirrel int code for placeholder
}

type Connector[C Config] interface {
	Config() C

	AddAllowsRepos(...Table)
	GetAllowsRepos() []Table
	IsAllowRepo(Table) bool

	Logger() Logger

	Connection() PureSqlxConnection

	Repo(DTO) Repository // TODO think about -> optional.Optional[Repository]

	RepoByName(Table) Repository

	AutoCreate(context.Context, DTO) (int64, error)
	AutoGet(context.Context, DTO) error
	AutoUpdate(context.Context, DTO) (int64, error)
	AutoDelete(context.Context, DTO) (int64, error)
}

type CursorPaginationParams struct {
	Limit     uint64
	Cursor    uint64
	DescOrder bool
}

type DTO interface {
	Repo() Table
	Identity() ID
}

type GDTO[I ID] interface {
	ID() I
	DTO
}

type GRepository[I ID, D DTO] interface {
	BaseRepositoryI

	Create(context.Context, D) (I, error)
	Get(context.Context, I) (D, error)
	Update(context.Context, I, D) (int64, error)
	Delete(context.Context, I) (int64, error)

	FindBy(context.Context, []Column, Condition) ([]D, error)
	FindOneBy(context.Context, []Column, Condition) (D, error)

	Select(context.Context, SelectBuilder) ([]D, error)
	SelectWithPagePagination(context.Context, SelectBuilder, PagePaginationParams) ([]D, PagePaginationResults, error)
	SelectWithCursorOnPKPagination(context.Context, SelectBuilder, CursorPaginationParams) ([]D, error)
}

type ID = any

type Join = string

type Logger = *zap.Logger

type Obj = any

type PagePaginationParams struct {
	PageNumber uint64
	PageSize   uint64
}

type PagePaginationResults struct {
	CurrentPageNumber uint64
	NextPageNumber    uint64
	CntPages          uint64
}

type PlaceholderFormat = squirrel.PlaceholderFormat

type PureSqlxConnection interface {
	sqlx.QueryerContext
	sqlx.ExecerContext
	sqlx.ExtContext
	sqlx.PreparerContext
	transaction.TxxI
}

type Query = string

type Repository interface {
	BaseRepositoryI

	Create(context.Context, any) (int64, error) // todo add one method for ID = string or move to generics API only
	Get(context.Context, ID, any) error
	Update(context.Context, ID, any) (int64, error)
	Delete(context.Context, ID) (int64, error)

	FindBy(context.Context, []Column, Condition, any) error
	FindOneBy(context.Context, []Column, Condition, any) error

	FindByWithInnerJoin(context.Context, []Column, Alias, Join, Condition, any) error
	FindOneByWithInnerJoin(context.Context, []Column, Alias, Join, Condition, any) error

	Select(context.Context, SelectBuilder, any) error
	SelectWithPagePagination(context.Context, SelectBuilder, PagePaginationParams, any) (PagePaginationResults, error)
	SelectWithCursorOnPKPagination(context.Context, SelectBuilder, CursorPaginationParams, any) error
}

type SelectBuilder = squirrel.SelectBuilder

type Storage[C Config] interface {
	Config() C

	Connect() error
	Reconnect() error

	OnConnect(context.Context, func()) error   // actions that will be performed after function call Connect()
	OnReconnect(context.Context, func()) error // actions that will be performed after function call Reconnect()
	OnStop(context.Context, func()) error      // actions that will be performed after function call Close()

	Master() Connector[C]
	Slaves() []Connector[C]

	Close() error
}

type Table = string