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: retry incrObjtFieldBy

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2021-12-23 11:28:48 -05:00
parent b179f0fc0f
commit 07232a8cf6
1 changed files with 21 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -239,17 +239,26 @@ module.exports = function (module) {
const result = await module.getObjectsFields(key, [field]); const result = await module.getObjectsFields(key, [field]);
return result.map(data => data && data[field]); return result.map(data => data && data[field]);
} }
try {
const result = await module.client.collection('objects').findOneAndUpdate({ const result = await module.client.collection('objects').findOneAndUpdate({
_key: key, _key: key,
}, { }, {
$inc: increment, $inc: increment,
}, { }, {
returnDocument: 'after', returnDocument: 'after',
upsert: true, upsert: true,
}); });
cache.del(key);
cache.del(key); return result && result.value ? result.value[field] : null;
return result && result.value ? result.value[field] : null; } catch (err) {
// if there is duplicate key error retry the upsert
// https://github.com/NodeBB/NodeBB/issues/4467
// https://jira.mongodb.org/browse/SERVER-14322
// https://docs.mongodb.org/manual/reference/command/findAndModify/#upsert-and-unique-index
if (err && err.message.startsWith('E11000 duplicate key error')) {
return await module.incrObjectFieldBy(key, field, value);
}
throw err;
}
}; };
}; };