core/oc-lib
5
0
Fork 0
Code Issues 3 Pull Requests Packages Projects Releases Wiki Activity

set up print

Browse Source
This commit is contained in:
mr 2024-07-29 13:36:25 +02:00
parent c7f65914bb
commit 956af8f5f5
3 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
entrypoint.go
View File

@ -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()}

7
models/resources/storage/storage.go
View File

@ -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 {

2
models/workflow/workflow_mongo_accessor.go
View File

@ -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{})
}