simple.js

var fs = require('fs')

var Blocks = require('../blocks')
var File = require('../file')

var tape = require('tape')

var a = Buffer.alloc(32, 'a')
var b = Buffer.alloc(32, 'b')
var c = Buffer.alloc(32, 'c')

function Cache () {
  var c = []
  return {
    get: function (key) { return c[key] },
    set: function (key, value) { c[key] = value }
  }
}

tape('splice', function (t) {
  var cache = Cache()
  var bufs = Blocks(null, 32, cache)
  cache.set(0, a)
  cache.set(1, b)
  cache.set(2, c)
  bufs.offset = 96

  function test(start, end, expected) {
    bufs.read(start, end, function (err, actual) {
      if(err) throw err
      t.deepEqual(actual, expected)
    })
  }

  test(0, 32, a)
  test(32, 64, b)
  test(64, 96, c)

  test(0, 64, Buffer.concat([a, b]))
  test(32, 96, Buffer.concat([b, c]))

  var _a = a.slice(0, 16)
  var _b = b.slice(0, 16)
  var _c = c.slice(0, 16)

  test(16, 32 + 16, Buffer.concat([_a, _b]))
  test(32 + 16, 64 + 16, Buffer.concat([_b, _c]))

  t.end()
})

tape('read file', function (t) {
  var file = '/tmp/test_block-reader_'+Date.now()
  fs.appendFileSync(file, a)
  fs.appendFileSync(file, b)
  fs.appendFileSync(file, c)
  var bufs = Blocks(File(file, 32, 'a+'), 32)

  t.plan(7)

  function test(start, end, expected) {
    bufs.read(start, end, function (err, actual) {
      if(err) throw err
      t.deepEqual(actual, expected)
    })
  }

  test(0, 32, a)
  test(32, 64, b)
  test(64, 96, c)

  test(0, 64, Buffer.concat([a, b]))
  test(32, 96, Buffer.concat([b, c]))

  var _a = a.slice(0, 16)
  var _b = b.slice(0, 16)
  var _c = c.slice(0, 16)

  test(16, 32 + 16, Buffer.concat([_a, _b]))
  test(32 + 16, 64 + 16, Buffer.concat([_b, _c]))

})

tape('read empty file', function (t) {
  var file = '/tmp/test_block-reader_'+Date.now()
  var bufs = Blocks(File(file, 32, 'a+'), 32)
  bufs.read(0, 32, function (err, buf, bytes_read) {
    t.ok(err)
    t.equal(bytes_read, 0)
    t.end()
  })
})

tape('overwrite previous data', function (t) {
  var file = '/tmp/test_block-reader_'+Date.now()
  var bufs = Blocks(File(file, 32, 'r+'), 32)
  bufs.append(a, function (err) {
    t.error(err)
    bufs.read(0, 32, function (err, bufA) {
      t.error(err)
      t.deepEqual(bufA, a)
      bufs.write(b, 0, function (err) {
        t.error(err)
        bufs.read(0, 32, function (err, bufB) {
          t.error(err)
          t.deepEqual(bufB, b)
          bufs.write(b, 1, function (err) {
            t.ok(err, 'error if writing past last offset')

            // let's make a race condition!
            // first we'll start writing...
            bufs.write(c, 0, function (err) {
              t.error(err)
            })

            // and we'll start reading before it's done
            bufs.read(0, 32, (err, bufC) => {
              t.error(err)
              t.deepEqual(bufC, c)
              t.end()
            })
          })
        })
      })
    })
  })
})