Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-26 08:36: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]);
return result.map(data => data && data[field]);
}
const result = await module.client.collection('objects').findOneAndUpdate({
_key: key,
}, {
$inc: increment,
}, {
returnDocument: 'after',
upsert: true,
});
cache.del(key);
return result && result.value ? result.value[field] : null;
try {
const result = await module.client.collection('objects').findOneAndUpdate({
_key: key,
}, {
$inc: increment,
}, {
returnDocument: 'after',
upsert: true,
});
cache.del(key);
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;
}
};
};