mongo adjust

This commit is contained in:
mr
2026-02-05 15:06:45 +01:00
parent e32ba1e37a
commit 2cf960e4f7
3 changed files with 4 additions and 7 deletions

View File

@@ -3,7 +3,6 @@ package mongo
import (
"context"
"errors"
"fmt"
"slices"
"time"
@@ -248,16 +247,11 @@ func (m *MongoDB) StoreOne(obj interface{}, id string, collection_name string) (
if err := m.createClient(mngoConfig.GetUrl(), false); err != nil {
return "", 503, err
}
doc := map[string]interface{}{}
fmt.Println("sqdqsd", obj)
b, _ := bson.Marshal(obj)
bson.Unmarshal(b, &doc)
doc["_id"] = id
targetDBCollection := CollectionMap[collection_name]
MngoCtx, cancel = context.WithTimeout(context.Background(), 5*time.Second)
//defer cancel()
_, err := targetDBCollection.InsertOne(MngoCtx, doc)
_, err := targetDBCollection.InsertOne(MngoCtx, obj)
if err != nil {
// m.Logger.Error().Msg("Couldn't insert resource: " + err.Error())
return "", 409, err