Add uTP support (BEP29)

1 files changed, 0 insertions, 128 deletions

diff --git a/lib/tcp-pool.js b/lib/tcp-pool.js
deleted file mode 100644
index 1094c4f..0000000
--- a/lib/tcp-pool.js
+++ /dev/null
@@ -1,128 +0,0 @@
-const arrayRemove = require('unordered-array-remove')
-const debug = require('debug')('webtorrent:tcp-pool')
-const net = require('net') // browser exclude
-
-const Peer = require('./peer')
-
-/**
- * TCPPool
- *
- * A "TCP pool" allows multiple swarms to listen on the same TCP port and determines
- * which swarm incoming connections are intended for by inspecting the bittorrent
- * handshake that the remote peer sends.
- *
- * @param {number} port
- */
-class TCPPool {
-  constructor (client) {
-    debug('create tcp pool (port %s)', client.torrentPort)
-
-    this.server = net.createServer()
-    this._client = client
-
-    // Temporarily store incoming connections so they can be destroyed if the server is
-    // closed before the connection is passed off to a Torrent.
-    this._pendingConns = []
-
-    this._onConnectionBound = conn => {
-      this._onConnection(conn)
-    }
-
-    this._onListening = () => {
-      this._client._onListening()
-    }
-
-    this._onError = err => {
-      this._client._destroy(err)
-    }
-
-    this.server.on('connection', this._onConnectionBound)
-    this.server.on('listening', this._onListening)
-    this.server.on('error', this._onError)
-
-    this.server.listen(client.torrentPort)
-  }
-
-  /**
-   * Destroy this TCP pool.
-   * @param  {function} cb
-   */
-  destroy (cb) {
-    debug('destroy tcp pool')
-
-    this.server.removeListener('connection', this._onConnectionBound)
-    this.server.removeListener('listening', this._onListening)
-    this.server.removeListener('error', this._onError)
-
-    // Destroy all open connection objects so server can close gracefully without waiting
-    // for connection timeout or remote peer to disconnect.
-    this._pendingConns.forEach(conn => {
-      conn.on('error', noop)
-      conn.destroy()
-    })
-
-    try {
-      this.server.close(cb)
-    } catch (err) {
-      if (cb) process.nextTick(cb)
-    }
-
-    this.server = null
-    this._client = null
-    this._pendingConns = null
-  }
-
-  /**
-   * On incoming connections, we expect the remote peer to send a handshake first. Based
-   * on the infoHash in that handshake, route the peer to the right swarm.
-   */
-  _onConnection (conn) {
-    const self = this
-
-    // If the connection has already been closed before the `connect` event is fired,
-    // then `remoteAddress` will not be available, and we can't use this connection.
-    // - Node.js issue: https://github.com/nodejs/node-v0.x-archive/issues/7566
-    // - WebTorrent issue: https://github.com/webtorrent/webtorrent/issues/398
-    if (!conn.remoteAddress) {
-      conn.on('error', noop)
-      conn.destroy()
-      return
-    }
-
-    self._pendingConns.push(conn)
-    conn.once('close', cleanupPending)
-
-    const peer = Peer.createTCPIncomingPeer(conn)
-
-    const wire = peer.wire
-    wire.once('handshake', onHandshake)
-
-    function onHandshake (infoHash, peerId) {
-      cleanupPending()
-
-      const torrent = self._client.get(infoHash)
-      if (torrent) {
-        peer.swarm = torrent
-        torrent._addIncomingPeer(peer)
-        peer.onHandshake(infoHash, peerId)
-      } else {
-        const err = new Error(
-          `Unexpected info hash ${infoHash} from incoming peer ${peer.id}`
-        )
-        peer.destroy(err)
-      }
-    }
-
-    function cleanupPending () {
-      conn.removeListener('close', cleanupPending)
-      wire.removeListener('handshake', onHandshake)
-      if (self._pendingConns) {
-        arrayRemove(self._pendingConns, self._pendingConns.indexOf(conn))
-      }
-    }
-  }
-}
-
-function noop () {}
-
-module.exports = TCPPool