Typed errors (#18)

Author: LuKks

index.js

@@ -46,7 +46,7 @@ module.exports = class Hyperblobs {
         res.push(block)
       }
     } catch (error) {
-      if (error.message === 'Block not available') return null
+      if (error.code === 'BLOCK_NOT_AVAILABLE') return null
       throw error
     }
 

lib/streams.js

@@ -1,4 +1,5 @@
 const { Readable, Writable } = require('streamx')
+const { BLOCK_NOT_AVAILABLE } = require('hypercore/errors')
 
 class SparsePrefetcher {
   constructor (opts = {}) {
@@ -121,7 +122,7 @@ class BlobReadStream extends Readable {
       start: this.id.blockOffset,
       end: this.id.blockOffset + this.id.blockLength
     }).then(result => {
-      if (!result) return cb(new Error('Block not available'))
+      if (!result) return cb(BLOCK_NOT_AVAILABLE())
 
       this._index = result[0]
       this._relativeOffset = result[1]
@@ -150,7 +151,7 @@ class BlobReadStream extends Readable {
     }
 
     this.core.get(this._index).then(block => {
-      if (!block) return cb(new Error('Block not available'))
+      if (!block) return cb(BLOCK_NOT_AVAILABLE())
 
       const remainder = this._end - this._pos
       if (this._relativeOffset || (remainder < block.length)) {

package.json

@@ -23,12 +23,12 @@
   "homepage": "https://github.com/holepunchto/hyperblobs#readme",
   "dependencies": {
     "b4a": "^1.6.1",
+    "hypercore": "^10.18.0",
     "mutexify": "^1.4.0",
     "streamx": "^2.13.2"
   },
   "devDependencies": {
     "brittle": "^3.1.0",
-    "hypercore": "^10.11.0",
     "random-access-memory": "^6.0.0",
     "standard": "^17.0.0"
   }

test/all.js

@@ -264,7 +264,7 @@ test('read stream without waiting', async function (t) {
       t.fail('should not get any block: ' + block.toString())
     }
   } catch (error) {
-    t.is(error.message, 'Block not available')
+    t.is(error.code, 'BLOCK_NOT_AVAILABLE')
   }
 })
 
@@ -281,7 +281,7 @@ test('seek stream without waiting', async function (t) {
       t.fail('should not get any block: ' + block.toString())
     }
   } catch (error) {
-    t.is(error.message, 'Block not available')
+    t.is(error.code, 'BLOCK_NOT_AVAILABLE')
   }
 })