From 637b2c977dda85a2b05a714b7a76b3079be6e890 Mon Sep 17 00:00:00 2001
From: mr <mr>
Date: Wed, 24 Jul 2024 09:53:30 +0200
Subject: [PATCH] Serialize failures

---
 dbs/mongo/mongo.go                              | 2 --
 models/resources/data/data.go                   | 2 +-
 models/resources/datacenter/datacenter.go       | 2 +-
 models/resources/processing/processing.go       | 2 +-
 models/resources/storage/storage.go             | 2 +-
 models/resources/workflow/workflow.go           | 2 +-
 models/workflow/workflow.go                     | 4 +---
 models/workflow_execution/workflow_execution.go | 2 +-
 8 files changed, 7 insertions(+), 11 deletions(-)

diff --git a/dbs/mongo/mongo.go b/dbs/mongo/mongo.go
index 2f23ec6..3e12e01 100644
--- a/dbs/mongo/mongo.go
+++ b/dbs/mongo/mongo.go
@@ -3,7 +3,6 @@ package mongo
 import (
 	"context"
 	"errors"
-	"fmt"
 	"time"
 
 	"cloud.o-forge.io/core/oc-lib/dbs"
@@ -172,7 +171,6 @@ func (m *MongoDB) UpdateOne(set interface{}, id string, collection_name string)
 	targetDBCollection := CollectionMap[collection_name]
 	MngoCtx, cancel = context.WithTimeout(context.Background(), 10*time.Second)
 	defer cancel()
-	fmt.Println(doc)
 	_, err := targetDBCollection.UpdateOne(MngoCtx, filter, dbs.InputToBson(doc, true))
 	if err != nil {
 		m.Logger.Error().Msg("Couldn't update resource: " + err.Error())
diff --git a/models/resources/data/data.go b/models/resources/data/data.go
index e911385..7f96f85 100644
--- a/models/resources/data/data.go
+++ b/models/resources/data/data.go
@@ -29,7 +29,7 @@ func (dma *DataResource) Serialize() map[string]interface{} {
 	if err != nil {
 		return nil
 	}
-	json.Unmarshal(b, dma)
+	json.Unmarshal(b, &m)
 	return m
 }
 
diff --git a/models/resources/datacenter/datacenter.go b/models/resources/datacenter/datacenter.go
index e8233ba..4758698 100644
--- a/models/resources/datacenter/datacenter.go
+++ b/models/resources/datacenter/datacenter.go
@@ -51,7 +51,7 @@ func (dma *DatacenterResource) Serialize() map[string]interface{} {
 	if err != nil {
 		return nil
 	}
-	json.Unmarshal(b, dma)
+	json.Unmarshal(b, &m)
 	return m
 }
 
diff --git a/models/resources/processing/processing.go b/models/resources/processing/processing.go
index 4a22dc0..0f1f582 100644
--- a/models/resources/processing/processing.go
+++ b/models/resources/processing/processing.go
@@ -46,7 +46,7 @@ func (dma *ProcessingResource) Serialize() map[string]interface{} {
 	if err != nil {
 		return nil
 	}
-	json.Unmarshal(b, dma)
+	json.Unmarshal(b, &m)
 	return m
 }
 
diff --git a/models/resources/storage/storage.go b/models/resources/storage/storage.go
index 8906823..436036c 100644
--- a/models/resources/storage/storage.go
+++ b/models/resources/storage/storage.go
@@ -39,7 +39,7 @@ func (dma *StorageResource) Serialize() map[string]interface{} {
 	if err != nil {
 		return nil
 	}
-	json.Unmarshal(b, dma)
+	json.Unmarshal(b, &m)
 	return m
 }
 
diff --git a/models/resources/workflow/workflow.go b/models/resources/workflow/workflow.go
index fd8452e..d08e4ec 100644
--- a/models/resources/workflow/workflow.go
+++ b/models/resources/workflow/workflow.go
@@ -52,6 +52,6 @@ func (dma *WorkflowResource) Serialize() map[string]interface{} {
 	if err != nil {
 		return nil
 	}
-	json.Unmarshal(b, dma)
+	json.Unmarshal(b, &m)
 	return m
 }
diff --git a/models/workflow/workflow.go b/models/workflow/workflow.go
index 040dc53..5f6457c 100644
--- a/models/workflow/workflow.go
+++ b/models/workflow/workflow.go
@@ -2,7 +2,6 @@ package oclib
 
 import (
 	"encoding/json"
-	"fmt"
 
 	w "cloud.o-forge.io/core/oc-lib/models/resources/workflow"
 	"cloud.o-forge.io/core/oc-lib/models/utils"
@@ -29,7 +28,6 @@ func (dma *Workflow) Deserialize(j map[string]interface{}) utils.DBObject {
 		return nil
 	}
 	json.Unmarshal(b, dma)
-	fmt.Println(j, dma)
 	return dma
 }
 
@@ -39,6 +37,6 @@ func (dma *Workflow) Serialize() map[string]interface{} {
 	if err != nil {
 		return nil
 	}
-	json.Unmarshal(b, dma)
+	json.Unmarshal(b, &m)
 	return m
 }
diff --git a/models/workflow_execution/workflow_execution.go b/models/workflow_execution/workflow_execution.go
index 14211cc..1009c78 100644
--- a/models/workflow_execution/workflow_execution.go
+++ b/models/workflow_execution/workflow_execution.go
@@ -78,6 +78,6 @@ func (dma *WorkflowExecution) Serialize() map[string]interface{} {
 	if err != nil {
 		return nil
 	}
-	json.Unmarshal(b, dma)
+	json.Unmarshal(b, &m)
 	return m
 }