repository

type BaseRepository[M IModel] struct {
	// contains filtered or unexported fields
}

type IModel interface {
	TableName() string
}

type IRepository[M IModel] interface {
	FindAll(conds ...any) ([]M, core.IError)                                               // Function to find all records that match the given conditions
	FindOne(conds ...any) (*M, core.IError)                                                // Function to find the first record that matches the given conditions
	Count() (int64, core.IError)                                                           // Function to count the number of records
	Create(values any) core.IError                                                         // Function to insert a value into the database
	Updates(values any) core.IError                                                        // Function to update attributes with callbacks
	Delete(conds ...any) core.IError                                                       // Function to delete a value that matches the given conditions
	HardDelete(conds ...any) core.IError                                                   // Function to hard delete a value that matches the given conditions
	Pagination(pageOptions *models.PageOptions) (*Pagination[M], core.IError)              // Function to perform pagination on the records
	Save(values any) core.IError                                                           // Function to set values on a model
	Where(query any, args ...any) IRepository[M]                                           // Function to filter records based on a query
	Preload(query string, args ...any) IRepository[M]                                      // Function to preload associations
	Unscoped() IRepository[M]                                                              // Function to apply an unscoped query
	Exec(sql string, values ...any) core.IError                                            // Function to execute raw SQL queries
	Group(name string) IRepository[M]                                                      // Function to group records
	Joins(query string, args ...any) IRepository[M]                                        // Function to perform joins
	Order(value any) IRepository[M]                                                        // Function to order the records
	Distinct(args ...any) IRepository[M]                                                   // Function to specify distinct fields for querying
	Update(column string, value any) IRepository[M]                                        // Function to update a column with a value
	Select(query any, args ...any) IRepository[M]                                          // Function to select specific columns
	Omit(columns ...string) IRepository[M]                                                 // Function to omit specific columns
	Limit(limit int) IRepository[M]                                                        // Function to limit the number of records
	Offset(offset int) IRepository[M]                                                      // Function to specify the offset of records
	Association(column string) core.IError                                                 // Function to retrieve an association
	FindInBatches(dest any, batchSize int, fc func(tx *gorm.DB, batch int) error) *gorm.DB // Function to find records in batches
	FindOneOrInit(dest any, conds ...any) core.IError                                      // Function to find the first record that matches the given conditions or initialize a new one
	FindOneOrCreate(dest any, conds ...any) core.IError                                    // Function to find the first record that matches the given conditions or create a new one
	Attrs(attrs ...any) IRepository[M]                                                     // Function to set attributes on a model
	Assign(attrs ...any) IRepository[M]                                                    // Function to assign attributes to a model
	Pluck(column string, desc any) core.IError                                             // Function to retrieve a specific column value
	Scan(dest any) core.IError                                                             // Function to scan query results into a destination
	Row() *sql.Row                                                                         // Function to retrieve a single row
	Rows() (*sql.Rows, error)                                                              // Function to retrieve multiple rows
	Raw(dest any, sql string, values ...any) core.IError                                   // Function to execute a raw SQL query
	Clauses(conds ...clause.Expression) IRepository[M]                                     // Function to apply additional query clauses
	WithContext(ctx context.Context) IRepository[M]                                        // Function to set the context used for future queries
	NewSession() IRepository[M]                                                            // Function to create a new session for this query
}

type MockRepository[M IModel] struct {
	mock.Mock
}

type Pagination[M any] struct {
	Page  int64 `json:"page" example:"1"`
	Total int64 `json:"total" example:"45"`
	Limit int64 `json:"limit" example:"30"`
	Count int64 `json:"count" example:"30"`
	Items []M   `json:"items"`
}