map-filter-reduce - npm Package Compare versions

Comparing version 3.1.1 to 3.2.0

index.js

@@ -6,2 +6,4 @@ var pull = require('pull-stream/pull')
 var pullReduce = require('pull-stream/sinks/reduce')
+var pullSort = require('pull-sort')
+var CompareAt = require('compare-at-paths')
 
@@ -64,2 +66,5 @@ var make = require('./make')
 
-
+exports.sort = function (paths) {
+  console.log("SORT", paths)
+  return pullSort(CompareAt(paths.$sort))
+}

package.json

 {
   "name": "map-filter-reduce",
   "description": "",
-  "version": "3.1.1",
+  "version": "3.2.0",
   "homepage": "https://github.com/dominictarr/map-filter-reduce",
@@ -12,3 +12,5 @@ "repository": {
     "binary-search": "^1.2.0",
+    "compare-at-paths": "^1.0.0",
     "pull-sink-through": "0.0.0",
+    "pull-sort": "^1.0.1",
     "pull-stream": "^3.4.3",
@@ -15,0 +17,0 @@ "typewiselite": "^1.0.0"

test/filter.js

@@ -85,4 +85,40 @@ var tape = require('tape')
 
+var mfr = require('..')
+var pull = require('pull-stream')
+queries.forEach(function (q, i) {
+  tape('test filter: '+JSON.stringify(q), function (t) {
+    pull(
+      pull.values(data),
+      mfr([{$filter: q}]),
+      pull.collect(function (err, results) {
+        t.deepEqual(results, expected[i])
+        t.end()
+      })
+    )
+  })
+})
 
+tape('sort', function (t) {
+  pull(
+    pull.values(data),
+    mfr([{
+      $filter: {
+        rel: ['name']
+      }}, {
+      $sort: [
+        ['rel', 0],
+        ['rel', 1],
+        ['source'],
+        ['dest']
+      ]}
+    ]),
+    pull.collect(function (err, results) {
+      t.deepEqual(results, [
+        {source: 'b', dest: 'a', rel: ['name', '@alice']},
+        {source: 'a', dest: 'b', rel: ['name', '@bob']}
+      ])
+      t.end()
+    })
+  )
+})
 
-

test/groups.js

@@ -115,5 +115,1 @@ var tape = require('tape')
 
-
-
-
-

No alert changes

Improved metrics

Total package byte prevSize

35675

increased by2.98%

Lines of code

1118

increased by4%

Worsened metrics

Dependency count

6

increased by50%

Dependency changes

• + Addedcompare-at-paths@^1.0.0

• + Addedpull-sort@^1.0.1

• + Added@ljharb/resumer@0.0.1(transitive)

• + Added@ljharb/through@2.3.13(transitive)

• + Addedarray-buffer-byte-length@1.0.1(transitive)

• + Addedarraybuffer.prototype.slice@1.0.3(transitive)

• + Addedavailable-typed-arrays@1.0.7(transitive)

• + Addedbalanced-match@1.0.2(transitive)

• + Addedbrace-expansion@1.1.11(transitive)

• + Addedcall-bind@1.0.7(transitive)

• + Addedcompare-at-paths@1.0.0(transitive)

• + Addedconcat-map@0.0.1(transitive)

• + Addeddata-view-buffer@1.0.1(transitive)

• + Addeddata-view-byte-length@1.0.1(transitive)

• + Addeddata-view-byte-offset@1.0.0(transitive)

• + Addeddeep-equal@1.1.2(transitive)

• + Addeddefine-data-property@1.1.4(transitive)

• + Addeddefine-properties@1.2.1(transitive)

• + Addeddefined@1.0.1(transitive)

• + Addeddotignore@0.1.2(transitive)

• + Addedes-abstract@1.23.3(transitive)

• + Addedes-define-property@1.0.0(transitive)

• + Addedes-errors@1.3.0(transitive)

• + Addedes-object-atoms@1.0.0(transitive)

• + Addedes-set-tostringtag@2.0.3(transitive)

• + Addedes-to-primitive@1.2.1(transitive)

• + Addedfor-each@0.3.3(transitive)

• + Addedfs.realpath@1.0.0(transitive)

• + Addedfunction-bind@1.1.2(transitive)

• + Addedfunction.prototype.name@1.1.6(transitive)

• + Addedfunctions-have-names@1.2.3(transitive)

• + Addedget-intrinsic@1.2.4(transitive)

• + Addedget-symbol-description@1.0.2(transitive)

• + Addedglob@7.2.3(transitive)

• + Addedglobalthis@1.0.4(transitive)

• + Addedgopd@1.0.1(transitive)

• + Addedhas@1.0.4(transitive)

• + Addedhas-bigints@1.0.2(transitive)

• + Addedhas-property-descriptors@1.0.2(transitive)

• + Addedhas-proto@1.0.3(transitive)

• + Addedhas-symbols@1.0.3(transitive)

• + Addedhas-tostringtag@1.0.2(transitive)

• + Addedhasown@2.0.2(transitive)

• + Addedinflight@1.0.6(transitive)

• + Addedinherits@2.0.4(transitive)

• + Addedinternal-slot@1.0.7(transitive)

• + Addedis-arguments@1.1.1(transitive)

• + Addedis-array-buffer@3.0.4(transitive)

• + Addedis-bigint@1.0.4(transitive)

• + Addedis-boolean-object@1.1.2(transitive)

• + Addedis-callable@1.2.7(transitive)

• + Addedis-core-module@2.14.0(transitive)

• + Addedis-data-view@1.0.1(transitive)

• + Addedis-date-object@1.0.5(transitive)

• + Addedis-negative-zero@2.0.3(transitive)

• + Addedis-number-object@1.0.7(transitive)

• + Addedis-regex@1.1.4(transitive)

• + Addedis-shared-array-buffer@1.0.3(transitive)

• + Addedis-string@1.0.7(transitive)

• + Addedis-symbol@1.0.4(transitive)

• + Addedis-typed-array@1.1.13(transitive)

• + Addedis-weakref@1.0.2(transitive)

• + Addedisarray@2.0.5(transitive)

• + Addedlibnested@1.5.2(transitive)

• + Addedminimatch@3.1.2(transitive)

• + Addedminimist@1.2.8(transitive)

• + Addedmock-property@1.0.3(transitive)

• + Addedobject-inspect@1.12.31.13.2(transitive)

• + Addedobject-is@1.1.6(transitive)

• + Addedobject-keys@1.1.1(transitive)

• + Addedobject.assign@4.1.5(transitive)

• + Addedonce@1.4.0(transitive)

• + Addedpath-is-absolute@1.0.1(transitive)

• + Addedpath-parse@1.0.7(transitive)

• + Addedpossible-typed-array-names@1.0.0(transitive)

• + Addedpull-defer@0.2.3(transitive)

• + Addedpull-sort@1.0.2(transitive)

• + Addedregexp.prototype.flags@1.5.2(transitive)

• + Addedresolve@1.22.8(transitive)

• + Addedsafe-array-concat@1.1.2(transitive)

• + Addedsafe-regex-test@1.0.3(transitive)

• + Addedset-function-length@1.2.2(transitive)

• + Addedset-function-name@2.0.2(transitive)

• + Addedside-channel@1.0.6(transitive)

• + Addedstring.prototype.trim@1.2.9(transitive)

• + Addedstring.prototype.trimend@1.0.8(transitive)

• + Addedstring.prototype.trimstart@1.0.8(transitive)

• + Addedsupports-preserve-symlinks-flag@1.0.0(transitive)

• + Addedtape@4.17.0(transitive)

• + Addedtyped-array-buffer@1.0.2(transitive)

• + Addedtyped-array-byte-length@1.0.1(transitive)

• + Addedtyped-array-byte-offset@1.0.2(transitive)

• + Addedtyped-array-length@1.0.6(transitive)

• + Addedunbox-primitive@1.0.2(transitive)

• + Addedwhich-boxed-primitive@1.0.2(transitive)

• + Addedwhich-typed-array@1.1.15(transitive)

• + Addedwrappy@1.0.2(transitive)