summaryrefslogtreecommitdiffstats
path: root/module/plugins/container
diff options
context:
space:
mode:
Diffstat (limited to 'module/plugins/container')
-rw-r--r--module/plugins/container/CCF.py40
-rw-r--r--module/plugins/container/DLC.py72
-rw-r--r--module/plugins/container/LinkList.py52
-rw-r--r--module/plugins/container/RSDF.py54
4 files changed, 145 insertions, 73 deletions
diff --git a/module/plugins/container/CCF.py b/module/plugins/container/CCF.py
index a27511358..452b9bb65 100644
--- a/module/plugins/container/CCF.py
+++ b/module/plugins/container/CCF.py
@@ -4,40 +4,46 @@ from __future__ import with_statement
import re
-from os import makedirs
-from os.path import exists
from urllib2 import build_opener
from MultipartPostHandler import MultipartPostHandler
-from pyload.plugin.Container import Container
-from pyload.utils import safe_join
+from module.plugins.Container import Container
+from module.utils import fs_encode, save_join
class CCF(Container):
__name__ = "CCF"
- __version__ = "0.20"
+ __type__ = "container"
+ __version__ = "0.23"
- __pattern__ = r'.+\.ccf'
+ __pattern__ = r'.+\.ccf$'
__description__ = """CCF container decrypter plugin"""
__license__ = "GPLv3"
- __authors__ = [("Willnix", "Willnix@pyload.org")]
+ __authors__ = [("Willnix", "Willnix@pyload.org"),
+ ("Walter Purcaro", "vuolter@gmail.com")]
def decrypt(self, pyfile):
- infile = pyfile.url.replace("\n", "")
-
+ file = fs_encode(pyfile.url.strip())
opener = build_opener(MultipartPostHandler)
- params = {"src": "ccf",
- "filename": "test.ccf",
- "upload": open(infile, "rb")}
- tempdlc_content = opener.open('http://service.jdownloader.net/dlcrypt/getDLC.php', params).read()
+
+ dlc_content = opener.open('http://service.jdownloader.net/dlcrypt/getDLC.php',
+ {'src' : "ccf",
+ 'filename': "test.ccf",
+ 'upload' : open(file, "rb")}).read()
download_folder = self.config['general']['download_folder']
+ dlc_file = save_join(download_folder, "tmp_%s.dlc" % pyfile.name)
+
+ try:
+ dlc = re.search(r'<dlc>(.+)</dlc>', dlc_content, re.S).group(1).decode('base64')
+
+ except AttributeError:
+ self.fail(_("Container is corrupted"))
- tempdlc_name = safe_join(download_folder, "tmp_%s.dlc" % pyfile.name)
- with open(tempdlc_name, "w") as tempdlc:
- tempdlc.write(re.search(r'<dlc>(.*)</dlc>', tempdlc_content, re.S).group(1))
+ with open(dlc_file, "w") as tempdlc:
+ tempdlc.write(dlc)
- self.urls = [tempdlc_name]
+ self.urls = [dlc_file]
diff --git a/module/plugins/container/DLC.py b/module/plugins/container/DLC.py
new file mode 100644
index 000000000..b01e3098c
--- /dev/null
+++ b/module/plugins/container/DLC.py
@@ -0,0 +1,72 @@
+# -*- coding: utf-8 -*-
+
+from __future__ import with_statement
+
+import re
+import xml.dom.minidom
+
+from Crypto.Cipher import AES
+
+from module.plugins.Container import Container
+from module.utils import decode, fs_encode
+
+
+class DLC(Container):
+ __name__ = "DLC"
+ __type__ = "container"
+ __version__ = "0.24"
+
+ __pattern__ = r'.+\.dlc$'
+
+ __description__ = """DLC container decrypter plugin"""
+ __license__ = "GPLv3"
+ __authors__ = [("RaNaN", "RaNaN@pyload.org"),
+ ("spoob", "spoob@pyload.org"),
+ ("mkaay", "mkaay@mkaay.de"),
+ ("Schnusch", "Schnusch@users.noreply.github.com"),
+ ("Walter Purcaro", "vuolter@gmail.com")]
+
+
+ KEY = "cb99b5cbc24db398"
+ IV = "9bc24cb995cb8db3"
+ API_URL = "http://service.jdownloader.org/dlcrypt/service.php?srcType=dlc&destType=pylo&data=%s"
+
+
+ def decrypt(self, pyfile):
+ file = fs_encode(pyfile.url.strip())
+ with open(file) as dlc:
+ data = dlc.read().strip()
+
+ data += '=' * (-len(data) % 4)
+
+ dlc_key = data[-88:]
+ dlc_data = data[:-88].decode('base64')
+ dlc_content = self.load(self.API_URL % dlc_key)
+
+ try:
+ rc = re.search(r'<rc>(.+)</rc>', dlc_content, re.S).group(1).decode('base64')
+
+ except AttributeError:
+ self.fail(_("Container is corrupted"))
+
+ cipher = AES.new(self.KEY, AES.MODE_CBC, self.IV).decrypt(rc)
+
+ self.data = AES.new(cipher, AES.MODE_CBC, cipher).decrypt(dlc_data).decode('base64')
+ self.packages = [(entry[0] if entry[0] else pyfile.name, entry[1], entry[0] if entry[0] else pyfile.name) \
+ for entry in self.getPackages()]
+
+
+ def getPackages(self):
+ root = xml.dom.minidom.parseString(self.data).documentElement
+ content = root.getElementsByTagName("content")[0]
+ return self.parsePackages(content)
+
+
+ def parsePackages(self, startNode):
+ return [(decode(node.getAttribute("name")).decode('base64'), self.parseLinks(node)) \
+ for node in startNode.getElementsByTagName("package")]
+
+
+ def parseLinks(self, startNode):
+ return [node.getElementsByTagName("url")[0].firstChild.data.decode('base64') \
+ for node in startNode.getElementsByTagName("file")]
diff --git a/module/plugins/container/LinkList.py b/module/plugins/container/LinkList.py
index 305da8a38..ccb9b2fa3 100644
--- a/module/plugins/container/LinkList.py
+++ b/module/plugins/container/LinkList.py
@@ -2,17 +2,18 @@
import codecs
-from pyload.plugin.Container import Container
-from pyload.utils import fs_encode
+from module.plugins.Container import Container
+from module.utils import fs_encode
class LinkList(Container):
__name__ = "LinkList"
- __version__ = "0.12"
+ __type__ = "container"
+ __version__ = "0.14"
- __pattern__ = r'.+\.txt'
- __config__ = [("clear", "bool", "Clear Linklist after adding", False),
- ("encoding", "string", "File encoding (default utf-8)", "")]
+ __pattern__ = r'.+\.txt$'
+ __config__ = [("flush" , "bool" , "Flush list after adding", False ),
+ ("encoding", "string", "File encoding" , "utf-8")]
__description__ = """Read link lists in txt format"""
__license__ = "GPLv3"
@@ -22,50 +23,47 @@ class LinkList(Container):
def decrypt(self, pyfile):
try:
- file_enc = codecs.lookup(self.getConfig("encoding")).name
- except Exception:
- file_enc = "utf-8"
-
- file_name = fs_encode(pyfile.url)
+ encoding = codecs.lookup(self.getConfig("encoding")).name
- txt = codecs.open(file_name, 'r', file_enc)
- links = txt.readlines()
- curPack = "Parsed links from %s" % pyfile.name
+ except Exception:
+ encoding = "utf-8"
+ file = fs_encode(pyfile.url.strip())
+ txt = codecs.open(file, 'r', encoding)
+ curPack = "Parsed links from %s" % pyfile.name
packages = {curPack:[],}
- for link in links:
+ for link in txt.readlines():
link = link.strip()
+
if not link:
continue
if link.startswith(";"):
continue
+
if link.startswith("[") and link.endswith("]"):
# new package
curPack = link[1:-1]
packages[curPack] = []
continue
+
packages[curPack].append(link)
+
txt.close()
# empty packages fix
-
- delete = []
-
- for key,value in packages.iteritems():
+ for key, value in packages.iteritems():
if not value:
- delete.append(key)
+ packages.pop(key, None)
- for key in delete:
- del packages[key]
-
- if self.getConfig("clear"):
+ if self.getConfig("flush"):
try:
- txt = open(file_name, 'wb')
+ txt = open(file, 'wb')
txt.close()
- except Exception:
- self.logWarning(_("LinkList could not be cleared"))
+
+ except IOError:
+ self.logWarning(_("Failed to flush list"))
for name, links in packages.iteritems():
self.packages.append((name, links, name))
diff --git a/module/plugins/container/RSDF.py b/module/plugins/container/RSDF.py
index 17f304f50..8f9bfc0d5 100644
--- a/module/plugins/container/RSDF.py
+++ b/module/plugins/container/RSDF.py
@@ -2,55 +2,51 @@
from __future__ import with_statement
-import base64
import binascii
import re
-from pyload.plugin.Container import Container
-from pyload.utils import fs_encode
+from Crypto.Cipher import AES
+
+from module.plugins.Container import Container
+from module.utils import fs_encode
class RSDF(Container):
__name__ = "RSDF"
- __version__ = "0.24"
+ __type__ = "container"
+ __version__ = "0.27"
- __pattern__ = r'.+\.rsdf'
+ __pattern__ = r'.+\.rsdf$'
__description__ = """RSDF container decrypter plugin"""
__license__ = "GPLv3"
__authors__ = [("RaNaN", "RaNaN@pyload.org"),
- ("spoob", "spoob@pyload.org")]
-
+ ("spoob", "spoob@pyload.org"),
+ ("Walter Purcaro", "vuolter@gmail.com")]
- def decrypt(self, pyfile):
- from Crypto.Cipher import AES
+ KEY = "8C35192D964DC3182C6F84F3252239EB4A320D2500000000"
+ IV = "FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF"
- infile = fs_encode(pyfile.url.replace("\n", ""))
- Key = binascii.unhexlify('8C35192D964DC3182C6F84F3252239EB4A320D2500000000')
- IV = binascii.unhexlify('FFFFFFFFFFFFFFFFFFFFFFFFFFFFFFFF')
- IV_Cipher = AES.new(Key, AES.MODE_ECB)
- IV = IV_Cipher.encrypt(IV)
+ def decrypt(self, pyfile):
+ KEY = binascii.unhexlify(self.KEY)
+ IV = AES.new(Key, AES.MODE_ECB).encrypt(binascii.unhexlify(self.IV))
- obj = AES.new(Key, AES.MODE_CFB, IV)
+ cipher = AES.new(KEY, AES.MODE_CFB, IV)
try:
- with open(infile, 'r') as rsdf:
+ file = fs_encode(pyfile.url.strip())
+ with open(file, 'r') as rsdf:
data = rsdf.read()
- except IOError, e:
- self.fail(str(e))
- if re.search(r"<title>404 - Not Found</title>", data) is None:
- data = binascii.unhexlify(''.join(data.split()))
- data = data.splitlines()
+ except IOError, e:
+ self.fail(e)
- for link in data:
- if not link:
- continue
- link = base64.b64decode(link)
- link = obj.decrypt(link)
- decryptedUrl = link.replace('CCF: ', '')
- self.urls.append(decryptedUrl)
+ if re.search(r"<title>404 - Not Found</title>", data):
+ return
- self.logDebug("Adding package %s with %d links" % (pyfile.package().name, len(self.urls)))
+ for link in binascii.unhexlify(''.join(data.split())).splitlines():
+ if link:
+ link = cipher.decrypt(link.decode('base64')).replace('CCF: ', '')
+ self.urls.append(link)
generated by cgit v1.2.3 (git 2.25.1) at 2025-05-28 17:18:51 +0200