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

test: log e11000 errors

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2023-07-15 23:30:19 -04:00
parent 052f1f2232
commit 934df69e9d
4 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -26,7 +26,8 @@ module.exports = function (module) {
await module.client.collection('objects').updateOne({ _key: key }, { $set: writeData }, { upsert: true }); await module.client.collection('objects').updateOne({ _key: key }, { $set: writeData }, { upsert: true });
} }
} catch (err) { } catch (err) {
if (err && err.message.startsWith('E11000 duplicate key error')) { if (err && err.message.includes('E11000 duplicate key error')) {
console.log(new Error('e11000').stack, key, data);
return await module.setObject(key, data); return await module.setObject(key, data);
} }
throw err; throw err;
@@ -61,7 +62,8 @@ module.exports = function (module) {
await bulk.execute(); await bulk.execute();
} }
} catch (err) { } catch (err) {
if (err && err.message.startsWith('E11000 duplicate key error')) { if (err && err.message.includes('E11000 duplicate key error')) {
console.log(new Error('e11000').stack, data);
return await module.setObjectBulk(data); return await module.setObjectBulk(data);
} }
throw err; throw err;
@@ -256,7 +258,8 @@ module.exports = function (module) {
// https://jira.mongodb.org/browse/SERVER-14322 // https://jira.mongodb.org/browse/SERVER-14322
// https://docs.mongodb.org/manual/reference/command/findAndModify/#upsert-and-unique-index // https://docs.mongodb.org/manual/reference/command/findAndModify/#upsert-and-unique-index
console.log('test', err.message); console.log('test', err.message);
if (err && err.message.startsWith('E11000 duplicate key error')) { if (err && err.message.includes('E11000 duplicate key error')) {
console.log(new Error('e11000').stack, key, field, value);
return await module.incrObjectFieldBy(key, field, value); return await module.incrObjectFieldBy(key, field, value);
} }
throw err; throw err;

3
src/database/mongo/sets.js
View File

@@ -51,7 +51,8 @@ module.exports = function (module) {
try { try {
await bulk.execute(); await bulk.execute();
} catch (err) { } catch (err) {
if (err && err.message.startsWith('E11000 duplicate key error')) { if (err && err.message.includes('E11000 duplicate key error')) {
console.log(new Error('e11000').stack, keys, value);
return await module.setsAdd(keys, value); return await module.setsAdd(keys, value);
} }
throw err; throw err;

3
src/database/mongo/sorted.js
View File

@@ -443,7 +443,8 @@ module.exports = function (module) {
// https://github.com/NodeBB/NodeBB/issues/4467 // https://github.com/NodeBB/NodeBB/issues/4467
// https://jira.mongodb.org/browse/SERVER-14322 // https://jira.mongodb.org/browse/SERVER-14322
// https://docs.mongodb.org/manual/reference/command/findAndModify/#upsert-and-unique-index // https://docs.mongodb.org/manual/reference/command/findAndModify/#upsert-and-unique-index
if (err && err.message.startsWith('E11000 duplicate key error')) { if (err && err.message.includes('E11000 duplicate key error')) {
console.log(new Error('e11000').stack, key, increment, value);
return await module.sortedSetIncrBy(key, increment, value); return await module.sortedSetIncrBy(key, increment, value);
} }
throw err; throw err;

3
src/database/mongo/sorted/add.js
View File

@@ -19,7 +19,8 @@ module.exports = function (module) {
try { try {
await module.client.collection('objects').updateOne({ _key: key, value: value }, { $set: { score: parseFloat(score) } }, { upsert: true }); await module.client.collection('objects').updateOne({ _key: key, value: value }, { $set: { score: parseFloat(score) } }, { upsert: true });
} catch (err) { } catch (err) {
if (err && err.message.startsWith('E11000 duplicate key error')) { if (err && err.message.includes('E11000 duplicate key error')) {
console.log(new Error('e11000').stack, key, score, value);
return await module.sortedSetAdd(key, score, value); return await module.sortedSetAdd(key, score, value);
} }
throw err; throw err;