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: one last try

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2022-02-15 20:51:52 -05:00
parent 2f64d63369
commit 9205169f00
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/upgrades/1.19.3/rename_post_upload_hashes.js
View File

@@ -40,10 +40,20 @@ module.exports = {
// Rename the object and pids zsets
const hashes = uploads.map(upload => md5(upload.value));
const newHashes = uploads.map(upload => md5(`files/${upload.value}`));
const promises = hashes.map((hash, idx) => db.rename(`upload:${hash}`, `upload:${newHashes[idx]}`));
promises.concat(hashes.map((hash, idx) => db.rename(`upload:${hash}:pids`, `upload:${newHashes[idx]}:pids`)));
await Promise.all(promises);
// cant use db.rename since `fix_user_uploads_zset.js` upgrade script already creates
// `upload:md5(upload.value) hash, trying to rename to existing key results in dupe error
const oldData = await db.getObjects(hashes.map(hash => `upload:${hash}`));
const bulkSet = [];
oldData.forEach((data, idx) => {
if (data) {
bulkSet.push([`upload:${newHashes[idx]}`, data]);
}
});
await db.setObjectBulk(bulkSet);
await db.deleteAll(hashes.map(hash => `upload:${hash}`));
await Promise.all(hashes.map((hash, idx) => db.rename(`upload:${hash}:pids`, `upload:${newHashes[idx]}:pids`)));
}
}, {
batch: 100,