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

convert values to string before removing

Browse Source
This commit is contained in:
Barış Soner Uşaklı
2018-10-11 16:23:05 -04:00
parent 54a92984d8
commit e615391b22
2 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/database/mongo/sorted/remove.js
View File

@@ -11,16 +11,20 @@ module.exports = function (db, module) {
if (!key) { if (!key) {
return callback(); return callback();
} }
if (Array.isArray(value)) {
value = value.map(helpers.valueToString);
} else {
value = helpers.valueToString(value);
}
if (Array.isArray(key) && Array.isArray(value)) { if (Array.isArray(key) && Array.isArray(value)) {
db.collection('objects').deleteMany({ _key: { $in: key }, value: { $in: value } }, done); db.collection('objects').deleteMany({ _key: { $in: key }, value: { $in: value } }, done);
} else if (Array.isArray(value)) { } else if (Array.isArray(value)) {
value = value.map(helpers.valueToString);
db.collection('objects').deleteMany({ _key: key, value: { $in: value } }, done); db.collection('objects').deleteMany({ _key: key, value: { $in: value } }, done);
} else if (Array.isArray(key)) { } else if (Array.isArray(key)) {
value = helpers.valueToString(value);
db.collection('objects').deleteMany({ _key: { $in: key }, value: value }, done); db.collection('objects').deleteMany({ _key: { $in: key }, value: value }, done);
} else { } else {
value = helpers.valueToString(value);
db.collection('objects').deleteOne({ _key: key, value: value }, done); db.collection('objects').deleteOne({ _key: key, value: value }, done);
} }
}; };

4
test/database/sorted.js
View File

@@ -708,9 +708,9 @@ describe('Sorted Set methods', function () {
assert.ifError(err); assert.ifError(err);
db.sortedSetAdd('multiTest6', [2], ['two'], function (err) { db.sortedSetAdd('multiTest6', [2], ['two'], function (err) {
assert.ifError(err); assert.ifError(err);
db.sortedSetAdd('multiTest7', [3], ['three'], function (err) { db.sortedSetAdd('multiTest7', [3], [333], function (err) {
assert.ifError(err); assert.ifError(err);
db.sortedSetRemove(['multiTest5', 'multiTest6', 'multiTest7'], ['one', 'two', 'three'], function (err) { db.sortedSetRemove(['multiTest5', 'multiTest6', 'multiTest7'], ['one', 'two', 333], function (err) {
assert.ifError(err); assert.ifError(err);
db.getSortedSetsMembers(['multiTest5', 'multiTest6', 'multiTest7'], function (err, members) { db.getSortedSetsMembers(['multiTest5', 'multiTest6', 'multiTest7'], function (err, members) {
assert.ifError(err); assert.ifError(err);