This commit is contained in:
mr
2024-07-19 13:15:51 +02:00
parent 5c44b46bcb
commit cdc077c59e
8 changed files with 78 additions and 1 deletions

View File

@@ -22,6 +22,25 @@ type AbstractWorkflow struct {
Schedule WorkflowSchedule `bson:"schedule,omitempty" json:"schedule,omitempty"`
}
func (w *AbstractWorkflow) ObjDeserialize(j map[string]interface{}) *AbstractWorkflow {
b, err := json.Marshal(j)
if err != nil {
return nil
}
json.Unmarshal(b, w)
return w
}
func (w *AbstractWorkflow) ObjSerialize() map[string]interface{} {
var m map[string]interface{}
b, err := json.Marshal(w)
if err != nil {
return nil
}
json.Unmarshal(b, w)
return m
}
func (w *AbstractWorkflow) isDCLink(link graph.GraphLink) bool {
if _, exists := w.Datacenters[link.Destination.ID]; exists {
return true
@@ -50,6 +69,7 @@ func (dma *WorkflowResource) Deserialize(j map[string]interface{}) utils.DBObjec
return nil
}
json.Unmarshal(b, dma)
dma.AbstractResource.ObjDeserialize(j)
return dma
}
@@ -60,5 +80,6 @@ func (dma *WorkflowResource) Serialize() map[string]interface{} {
return nil
}
json.Unmarshal(b, dma)
dma.AbstractResource.ObjSerialize()
return m
}