From 8751d36b347d8217bdf6dd9b009a030158590949 Mon Sep 17 00:00:00 2001 From: mr Date: Tue, 20 Aug 2024 12:20:30 +0200 Subject: [PATCH] id on peer --- dbs/mongo/mongo.go | 3 +++ models/workflow/workflow_mongo_accessor.go | 5 ++++- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/dbs/mongo/mongo.go b/dbs/mongo/mongo.go index c951ec6..d727294 100644 --- a/dbs/mongo/mongo.go +++ b/dbs/mongo/mongo.go @@ -53,6 +53,9 @@ func (m *MongoDB) Init(collections []string, config MongoConf) { } func (m *MongoDB) createClient(MongoURL string) error { + if mngoClient != nil { + return nil + } var err error // Allows us to use marshal and unmarshall with results of FindOne() and others bsonOpts := &options.BSONOptions{ diff --git a/models/workflow/workflow_mongo_accessor.go b/models/workflow/workflow_mongo_accessor.go index ee576da..436bafc 100644 --- a/models/workflow/workflow_mongo_accessor.go +++ b/models/workflow/workflow_mongo_accessor.go @@ -92,7 +92,10 @@ func (wfa *workflowMongoAccessor) book(id string, realData *Workflow, execs []*w if _, ok := methods[tools.POST]; !ok { return errors.New("no path found") } - res, _, _ := wfa.LoadOne(id) + res, code, _ := wfa.LoadOne(id) + if code == 200 { + return errors.New("could not load workflow") + } r := res.(*Workflow) g := r.Graph if realData.Graph != nil {