[addon] adds premiumize download functionality

addon/moch/premiumize.js

@@ -2,6 +2,7 @@ const PremiumizeClient = require('premiumize-api');
 const namedQueue = require('named-queue');
 const { encode } = require('magnet-uri');
 const isVideo = require('../lib/video');
+const StaticResponse = require('./static');
 const { getRandomProxy, getRandomUserAgent } = require('../lib/request_helper');
 const { cacheWrapResolvedUrl, cacheWrapProxy, cacheUserAgent } = require('../lib/cache');
 
@@ -37,7 +38,11 @@ async function resolve({ ip, apiKey, infoHash, cachedEntryInfo, fileIndex }) {
     return Promise.reject("No valid parameters passed");
   }
   const id = `${apiKey}_${infoHash}_${fileIndex}`;
-  const method = () => cacheWrapResolvedUrl(id, () => _unrestrict(ip, apiKey, infoHash, cachedEntryInfo, fileIndex));
+  const method = () => cacheWrapResolvedUrl(id, () => _unrestrict(ip, apiKey, infoHash, cachedEntryInfo, fileIndex))
+      .catch(error => {
+        console.warn(error);
+        return StaticResponse.FAILED_UNEXPECTED;
+      });
 
   return new Promise(((resolve, reject) => {
     unrestrictQueue.push({ id, method }, (error, result) => result ? resolve(result) : reject(error));
@@ -48,8 +53,26 @@ async function _unrestrict(ip, apiKey, infoHash, encodedFileName, fileIndex) {
   console.log(`Unrestricting ${infoHash} [${fileIndex}]`);
   const options = await getDefaultOptions(apiKey, ip);
   const PM = new PremiumizeClient(apiKey, options);
+
+  const cachedLink = await _getCachedLink(PM, infoHash, encodedFileName, fileIndex).catch(() => undefined);
+  if (cachedLink) {
+    return cachedLink;
+  }
+
+  const torrent = await _createOrFindTorrent(PM, infoHash, encodedFileName, fileIndex);
+  if (torrent && statusReady(torrent.status)) {
+    return _getCachedLink(PM, infoHash, encodedFileName, fileIndex);
+  } else if (torrent && statusDownloading(torrent.status)) {
+    return StaticResponse.DOWNLOADING;
+  } else if (torrent && statusError(torrent.status)) {
+    return _retryCreateTorrent(PM, infoHash, encodedFileName, fileIndex);
+  }
+  return Promise.reject("Failed Premiumize adding torrent");
+}
+
+async function _getCachedLink(PM, infoHash, encodedFileName, fileIndex) {
   const cachedTorrent = await PM.transfer.directDownload(encode({ infoHash }));
-  if (cachedTorrent.content && cachedTorrent.content.length) {
+  if (cachedTorrent && cachedTorrent.content && cachedTorrent.content.length) {
     const targetFileName = decodeURIComponent(encodedFileName);
     const videos = cachedTorrent.content.filter(file => isVideo(file.path));
     const targetVideo = Number.isInteger(fileIndex)
@@ -59,7 +82,47 @@ async function _unrestrict(ip, apiKey, infoHash, encodedFileName, fileIndex) {
     console.log(`Unrestricted ${infoHash} [${fileIndex}] to ${unrestrictedLink}`);
     return unrestrictedLink;
   }
-  return Promise.reject("Failed Premiumize adding torrent");
+  return Promise.reject('No cached entry found');
+}
+
+async function _createOrFindTorrent(PM, infoHash) {
+  return _findTorrent(PM, infoHash)
+      .catch(() => _createTorrent(PM, infoHash))
+      .catch(error => {
+        console.warn('Failed Premiumize torrent retrieval', error);
+        return error;
+      });
+}
+
+async function _findTorrent(PM, infoHash) {
+  const torrents = await PM.transfer.list().then(response => response.transfers);
+  const foundTorrents = torrents.filter(torrent => torrent.src.toLowerCase().includes(infoHash));
+  const nonFailedTorrent = foundTorrents.find(torrent => !statusError(torrent.statusCode));
+  const foundTorrent = nonFailedTorrent || foundTorrents[0];
+  return foundTorrent || Promise.reject('No recent torrent found');
+}
+
+async function _createTorrent(PM, infoHash) {
+  return PM.transfer.create(encode({ infoHash })).then(() => _findTorrent(PM, infoHash));
+}
+
+async function _retryCreateTorrent(PM, infoHash, encodedFileName, fileIndex) {
+  const newTorrent = await _createTorrent(PM, infoHash).then(() => _findTorrent(PM, infoHash));
+  return newTorrent && statusReady(newTorrent.status)
+      ? _getCachedLink(PM, infoHash, encodedFileName, fileIndex)
+      : StaticResponse.FAILED_DOWNLOAD;
+}
+
+function statusError(status) {
+  return ['deleted', 'error', 'timeout'].includes(status)
+}
+
+function statusDownloading(status) {
+  return ['waiting', 'queued', 'running'].includes(status)
+}
+
+function statusReady(status) {
+  return status === 'finished';
 }
 
 async function getDefaultOptions(id, ip) {