test
This commit is contained in:
@@ -3,6 +3,7 @@ package mongo
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"errors"
|
"errors"
|
||||||
|
"fmt"
|
||||||
"slices"
|
"slices"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
@@ -248,6 +249,7 @@ func (m *MongoDB) StoreOne(obj interface{}, id string, collection_name string) (
|
|||||||
return "", 503, err
|
return "", 503, err
|
||||||
}
|
}
|
||||||
doc := map[string]interface{}{}
|
doc := map[string]interface{}{}
|
||||||
|
fmt.Println("sqdqsd", obj)
|
||||||
b, _ := bson.Marshal(obj)
|
b, _ := bson.Marshal(obj)
|
||||||
bson.Unmarshal(b, &doc)
|
bson.Unmarshal(b, &doc)
|
||||||
doc["_id"] = id
|
doc["_id"] = id
|
||||||
|
|||||||
@@ -91,7 +91,7 @@ func (ao *AbstractObject) UpToDate(user string, peer string, create bool) {
|
|||||||
ao.UpdateDate = time.Now()
|
ao.UpdateDate = time.Now()
|
||||||
ao.UpdaterID = peer
|
ao.UpdaterID = peer
|
||||||
ao.UserUpdaterID = user
|
ao.UserUpdaterID = user
|
||||||
if create {
|
if create && ao.CreatorID != "" {
|
||||||
ao.CreationDate = time.Now()
|
ao.CreationDate = time.Now()
|
||||||
ao.CreatorID = peer
|
ao.CreatorID = peer
|
||||||
ao.UserCreatorID = user
|
ao.UserCreatorID = user
|
||||||
|
|||||||
@@ -2,6 +2,7 @@ package utils
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"errors"
|
"errors"
|
||||||
|
"fmt"
|
||||||
"os"
|
"os"
|
||||||
|
|
||||||
"cloud.o-forge.io/core/oc-lib/dbs"
|
"cloud.o-forge.io/core/oc-lib/dbs"
|
||||||
@@ -28,7 +29,9 @@ func VerifyAccess(a Accessor, id string) error {
|
|||||||
|
|
||||||
// GenericLoadOne loads one object from the database (generic)
|
// GenericLoadOne loads one object from the database (generic)
|
||||||
func GenericStoreOne(data DBObject, a Accessor) (DBObject, int, error) {
|
func GenericStoreOne(data DBObject, a Accessor) (DBObject, int, error) {
|
||||||
|
if data.GetID() == "" {
|
||||||
data.GenerateID()
|
data.GenerateID()
|
||||||
|
}
|
||||||
data.StoreDraftDefault()
|
data.StoreDraftDefault()
|
||||||
data.UpToDate(a.GetUser(), a.GetPeerID(), true)
|
data.UpToDate(a.GetUser(), a.GetPeerID(), true)
|
||||||
f := dbs.Filters{
|
f := dbs.Filters{
|
||||||
@@ -53,6 +56,7 @@ func GenericStoreOne(data DBObject, a Accessor) (DBObject, int, error) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, 422, errors.New("error when validating the received struct: " + err.Error())
|
return nil, 422, errors.New("error when validating the received struct: " + err.Error())
|
||||||
}
|
}
|
||||||
|
fmt.Println(data.GetName(), data.GetCreatorID())
|
||||||
id, code, err := mongo.MONGOService.StoreOne(data, data.GetID(), a.GetType().String())
|
id, code, err := mongo.MONGOService.StoreOne(data, data.GetID(), a.GetType().String())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
a.GetLogger().Error().Msg("Could not store " + data.GetName() + " to db. Error: " + err.Error())
|
a.GetLogger().Error().Msg("Could not store " + data.GetName() + " to db. Error: " + err.Error())
|
||||||
|
|||||||
Reference in New Issue
Block a user