tools/knightcrawler
1
0
Fork 0
mirror of https://github.com/knightcrawler-stremio/knightcrawler.git synced 2024-12-20 03:29:51 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

[addon] adds a longer waiting period to wait when opening a torrent in RD

Browse Source
This commit is contained in:
TheBeastLT
2020-12-19 15:19:50 +01:00
parent b39e54e2e0
commit 3e96d7206d
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
addon/moch/realdebrid.js
View File

@@ -7,7 +7,7 @@ const StaticResponse = require('./static');
const { getRandomProxy, getProxyAgent, getRandomUserAgent, blacklistProxy } = require('../lib/requestHelper'); const { getRandomProxy, getProxyAgent, getRandomUserAgent, blacklistProxy } = require('../lib/requestHelper');
const { cacheWrapProxy, cacheUserAgent, uncacheProxy } = require('../lib/cache'); const { cacheWrapProxy, cacheUserAgent, uncacheProxy } = require('../lib/cache');
const MIN_SIZE = 15728640; // 15 MB const MIN_SIZE = 5 * 1024 * 1024; // 5 MB
const CATALOG_MAX_PAGE = 5; const CATALOG_MAX_PAGE = 5;
const CATALOG_PAGE_SIZE = 100; const CATALOG_PAGE_SIZE = 100;
const KEY = "realdebrid" const KEY = "realdebrid"
@@ -197,11 +197,7 @@ async function _selectTorrentFiles(RD, torrent, cachedFileIds) {
return RD.torrents.selectFiles(torrent.id, cachedFileIds); return RD.torrents.selectFiles(torrent.id, cachedFileIds);
} }
torrent = torrent.status ? torrent : await _getTorrentInfo(RD, torrent.id); torrent = statusWaitingSelection(torrent.status) ? torrent : await _openTorrent(RD, torrent.id);
if (torrent && statusOpening(torrent.status)) {
// sleep for 2 seconds, maybe the torrent will be converted
torrent = await delay(2000).then(() => _getTorrentInfo(RD, torrent.id));
}
if (torrent && torrent.files && statusWaitingSelection(torrent.status)) { if (torrent && torrent.files && statusWaitingSelection(torrent.status)) {
const videoFileIds = torrent.files const videoFileIds = torrent.files
.filter(file => isVideo(file.path)) .filter(file => isVideo(file.path))
@@ -213,6 +209,13 @@ async function _selectTorrentFiles(RD, torrent, cachedFileIds) {
return Promise.reject('Failed RealDebrid torrent file selection') return Promise.reject('Failed RealDebrid torrent file selection')
} }
async function _openTorrent(RD, torrentId, pollCounter = 0, pollRate = 2000, maxPollNumber = 10) {
return _getTorrentInfo(RD, torrentId)
.then(torrent => torrent && statusOpening(torrent.status) && pollCounter < maxPollNumber
? delay(pollRate).then(() => _openTorrent(RD, torrentId, pollCounter + 1))
: torrent);
}
async function _unrestrictLink(RD, torrent, fileIndex) { async function _unrestrictLink(RD, torrent, fileIndex) {
const targetFile = torrent.files.find(file => file.id === fileIndex + 1) const targetFile = torrent.files.find(file => file.id === fileIndex + 1)
|| torrent.files.filter(file => file.selected).sort((a, b) => b.bytes - a.bytes)[0]; || torrent.files.filter(file => file.selected).sort((a, b) => b.bytes - a.bytes)[0];