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

test booking

Browse Source
This commit is contained in:
mr 2024-09-25 10:02:10 +02:00
parent 89a1ab3f6e
commit 2df71c6571
2 changed files with 5 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
models/workflow/workflow_mongo_accessor.go
View File

@ -97,8 +97,8 @@ func (wfa *workflowMongoAccessor) DeleteOne(id string) (utils.DBObject, int, err
res, code, err := wfa.GenericDeleteOne(id, wfa) res, code, err := wfa.GenericDeleteOne(id, wfa)
if res != nil && code == 200 { if res != nil && code == 200 {
wfa.execute(res.(*Workflow), false, false) // up to date the workspace for the workflow wfa.execute(res.(*Workflow), false, false) // up to date the workspace for the workflow
wfa.share(res.(*Workflow), true, wfa.Caller)
} }
wfa.share(res.(*Workflow), true, wfa.Caller) // send the deletion to the peers where workflow is shared
return res, code, err return res, code, err
} }
@ -206,25 +206,20 @@ func (wfa *workflowMongoAccessor) execution(id string, realData *Workflow, delet
} }
accessor := (&workflow_execution.WorkflowExecution{}).GetAccessor(nil) accessor := (&workflow_execution.WorkflowExecution{}).GetAccessor(nil)
execs, err := wfa.getExecutions(id, realData) // get the executions of the workflow execs, err := wfa.getExecutions(id, realData) // get the executions of the workflow
fmt.Println("EXECUTIONS", execs)
if err != nil { if err != nil {
return 422, err return 422, err
} }
err = wfa.book(id, realData, execs) // book the workflow on the peers err = wfa.book(id, realData, execs) // book the workflow on the peers
fmt.Println("BOOKING", err)
if err != nil { if err != nil {
return 409, err // if the booking fails, return an error for integrity between peers return 409, err // if the booking fails, return an error for integrity between peers
} }
fmt.Println("BOOKING2", err, delete)
if delete { // if delete is set to true, delete the executions if delete { // if delete is set to true, delete the executions
return 200, nil return 200, nil
} }
fmt.Println("EXECS", err, len(execs))
if len(execs) > 0 { // if the executions are set, store them if len(execs) > 0 { // if the executions are set, store them
for _, obj := range execs { for _, obj := range execs {
_, code, err := accessor.StoreOne(obj) _, code, err := accessor.StoreOne(obj)
fmt.Println("EXECS LOOP", err, code)
if code != 200 { if code != 200 {
return code, err return code, err
} }
@ -263,7 +258,7 @@ func (wfa *workflowMongoAccessor) UpdateOne(set utils.DBObject, id string) (util
// StoreOne stores a workflow in the database // StoreOne stores a workflow in the database
func (wfa *workflowMongoAccessor) StoreOne(data utils.DBObject) (utils.DBObject, int, error) { func (wfa *workflowMongoAccessor) StoreOne(data utils.DBObject) (utils.DBObject, int, error) {
res, code, err := wfa.GenericStoreOne(data, wfa) res, code, err := wfa.GenericStoreOne(data, wfa)
if err != nil { if err != nil || code != 200 {
return nil, code, err return nil, code, err
} }
wfa.share(res.(*Workflow), false, wfa.Caller) // share the creation to the peers wfa.share(res.(*Workflow), false, wfa.Caller) // share the creation to the peers

2
models/workspace/workspace_mongo_accessor.go
View File

@ -30,7 +30,9 @@ func New() *workspaceMongoAccessor {
// it checks if a workspace with the same name already exists // it checks if a workspace with the same name already exists
func (wfa *workspaceMongoAccessor) DeleteOne(id string) (utils.DBObject, int, error) { func (wfa *workspaceMongoAccessor) DeleteOne(id string) (utils.DBObject, int, error) {
res, code, err := wfa.GenericDeleteOne(id, wfa) res, code, err := wfa.GenericDeleteOne(id, wfa)
if code == 200 && res != nil {
wfa.share(res.(*Workspace), true, wfa.Caller) // Share the deletion to the peers wfa.share(res.(*Workspace), true, wfa.Caller) // Share the deletion to the peers
}
return res, code, err return res, code, err
} }