Debugging Put / GET ALL

models/resources/data/data_mongo_accessor.go

@@ -44,10 +44,12 @@ func (wfa DataMongoAccessor) LoadAll() ([]utils.ShallowDBObject, int, error) {
 		wfa.Logger.Error().Msg("Could not retrieve any from db. Error: " + err.Error())
 		return nil, code, err
 	}
-	for res_mongo.Next(mongo.MngoCtx) {
+	var results []DataResource
-		var obj DataResource
+	if err = res_mongo.All(mongo.MngoCtx, &results); err != nil {
-		res_mongo.Decode(&obj)
+		return nil, 404, err
-		objs = append(objs, &obj.AbstractResource)
+	}
+	for _, r := range results {
+		objs = append(objs, &r.AbstractResource)
 	}
 	return objs, 200, nil
 }

models/resources/datacenter/datacenter_mongo_accessor.go

@@ -46,10 +46,12 @@ func (wfa DatacenterMongoAccessor) LoadAll() ([]utils.ShallowDBObject, int, erro
 		wfa.Logger.Error().Msg("Could not retrieve any from db. Error: " + err.Error())
 		return nil, code, err
 	}
-	for res_mongo.Next(mongo.MngoCtx) {
+	var results []DatacenterResource
-		var obj DatacenterResource
+	if err = res_mongo.All(mongo.MngoCtx, &results); err != nil {
-		res_mongo.Decode(&obj)
+		return nil, 404, err
-		objs = append(objs, &obj.AbstractResource)
+	}
+	for _, r := range results {
+		objs = append(objs, &r.AbstractResource)
 	}
 	return objs, 200, nil
 }

models/resources/processing/processing_mongo_accessor.go

@@ -47,10 +47,12 @@ func (wfa ProcessingMongoAccessor) LoadAll() ([]utils.ShallowDBObject, int, erro
 		wfa.Logger.Error().Msg("Could not retrieve any from db. Error: " + err.Error())
 		return nil, code, err
 	}
-	for res_mongo.Next(mongo.MngoCtx) {
+	var results []ProcessingResource
-		var obj ProcessingResource
+	if err = res_mongo.All(mongo.MngoCtx, &results); err != nil {
-		res_mongo.Decode(&obj)
+		return nil, 404, err
-		objs = append(objs, &obj.AbstractResource)
+	}
+	for _, r := range results {
+		objs = append(objs, &r.AbstractResource)
 	}
 	return objs, 200, nil
 }

models/resources/storage/storage_mongo_accessor.go

@@ -47,10 +47,12 @@ func (wfa StorageMongoAccessor) LoadAll() ([]utils.ShallowDBObject, int, error)
 		wfa.Logger.Error().Msg("Could not retrieve any from db. Error: " + err.Error())
 		return nil, code, err
 	}
-	for res_mongo.Next(mongo.MngoCtx) {
+	var results []StorageResource
-		var obj StorageResource
+	if err = res_mongo.All(mongo.MngoCtx, &results); err != nil {
-		res_mongo.Decode(&obj)
+		return nil, 404, err
-		objs = append(objs, &obj.AbstractResource)
+	}
+	for _, r := range results {
+		objs = append(objs, &r.AbstractResource)
 	}
 	return objs, 200, nil
 }

models/resources/workflow/workflow_mongo_accessor.go

@@ -50,10 +50,12 @@ func (wfa WorkflowResourceMongoAccessor) LoadAll() ([]utils.ShallowDBObject, int
 		wfa.Logger.Error().Msg("Could not retrieve any from db. Error: " + err.Error())
 		return nil, code, err
 	}
-	for res_mongo.Next(mongo.MngoCtx) {
+	var results []WorkflowResource
-		var obj WorkflowResource
+	if err = res_mongo.All(mongo.MngoCtx, &results); err != nil {
-		res_mongo.Decode(&obj)
+		return nil, 404, err
-		objs = append(objs, &obj.AbstractResource)
+	}
+	for _, r := range results {
+		objs = append(objs, &r.AbstractResource)
 	}
 	return objs, 200, nil
 }

models/utils/abstracts.go

@@ -1,6 +1,8 @@
 package utils
 
 import (
+	"fmt"
+
 	"cloud.o-forge.io/core/oc-lib/dbs/mongo"
 	"cloud.o-forge.io/core/oc-lib/logs"
 	"github.com/go-playground/validator/v10"
@@ -79,7 +81,8 @@ func (dma *AbstractAccessor) GenericUpdateOne(set DBObject, id string, accessor
 	for k, v := range changeMap {
 		original[k] = v
 	}
-	id, code, err := mongo.MONGOService.UpdateOne(set.Deserialize(original), id, accessor.GetType())
+	fmt.Println(original)
+	id, code, err := mongo.MONGOService.UpdateOne(r.Deserialize(original), id, accessor.GetType())
 	if err != nil {
 		dma.Logger.Error().Msg("Could not update " + id + " to db. Error: " + err.Error())
 		return nil, code, err

models/workflow/workflow_mongo_accessor.go

@@ -99,10 +99,12 @@ func (wfa WorkflowMongoAccessor) LoadAll() ([]utils.ShallowDBObject, int, error)
 		wfa.Logger.Error().Msg("Could not retrieve any from db. Error: " + err.Error())
 		return nil, code, err
 	}
-	for res_mongo.Next(mongo.MngoCtx) {
+	var results []Workflow
-		var obj Workflow
+	if err = res_mongo.All(mongo.MngoCtx, &results); err != nil {
-		res_mongo.Decode(&obj)
+		return nil, 404, err
-		objs = append(objs, &obj.AbstractObject)
+	}
+	for _, r := range results {
+		objs = append(objs, &r.AbstractObject)
 	}
 	return objs, 200, nil
 }

models/workflow_execution/workflow_execution_mongo_accessor.go

@@ -43,10 +43,12 @@ func (wfa WorkflowExecutionMongoAccessor) LoadAll() ([]utils.ShallowDBObject, in
 		wfa.Logger.Error().Msg("Could not retrieve any from db. Error: " + err.Error())
 		return nil, code, err
 	}
-	for res_mongo.Next(mongo.MngoCtx) {
+	var results []WorkflowExecution
-		var obj utils.AbstractObject
+	if err = res_mongo.All(mongo.MngoCtx, &results); err != nil {
-		res_mongo.Decode(&obj)
+		return nil, 404, err
-		objs = append(objs, &obj)
+	}
+	for _, r := range results {
+		objs = append(objs, &r)
 	}
 	return objs, 200, nil
 }