random-access-storage - npm Package Compare versions

Comparing version 0.0.0 to 1.0.0

index.js

@@ -30,2 +30,3 @@ var events = require('events')
     if (opts.stat) this._stat = opts.stat
+    if (opts.close) this._close = opts.close
   }
@@ -32,0 +33,0 @@

package.json

 {
   "name": "random-access-storage",
-  "version": "0.0.0",
+  "version": "1.0.0",
   "description": "Easily make random-access-storage instances",
@@ -5,0 +5,0 @@ "main": "index.js",

test.js

 var tape = require('tape')
 var ras = require('./')
 
-tape('basic', function (t) {
-  t.plan(4)
+tape('basic read', function (t) {
+  t.plan(2 * 4 + 4)
 
+  var expected = [Buffer.from('hi'), Buffer.from('ho')]
+  var queued = expected.slice(0)
   var s = ras({
-    read: req => req.callback(null, Buffer.from('hi'))
+    read: function (req) {
+      process.nextTick(function () {
+        t.same(req.offset, 0)
+        t.same(req.size, 2)
+        req.callback(null, queued.shift())
+      })
+    }
   })
 
-  s.read(0, 2, function (err, data) {
+  t.ok(s.readable)
+  t.notOk(s.writable)
+  t.notOk(s.deletable)
+  t.notOk(s.statable)
+  s.read(0, 2, ondata)
+  s.read(0, 2, ondata)
+
+  function ondata (err, data) {
     t.error(err, 'no error')
-    t.same(data, Buffer.from('hi'))
+    t.same(data, expected.shift())
+  }
+})
+
+tape('basic write', function (t) {
+  t.plan(2 * 2 + 4)
+
+  var expected = [Buffer.from('hi'), Buffer.from('ho')]
+  var s = ras({
+    write: function (req) {
+      t.same(req.data, expected.shift())
+      req.callback(null)
+    }
   })
 
-  s.read(0, 2, function (err, data) {
+  t.notOk(s.readable)
+  t.ok(s.writable)
+  t.notOk(s.deletable)
+  t.notOk(s.statable)
+  s.write(0, Buffer.from('hi'), onwrite)
+  s.write(0, Buffer.from('ho'), onwrite)
+
+  function onwrite (err, write) {
     t.error(err, 'no error')
+  }
+})
+
+tape('basic del', function (t) {
+  t.plan(2 + 2 * 3 + 4)
+
+  var s = ras({
+    del: function (req) {
+      t.same(req.offset, 0)
+      t.same(req.size, 2)
+      req.callback(null)
+    }
+  })
+
+  t.notOk(s.readable)
+  t.notOk(s.writable)
+  t.ok(s.deletable)
+  t.notOk(s.statable)
+  s.del(0, 2, ondelete)
+  s.del(0, 2, ondelete)
+  s.del(0, 2) // cb is optional
+
+  function ondelete (err) {
+    t.error(err, 'no error')
+  }
+})
+
+tape('basic stat', function (t) {
+  t.plan(2 * 2 + 4)
+
+  var s = ras({
+    stat: function (req) {
+      req.callback(null, {size: 42})
+    }
+  })
+
+  t.notOk(s.readable)
+  t.notOk(s.writable)
+  t.notOk(s.deletable)
+  t.ok(s.statable)
+  s.stat(onstat)
+  s.stat(onstat)
+
+  function onstat (err, st) {
+    t.error(err, 'no error')
+    t.same(st, {size: 42})
+  }
+})
+
+tape('no opts', function (t) {
+  var s = ras()
+
+  t.notOk(s.readable)
+  t.notOk(s.writable)
+  t.notOk(s.deletable)
+  t.notOk(s.statable)
+  t.end()
+})
+
+tape('many open calls only trigger one _open', function (t) {
+  t.plan(1)
+
+  var s = ras({
+    open: function (req) {
+      process.nextTick(function () {
+        t.pass('is opening')
+        req.callback(null)
+      })
+    }
+  })
+
+  s.open()
+  s.open()
+  s.open()
+  s.open()
+  s.open()
+  setImmediate(() => s.open())
+})
+
+tape('open errors', function (t) {
+  t.plan(3 + 2)
+
+  var s = ras({
+    open: function (req) {
+      t.pass('in open')
+      setImmediate(() => req.callback(new Error('nope')))
+    },
+    write: function (req) {
+      t.fail('should not get here')
+      req.callback(null)
+    }
+  })
+
+  s.write(0, Buffer.from('hi'), onwrite)
+  s.write(0, Buffer.from('hi'), onwrite)
+  s.write(0, Buffer.from('hi'), onwrite)
+  s.open() // should try and open again
+
+  function onwrite (err) {
+    t.same(err, new Error('Not opened'))
+  }
+})
+
+tape('open before read', function (t) {
+  t.plan(5 * 2 + 1 + 1)
+
+  var open = false
+  var s = ras({
+    open: function (req) {
+      t.ok(!open, 'only open once')
+      open = true
+      req.callback(null)
+    },
+    read: function (req) {
+      t.ok(open, 'is open')
+      req.callback(null, Buffer.from('hi'))
+    }
+  })
+
+  t.notOk(s.opened, 'opened property not set')
+  s.read(0, 2, ondata)
+  s.read(0, 2, ondata)
+
+  function ondata (err, data) {
+    t.error(err, 'no error')
+    t.ok(open, 'is open')
+    t.ok(s.opened, 'opened property set')
     t.same(data, Buffer.from('hi'))
+  }
+})
+
+tape('close', function (t) {
+  t.plan(6)
+
+  var s = ras({
+    open: () => t.fail('no open'),
+    close: function (req) {
+      t.pass('closing')
+      req.callback(null)
+    }
   })
+
+  s.close()
+  s.close()
+  s.close(function () {
+    t.pass('calls the callback')
+  })
+
+  s.read(0, 10, err => t.same(err, new Error('Closed')))
+  s.stat(err => t.same(err, new Error('Closed')))
+  s.write(0, Buffer.from('hi'), err => t.same(err, new Error('Closed')))
+  s.del(0, 10, err => t.same(err, new Error('Closed')))
 })
+
+tape('open and close', function (t) {
+  t.plan(7)
+
+  var s = ras({
+    open: function (req) {
+      t.pass('opening')
+      req.callback(null)
+    },
+    close: function (req) {
+      t.pass('closing')
+      req.callback(null)
+    }
+  })
+
+  s.open()
+  s.close()
+  s.close()
+  s.close(function () {
+    t.pass('calls the callback')
+  })
+
+  s.read(0, 10, err => t.same(err, new Error('Closed')))
+  s.stat(err => t.same(err, new Error('Closed')))
+  s.write(0, Buffer.from('hi'), err => t.same(err, new Error('Closed')))
+  s.del(0, 10, err => t.same(err, new Error('Closed')))
+})
+
+tape('write and close', function (t) {
+  t.plan(1 + 5 + 1 + 3)
+
+  var closed = false
+  var s = ras({
+    open: function (req) {
+      t.pass('opened')
+      req.callback(null)
+    },
+    write: function (req) {
+      t.pass('in write')
+      process.nextTick(function () {
+        req.callback(null)
+      })
+    },
+    close: function (req) {
+      t.notOk(closed, 'not closed yet')
+      closed = true
+      req.callback(null)
+    }
+  })
+
+  s.write(0, Buffer.from('hi'))
+  s.write(0, Buffer.from('hi'))
+  s.write(0, Buffer.from('hi'))
+  s.write(0, Buffer.from('hi'))
+  s.write(0, Buffer.from('hi'))
+  s.close(err => t.error(err, 'no error'))
+  s.close(err => t.error(err, 'no error'))
+  s.close(err => t.error(err, 'no error'))
+})
+
+tape('open readonly', function (t) {
+  t.plan(2)
+
+  var s = ras({
+    open: () => t.fail('no open'),
+    openReadonly: function (req) {
+      t.pass('open readonly')
+      req.callback(null)
+    },
+    read: req => req.callback(null, Buffer.from('hi'))
+  })
+
+  s.open()
+  s.read(0, 10, err => t.error(err, 'no error'))
+})
+
+tape('open readonly and then write', function (t) {
+  t.plan(4)
+
+  var readonlyFirst = true
+
+  var s = ras({
+    open: function (req) {
+      t.notOk(readonlyFirst, 'open readonly first')
+      req.callback(null)
+    },
+    openReadonly: function (req) {
+      t.ok(readonlyFirst, 'open readonly first')
+      readonlyFirst = false
+      req.callback(null)
+    },
+    read: req => req.callback(null, Buffer.from('hi')),
+    write: req => req.callback(null)
+  })
+
+  s.open()
+  s.read(0, 2, err => t.error(err, 'no error'))
+  s.write(0, Buffer.from('hi'), err => t.error(err, 'no error'))
+})
+
+tape('open readonly ignored when first op is write', function (t) {
+  t.plan(3)
+
+  var s = ras({
+    open: function (req) {
+      t.pass('should open')
+      req.callback(null)
+    },
+    openReadonly: req => t.fail('first op is a write'),
+    read: req => req.callback(null, Buffer.from('hi')),
+    write: req => req.callback(null)
+  })
+
+  s.write(0, Buffer.from('hi'), err => t.error(err, 'no error'))
+  s.read(0, 2, err => t.error(err, 'no error'))
+})

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

19796

increased by46.96%

Lines of code

460

increased by124.39%

Number of low quality alerts

0

decreased by-100%

No dependency changes