golib/infra/svc/default.go

package svc

import (
	"golib/features/mo"
	"golib/infra/ii"
	"golib/log/logs"
)

var (
	Default *Service
)

func InitDefault(client *mo.Client, items ii.Items, log *logs.Logs) {
	Default = new(Service)
	Default.Client = client
	Default.Items = items
	Default.Logs = log
}

func Find(name string, filter mo.D) ([]mo.M, error) {
	return Default.Find(name, filter)
}

func FindOne(name string, filter mo.D) (mo.M, error) {
	return Default.FindOne(name, filter)
}

func FindOneAndUpdate(name string, filter mo.D, update mo.M) error {
	return Default.FindOneAndUpdate(name, filter, update)
}

func EstimatedDocumentCount(name string) (int64, error) {
	return Default.EstimatedDocumentCount(name)
}

func CountDocuments(name string, filter mo.D) (int64, error) {
	return Default.CountDocuments(name, filter)
}

func InsertOne(name string, doc mo.M) (mo.ObjectID, error) {
	return Default.InsertOne(name, doc)
}

func InsertMany(name string, docs mo.A) ([]mo.ObjectID, error) {
	return Default.InsertMany(name, docs)
}

func UpdateOne(name string, filter mo.D, update mo.M) error {
	return Default.UpdateOne(name, filter, update)
}

func UpdateByID(name string, id mo.ObjectID, update mo.M) error {
	return Default.UpdateByID(name, id, update)
}

func UpdateMany(name string, filter mo.D, update mo.M) error {
	return Default.UpdateMany(name, filter, update)
}

func DeleteOne(name string, filter mo.D) error {
	return Default.DeleteOne(name, filter)
}

func DeleteMany(name string, filter mo.D) error {
	return Default.DeleteMany(name, filter)
}

func Aggregate(name string, pipe mo.Pipeline, v interface{}) error {
	return Default.Aggregate(name, pipe, v)
}

func ItemHas(name string) (ii.ItemInfo, bool) {
	return Default.Items.Has(name)
}