Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-16 10:46:14 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix decr/incrObjectField if key in array doesn't exist create it

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2018-03-17 19:08:52 -04:00
parent 6a9a73c86c
commit be5c237388
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -289,7 +289,10 @@ module.exports = function (db, module) {
if (Array.isArray(key)) { if (Array.isArray(key)) {
var bulk = db.collection('objects').initializeUnorderedBulkOp(); var bulk = db.collection('objects').initializeUnorderedBulkOp();
bulk.find({ _key: { $in: key } }).upsert().update({ $inc: data }); key.forEach(function (key) {
bulk.find({ _key: key }).upsert().update({ $inc: data });
});
async.waterfall([ async.waterfall([
function (next) { function (next) {
bulk.execute(function (err) { bulk.execute(function (err) {

3
test/database/hash.js
View File

@@ -408,10 +408,11 @@ describe('Hash methods', function () {
}); });
it('should decrement multiple objects field by 1 and return an array of new values', function (done) { it('should decrement multiple objects field by 1 and return an array of new values', function (done) {
db.decrObjectField(['testObject13', 'testObject14'], 'age', function (err, data) { db.decrObjectField(['testObject13', 'testObject14', 'decrTestObject'], 'age', function (err, data) {
assert.ifError(err); assert.ifError(err);
assert.equal(data[0], 97); assert.equal(data[0], 97);
assert.equal(data[1], -1); assert.equal(data[1], -1);
assert.equal(data[2], -1);
done(); done();
}); });
}); });