From c6b8464bc3f86a1afa65fb820e7433510fa27f44 Mon Sep 17 00:00:00 2001 From: Matias Alejo Garcia Date: Thu, 28 Aug 2014 19:20:27 -0300 Subject: [PATCH 1/2] add no message event --- plugins/mailbox.js | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/plugins/mailbox.js b/plugins/mailbox.js index a32da98..57b9cbf 100644 --- a/plugins/mailbox.js +++ b/plugins/mailbox.js @@ -26,8 +26,13 @@ module.exports.init = function(ext_io, config) { throw new Error('Couldn\'t get messages on sync request: ' + err); } logger.verbose('\tFound ' + messages.length + ' message' + (messages.length !== 1 ? 's' : '')); - for (var i = 0; i < messages.length; i++) { - broadcastMessage(messages[i], socket); + + if (messages.length) { + for (var i = 0; i < messages.length; i++) { + broadcastMessage(messages[i], socket); + } + } else { + socket.emit('no messages'); } }); }); From 384ce8ad501c40a7efcab0119a9fe6912ce848dc Mon Sep 17 00:00:00 2001 From: Matias Alejo Garcia Date: Thu, 28 Aug 2014 19:22:52 -0300 Subject: [PATCH 2/2] add subscribed event --- app/controllers/socket.js | 1 + 1 file changed, 1 insertion(+) diff --git a/app/controllers/socket.js b/app/controllers/socket.js index 8c573b5..de01ba3 100644 --- a/app/controllers/socket.js +++ b/app/controllers/socket.js @@ -15,6 +15,7 @@ module.exports.init = function(io_ext) { socket.on('subscribe', function(topic) { logger.debug('subscribe to ' + topic); socket.join(topic); + socket.emit('subscribed'); }); // disconnect handler