map-reduce - npm Package Compare versions

Comparing version 6.0.0 to 6.0.1

package.json

 {
   "name": "map-reduce",
   "description": "map-reduce on leveldb",
-  "version": "6.0.0",
+  "version": "6.0.1",
   "homepage": "https://github.com/dominictarr/map-reduce",
@@ -12,3 +12,3 @@ "repository": {
   "dependencies": {
-    "level-trigger": "~1.3.1",
+    "level-trigger": "~1.3.2",
     "bytewise": "~0.6.1"
@@ -25,3 +25,3 @@ },
     "pull-level": "~1.1.0",
-    "level-test": "~1.1",
+    "level-test": "~1.6.3",
     "tape": "~1.0.4"
@@ -28,0 +28,0 @@ },

range.js

@@ -20,4 +20,8 @@ var bytewise = require('bytewise')
     return {
-      min: exports.stringify(array.map(function(v) { if (v === true) return min; else return v})),
-      max: exports.stringify(array.map(function(v) { if (v === true) return max; else return v})),
+      min: exports.stringify(array.map(function(v) {
+        if (v === true) return min; else return v
+      })),
+      max: exports.stringify(array.map(function(v) {
+        if (v === true) return max; else return v
+      })),
     }
@@ -24,0 +28,0 @@ }

test/fixtures/sum.js

@@ -0,24 +1,27 @@
+'use strict'
+var levelup  = require('level-test')()
+var rimraf   = require('rimraf')
+var pad      = require('pad')
+var sublevel = require('level-sublevel')
 
-var levelup = require('level-test')()
-var rimraf  = require('rimraf')
-var pad     = require('pad')
-
 function genSum (path, n, cb) {
-  rimraf(path, function () {
-    levelup(path, {createIfMissing: true}, function (err, db) {
+  console.log(path)
+  rimraf.sync(path)
+  var db = sublevel(levelup(path))
 
-      var l = n || 1e3, i = 0
-      var stream = db.writeStream(), total = 0
-      while(l--) {
-        stream.write({key: pad(6, ''+ ++i, '0'), value: JSON.stringify(i)})
-        total += i
-      }
-      stream.end()
-      if(cb) stream.on('close', function () {
-        console.log('TOTAL', total)
+  var l = n || 1e3, i = 0, N = n, total = 0
+  while(l--) {
+    db.put(
+      pad(6, ''+ ++i, '0'),
+      JSON.stringify(i),
+      next
+    )
+    total += i
+  }
+  function next () {
+    if(--N) return
+    if(cb) cb(null, db)
+  }
 
-        cb(null, db)
-      })
-    })
-  })
+  return db
 }
@@ -25,0 +28,0 @@

test/live.js

@@ -10,4 +10,3 @@ var MapReduce = require('..')
 
-var db = levelup(dir)
-SubLevel(db)
+var db = SubLevel(levelup(dir))
 
@@ -24,3 +23,3 @@ var vowels = 'aeiou'.split('')
   function (big, little, key) {
-    console.log(big, little, key)
+    console.log(big, little)
     return (
@@ -55,3 +54,3 @@ Number((big || 0).toString())
   assert.equal(consonants, 90)
-
+  console.log('passed')
 })

test/ranges.js

@@ -21,3 +21,3 @@ var level = require('level-test')()
 test ('ranges', function (t) {
-  var db = sublevel(level())
+  var db = sublevel(level('map-reduce-ranges'))
   //numbers under between 1-100
@@ -33,3 +33,3 @@
 
-  mapDb.post(console.log.bind(null, '  ?'))
+//  mapDb.post(console.log.bind(null, '---?'))
 
@@ -49,3 +49,3 @@ var sums = {
       pl.read(mapDb, {range: r, tail: true}),
-      pull.through(console.log),
+      pull.through(console.log.bind(null, '>?>?>?>')),
       exactly(expected),
@@ -55,2 +55,3 @@ pull.through(function (e) {
           t.equal(a.length, depth)
+          console.log(a, depth)
           console.log(a)
@@ -70,2 +71,3 @@ }),
        console.log('written')
+
        var n = 3
@@ -72,0 +74,0 @@ checkRange(3, 100, function (err) {

test/sum.js

@@ -17,3 +17,2 @@
     throw err
-  SubLevel(db)
   var TOTAL = false
@@ -41,5 +40,5 @@
   process.on('exit', function () {
-    assert.ok(TOTAL, 'eventually hit the right value')
+    assert.ok(TOTAL, 'eventually hit the right value: ' + target + ' but got to: ' + total)
   })
 })
 

No alert changes

Improved metrics

Total package byte prevSize

20276

increased by0.41%

Lines of code

456

increased by1.79%

Dependency changes

• Updatedlevel-trigger@~1.3.2