|
|
@ -105,9 +105,8 @@ Channel.removeOwnedChannelHistory = function (Env, channelId, unsafeKey, hash, c
|
|
|
|
}).nThen(function () {
|
|
|
|
}).nThen(function () {
|
|
|
|
Env.msgStore.trimChannel(channelId, hash, function (err) {
|
|
|
|
Env.msgStore.trimChannel(channelId, hash, function (err) {
|
|
|
|
if (err) { return void cb(err); }
|
|
|
|
if (err) { return void cb(err); }
|
|
|
|
|
|
|
|
// clear historyKeeper's cache for this channel
|
|
|
|
|
|
|
|
Env.historyKeeper.channelClose(channelId);
|
|
|
|
// XXX you must also clear the channel's index from historyKeeper cache
|
|
|
|
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
});
|
|
|
|
};
|
|
|
|
};
|
|
|
|