summaryrefslogtreecommitdiffstats
path: root/module/remote
diff options
context:
space:
mode:
Diffstat (limited to 'module/remote')
-rw-r--r--module/remote/JSONClient.py2
-rw-r--r--module/remote/WSClient.py2
-rw-r--r--module/remote/apitypes.py534
-rw-r--r--module/remote/apitypes_debug.py (renamed from module/remote/ttypes_debug.py)12
-rw-r--r--module/remote/create_apitypes.py (renamed from module/remote/create_ttypes.py)14
-rw-r--r--module/remote/create_jstypes.py34
-rw-r--r--module/remote/json_converter.py8
7 files changed, 595 insertions, 11 deletions
diff --git a/module/remote/JSONClient.py b/module/remote/JSONClient.py
index 469d40317..a2c07a132 100644
--- a/module/remote/JSONClient.py
+++ b/module/remote/JSONClient.py
@@ -5,7 +5,7 @@ from urllib import urlopen, urlencode
from httplib import UNAUTHORIZED, FORBIDDEN
from json_converter import loads, dumps
-from ttypes import Unauthorized, Forbidden
+from apitypes import Unauthorized, Forbidden
class JSONClient:
URL = "http://localhost:8001/api"
diff --git a/module/remote/WSClient.py b/module/remote/WSClient.py
index fc7590edb..793a6ef28 100644
--- a/module/remote/WSClient.py
+++ b/module/remote/WSClient.py
@@ -5,7 +5,7 @@ from websocket import create_connection
from httplib import UNAUTHORIZED, FORBIDDEN
from json_converter import loads, dumps
-from ttypes import Unauthorized, Forbidden
+from apitypes import Unauthorized, Forbidden
class WSClient:
URL = "ws://localhost:7227/api"
diff --git a/module/remote/apitypes.py b/module/remote/apitypes.py
new file mode 100644
index 000000000..1f91403d5
--- /dev/null
+++ b/module/remote/apitypes.py
@@ -0,0 +1,534 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+# Autogenerated by pyload
+# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+
+class BaseObject(object):
+ __slots__ = []
+
+ def __str__(self):
+ return "<%s %s>" % (self.__class__.__name__, ", ".join("%s=%s" % (k,getattr(self,k)) for k in self.__slots__))
+
+class ExceptionObject(Exception):
+ __slots__ = []
+
+class DownloadState:
+ All = 0
+ Finished = 1
+ Unfinished = 2
+ Failed = 3
+ Unmanaged = 4
+
+class DownloadStatus:
+ NA = 0
+ Offline = 1
+ Online = 2
+ Queued = 3
+ Paused = 4
+ Finished = 5
+ Skipped = 6
+ Failed = 7
+ Starting = 8
+ Waiting = 9
+ Downloading = 10
+ TempOffline = 11
+ Aborted = 12
+ Decrypting = 13
+ Processing = 14
+ Custom = 15
+ Unknown = 16
+
+class FileStatus:
+ Ok = 0
+ Missing = 1
+ Remote = 2
+
+class Input:
+ NA = 0
+ Text = 1
+ Int = 2
+ File = 3
+ Folder = 4
+ Textbox = 5
+ Password = 6
+ Bool = 7
+ Click = 8
+ Select = 9
+ Multiple = 10
+ List = 11
+ Table = 12
+
+class MediaType:
+ All = 0
+ Other = 1
+ Audio = 2
+ Image = 4
+ Video = 8
+ Document = 16
+ Archive = 32
+
+class Output:
+ All = 0
+ Notification = 1
+ Captcha = 2
+ Query = 4
+
+class PackageStatus:
+ Ok = 0
+ Paused = 1
+ Folder = 2
+ Remote = 3
+
+class Permission:
+ All = 0
+ Add = 1
+ Delete = 2
+ Modify = 4
+ Download = 8
+ Accounts = 16
+ Interaction = 32
+ Plugins = 64
+
+class Role:
+ Admin = 0
+ User = 1
+
+class AccountInfo(BaseObject):
+ __slots__ = ['plugin', 'loginname', 'owner', 'valid', 'validuntil', 'trafficleft', 'maxtraffic', 'premium', 'activated', 'shared', 'options']
+
+ def __init__(self, plugin=None, loginname=None, owner=None, valid=None, validuntil=None, trafficleft=None, maxtraffic=None, premium=None, activated=None, shared=None, options=None):
+ self.plugin = plugin
+ self.loginname = loginname
+ self.owner = owner
+ self.valid = valid
+ self.validuntil = validuntil
+ self.trafficleft = trafficleft
+ self.maxtraffic = maxtraffic
+ self.premium = premium
+ self.activated = activated
+ self.shared = shared
+ self.options = options
+
+class AddonInfo(BaseObject):
+ __slots__ = ['func_name', 'description', 'value']
+
+ def __init__(self, func_name=None, description=None, value=None):
+ self.func_name = func_name
+ self.description = description
+ self.value = value
+
+class AddonService(BaseObject):
+ __slots__ = ['func_name', 'description', 'arguments', 'media']
+
+ def __init__(self, func_name=None, description=None, arguments=None, media=None):
+ self.func_name = func_name
+ self.description = description
+ self.arguments = arguments
+ self.media = media
+
+class ConfigHolder(BaseObject):
+ __slots__ = ['name', 'label', 'description', 'long_description', 'items', 'info', 'handler']
+
+ def __init__(self, name=None, label=None, description=None, long_description=None, items=None, info=None, handler=None):
+ self.name = name
+ self.label = label
+ self.description = description
+ self.long_description = long_description
+ self.items = items
+ self.info = info
+ self.handler = handler
+
+class ConfigInfo(BaseObject):
+ __slots__ = ['name', 'label', 'description', 'category', 'user_context', 'activated']
+
+ def __init__(self, name=None, label=None, description=None, category=None, user_context=None, activated=None):
+ self.name = name
+ self.label = label
+ self.description = description
+ self.category = category
+ self.user_context = user_context
+ self.activated = activated
+
+class ConfigItem(BaseObject):
+ __slots__ = ['name', 'label', 'description', 'type', 'default_value', 'value']
+
+ def __init__(self, name=None, label=None, description=None, type=None, default_value=None, value=None):
+ self.name = name
+ self.label = label
+ self.description = description
+ self.type = type
+ self.default_value = default_value
+ self.value = value
+
+class DownloadInfo(BaseObject):
+ __slots__ = ['url', 'plugin', 'hash', 'status', 'statusmsg', 'error']
+
+ def __init__(self, url=None, plugin=None, hash=None, status=None, statusmsg=None, error=None):
+ self.url = url
+ self.plugin = plugin
+ self.hash = hash
+ self.status = status
+ self.statusmsg = statusmsg
+ self.error = error
+
+class DownloadProgress(BaseObject):
+ __slots__ = ['fid', 'pid', 'speed', 'status']
+
+ def __init__(self, fid=None, pid=None, speed=None, status=None):
+ self.fid = fid
+ self.pid = pid
+ self.speed = speed
+ self.status = status
+
+class EventInfo(BaseObject):
+ __slots__ = ['eventname', 'event_args']
+
+ def __init__(self, eventname=None, event_args=None):
+ self.eventname = eventname
+ self.event_args = event_args
+
+class FileDoesNotExists(ExceptionObject):
+ __slots__ = ['fid']
+
+ def __init__(self, fid=None):
+ self.fid = fid
+
+class FileInfo(BaseObject):
+ __slots__ = ['fid', 'name', 'package', 'owner', 'size', 'status', 'media', 'added', 'fileorder', 'download']
+
+ def __init__(self, fid=None, name=None, package=None, owner=None, size=None, status=None, media=None, added=None, fileorder=None, download=None):
+ self.fid = fid
+ self.name = name
+ self.package = package
+ self.owner = owner
+ self.size = size
+ self.status = status
+ self.media = media
+ self.added = added
+ self.fileorder = fileorder
+ self.download = download
+
+class Forbidden(ExceptionObject):
+ pass
+
+class InteractionTask(BaseObject):
+ __slots__ = ['iid', 'input', 'data', 'output', 'default_value', 'title', 'description', 'plugin']
+
+ def __init__(self, iid=None, input=None, data=None, output=None, default_value=None, title=None, description=None, plugin=None):
+ self.iid = iid
+ self.input = input
+ self.data = data
+ self.output = output
+ self.default_value = default_value
+ self.title = title
+ self.description = description
+ self.plugin = plugin
+
+class InvalidConfigSection(ExceptionObject):
+ __slots__ = ['section']
+
+ def __init__(self, section=None):
+ self.section = section
+
+class LinkStatus(BaseObject):
+ __slots__ = ['url', 'name', 'plugin', 'size', 'status', 'packagename']
+
+ def __init__(self, url=None, name=None, plugin=None, size=None, status=None, packagename=None):
+ self.url = url
+ self.name = name
+ self.plugin = plugin
+ self.size = size
+ self.status = status
+ self.packagename = packagename
+
+class OnlineCheck(BaseObject):
+ __slots__ = ['rid', 'data']
+
+ def __init__(self, rid=None, data=None):
+ self.rid = rid
+ self.data = data
+
+class PackageDoesNotExists(ExceptionObject):
+ __slots__ = ['pid']
+
+ def __init__(self, pid=None):
+ self.pid = pid
+
+class PackageInfo(BaseObject):
+ __slots__ = ['pid', 'name', 'folder', 'root', 'owner', 'site', 'comment', 'password', 'added', 'tags', 'status', 'shared', 'packageorder', 'stats', 'fids', 'pids']
+
+ def __init__(self, pid=None, name=None, folder=None, root=None, owner=None, site=None, comment=None, password=None, added=None, tags=None, status=None, shared=None, packageorder=None, stats=None, fids=None, pids=None):
+ self.pid = pid
+ self.name = name
+ self.folder = folder
+ self.root = root
+ self.owner = owner
+ self.site = site
+ self.comment = comment
+ self.password = password
+ self.added = added
+ self.tags = tags
+ self.status = status
+ self.shared = shared
+ self.packageorder = packageorder
+ self.stats = stats
+ self.fids = fids
+ self.pids = pids
+
+class PackageStats(BaseObject):
+ __slots__ = ['linkstotal', 'linksdone', 'sizetotal', 'sizedone']
+
+ def __init__(self, linkstotal=None, linksdone=None, sizetotal=None, sizedone=None):
+ self.linkstotal = linkstotal
+ self.linksdone = linksdone
+ self.sizetotal = sizetotal
+ self.sizedone = sizedone
+
+class ProgressInfo(BaseObject):
+ __slots__ = ['plugin', 'name', 'statusmsg', 'eta', 'done', 'total', 'download']
+
+ def __init__(self, plugin=None, name=None, statusmsg=None, eta=None, done=None, total=None, download=None):
+ self.plugin = plugin
+ self.name = name
+ self.statusmsg = statusmsg
+ self.eta = eta
+ self.done = done
+ self.total = total
+ self.download = download
+
+class ServerStatus(BaseObject):
+ __slots__ = ['queuedDownloads', 'totalDownloads', 'speed', 'pause', 'download', 'reconnect']
+
+ def __init__(self, queuedDownloads=None, totalDownloads=None, speed=None, pause=None, download=None, reconnect=None):
+ self.queuedDownloads = queuedDownloads
+ self.totalDownloads = totalDownloads
+ self.speed = speed
+ self.pause = pause
+ self.download = download
+ self.reconnect = reconnect
+
+class ServiceDoesNotExists(ExceptionObject):
+ __slots__ = ['plugin', 'func']
+
+ def __init__(self, plugin=None, func=None):
+ self.plugin = plugin
+ self.func = func
+
+class ServiceException(ExceptionObject):
+ __slots__ = ['msg']
+
+ def __init__(self, msg=None):
+ self.msg = msg
+
+class TreeCollection(BaseObject):
+ __slots__ = ['root', 'files', 'packages']
+
+ def __init__(self, root=None, files=None, packages=None):
+ self.root = root
+ self.files = files
+ self.packages = packages
+
+class Unauthorized(ExceptionObject):
+ pass
+
+class UserData(BaseObject):
+ __slots__ = ['uid', 'name', 'email', 'role', 'permission', 'folder', 'traffic', 'dllimit', 'dlquota', 'hddquota', 'user', 'templateName']
+
+ def __init__(self, uid=None, name=None, email=None, role=None, permission=None, folder=None, traffic=None, dllimit=None, dlquota=None, hddquota=None, user=None, templateName=None):
+ self.uid = uid
+ self.name = name
+ self.email = email
+ self.role = role
+ self.permission = permission
+ self.folder = folder
+ self.traffic = traffic
+ self.dllimit = dllimit
+ self.dlquota = dlquota
+ self.hddquota = hddquota
+ self.user = user
+ self.templateName = templateName
+
+class UserDoesNotExists(ExceptionObject):
+ __slots__ = ['user']
+
+ def __init__(self, user=None):
+ self.user = user
+
+class Iface(object):
+ def addFromCollector(self, name, paused):
+ pass
+ def addLinks(self, pid, links):
+ pass
+ def addLocalFile(self, pid, name, path):
+ pass
+ def addPackage(self, name, links, password):
+ pass
+ def addPackageChild(self, name, links, password, root, paused):
+ pass
+ def addPackageP(self, name, links, password, paused):
+ pass
+ def addToCollector(self, links):
+ pass
+ def addUser(self, username, password):
+ pass
+ def callAddon(self, plugin, func, arguments):
+ pass
+ def callAddonHandler(self, plugin, func, pid_or_fid):
+ pass
+ def checkOnlineStatus(self, urls):
+ pass
+ def checkOnlineStatusContainer(self, urls, filename, data):
+ pass
+ def checkURLs(self, urls):
+ pass
+ def configurePlugin(self, plugin):
+ pass
+ def createPackage(self, name, folder, root, password, site, comment, paused):
+ pass
+ def deleteCollLink(self, url):
+ pass
+ def deleteCollPack(self, name):
+ pass
+ def deleteConfig(self, plugin):
+ pass
+ def deleteFiles(self, fids):
+ pass
+ def deletePackages(self, pids):
+ pass
+ def findFiles(self, pattern):
+ pass
+ def findPackages(self, tags):
+ pass
+ def freeSpace(self):
+ pass
+ def generateAndAddPackages(self, links, paused):
+ pass
+ def generateDownloadLink(self, fid, timeout):
+ pass
+ def generatePackages(self, links):
+ pass
+ def getAccountTypes(self):
+ pass
+ def getAccounts(self, refresh):
+ pass
+ def getAddonHandler(self):
+ pass
+ def getAllFiles(self):
+ pass
+ def getAllUserData(self):
+ pass
+ def getAutocompletion(self, pattern):
+ pass
+ def getAvailablePlugins(self):
+ pass
+ def getCollector(self):
+ pass
+ def getConfig(self):
+ pass
+ def getConfigValue(self, section, option):
+ pass
+ def getCoreConfig(self):
+ pass
+ def getEvents(self, uuid):
+ pass
+ def getFileInfo(self, fid):
+ pass
+ def getFileTree(self, pid, full):
+ pass
+ def getFilteredFileTree(self, pid, full, state):
+ pass
+ def getFilteredFiles(self, state):
+ pass
+ def getInteractionTask(self, mode):
+ pass
+ def getLog(self, offset):
+ pass
+ def getNotifications(self):
+ pass
+ def getPackageContent(self, pid):
+ pass
+ def getPackageInfo(self, pid):
+ pass
+ def getPluginConfig(self):
+ pass
+ def getProgressInfo(self):
+ pass
+ def getServerStatus(self):
+ pass
+ def getServerVersion(self):
+ pass
+ def getUserData(self):
+ pass
+ def getWSAddress(self):
+ pass
+ def hasAddonHandler(self, plugin, func):
+ pass
+ def isInteractionWaiting(self, mode):
+ pass
+ def login(self, username, password):
+ pass
+ def moveFiles(self, fids, pid):
+ pass
+ def movePackage(self, pid, root):
+ pass
+ def orderFiles(self, fids, pid, position):
+ pass
+ def orderPackage(self, pids, position):
+ pass
+ def parseURLs(self, html, url):
+ pass
+ def pauseServer(self):
+ pass
+ def pollResults(self, rid):
+ pass
+ def quit(self):
+ pass
+ def recheckPackage(self, pid):
+ pass
+ def removeAccount(self, plugin, account):
+ pass
+ def removeUser(self, uid):
+ pass
+ def renameCollPack(self, name, new_name):
+ pass
+ def restart(self):
+ pass
+ def restartFailed(self):
+ pass
+ def restartFile(self, fid):
+ pass
+ def restartPackage(self, pid):
+ pass
+ def saveConfig(self, config):
+ pass
+ def setConfigHandler(self, plugin, iid, value):
+ pass
+ def setConfigValue(self, section, option, value):
+ pass
+ def setInteractionResult(self, iid, result):
+ pass
+ def setPackageFolder(self, pid, path):
+ pass
+ def setPassword(self, username, old_password, new_password):
+ 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):
+ pass
+ def updateAccountInfo(self, account):
+ pass
+ def updatePackage(self, pack):
+ pass
+ def updateUserData(self, data):
+ pass
+ def uploadContainer(self, filename, data):
+ pass
+
diff --git a/module/remote/ttypes_debug.py b/module/remote/apitypes_debug.py
index f7f02b127..3c4f67a49 100644
--- a/module/remote/ttypes_debug.py
+++ b/module/remote/apitypes_debug.py
@@ -5,6 +5,18 @@
from ttypes import *
+enums = [
+ "DownloadState",
+ "DownloadStatus",
+ "FileStatus",
+ "Input",
+ "MediaType",
+ "Output",
+ "PackageStatus",
+ "Permission",
+ "Role",
+]
+
classes = {
'AccountInfo' : [basestring, basestring, int, bool, int, int, int, bool, bool, bool, (dict, basestring, basestring)],
'AddonInfo' : [basestring, basestring, basestring],
diff --git a/module/remote/create_ttypes.py b/module/remote/create_apitypes.py
index 544b00ee8..7755b5c57 100644
--- a/module/remote/create_ttypes.py
+++ b/module/remote/create_apitypes.py
@@ -59,7 +59,7 @@ def main():
classes = []
tf = open(join(path, "pyload.thrift"), "rb").read()
- print "generating lightweight ttypes.py"
+ print "generating apitypes.py"
for name in dir(ttypes):
klass = getattr(ttypes, name)
@@ -68,12 +68,12 @@ def main():
continue
if hasattr(klass, "thrift_spec"):
- classes.append(klass)
+ classes.append(klass)
else:
enums.append(klass)
- f = open(join(path, "ttypes.py"), "wb")
+ f = open(join(path, "apitypes.py"), "wb")
f.write(
"""#!/usr/bin/env python
# -*- coding: utf-8 -*-
@@ -91,7 +91,7 @@ class ExceptionObject(Exception):
""")
- dev = open(join(path, "ttypes_debug.py"), "wb")
+ dev = open(join(path, "apitypes_debug.py"), "wb")
dev.write("""#!/usr/bin/env python
# -*- coding: utf-8 -*-
# Autogenerated by pyload
@@ -99,6 +99,8 @@ class ExceptionObject(Exception):
from ttypes import *\n
""")
+ dev.write("enums = [\n")
+
## generate enums
for enum in enums:
name = enum.__name__
@@ -106,11 +108,13 @@ from ttypes import *\n
for attr in sorted(dir(enum), key=lambda x: getattr(enum, x)):
if attr.startswith("_") or attr in ("read", "write"): continue
-
f.write("\t%s = %s\n" % (attr, getattr(enum, attr)))
+ dev.write('\t"%s",\n' % name)
f.write("\n")
+ dev.write("]\n\n")
+
dev.write("classes = {\n")
for klass in classes:
diff --git a/module/remote/create_jstypes.py b/module/remote/create_jstypes.py
new file mode 100644
index 000000000..ad05ec9a8
--- /dev/null
+++ b/module/remote/create_jstypes.py
@@ -0,0 +1,34 @@
+#!/usr/bin/env python
+# -*- coding: utf-8 -*-
+
+from os.path import abspath, dirname, join
+
+path = dirname(abspath(__file__))
+module = join(path, "..")
+
+import apitypes
+from apitypes_debug import enums
+
+# generate js enums
+def main():
+
+ print "generating apitypes.js"
+
+ f = open(join(module, 'web', 'static', 'js', 'utils', 'apitypes.js'), 'wb')
+ f.write("""// Autogenerated, do not edit!
+define([], function() {
+\treturn {
+""")
+
+ for name in enums:
+ enum = getattr(apitypes, name)
+ values = dict([(attr, getattr(enum, attr)) for attr in dir(enum) if not attr.startswith("_")])
+
+ f.write("\t\t%s: %s,\n" % (name, str(values)))
+
+ f.write("\t};\n});")
+ f.close()
+
+
+if __name__ == "__main__":
+ main()
diff --git a/module/remote/json_converter.py b/module/remote/json_converter.py
index 5b85f30cd..256674c34 100644
--- a/module/remote/json_converter.py
+++ b/module/remote/json_converter.py
@@ -7,9 +7,9 @@ except ImportError:
import json
-import ttypes
-from ttypes import BaseObject
-from ttypes import ExceptionObject
+import apitypes
+from apitypes import BaseObject
+from apitypes import ExceptionObject
# compact json separator
separators = (',', ':')
@@ -29,7 +29,7 @@ class BaseEncoder(json.JSONEncoder):
def convert_obj(dct):
if '@class' in dct:
- cls = getattr(ttypes, dct['@class'])
+ cls = getattr(apitypes, dct['@class'])
del dct['@class']
return cls(**dct)
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-31 02:50:12 +0100