Barış Soner Uşaklı 4 years ago
parent e6c3840a4d
commit 3fb7444580

@ -222,7 +222,15 @@ module.exports = function (module) {
return result.map(data => data && data[field]); return result.map(data => data && data[field]);
} }
const result = await module.client.collection('objects').findOneAndUpdate({ _key: key }, { $inc: increment }, { returnOriginal: false, upsert: true }); const result = await module.client.collection('objects').findOneAndUpdate({
_key: key,
}, {
$inc: increment,
}, {
returnDocument: 'after',
upsert: true,
});
cache.del(key); cache.del(key);
return result && result.value ? result.value[field] : null; return result && result.value ? result.value[field] : null;
}; };

@ -90,7 +90,12 @@ module.exports = function (module) {
} }
const result = await module.client.collection('objects').findOneAndUpdate({ const result = await module.client.collection('objects').findOneAndUpdate({
_key: key, _key: key,
}, { $inc: { data: 1 } }, { returnOriginal: false, upsert: true }); }, {
$inc: { data: 1 },
}, {
returnDocument: 'after',
upsert: true,
});
return result && result.value ? result.value.data : null; return result && result.value ? result.value.data : null;
}; };

@ -400,7 +400,15 @@ module.exports = function (module) {
data.score = parseFloat(increment); data.score = parseFloat(increment);
try { try {
const result = await module.client.collection('objects').findOneAndUpdate({ _key: key, value: value }, { $inc: data }, { returnOriginal: false, upsert: true }); const result = await module.client.collection('objects').findOneAndUpdate({
_key: key,
value: value,
}, {
$inc: data,
}, {
returnDocument: 'after',
upsert: true,
});
return result && result.value ? result.value.score : null; return result && result.value ? result.value.score : null;
} catch (err) { } catch (err) {
// if there is duplicate key error retry the upsert // if there is duplicate key error retry the upsert

Loading…
Cancel
Save