mongo-control - npm Package Compare versions

Comparing version 1.0.56 to 1.0.57

mongo.control.js

@@ -467,2 +467,55 @@ var MongoClient = require('mongodb').MongoClient
 
+MC.lookup = function (params) {
+  return new Promise(function (res, err) {
+    if (!params.db || !params.collection || !params.localField || !params.foreignField || !params.foreignCollection) return err('!params.db || !params.collection || !params.localField || !params.foreignField || !params.foreignCollection')
+
+    if (params.query) {
+      if (typeof params.query === 'string') {
+        try {
+          params.query = JSON.parse(params.query)
+        } catch (e) {
+          params.query = {}
+          err(e)
+        }
+      }
+    } else params.query = {}
+
+    if (params.projection) {
+      if (typeof params.projection === 'string') {
+        try {
+          params.projection = JSON.parse(params.projection)
+        } catch (e) {
+          params.projection = {}
+          err(e)
+        }
+      }
+    } else params.projection = {}
+
+    if (params.limit) params.limit = parseInt(params.limit, 10)
+    else params.limit = 0
+
+    MongoClient.connect(params.db, function (e, db) {
+      if (e) return err(e)
+
+      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) {
+        if (e) return err(e)
+
+        res(docs)
+        db.close()
+      })
+    })
+  })
+}
+
 MC.insert = function (params) {
@@ -469,0 +522,0 @@ return new Promise(function (res, err) {

package.json

 {
   "name": "mongo-control",
-  "version": "1.0.56",
+  "version": "1.0.57",
   "description": "Simple functions to control mongo",
@@ -5,0 +5,0 @@ "main": "mongo.control.js",

No alert changes

Improved metrics

Total package byte prevSize

26075

increased by6.18%

Lines of code

823

increased by5.78%

No dependency changes