Merge pull request #3 from mikeal/inmemory-set

fix(inmemory): Fixing inmemory set reference to createHasher.

inmemory.js

@@ -46,7 +46,7 @@ class InMemoryContentAddressableStorage {
 
   set (value, cb) {
     let _value = bl()
-    let hasher = createHasher('sha256', (err, hash) => {
+    let hasher = this._createHasher('sha256', (err, hash) => {
       if (err) return cb(err)
       this._store.set(hash, _value)
       cb(null, hash)

lib/test-basics.js

@@ -49,7 +49,7 @@ module.exports = (name, store) => {
     })
   })
 
-  test(`${name}: consistent hashing w/ hash API`, t => {
+  test(`${name}: consistent hashing w/ hash API, Buffer`, t => {
     t.plan(3)
     let buff = Buffer.from('asldkfjalskdjfldddkasdjf')
     store.hash(buff, (err, hash) => {
@@ -61,6 +61,24 @@ module.exports = (name, store) => {
     })
   })
 
+  test(`${name}: consistent hashing w/ hash API, Stream`, t => {
+    t.plan(3)
+    let buff = Buffer.from('asldkfjalskdjfldddkasdjf')
+    let stream = bl()
+    store.hash(stream, (err, hash) => {
+      t.error(err)
+      stream = bl()
+      store.hash(buff, (err, _hash) => {
+        t.error(err)
+        t.equals(hash, _hash)
+      })
+      stream.write(buff)
+      stream.end()
+    })
+    stream.write(buff)
+    stream.end()
+  })
+
   test(`${name}: get Buffer from key that has not been stored`, t => {
     t.plan(1)
     store.getBuffer('notfound', (err, buff) => {

tests/test-inmemory.js

@@ -1 +1,28 @@
 require('../lib/test-basics')('inmemory', require('../inmemory')())
+
+const test = require('tap').test
+const inmemory = require('../inmemory')
+const through = require('through2')
+
+const failHasher = (algo, cb) => {
+  process.nextTick(() => cb(new Error('Test Error')))
+  return through(() => {})
+}
+
+test('inmemory: (implementation) hash error in hash()', t => {
+  t.plan(1)
+  let store = inmemory()
+  store._createHasher = failHasher
+  store.hash(Buffer.from('asdf'), err => {
+    t.type(err, 'Error')
+  })
+})
+
+test('inmemory: (implementation) hash error in set()', t => {
+  t.plan(1)
+  let store = inmemory()
+  store._createHasher = failHasher
+  store.set(Buffer.from('asdf'), err => {
+    t.type(err, 'Error')
+  })
+})