resume the swarm and restart peer discovery on interested

index.js

@@ -180,8 +180,15 @@ var torrentStream = function(link, opts, cb) {
 			});
 
 			if (prev === engine.amInterested) return;
-			if (engine.amInterested) engine.emit('interested');
-			else engine.emit('uninterested');
+			if (engine.amInterested) {
+				engine.emit('interested');
+				if (swarm.paused) {
+					swarm.resume();
+					discovery.restart();
+				}
+			} else {
+				engine.emit('uninterested');
+			}
 		};
 
 		var gc = function() {
@@ -581,15 +588,11 @@ var torrentStream = function(link, opts, cb) {
 		if (engine.bitfield) wire.bitfield(engine.bitfield);
 	});
 
-	swarm.pause();
-
 	if (link.files && engine.metadata) {
-		swarm.resume();
 		ontorrent(link);
 	} else {
 		fs.readFile(torrentPath, function(_, buf) {
 			if (destroyed) return;
-			swarm.resume();
 
 			// We know only infoHash here, not full infoDictionary.
 			// But infoHash is enough to connect to trackers and get peers.

lib/peer-discovery.js

@@ -4,12 +4,8 @@ var tracker = require('bittorrent-tracker');
 
 var DEFAULT_PORT = 6881;
 
-module.exports = function(torrent, opts) {
-	if (typeof opts !== 'object') {
-		opts = torrent;
-		torrent = null;
-	}
-
+module.exports = function(opts) {
+	var torrent;
 	var port = opts.port || DEFAULT_PORT;
 
 	var discovery = new events.EventEmitter();
@@ -74,16 +70,24 @@ module.exports = function(torrent, opts) {
 		if (port === p) return;
 		port = p;
 		if (discovery.tracker) discovery.tracker.stop();
-		if (discovery.dht) discovery.dht.announce(torrent.infoHash, port);
-		if (torrent) discovery.tracker = createTracker(torrent);
+		if (torrent) {
+			if (discovery.dht) discovery.dht.announce(torrent.infoHash, port);
+			discovery.tracker = createTracker(torrent);
+		}
 	};
 
 	discovery.stop = function() {
 		if (discovery.tracker) discovery.tracker.stop();
 		if (discovery.dht) discovery.dht.destroy();
 	};
 
-	if (torrent) discovery.setTorrent(torrent);
+	discovery.restart = function() {
+		if (!torrent) return;
+		if (discovery.tracker) discovery.tracker.stop();
+		if (discovery.dht) discovery.dht.destroy();
+		discovery.tracker = createTracker(torrent);
+		discovery.dht = createDHT(torrent.infoHash);
+	};
 
 	return discovery;
 };