diff --git a/entrypoint.go b/entrypoint.go index 0b6c143..d2cd739 100644 --- a/entrypoint.go +++ b/entrypoint.go @@ -1,6 +1,8 @@ package oclib import ( + "fmt" + "cloud.o-forge.io/core/oc-lib/dbs/mongo" "cloud.o-forge.io/core/oc-lib/logs" "cloud.o-forge.io/core/oc-lib/models" @@ -102,6 +104,7 @@ func DeleteOne(collection LibDataEnum, id string) LibData { func StoreOne(collection LibDataEnum, object map[string]interface{}) LibData { model := models.Model(collection.EnumIndex()) + fmt.Println(object) d, code, err := model.GetAccessor().StoreOne(model.Deserialize(object)) if err != nil { return LibData{Data: d, Code: code, Err: err.Error()} diff --git a/models/resources/storage/storage.go b/models/resources/storage/storage.go index 73f9bd4..a16635b 100644 --- a/models/resources/storage/storage.go +++ b/models/resources/storage/storage.go @@ -18,10 +18,9 @@ type StorageResource struct { Size uint `bson:"size,omitempty" json:"size,omitempty"` Url *URL `bson:"url,omitempty" json:"url,omitempty"` // Will allow to select between several protocols - Encryption bool `bson:"encryption,omitempty" json:"encryption,omitempty"` - Redundancy string `bson:"redundancy,omitempty" json:"redundancy,omitempty"` - Throughput string `bson:"throughput,omitempty" json:"throughput,omitempty"` - BookingPrice uint `bson:"booking_price,omitempty" json:"booking_price,omitempty"` + Encryption bool `bson:"encryption,omitempty" json:"encryption,omitempty"` + Redundancy string `bson:"redundancy,omitempty" json:"redundancy,omitempty"` + Throughput string `bson:"throughput,omitempty" json:"throughput,omitempty"` } func (dma *StorageResource) Deserialize(j map[string]interface{}) utils.DBObject { diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go index 4f3209f..786140c 100644 --- a/models/workflow/workflow_mongo_accessor.go +++ b/models/workflow/workflow_mongo_accessor.go @@ -2,6 +2,7 @@ package oclib import ( "errors" + "fmt" "slices" "cloud.o-forge.io/core/oc-lib/dbs/mongo" @@ -65,6 +66,7 @@ func (wfa *WorkflowMongoAccessor) UpdateOne(set utils.DBObject, id string) (util if code, err := wfa.execution(set.(*Workflow), true); err != nil { return nil, code, err } + fmt.Println(set.Serialize()) return wfa.GenericUpdateOne(set, id, wfa, &Workflow{}) }