Skip to content

Commit 65d18dd

Browse files
committed
update lastheartbeat on any message
1 parent 2d56a13 commit 65d18dd

6 files changed

Lines changed: 9 additions & 9 deletions

File tree

OpenFlow/src/Messages/Message.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -210,9 +210,9 @@ export class Message {
210210

211211
if (!NoderedUtil.IsNullEmpty(this.command)) { this.command = this.command.toLowerCase(); }
212212
let command: string = this.command;
213+
cli.lastheartbeat = new Date();
213214
if (command == "ping" || command == "pong") {
214215
if (command == "ping") this.Ping(cli);
215-
cli.lastheartbeat = new Date();
216216
return;
217217
}
218218
try {

OpenFlow/src/WebSocketServer.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -126,8 +126,8 @@ export class WebSocketServer {
126126
Logger.instanse.info("removing disconnected client " + cli.id + "/" + cli.user.name + "/" + cli.clientagent);
127127
span.addEvent("removing disconnected client " + cli.id + "/" + cli.user.name + "/" + cli.clientagent);
128128
} else {
129-
Logger.instanse.info("removing disconnected client " + cli.id + "/" + cli.clientagent + " timeout, close down");
130-
span.addEvent("removing disconnected client " + cli.id + "/" + cli.clientagent + " timeout, close down");
129+
Logger.instanse.info("removing disconnected client " + cli.id + "/" + cli.clientagent);
130+
span.addEvent("removing disconnected client " + cli.id + "/" + cli.clientagent);
131131
}
132132
WebSocketServer._clients.splice(i, 1);
133133
}

OpenFlow/src/public/Controllers.ts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6907,7 +6907,7 @@ export class ResourcesCtrl extends entitiesCtrl<Resource> {
69076907

69086908
const support = await this.newResource("Support Agreement", "customer", "singlevariant", "singlevariant", {},
69096909
[
6910-
this.newProduct("Basic Support", "prod_HEGjSQ9M6wiYiP", "plan_HEGjLCtwsVbIx8", "single", "single", supporthours._id, "plan_HEZAsA1DfkiQ6k", 1, {}, true, 0),
6910+
this.newProduct("Basic Support", "prod_HEGjSQ9M6wiYiP", "plan_HEGjLCtwsVbIx8", "single", "single", supporthours._id, "plan_HEZAsA1DfkiQ6k", 1, {}, false, 0),
69116911
], true, true, 0);
69126912

69136913
const premium: Resource = await this.newResource("Openflow License", "customer", "singlevariant", "singlevariant", {},
@@ -6940,13 +6940,13 @@ export class ResourcesCtrl extends entitiesCtrl<Resource> {
69406940

69416941
const support = await this.newResource("Support Agreement", "customer", "singlevariant", "singlevariant", {},
69426942
[
6943-
this.newProduct("Basic Support", "prod_HG1vTqU4c7EaV5", "plan_HG1vb53VlOu46y", "single", "single", supporthours._id, "plan_HG1wBF6yq1O15C", 1, {}, true, 0),
6943+
this.newProduct("Basic Support", "prod_HG1vTqU4c7EaV5", "plan_HG1vb53VlOu46y", "single", "single", supporthours._id, "plan_HG1wBF6yq1O15C", 1, {}, false, 0),
69446944
], true, true, 0);
69456945

69466946
const premium: Resource = await this.newResource("Openflow License", "customer", "singlevariant", "singlevariant", {},
69476947
[
69486948
this.newProduct("Premium License", "prod_JcXS2AvXfwk1Lv", "price_1J2KcMC2vUMc6gvhmmsAGo35", "multiple", "multiple", supporthours._id, "plan_HFkbfsAs1Yvcly", 1, {}, true, 0),
6949-
this.newProduct("Premium License Legacy", "prod_HFkZ8lKn7GtFQU", "plan_HFka1sgovtAQ7k", "single", "single", supporthours._id, "plan_HFkbfsAs1Yvcly", 1, {}, true, 1),
6949+
this.newProduct("Premium License Legacy", "prod_HFkZ8lKn7GtFQU", "plan_HFka1sgovtAQ7k", "single", "single", supporthours._id, "plan_HFkbfsAs1Yvcly", 1, {}, false, 1),
69506950
], true, true, 2);
69516951

69526952
const databaseusage: Resource = await this.newResource("Database Usage", "customer", "singlevariant", "singlevariant", { dbusage: (1048576 * 25) },

OpenFlowNodeRED/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@openiap/nodered",
3-
"version": "1.3.44",
3+
"version": "1.3.45",
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.3.44
1+
1.3.45

package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@openiap/openflow",
3-
"version": "1.3.44",
3+
"version": "1.3.45",
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)