implements deep querying on arrays

src/mixins.js

@@ -4,7 +4,8 @@ var pluralize = require('pluralize')
 module.exports = {
   getRemovable: getRemovable,
   createId: createId,
-  deepQuery: deepQuery
+  deepQuery: deepQuery,
+  deepFilter: deepFilter
 }
 
 // Returns document ids that have unsatisfied relations
@@ -75,3 +76,43 @@ function deepQuery (value, q) {
     }
   }
 }
+
+function deepFilter (list, address, predicate) {
+  var _ = this
+  var parts = address.split('.')
+  var part = parts.shift()
+
+  if (part === address) {
+    if (_.isArray(list)) {
+      list = _.reduce(list, function (memo, item) {
+        if (_.isArray(item)) {
+          var search = {}
+          search[address] = predicate
+
+          Array.prototype.push.apply(memo, _.where(item, search))
+        } else if (item[address] === predicate) {
+          memo.push(item)
+        }
+
+        return memo
+      }, [])
+
+      return list.length && list || undefined
+    } else if (list && list[address] === predicate) {
+      return list
+    }
+
+    return undefined
+  } else {
+    list = _.reduce(list, function (memo, item) {
+      item[part] = _.deepFilter(item[part], parts.join('.'), predicate)
+      if (item[part] !== undefined) {
+        memo.push(item)
+      }
+
+      return memo
+    }, [])
+  }
+
+  return list
+}

src/router.js

@@ -94,6 +94,8 @@ module.exports = function (source) {
 
     } else {
 
+      array = db(req.params.resource).value()
+
       // Add :parentId filter in case URL is like /:parent/:parentId/:resource
       if (req.params.parent) {
         var parent = pluralize.singular(req.params.parent)
@@ -111,15 +113,12 @@ module.exports = function (source) {
       }
 
       // Filter
-      if (_(filters).isEmpty()) {
-        array = db(req.params.resource).value()
-      } else {
-        var chain = db(req.params.resource).chain()
+      if (!_(filters).isEmpty()) {
+        array = _.cloneDeep(array)
+
         for (var f in filters) {
-          // This syntax allow for deep filtering using lodash (i.e. a.b.c[0])
-          chain = chain.filter(f, filters[f])
+          array = db._.deepFilter(array, f, filters[f])
         }
-        array = chain.value()
       }
     }