From 869b8b357bdea47bc0de2020de7df36936fbf122 Mon Sep 17 00:00:00 2001 From: Pietro Brenna Date: Fri, 14 Feb 2020 15:59:14 +0100 Subject: [PATCH] cose iniziali --- .gitignore | 1 + 92-xmpp.html | 155 ++++++++++++++++++++++++++++ 92-xmpp.js | 270 +++++++++++++++++++++++++++++++++++++++++++++++++ LICENSE | 14 +++ README.md | 45 +++++++++ icons/xmpp.png | Bin 0 -> 1042 bytes package.json | 24 +++++ 7 files changed, 509 insertions(+) create mode 100644 .gitignore create mode 100644 92-xmpp.html create mode 100644 92-xmpp.js create mode 100644 LICENSE create mode 100644 README.md create mode 100644 icons/xmpp.png create mode 100644 package.json diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..c2658d7 --- /dev/null +++ b/.gitignore @@ -0,0 +1 @@ +node_modules/ diff --git a/92-xmpp.html b/92-xmpp.html new file mode 100644 index 0000000..df2d497 --- /dev/null +++ b/92-xmpp.html @@ -0,0 +1,155 @@ + + + + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/92-xmpp.js b/92-xmpp.js new file mode 100644 index 0000000..9fab652 --- /dev/null +++ b/92-xmpp.js @@ -0,0 +1,270 @@ + +module.exports = function(RED) { + "use strict"; + var XMPP = require('simple-xmpp'); + process.env.NODE_TLS_REJECT_UNAUTHORIZED = '0' + + function XMPPServerNode(n) { + RED.nodes.createNode(this,n); + this.server = n.server; + this.port = n.port; + this.nickname = n.nickname; + this.username = n.user; + var credentials = this.credentials; + if (credentials) { + this.password = credentials.password; + } + this.client = new XMPP.SimpleXMPP(); + this.connected = false; + var that = this; + + this.client.con = function() { + if (that.connected === false ) { + that.connected = true; + that.client.connect({ + jid : that.username, + password : that.password, + host : that.server, + port : that.port, + //skipPresence : true, + reconnect : true, + preferred : "PLAIN" + }); + } + } + + that.client.on('online', function(data) { + that.connected = true; + that.client.setPresence('online', data.jid.user+' is online'); + that.log('connected as '+data.jid.user+' to '+data.jid._domain+":5222"); + }); + that.client.on('close', function() { + that.connected = false; + that.log('connection closed'); + }); + this.on("close", function(done) { + that.client.setPresence('offline'); + that.client.disconnect(); + if (that.client.conn) { that.client.conn.end(); } + that.client = null; + done(); + }); + } + + RED.nodes.registerType("xmpp-server",XMPPServerNode,{ + credentials: { + password: {type: "password"} + } + }); + + function XmppInNode(n) { + RED.nodes.createNode(this,n); + this.server = n.server; + this.serverConfig = RED.nodes.getNode(this.server); + this.nick = this.serverConfig.nickname || this.serverConfig.username.split("@")[0]; + this.join = n.join || false; + this.sendAll = n.sendObject; + this.from = n.to || ""; + var node = this; + + var xmpp = this.serverConfig.client; + + xmpp.on('online', function(data) { + node.status({fill:"green",shape:"dot",text:"connected"}); + if ((node.join) && (node.from !== "")) { + // disable chat history + var to = node.to+'/'+node.nick; + var stanza = new xmpp.Element('presence', {"to": to}). + c('x', { xmlns: 'http://jabber.org/protocol/muc' }). + c('history', { maxstanzas:0, seconds:1 }); + xmpp.conn.send(stanza); + xmpp.join(to); + } + }); + + // xmpp.on('chat', function(from, message) { + // var msg = { topic:from, payload:message }; + // if (!node.join && ((node.from === "") || (node.from === from))) { + // node.send([msg,null]); + // } + // }); + + xmpp.on('stanza', function(stanza) { + if (stanza.is('message')) { + if (stanza.attrs.type == 'chat') { + //console.log(stanza); + var body = stanza.getChild('body'); + if (body) { + var msg = { payload:body.getText() }; + var ids = stanza.attrs.from.split('/'); + if (ids[1].length !== 36) { + msg.topic = stanza.attrs.from + } + else { msg.topic = ids[0]; } + if (!node.join && ((node.from === "") || (node.from === stanza.attrs.from))) { + node.send([msg,null]); + } + } + } + } + }); + + xmpp.on('groupchat', function(conference, from, message, stamp) { + var msg = { topic:from, payload:message, room:conference }; + if (from != node.nick) { + if ((node.join) && (node.from === conference)) { + node.send([msg,null]); + } + } + }); + + //xmpp.on('chatstate', function(from, state) { + //console.log('%s is currently %s', from, state); + //var msg = { topic:from, payload: {presence:state} }; + //node.send([null,msg]); + //}); + + xmpp.on('buddy', function(jid, state, statusText) { + node.log(jid+" is "+state+" : "+statusText); + var msg = { topic:jid, payload: { presence:state, status:statusText} }; + node.send([null,msg]); + }); + + // xmpp.on('groupbuddy', function(conference, from, state, statusText) { + // //console.log('%s: %s is in %s state - %s',conference, from, state, statusText); + // var msg = { topic:from, payload: { presence:state, status:statusText}, room:conference }; + // }); + + xmpp.on('error', function(err) { + if (RED.settings.verbose) { node.log(err); } + if (err.hasOwnProperty("stanza")) { + if (err.stanza.name === 'stream:error') { node.error("stream:error - bad login id/pwd ?",err); } + else { node.error(err.stanza.name,err); } + node.status({fill:"red",shape:"ring",text:"bad login"}); + } + else { + if (err.errno === "ETIMEDOUT") { + node.error("Timeout connecting to server",err); + node.status({fill:"red",shape:"ring",text:"timeout"}); + } + else if (err === "XMPP authentication failure") { + node.error(err,err); + node.status({fill:"red",shape:"ring",text:"XMPP authentication failure"}); + } + else { + node.error(err.errno,err); + node.status({fill:"red",shape:"ring",text:"error"}); + } + } + }); + + xmpp.on('subscribe', function(from) { + xmpp.acceptSubscription(from); + }); + + // Now actually make the connection + try { + node.status({fill:"grey",shape:"dot",text:"connecting"}); + xmpp.con(); + } + catch(e) { + node.error("Bad xmpp configuration"); + node.status({fill:"red",shape:"ring",text:"not connected"}); + } + + node.on("close", function() { + node.status({}); + }); + } + RED.nodes.registerType("xmpp in",XmppInNode); + + + function XmppOutNode(n) { + RED.nodes.createNode(this,n); + this.server = n.server; + this.serverConfig = RED.nodes.getNode(this.server); + this.nick = this.serverConfig.nickname || this.serverConfig.username.split("@")[0]; + this.join = n.join || false; + this.sendAll = n.sendObject; + this.to = n.to || ""; + var node = this; + + var xmpp = this.serverConfig.client; + + xmpp.on('online', function(data) { + node.status({fill:"green",shape:"dot",text:"connected"}); + if ((node.join) && (node.from !== "")) { + // disable chat history + var to = node.to+'/'+node.nick; + var stanza = new xmpp.Element('presence', {"to": to}). + c('x', { xmlns: 'http://jabber.org/protocol/muc' }). + c('history', { maxstanzas:0, seconds:1 }); + xmpp.conn.send(stanza); + xmpp.join(to); + } + }); + + xmpp.on('error', function(err) { + if (RED.settings.verbose) { node.log(err); } + if (err.hasOwnProperty("stanza")) { + if (err.stanza.name === 'stream:error') { node.error("stream:error - bad login id/pwd ?",err); } + else { node.error(err.stanza.name,err); } + node.status({fill:"red",shape:"ring",text:"bad login"}); + } + else { + if (err.errno === "ETIMEDOUT") { + node.error("Timeout connecting to server",err); + node.status({fill:"red",shape:"ring",text:"timeout"}); + } + else if (err === "XMPP authentication failure") { + node.error(err,err); + node.status({fill:"red",shape:"ring",text:"XMPP authentication failure"}); + } + else { + node.error(err.errno,err); + node.status({fill:"red",shape:"ring",text:"error"}); + } + } + }); + + // Now actually make the connection + try { + node.status({fill:"grey",shape:"dot",text:"connecting"}); + xmpp.con(); + } + catch(e) { + node.error("Bad xmpp configuration"); + node.status({fill:"red",shape:"ring",text:"not connected"}); + } + + node.on("input", function(msg) { + if (msg.presence) { + if (['away', 'dnd', 'xa', 'chat'].indexOf(msg.presence) > -1 ) { + xmpp.setPresence(msg.presence, msg.payload); + } + else { node.warn("Can't set presence - invalid value: "+msg.presence); } + } + else { + var to = node.to || msg.topic || ""; + if (to !== "") { + if (node.sendAll) { + xmpp.send(to, JSON.stringify(msg), node.join); + } + else if (msg.payload) { + if (typeof(msg.payload) === "object") { + xmpp.send(to, JSON.stringify(msg.payload), node.join); + } + else { + xmpp.send(to, msg.payload.toString(), node.join); + } + } + } + } + }); + + node.on("close", function() { + node.status({}); + }); + } + RED.nodes.registerType("xmpp out",XmppOutNode); +} diff --git a/LICENSE b/LICENSE new file mode 100644 index 0000000..f5b6011 --- /dev/null +++ b/LICENSE @@ -0,0 +1,14 @@ +Copyright 2016 JS Foundation and other contributors, https://js.foundation/ +Copyright 2013-2016 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. diff --git a/README.md b/README.md new file mode 100644 index 0000000..f4ca592 --- /dev/null +++ b/README.md @@ -0,0 +1,45 @@ +node-red-node-xmpp +================== + +A Node-RED node to talk to an XMPP server. + +Install +------- + +Run the following command in your Node-RED user directory - typically `~/.node-red` + + npm install node-red-node-xmpp + + +Usage +----- + +Provides two nodes - one to send messages, and one to receive. + +### Receive + +Connects to an XMPP server to receive messages.

+ +The **Buddy** field is the id of the buddy or room you want to receive messages from. + +Incoming messages will appear as `msg.payload` on the first output, while `msg.topic` will contain who it is from. + +The second output will show the presence and status of a user in `msg.payload`. +Again `msg.topic` will hold the user. + +### Send + +Connects to an XMPP server to send messages. + +The **To** field is optional. If not set the `msg.topic` property of the message is used to set that value. + +If you are joining a chat room then the **To** field must be filled in with the room name. + +You may also send a msg with `msg.presence` to set your presence to one of + + 1. chat + 2. away + 3. dnd + 4. xa + +If you do this then the `msg.payload` is used to set your status message. diff --git a/icons/xmpp.png b/icons/xmpp.png new file mode 100644 index 0000000000000000000000000000000000000000..636847e38011ca4a10791d5457c84a5da2f63bf1 GIT binary patch literal 1042 zcmV+t1nv8YP)P000>X1^@s6#OZ}&00001b5ch_0Itp) z=>Px#24YJ`L;(K){{a7>y{D4^000SaNLh0L01FcU01FcV0GgZ_00007bV*G`2i^t- z3NSRit~wI{00WXqL_t(Y$K91NXe4D6$N%r`xY>{>iDmbpCg9D6?j*gkxf|<>!>fHGF_*9@Ns<^55i_p>0Jqz1v|6o0X1>kLoaZ^r49tw`!)FIUhKGlts!vq~nVC_& zUe{_hcBiMOf9iBP;8yFjP*wc^KrABWy|+ro06eFvwLu^vnm02L5d%PyB*e@FU=aYO zrl!FClfQ>ycz)l#UJn4!?RH=9^?K%<6IB%vF%h|W zW@n8%=St_CW?3e299yT;`Q-5Mkal->FSdnlw+jFW!|<&rip+a2dP=%mmgVDRS@t1I zS(ce|PMvcWhT&I7M@K{d*nj%1b~>GRkB^VFEK5;U6OmgL;6|2ZmSveb=PZh%+uPgQ z{I89!4+_KZjWkVT5m7UR&i&z>Gv}Pdas1)(@-px5?_bVQ_xAQsdE4_RCnsBZ zo{O1T)y3T?iWUJNj^oSEgfva>-^X!$(|fOZp2uZbT3MDKnOUtm$d{T45ALEX&bjxq zEZgzkuRG`F@;v`qL_!f+Rn@D1r$-ln#?0(ZBANiu1@O(#(9r#1mL$p5dcFRdnO(2d zYWDzq#>`u15AB7K=Q(-r$DDKZ^WOJuCP|V;Q4~+6Y1*h9{2`7%0lgPwoEcG{-T(jq M07*qoM6N<$g3|5Z$^ZZW literal 0 HcmV?d00001 diff --git a/package.json b/package.json new file mode 100644 index 0000000..a37f3b5 --- /dev/null +++ b/package.json @@ -0,0 +1,24 @@ +{ + "name" : "node-red-node-xmpp", + "version" : "0.2.4", + "description" : "A Node-RED node to talk to an XMPP server", + "dependencies" : { + "simple-xmpp" : "^1.3.1" + }, + "repository" : { + "type":"git", + "url":"https://github.com/node-red/node-red-nodes/tree/master/social/xmpp" + }, + "license": "Apache-2.0", + "keywords": [ "node-red", "xmpp" ], + "node-red" : { + "nodes" : { + "xmpp": "92-xmpp.js" + } + }, + "author": { + "name": "Dave Conway-Jones", + "email": "ceejay@vnet.ibm.com", + "url": "http://nodered.org" + } +}