From 6a595fa747c1abc196e1b034626a5d5d1fe53fb2 Mon Sep 17 00:00:00 2001 From: OldHawk Date: Thu, 2 Nov 2017 17:49:21 +0800 Subject: [PATCH] fix(torrents):fixed announce peer issues --- .../server/controllers/announces.server.controller.js | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/modules/announce/server/controllers/announces.server.controller.js b/modules/announce/server/controllers/announces.server.controller.js index b38f8e04..daf996dd 100644 --- a/modules/announce/server/controllers/announces.server.controller.js +++ b/modules/announce/server/controllers/announces.server.controller.js @@ -265,7 +265,7 @@ exports.announce = function (req, res) { if (req.torrent._peers.length > 0) { for (var i = req.torrent._peers.length; i > 0; i--) { var p = req.torrent._peers[i - 1]; - if (p.user.str === req.passkeyuser._id.str) { + if (p.user.equals(req.passkeyuser._id)) { var diff = moment(Date.now()).diff(moment(p.last_announce_at || p.startedat), 'seconds'); if (diff > ANNOUNCE_INTERVAL * ANNOUNCE_GHOST) { removePeer(p); @@ -361,8 +361,10 @@ exports.announce = function (req, res) { mtDebug.debugGreen('---------------EVENT_STARTED----------------'); if (getSelfLeecherCount() >= 1 && !req.seeder) { + mtDebug.debugGreen(req.selfpeer); done(180); } else if (getSelfSeederCount >= 3 && req.seeder) { + mtDebug.debugGreen(req.selfpeer); done(181); } else { if (req.currentPeer === undefined) { @@ -789,7 +791,7 @@ exports.announce = function (req, res) { for (var i = 0; i < m; i++) { var index = Math.floor(Math.random() * peers.length); p = peers[index]; - //if (p !== undefined && p.user.str !== req.passkeyuser._id.str) { + //if (p !== undefined && !p.user.equals(req.passkeyuser._id)) { if (p !== undefined) { var b = compact(p); if (b) {