62 lines
1.4 KiB
Go
62 lines
1.4 KiB
Go
package persist
|
|
|
|
import (
|
|
"fmt"
|
|
"context"
|
|
"reflect"
|
|
|
|
"go.mongodb.org/mongo-driver/v2/bson"
|
|
|
|
"git.gsuntres.com/general/commons"
|
|
"git.gsuntres.com/general/mongo"
|
|
)
|
|
|
|
func BuildReplaceOne(col map[string]any, report *InitReport) {
|
|
name := col["_name"].(string)
|
|
singular := col["singular"].(string)
|
|
|
|
// prepare input arguments and return results
|
|
in := []reflect.Type{
|
|
reflect.TypeOf((*context.Context)(nil)).Elem(),
|
|
reflect.TypeOf((*string)(nil)).Elem(),
|
|
reflect.TypeOf((*map[string]any)(nil)).Elem(),
|
|
}
|
|
out := []reflect.Type{
|
|
reflect.TypeOf(bson.M{}),
|
|
reflect.TypeOf((*error)(nil)).Elem(),
|
|
}
|
|
|
|
// create function signature
|
|
variadic := false
|
|
funcType := reflect.FuncOf(in, out, variadic)
|
|
fname := fmt.Sprintf("%s%s", "Replace", commons.StringTitle(singular))
|
|
fields = append(fields, reflect.StructField{
|
|
Name: fname,
|
|
Type: funcType,
|
|
})
|
|
|
|
isSystem := false
|
|
if v, ok := col["system"]; ok {
|
|
isSystem = v.(bool)
|
|
}
|
|
|
|
report.AddField(fname)
|
|
|
|
mc := mongo.GetMongoClient()
|
|
|
|
// we defer function's implementation until we create the actual struct
|
|
deferedFuncs[fname] = func(ctx context.Context, id string, data map[string]any) (bson.M, error) {
|
|
db := "__undefined__"
|
|
if isSystem {
|
|
db = sysDb
|
|
} else {
|
|
account := ctx.Value("account").(string)
|
|
if account != "" {
|
|
db = mc.GetName(account)
|
|
}
|
|
}
|
|
|
|
return mc.Replace(ctx, db, name, id, data)
|
|
}
|
|
}
|