frodovdr/node-red-nodes
1
0
Fork 0
mirror of https://github.com/node-red/node-red-nodes.git synced 2025-03-01 10:37:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

better filtering for XMPP messages, stop history when joining rooms

Browse Source
This commit is contained in:
Dave Conway-Jones
2018-09-28 21:42:36 +01:00
parent b856ee6439
commit 7bd255a341
3 changed files with 27 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
social/xmpp/92-xmpp.js
View File

@@ -78,18 +78,32 @@ module.exports = function(RED) {
xmpp.on('online', function(data) {
node.status({fill:"green",shape:"dot",text:"connected"});
if ((node.join) && (node.from !== "")) {
xmpp.join(node.to+'/'+node.nick);
// 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 };
node.send([msg,null]);
if (!node.join && ((node.from === "") || (node.from === from))) {
node.send([msg,null]);
}
});
xmpp.on('groupchat', function(conference, from, message, stamp) {
if (!stamp) {stamp = Date.now(); }
//else { console.log("STAMP",stamp) }
var msg = { topic:from, payload:message, room:conference, ts:stamp };
if (from != node.nick) { node.send([msg,null]); }
if (from != node.nick) {
if ((node.join) && (node.from === conference)) {
node.send([msg,null]);
}
}
});
//xmpp.on('chatstate', function(from, state) {
@@ -170,7 +184,13 @@ module.exports = function(RED) {
xmpp.on('online', function(data) {
node.status({fill:"green",shape:"dot",text:"connected"});
if ((node.join) && (node.from !== "")) {
xmpp.join(node.to+'/'+node.nick);
// 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);
}
});