helperrepo

type Map map[string]interface{}

type Repo struct {
	Storage    Storage
	Collection *mongo.Collection
}

type Repoable interface {
	DeleteFile(ctx context.Context, filename string) error
	SaveFile(ctx context.Context, filename, fileType string, file []byte) error
	GetFile(ctx context.Context, id string) ([]byte, int64, error)
	FindBy(ctx context.Context, by, key string, p Map, result helpermodels.Datable) error
	Find(ctx context.Context, query Map, data interface{}, opts ...*options.FindOptions) error
	FindOne(ctx context.Context, query Map, data interface{}, opts ...*options.FindOneOptions) error
	FindByID(ctx context.Context, id string, p Map, result helpermodels.Datable) error
	Insert(ctx context.Context, data helpermodels.Datable) error
	UpdateOne(ctx context.Context, data helpermodels.Datable, upsert bool) error
	UpdateMany(ctx context.Context, query Map, updateWith Map, opts ...*options.UpdateOptions) error
	CountManyByOwner(ctx context.Context, ownerID string, query Map) (int64, error)
	CountBy(ctx context.Context, query Map) (int64, error)
	BulkWrite(ctx context.Context, operations []mongo.WriteModel, op *options.BulkWriteOptions) error
	SoftDeleteMany(ctx context.Context, q Map) error
	DeleteOne(ctx context.Context, data helpermodels.Datable) error
	DeleteMany(ctx context.Context, query Map) error
	Aggregate(ctx context.Context, r interface{}, c string, p interface{}, o *options.AggregateOptions) error
}

type Storage interface {
	GetDatabase() *mongo.Database
	GetCollection(name string) *mongo.Collection
}

type StorageMongo struct {
	Database         string
	CollectionPrefix string
	// contains filtered or unexported fields
}