From 2a8efd4f8cd994f519a18d87fec8deb756768713 Mon Sep 17 00:00:00 2001 From: Julian Lam Date: Wed, 25 Mar 2026 15:22:26 -0400 Subject: [PATCH] fix: sortedSetIncrByBulk null response --- src/database/redis/sorted.js | 4 ++++ test/database/sorted.js | 6 ++++-- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/src/database/redis/sorted.js b/src/database/redis/sorted.js index 8433133f15..aea003dcdf 100644 --- a/src/database/redis/sorted.js +++ b/src/database/redis/sorted.js @@ -261,6 +261,10 @@ module.exports = function (module) { }; module.sortedSetIncrByBulk = async function (data) { + if (!Array.isArray(data) || !data.length) { + return []; + } + const multi = module.client.multi(); data.forEach((item) => { multi.zIncrBy(item[0], item[1], String(item[2])); diff --git a/test/database/sorted.js b/test/database/sorted.js index 389153c3d2..2d17988e5a 100644 --- a/test/database/sorted.js +++ b/test/database/sorted.js @@ -1061,8 +1061,10 @@ NUMERIC)-- WsPn&query[cid]=-1&parentCid=0&selectedCids[]=-1&privilege=topics:rea this.set = utils.generateUUID(); }); - it('should throw', async function () { - await assert.rejects(db.sortedSetIncrByBulk(this.set, [])); + it('should return empty array', async function () { + const response = await db.sortedSetIncrByBulk(this.set, []); + assert(Array.isArray(response)); + assert.strictEqual(response.length, 0); }); });