Merge pull request #170 from matiu/feature/noMessages
Feature/no messages
This commit is contained in:
commit
a582fdacb2
@ -15,6 +15,7 @@ module.exports.init = function(io_ext) {
|
|||||||
socket.on('subscribe', function(topic) {
|
socket.on('subscribe', function(topic) {
|
||||||
logger.debug('subscribe to ' + topic);
|
logger.debug('subscribe to ' + topic);
|
||||||
socket.join(topic);
|
socket.join(topic);
|
||||||
|
socket.emit('subscribed');
|
||||||
});
|
});
|
||||||
|
|
||||||
// disconnect handler
|
// disconnect handler
|
||||||
|
|||||||
@ -26,8 +26,13 @@ module.exports.init = function(ext_io, config) {
|
|||||||
throw new Error('Couldn\'t get messages on sync request: ' + err);
|
throw new Error('Couldn\'t get messages on sync request: ' + err);
|
||||||
}
|
}
|
||||||
logger.verbose('\tFound ' + messages.length + ' message' + (messages.length !== 1 ? 's' : ''));
|
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');
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
});
|
});
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user