hyperdrive-swarm.js

var test = require('tape')
var path = require('path')
var fs = require('fs')
var raf = require('random-access-file')
var hyperdrive = require('hyperdrive')
var memdb = require('memdb')

test('download with swarm', function (t) {
  var drive = hyperdrive(memdb())
  var drive2 = hyperdrive(memdb())
  var archive = drive.createArchive({
    file: function (name) {
      return raf(path.join(__dirname, name))
    }
  })
  var ws = archive.createFileWriteStream('hello.txt') // add hello.txt

  ws.write('hello')
  ws.write('world')
  ws.end()

  archive.finalize(function (err) { // finalize the archive
    t.error(err, 'no error')
    var link = archive.key
    var archive2 = drive2.createArchive(link, {
      file: function (name) {
        return raf(path.join(__dirname, name))
      }
    })
    archive = drive.createArchive(link, {
      file: function (name) {
        return raf(path.join(__dirname, name))
      }
    })

    var replication = archive.replicate()
    var clone = archive2.replicate()
    replication.pipe(clone).pipe(replication)

    var stream = archive2.list()
    stream.on('data', function (entry) {
      t.same(entry.name, 'hello.txt', 'got entry')
      archive2.download(entry, function (err) {
        t.error(err, 'no error')
        var contents = fs.readFileSync(path.join(__dirname, 'hello.txt')).toString()
        t.same(contents, 'helloworld', 'contents downloaded to disk')
        t.end()
      })
    })
  })
})