Change hyperkv back to hypercore temporarily

Author: mels065

index.js

@@ -1,20 +1,13 @@
-var hyperkv = require('hyperkv')
-var hyperlog = require('hyperlog')
-var sub = require('subleveldown')
 var level = require('level')
-
+var hypercore = require('hypercore')
 var createImportPipeline = require('./lib/import.js')
 
 module.exports = Jawn
 
 function Jawn (opts) {
   if (!opts) opts = {}
   var db = opts.db || level('data.jawn')
-  var kv = hyperkv({
-    log: hyperlog(sub(db, 'log'), {valueEncoding: 'json'}),
-    db: sub(db, 'kv')
-  })
-  this.core = opts.core || kv
+  this.core = opts.core || hypercore(db)
   this.db = this.core.db
 }
 

test/hyperkv.js

@@ -5,7 +5,6 @@ var hyperkv = require('hyperkv')
 var hyperlog = require('hyperlog')
 var sub = require('subleveldown')
 var through = require('through2')
-var miss = require('mississippi')
 var memdb = require('memdb')
 
 test('import rows to hyperkv', function (t) {
@@ -15,23 +14,24 @@ test('import rows to hyperkv', function (t) {
     db: sub(db, 'kv')
   })
 
-  var importStream = importFromFile(kv, 'dummy.json')
+  var hs = kv.createHistoryStream()
+  importFromFile(kv, 'dummy.json')
 
   var expected = [
     '{"foo":"bar","name":"josie","age":"35"}',
     '{"foo":"baz","name":"eloise","age":"71"}',
     '{"foo":"baz","name":"francoise","age":"5"}'
   ]
 
-  importStream.on('finish', verify)
+  hs.on('data', verifyBlock)
+  hs.on('end', countBlocks)
 
-  function verify (err) {
-    if (err) { console.log(err) }
-    var hs = kv.createHistoryStream('test')
-    hs.on('data', function (block) {
-      t.same(block.toString(), expected.shift(), 'blocks matched imported line')
-    })
+  function verifyBlock (block) {
+    t.same(block.toString(), expected.shift(), 'blocks matched imported line')
+  }
 
+  function countBlocks (err) {
+    if (err) { console.log(err) }
     t.end()
   }
 })
@@ -44,7 +44,7 @@ function importFromFile (kv, file) {
   var data = fs.createReadStream(fixture(file))
   var tr = through(putData, end)
 
-  var importStream = miss.pipeline(data, tr)
+  data.pipe(tr)
 
   function putData (row, _, next) {
     kv.put('test', row.toString())
@@ -54,6 +54,4 @@ function importFromFile (kv, file) {
   function end (done) {
     done()
   }
-
-  return importStream
 }