From 8375237fdfdd986dacef6601129098a1d8b812b1 Mon Sep 17 00:00:00 2001 From: OldHawk Date: Wed, 20 Dec 2017 18:12:34 +0800 Subject: [PATCH] fix(core): fixed model.remove method with exec() --- .../server/controllers/announces.server.controller.js | 4 ++-- .../server/controllers/subtitles.server.controller.js | 2 +- .../server/controllers/torrents.server.controller.js | 8 ++++---- 3 files changed, 7 insertions(+), 7 deletions(-) diff --git a/modules/announce/server/controllers/announces.server.controller.js b/modules/announce/server/controllers/announces.server.controller.js index 213ad408..9e1daf9c 100644 --- a/modules/announce/server/controllers/announces.server.controller.js +++ b/modules/announce/server/controllers/announces.server.controller.js @@ -327,7 +327,7 @@ exports.announce = function (req, res) { Peer.remove({ torrent: req.torrent._id, _id: {$nin: req.torrent._peers} - }); + }).exec(); } done(null); @@ -741,7 +741,7 @@ exports.announce = function (req, res) { $pull: {_peers: p._id} }).exec(); - p.remove(); + p.remove().exec(); mtDebug.debugGreen('---------------removePeer()----------------'); } diff --git a/modules/torrents/server/controllers/subtitles.server.controller.js b/modules/torrents/server/controllers/subtitles.server.controller.js index ce9ad0d4..3c6064ae 100644 --- a/modules/torrents/server/controllers/subtitles.server.controller.js +++ b/modules/torrents/server/controllers/subtitles.server.controller.js @@ -154,7 +154,7 @@ exports.delete = function (req, res) { //}).exec(); torrent._subtitles.pull(r._id); - r.remove(); + r.remove().exec(); res.json(torrent); scoreUpdate(req, torrent.user, scoreConfig.action.uploadSubtitleBeDeleted); diff --git a/modules/torrents/server/controllers/torrents.server.controller.js b/modules/torrents/server/controllers/torrents.server.controller.js index 2d60f7f1..4ff5922c 100644 --- a/modules/torrents/server/controllers/torrents.server.controller.js +++ b/modules/torrents/server/controllers/torrents.server.controller.js @@ -799,7 +799,7 @@ exports.toggleHnRStatus = function (req, res) { removeTorrentHnRWarning(torrent._id); Complete.remove({ torrent: torrent._id - }); + }).exec(); } //add server message @@ -1199,11 +1199,11 @@ exports.delete = function (req, res) { //remove all peers of the torrent Peer.remove({ torrent: torrent._id - }); + }).exec(); //remove all subtitle of the torrent Subtitle.remove({ torrent: torrent._id - }); + }).exec(); //update maker torrent count if (torrent.maker) { torrent.maker.update({ @@ -1220,7 +1220,7 @@ exports.delete = function (req, res) { removeTorrentHnRWarning(torrent._id); Complete.remove({ torrent: torrent._id - }); + }).exec(); torrent.remove(function (err) { if (err) {