# -*- coding: utf-8 -*- import re from pycurl import error from module.plugins.Hoster import Hoster from module.network.RequestFactory import getURL from module.plugins.Plugin import chunks from module.plugins.ReCaptcha import ReCaptcha from module.utils import parseFileSize def getInfo(urls): pattern = re.compile(UploadedTo.__pattern__) for chunk in chunks(urls, 10): result = [] for url in chunk: match = pattern.search(url) if match: src = getURL("http://uploaded.to/api/file", get={"id": match.group(1).split("/")[0]}).decode("utf8", "ignore") if src.find("404 Not Found") >= 0: result.append((url, 0, 1, url)) continue lines = src.splitlines() result.append((lines[0], int(lines[1]), 2, url)) yield result class UploadedTo(Hoster): __name__ = "UploadedTo" __type__ = "hoster" __pattern__ = r"http://(?:www\.)?u(?:p)?l(?:oaded)?\.to/(?:file/|\?id=)?(.+)" __version__ = "0.4" __description__ = """Uploaded.to Download Hoster""" __author_name__ = ("spoob", "mkaay") __author_mail__ = ("spoob@pyload.org", "mkaay@mkaay.de") def setup(self): self.html = None self.data = {} self.multiDL = False self.url = False if self.account: self.multiDL = True self.chunkLimit = -1 self.resumeDownload = True self.pyfile.url = self.cleanUrl(self.pyfile.url) self.fileID = re.search(self.__pattern__, self.pyfile.url).group(1) def process(self, pyfile): self.req.cj.setCookie("uploaded.to", "lang", "en") self.html = self.load(self.pyfile.url, cookies=False, utf8=True) if re.search(r"(File doesn't exist)", self.html) is not None: self.offline() self.parseInfos() pyfile.name = self.data["name"] # self.pyfile.name = self.get_file_name() self.premium = self.account.getAccountInfo(self.user) if self.account and self.premium: self.handlePremium() else: self.handleFree() def handlePremium(self): info = self.account.getAccountInfo(self.user, True) self.log.debug("%(name)s: Use Premium Account (%(left)sGB left)" % {"name" :self.__name__, "left" : info["trafficleft"]/1024/1024}) if self.data["size"]/1024 > info["trafficleft"]: self.log.info(_("%s: Not enough traffic left" % self.__name__)) self.account.empty() self.resetAccount() self.fail(_("Traffic exceeded")) try: html = self.load(self.pyfile.url, utf8=True) except error, e: if e.args and e.args[0] == 23: self.download(self.pyfile.url) else: url = re.search(r'action="(http://.*\.uploaded.to/dl\?id=[^"]+)', html) url = url.group(1) self.download(url) def handleFree(self): wait = re.search(r"Current waiting period: (\d+) seconds", self.html).group(1) self.setWait(wait) js = self.load("http://uploaded.to/js/download.js") challengeId = re.search(r'Recaptcha\.create\("([^"]+)', js) url = "http://uploaded.to/io/ticket/captcha/%s" % self.fileID downloadURL = "" for i in range(5): self.req.lastURL = str(self.url) re_captcha = ReCaptcha(self) challenge, result = re_captcha.challenge(challengeId.group(1)) options = {"recaptcha_challenge_field" : challenge, "recaptcha_response_field": result} self.wait() result = self.load(url, post=options) self.log.debug("UploadedTo result: %s" % result) if "limit-dl" in result: self.setWait(30 * 60, True) self.wait() self.retry() elif 'err:"captcha"' in result: self.invalidCaptcha() elif "type:'download'" in result: downloadURL = re.search("url:'([^']+)", result).group(1) break if not downloadURL: self.fail("No Download url retrieved") self.download(downloadURL) def parseInfos(self): match = re.search(r'id="filename">([^<]+)
([^<]+)', self.html) self.data = {"name" : match.group(1), "size": parseFileSize(match.group(2))} def cleanUrl(self, url): url = url.replace("ul.to/", "uploaded.to/file/") url = url.replace("/?id=", "/file/") url = url.replace("?id=", "file/") url = re.sub("/\?(.*?)&id=", "/file/", url, 1) return url