brock/torrentio
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[addon] fix multiple entries from same torrent issue

Browse Source
This commit is contained in:
TheBeastLT
2020-03-17 22:57:31 +01:00
parent 60b74683d4
commit 1308b9eb7a
1 changed files with 10 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
addon/moch/realdebrid.js
View File

@@ -11,23 +11,18 @@ const PROXY_PASSWORD = process.env.PROXY_PASSWORD;
async function applyMoch(streams, apiKey) {
const RD = new RealDebridClient(apiKey);
const hashes = streams.map(stream => stream.infoHash);
const streamMapping = streams.reduce((map, stream) => (map[stream.infoHash] = stream, map), {});
const available = await _instantAvailability(RD, hashes);
if (available) {
Object.entries(available)
.map(([key, value]) => ({
cachedInfoHash: key.toLowerCase(),
cachedFileIds: getCachedFileIds(streamMapping[key.toLowerCase()].fileIdx, value)
}))
.filter(cachedEntry => cachedEntry.cachedFileIds && cachedEntry.cachedFileIds.length)
.forEach(cachedEntry => {
const stream = streamMapping[cachedEntry.cachedInfoHash];
const cachedIds = cachedEntry.cachedFileIds.join(',');
stream.name = `[RD Cached]\n${stream.name}`;
stream.url = `${ADDON_HOST}/realdebrid/${apiKey}/${stream.infoHash}/${cachedIds}/${stream.fileIdx}`;
delete stream.infoHash;
delete stream.fileIndex;
})
streams.forEach(stream => {
const cachedEntry = available[stream.infoHash];
const cachedIds = getCachedFileIds(stream.fileIdx, cachedEntry);
if (cachedIds && cachedIds.length) {
stream.name = `[RD Cached]\n${stream.name}`;
stream.url = `${ADDON_HOST}/realdebrid/${apiKey}/${stream.infoHash}/${cachedIds.join(',')}/${stream.fileIdx}`;
delete stream.infoHash;
delete stream.fileIndex;
}
});
}
return streams;