module -> pyload

3 files changed, 467 insertions, 0 deletions

diff --git a/pyload/remote/socketbackend/__init__.py b/pyload/remote/socketbackend/__init__.py
new file mode 100644
index 000000000..e69de29bb
--- /dev/null
+++ b/pyload/remote/socketbackend/__init__.py
diff --git a/pyload/remote/socketbackend/create_ttypes.py b/pyload/remote/socketbackend/create_ttypes.py
new file mode 100644
index 000000000..64398c3e7
--- /dev/null
+++ b/pyload/remote/socketbackend/create_ttypes.py
@@ -0,0 +1,86 @@
+# -*- coding: utf-8 -*-
+
+import inspect
+import sys
+from os.path import abspath, dirname, join
+
+path = dirname(abspath(__file__))
+module = join(path, "..", "..")
+
+sys.path.append(join(module, "lib"))
+sys.path.append(join(module, "remote"))
+
+from thriftbackend.thriftgen.pyload import ttypes
+from thriftbackend.thriftgen.pyload.Pyload import Iface
+
+
+def main():
+
+    enums = []
+    classes = []
+
+    print "generating lightweight ttypes.py"
+
+    for name in dir(ttypes):
+        klass = getattr(ttypes, name)
+
+        if name in ("TBase", "TExceptionBase") or name.startswith("_") or not (issubclass(klass, ttypes.TBase) or issubclass(klass, ttypes.TExceptionBase)):
+            continue
+
+        if hasattr(klass, "thrift_spec"):
+           classes.append(klass)
+        else:
+            enums.append(klass)
+
+
+    f = open(join(path, "ttypes.py"), "wb")
+
+    f.write(
+        """# -*- coding: utf-8 -*-
+# Autogenerated by pyload
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+
+class BaseObject(object):
+\t__slots__ = []
+
+""")
+
+    ## generate enums
+    for enum in enums:
+        name = enum.__name__
+        f.write("class %s:\n" % name)
+
+        for attr in dir(enum):
+            if attr.startswith("_") or attr in ("read", "write"): continue
+
+            f.write("\t%s = %s\n" % (attr, getattr(enum, attr)))
+
+        f.write("\n")
+
+    for klass in classes:
+        name = klass.__name__
+        base = "Exception" if issubclass(klass, ttypes.TExceptionBase) else "BaseObject"
+        f.write("class %s(%s):\n" % (name,  base))
+        f.write("\t__slots__ = %s\n\n" % klass.__slots__)
+
+        #create init
+        args = ["self"] + ["%s=None" % x for x in klass.__slots__]
+
+        f.write("\tdef __init__(%s):\n" % ", ".join(args))
+        for attr in klass.__slots__:
+            f.write("\t\tself.%s = %s\n" % (attr, attr))
+
+        f.write("\n")
+
+    f.write("class Iface:\n")
+
+    for name in dir(Iface):
+        if name.startswith("_"): continue
+
+        func = inspect.getargspec(getattr(Iface, name))
+
+        f.write("\tdef %s(%s):\n\t\tpass\n" % (name, ", ".join(func.args)))
+
+    f.write("\n")
+
+    f.close()
diff --git a/pyload/remote/socketbackend/ttypes.py b/pyload/remote/socketbackend/ttypes.py
new file mode 100644
index 000000000..3fd02fac8
--- /dev/null
+++ b/pyload/remote/socketbackend/ttypes.py
@@ -0,0 +1,381 @@
+# -*- coding: utf-8 -*-
+# Autogenerated by pyload
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+
+class BaseObject(object):
+	__slots__ = []
+
+class Destination:
+	Collector = 0
+	Queue = 1
+
+class DownloadStatus:
+	Aborted = 9
+	Custom = 11
+	Decrypting = 10
+	Downloading = 12
+	Failed = 8
+	Finished = 0
+	Offline = 1
+	Online = 2
+	Processing = 13
+	Queued = 3
+	Skipped = 4
+	Starting = 7
+	TempOffline = 6
+	Unknown = 14
+	Waiting = 5
+
+class ElementType:
+	File = 1
+	Package = 0
+
+class Input:
+	BOOL = 4
+	CHOICE = 6
+	CLICK = 5
+	LIST = 8
+	MULTIPLE = 7
+	NONE = 0
+	PASSWORD = 3
+	TABLE = 9
+	TEXT = 1
+	TEXTBOX = 2
+
+class Output:
+	CAPTCHA = 1
+	NOTIFICATION = 4
+	QUESTION = 2
+
+class AccountInfo(BaseObject):
+	__slots__ = ['validuntil', 'login', 'options', 'valid', 'trafficleft', 'maxtraffic', 'premium', 'type']
+
+	def __init__(self, validuntil=None, login=None, options=None, valid=None, trafficleft=None, maxtraffic=None, premium=None, type=None):
+		self.validuntil = validuntil
+		self.login = login
+		self.options = options
+		self.valid = valid
+		self.trafficleft = trafficleft
+		self.maxtraffic = maxtraffic
+		self.premium = premium
+		self.type = type
+
+class CaptchaTask(BaseObject):
+	__slots__ = ['tid', 'data', 'type', 'resultType']
+
+	def __init__(self, tid=None, data=None, type=None, resultType=None):
+		self.tid = tid
+		self.data = data
+		self.type = type
+		self.resultType = resultType
+
+class ConfigItem(BaseObject):
+	__slots__ = ['name', 'description', 'value', 'type']
+
+	def __init__(self, name=None, description=None, value=None, type=None):
+		self.name = name
+		self.description = description
+		self.value = value
+		self.type = type
+
+class ConfigSection(BaseObject):
+	__slots__ = ['name', 'description', 'items', 'outline']
+
+	def __init__(self, name=None, description=None, items=None, outline=None):
+		self.name = name
+		self.description = description
+		self.items = items
+		self.outline = outline
+
+class DownloadInfo(BaseObject):
+	__slots__ = ['fid', 'name', 'speed', 'eta', 'format_eta', 'bleft', 'size', 'format_size', 'percent', 'status', 'statusmsg', 'format_wait', 'wait_until', 'packageID', 'packageName', 'plugin']
+
+	def __init__(self, fid=None, name=None, speed=None, eta=None, format_eta=None, bleft=None, size=None, format_size=None, percent=None, status=None, statusmsg=None, format_wait=None, wait_until=None, packageID=None, packageName=None, plugin=None):
+		self.fid = fid
+		self.name = name
+		self.speed = speed
+		self.eta = eta
+		self.format_eta = format_eta
+		self.bleft = bleft
+		self.size = size
+		self.format_size = format_size
+		self.percent = percent
+		self.status = status
+		self.statusmsg = statusmsg
+		self.format_wait = format_wait
+		self.wait_until = wait_until
+		self.packageID = packageID
+		self.packageName = packageName
+		self.plugin = plugin
+
+class EventInfo(BaseObject):
+	__slots__ = ['eventname', 'id', 'type', 'destination']
+
+	def __init__(self, eventname=None, id=None, type=None, destination=None):
+		self.eventname = eventname
+		self.id = id
+		self.type = type
+		self.destination = destination
+
+class FileData(BaseObject):
+	__slots__ = ['fid', 'url', 'name', 'plugin', 'size', 'format_size', 'status', 'statusmsg', 'packageID', 'error', 'order']
+
+	def __init__(self, fid=None, url=None, name=None, plugin=None, size=None, format_size=None, status=None, statusmsg=None, packageID=None, error=None, order=None):
+		self.fid = fid
+		self.url = url
+		self.name = name
+		self.plugin = plugin
+		self.size = size
+		self.format_size = format_size
+		self.status = status
+		self.statusmsg = statusmsg
+		self.packageID = packageID
+		self.error = error
+		self.order = order
+
+class FileDoesNotExists(Exception):
+	__slots__ = ['fid']
+
+	def __init__(self, fid=None):
+		self.fid = fid
+
+class InteractionTask(BaseObject):
+	__slots__ = ['iid', 'input', 'structure', 'preset', 'output', 'data', 'title', 'description', 'plugin']
+
+	def __init__(self, iid=None, input=None, structure=None, preset=None, output=None, data=None, title=None, description=None, plugin=None):
+		self.iid = iid
+		self.input = input
+		self.structure = structure
+		self.preset = preset
+		self.output = output
+		self.data = data
+		self.title = title
+		self.description = description
+		self.plugin = plugin
+
+class OnlineCheck(BaseObject):
+	__slots__ = ['rid', 'data']
+
+	def __init__(self, rid=None, data=None):
+		self.rid = rid
+		self.data = data
+
+class OnlineStatus(BaseObject):
+	__slots__ = ['name', 'plugin', 'packagename', 'status', 'size']
+
+	def __init__(self, name=None, plugin=None, packagename=None, status=None, size=None):
+		self.name = name
+		self.plugin = plugin
+		self.packagename = packagename
+		self.status = status
+		self.size = size
+
+class PackageData(BaseObject):
+	__slots__ = ['pid', 'name', 'folder', 'site', 'password', 'dest', 'order', 'linksdone', 'sizedone', 'sizetotal', 'linkstotal', 'links', 'fids']
+
+	def __init__(self, pid=None, name=None, folder=None, site=None, password=None, dest=None, order=None, linksdone=None, sizedone=None, sizetotal=None, linkstotal=None, links=None, fids=None):
+		self.pid = pid
+		self.name = name
+		self.folder = folder
+		self.site = site
+		self.password = password
+		self.dest = dest
+		self.order = order
+		self.linksdone = linksdone
+		self.sizedone = sizedone
+		self.sizetotal = sizetotal
+		self.linkstotal = linkstotal
+		self.links = links
+		self.fids = fids
+
+class PackageDoesNotExists(Exception):
+	__slots__ = ['pid']
+
+	def __init__(self, pid=None):
+		self.pid = pid
+
+class ServerStatus(BaseObject):
+	__slots__ = ['pause', 'active', 'queue', 'total', 'speed', 'download', 'reconnect']
+
+	def __init__(self, pause=None, active=None, queue=None, total=None, speed=None, download=None, reconnect=None):
+		self.pause = pause
+		self.active = active
+		self.queue = queue
+		self.total = total
+		self.speed = speed
+		self.download = download
+		self.reconnect = reconnect
+
+class ServiceCall(BaseObject):
+	__slots__ = ['plugin', 'func', 'arguments', 'parseArguments']
+
+	def __init__(self, plugin=None, func=None, arguments=None, parseArguments=None):
+		self.plugin = plugin
+		self.func = func
+		self.arguments = arguments
+		self.parseArguments = parseArguments
+
+class ServiceDoesNotExists(Exception):
+	__slots__ = ['plugin', 'func']
+
+	def __init__(self, plugin=None, func=None):
+		self.plugin = plugin
+		self.func = func
+
+class ServiceException(Exception):
+	__slots__ = ['msg']
+
+	def __init__(self, msg=None):
+		self.msg = msg
+
+class UserData(BaseObject):
+	__slots__ = ['name', 'email', 'role', 'permission', 'templateName']
+
+	def __init__(self, name=None, email=None, role=None, permission=None, templateName=None):
+		self.name = name
+		self.email = email
+		self.role = role
+		self.permission = permission
+		self.templateName = templateName
+
+class Iface:
+	def addFiles(self, pid, links):
+		pass
+	def addPackage(self, name, links, dest):
+		pass
+	def call(self, info):
+		pass
+	def checkOnlineStatus(self, urls):
+		pass
+	def checkOnlineStatusContainer(self, urls, filename, data):
+		pass
+	def checkURLs(self, urls):
+		pass
+	def deleteFiles(self, fids):
+		pass
+	def deleteFinished(self):
+		pass
+	def deletePackages(self, pids):
+		pass
+	def freeSpace(self):
+		pass
+	def generateAndAddPackages(self, links, dest):
+		pass
+	def generatePackages(self, links):
+		pass
+	def getAccountTypes(self):
+		pass
+	def getAccounts(self, refresh):
+		pass
+	def getAllInfo(self):
+		pass
+	def getAllUserData(self):
+		pass
+	def getCaptchaTask(self, exclusive):
+		pass
+	def getCaptchaTaskStatus(self, tid):
+		pass
+	def getCollector(self):
+		pass
+	def getCollectorData(self):
+		pass
+	def getConfig(self):
+		pass
+	def getConfigValue(self, category, option, section):
+		pass
+	def getEvents(self, uuid):
+		pass
+	def getFileData(self, fid):
+		pass
+	def getFileOrder(self, pid):
+		pass
+	def getInfoByPlugin(self, plugin):
+		pass
+	def getLog(self, offset):
+		pass
+	def getPackageData(self, pid):
+		pass
+	def getPackageInfo(self, pid):
+		pass
+	def getPackageOrder(self, destination):
+		pass
+	def getPluginConfig(self):
+		pass
+	def getQueue(self):
+		pass
+	def getQueueData(self):
+		pass
+	def getServerVersion(self):
+		pass
+	def getServices(self):
+		pass
+	def getUserData(self, username, password):
+		pass
+	def hasService(self, plugin, func):
+		pass
+	def isCaptchaWaiting(self):
+		pass
+	def isTimeDownload(self):
+		pass
+	def isTimeReconnect(self):
+		pass
+	def kill(self):
+		pass
+	def login(self, username, password):
+		pass
+	def moveFiles(self, fids, pid):
+		pass
+	def movePackage(self, destination, pid):
+		pass
+	def orderFile(self, fid, position):
+		pass
+	def orderPackage(self, pid, position):
+		pass
+	def parseURLs(self, html, url):
+		pass
+	def pauseServer(self):
+		pass
+	def pollResults(self, rid):
+		pass
+	def pullFromQueue(self, pid):
+		pass
+	def pushToQueue(self, pid):
+		pass
+	def recheckPackage(self, pid):
+		pass
+	def removeAccount(self, plugin, account):
+		pass
+	def restart(self):
+		pass
+	def restartFailed(self):
+		pass
+	def restartFile(self, fid):
+		pass
+	def restartPackage(self, pid):
+		pass
+	def setCaptchaResult(self, tid, result):
+		pass
+	def setConfigValue(self, category, option, value, section):
+		pass
+	def setPackageData(self, pid, data):
+		pass
+	def setPackageName(self, pid, name):
+		pass
+	def statusDownloads(self):
+		pass
+	def statusServer(self):
+		pass
+	def stopAllDownloads(self):
+		pass
+	def stopDownloads(self, fids):
+		pass
+	def togglePause(self):
+		pass
+	def toggleReconnect(self):
+		pass
+	def unpauseServer(self):
+		pass
+	def updateAccount(self, plugin, account, password, options):
+		pass
+	def uploadContainer(self, filename, data):
+		pass