frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2023-10-10 13:36:53 +02:00
Code Issues Releases Wiki Activity

Batch messages sent over comms to prevent flooding

Browse Source
This commit is contained in:
Nick O'Leary 2021-06-16 11:36:24 +01:00
parent 1a27e60e55
commit b516ab9b4f
No known key found for this signature in database
GPG Key ID: 4F2157149161A6C9
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
packages/node_modules/@node-red/editor-api/lib/editor/comms.js vendored
View File

@ -158,25 +158,31 @@ function CommsConnection(ws, user) {
} }
CommsConnection.prototype.send = function(topic,data) { CommsConnection.prototype.send = function(topic,data) {
var self = this;
if (topic && data) { if (topic && data) {
this.stack.push({topic:topic,data:data}); this.stack.push({topic:topic,data:data});
} }
this._queueSend();
}
CommsConnection.prototype._queueSend = function() {
var self = this;
if (!this._xmitTimer) { if (!this._xmitTimer) {
this._xmitTimer = setTimeout(function() { this._xmitTimer = setTimeout(function() {
try { try {
self.ws.send(JSON.stringify(self.stack)); self.ws.send(JSON.stringify(self.stack.splice(0,50)));
self.lastSentTime = Date.now(); self.lastSentTime = Date.now();
} catch(err) { } catch(err) {
removeActiveConnection(self); removeActiveConnection(self);
log.warn(log._("comms.error-send",{message:err.toString()})); log.warn(log._("comms.error-send",{message:err.toString()}));
} }
delete self._xmitTimer; delete self._xmitTimer;
self.stack = []; if (self.stack.length > 0) {
self._queueSend();
}
},50); },50);
} }
} }
CommsConnection.prototype.subscribe = function(topic) { CommsConnection.prototype.subscribe = function(topic) {
runtimeAPI.comms.subscribe({ runtimeAPI.comms.subscribe({
user: this.user, user: this.user,