blob-log-decoder

var Decoder = require('blob-log-decoder')
var fs = require('fs')
 
fs.createReadStream(path)
.pipe(new Decoder())
.on('data', function (blob) {
  // blob.index (Number)
  // blob.length (Number)
  // blob.crc (Number)
  // blob.stream (Readable)
})
.once('end', function () {
  // ...
})

var crcHash = require('crc-hash')
var assert = require('assert')
 
decoder.on('data', function (blob) {
  var expectedCRC = blob.crc
  var expectedLength = blob.length
  var crc = crcHash.createHash('crc32')
  var length = 0
  var buffer = []
  blob.stream
  .on('data', function (chunk) {
    length += chunk.length
    crc.update(chunk)
  })
  .once('end', function () {
    assert.equal(crc.digest().readUInt32BE(), expectedCRC)
    assert.equal(length, expectedLength)
  })
})