const DHT = require('bittorrent-dht/server')
const fixtures = require('webtorrent-fixtures')
const MemoryChunkStore = require('memory-chunk-store')
const series = require('run-series')
const test = require('tape')
const WebTorrent = require('../../')

test('private torrent should not use DHT', t => {
  t.plan(4)

  const dhtServer = new DHT({ bootstrap: false })

  dhtServer.on('error', err => { t.fail(err) })
  dhtServer.on('warning', err => { t.fail(err) })

  let client

  series([
    cb => {
      dhtServer.listen(cb)
    },

    cb => {
      client = new WebTorrent({
        tracker: false,
        lsd: false,
        dht: { bootstrap: `127.0.0.1:${dhtServer.address().port}` }
      })

      client.on('error', err => { t.fail(err) })
      client.on('warning', err => { t.fail(err) })

      const torrent = client.add(fixtures.bunny.parsedTorrent, { store: MemoryChunkStore })

      torrent.on('dhtAnnounce', () => {
        t.fail('client announced to dht')
      })

      client.on('torrent', () => {
        if (!torrent.discovery.dht) {
          t.pass('dht is disabled for this torrent')
          cb(null)
        }
      })
    }
  ], err => {
    t.error(err)

    dhtServer.destroy(err => {
      t.error(err, 'dht server destroyed')
    })
    client.destroy(err => {
      t.error(err, 'client destroyed')
    })
  })
})

test('public torrent should use DHT', t => {
  t.plan(4)

  const dhtServer = new DHT({ bootstrap: false })

  dhtServer.on('error', err => { t.fail(err) })
  dhtServer.on('warning', err => { t.fail(err) })

  let client

  series([
    cb => {
      dhtServer.listen(cb)
    },

    cb => {
      client = new WebTorrent({
        tracker: false,
        lsd: false,
        dht: { bootstrap: `127.0.0.1:${dhtServer.address().port}` }
      })

      client.on('error', err => { t.fail(err) })
      client.on('warning', err => { t.fail(err) })

      const torrent = client.add(fixtures.leaves.parsedTorrent, { store: MemoryChunkStore })

      torrent.on('dhtAnnounce', () => {
        t.pass('client announced to dht')
        cb(null)
      })

      client.on('torrent', () => {
        if (!torrent.client.dht) {
          t.fail('dht server is null')
        }
      })
    }
  ], err => {
    t.error(err)

    dhtServer.destroy(err => {
      t.error(err, 'dht server destroyed')
    })
    client.destroy(err => {
      t.error(err, 'client destroyed')
    })
  })
})

test('public torrent with forced private option should not use DHT', t => {
  t.plan(4)

  const dhtServer = new DHT({ bootstrap: false })

  dhtServer.on('error', err => { t.fail(err) })
  dhtServer.on('warning', err => { t.fail(err) })

  let client

  series([
    cb => {
      dhtServer.listen(cb)
    },

    cb => {
      client = new WebTorrent({
        tracker: false,
        lsd: false,
        dht: { bootstrap: `127.0.0.1:${dhtServer.address().port}` }
      })

      client.on('error', err => { t.fail(err) })
      client.on('warning', err => { t.fail(err) })

      const torrent = client.add(fixtures.leaves.parsedTorrent, {
        private: true,
        store: MemoryChunkStore
      })

      torrent.on('dhtAnnounce', () => {
        t.fail('client announced to dht')
      })

      client.on('torrent', () => {
        if (!torrent.discovery.dht) {
          t.pass('dht is disabled for this torrent')
          cb(null)
        }
      })
    }
  ], err => {
    t.error(err)

    dhtServer.destroy(err => {
      t.error(err, 'dht server destroyed')
    })
    client.destroy(err => {
      t.error(err, 'client destroyed')
    })
  })
})

test('private torrent with forced public option should use DHT', t => {
  t.plan(4)

  const dhtServer = new DHT({ bootstrap: false })

  dhtServer.on('error', err => { t.fail(err) })
  dhtServer.on('warning', err => { t.fail(err) })

  let client

  series([
    cb => {
      dhtServer.listen(cb)
    },

    cb => {
      client = new WebTorrent({
        tracker: false,
        lsd: false,
        dht: { bootstrap: `127.0.0.1:${dhtServer.address().port}` }
      })

      client.on('error', err => { t.fail(err) })
      client.on('warning', err => { t.fail(err) })

      const torrent = client.add(fixtures.bunny.parsedTorrent, {
        private: false,
        store: MemoryChunkStore
      })

      torrent.on('dhtAnnounce', () => {
        t.pass('client announced to dht')
        cb(null)
      })

      client.on('torrent', () => {
        if (!torrent.client.dht) {
          t.fail('dht server is null')
        }
      })
    }
  ], err => {
    t.error(err)

    dhtServer.destroy(err => {
      t.error(err, 'dht server destroyed')
    })
    client.destroy(err => {
      t.error(err, 'client destroyed')
    })
  })
})