mongo-control
Advanced tools
Comparing version 1.0.57 to 1.0.58
@@ -471,2 +471,9 @@ var MongoClient = require('mongodb').MongoClient | ||
var pipeline = [{$lookup: { | ||
from: params.collection, | ||
localField: params.localField, | ||
foreignField: params.foreignField, | ||
as: params.foreignCollection | ||
}}] | ||
if (params.query) { | ||
@@ -476,2 +483,3 @@ if (typeof params.query === 'string') { | ||
params.query = JSON.parse(params.query) | ||
pipeline.push({$match: params.query}) | ||
} catch (e) { | ||
@@ -488,2 +496,3 @@ params.query = {} | ||
params.projection = JSON.parse(params.projection) | ||
pipeline.push({$project: params.projection}) | ||
} catch (e) { | ||
@@ -502,14 +511,3 @@ params.projection = {} | ||
db.collection(params.collection).aggregate([ | ||
{$lookup: { | ||
from: params.collection, | ||
localField: params.localField, | ||
foreignField: params.foreignField, | ||
as: params.foreignCollection | ||
}}, { | ||
$match: params.query | ||
}, | ||
{ $project: params.projection } | ||
], function (e, docs) { | ||
db.collection(params.collection).aggregate(pipeline, function (e, docs) { | ||
if (e) return err(e) | ||
@@ -516,0 +514,0 @@ |
{ | ||
"name": "mongo-control", | ||
"version": "1.0.57", | ||
"version": "1.0.58", | ||
"description": "Simple functions to control mongo", | ||
@@ -5,0 +5,0 @@ "main": "mongo.control.js", |
26103
821