text: var DHT = require('bittorrent-dht/server')
  var fixtures = require('webtorrent-fixtures')
  var fs = require('fs')
  var MemoryChunkStore = require('memory-chunk-store')
  var networkAddress = require('network-address')
  var series = require('run-series')
  var test = require('tape')
  var WebTorrent = require('../../')
  
  test('Download using DHT (via magnet uri)', function (t) {
    t.plan(12)
  
    var dhtServer = new DHT({ bootstrap: false })
  
    dhtServer.on('error', function (err) { t.fail(err) })
    dhtServer.on('warning', function (err) { t.fail(err) })
  
    var client1, client2
  
    series([
      function (cb) {
        dhtServer.listen(cb)
      },
  
      function (cb) {
        client1 = new WebTorrent({
          tracker: false,
          dht: { bootstrap: '127.0.0.1:' + dhtServer.address().port, host: networkAddress.ipv4() }
        })
  
        client1.dht.on('listening', function () {
          t.equal(client1.dhtPort, client1.dht.address().port)
        })
  
        client1.on('error', function (err) { t.fail(err) })
        client1.on('warning', function (err) { t.fail(err) })
  
        var torrent = client1.add(fixtures.leaves.parsedTorrent, { store: MemoryChunkStore })
  
        torrent.on('dhtAnnounce', function () {
          t.pass('finished dht announce')
          announced = true
          maybeDone()
        })
  
        torrent.on('ready', function () {
          // torrent metadata has been fetched -- sanity check it
          t.equal(torrent.name, 'Leaves of Grass by Walt Whitman.epub')
  
          var names = ['Leaves of Grass by Walt Whitman.epub']
          t.deepEqual(torrent.files.map(function (file) { return file.name }), names)
        })
  
        torrent.load(fs.createReadStream(fixtures.leaves.contentPath), function (err) {
          t.error(err)
          loaded = true
          maybeDone()
        })
  
        var announced = false
        var loaded = false
        function maybeDone () {
          if (announced && loaded) cb(null)
        }
      },
  
      function (cb) {
        client2 = new WebTorrent({
          tracker: false,
          dht: { bootstrap: '127.0.0.1:' + dhtServer.address().port, host: networkAddress.ipv4() }
        })
  
        client2.on('error', function (err) { t.fail(err) })
        client2.on('warning', function (err) { t.fail(err) })
  
        client2.on('torrent', function (torrent) {
          torrent.files[0].getBuffer(function (err, buf) {
            t.error(err)
            t.deepEqual(buf, fixtures.leaves.content, 'downloaded correct content')
  
            gotBuffer = true
            maybeDone()
          })
  
          torrent.once('done', function () {
            t.pass('client2 downloaded torrent from client1')
  
            gotDone = true
            maybeDone()
          })
        })
  
        client2.add(fixtures.leaves.magnetURI, { store: MemoryChunkStore })
  
        var gotBuffer = false
        var gotDone = false
        function maybeDone () {
          if (gotBuffer && gotDone) cb(null)
        }
      }
    ], function (err) {
      t.error(err)
  
      client1.destroy(function (err) {
        t.error(err, 'client1 destroyed')
      })
      client2.destroy(function (err) {
        t.error(err, 'client2 destroyed')
      })
      dhtServer.destroy(function (err) {
        t.error(err, 'dht server destroyed')
      })
    })
  })
  