)?((?:[\w\s]*(?:[Ee]rror|ERROR)\s*\:?)?\s*\d{3})(?:\Z|\s+)'), ('Request error', r'([Aa]n error occured while processing your request)' ), ('Html file' , r'\A\s*', " ", errmsg) self.log_warning(self.info['error']) if re.search('da(il)?y|today', errmsg, re.I): wait_time = seconds_to_midnight(gmt=2) else: wait_time = sum(int(v) * {'hr': 3600, 'hour': 3600, 'min': 60, 'sec': 1, "": 1}[u.lower()] for v, u in re.findall(r'(\d+)\s*(hr|hour|min|sec|)', errmsg, re.I)) self.want_reconnect = wait_time > 300 self.retry(1, wait_time, _("Download limit exceeded")) if hasattr(self, 'HAPPY_HOUR_PATTERN') and re.search(self.HAPPY_HOUR_PATTERN, self.html): self.multi_dl = True if hasattr(self, 'ERROR_PATTERN'): m = re.search(self.ERROR_PATTERN, self.html) if m: try: errmsg = m.group(1).strip() except Exception: errmsg = m.group(0).strip() self.info['error'] = re.sub(r'<.*?>', " ", errmsg) self.log_warning(self.info['error']) if re.search('limit|wait|slot', errmsg, re.I): if re.search("da(il)?y|today", errmsg): wait_time = seconds_to_midnight(gmt=2) else: wait_time = sum(int(v) * {'hr': 3600, 'hour': 3600, 'min': 60, 'sec': 1, "": 1}[u.lower()] for v, u in re.findall(r'(\d+)\s*(hr|hour|min|sec|)', errmsg, re.I)) self.want_reconnect = wait_time > 300 self.retry(1, wait_time, _("Download limit exceeded")) elif re.search('country|ip|region|nation', errmsg, re.I): self.fail(_("Connection from your current IP address is not allowed")) elif re.search('captcha|code', errmsg, re.I): self.invalid_captcha() self.retry(10, reason=_("Wrong captcha")) elif re.search('countdown|expired', errmsg, re.I): self.retry(10, 60, _("Link expired")) elif re.search('maintenance|maintainance|temp', errmsg, re.I): self.temp_offline() elif re.search('up to|size', errmsg, re.I): self.fail(_("File too large for free download")) elif re.search('offline|delet|remov|not? (found|(longer)? available)', errmsg, re.I): self.offline() elif re.search('filename', errmsg, re.I): url_p = urlparse.urlparse(self.pyfile.url) self.pyfile.url = "%s://%s/%s" % (url_p.scheme, url_p.netloc, url_p.path.strip('/').split('/')[0]) self.retry(1, reason=_("Wrong url")) elif re.search('premium', errmsg, re.I): self.fail(_("File can be downloaded by premium users only")) else: self.want_reconnect = True self.retry(wait_time=60, reason=errmsg) elif hasattr(self, 'WAIT_PATTERN'): m = re.search(self.WAIT_PATTERN, self.html) if m: try: waitmsg = m.group(1).strip() except Exception: waitmsg = m.group(0).strip() wait_time = sum(int(v) * {'hr': 3600, 'hour': 3600, 'min': 60, 'sec': 1, "": 1}[u.lower()] for v, u in re.findall(r'(\d+)\s*(hr|hour|min|sec|)', waitmsg, re.I)) self.wait(wait_time, wait_time > 300) self.info.pop('error', None) def check_status(self, getinfo=True): if not self.info or getinfo: self.log_debug("Update file info...") self.log_debug("Previous file info: %s" % self.info) self.info.update(self.get_info(self.pyfile.url, self.html)) self.log_debug("Current file info: %s" % self.info) try: status = self.info['status'] if status is 1: self.offline() elif status is 6: self.temp_offline() elif status is 8: self.fail(self.info['error'] if 'error' in self.info else _("Failed")) finally: self.log_debug("File status: %s" % statusMap[status]) def check_name_size(self, getinfo=True): if not self.info or getinfo: self.log_debug("Update file info...") self.log_debug("Previous file info: %s" % self.info) self.info.update(self.get_info(self.pyfile.url, self.html)) self.log_debug("Current file info: %s" % self.info) try: url = self.info['url'].strip() name = self.info['name'].strip() if name and name != url: self.pyfile.name = name except Exception: pass try: size = self.info['size'] if size > 0: self.pyfile.size = size except Exception: pass self.log_debug("File name: %s" % self.pyfile.name, "File size: %s byte" % self.pyfile.size if self.pyfile.size > 0 else "File size: Unknown") def check_info(self): self.check_name_size() if self.html: self.check_errors() self.check_name_size() self.check_status(getinfo=False) #: Deprecated method def get_fileInfo(self): self.info = {} self.check_info() return self.info def handle_direct(self, pyfile): link = self.direct_link(pyfile.url, self.resume_download) if link: self.log_info(_("Direct download link detected")) self.link = link else: self.log_debug("Direct download link not found") def handle_multi(self, pyfile): #: Multi-hoster handler pass def handle_free(self, pyfile): if not hasattr(self, 'LINK_FREE_PATTERN'): self.log_error(_("Free download not implemented")) m = re.search(self.LINK_FREE_PATTERN, self.html) if m is None: self.error(_("Free download link not found")) else: self.link = m.group(1) def handle_premium(self, pyfile): if not hasattr(self, 'LINK_PREMIUM_PATTERN'): self.log_error(_("Premium download not implemented")) self.log_debug("Handled as free download") self.handle_free(pyfile) m = re.search(self.LINK_PREMIUM_PATTERN, self.html) if m is None: self.error(_("Premium download link not found")) else: self.link = m.group(1) def retry_free(self): if not self.premium: return self.premium = False self.account = None self.req = self.pyload.requestFactory.getRequest(self.__name__) raise Retry(_("Fallback to free download"))