From 2d41bacf9b8fa26f596a2dfa442dbf610c88f097 Mon Sep 17 00:00:00 2001 From: Alexey Kasyanchuk Date: Sun, 22 Jul 2018 13:59:52 +0300 Subject: [PATCH] fix(feed): fix fileList coruption of feed replication --- src/background/spider.js | 33 ++++++++++++++------------------- 1 file changed, 14 insertions(+), 19 deletions(-) diff --git a/src/background/spider.js b/src/background/spider.js index 169a63c..d156304 100644 --- a/src/background/spider.js +++ b/src/background/spider.js @@ -284,25 +284,6 @@ app.get('*', function(req, res) }, 90000) // try to load new peers if there is no one found } - let undoneQueries = 0; - let pushDatabaseBalance = () => { - undoneQueries++; - if(undoneQueries >= 5000) - { - balanceDebug('start balance mysql, queries:', undoneQueries); - spider.ignore = true; - } - }; - let popDatabaseBalance = () => { - undoneQueries--; - balanceDebug('balanced, queries left:', undoneQueries); - if(undoneQueries == 0) - { - balanceDebug('balance done'); - spider.ignore = false; - } - }; - const updateTorrentTrackers = (hash) => { let maxSeeders = 0, maxLeechers = 0, maxCompleted = 0; mysqlSingle.query('UPDATE torrents SET trackersChecked = ? WHERE hash = ?', [Math.floor(Date.now() / 1000), hash], (err, result) => { @@ -458,6 +439,10 @@ app.get('*', function(req, res) // clean download info if added if(torrent.download) delete torrent.download + + // feed date clean + if(typeof torrent.feedDate !== 'undefined') + delete torrent.feedDate } const insertTorrentToDB = (torrent, silent) => new Promise((resolve) => { @@ -467,6 +452,9 @@ app.get('*', function(req, res) return } + // duplicate object because we will do object modification + torrent = Object.assign({}, torrent) + // setup torrent record if it from db setupTorrentRecord(torrent) @@ -568,7 +556,14 @@ app.get('*', function(req, res) if(typeof torrent !== 'object') return + // duplicate object because we will do object modification + torrent = Object.assign({}, torrent) + + // setup torrent record if it from db + setupTorrentRecord(torrent) + delete torrent.id + delete torrent.filesList await mysqlSingle.updateValues('torrents', torrent, {hash: torrent.hash}) }