Nemcio/meanTorrent
1
0
Fork 0
mirror of https://github.com/taobataoma/meanTorrent.git synced 2026-03-24 04:40:18 +01:00
Code Issues Packages Projects Releases Wiki Activity

fix(announce): update peer ip & port when changed than old peer record

Browse Source
This commit is contained in:
OldHawk
2018-05-14 18:58:10 +08:00
parent d858f6c9a9
commit f2882279ab
1 changed files with 14 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
modules/announce/server/controllers/announces.server.controller.js
View File

@@ -489,7 +489,7 @@ exports.announce = function (req, res) {
getCurrentPeer(function () {
mtDebug.debugRed('req.currentPeer.isNewCreated = ' + req.currentPeer.isNewCreated, 'ANNOUNCE', true, req.passkeyuser);
mtDebug.debugRed(req.currentPeer._id.toString(), 'ANNOUNCE', true, req.passkeyuser);
mtDebug.debugRed('req.currentPeer._id = ' + req.currentPeer._id.toString(), 'ANNOUNCE', true, req.passkeyuser);
done(null);
});
},
@@ -948,6 +948,19 @@ exports.announce = function (req, res) {
req.currentPeer.torrent = req.torrent;
req.currentPeer.isNewCreated = false;
//if find peer_id, but some time some client (like qbittorrent 4.1.0) the ip or port is changed, update it
if (req.currentPeer.peer_ip !== req.cf_ip || req.currentPeer.peer_port !== query.port) {
req.currentPeer.peer_ip = req.cf_ip;
req.currentPeer.peer_port = query.port;
req.currentPeer.update({
$set: {
peer_ip: req.cf_ip,
peer_port: query.port
}
}).exec();
}
if (req.seeder && req.currentPeer.peer_status !== PEERSTATE_SEEDER && event(query.event) !== EVENT_COMPLETED) {
mtDebug.debugGreen('---------------PEER STATUS CHANGED: Seeder----------------', 'ANNOUNCE', true, req.passkeyuser);
doCompleteEvent(function () {