1
0
mirror of https://github.com/node-red/node-red.git synced 2023-10-10 13:36:53 +02:00
node-red/packages/node_modules/@node-red/editor-client/src/js/comms.js

189 lines
7.0 KiB
JavaScript
Raw Normal View History

2014-05-07 21:47:25 +02:00
/**
* Copyright JS Foundation and other contributors, http://js.foundation
2014-05-07 21:47:25 +02:00
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
**/
2015-07-01 00:42:03 +02:00
2014-08-08 01:01:35 +02:00
RED.comms = (function() {
2015-07-01 00:42:03 +02:00
2014-05-07 21:47:25 +02:00
var errornotification = null;
var clearErrorTimer = null;
var connectCountdownTimer = null;
var connectCountdown = 10;
2014-05-07 21:47:25 +02:00
var subscriptions = {};
2014-05-08 15:15:54 +02:00
var ws;
2014-12-10 15:16:07 +01:00
var pendingAuth = false;
var reconnectAttempts = 0;
var active = false;
2015-07-01 00:42:03 +02:00
2014-05-07 21:47:25 +02:00
function connectWS() {
active = true;
2018-05-11 23:13:13 +02:00
var wspath;
if (RED.settings.apiRootUrl) {
var m = /^(https?):\/\/(.*)$/.exec(RED.settings.apiRootUrl);
if (m) {
console.log(m);
wspath = "ws"+(m[1]==="https"?"s":"")+"://"+m[2]+"comms";
}
} else {
var path = location.hostname;
var port = location.port;
if (port.length !== 0) {
path = path+":"+port;
}
path = path+document.location.pathname;
path = path+(path.slice(-1) == "/"?"":"/")+"comms";
wspath = "ws"+(document.location.protocol=="https:"?"s":"")+"://"+path;
2015-06-17 23:09:05 +02:00
}
2015-07-01 00:42:03 +02:00
2014-12-10 15:16:07 +01:00
var auth_tokens = RED.settings.get("auth-tokens");
pendingAuth = (auth_tokens!=null);
2015-07-01 00:42:03 +02:00
2014-12-10 15:16:07 +01:00
function completeConnection() {
for (var t in subscriptions) {
if (subscriptions.hasOwnProperty(t)) {
ws.send(JSON.stringify({subscribe:t}));
}
}
}
2015-07-01 00:42:03 +02:00
2018-05-11 23:13:13 +02:00
ws = new WebSocket(wspath);
2014-05-07 21:47:25 +02:00
ws.onopen = function() {
reconnectAttempts = 0;
2014-05-07 21:47:25 +02:00
if (errornotification) {
clearErrorTimer = setTimeout(function() {
errornotification.close();
errornotification = null;
},1000);
2014-05-07 21:47:25 +02:00
}
2014-12-10 15:16:07 +01:00
if (pendingAuth) {
2014-11-12 14:21:59 +01:00
ws.send(JSON.stringify({auth:auth_tokens.access_token}));
2014-12-10 15:16:07 +01:00
} else {
completeConnection();
2014-05-08 15:15:54 +02:00
}
2014-05-07 21:47:25 +02:00
}
ws.onmessage = function(event) {
var message = JSON.parse(event.data);
if (message.auth) {
if (pendingAuth) {
if (message.auth === "ok") {
pendingAuth = false;
completeConnection();
} else if (message.auth === "fail") {
// anything else is an error...
active = false;
RED.user.login({updateMenu:true},function() {
connectWS();
})
}
} else if (message.auth === "fail") {
// Our current session has expired
active = false;
RED.user.login({updateMenu:true},function() {
connectWS();
})
}
} else {
// Otherwise, 'message' is an array of actual comms messages
for (var m = 0; m < message.length; m++) {
var msg = message[m];
if (msg.topic) {
for (var t in subscriptions) {
if (subscriptions.hasOwnProperty(t)) {
var re = new RegExp("^"+t.replace(/([\[\]\?\(\)\\\\$\^\*\.|])/g,"\\$1").replace(/\+/g,"[^/]+").replace(/\/#$/,"(\/.*)?")+"$");
if (re.test(msg.topic)) {
var subscribers = subscriptions[t];
if (subscribers) {
for (var i=0;i<subscribers.length;i++) {
subscribers[i](msg.topic,msg.data);
}
}
2014-08-08 01:01:35 +02:00
}
2014-05-08 15:15:54 +02:00
}
}
}
2014-05-07 21:47:25 +02:00
}
}
};
ws.onclose = function() {
if (!active) {
return;
}
if (clearErrorTimer) {
clearTimeout(clearErrorTimer);
clearErrorTimer = null;
2014-05-07 21:47:25 +02:00
}
reconnectAttempts++;
if (reconnectAttempts < 10) {
setTimeout(connectWS,1000);
if (reconnectAttempts > 5 && errornotification == null) {
errornotification = RED.notify(RED._("notification.errors.lostConnection"),"error",true);
}
} else if (reconnectAttempts < 20) {
setTimeout(connectWS,2000);
} else {
connectCountdown = 60;
connectCountdownTimer = setInterval(function() {
connectCountdown--;
if (connectCountdown === 0) {
errornotification.update(RED._("notification.errors.lostConnection"));
clearInterval(connectCountdownTimer);
connectWS();
} else {
var msg = RED._("notification.errors.lostConnectionReconnect",{time: connectCountdown})+' <a href="#">'+ RED._("notification.errors.lostConnectionTry")+'</a>';
errornotification.update(msg,{silent:true});
$(errornotification).find("a").on("click", function(e) {
e.preventDefault();
errornotification.update(RED._("notification.errors.lostConnection"),{silent:true});
clearInterval(connectCountdownTimer);
connectWS();
})
}
},1000);
}
2014-05-07 21:47:25 +02:00
}
}
2015-07-01 00:42:03 +02:00
2014-05-07 21:47:25 +02:00
function subscribe(topic,callback) {
if (subscriptions[topic] == null) {
subscriptions[topic] = [];
}
subscriptions[topic].push(callback);
2014-05-08 15:15:54 +02:00
if (ws && ws.readyState == 1) {
ws.send(JSON.stringify({subscribe:topic}));
}
2014-05-07 21:47:25 +02:00
}
2015-07-01 00:42:03 +02:00
function unsubscribe(topic,callback) {
if (subscriptions[topic]) {
for (var i=0;i<subscriptions[topic].length;i++) {
if (subscriptions[topic][i] === callback) {
subscriptions[topic].splice(i,1);
break;
}
}
if (subscriptions[topic].length === 0) {
delete subscriptions[topic];
}
}
}
2015-07-01 00:42:03 +02:00
2014-05-07 21:47:25 +02:00
return {
2014-05-08 15:15:54 +02:00
connect: connectWS,
subscribe: subscribe,
unsubscribe:unsubscribe
2014-05-07 21:47:25 +02:00
}
2014-08-08 01:01:35 +02:00
})();