Skip to content

Commit 6969f5a

Browse files
committed
11
1 parent 2c51a22 commit 6969f5a

4 files changed

Lines changed: 18 additions & 6 deletions

File tree

OpenFlow/src/Messages/Message.ts

Lines changed: 15 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2227,18 +2227,30 @@ export class Message {
22272227
item.consumers = consumers;
22282228
item.name = queue.name + "(" + consumers + ")";
22292229
if (exists.length == 0) {
2230-
await Config.db.InsertOne(item, "configclients", 1, false, jwt);
2230+
try {
2231+
await Config.db.InsertOne(item, "configclients", 1, false, jwt);
2232+
} catch (error) {
2233+
cli._logger.error(error);
2234+
}
22312235
} else {
22322236
item._id = exists[i]._id;
2233-
await Config.db._UpdateOne(null, item, "configclients", 1, false, jwt);
2237+
try {
2238+
await Config.db._UpdateOne(null, item, "configclients", 1, false, jwt);
2239+
} catch (error) {
2240+
cli._logger.error(error);
2241+
}
22342242
}
22352243
}
22362244
for (let i = 0; i < known.length; i++) {
22372245
let queue: any = known[i];
22382246
let id = queue.id;
22392247
let exists = queues.filter((x: any) => x.queuename == queue.name);
22402248
if (exists.length == 0) {
2241-
await Config.db.DeleteOne(queue._id, "configclients", jwt);
2249+
try {
2250+
await Config.db.DeleteOne(queue._id, "configclients", jwt);
2251+
} catch (error) {
2252+
cli._logger.error(error);
2253+
}
22422254
}
22432255
}
22442256
} catch (error) {

OpenFlowNodeRED/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "openflow-nodered",
3-
"version": "1.0.57",
3+
"version": "1.0.59",
44
"description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
55
"main": "index.js",
66
"scripts": {

VERSION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
1.0.58
1+
1.0.59

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "openiap",
3-
"version": "1.0.57",
3+
"version": "1.0.59",
44
"description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
55
"main": "index.js",
66
"scripts": {

0 commit comments

Comments
 (0)