Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2026-05-06 10:17:15 +02:00
Code Issues Packages Projects Releases Wiki Activity

retrt e11000 in incrObjectField

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2026-03-27 11:48:45 -04:00
parent 837d984b84
commit 28fafcdc56
1 changed files with 28 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -240,7 +240,22 @@ module.exports = function (module) {
key.forEach((key) => {
bulk.find({ _key: key }).upsert().update({ $inc: increment });
});
await bulk.execute();
try {
await bulk.execute();
} catch (err) {
// retry failed e11000 operations
if (err.code === 11000 || (err.writeErrors && err.writeErrors.some(e => e.code === 11000))) {
const failedIndices = err.writeErrors.filter(e => e.code === 11000).map(e => e.index);
const retryData = failedIndices.map(idx => key[idx]);
await Promise.all(retryData.map(
key => module.incrObjectFieldBy(key, field, value)
));
} else {
throw err;
}
}
cache.del(key);
const result = await module.getObjectsFields(key, [field]);
return result.map(data => data && data[field]);
@@ -284,7 +299,18 @@ module.exports = function (module) {
}
bulk.find({ _key: item[0] }).upsert().update({ $inc: increment });
});
await bulk.execute();
try {
await bulk.execute();
} catch (err) {
// retry failed e11000 operations
if (err.code === 11000 || (err.writeErrors && err.writeErrors.some(e => e.code === 11000))) {
const failedIndices = err.writeErrors.filter(e => e.code === 11000).map(e => e.index);
const retryData = failedIndices.map(idx => data[idx]);
await module.incrObjectFieldByBulk(retryData);
} else {
throw err;
}
}
cache.del(data.map(item => item[0]));
};
};