amelisa-mongo
Advanced tools
Comparing version 0.1.2 to 0.1.3
@@ -174,2 +174,3 @@ 'use strict'; | ||
expression = this.mongolizeExpression(expression); | ||
docs = this.getQueryResultFromArray(allDocs, expression); | ||
@@ -180,3 +181,3 @@ | ||
case 6: | ||
case 7: | ||
case 'end': | ||
@@ -183,0 +184,0 @@ return _context4.stop(); |
@@ -142,4 +142,2 @@ 'use strict'; | ||
this.mongolizeExpression(normalized); | ||
// Do not return deleted docs | ||
@@ -154,13 +152,16 @@ normalized.$query._del = { | ||
key: 'mongolizeExpression', | ||
value: function mongolizeExpression(object) { | ||
if ((typeof object === 'undefined' ? 'undefined' : (0, _typeof3.default)(object)) !== 'object') return; | ||
value: function mongolizeExpression(expression) { | ||
if ((typeof expression === 'undefined' ? 'undefined' : (0, _typeof3.default)(expression)) !== 'object') return expression; | ||
if (object.id) { | ||
object._id = object.id; | ||
delete object.id; | ||
var mongolized = Array.isArray(expression) ? [] : {}; | ||
for (var key in expression) { | ||
if (key === 'id') { | ||
mongolized._id = expression.id; | ||
continue; | ||
} | ||
mongolized[key] = this.mongolizeExpression(expression[key]); | ||
} | ||
for (var key in object) { | ||
this.mongolizeExpression(object[key]); | ||
} | ||
return mongolized; | ||
} | ||
@@ -179,3 +180,3 @@ }, { | ||
value: function isDocsQuery(expression) { | ||
if (!expression || (typeof expression === 'undefined' ? 'undefined' : (0, _typeof3.default)(expression)) !== 'object') return false; | ||
if (!this.isQuery(expression)) return false; | ||
@@ -202,2 +203,4 @@ var query = this.normalizeExpression(expression); | ||
value: function isJoinQuery(expression) { | ||
if (!this.isQuery(expression)) return false; | ||
var query = this.normalizeExpression(expression); | ||
@@ -204,0 +207,0 @@ |
@@ -150,2 +150,3 @@ 'use strict'; | ||
case 0: | ||
expression = this.mongolizeExpression(expression); | ||
expression = this.normalizeExpression(expression); | ||
@@ -155,3 +156,3 @@ collection = this.db.collection(collectionName); | ||
if (!expression.$count) { | ||
_context4.next = 4; | ||
_context4.next = 5; | ||
break; | ||
@@ -162,5 +163,5 @@ } | ||
case 4: | ||
case 5: | ||
if (!expression.$distinct) { | ||
_context4.next = 6; | ||
_context4.next = 7; | ||
break; | ||
@@ -171,5 +172,5 @@ } | ||
case 6: | ||
case 7: | ||
if (!expression.$aggregate) { | ||
_context4.next = 8; | ||
_context4.next = 9; | ||
break; | ||
@@ -180,5 +181,5 @@ } | ||
case 8: | ||
case 9: | ||
if (!expression.$mapReduce) { | ||
_context4.next = 11; | ||
_context4.next = 12; | ||
break; | ||
@@ -194,3 +195,3 @@ } | ||
case 11: | ||
case 12: | ||
cursor = collection.find(expression.$query); | ||
@@ -203,6 +204,6 @@ | ||
_context4.next = 17; | ||
_context4.next = 18; | ||
return cursor.toArray(); | ||
case 17: | ||
case 18: | ||
docs = _context4.sent; | ||
@@ -213,3 +214,3 @@ | ||
case 20: | ||
case 21: | ||
case 'end': | ||
@@ -216,0 +217,0 @@ return _context4.stop(); |
{ | ||
"name": "amelisa-mongo", | ||
"version": "0.1.2", | ||
"version": "0.1.3", | ||
"description": "Mongo queries storage for Amelisa", | ||
@@ -5,0 +5,0 @@ "main": "lib", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
56168
1362