|
|
@ -213,7 +213,7 @@ class Messages extends RedisModel {
|
|
|
let messagesByTimestampKey = this.makeRedisKey(REDIS_KEYS.MessagesByTimestamp, sessionId);
|
|
|
redis.zcardAsync(messagesByTimestampKey).then(function (count) {
|
|
|
if (count > maxMessageCacheCount) {
|
|
|
redis.zrevrangeAsync(messagesByTimestampKey, 0, count - maxMessageCacheCount).then(function (idList) {
|
|
|
redis.zrevrangeAsync(messagesByTimestampKey, maxMessageCacheCount, count - maxMessageCacheCount).then(function (idList) {
|
|
|
redis.zremAsync(messagesByTimestampKey, idList).then(function (res) {
|
|
|
redis.hdel(messageById, idList);
|
|
|
})
|
