Current work; move to cloud

Author: mels065

index.js

@@ -1,26 +1,32 @@
 var level = require('level')
+var hypercore = require('hypercore')
 
 var hyperkv = require('hyperkv')
 var hyperlog = require('hyperlog')
 var sub = require('subleveldown')
 
-// var createImportPipeline = require('./lib/import.js')
+var createImportPipeline = require('./lib/import.js')
+var importRowKv = require('./lib/importkv.js')
 var addRow = require('./lib/add.js')
 var deleteRow = require('./lib/delete.js')
 
 module.exports = Jawn
 
 function Jawn (opts) {
   if (!opts) opts = {}
+  this.core = initializeHypercore(opts)
   this.kv = initializeHyperkv(opts)
   this.db = this.core.db
+  this.db_kv = this.kv.db
 }
 
-/*
 Jawn.prototype.createImportPipeline = function (opts) {
   return createImportPipeline(this, opts)
 }
-*/
+
+Jawn.prototype.importRowKv = function (file) {
+  return importRowKv(this, file)
+}
 
 Jawn.prototype.addRow = function (key, value) {
   return addRow(this, key, value)
@@ -34,6 +40,17 @@ Jawn.prototype.deleteRow = function (key) {
 // @default Creates a leveldb database called `data.jawn` and initializes hypercore using that db
 // @option 'core' the hypercore instance to use
 // @option 'db' the db instace (leveldb) to initialize hypercore with. This is ignored if you use the `core` option
+function initializeHypercore (opts) {
+  var core
+  if (opts.hasOwnProperty('core')) {
+    core = opts.core
+  } else {
+    var db = opts.db || level('data.jawn')
+    core = hypercore(db)
+  }
+  return core
+}
+
 function initializeHyperkv (opts) {
   var kv
   if (opts.hasOwnProperty('core')) {

lib/add.js

@@ -3,6 +3,6 @@ module.exports = addRow
 function addRow (jawn, key, value) {
   jawn.kv.put(key, JSON.stringify(value), function (err, node) {
     if (err) console.error(err)
-    else console.log(node.key)
+    else console.log(node.key + ': ' + node.value)
   })
 }

test/add.js

@@ -0,0 +1,31 @@
+var test = require('tape')
+var Jawn = require('../')
+var memdb = require('memdb')
+
+test('add 3 rows', function (t) {
+  var jawn = freshJawn()
+  var testValues = [
+    '{"foo":"bar","name":"josie","age":"35"}',
+    '{"foo":"baz","name":"eloise","age":"71"}',
+    '{"foo":"baz","name":"francoise","age":"5"}'
+  ]
+  /*
+  var expected = [
+    '0: {"foo":"bar","name":"josie","age":"35"}',
+    '1: {"foo":"baz","name":"eloise","age":"71"}',
+    '2: {"foo":"baz","name":"francoise","age":"5"}'
+  ]
+  */
+
+  for (var i = 0; testValues.length; i++) {
+    jawn.addRow(i, testValues[i])
+  }
+
+  jawn.kv.on('put', function (key, value, node) {
+    console.log(key + ': ' + value)
+  })
+})
+
+function freshJawn () {
+  return new Jawn({db: memdb()})
+}