kosmos/wormhole
kosmos/wormhole
8
0
Fork 0
Code Issues Pull Requests Releases 2 Activity

XMPP: re-connect when disconnected

Browse Source 
closes #1
This commit is contained in:
Basti 2020-11-26 18:43:20 +01:00
parent 377040e196
commit d653d184f2
Signed by untrusted user: basti
GPG Key ID: 9F88009D31D99C72
1 changed files with 22 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
scripts/xmpp-muc-bridge.js
View File

@ -4,8 +4,27 @@ const xmpp = require('simple-xmpp');
const hubotRooms = process.env.HUBOT_IRC_ROOMS.split(','); const hubotRooms = process.env.HUBOT_IRC_ROOMS.split(',');
const xmppRooms = process.env.HUBOT_WORMHOLE_XMPP_ROOMS.split(','); const xmppRooms = process.env.HUBOT_WORMHOLE_XMPP_ROOMS.split(',');
const xmppConfig = {
jid: process.env.HUBOT_WORMHOLE_XMPP_JID,
password: process.env.HUBOT_WORMHOLE_XMPP_PASSWORD,
host: process.env.HUBOT_WORMHOLE_XMPP_HOST,
port: parseInt(process.env.HUBOT_WORMHOLE_XMPP_PORT)
};
module.exports = function (robot) { module.exports = function (robot) {
xmpp.on('online', function(data) {
robot.logger.info('XMPP connected with JID: ' + data.jid.toString());
xmppRooms.forEach(room => xmpp.join(`${room}/wormholedev`));
});
xmpp.on('close', function() {
robot.logger.info('XMPP connection has been closed. Re-connecting...');
xmpp.connect(xmppConfig);
});
xmpp.on('groupchat', function(conference, from, message, whatevs, meta) { xmpp.on('groupchat', function(conference, from, message, whatevs, meta) {
if (meta || (from === 'wormhole')) return; if (meta || (from === 'wormhole')) return;
if (!xmppRooms.includes(conference)) return; if (!xmppRooms.includes(conference)) return;
@ -16,14 +35,11 @@ module.exports = function (robot) {
robot.messageRoom(room, msg); robot.messageRoom(room, msg);
}); });
xmpp.connect({ xmpp.on('error', function(err) {
jid: process.env.HUBOT_WORMHOLE_XMPP_JID, robot.logger.error(err);
password: process.env.HUBOT_WORMHOLE_XMPP_PASSWORD,
host: process.env.HUBOT_WORMHOLE_XMPP_HOST,
port: parseInt(process.env.HUBOT_WORMHOLE_XMPP_PORT)
}); });
xmppRooms.forEach(room => xmpp.join(`${room}/wormhole`)); xmpp.connect(xmppConfig);
function messageMUC(res) { function messageMUC(res) {
const message = res.message; const message = res.message;