diff --git a/src/database/mongo/hash.js b/src/database/mongo/hash.js index 75d3efa06c..59d6ee2585 100644 --- a/src/database/mongo/hash.js +++ b/src/database/mongo/hash.js @@ -20,7 +20,7 @@ module.exports = function (module) { key.forEach(key => bulk.find({ _key: key }).upsert().updateOne({ $set: writeData })); await bulk.execute(); } else { - await module.client.collection('objects').updateOne({ _key: key }, { $set: writeData }, { upsert: true, w: 1 }); + await module.client.collection('objects').updateOne({ _key: key }, { $set: writeData }, { upsert: true }); } } catch (err) { if (err && err.message.startsWith('E11000 duplicate key error')) { diff --git a/src/database/mongo/list.js b/src/database/mongo/list.js index 69a32f0fc5..398d8f2528 100644 --- a/src/database/mongo/list.js +++ b/src/database/mongo/list.js @@ -12,7 +12,7 @@ module.exports = function (module) { const exists = await module.isObjectField(key, 'array'); if (exists) { - await module.client.collection('objects').updateOne({ _key: key }, { $push: { array: { $each: [value], $position: 0 } } }, { upsert: true, w: 1 }); + await module.client.collection('objects').updateOne({ _key: key }, { $push: { array: { $each: [value], $position: 0 } } }, { upsert: true }); } else { await module.listAppend(key, value); } @@ -23,7 +23,7 @@ module.exports = function (module) { return; } value = helpers.valueToString(value); - await module.client.collection('objects').updateOne({ _key: key }, { $push: { array: value } }, { upsert: true, w: 1 }); + await module.client.collection('objects').updateOne({ _key: key }, { $push: { array: value } }, { upsert: true }); }; module.listRemoveLast = async function (key) { diff --git a/src/database/mongo/sets.js b/src/database/mongo/sets.js index 41928f278d..a88ec7096b 100644 --- a/src/database/mongo/sets.js +++ b/src/database/mongo/sets.js @@ -22,7 +22,6 @@ module.exports = function (module) { }, }, { upsert: true, - w: 1, }); }; diff --git a/src/database/mongo/sorted/add.js b/src/database/mongo/sorted/add.js index f576a27100..77fbc8f7ab 100644 --- a/src/database/mongo/sorted/add.js +++ b/src/database/mongo/sorted/add.js @@ -17,7 +17,7 @@ module.exports = function (module) { value = helpers.valueToString(value); try { - await module.client.collection('objects').updateOne({ _key: key, value: value }, { $set: { score: parseFloat(score) } }, { upsert: true, w: 1 }); + await module.client.collection('objects').updateOne({ _key: key, value: value }, { $set: { score: parseFloat(score) } }, { upsert: true }); } catch (err) { if (err && err.message.startsWith('E11000 duplicate key error')) { return await module.sortedSetAdd(key, score, value);