Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-27 09:06:15 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix: retry failed setObject calls

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2020-05-30 15:49:34 -04:00
parent d7b2f163f2
commit 2c9e865763
1 changed files with 13 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/database/mongo/hash.js
View File

@@ -15,12 +15,19 @@ module.exports = function (module) {
} }
const writeData = helpers.serializeData(data); const writeData = helpers.serializeData(data);
if (isArray) { try {
var bulk = module.client.collection('objects').initializeUnorderedBulkOp(); if (isArray) {
key.forEach(key => bulk.find({ _key: key }).upsert().updateOne({ $set: writeData })); var bulk = module.client.collection('objects').initializeUnorderedBulkOp();
await bulk.execute(); key.forEach(key => bulk.find({ _key: key }).upsert().updateOne({ $set: writeData }));
} else { await bulk.execute();
await module.client.collection('objects').updateOne({ _key: key }, { $set: writeData }, { upsert: true, w: 1 }); } else {
await module.client.collection('objects').updateOne({ _key: key }, { $set: writeData }, { upsert: true, w: 1 });
}
} catch (err) {
if (err && err.message.startsWith('E11000 duplicate key error')) {
return await module.setObject(key, data);
}
throw err;
} }
cache.delObjectCache(key); cache.delObjectCache(key);