var hyperdrive = require('hyperdrive')
var pump = require('pump')
var fs = require('fs')
var storage = require('dat-storage')

var source = hyperdrive('./source')

source.ready(() => {
  var dest = hyperdrive(storage('./dest'), source.key, {
    latest: true, sparse: false
  })

  dest.on('syncing', () => {
    console.log('dest syncing')
    console.log('  dest version:', dest.version)
    console.log('  source version:', source.version)
  })

  dest.on('sync', () => {
    console.log('dest sync, version:', dest.version)
  })

  setInterval(() => {
    source.readFile('hi.txt', 'utf8', (err,data) => {
      if (!data) data = ''
      source.writeFile('hi.txt', data + new Date() + '\n')
    })
  }, 1000)

  var stream = dest.replicate({live: true})
  stream.pipe(source.replicate()).pipe(stream)
})