From 7a02d85ec50c1eaa53824c95a19a4d4dcea7c0a4 Mon Sep 17 00:00:00 2001 From: ansuz Date: Thu, 21 Apr 2016 17:02:54 +0200 Subject: [PATCH] Netflux server mustn't send a zero message until the history is synced --- NetfluxWebsocketSrv.js | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/NetfluxWebsocketSrv.js b/NetfluxWebsocketSrv.js index d2f5f0fb9..93aac0d0e 100644 --- a/NetfluxWebsocketSrv.js +++ b/NetfluxWebsocketSrv.js @@ -66,8 +66,8 @@ dropUser = function (ctx, user) { }); }; -const getHistory = function (ctx, channelName, handler) { - ctx.store.getMessages(channelName, function (msgStr) { handler(JSON.parse(msgStr)); }); +const getHistory = function (ctx, channelName, handler, cb) { + ctx.store.getMessages(channelName, function (msgStr) { handler(JSON.parse(msgStr)); }, cb); }; const randName = function () { return Crypto.randomBytes(16).toString('hex'); }; @@ -105,8 +105,9 @@ const handleMessage = function (ctx, user, msg) { if (parsed[0] === 'GET_HISTORY') { getHistory(ctx, parsed[1], function (msg) { sendMsg(ctx, user, [0, HISTORY_KEEPER_ID, 'MSG', user.id, JSON.stringify(msg)]); + }, function () { + sendMsg(ctx, user, [0, HISTORY_KEEPER_ID, 'MSG', user.id, 0]); }); - sendMsg(ctx, user, [0, HISTORY_KEEPER_ID, 'MSG', user.id, 0]); } return; }