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

peer is a public data

Browse Source
This commit is contained in:
mr 2025-02-04 16:51:13 +01:00
parent 69bf951866
commit a8e2445c10
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
dbs/mongo/mongo.go
View File

@ -48,7 +48,7 @@ func (m *MongoDB) Init(collections []string, config MongoConf) {
mngoCollections = collections mngoCollections = collections
mngoConfig = config mngoConfig = config
if err := m.createClient(config.GetUrl(), false); err != nil { if err := m.createClient(config.GetUrl(), false); err != nil {
m.Logger.Error().Msg(err.Error()) // m.Logger.Error().Msg(err.Error())
} }
} }
@ -175,7 +175,7 @@ func (m *MongoDB) DeleteOne(id string, collection_name string) (int64, int, erro
result, err := targetDBCollection.DeleteOne(MngoCtx, filter, opts) result, err := targetDBCollection.DeleteOne(MngoCtx, filter, opts)
if err != nil { if err != nil {
m.Logger.Error().Msg("Couldn't insert resource: " + err.Error()) // m.Logger.Error().Msg("Couldn't insert resource: " + err.Error())
return 0, 404, err return 0, 404, err
} }
return result.DeletedCount, 200, nil return result.DeletedCount, 200, nil
@ -196,7 +196,7 @@ func (m *MongoDB) DeleteMultiple(f map[string]interface{}, collection_name strin
result, err := targetDBCollection.DeleteMany(MngoCtx, filter, opts) result, err := targetDBCollection.DeleteMany(MngoCtx, filter, opts)
if err != nil { if err != nil {
m.Logger.Error().Msg("Couldn't insert resource: " + err.Error()) // m.Logger.Error().Msg("Couldn't insert resource: " + err.Error())
return 0, 404, err return 0, 404, err
} }
return result.DeletedCount, 200, nil return result.DeletedCount, 200, nil
@ -218,7 +218,7 @@ func (m *MongoDB) UpdateMultiple(set interface{}, filter map[string]interface{},
//defer cancel() //defer cancel()
res, err := targetDBCollection.UpdateMany(MngoCtx, f, dbs.InputToBson(doc, true)) res, err := targetDBCollection.UpdateMany(MngoCtx, f, dbs.InputToBson(doc, true))
if err != nil { if err != nil {
m.Logger.Error().Msg("Couldn't update resource: " + err.Error()) // m.Logger.Error().Msg("Couldn't update resource: " + err.Error())
return 0, 404, err return 0, 404, err
} }
return res.UpsertedCount, 200, nil return res.UpsertedCount, 200, nil
@ -237,7 +237,7 @@ func (m *MongoDB) UpdateOne(set interface{}, id string, collection_name string)
//defer cancel() //defer cancel()
_, err := targetDBCollection.UpdateOne(MngoCtx, filter, dbs.InputToBson(doc, true)) _, err := targetDBCollection.UpdateOne(MngoCtx, filter, dbs.InputToBson(doc, true))
if err != nil { if err != nil {
m.Logger.Error().Msg("Couldn't update resource: " + err.Error()) // m.Logger.Error().Msg("Couldn't update resource: " + err.Error())
return "", 404, err return "", 404, err
} }
return id, 200, nil return id, 200, nil
@ -257,7 +257,7 @@ func (m *MongoDB) StoreOne(obj interface{}, id string, collection_name string) (
_, err := targetDBCollection.InsertOne(MngoCtx, doc) _, err := targetDBCollection.InsertOne(MngoCtx, doc)
if err != nil { if err != nil {
m.Logger.Error().Msg("Couldn't insert resource: " + err.Error()) // m.Logger.Error().Msg("Couldn't insert resource: " + err.Error())
return "", 409, err return "", 409, err
} }
@ -275,7 +275,7 @@ func (m *MongoDB) LoadOne(id string, collection_name string) (*mongo.SingleResul
res := targetDBCollection.FindOne(MngoCtx, filter) res := targetDBCollection.FindOne(MngoCtx, filter)
if res.Err() != nil { if res.Err() != nil {
m.Logger.Error().Msg("Couldn't find resource " + id + ". Error : " + res.Err().Error()) // m.Logger.Error().Msg("Couldn't find resource " + id + ". Error : " + res.Err().Error())
err := res.Err() err := res.Err()
return nil, 404, err return nil, 404, err
} }
@ -341,7 +341,7 @@ func (m *MongoDB) LoadFilter(filter map[string]interface{}, collection_name stri
res, err := targetDBCollection.Find(MngoCtx, f) res, err := targetDBCollection.Find(MngoCtx, f)
if err != nil { if err != nil {
m.Logger.Error().Msg("Couldn't find any resources. Error : " + err.Error()) // m.Logger.Error().Msg("Couldn't find any resources. Error : " + err.Error())
return nil, 404, err return nil, 404, err
} }
return res, 200, nil return res, 200, nil
@ -358,7 +358,7 @@ func (m *MongoDB) LoadAll(collection_name string) (*mongo.Cursor, int, error) {
res, err := targetDBCollection.Find(MngoCtx, bson.D{}) res, err := targetDBCollection.Find(MngoCtx, bson.D{})
if err != nil { if err != nil {
m.Logger.Error().Msg("Couldn't find any resources. Error : " + err.Error()) // m.Logger.Error().Msg("Couldn't find any resources. Error : " + err.Error())
return nil, 404, err return nil, 404, err
} }
return res, 200, nil return res, 200, nil

2
models/workflow_execution/workflow_execution.go
View File

@ -37,7 +37,7 @@ func (r *WorkflowExecutions) CanUpdate(set utils.DBObject) (bool, utils.DBObject
if r.State != set.(*WorkflowExecutions).State { if r.State != set.(*WorkflowExecutions).State {
return true, &WorkflowExecutions{State: set.(*WorkflowExecutions).State} // only state can be updated return true, &WorkflowExecutions{State: set.(*WorkflowExecutions).State} // only state can be updated
} }
return r.IsDraft, set // only draft buying can be updated return !r.IsDraft, set // only draft buying can be updated
} }
func (r *WorkflowExecutions) CanDelete() bool { func (r *WorkflowExecutions) CanDelete() bool {