fix(feed): replicate all feed record on new feed

This commit is contained in:
Alexey Kasyanchuk 2018-07-22 14:17:26 +03:00
parent 2d41bacf9b
commit 7e08d70d56
2 changed files with 5 additions and 1 deletions

View File

@ -877,7 +877,7 @@ module.exports = async ({
vote: action, vote: action,
_index: `vote:${hash}`, _index: `vote:${hash}`,
_temp: { _temp: {
torrent: await getTorrent(sphinx, hash) torrent: setupTorrentRecord(await getTorrent(sphinx, hash))
} }
}), 0) }), 0)
good += isGood ? 1 : 0 good += isGood ? 1 : 0
@ -967,6 +967,8 @@ module.exports = async ({
console.log('replace our feed with remote feed') console.log('replace our feed with remote feed')
feed.feed = remoteFeed.feed feed.feed = remoteFeed.feed
feed.feedDate = remoteFeed.feedDate || 0 feed.feedDate = remoteFeed.feedDate || 0
// it can be new torrents replicate all
feed.feed.forEach(torrent => insertTorrentToDB(torrent, true))
send('feedUpdate', { send('feedUpdate', {
feed: feed.feed feed: feed.feed
}); });

View File

@ -443,6 +443,8 @@ app.get('*', function(req, res)
// feed date clean // feed date clean
if(typeof torrent.feedDate !== 'undefined') if(typeof torrent.feedDate !== 'undefined')
delete torrent.feedDate delete torrent.feedDate
return torrent
} }
const insertTorrentToDB = (torrent, silent) => new Promise((resolve) => { const insertTorrentToDB = (torrent, silent) => new Promise((resolve) => {