mirror of
https://github.com/node-red/node-red.git
synced 2023-10-10 13:36:53 +02:00
0c636ca707
now only logs connects/reconnects, errors and "raw" input commands (so you can debug them when you get it wrong) All other messages appear on the node output anyway.
238 lines
12 KiB
JavaScript
238 lines
12 KiB
JavaScript
/**
|
|
* Copyright 2013 IBM Corp.
|
|
*
|
|
* 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.
|
|
**/
|
|
|
|
module.exports = function(RED) {
|
|
"use strict";
|
|
var irc = require("irc");
|
|
|
|
// The Server Definition - this opens (and closes) the connection
|
|
function IRCServerNode(n) {
|
|
RED.nodes.createNode(this,n);
|
|
this.server = n.server;
|
|
this.channel = n.channel;
|
|
this.nickname = n.nickname;
|
|
this.lastseen = 0;
|
|
this.ircclient = null;
|
|
this.on("close", function() {
|
|
if (this.ircclient != null) {
|
|
this.ircclient.removeAllListeners();
|
|
this.ircclient.disconnect();
|
|
}
|
|
});
|
|
}
|
|
RED.nodes.registerType("irc-server",IRCServerNode);
|
|
|
|
|
|
// The Input Node
|
|
function IrcInNode(n) {
|
|
RED.nodes.createNode(this,n);
|
|
this.ircserver = n.ircserver;
|
|
this.serverConfig = RED.nodes.getNode(this.ircserver);
|
|
this.channel = n.channel || this.serverConfig.channel;
|
|
var node = this;
|
|
if (node.serverConfig.ircclient === null) {
|
|
node.log("Connecting to "+node.serverConfig.server);
|
|
node.status({fill:"grey",shape:"dot",text:"connecting"});
|
|
node.serverConfig.ircclient = new irc.Client(node.serverConfig.server, node.serverConfig.nickname,{autoConnect:false,retryDelay:20000});
|
|
node.serverConfig.ircclient.setMaxListeners(0);
|
|
node.serverConfig.ircclient.addListener('error', function(message) {
|
|
node.log(JSON.stringify(message));
|
|
});
|
|
node.serverConfig.ircclient.addListener('netError', function(message) {
|
|
node.log(JSON.stringify("NET "+message));
|
|
node.serverConfig.lastseen = Date.now();
|
|
});
|
|
node.serverConfig.ircclient.addListener('connect', function() {
|
|
node.serverConfig.lastseen = Date.now();
|
|
});
|
|
node.serverConfig.ircclient.addListener('ping', function(server) {
|
|
node.serverConfig.lastseen = Date.now();
|
|
//node.log("PING "+JSON.stringify(server));
|
|
});
|
|
node.recon = setInterval( function() {
|
|
//console.log("CHK ",(Date.now()-node.serverConfig.lastseen)/1000);
|
|
if ((Date.now()-node.serverConfig.lastseen) > 300000) { // if more than 5 mins since last seen
|
|
node.ircclient.send.apply(node.ircclient,["TIME"]); // request time to check link
|
|
}
|
|
if ((Date.now()-node.serverConfig.lastseen) > 400000) { // If more than 6.5 mins
|
|
node.serverConfig.ircclient.disconnect();
|
|
node.serverConfig.ircclient.connect();
|
|
node.log("reconnect"); // then retry
|
|
}
|
|
node.ircclient.send.apply(node.ircclient,["TIME"]); // request time to check link
|
|
}, 60000); // check every 1 min
|
|
}
|
|
else { node.status({text:""}); }
|
|
node.ircclient = node.serverConfig.ircclient;
|
|
|
|
node.ircclient.addListener('registered', function(message) {
|
|
//node.log(node.ircclient.nick+" ONLINE");
|
|
node.status({fill:"yellow",shape:"dot",text:"connected"});
|
|
node.ircclient.join( node.channel, function(data) {
|
|
// node.log(data+" JOINED "+node.channel);
|
|
node.status({fill:"green",shape:"dot",text:"joined"});
|
|
});
|
|
});
|
|
node.ircclient.addListener('message', function (from, to, message) {
|
|
//node.log(from + ' => ' + to + ' : ' + message);
|
|
if (~node.channel.toLowerCase().indexOf(to.toLowerCase())) {
|
|
var msg = { "topic":from, "from":from, "to":to, "payload":message };
|
|
node.send([msg,null]);
|
|
}
|
|
//else { console.log(node.channel,to); }
|
|
});
|
|
node.ircclient.addListener('pm', function(from, message) {
|
|
//node.log("PM => "+from + ': ' + message);
|
|
var msg = { "topic":from, "from":from, "to":"PRIV", "payload":message };
|
|
node.send([msg,null]);
|
|
});
|
|
node.ircclient.addListener('join', function(channel, who) {
|
|
var msg = { "payload": { "type":"join", "who":who, "channel":channel } };
|
|
node.send([null,msg]);
|
|
//node.log(who+' has joined '+channel);
|
|
});
|
|
node.ircclient.addListener('invite', function(channel, from, message) {
|
|
var msg = { "payload": { "type":"invite", "who":from, "channel":channel, "message":message } };
|
|
node.send([null,msg]);
|
|
//node.log(from+' sent invite to '+channel+': '+message);
|
|
});
|
|
node.ircclient.addListener('part', function(channel, who, reason) {
|
|
var msg = { "payload": { "type":"part", "who":who, "channel":channel, "reason":reason } };
|
|
node.send([null,msg]);
|
|
//node.log(who+' has left '+channel+': '+reason);
|
|
});
|
|
node.ircclient.addListener('quit', function(nick, reason, channels, message) {
|
|
var msg = { "payload": { "type":"quit", "who":nick, "channel":channels, "reason":reason } };
|
|
node.send([null,msg]);
|
|
//node.log(nick+' has quit '+channels+': '+reason);
|
|
});
|
|
node.ircclient.addListener('kick', function(channel, who, by, reason) {
|
|
var msg = { "payload": { "type":"kick", "who":who, "channel":channel, "by":by, "reason":reason } };
|
|
node.send([null,msg]);
|
|
//node.log(who+' was kicked from '+channel+' by '+by+': '+reason);
|
|
});
|
|
node.ircclient.addListener('names', function (channel, nicks) {
|
|
var msg = { "payload": { "type": "names", "channel": channel, "names": nicks} };
|
|
node.send([null, msg]);
|
|
});
|
|
node.ircclient.addListener('raw', function (message) { // any message means we are alive
|
|
node.serverConfig.lastseen = Date.now();
|
|
});
|
|
node.on("close", function() {
|
|
node.ircclient.removeAllListeners();
|
|
if (node.recon) { clearInterval(node.recon); }
|
|
});
|
|
}
|
|
RED.nodes.registerType("irc in",IrcInNode);
|
|
|
|
|
|
// The Output Node
|
|
function IrcOutNode(n) {
|
|
RED.nodes.createNode(this,n);
|
|
this.sendFlag = n.sendObject;
|
|
this.ircserver = n.ircserver;
|
|
this.serverConfig = RED.nodes.getNode(this.ircserver);
|
|
this.channel = n.channel || this.serverConfig.channel;
|
|
var node = this;
|
|
if (node.serverConfig.ircclient === null) {
|
|
node.log("connecting to "+node.serverConfig.server);
|
|
node.status({fill:"grey",shape:"dot",text:"connecting"});
|
|
node.serverConfig.ircclient = new irc.Client(node.serverConfig.server, node.serverConfig.nickname,{autoConnect:false,retryDelay:20000});
|
|
node.serverConfig.ircclient.setMaxListeners(0);
|
|
node.serverConfig.ircclient.addListener('error', function(message) {
|
|
node.log(JSON.stringify(message));
|
|
});
|
|
node.serverConfig.ircclient.addListener('netError', function(message) {
|
|
node.log(JSON.stringify("NET "+message));
|
|
node.serverConfig.lastseen = Date.now();
|
|
});
|
|
node.serverConfig.ircclient.addListener('connect', function() {
|
|
node.serverConfig.lastseen = Date.now();
|
|
});
|
|
node.serverConfig.ircclient.addListener('ping', function(server) {
|
|
node.serverConfig.lastseen = Date.now();
|
|
//node.log("PING "+JSON.stringify(server));
|
|
});
|
|
node.serverConfig.ircclient.addListener('raw', function (message) { // any message received means we are alive
|
|
if (message.commandType === "reply") { node.serverConfig.lastseen = Date.now(); }
|
|
});
|
|
node.recon = setInterval( function() {
|
|
//console.log("CHK ",(Date.now()-node.serverConfig.lastseen)/1000);
|
|
if ((Date.now()-node.serverConfig.lastseen) > 300000) { // if more than 5 mins since last seen
|
|
node.ircclient.send.apply(node.ircclient,["TIME"]); // request time to check link
|
|
}
|
|
if ((Date.now()-node.serverConfig.lastseen) > 400000) { // If more than 6.5 mins
|
|
node.serverConfig.ircclient.disconnect();
|
|
node.serverConfig.ircclient.connect();
|
|
node.log("reconnect"); // then retry
|
|
}
|
|
node.ircclient.send.apply(node.ircclient,["TIME"]); // request time to check link
|
|
}, 60000); // check every 1 min
|
|
node.serverConfig.ircclient.connect();
|
|
}
|
|
else { node.status({text:""}); }
|
|
node.ircclient = node.serverConfig.ircclient;
|
|
|
|
node.ircclient.addListener('registered', function(message) {
|
|
node.log(node.ircclient.nick+" ONLINE");
|
|
node.status({fill:"yellow",shape:"dot",text:"connected"});
|
|
node.ircclient.join( node.channel, function(data) {
|
|
//node.log(data+" JOINED "+node.channel);
|
|
node.status({fill:"green",shape:"dot",text:"joined"});
|
|
});
|
|
});
|
|
|
|
node.on("input", function(msg) {
|
|
if (Object.prototype.toString.call( msg.raw ) === '[object Array]') {
|
|
node.log("RAW command:"+msg.raw);
|
|
node.ircclient.send.apply(node.ircclient,msg.raw);
|
|
//var m = msg.raw;
|
|
//for (var i = 0; i < 10; i++) {
|
|
//if (typeof m[i] !== "string") { m[i] = ""; }
|
|
//m[i] = m[i].replace(/"/g, "");
|
|
//}
|
|
//node.log("RAW command:"+m);
|
|
//node.ircclient.send(m[0],m[1],m[2],m[3],m[4],m[5],m[6],m[7],m[8],m[9]);
|
|
}
|
|
else {
|
|
if (msg._topic) { delete msg._topic; }
|
|
var ch = node.channel.split(","); // split on , so we can send to multiple
|
|
if (node.sendFlag == "true") { // override channels with msg.topic
|
|
if ((msg.hasOwnProperty('topic'))&&(typeof msg.topic === "string")) {
|
|
ch = msg.topic.split(","); // split on , so we can send to multiple
|
|
}
|
|
else { node.warn("msg.topic not set"); }
|
|
}
|
|
for (var c = 0; c < ch.length; c++) {
|
|
if (node.sendFlag == "false") { // send whole message object to each channel
|
|
node.ircclient.say(ch[c], JSON.stringify(msg));
|
|
}
|
|
else { // send just the payload to each channel
|
|
if (typeof msg.payload === "object") { msg.payload = JSON.stringify(msg.payload); }
|
|
node.ircclient.say(ch[c], msg.payload);
|
|
}
|
|
}
|
|
}
|
|
});
|
|
|
|
node.on("close", function() {
|
|
node.ircclient.removeAllListeners();
|
|
if (node.recon) { clearInterval(node.recon); }
|
|
});
|
|
}
|
|
RED.nodes.registerType("irc out",IrcOutNode);
|
|
}
|