From f14d0b83df663697edb1ab073fb865122e86ac58 Mon Sep 17 00:00:00 2001 From: Alex Date: Mon, 8 Aug 2016 17:25:25 +0200 Subject: [PATCH] Add id parameter in announce calls --- lib/server/swarm.js | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/lib/server/swarm.js b/lib/server/swarm.js index d0b3277..3d987bf 100644 --- a/lib/server/swarm.js +++ b/lib/server/swarm.js @@ -50,7 +50,7 @@ Swarm.prototype.scrape = function (params, cb) { Swarm.prototype._onAnnounceStarted = function (params, peer, id) { if (peer) { debug('unexpected `started` event from peer that is already in swarm') - return this._onAnnounceUpdate(params, peer) // treat as an update + return this._onAnnounceUpdate(params, peer, id) // treat as an update } if (params.left === 0) this.complete += 1 @@ -79,7 +79,7 @@ Swarm.prototype._onAnnounceStopped = function (params, peer, id) { Swarm.prototype._onAnnounceCompleted = function (params, peer, id) { if (!peer) { debug('unexpected `completed` event from peer that is not in swarm') - return this._onAnnounceStarted(params, peer) // treat as a start + return this._onAnnounceStarted(params, peer, id) // treat as a start } if (peer.complete) { debug('unexpected `completed` event from peer that is already marked as completed') @@ -95,7 +95,7 @@ Swarm.prototype._onAnnounceCompleted = function (params, peer, id) { Swarm.prototype._onAnnounceUpdate = function (params, peer, id) { if (!peer) { debug('unexpected `update` event from peer that is not in swarm') - return this._onAnnounceStarted(params, peer) // treat as a start + return this._onAnnounceStarted(params, peer, id) // treat as a start } if (!peer.complete && params.left === 0) {