enforce asynchrony in 'gethistoryOffset'

5 years ago · bc034d95a3
parent e80a81a2bb
commit bc034d95a3
1 changed files with 2 additions and 1 deletions
--- a/lib/hk-util.js
+++ b/lib/hk-util.js
@ -436,7 +436,8 @@ const storeMessage = function (Env, channel, msg, isCp, optionalMessageHash) {
      * -1 if you didn't find it

 */
-const getHistoryOffset = (Env, channelName, lastKnownHash, cb) => {
+const getHistoryOffset = (Env, channelName, lastKnownHash, _cb) => {
+    const cb = Util.once(Util.mkAsync(_cb));
    const store = Env.store;
    const Log = Env.Log;