You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
67 lines
1.9 KiB
JavaScript
67 lines
1.9 KiB
JavaScript
'use strict';
|
|
|
|
|
|
const _ = require('lodash');
|
|
|
|
const db = require('../../database');
|
|
const batch = require('../../batch');
|
|
|
|
|
|
module.exports = {
|
|
name: 'Update chat messages to add roomId field',
|
|
timestamp: Date.UTC(2023, 6, 2),
|
|
method: async function () {
|
|
const { progress } = this;
|
|
|
|
const nextChatRoomId = await db.getObjectField('global', 'nextChatRoomId');
|
|
const allRoomIds = [];
|
|
for (let i = 1; i <= nextChatRoomId; i++) {
|
|
allRoomIds.push(i);
|
|
}
|
|
progress.total = allRoomIds.length;
|
|
await batch.processArray(allRoomIds, async (roomIds) => {
|
|
progress.incr(roomIds.length);
|
|
const [arrayOfUids, arrayOfRoomData] = await Promise.all([
|
|
db.getSortedSetsMembers(roomIds.map(roomId => `chat:room:${roomId}:uids`)),
|
|
db.getObjects(roomIds.map(roomId => `chat:room:${roomId}`)),
|
|
]);
|
|
|
|
await Promise.all(roomIds.map(async (roomId, index) => {
|
|
const uids = arrayOfUids[index];
|
|
const roomData = arrayOfRoomData[index];
|
|
if (!uids.length && !roomData) {
|
|
return;
|
|
}
|
|
if (roomData && roomData.owner && !uids.includes(String(roomData.owner))) {
|
|
uids.push(roomData.owner);
|
|
}
|
|
const userKeys = uids.map(uid => `uid:${uid}:chat:room:${roomId}:mids`);
|
|
const mids = await db.getSortedSetsMembers(userKeys);
|
|
const uniqMids = _.uniq(_.flatten(mids));
|
|
let messageData = await db.getObjects(uniqMids.map(mid => `message:${mid}`));
|
|
messageData.forEach((m, idx) => {
|
|
if (m) {
|
|
m.mid = parseInt(uniqMids[idx], 10);
|
|
}
|
|
});
|
|
messageData = messageData.filter(Boolean);
|
|
|
|
const bulkSet = messageData.map(
|
|
msg => [`message:${msg.mid}`, { roomId: roomId }]
|
|
);
|
|
|
|
await db.setObjectBulk(bulkSet);
|
|
await db.setObjectField(`chat:room:${roomId}`, 'userCount', uids.length);
|
|
await db.sortedSetAdd(
|
|
`chat:room:${roomId}:mids`,
|
|
messageData.map(m => m.timestamp),
|
|
messageData.map(m => m.mid),
|
|
);
|
|
await db.deleteAll(userKeys);
|
|
}));
|
|
}, {
|
|
batch: 500,
|
|
});
|
|
},
|
|
};
|