diff options
Diffstat (limited to 'pyload/remote/socketbackend')
| -rw-r--r-- | pyload/remote/socketbackend/__init__.py | 0 | ||||
| -rw-r--r-- | pyload/remote/socketbackend/create_ttypes.py | 86 | ||||
| -rw-r--r-- | pyload/remote/socketbackend/ttypes.py | 381 | 
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 | 
