const { createReadStream } = require('fs')
const { BasicTimeline } = require('hypersim-parser')
 
const parser = new BasicTimeline()
 
// Register a custom aggregator
parser.pushReducer('version', (prev, { type, event, seq }) => {
  if (type !== 'custom' && event !== 'block') return 0
  return seq
})
 
// 'snapshot' event is emitted once for each tick in the simulation's timeline
parser.once('snapshot', (snapshot, iteration) => {
  console.log(snapshot)
  snapshot.version // contains the result the custom reducer/aggregator.
})
 
// 'close' is fired once all events has been traversed.
parser.once('close', () => console.log('Parsing complete'))
 
// The parser implements a Writable stream, and accepts
// ndjson in chunks of Buffer | Uint8Array | string
 
const readable = fs.createReadStream('swarm-log.json')
readable.pipe(parser)