Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 16:46:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: #11947, make user message has a numeric timestamp

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2023-08-23 18:07:05 -04:00
parent f5baca1451
commit dc0fb81bf5
1 changed files with 10 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
src/upgrades/3.3.0/chat_room_refactor.js
View File

@@ -40,22 +40,27 @@ module.exports = {
const { roomId } = roomData; const { roomId } = roomData;
const uids = await db.getSortedSetRange(`chat:room:${roomId}:uids`, 0, -1); const uids = await db.getSortedSetRange(`chat:room:${roomId}:uids`, 0, -1);
for (const uid of uids) { for (const uid of uids) {
await batch.processSortedSet(`uid:${uid}:chat:room:${roomId}:mids`, async (mids) => { await batch.processSortedSet(`uid:${uid}:chat:room:${roomId}:mids`, async (userMessageData) => {
const uniqMids = mids.filter(mid => !midsSeen.hasOwnProperty(mid)); const uniqMessages = userMessageData.filter(m => !midsSeen.hasOwnProperty(m.value));
const uniqMids = uniqMessages.map(m => m.value);
if (!uniqMids.length) { if (!uniqMids.length) {
return; return;
} }
let messageData = await db.getObjects(uniqMids.map(mid => `message:${mid}`)); let messageData = await db.getObjects(uniqMids.map(mid => `message:${mid}`));
messageData.forEach((m, idx) => { messageData.forEach((m, idx) => {
if (m) { if (m && uniqMessages[idx]) {
m.mid = parseInt(uniqMids[idx], 10); m.mid = parseInt(uniqMids[idx], 10);
m.timestamp = m.timestamp || uniqMessages[idx].score || 0;
} }
}); });
messageData = messageData.filter(Boolean); messageData = messageData.filter(Boolean);
const bulkSet = messageData.map( const bulkSet = messageData.map(
msg => [`message:${msg.mid}`, { roomId: roomId }] msg => [`message:${msg.mid}`, {
roomId: roomId,
timestamp: m.timestamp,
}]
); );
await db.setObjectBulk(bulkSet); await db.setObjectBulk(bulkSet);
@@ -69,6 +74,7 @@ module.exports = {
}); });
}, { }, {
batch: 500, batch: 500,
withScores: true,
}); });
// eslint-disable-next-line no-await-in-loop // eslint-disable-next-line no-await-in-loop
await db.deleteAll(`uid:${uid}:chat:room:${roomId}:mids`); await db.deleteAll(`uid:${uid}:chat:room:${roomId}:mids`);