From 2b23a6564788da8b4cd648f5cc43bf94d512e5ab Mon Sep 17 00:00:00 2001 From: mr Date: Tue, 27 Aug 2024 13:11:34 +0200 Subject: [PATCH] Bug on Format date --- models/workspace/shared/shared_workspace_mongo_accessor.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/models/workspace/shared/shared_workspace_mongo_accessor.go b/models/workspace/shared/shared_workspace_mongo_accessor.go index 6736fe2..9532884 100644 --- a/models/workspace/shared/shared_workspace_mongo_accessor.go +++ b/models/workspace/shared/shared_workspace_mongo_accessor.go @@ -1,6 +1,7 @@ package shared_workspace import ( + "fmt" "slices" "cloud.o-forge.io/core/oc-lib/dbs" @@ -60,7 +61,7 @@ func (wfa *sharedWorkspaceMongoAccessor) sharedWorkspace(shared *SharedWorkspace continue } for _, p := range shared.Peers { - if code != 200 { + if code != 200 || (&peer.Peer{AbstractObject: utils.AbstractObject{UUID: p}}).IsMySelf() { continue } paccess := (&peer.Peer{}) @@ -97,6 +98,9 @@ func (wfa *sharedWorkspaceMongoAccessor) sharedWorkflow(shared *SharedWorkspace, } paccess := (&peer.Peer{}) for _, p := range shared.Peers { + if (&peer.Peer{AbstractObject: utils.AbstractObject{UUID: p}}).IsMySelf() { + continue + } b, err := paccess.LaunchPeerExecution(p, v, utils.WORKFLOW, tools.DELETE, nil, wfa.Caller) if err != nil && b == nil { wfa.Logger.Error().Msg("Could not send to peer " + p + ". Error: " + err.Error()) @@ -168,6 +172,7 @@ func (wfa *sharedWorkspaceMongoAccessor) sendToPeer(shared *SharedWorkspace) { func (wfa *sharedWorkspaceMongoAccessor) UpdateOne(set utils.DBObject, id string) (utils.DBObject, int, error) { res, code, err := wfa.GenericUpdateOne(set.(*SharedWorkspace), id, wfa, &SharedWorkspace{}) + fmt.Println("UPDATE SHARED", res.Serialize()) wfa.deleteToPeer(res.(*SharedWorkspace)) wfa.sharedWorkflow(res.(*SharedWorkspace), id) wfa.sharedWorkspace(res.(*SharedWorkspace), id)