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

[addon] updates putio target file retrieval

Browse Source
This commit is contained in:
TheBeastLT
2020-05-14 23:13:25 +02:00
parent d9203a88cc
commit f0886d966a
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
addon/moch/putio.js
View File

@@ -20,7 +20,7 @@ async function getCachedStreams(streams, apiKey) {
} }
async function resolve({ ip, apiKey, infoHash, cachedEntryInfo, fileIndex }) { async function resolve({ ip, apiKey, infoHash, cachedEntryInfo, fileIndex }) {
console.log(`Unrestricting ${infoHash} [${fileIndex}]`); console.log(`Unrestricting Putio ${infoHash} [${fileIndex}]`);
const clientId = apiKey.replace(/@.*/, ''); const clientId = apiKey.replace(/@.*/, '');
const token = apiKey.replace(/.*@/, ''); const token = apiKey.replace(/.*@/, '');
const Putio = new PutioAPI({ clientID: clientId }); const Putio = new PutioAPI({ clientID: clientId });
@@ -77,14 +77,14 @@ async function _getNewTorrent(Putio, torrentId, pollCounter = 0, pollRate = 2000
} }
async function _unrestrictLink(Putio, torrent, encodedFileName, fileIndex) { async function _unrestrictLink(Putio, torrent, encodedFileName, fileIndex) {
const targetVideo = await _getTargetFile(Putio, torrent, encodedFileName, fileIndex) const targetVideo = await _getTargetFile(Putio, torrent, encodedFileName, fileIndex);
const publicToken = await _getPublicToken(Putio, targetVideo.id); const publicToken = await _getPublicToken(Putio, targetVideo.id);
const publicFile = await Putio.File.Public(publicToken).then(response => response.data.parent); const publicFile = await Putio.File.Public(publicToken).then(response => response.data.parent);
if (!publicFile.stream_url || !publicFile.stream_url.length) { if (!publicFile.stream_url || !publicFile.stream_url.length) {
return Promise.reject("No available links found"); return Promise.reject(`No available links found for [${torrent.hash}] ${encodedFileName}`);
} }
console.log(`Unrestricted ${torrent.hash} [${fileIndex}] to ${publicFile.stream_url}`); console.log(`Unrestricted Putio ${torrent.hash} [${fileIndex}] to ${publicFile.stream_url}`);
return publicFile.stream_url; return publicFile.stream_url;
} }
@@ -107,11 +107,15 @@ async function _getTargetFile(Putio, torrent, encodedFileName, fileIndex) {
.then(results => results.reduce((a, b) => a.concat(b), [])) .then(results => results.reduce((a, b) => a.concat(b), []))
: []; : [];
} }
return targetFile; return targetFile ? targetFile : Promise.reject(`No target file found for Putio [${torrent.hash}] ${targetFileName}`);
} }
async function _getFiles(Putio, fileId) { async function _getFiles(Putio, fileId) {
return Putio.Files.Query(fileId).then(response => response.data.files); const response = await Putio.Files.Query(fileId)
.catch(error => Promise.reject({ ...error.data, path: error.request.path }));
return response.data.files.length
? response.data.files
: [response.data.parent];
} }
async function _getPublicToken(Putio, targetVideoId) { async function _getPublicToken(Putio, targetVideoId) {