feat: add basic error codes

Author: jacobheun

src/mount.js

@@ -6,6 +6,7 @@ const many = require('pull-many')
 const pull = require('pull-stream')
 
 const Key = require('interface-datastore').Key
+const Errors = require('interface-datastore').Errors
 const utils = require('interface-datastore').utils
 const asyncFilter = utils.asyncFilter
 const asyncSort = utils.asyncSort
@@ -62,8 +63,9 @@ class MountDatastore /* :: <Value> */ {
   put (key /* : Key */, value /* : Value */, callback /* : Callback<void> */) /* : void */ {
     const match = this._lookup(key)
     if (match == null) {
-      callback(new Error('No datastore mounted for this key'))
-      return
+      return callback(
+        Errors.dbWriteFailedError(new Error('No datastore mounted for this key'))
+      )
     }
 
     match.datastore.put(match.rest, value, callback)
@@ -72,8 +74,9 @@ class MountDatastore /* :: <Value> */ {
   get (key /* : Key */, callback /* : Callback<Value> */) /* : void */ {
     const match = this._lookup(key)
     if (match == null) {
-      callback(new Error('No datastore mounted for this key'))
-      return
+      return callback(
+        Errors.notFoundError(new Error('No datastore mounted for this key'))
+      )
     }
 
     match.datastore.get(match.rest, callback)
@@ -92,8 +95,9 @@ class MountDatastore /* :: <Value> */ {
   delete (key /* : Key */, callback /* : Callback<void> */) /* : void */ {
     const match = this._lookup(key)
     if (match == null) {
-      callback(new Error('No datastore mounted for this key'))
-      return
+      return callback(
+        Errors.dbDeleteFailedError(new Error('No datastore mounted for this key'))
+      )
     }
 
     match.datastore.delete(match.rest, callback)

src/tiered.js

@@ -3,6 +3,7 @@
 
 const each = require('async/each')
 const whilst = require('async/whilst')
+const Errors = require('interface-datastore').Errors
 
 /* ::
 import type {Key, Datastore, Callback, Batch, Query, QueryResult} from 'interface-datastore'
@@ -25,13 +26,23 @@ class TieredDatastore /* :: <Value> */ {
   open (callback /* : Callback<void> */) /* : void */ {
     each(this.stores, (store, cb) => {
       store.open(cb)
-    }, callback)
+    }, (err) => {
+      if (err) {
+        return callback(Errors.dbOpenFailedError())
+      }
+      callback()
+    })
   }
 
   put (key /* : Key */, value /* : Value */, callback /* : Callback<void> */) /* : void */ {
     each(this.stores, (store, cb) => {
       store.put(key, value, cb)
-    }, callback)
+    }, (err) => {
+      if (err) {
+        return callback(Errors.dbWriteFailedError())
+      }
+      callback()
+    })
   }
 
   get (key /* : Key */, callback /* : Callback<Value> */) /* : void */ {
@@ -47,7 +58,12 @@ class TieredDatastore /* :: <Value> */ {
         }
         cb()
       })
-    }, callback)
+    }, (err, res) => {
+      if (err || !res) {
+        return callback(Errors.notFoundError())
+      }
+      callback(null, res)
+    })
   }
 
   has (key /* : Key */, callback /* : Callback<bool> */) /* : void */ {
@@ -69,7 +85,12 @@ class TieredDatastore /* :: <Value> */ {
   delete (key /* : Key */, callback /* : Callback<void> */) /* : void */ {
     each(this.stores, (store, cb) => {
       store.delete(key, cb)
-    }, callback)
+    }, (err) => {
+      if (err) {
+        return callback(Errors.dbDeleteFailedError())
+      }
+      callback()
+    })
   }
 
   close (callback /* : Callback<void> */) /* : void */ {