x7.to plugin, by ernieb

3 files changed, 224 insertions, 3 deletions

diff --git a/module/plugins/Account.py b/module/plugins/Account.py
index 557689fe9..732133d3a 100644
--- a/module/plugins/Account.py
+++ b/module/plugins/Account.py
@@ -35,9 +35,9 @@ class Account():
     __author_name__ = ("mkaay")
     __author_mail__ = ("mkaay@mkaay.de")
 
-    # after that time [in minutes] pyload will relogin the account
+    #: after that time [in minutes] pyload will relogin the account
     login_timeout = 600
-    # account data will be reloaded after this time
+    #: account data will be reloaded after this time
     info_threshold = 600
 
 
@@ -54,6 +54,12 @@ class Account():
         pass
 
     def login(self, user, data, req):
+        """login into account, the cookies will be saved so user can be recognized
+
+        :param user: loginname
+        :param data: data dictionary
+        :param req: `Request` instance
+        """
         pass
 
     def _login(self, user, data):
@@ -120,7 +126,13 @@ class Account():
             del self.timestamps[user]
 
     def getAccountInfo(self, name, force=False):
-        """ return dict with infos, do not overwrite this method! """
+        """retrieve account infos for an user, do **not** overwrite this method!\\
+        just use it to retrieve infos in hoster plugins. see `loadAccountInfo`
+
+        :param name: username
+        :param force: reloads cached account information
+        :return: dictionary with information
+        """
         data = Account.loadAccountInfo(self, name)
 
         if force or not self.infos.has_key(name):
@@ -152,6 +164,13 @@ class Account():
         return info["premium"]
 
     def loadAccountInfo(self, name, req=None):
+        """this should be overwritten in account plugin,\
+        and retrieving account information for user
+
+        :param name:
+        :param req: `Request` instance
+        :return:
+        """
         return {
             "validuntil": None, # -1 for unlimited
             "login": name,
diff --git a/module/plugins/accounts/X7To.py b/module/plugins/accounts/X7To.py
new file mode 100644
index 000000000..1e3ef782e
--- /dev/null
+++ b/module/plugins/accounts/X7To.py
@@ -0,0 +1,58 @@
+# -*- coding: utf-8 -*-

+

+"""

+    This program is free software; you can redistribute it and/or modify

+    it under the terms of the GNU General Public License as published by

+    the Free Software Foundation; either version 3 of the License,

+    or (at your option) any later version.

+

+    This program is distributed in the hope that it will be useful,

+    but WITHOUT ANY WARRANTY; without even the implied warranty of

+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

+    See the GNU General Public License for more details.

+

+    You should have received a copy of the GNU General Public License

+    along with this program; if not, see <http://www.gnu.org/licenses/>.

+

+    @author: ernieb

+"""

+

+import re

+from time import strptime, mktime

+

+from module.plugins.Account import Account

+

+class X7To(Account):

+    __name__ = "X7To"

+    __version__ = "0.1"

+    __type__ = "account"

+    __description__ = """X7.To account plugin"""

+    __author_name__ = ("ernieb")

+    __author_mail__ = ("ernieb")

+

+    def loadAccountInfo(self, user, req):

+        page = req.load("http://www.x7.to/my")

+

+        valid = re.search("Premium-Mitglied bis ([0-9]*-[0-9]*-[0-9]*)", page, re.IGNORECASE).group(1)

+        valid = int(mktime(strptime(valid, "%Y-%m-%d")))

+

+        trafficleft = re.search('<em style="white-space:nowrap">([\d]*)[,]?[\d]?[\d]? (KB|MB|GB)</em>', page,

+                                re.IGNORECASE)

+        if trafficleft:

+            units = float(trafficleft.group(1))

+            pow = {'KB': 0, 'MB': 1, 'GB': 2}[trafficleft.group(2)]

+            trafficleft = int(units * 1024 ** pow)

+        else:

+            trafficleft = -1

+

+        return {"trafficleft": trafficleft, "validuntil": valid}

+

+

+    def login(self, user, data, req):

+        #req.cj.setCookie("share.cx", "lang", "english")

+        page = req.load("http://x7.to/lang/en", None, {})

+        page = req.load("http://x7.to/james/login", None,

+                {"redirect": "http://www.x7.to/", "id": user, "pw": data['password'], "submit": "submit"})

+

+        if "Username and password are not matching." in page:

+            self.wrongPassword()
\ No newline at end of file
diff --git a/module/plugins/hoster/X7To.py b/module/plugins/hoster/X7To.py
new file mode 100644
index 000000000..39441d091
--- /dev/null
+++ b/module/plugins/hoster/X7To.py
@@ -0,0 +1,144 @@
+# -*- coding: utf-8 -*-

+from __future__ import with_statement

+

+import re

+

+from module.plugins.Hoster import Hoster

+

+from module.network.RequestFactory import getURL

+

+def getInfo(urls):

+    result = []

+

+    for url in urls:

+        #print "X7To: getinfo for "+url

+        # Get html

+        html = getURL(url)

+

+        if re.search(r"var page = '404';", html):

+            #print "x7html: 404"

+            result.append((url, 0, 1, url))

+            continue

+

+        # Name

+        fileInfo = re.search('<meta name="description" content="Download: (.*) ([0-9,.]*) (KB|MB|GB) at ', html)

+        if fileInfo:

+            name = fileInfo.group(1)

+            #print "X7To: filename "+name

+            # Size

+            units = float(fileInfo.group(1).replace(",", "."))

+            pow = {'KB': 1, 'MB': 2, 'GB': 3}[fileInfo.group(2)]

+            size = int(units * 1024 ** pow)

+        else:

+            # fallback: name could not be extracted.. most likely change on x7.to side ... needs to be checked then

+            #print "X7To: file information not found"

+            name = url

+            size = 0

+

+        # Return info

+        result.append((name, size, 2, url))

+

+    yield result

+

+

+class X7To(Hoster):

+    __name__ = "X7To"

+    __type__ = "hoster"

+    __pattern__ = r"http://(?:www.)?x7.to/"

+    __version__ = "0.1"

+    __description__ = """X7.To File Download Hoster"""

+    __author_name__ = ("ernieb")

+    __author_mail__ = ("ernieb")

+

+    def setup(self):

+        if self.premium:

+            self.multiDL = False

+            self.resumeDownload = False

+            self.chunkLimit = 1

+        else:

+            self.multiDL = False

+

+        self.file_id = re.search(r"http://x7.to/([a-zA-Z0-9]+)", self.pyfile.url).group(1)

+        self.pyfile.url = "http://x7.to/" + self.file_id

+

+    def process(self, pyfile):

+        self.html = self.load(self.pyfile.url, ref=False, decode=True)

+

+        if re.search(r"var page = '404';", self.html) is not None:

+            self.offline()

+

+        fileInfo = re.search(r'<meta name="description" content="Download: (.*) \(([0-9,.]*) (KB|MB|GB)\) at ',

+                             self.html, re.IGNORECASE)

+        size = 0

+        trafficLeft = 100000000000

+        if fileInfo:

+            self.pyfile.name = fileInfo.group(1)

+            if self.account:

+                trafficLeft = self.account.getAccountInfo(self.user)["trafficleft"]

+                # Size

+                units = float(fileInfo.group(2).replace(",", "."))

+                pow = {'KB': 1, 'MB': 2, 'GB': 3}[fileInfo.group(3)]

+                size = int(units * 1024 ** pow)

+                self.logDebug("filesize: %s    trafficleft: %s" % (size, trafficLeft))

+

+        else:

+            #self.log.debug( self.html )

+            self.logDebug("name and size not found")

+

+        if self.account and self.premium and trafficLeft > size:

+            self.handlePremium()

+        else:

+            self.handleFree()

+

+    def handlePremium(self):

+        # check if over limit first

+        overLimit = re.search(r'<a onClick="cUser.buyTraffic\(\)" id="DL">', self.html)

+        if overLimit:

+            self.logDebug("over limit")

+        else:

+            realurl = re.search(r'<a href="http://stor(\d*).x7.to/dl/([^"]*)" id="DL">', self.html)

+            if realurl:

+                realurl = 'http://stor' + realurl.group(1) + '.x7.to/dl/' + realurl.group(2)

+            else:

+                self.logDebug("premium link not found")

+            self.download(realurl)

+

+    def handleFree(self):

+        # find file id

+        file_id = re.search(r"var dlID = '([^']*)'", self.html)

+        if file_id:

+            file_url = "http://x7.to/james/ticket/dl/" + file_id.group(1)

+            #getDownloadXml = getURL(file_url)

+            self.html = self.load(file_url, ref=False, decode=True)

+

+            # find download limit in xml

+            haveToWait = re.search("limit-dl", self.html)

+            if haveToWait:

+                self.logDebug("Limit reached ... waiting")

+                self.setWait(900)

+                self.wait()

+                return True

+

+            # no waiting required, go to download

+            waitCheck = re.search(r"wait:(\d*),", self.html)

+            if waitCheck:

+                waitCheck = int(waitCheck.group(1))

+                self.setWait(waitCheck, True)

+                self.wait()

+

+            urlCheck = re.search(r"url:'(.*)',", self.html)

+            url = None

+            if urlCheck:

+                url = urlCheck.group(1)

+                self.logDebug("url found " + url)

+

+            if url:

+                try:

+                    self.download(url)

+                except:

+                    self.logDebug("downloading url failed:" + url)

+

+

+            else:

+                #print self.html

+                self.fail("no download url found")
\ No newline at end of file