access func

models/workflow/workflow.go

@@ -1,6 +1,8 @@
 package oclib
 
 import (
+	"encoding/json"
+
 	"cloud.o-forge.io/core/oc-lib/models/resources"
 	"cloud.o-forge.io/core/oc-lib/models/resources/data"
 	"cloud.o-forge.io/core/oc-lib/models/resources/datacenter"
@@ -8,6 +10,7 @@ import (
 	"cloud.o-forge.io/core/oc-lib/models/resources/storage"
 	"cloud.o-forge.io/core/oc-lib/models/utils"
 	"cloud.o-forge.io/core/oc-lib/models/workflow/graph"
+	tool "cloud.o-forge.io/core/oc-lib/utils"
 )
 
 const WORKFLOW = "workflow"
@@ -22,10 +25,10 @@ type Workflow struct {
 	Schedule    WorkflowSchedule                 `bson:"schedule,omitempty" json:"schedule,omitempty"`
 }
 
-func (d *Workflow) GetAccessor(driver utils.Driver) utils.Accessor {
+func (d *Workflow) GetAccessor(driver tool.Driver) utils.Accessor {
 	var data utils.Accessor
 	switch driver {
-	case utils.MONGO:
+	case tool.MONGO:
 		data = &WorkflowMongoAccessor{}
 	default:
 		data = &WorkflowMongoAccessor{}
@@ -34,6 +37,15 @@ func (d *Workflow) GetAccessor(driver utils.Driver) utils.Accessor {
 	return data
 }
 
+func (dma *Workflow) Deserialize(j map[string]interface{}) utils.DBObject {
+	b, err := json.Marshal(j)
+	if err != nil {
+		return nil
+	}
+	json.Unmarshal(b, dma)
+	return dma
+}
+
 func (w *Workflow) isDCLink(link graph.GraphLink) bool {
 	if _, exists := w.Datacenters[link.Destination.ID]; exists {
 		return true