frodovdr/node-red
1
0
Fork 0
mirror of https://github.com/node-red/node-red.git synced 2023-10-10 13:36:53 +02:00
Code Issues Releases Wiki Activity

Ensure valid mongo selector object

Browse Source
This commit is contained in:
Nick O'Leary 2014-09-26 11:30:09 +01:00
parent a5265784e8
commit d3956f9816
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
nodes/core/storage/66-mongodb.js
View File

@ -42,6 +42,14 @@ module.exports = function(RED) {
} }
}); });
function ensureValidSelectorObject(selector) {
if (selector != null && (typeof selector != 'object' || Buffer.isBuffer(selector))) {
return {};
}
return selector;
}
function MongoOutNode(n) { function MongoOutNode(n) {
RED.nodes.createNode(this,n); RED.nodes.createNode(this,n);
this.collection = n.collection; this.collection = n.collection;
@ -175,7 +183,8 @@ module.exports = function(RED) {
} }
if (node.operation === "find") { if (node.operation === "find") {
msg.projection = msg.projection || {}; msg.projection = msg.projection || {};
coll.find(msg.payload,msg.projection).sort(msg.sort).limit(msg.limit).toArray(function(err, items) { var selector = ensureValidSelectorObject(msg.payload);
coll.find(selector,msg.projection).sort(msg.sort).limit(msg.limit).toArray(function(err, items) {
if (err) { if (err) {
node.error(err); node.error(err);
} else { } else {
@ -187,7 +196,8 @@ module.exports = function(RED) {
} }
}); });
} else if (node.operation === "count") { } else if (node.operation === "count") {
coll.count(msg.payload, function(err, count) { var selector = ensureValidSelectorObject(msg.payload);
coll.count(selector, function(err, count) {
if (err) { if (err) {
node.error(err); node.error(err);
} else { } else {