From 8891548909fa5eb969d380502a73dec2072bf83f Mon Sep 17 00:00:00 2001 From: Dave C-J Date: Thu, 31 Oct 2013 16:33:14 +0000 Subject: [PATCH] Make simple payload types be objects for mongodb to stor sensibly. --- nodes/storage/66-mongodb.js | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/nodes/storage/66-mongodb.js b/nodes/storage/66-mongodb.js index d221dcbdd..3a486fa47 100644 --- a/nodes/storage/66-mongodb.js +++ b/nodes/storage/66-mongodb.js @@ -47,12 +47,18 @@ function MongoOutNode(n) { node.on("input",function(msg) { if (node.operation == "store") { delete msg._topic; - if (node.payonly) coll.save(msg.payload,function(err,item){ if (err){node.error(err);} }); + if (node.payonly) { + if (typeof msg.payload !== "object") { msg.payload = {"payload":msg.payload}; } + coll.save(msg.payload,function(err,item){ if (err){node.error(err);} }); + } else coll.save(msg,function(err,item){if (err){node.error(err);}}); } else if (node.operation == "insert") { delete msg._topic; - if (node.payonly) coll.insert(msg.payload,function(err,item){ if (err){node.error(err);} }); + if (node.payonly) { + if (typeof msg.payload !== "object") { msg.payload = {"payload":msg.payload}; } + coll.insert(msg.payload,function(err,item){ if (err){node.error(err);} }); + } else coll.insert(msg,function(err,item){if (err){node.error(err);}}); } if (node.operation == "delete") {