diff options
Diffstat (limited to 'module/remote/thriftbackend/thriftgen/pyload/Pyload.py')
| -rw-r--r-- | module/remote/thriftbackend/thriftgen/pyload/Pyload.py | 4177 |
1 files changed, 2911 insertions, 1266 deletions
diff --git a/module/remote/thriftbackend/thriftgen/pyload/Pyload.py b/module/remote/thriftbackend/thriftgen/pyload/Pyload.py index 78a42f16a..157d5b87b 100644 --- a/module/remote/thriftbackend/thriftgen/pyload/Pyload.py +++ b/module/remote/thriftbackend/thriftgen/pyload/Pyload.py @@ -1,5 +1,5 @@ # -# Autogenerated by Thrift Compiler (0.9.0-dev) +# Autogenerated by Thrift Compiler (0.8.0) # # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING # @@ -8,34 +8,15 @@ from thrift.Thrift import TType, TMessageType, TException from ttypes import * -from thrift.Thrift import TProcessor +from thrift.Thrift import TProcessor, TApplicationException from thrift.protocol.TBase import TBase, TExceptionBase class Iface(object): - def getConfigValue(self, category, option, section): - """ - Parameters: - - category - - option - - section - """ - pass - - def setConfigValue(self, category, option, value, section): - """ - Parameters: - - category - - option - - value - - section - """ - pass - - def getConfig(self, ): + def getServerVersion(self, ): pass - def getPluginConfig(self, ): + def statusServer(self, ): pass def pauseServer(self, ): @@ -47,15 +28,9 @@ class Iface(object): def togglePause(self, ): pass - def statusServer(self, ): - pass - def freeSpace(self, ): pass - def getServerVersion(self, ): - pass - def kill(self, ): pass @@ -78,10 +53,45 @@ class Iface(object): def toggleReconnect(self, ): pass - def generatePackages(self, links): + def getProgressInfo(self, ): + pass + + def getConfig(self, ): + pass + + def getGlobalPlugins(self, ): + pass + + def getUserPlugins(self, ): + pass + + def configurePlugin(self, plugin): """ Parameters: - - links + - plugin + """ + pass + + def saveConfig(self, config): + """ + Parameters: + - config + """ + pass + + def deleteConfig(self, plugin): + """ + Parameters: + - plugin + """ + pass + + def setConfigHandler(self, plugin, iid, value): + """ + Parameters: + - plugin + - iid + - value """ pass @@ -123,117 +133,193 @@ class Iface(object): """ pass - def statusDownloads(self, ): + def generatePackages(self, links): + """ + Parameters: + - links + """ pass - def getPackageData(self, pid): + def generateAndAddPackages(self, links, paused): """ Parameters: - - pid + - links + - paused """ pass - def getPackageInfo(self, pid): + def createPackage(self, name, folder, root, password, site, comment, paused): """ Parameters: - - pid + - name + - folder + - root + - password + - site + - comment + - paused """ pass - def getFileData(self, fid): + def addPackage(self, name, links, password): """ Parameters: - - fid + - name + - links + - password """ pass - def getQueue(self, ): + def addPackageP(self, name, links, password, paused): + """ + Parameters: + - name + - links + - password + - paused + """ pass - def getCollector(self, ): + def addPackageChild(self, name, links, password, root, paused): + """ + Parameters: + - name + - links + - password + - root + - paused + """ pass - def getQueueData(self, ): + def uploadContainer(self, filename, data): + """ + Parameters: + - filename + - data + """ + pass + + def addLinks(self, pid, links): + """ + Parameters: + - pid + - links + """ pass - def getCollectorData(self, ): + def addLocalFile(self, pid, name, path): + """ + Parameters: + - pid + - name + - path + """ pass - def getPackageOrder(self, destination): + def deleteFiles(self, fids): """ Parameters: - - destination + - fids """ pass - def getFileOrder(self, pid): + def deletePackages(self, pids): """ Parameters: - - pid + - pids """ pass - def generateAndAddPackages(self, links, dest): + def getCollector(self, ): + pass + + def addToCollector(self, links): """ Parameters: - links - - dest """ pass - def addPackage(self, name, links, dest): + def addFromCollector(self, name, paused): """ Parameters: - name - - links - - dest + - paused """ pass - def addFiles(self, pid, links): + def renameCollPack(self, name, new_name): """ Parameters: - - pid - - links + - name + - new_name """ pass - def uploadContainer(self, filename, data): + def deleteCollPack(self, name): """ Parameters: - - filename - - data + - name """ pass - def deleteFiles(self, fids): + def deleteCollLink(self, url): """ Parameters: - - fids + - url """ pass - def deletePackages(self, pids): + def getAllFiles(self, ): + pass + + def getAllUnfinishedFiles(self, ): + pass + + def getFileTree(self, pid, full): """ Parameters: - - pids + - pid + - full + """ + pass + + def getUnfinishedFileTree(self, pid, full): + """ + Parameters: + - pid + - full """ pass - def pushToQueue(self, pid): + def getPackageContent(self, pid): """ Parameters: - pid """ pass - def pullFromQueue(self, pid): + def getPackageInfo(self, pid): """ Parameters: - pid """ pass + def getFileInfo(self, fid): + """ + Parameters: + - fid + """ + pass + + def findFiles(self, pattern): + """ + Parameters: + - pattern + """ + pass + def restartPackage(self, pid): """ Parameters: @@ -255,7 +341,7 @@ class Iface(object): """ pass - def stopAllDownloads(self, ): + def restartFailed(self, ): pass def stopDownloads(self, fids): @@ -265,19 +351,38 @@ class Iface(object): """ pass - def setPackageName(self, pid, name): + def stopAllDownloads(self, ): + pass + + def setPackagePaused(self, pid, paused): """ Parameters: - pid - - name + - paused + """ + pass + + def setPackageFolder(self, pid, path): + """ + Parameters: + - pid + - path + """ + pass + + def setPackageData(self, pid, data): + """ + Parameters: + - pid + - data """ pass - def movePackage(self, destination, pid): + def movePackage(self, pid, root): """ Parameters: - - destination - pid + - root """ pass @@ -289,34 +394,54 @@ class Iface(object): """ pass - def orderPackage(self, pid, position): + def orderPackage(self, pids, position): """ Parameters: - - pid + - pids - position """ pass - def orderFile(self, fid, position): + def orderFiles(self, fids, pid, position): """ Parameters: - - fid + - fids + - pid - position """ pass - def setPackageData(self, pid, data): + def isInteractionWaiting(self, mode): """ Parameters: - - pid - - data + - mode + """ + pass + + def getInteractionTask(self, mode): + """ + Parameters: + - mode """ pass - def deleteFinished(self, ): + def setInteractionResult(self, iid, result): + """ + Parameters: + - iid + - result + """ pass - def restartFailed(self, ): + def generateDownloadLink(self, fid, timeout): + """ + Parameters: + - fid + - timeout + """ + pass + + def getNotifications(self, ): pass def getEvents(self, uuid): @@ -336,13 +461,19 @@ class Iface(object): def getAccountTypes(self, ): pass - def updateAccount(self, plugin, account, password, options): + def updateAccount(self, plugin, account, password): """ Parameters: - plugin - account - password - - options + """ + pass + + def updateAccountInfo(self, account): + """ + Parameters: + - account """ pass @@ -362,7 +493,13 @@ class Iface(object): """ pass - def getUserData(self, username, password): + def getUserData(self, ): + pass + + def getAllUserData(self, ): + pass + + def addUser(self, username, password): """ Parameters: - username @@ -370,24 +507,26 @@ class Iface(object): """ pass - def getAllUserData(self, ): - pass - - def getServices(self, ): + def updateUserData(self, data): + """ + Parameters: + - data + """ pass - def hasService(self, plugin, func): + def removeUser(self, uid): """ Parameters: - - plugin - - func + - uid """ pass - def call(self, info): + def setPassword(self, username, old_password, new_password): """ Parameters: - - info + - username + - old_password + - new_password """ pass @@ -401,28 +540,32 @@ class Iface(object): """ pass - def isCaptchaWaiting(self, ): + def getAddonHandler(self, ): pass - def getCaptchaTask(self, exclusive): + def hasAddonHandler(self, plugin, func): """ Parameters: - - exclusive + - plugin + - func """ pass - def getCaptchaTaskStatus(self, tid): + def callAddon(self, plugin, func, arguments): """ Parameters: - - tid + - plugin + - func + - arguments """ pass - def setCaptchaResult(self, tid, result): + def callAddonHandler(self, plugin, func, pid_or_fid): """ Parameters: - - tid - - result + - plugin + - func + - pid_or_fid """ pass @@ -434,123 +577,55 @@ class Client(Iface): self._oprot = oprot self._seqid = 0 - def getConfigValue(self, category, option, section): - """ - Parameters: - - category - - option - - section - """ - self.send_getConfigValue(category, option, section) - return self.recv_getConfigValue() - - def send_getConfigValue(self, category, option, section): - self._oprot.writeMessageBegin('getConfigValue', TMessageType.CALL, self._seqid) - args = getConfigValue_args() - args.category = category - args.option = option - args.section = section - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_getConfigValue(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = getConfigValue_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfigValue failed: unknown result"); - - def setConfigValue(self, category, option, value, section): - """ - Parameters: - - category - - option - - value - - section - """ - self.send_setConfigValue(category, option, value, section) - self.recv_setConfigValue() - - def send_setConfigValue(self, category, option, value, section): - self._oprot.writeMessageBegin('setConfigValue', TMessageType.CALL, self._seqid) - args = setConfigValue_args() - args.category = category - args.option = option - args.value = value - args.section = section - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_setConfigValue(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = setConfigValue_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - return - - def getConfig(self, ): - self.send_getConfig() - return self.recv_getConfig() + def getServerVersion(self, ): + self.send_getServerVersion() + return self.recv_getServerVersion() - def send_getConfig(self, ): - self._oprot.writeMessageBegin('getConfig', TMessageType.CALL, self._seqid) - args = getConfig_args() + def send_getServerVersion(self, ): + self._oprot.writeMessageBegin('getServerVersion', TMessageType.CALL, self._seqid) + args = getServerVersion_args() args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getConfig(self, ): + def recv_getServerVersion(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getConfig_result() + result = getServerVersion_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfig failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getServerVersion failed: unknown result"); - def getPluginConfig(self, ): - self.send_getPluginConfig() - return self.recv_getPluginConfig() + def statusServer(self, ): + self.send_statusServer() + return self.recv_statusServer() - def send_getPluginConfig(self, ): - self._oprot.writeMessageBegin('getPluginConfig', TMessageType.CALL, self._seqid) - args = getPluginConfig_args() + def send_statusServer(self, ): + self._oprot.writeMessageBegin('statusServer', TMessageType.CALL, self._seqid) + args = statusServer_args() args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getPluginConfig(self, ): + def recv_statusServer(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getPluginConfig_result() + result = statusServer_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getPluginConfig failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "statusServer failed: unknown result"); def pauseServer(self, ): self.send_pauseServer() @@ -623,31 +698,6 @@ class Client(Iface): return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "togglePause failed: unknown result"); - def statusServer(self, ): - self.send_statusServer() - return self.recv_statusServer() - - def send_statusServer(self, ): - self._oprot.writeMessageBegin('statusServer', TMessageType.CALL, self._seqid) - args = statusServer_args() - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_statusServer(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = statusServer_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "statusServer failed: unknown result"); - def freeSpace(self, ): self.send_freeSpace() return self.recv_freeSpace() @@ -673,31 +723,6 @@ class Client(Iface): return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "freeSpace failed: unknown result"); - def getServerVersion(self, ): - self.send_getServerVersion() - return self.recv_getServerVersion() - - def send_getServerVersion(self, ): - self._oprot.writeMessageBegin('getServerVersion', TMessageType.CALL, self._seqid) - args = getServerVersion_args() - args.write(self._oprot) - self._oprot.writeMessageEnd() - self._oprot.trans.flush() - - def recv_getServerVersion(self, ): - (fname, mtype, rseqid) = self._iprot.readMessageBegin() - if mtype == TMessageType.EXCEPTION: - x = TApplicationException() - x.read(self._iprot) - self._iprot.readMessageEnd() - raise x - result = getServerVersion_result() - result.read(self._iprot) - self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getServerVersion failed: unknown result"); - def kill(self, ): self.send_kill() self.recv_kill() @@ -849,35 +874,223 @@ class Client(Iface): return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "toggleReconnect failed: unknown result"); - def generatePackages(self, links): + def getProgressInfo(self, ): + self.send_getProgressInfo() + return self.recv_getProgressInfo() + + def send_getProgressInfo(self, ): + self._oprot.writeMessageBegin('getProgressInfo', TMessageType.CALL, self._seqid) + args = getProgressInfo_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getProgressInfo(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getProgressInfo_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getProgressInfo failed: unknown result"); + + def getConfig(self, ): + self.send_getConfig() + return self.recv_getConfig() + + def send_getConfig(self, ): + self._oprot.writeMessageBegin('getConfig', TMessageType.CALL, self._seqid) + args = getConfig_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getConfig(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getConfig_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfig failed: unknown result"); + + def getGlobalPlugins(self, ): + self.send_getGlobalPlugins() + return self.recv_getGlobalPlugins() + + def send_getGlobalPlugins(self, ): + self._oprot.writeMessageBegin('getGlobalPlugins', TMessageType.CALL, self._seqid) + args = getGlobalPlugins_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getGlobalPlugins(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getGlobalPlugins_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getGlobalPlugins failed: unknown result"); + + def getUserPlugins(self, ): + self.send_getUserPlugins() + return self.recv_getUserPlugins() + + def send_getUserPlugins(self, ): + self._oprot.writeMessageBegin('getUserPlugins', TMessageType.CALL, self._seqid) + args = getUserPlugins_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getUserPlugins(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getUserPlugins_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserPlugins failed: unknown result"); + + def configurePlugin(self, plugin): """ Parameters: - - links + - plugin """ - self.send_generatePackages(links) - return self.recv_generatePackages() + self.send_configurePlugin(plugin) + return self.recv_configurePlugin() - def send_generatePackages(self, links): - self._oprot.writeMessageBegin('generatePackages', TMessageType.CALL, self._seqid) - args = generatePackages_args() - args.links = links + def send_configurePlugin(self, plugin): + self._oprot.writeMessageBegin('configurePlugin', TMessageType.CALL, self._seqid) + args = configurePlugin_args() + args.plugin = plugin args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_generatePackages(self, ): + def recv_configurePlugin(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = generatePackages_result() + result = configurePlugin_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "generatePackages failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "configurePlugin failed: unknown result"); + + def saveConfig(self, config): + """ + Parameters: + - config + """ + self.send_saveConfig(config) + self.recv_saveConfig() + + def send_saveConfig(self, config): + self._oprot.writeMessageBegin('saveConfig', TMessageType.CALL, self._seqid) + args = saveConfig_args() + args.config = config + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_saveConfig(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = saveConfig_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + return + + def deleteConfig(self, plugin): + """ + Parameters: + - plugin + """ + self.send_deleteConfig(plugin) + self.recv_deleteConfig() + + def send_deleteConfig(self, plugin): + self._oprot.writeMessageBegin('deleteConfig', TMessageType.CALL, self._seqid) + args = deleteConfig_args() + args.plugin = plugin + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_deleteConfig(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = deleteConfig_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + return + + def setConfigHandler(self, plugin, iid, value): + """ + Parameters: + - plugin + - iid + - value + """ + self.send_setConfigHandler(plugin, iid, value) + self.recv_setConfigHandler() + + def send_setConfigHandler(self, plugin, iid, value): + self._oprot.writeMessageBegin('setConfigHandler', TMessageType.CALL, self._seqid) + args = setConfigHandler_args() + args.plugin = plugin + args.iid = iid + args.value = value + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_setConfigHandler(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = setConfigHandler_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + return def checkURLs(self, urls): """ @@ -1035,524 +1248,780 @@ class Client(Iface): return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "pollResults failed: unknown result"); - def statusDownloads(self, ): - self.send_statusDownloads() - return self.recv_statusDownloads() + def generatePackages(self, links): + """ + Parameters: + - links + """ + self.send_generatePackages(links) + return self.recv_generatePackages() - def send_statusDownloads(self, ): - self._oprot.writeMessageBegin('statusDownloads', TMessageType.CALL, self._seqid) - args = statusDownloads_args() + def send_generatePackages(self, links): + self._oprot.writeMessageBegin('generatePackages', TMessageType.CALL, self._seqid) + args = generatePackages_args() + args.links = links args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_statusDownloads(self, ): + def recv_generatePackages(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = statusDownloads_result() + result = generatePackages_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "statusDownloads failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "generatePackages failed: unknown result"); - def getPackageData(self, pid): + def generateAndAddPackages(self, links, paused): """ Parameters: - - pid + - links + - paused """ - self.send_getPackageData(pid) - return self.recv_getPackageData() + self.send_generateAndAddPackages(links, paused) + return self.recv_generateAndAddPackages() - def send_getPackageData(self, pid): - self._oprot.writeMessageBegin('getPackageData', TMessageType.CALL, self._seqid) - args = getPackageData_args() - args.pid = pid + def send_generateAndAddPackages(self, links, paused): + self._oprot.writeMessageBegin('generateAndAddPackages', TMessageType.CALL, self._seqid) + args = generateAndAddPackages_args() + args.links = links + args.paused = paused args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getPackageData(self, ): + def recv_generateAndAddPackages(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getPackageData_result() + result = generateAndAddPackages_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - if result.e is not None: - raise result.e - raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageData failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndAddPackages failed: unknown result"); - def getPackageInfo(self, pid): + def createPackage(self, name, folder, root, password, site, comment, paused): """ Parameters: - - pid + - name + - folder + - root + - password + - site + - comment + - paused """ - self.send_getPackageInfo(pid) - return self.recv_getPackageInfo() + self.send_createPackage(name, folder, root, password, site, comment, paused) + return self.recv_createPackage() - def send_getPackageInfo(self, pid): - self._oprot.writeMessageBegin('getPackageInfo', TMessageType.CALL, self._seqid) - args = getPackageInfo_args() - args.pid = pid + def send_createPackage(self, name, folder, root, password, site, comment, paused): + self._oprot.writeMessageBegin('createPackage', TMessageType.CALL, self._seqid) + args = createPackage_args() + args.name = name + args.folder = folder + args.root = root + args.password = password + args.site = site + args.comment = comment + args.paused = paused args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getPackageInfo(self, ): + def recv_createPackage(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getPackageInfo_result() + result = createPackage_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - if result.e is not None: - raise result.e - raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageInfo failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "createPackage failed: unknown result"); - def getFileData(self, fid): + def addPackage(self, name, links, password): """ Parameters: - - fid + - name + - links + - password """ - self.send_getFileData(fid) - return self.recv_getFileData() + self.send_addPackage(name, links, password) + return self.recv_addPackage() - def send_getFileData(self, fid): - self._oprot.writeMessageBegin('getFileData', TMessageType.CALL, self._seqid) - args = getFileData_args() - args.fid = fid + def send_addPackage(self, name, links, password): + self._oprot.writeMessageBegin('addPackage', TMessageType.CALL, self._seqid) + args = addPackage_args() + args.name = name + args.links = links + args.password = password args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getFileData(self, ): + def recv_addPackage(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getFileData_result() + result = addPackage_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - if result.e is not None: - raise result.e - raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileData failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addPackage failed: unknown result"); - def getQueue(self, ): - self.send_getQueue() - return self.recv_getQueue() + def addPackageP(self, name, links, password, paused): + """ + Parameters: + - name + - links + - password + - paused + """ + self.send_addPackageP(name, links, password, paused) + return self.recv_addPackageP() - def send_getQueue(self, ): - self._oprot.writeMessageBegin('getQueue', TMessageType.CALL, self._seqid) - args = getQueue_args() + def send_addPackageP(self, name, links, password, paused): + self._oprot.writeMessageBegin('addPackageP', TMessageType.CALL, self._seqid) + args = addPackageP_args() + args.name = name + args.links = links + args.password = password + args.paused = paused args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getQueue(self, ): + def recv_addPackageP(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getQueue_result() + result = addPackageP_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueue failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addPackageP failed: unknown result"); - def getCollector(self, ): - self.send_getCollector() - return self.recv_getCollector() + def addPackageChild(self, name, links, password, root, paused): + """ + Parameters: + - name + - links + - password + - root + - paused + """ + self.send_addPackageChild(name, links, password, root, paused) + return self.recv_addPackageChild() - def send_getCollector(self, ): - self._oprot.writeMessageBegin('getCollector', TMessageType.CALL, self._seqid) - args = getCollector_args() + def send_addPackageChild(self, name, links, password, root, paused): + self._oprot.writeMessageBegin('addPackageChild', TMessageType.CALL, self._seqid) + args = addPackageChild_args() + args.name = name + args.links = links + args.password = password + args.root = root + args.paused = paused args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getCollector(self, ): + def recv_addPackageChild(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getCollector_result() + result = addPackageChild_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getCollector failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addPackageChild failed: unknown result"); - def getQueueData(self, ): - self.send_getQueueData() - return self.recv_getQueueData() + def uploadContainer(self, filename, data): + """ + Parameters: + - filename + - data + """ + self.send_uploadContainer(filename, data) + return self.recv_uploadContainer() - def send_getQueueData(self, ): - self._oprot.writeMessageBegin('getQueueData', TMessageType.CALL, self._seqid) - args = getQueueData_args() + def send_uploadContainer(self, filename, data): + self._oprot.writeMessageBegin('uploadContainer', TMessageType.CALL, self._seqid) + args = uploadContainer_args() + args.filename = filename + args.data = data args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getQueueData(self, ): + def recv_uploadContainer(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getQueueData_result() + result = uploadContainer_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueueData failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "uploadContainer failed: unknown result"); - def getCollectorData(self, ): - self.send_getCollectorData() - return self.recv_getCollectorData() + def addLinks(self, pid, links): + """ + Parameters: + - pid + - links + """ + self.send_addLinks(pid, links) + self.recv_addLinks() - def send_getCollectorData(self, ): - self._oprot.writeMessageBegin('getCollectorData', TMessageType.CALL, self._seqid) - args = getCollectorData_args() + def send_addLinks(self, pid, links): + self._oprot.writeMessageBegin('addLinks', TMessageType.CALL, self._seqid) + args = addLinks_args() + args.pid = pid + args.links = links args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getCollectorData(self, ): + def recv_addLinks(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getCollectorData_result() + result = addLinks_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getCollectorData failed: unknown result"); + if result.e is not None: + raise result.e + return - def getPackageOrder(self, destination): + def addLocalFile(self, pid, name, path): """ Parameters: - - destination + - pid + - name + - path """ - self.send_getPackageOrder(destination) - return self.recv_getPackageOrder() + self.send_addLocalFile(pid, name, path) + self.recv_addLocalFile() - def send_getPackageOrder(self, destination): - self._oprot.writeMessageBegin('getPackageOrder', TMessageType.CALL, self._seqid) - args = getPackageOrder_args() - args.destination = destination + def send_addLocalFile(self, pid, name, path): + self._oprot.writeMessageBegin('addLocalFile', TMessageType.CALL, self._seqid) + args = addLocalFile_args() + args.pid = pid + args.name = name + args.path = path args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getPackageOrder(self, ): + def recv_addLocalFile(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getPackageOrder_result() + result = addLocalFile_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageOrder failed: unknown result"); + if result.e is not None: + raise result.e + return - def getFileOrder(self, pid): + def deleteFiles(self, fids): """ Parameters: - - pid + - fids """ - self.send_getFileOrder(pid) - return self.recv_getFileOrder() + self.send_deleteFiles(fids) + self.recv_deleteFiles() - def send_getFileOrder(self, pid): - self._oprot.writeMessageBegin('getFileOrder', TMessageType.CALL, self._seqid) - args = getFileOrder_args() - args.pid = pid + def send_deleteFiles(self, fids): + self._oprot.writeMessageBegin('deleteFiles', TMessageType.CALL, self._seqid) + args = deleteFiles_args() + args.fids = fids args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getFileOrder(self, ): + def recv_deleteFiles(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getFileOrder_result() + result = deleteFiles_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + return + + def deletePackages(self, pids): + """ + Parameters: + - pids + """ + self.send_deletePackages(pids) + self.recv_deletePackages() + + def send_deletePackages(self, pids): + self._oprot.writeMessageBegin('deletePackages', TMessageType.CALL, self._seqid) + args = deletePackages_args() + args.pids = pids + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_deletePackages(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = deletePackages_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + return + + def getCollector(self, ): + self.send_getCollector() + return self.recv_getCollector() + + def send_getCollector(self, ): + self._oprot.writeMessageBegin('getCollector', TMessageType.CALL, self._seqid) + args = getCollector_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getCollector(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getCollector_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileOrder failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getCollector failed: unknown result"); - def generateAndAddPackages(self, links, dest): + def addToCollector(self, links): """ Parameters: - links - - dest """ - self.send_generateAndAddPackages(links, dest) - return self.recv_generateAndAddPackages() + self.send_addToCollector(links) + self.recv_addToCollector() - def send_generateAndAddPackages(self, links, dest): - self._oprot.writeMessageBegin('generateAndAddPackages', TMessageType.CALL, self._seqid) - args = generateAndAddPackages_args() + def send_addToCollector(self, links): + self._oprot.writeMessageBegin('addToCollector', TMessageType.CALL, self._seqid) + args = addToCollector_args() args.links = links - args.dest = dest args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_generateAndAddPackages(self, ): + def recv_addToCollector(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = generateAndAddPackages_result() + result = addToCollector_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndAddPackages failed: unknown result"); + return - def addPackage(self, name, links, dest): + def addFromCollector(self, name, paused): """ Parameters: - name - - links - - dest + - paused """ - self.send_addPackage(name, links, dest) - return self.recv_addPackage() + self.send_addFromCollector(name, paused) + return self.recv_addFromCollector() - def send_addPackage(self, name, links, dest): - self._oprot.writeMessageBegin('addPackage', TMessageType.CALL, self._seqid) - args = addPackage_args() + def send_addFromCollector(self, name, paused): + self._oprot.writeMessageBegin('addFromCollector', TMessageType.CALL, self._seqid) + args = addFromCollector_args() args.name = name - args.links = links - args.dest = dest + args.paused = paused args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_addPackage(self, ): + def recv_addFromCollector(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = addPackage_result() + result = addFromCollector_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "addPackage failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addFromCollector failed: unknown result"); - def addFiles(self, pid, links): + def renameCollPack(self, name, new_name): """ Parameters: - - pid - - links + - name + - new_name """ - self.send_addFiles(pid, links) - self.recv_addFiles() + self.send_renameCollPack(name, new_name) + self.recv_renameCollPack() - def send_addFiles(self, pid, links): - self._oprot.writeMessageBegin('addFiles', TMessageType.CALL, self._seqid) - args = addFiles_args() - args.pid = pid - args.links = links + def send_renameCollPack(self, name, new_name): + self._oprot.writeMessageBegin('renameCollPack', TMessageType.CALL, self._seqid) + args = renameCollPack_args() + args.name = name + args.new_name = new_name args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_addFiles(self, ): + def recv_renameCollPack(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = addFiles_result() + result = renameCollPack_result() result.read(self._iprot) self._iprot.readMessageEnd() return - def uploadContainer(self, filename, data): + def deleteCollPack(self, name): """ Parameters: - - filename - - data + - name """ - self.send_uploadContainer(filename, data) - self.recv_uploadContainer() + self.send_deleteCollPack(name) + self.recv_deleteCollPack() - def send_uploadContainer(self, filename, data): - self._oprot.writeMessageBegin('uploadContainer', TMessageType.CALL, self._seqid) - args = uploadContainer_args() - args.filename = filename - args.data = data + def send_deleteCollPack(self, name): + self._oprot.writeMessageBegin('deleteCollPack', TMessageType.CALL, self._seqid) + args = deleteCollPack_args() + args.name = name args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_uploadContainer(self, ): + def recv_deleteCollPack(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = uploadContainer_result() + result = deleteCollPack_result() result.read(self._iprot) self._iprot.readMessageEnd() return - def deleteFiles(self, fids): + def deleteCollLink(self, url): """ Parameters: - - fids + - url """ - self.send_deleteFiles(fids) - self.recv_deleteFiles() + self.send_deleteCollLink(url) + self.recv_deleteCollLink() - def send_deleteFiles(self, fids): - self._oprot.writeMessageBegin('deleteFiles', TMessageType.CALL, self._seqid) - args = deleteFiles_args() - args.fids = fids + def send_deleteCollLink(self, url): + self._oprot.writeMessageBegin('deleteCollLink', TMessageType.CALL, self._seqid) + args = deleteCollLink_args() + args.url = url args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_deleteFiles(self, ): + def recv_deleteCollLink(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = deleteFiles_result() + result = deleteCollLink_result() result.read(self._iprot) self._iprot.readMessageEnd() return - def deletePackages(self, pids): + def getAllFiles(self, ): + self.send_getAllFiles() + return self.recv_getAllFiles() + + def send_getAllFiles(self, ): + self._oprot.writeMessageBegin('getAllFiles', TMessageType.CALL, self._seqid) + args = getAllFiles_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getAllFiles(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getAllFiles_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllFiles failed: unknown result"); + + def getAllUnfinishedFiles(self, ): + self.send_getAllUnfinishedFiles() + return self.recv_getAllUnfinishedFiles() + + def send_getAllUnfinishedFiles(self, ): + self._oprot.writeMessageBegin('getAllUnfinishedFiles', TMessageType.CALL, self._seqid) + args = getAllUnfinishedFiles_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getAllUnfinishedFiles(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getAllUnfinishedFiles_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllUnfinishedFiles failed: unknown result"); + + def getFileTree(self, pid, full): """ Parameters: - - pids + - pid + - full """ - self.send_deletePackages(pids) - self.recv_deletePackages() + self.send_getFileTree(pid, full) + return self.recv_getFileTree() - def send_deletePackages(self, pids): - self._oprot.writeMessageBegin('deletePackages', TMessageType.CALL, self._seqid) - args = deletePackages_args() - args.pids = pids + def send_getFileTree(self, pid, full): + self._oprot.writeMessageBegin('getFileTree', TMessageType.CALL, self._seqid) + args = getFileTree_args() + args.pid = pid + args.full = full args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_deletePackages(self, ): + def recv_getFileTree(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = deletePackages_result() + result = getFileTree_result() result.read(self._iprot) self._iprot.readMessageEnd() - return + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileTree failed: unknown result"); - def pushToQueue(self, pid): + def getUnfinishedFileTree(self, pid, full): """ Parameters: - pid + - full """ - self.send_pushToQueue(pid) - self.recv_pushToQueue() + self.send_getUnfinishedFileTree(pid, full) + return self.recv_getUnfinishedFileTree() - def send_pushToQueue(self, pid): - self._oprot.writeMessageBegin('pushToQueue', TMessageType.CALL, self._seqid) - args = pushToQueue_args() + def send_getUnfinishedFileTree(self, pid, full): + self._oprot.writeMessageBegin('getUnfinishedFileTree', TMessageType.CALL, self._seqid) + args = getUnfinishedFileTree_args() args.pid = pid + args.full = full args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_pushToQueue(self, ): + def recv_getUnfinishedFileTree(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = pushToQueue_result() + result = getUnfinishedFileTree_result() result.read(self._iprot) self._iprot.readMessageEnd() - return + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getUnfinishedFileTree failed: unknown result"); - def pullFromQueue(self, pid): + def getPackageContent(self, pid): """ Parameters: - pid """ - self.send_pullFromQueue(pid) - self.recv_pullFromQueue() + self.send_getPackageContent(pid) + return self.recv_getPackageContent() - def send_pullFromQueue(self, pid): - self._oprot.writeMessageBegin('pullFromQueue', TMessageType.CALL, self._seqid) - args = pullFromQueue_args() + def send_getPackageContent(self, pid): + self._oprot.writeMessageBegin('getPackageContent', TMessageType.CALL, self._seqid) + args = getPackageContent_args() args.pid = pid args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_pullFromQueue(self, ): + def recv_getPackageContent(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = pullFromQueue_result() + result = getPackageContent_result() result.read(self._iprot) self._iprot.readMessageEnd() - return + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageContent failed: unknown result"); + + def getPackageInfo(self, pid): + """ + Parameters: + - pid + """ + self.send_getPackageInfo(pid) + return self.recv_getPackageInfo() + + def send_getPackageInfo(self, pid): + self._oprot.writeMessageBegin('getPackageInfo', TMessageType.CALL, self._seqid) + args = getPackageInfo_args() + args.pid = pid + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getPackageInfo(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getPackageInfo_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.e is not None: + raise result.e + raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageInfo failed: unknown result"); + + def getFileInfo(self, fid): + """ + Parameters: + - fid + """ + self.send_getFileInfo(fid) + return self.recv_getFileInfo() + + def send_getFileInfo(self, fid): + self._oprot.writeMessageBegin('getFileInfo', TMessageType.CALL, self._seqid) + args = getFileInfo_args() + args.fid = fid + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getFileInfo(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getFileInfo_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.e is not None: + raise result.e + raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileInfo failed: unknown result"); + + def findFiles(self, pattern): + """ + Parameters: + - pattern + """ + self.send_findFiles(pattern) + return self.recv_findFiles() + + def send_findFiles(self, pattern): + self._oprot.writeMessageBegin('findFiles', TMessageType.CALL, self._seqid) + args = findFiles_args() + args.pattern = pattern + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_findFiles(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = findFiles_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "findFiles failed: unknown result"); def restartPackage(self, pid): """ @@ -1638,25 +2107,25 @@ class Client(Iface): self._iprot.readMessageEnd() return - def stopAllDownloads(self, ): - self.send_stopAllDownloads() - self.recv_stopAllDownloads() + def restartFailed(self, ): + self.send_restartFailed() + self.recv_restartFailed() - def send_stopAllDownloads(self, ): - self._oprot.writeMessageBegin('stopAllDownloads', TMessageType.CALL, self._seqid) - args = stopAllDownloads_args() + def send_restartFailed(self, ): + self._oprot.writeMessageBegin('restartFailed', TMessageType.CALL, self._seqid) + args = restartFailed_args() args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_stopAllDownloads(self, ): + def recv_restartFailed(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = stopAllDownloads_result() + result = restartFailed_result() result.read(self._iprot) self._iprot.readMessageEnd() return @@ -1689,50 +2158,141 @@ class Client(Iface): self._iprot.readMessageEnd() return - def setPackageName(self, pid, name): + def stopAllDownloads(self, ): + self.send_stopAllDownloads() + self.recv_stopAllDownloads() + + def send_stopAllDownloads(self, ): + self._oprot.writeMessageBegin('stopAllDownloads', TMessageType.CALL, self._seqid) + args = stopAllDownloads_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_stopAllDownloads(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = stopAllDownloads_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + return + + def setPackagePaused(self, pid, paused): """ Parameters: - pid - - name + - paused """ - self.send_setPackageName(pid, name) - self.recv_setPackageName() + self.send_setPackagePaused(pid, paused) + self.recv_setPackagePaused() - def send_setPackageName(self, pid, name): - self._oprot.writeMessageBegin('setPackageName', TMessageType.CALL, self._seqid) - args = setPackageName_args() + def send_setPackagePaused(self, pid, paused): + self._oprot.writeMessageBegin('setPackagePaused', TMessageType.CALL, self._seqid) + args = setPackagePaused_args() args.pid = pid - args.name = name + args.paused = paused args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_setPackageName(self, ): + def recv_setPackagePaused(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = setPackageName_result() + result = setPackagePaused_result() result.read(self._iprot) self._iprot.readMessageEnd() + if result.e is not None: + raise result.e return - def movePackage(self, destination, pid): + def setPackageFolder(self, pid, path): """ Parameters: - - destination - pid + - path """ - self.send_movePackage(destination, pid) - self.recv_movePackage() + self.send_setPackageFolder(pid, path) + return self.recv_setPackageFolder() - def send_movePackage(self, destination, pid): + def send_setPackageFolder(self, pid, path): + self._oprot.writeMessageBegin('setPackageFolder', TMessageType.CALL, self._seqid) + args = setPackageFolder_args() + args.pid = pid + args.path = path + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_setPackageFolder(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = setPackageFolder_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.e is not None: + raise result.e + raise TApplicationException(TApplicationException.MISSING_RESULT, "setPackageFolder failed: unknown result"); + + def setPackageData(self, pid, data): + """ + Parameters: + - pid + - data + """ + self.send_setPackageData(pid, data) + self.recv_setPackageData() + + def send_setPackageData(self, pid, data): + self._oprot.writeMessageBegin('setPackageData', TMessageType.CALL, self._seqid) + args = setPackageData_args() + args.pid = pid + args.data = data + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_setPackageData(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = setPackageData_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.e is not None: + raise result.e + return + + def movePackage(self, pid, root): + """ + Parameters: + - pid + - root + """ + self.send_movePackage(pid, root) + return self.recv_movePackage() + + def send_movePackage(self, pid, root): self._oprot.writeMessageBegin('movePackage', TMessageType.CALL, self._seqid) args = movePackage_args() - args.destination = destination args.pid = pid + args.root = root args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() @@ -1747,7 +2307,11 @@ class Client(Iface): result = movePackage_result() result.read(self._iprot) self._iprot.readMessageEnd() - return + if result.success is not None: + return result.success + if result.e is not None: + raise result.e + raise TApplicationException(TApplicationException.MISSING_RESULT, "movePackage failed: unknown result"); def moveFiles(self, fids, pid): """ @@ -1756,7 +2320,7 @@ class Client(Iface): - pid """ self.send_moveFiles(fids, pid) - self.recv_moveFiles() + return self.recv_moveFiles() def send_moveFiles(self, fids, pid): self._oprot.writeMessageBegin('moveFiles', TMessageType.CALL, self._seqid) @@ -1777,21 +2341,25 @@ class Client(Iface): result = moveFiles_result() result.read(self._iprot) self._iprot.readMessageEnd() - return + if result.success is not None: + return result.success + if result.e is not None: + raise result.e + raise TApplicationException(TApplicationException.MISSING_RESULT, "moveFiles failed: unknown result"); - def orderPackage(self, pid, position): + def orderPackage(self, pids, position): """ Parameters: - - pid + - pids - position """ - self.send_orderPackage(pid, position) + self.send_orderPackage(pids, position) self.recv_orderPackage() - def send_orderPackage(self, pid, position): + def send_orderPackage(self, pids, position): self._oprot.writeMessageBegin('orderPackage', TMessageType.CALL, self._seqid) args = orderPackage_args() - args.pid = pid + args.pids = pids args.position = position args.write(self._oprot) self._oprot.writeMessageEnd() @@ -1809,116 +2377,185 @@ class Client(Iface): self._iprot.readMessageEnd() return - def orderFile(self, fid, position): + def orderFiles(self, fids, pid, position): """ Parameters: - - fid + - fids + - pid - position """ - self.send_orderFile(fid, position) - self.recv_orderFile() + self.send_orderFiles(fids, pid, position) + self.recv_orderFiles() - def send_orderFile(self, fid, position): - self._oprot.writeMessageBegin('orderFile', TMessageType.CALL, self._seqid) - args = orderFile_args() - args.fid = fid + def send_orderFiles(self, fids, pid, position): + self._oprot.writeMessageBegin('orderFiles', TMessageType.CALL, self._seqid) + args = orderFiles_args() + args.fids = fids + args.pid = pid args.position = position args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_orderFile(self, ): + def recv_orderFiles(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = orderFile_result() + result = orderFiles_result() result.read(self._iprot) self._iprot.readMessageEnd() return - def setPackageData(self, pid, data): + def isInteractionWaiting(self, mode): """ Parameters: - - pid - - data + - mode """ - self.send_setPackageData(pid, data) - self.recv_setPackageData() + self.send_isInteractionWaiting(mode) + return self.recv_isInteractionWaiting() - def send_setPackageData(self, pid, data): - self._oprot.writeMessageBegin('setPackageData', TMessageType.CALL, self._seqid) - args = setPackageData_args() - args.pid = pid - args.data = data + def send_isInteractionWaiting(self, mode): + self._oprot.writeMessageBegin('isInteractionWaiting', TMessageType.CALL, self._seqid) + args = isInteractionWaiting_args() + args.mode = mode args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_setPackageData(self, ): + def recv_isInteractionWaiting(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = setPackageData_result() + result = isInteractionWaiting_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.e is not None: - raise result.e - return + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "isInteractionWaiting failed: unknown result"); - def deleteFinished(self, ): - self.send_deleteFinished() - return self.recv_deleteFinished() + def getInteractionTask(self, mode): + """ + Parameters: + - mode + """ + self.send_getInteractionTask(mode) + return self.recv_getInteractionTask() - def send_deleteFinished(self, ): - self._oprot.writeMessageBegin('deleteFinished', TMessageType.CALL, self._seqid) - args = deleteFinished_args() + def send_getInteractionTask(self, mode): + self._oprot.writeMessageBegin('getInteractionTask', TMessageType.CALL, self._seqid) + args = getInteractionTask_args() + args.mode = mode args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_deleteFinished(self, ): + def recv_getInteractionTask(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = deleteFinished_result() + result = getInteractionTask_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteFinished failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getInteractionTask failed: unknown result"); - def restartFailed(self, ): - self.send_restartFailed() - self.recv_restartFailed() + def setInteractionResult(self, iid, result): + """ + Parameters: + - iid + - result + """ + self.send_setInteractionResult(iid, result) + self.recv_setInteractionResult() - def send_restartFailed(self, ): - self._oprot.writeMessageBegin('restartFailed', TMessageType.CALL, self._seqid) - args = restartFailed_args() + def send_setInteractionResult(self, iid, result): + self._oprot.writeMessageBegin('setInteractionResult', TMessageType.CALL, self._seqid) + args = setInteractionResult_args() + args.iid = iid + args.result = result args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_restartFailed(self, ): + def recv_setInteractionResult(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = restartFailed_result() + result = setInteractionResult_result() result.read(self._iprot) self._iprot.readMessageEnd() return + def generateDownloadLink(self, fid, timeout): + """ + Parameters: + - fid + - timeout + """ + self.send_generateDownloadLink(fid, timeout) + return self.recv_generateDownloadLink() + + def send_generateDownloadLink(self, fid, timeout): + self._oprot.writeMessageBegin('generateDownloadLink', TMessageType.CALL, self._seqid) + args = generateDownloadLink_args() + args.fid = fid + args.timeout = timeout + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_generateDownloadLink(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = generateDownloadLink_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "generateDownloadLink failed: unknown result"); + + def getNotifications(self, ): + self.send_getNotifications() + return self.recv_getNotifications() + + def send_getNotifications(self, ): + self._oprot.writeMessageBegin('getNotifications', TMessageType.CALL, self._seqid) + args = getNotifications_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getNotifications(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getNotifications_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getNotifications failed: unknown result"); + def getEvents(self, uuid): """ Parameters: @@ -2004,24 +2641,22 @@ class Client(Iface): return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getAccountTypes failed: unknown result"); - def updateAccount(self, plugin, account, password, options): + def updateAccount(self, plugin, account, password): """ Parameters: - plugin - account - password - - options """ - self.send_updateAccount(plugin, account, password, options) + self.send_updateAccount(plugin, account, password) self.recv_updateAccount() - def send_updateAccount(self, plugin, account, password, options): + def send_updateAccount(self, plugin, account, password): self._oprot.writeMessageBegin('updateAccount', TMessageType.CALL, self._seqid) args = updateAccount_args() args.plugin = plugin args.account = account args.password = password - args.options = options args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() @@ -2038,6 +2673,34 @@ class Client(Iface): self._iprot.readMessageEnd() return + def updateAccountInfo(self, account): + """ + Parameters: + - account + """ + self.send_updateAccountInfo(account) + self.recv_updateAccountInfo() + + def send_updateAccountInfo(self, account): + self._oprot.writeMessageBegin('updateAccountInfo', TMessageType.CALL, self._seqid) + args = updateAccountInfo_args() + args.account = account + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_updateAccountInfo(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = updateAccountInfo_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + return + def removeAccount(self, plugin, account): """ Parameters: @@ -2100,20 +2763,13 @@ class Client(Iface): return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "login failed: unknown result"); - def getUserData(self, username, password): - """ - Parameters: - - username - - password - """ - self.send_getUserData(username, password) + def getUserData(self, ): + self.send_getUserData() return self.recv_getUserData() - def send_getUserData(self, username, password): + def send_getUserData(self, ): self._oprot.writeMessageBegin('getUserData', TMessageType.CALL, self._seqid) args = getUserData_args() - args.username = username - args.password = password args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() @@ -2157,96 +2813,127 @@ class Client(Iface): return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllUserData failed: unknown result"); - def getServices(self, ): - self.send_getServices() - return self.recv_getServices() + def addUser(self, username, password): + """ + Parameters: + - username + - password + """ + self.send_addUser(username, password) + return self.recv_addUser() - def send_getServices(self, ): - self._oprot.writeMessageBegin('getServices', TMessageType.CALL, self._seqid) - args = getServices_args() + def send_addUser(self, username, password): + self._oprot.writeMessageBegin('addUser', TMessageType.CALL, self._seqid) + args = addUser_args() + args.username = username + args.password = password args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getServices(self, ): + def recv_addUser(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getServices_result() + result = addUser_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getServices failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "addUser failed: unknown result"); - def hasService(self, plugin, func): + def updateUserData(self, data): """ Parameters: - - plugin - - func + - data """ - self.send_hasService(plugin, func) - return self.recv_hasService() + self.send_updateUserData(data) + self.recv_updateUserData() - def send_hasService(self, plugin, func): - self._oprot.writeMessageBegin('hasService', TMessageType.CALL, self._seqid) - args = hasService_args() - args.plugin = plugin - args.func = func + def send_updateUserData(self, data): + self._oprot.writeMessageBegin('updateUserData', TMessageType.CALL, self._seqid) + args = updateUserData_args() + args.data = data args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_hasService(self, ): + def recv_updateUserData(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = hasService_result() + result = updateUserData_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "hasService failed: unknown result"); + return - def call(self, info): + def removeUser(self, uid): """ Parameters: - - info + - uid """ - self.send_call(info) - return self.recv_call() + self.send_removeUser(uid) + self.recv_removeUser() - def send_call(self, info): - self._oprot.writeMessageBegin('call', TMessageType.CALL, self._seqid) - args = call_args() - args.info = info + def send_removeUser(self, uid): + self._oprot.writeMessageBegin('removeUser', TMessageType.CALL, self._seqid) + args = removeUser_args() + args.uid = uid args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_call(self, ): + def recv_removeUser(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = call_result() + result = removeUser_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + return + + def setPassword(self, username, old_password, new_password): + """ + Parameters: + - username + - old_password + - new_password + """ + self.send_setPassword(username, old_password, new_password) + return self.recv_setPassword() + + def send_setPassword(self, username, old_password, new_password): + self._oprot.writeMessageBegin('setPassword', TMessageType.CALL, self._seqid) + args = setPassword_args() + args.username = username + args.old_password = old_password + args.new_password = new_password + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_setPassword(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = setPassword_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - if result.ex is not None: - raise result.ex - if result.e is not None: - raise result.e - raise TApplicationException(TApplicationException.MISSING_RESULT, "call failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "setPassword failed: unknown result"); def getAllInfo(self, ): self.send_getAllInfo() @@ -2303,119 +2990,133 @@ class Client(Iface): return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getInfoByPlugin failed: unknown result"); - def isCaptchaWaiting(self, ): - self.send_isCaptchaWaiting() - return self.recv_isCaptchaWaiting() + def getAddonHandler(self, ): + self.send_getAddonHandler() + return self.recv_getAddonHandler() - def send_isCaptchaWaiting(self, ): - self._oprot.writeMessageBegin('isCaptchaWaiting', TMessageType.CALL, self._seqid) - args = isCaptchaWaiting_args() + def send_getAddonHandler(self, ): + self._oprot.writeMessageBegin('getAddonHandler', TMessageType.CALL, self._seqid) + args = getAddonHandler_args() args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_isCaptchaWaiting(self, ): + def recv_getAddonHandler(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = isCaptchaWaiting_result() + result = getAddonHandler_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "isCaptchaWaiting failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "getAddonHandler failed: unknown result"); - def getCaptchaTask(self, exclusive): + def hasAddonHandler(self, plugin, func): """ Parameters: - - exclusive + - plugin + - func """ - self.send_getCaptchaTask(exclusive) - return self.recv_getCaptchaTask() + self.send_hasAddonHandler(plugin, func) + return self.recv_hasAddonHandler() - def send_getCaptchaTask(self, exclusive): - self._oprot.writeMessageBegin('getCaptchaTask', TMessageType.CALL, self._seqid) - args = getCaptchaTask_args() - args.exclusive = exclusive + def send_hasAddonHandler(self, plugin, func): + self._oprot.writeMessageBegin('hasAddonHandler', TMessageType.CALL, self._seqid) + args = hasAddonHandler_args() + args.plugin = plugin + args.func = func args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getCaptchaTask(self, ): + def recv_hasAddonHandler(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getCaptchaTask_result() + result = hasAddonHandler_result() result.read(self._iprot) self._iprot.readMessageEnd() if result.success is not None: return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getCaptchaTask failed: unknown result"); + raise TApplicationException(TApplicationException.MISSING_RESULT, "hasAddonHandler failed: unknown result"); - def getCaptchaTaskStatus(self, tid): + def callAddon(self, plugin, func, arguments): """ Parameters: - - tid + - plugin + - func + - arguments """ - self.send_getCaptchaTaskStatus(tid) - return self.recv_getCaptchaTaskStatus() + self.send_callAddon(plugin, func, arguments) + self.recv_callAddon() - def send_getCaptchaTaskStatus(self, tid): - self._oprot.writeMessageBegin('getCaptchaTaskStatus', TMessageType.CALL, self._seqid) - args = getCaptchaTaskStatus_args() - args.tid = tid + def send_callAddon(self, plugin, func, arguments): + self._oprot.writeMessageBegin('callAddon', TMessageType.CALL, self._seqid) + args = callAddon_args() + args.plugin = plugin + args.func = func + args.arguments = arguments args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_getCaptchaTaskStatus(self, ): + def recv_callAddon(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = getCaptchaTaskStatus_result() + result = callAddon_result() result.read(self._iprot) self._iprot.readMessageEnd() - if result.success is not None: - return result.success - raise TApplicationException(TApplicationException.MISSING_RESULT, "getCaptchaTaskStatus failed: unknown result"); + if result.e is not None: + raise result.e + if result.ex is not None: + raise result.ex + return - def setCaptchaResult(self, tid, result): + def callAddonHandler(self, plugin, func, pid_or_fid): """ Parameters: - - tid - - result + - plugin + - func + - pid_or_fid """ - self.send_setCaptchaResult(tid, result) - self.recv_setCaptchaResult() + self.send_callAddonHandler(plugin, func, pid_or_fid) + self.recv_callAddonHandler() - def send_setCaptchaResult(self, tid, result): - self._oprot.writeMessageBegin('setCaptchaResult', TMessageType.CALL, self._seqid) - args = setCaptchaResult_args() - args.tid = tid - args.result = result + def send_callAddonHandler(self, plugin, func, pid_or_fid): + self._oprot.writeMessageBegin('callAddonHandler', TMessageType.CALL, self._seqid) + args = callAddonHandler_args() + args.plugin = plugin + args.func = func + args.pid_or_fid = pid_or_fid args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_setCaptchaResult(self, ): + def recv_callAddonHandler(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = setCaptchaResult_result() + result = callAddonHandler_result() result.read(self._iprot) self._iprot.readMessageEnd() + if result.e is not None: + raise result.e + if result.ex is not None: + raise result.ex return @@ -2423,76 +3124,93 @@ class Processor(Iface, TProcessor): def __init__(self, handler): self._handler = handler self._processMap = {} - self._processMap["getConfigValue"] = Processor.process_getConfigValue - self._processMap["setConfigValue"] = Processor.process_setConfigValue - self._processMap["getConfig"] = Processor.process_getConfig - self._processMap["getPluginConfig"] = Processor.process_getPluginConfig + self._processMap["getServerVersion"] = Processor.process_getServerVersion + self._processMap["statusServer"] = Processor.process_statusServer self._processMap["pauseServer"] = Processor.process_pauseServer self._processMap["unpauseServer"] = Processor.process_unpauseServer self._processMap["togglePause"] = Processor.process_togglePause - self._processMap["statusServer"] = Processor.process_statusServer self._processMap["freeSpace"] = Processor.process_freeSpace - self._processMap["getServerVersion"] = Processor.process_getServerVersion self._processMap["kill"] = Processor.process_kill self._processMap["restart"] = Processor.process_restart self._processMap["getLog"] = Processor.process_getLog self._processMap["isTimeDownload"] = Processor.process_isTimeDownload self._processMap["isTimeReconnect"] = Processor.process_isTimeReconnect self._processMap["toggleReconnect"] = Processor.process_toggleReconnect - self._processMap["generatePackages"] = Processor.process_generatePackages + self._processMap["getProgressInfo"] = Processor.process_getProgressInfo + self._processMap["getConfig"] = Processor.process_getConfig + self._processMap["getGlobalPlugins"] = Processor.process_getGlobalPlugins + self._processMap["getUserPlugins"] = Processor.process_getUserPlugins + self._processMap["configurePlugin"] = Processor.process_configurePlugin + self._processMap["saveConfig"] = Processor.process_saveConfig + self._processMap["deleteConfig"] = Processor.process_deleteConfig + self._processMap["setConfigHandler"] = Processor.process_setConfigHandler self._processMap["checkURLs"] = Processor.process_checkURLs self._processMap["parseURLs"] = Processor.process_parseURLs self._processMap["checkOnlineStatus"] = Processor.process_checkOnlineStatus self._processMap["checkOnlineStatusContainer"] = Processor.process_checkOnlineStatusContainer self._processMap["pollResults"] = Processor.process_pollResults - self._processMap["statusDownloads"] = Processor.process_statusDownloads - self._processMap["getPackageData"] = Processor.process_getPackageData - self._processMap["getPackageInfo"] = Processor.process_getPackageInfo - self._processMap["getFileData"] = Processor.process_getFileData - self._processMap["getQueue"] = Processor.process_getQueue - self._processMap["getCollector"] = Processor.process_getCollector - self._processMap["getQueueData"] = Processor.process_getQueueData - self._processMap["getCollectorData"] = Processor.process_getCollectorData - self._processMap["getPackageOrder"] = Processor.process_getPackageOrder - self._processMap["getFileOrder"] = Processor.process_getFileOrder + self._processMap["generatePackages"] = Processor.process_generatePackages self._processMap["generateAndAddPackages"] = Processor.process_generateAndAddPackages + self._processMap["createPackage"] = Processor.process_createPackage self._processMap["addPackage"] = Processor.process_addPackage - self._processMap["addFiles"] = Processor.process_addFiles + self._processMap["addPackageP"] = Processor.process_addPackageP + self._processMap["addPackageChild"] = Processor.process_addPackageChild self._processMap["uploadContainer"] = Processor.process_uploadContainer + self._processMap["addLinks"] = Processor.process_addLinks + self._processMap["addLocalFile"] = Processor.process_addLocalFile self._processMap["deleteFiles"] = Processor.process_deleteFiles self._processMap["deletePackages"] = Processor.process_deletePackages - self._processMap["pushToQueue"] = Processor.process_pushToQueue - self._processMap["pullFromQueue"] = Processor.process_pullFromQueue + self._processMap["getCollector"] = Processor.process_getCollector + self._processMap["addToCollector"] = Processor.process_addToCollector + self._processMap["addFromCollector"] = Processor.process_addFromCollector + self._processMap["renameCollPack"] = Processor.process_renameCollPack + self._processMap["deleteCollPack"] = Processor.process_deleteCollPack + self._processMap["deleteCollLink"] = Processor.process_deleteCollLink + self._processMap["getAllFiles"] = Processor.process_getAllFiles + self._processMap["getAllUnfinishedFiles"] = Processor.process_getAllUnfinishedFiles + self._processMap["getFileTree"] = Processor.process_getFileTree + self._processMap["getUnfinishedFileTree"] = Processor.process_getUnfinishedFileTree + self._processMap["getPackageContent"] = Processor.process_getPackageContent + self._processMap["getPackageInfo"] = Processor.process_getPackageInfo + self._processMap["getFileInfo"] = Processor.process_getFileInfo + self._processMap["findFiles"] = Processor.process_findFiles self._processMap["restartPackage"] = Processor.process_restartPackage self._processMap["restartFile"] = Processor.process_restartFile self._processMap["recheckPackage"] = Processor.process_recheckPackage - self._processMap["stopAllDownloads"] = Processor.process_stopAllDownloads + self._processMap["restartFailed"] = Processor.process_restartFailed self._processMap["stopDownloads"] = Processor.process_stopDownloads - self._processMap["setPackageName"] = Processor.process_setPackageName + self._processMap["stopAllDownloads"] = Processor.process_stopAllDownloads + self._processMap["setPackagePaused"] = Processor.process_setPackagePaused + self._processMap["setPackageFolder"] = Processor.process_setPackageFolder + self._processMap["setPackageData"] = Processor.process_setPackageData self._processMap["movePackage"] = Processor.process_movePackage self._processMap["moveFiles"] = Processor.process_moveFiles self._processMap["orderPackage"] = Processor.process_orderPackage - self._processMap["orderFile"] = Processor.process_orderFile - self._processMap["setPackageData"] = Processor.process_setPackageData - self._processMap["deleteFinished"] = Processor.process_deleteFinished - self._processMap["restartFailed"] = Processor.process_restartFailed + self._processMap["orderFiles"] = Processor.process_orderFiles + self._processMap["isInteractionWaiting"] = Processor.process_isInteractionWaiting + self._processMap["getInteractionTask"] = Processor.process_getInteractionTask + self._processMap["setInteractionResult"] = Processor.process_setInteractionResult + self._processMap["generateDownloadLink"] = Processor.process_generateDownloadLink + self._processMap["getNotifications"] = Processor.process_getNotifications self._processMap["getEvents"] = Processor.process_getEvents self._processMap["getAccounts"] = Processor.process_getAccounts self._processMap["getAccountTypes"] = Processor.process_getAccountTypes self._processMap["updateAccount"] = Processor.process_updateAccount + self._processMap["updateAccountInfo"] = Processor.process_updateAccountInfo self._processMap["removeAccount"] = Processor.process_removeAccount self._processMap["login"] = Processor.process_login self._processMap["getUserData"] = Processor.process_getUserData self._processMap["getAllUserData"] = Processor.process_getAllUserData - self._processMap["getServices"] = Processor.process_getServices - self._processMap["hasService"] = Processor.process_hasService - self._processMap["call"] = Processor.process_call + self._processMap["addUser"] = Processor.process_addUser + self._processMap["updateUserData"] = Processor.process_updateUserData + self._processMap["removeUser"] = Processor.process_removeUser + self._processMap["setPassword"] = Processor.process_setPassword self._processMap["getAllInfo"] = Processor.process_getAllInfo self._processMap["getInfoByPlugin"] = Processor.process_getInfoByPlugin - self._processMap["isCaptchaWaiting"] = Processor.process_isCaptchaWaiting - self._processMap["getCaptchaTask"] = Processor.process_getCaptchaTask - self._processMap["getCaptchaTaskStatus"] = Processor.process_getCaptchaTaskStatus - self._processMap["setCaptchaResult"] = Processor.process_setCaptchaResult + self._processMap["getAddonHandler"] = Processor.process_getAddonHandler + self._processMap["hasAddonHandler"] = Processor.process_hasAddonHandler + self._processMap["callAddon"] = Processor.process_callAddon + self._processMap["callAddonHandler"] = Processor.process_callAddonHandler def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() @@ -2509,46 +3227,24 @@ class Processor(Iface, TProcessor): self._processMap[name](self, seqid, iprot, oprot) return True - def process_getConfigValue(self, seqid, iprot, oprot): - args = getConfigValue_args() - args.read(iprot) - iprot.readMessageEnd() - result = getConfigValue_result() - result.success = self._handler.getConfigValue(args.category, args.option, args.section) - oprot.writeMessageBegin("getConfigValue", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_setConfigValue(self, seqid, iprot, oprot): - args = setConfigValue_args() - args.read(iprot) - iprot.readMessageEnd() - result = setConfigValue_result() - self._handler.setConfigValue(args.category, args.option, args.value, args.section) - oprot.writeMessageBegin("setConfigValue", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - - def process_getConfig(self, seqid, iprot, oprot): - args = getConfig_args() + def process_getServerVersion(self, seqid, iprot, oprot): + args = getServerVersion_args() args.read(iprot) iprot.readMessageEnd() - result = getConfig_result() - result.success = self._handler.getConfig() - oprot.writeMessageBegin("getConfig", TMessageType.REPLY, seqid) + result = getServerVersion_result() + result.success = self._handler.getServerVersion() + oprot.writeMessageBegin("getServerVersion", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getPluginConfig(self, seqid, iprot, oprot): - args = getPluginConfig_args() + def process_statusServer(self, seqid, iprot, oprot): + args = statusServer_args() args.read(iprot) iprot.readMessageEnd() - result = getPluginConfig_result() - result.success = self._handler.getPluginConfig() - oprot.writeMessageBegin("getPluginConfig", TMessageType.REPLY, seqid) + result = statusServer_result() + result.success = self._handler.statusServer() + oprot.writeMessageBegin("statusServer", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -2586,17 +3282,6 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_statusServer(self, seqid, iprot, oprot): - args = statusServer_args() - args.read(iprot) - iprot.readMessageEnd() - result = statusServer_result() - result.success = self._handler.statusServer() - oprot.writeMessageBegin("statusServer", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - def process_freeSpace(self, seqid, iprot, oprot): args = freeSpace_args() args.read(iprot) @@ -2608,17 +3293,6 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_getServerVersion(self, seqid, iprot, oprot): - args = getServerVersion_args() - args.read(iprot) - iprot.readMessageEnd() - result = getServerVersion_result() - result.success = self._handler.getServerVersion() - oprot.writeMessageBegin("getServerVersion", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() - def process_kill(self, seqid, iprot, oprot): args = kill_args() args.read(iprot) @@ -2685,13 +3359,90 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_generatePackages(self, seqid, iprot, oprot): - args = generatePackages_args() + def process_getProgressInfo(self, seqid, iprot, oprot): + args = getProgressInfo_args() args.read(iprot) iprot.readMessageEnd() - result = generatePackages_result() - result.success = self._handler.generatePackages(args.links) - oprot.writeMessageBegin("generatePackages", TMessageType.REPLY, seqid) + result = getProgressInfo_result() + result.success = self._handler.getProgressInfo() + oprot.writeMessageBegin("getProgressInfo", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_getConfig(self, seqid, iprot, oprot): + args = getConfig_args() + args.read(iprot) + iprot.readMessageEnd() + result = getConfig_result() + result.success = self._handler.getConfig() + oprot.writeMessageBegin("getConfig", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_getGlobalPlugins(self, seqid, iprot, oprot): + args = getGlobalPlugins_args() + args.read(iprot) + iprot.readMessageEnd() + result = getGlobalPlugins_result() + result.success = self._handler.getGlobalPlugins() + oprot.writeMessageBegin("getGlobalPlugins", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_getUserPlugins(self, seqid, iprot, oprot): + args = getUserPlugins_args() + args.read(iprot) + iprot.readMessageEnd() + result = getUserPlugins_result() + result.success = self._handler.getUserPlugins() + oprot.writeMessageBegin("getUserPlugins", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_configurePlugin(self, seqid, iprot, oprot): + args = configurePlugin_args() + args.read(iprot) + iprot.readMessageEnd() + result = configurePlugin_result() + result.success = self._handler.configurePlugin(args.plugin) + oprot.writeMessageBegin("configurePlugin", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_saveConfig(self, seqid, iprot, oprot): + args = saveConfig_args() + args.read(iprot) + iprot.readMessageEnd() + result = saveConfig_result() + self._handler.saveConfig(args.config) + oprot.writeMessageBegin("saveConfig", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_deleteConfig(self, seqid, iprot, oprot): + args = deleteConfig_args() + args.read(iprot) + iprot.readMessageEnd() + result = deleteConfig_result() + self._handler.deleteConfig(args.plugin) + oprot.writeMessageBegin("deleteConfig", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_setConfigHandler(self, seqid, iprot, oprot): + args = setConfigHandler_args() + args.read(iprot) + iprot.readMessageEnd() + result = setConfigHandler_result() + self._handler.setConfigHandler(args.plugin, args.iid, args.value) + oprot.writeMessageBegin("setConfigHandler", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -2751,66 +3502,129 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_statusDownloads(self, seqid, iprot, oprot): - args = statusDownloads_args() + def process_generatePackages(self, seqid, iprot, oprot): + args = generatePackages_args() + args.read(iprot) + iprot.readMessageEnd() + result = generatePackages_result() + result.success = self._handler.generatePackages(args.links) + oprot.writeMessageBegin("generatePackages", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_generateAndAddPackages(self, seqid, iprot, oprot): + args = generateAndAddPackages_args() + args.read(iprot) + iprot.readMessageEnd() + result = generateAndAddPackages_result() + result.success = self._handler.generateAndAddPackages(args.links, args.paused) + oprot.writeMessageBegin("generateAndAddPackages", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_createPackage(self, seqid, iprot, oprot): + args = createPackage_args() + args.read(iprot) + iprot.readMessageEnd() + result = createPackage_result() + result.success = self._handler.createPackage(args.name, args.folder, args.root, args.password, args.site, args.comment, args.paused) + oprot.writeMessageBegin("createPackage", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_addPackage(self, seqid, iprot, oprot): + args = addPackage_args() + args.read(iprot) + iprot.readMessageEnd() + result = addPackage_result() + result.success = self._handler.addPackage(args.name, args.links, args.password) + oprot.writeMessageBegin("addPackage", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_addPackageP(self, seqid, iprot, oprot): + args = addPackageP_args() + args.read(iprot) + iprot.readMessageEnd() + result = addPackageP_result() + result.success = self._handler.addPackageP(args.name, args.links, args.password, args.paused) + oprot.writeMessageBegin("addPackageP", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_addPackageChild(self, seqid, iprot, oprot): + args = addPackageChild_args() + args.read(iprot) + iprot.readMessageEnd() + result = addPackageChild_result() + result.success = self._handler.addPackageChild(args.name, args.links, args.password, args.root, args.paused) + oprot.writeMessageBegin("addPackageChild", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_uploadContainer(self, seqid, iprot, oprot): + args = uploadContainer_args() args.read(iprot) iprot.readMessageEnd() - result = statusDownloads_result() - result.success = self._handler.statusDownloads() - oprot.writeMessageBegin("statusDownloads", TMessageType.REPLY, seqid) + result = uploadContainer_result() + result.success = self._handler.uploadContainer(args.filename, args.data) + oprot.writeMessageBegin("uploadContainer", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getPackageData(self, seqid, iprot, oprot): - args = getPackageData_args() + def process_addLinks(self, seqid, iprot, oprot): + args = addLinks_args() args.read(iprot) iprot.readMessageEnd() - result = getPackageData_result() + result = addLinks_result() try: - result.success = self._handler.getPackageData(args.pid) + self._handler.addLinks(args.pid, args.links) except PackageDoesNotExists, e: result.e = e - oprot.writeMessageBegin("getPackageData", TMessageType.REPLY, seqid) + oprot.writeMessageBegin("addLinks", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getPackageInfo(self, seqid, iprot, oprot): - args = getPackageInfo_args() + def process_addLocalFile(self, seqid, iprot, oprot): + args = addLocalFile_args() args.read(iprot) iprot.readMessageEnd() - result = getPackageInfo_result() + result = addLocalFile_result() try: - result.success = self._handler.getPackageInfo(args.pid) + self._handler.addLocalFile(args.pid, args.name, args.path) except PackageDoesNotExists, e: result.e = e - oprot.writeMessageBegin("getPackageInfo", TMessageType.REPLY, seqid) + oprot.writeMessageBegin("addLocalFile", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getFileData(self, seqid, iprot, oprot): - args = getFileData_args() + def process_deleteFiles(self, seqid, iprot, oprot): + args = deleteFiles_args() args.read(iprot) iprot.readMessageEnd() - result = getFileData_result() - try: - result.success = self._handler.getFileData(args.fid) - except FileDoesNotExists, e: - result.e = e - oprot.writeMessageBegin("getFileData", TMessageType.REPLY, seqid) + result = deleteFiles_result() + self._handler.deleteFiles(args.fids) + oprot.writeMessageBegin("deleteFiles", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getQueue(self, seqid, iprot, oprot): - args = getQueue_args() + def process_deletePackages(self, seqid, iprot, oprot): + args = deletePackages_args() args.read(iprot) iprot.readMessageEnd() - result = getQueue_result() - result.success = self._handler.getQueue() - oprot.writeMessageBegin("getQueue", TMessageType.REPLY, seqid) + result = deletePackages_result() + self._handler.deletePackages(args.pids) + oprot.writeMessageBegin("deletePackages", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -2826,134 +3640,151 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_getQueueData(self, seqid, iprot, oprot): - args = getQueueData_args() + def process_addToCollector(self, seqid, iprot, oprot): + args = addToCollector_args() args.read(iprot) iprot.readMessageEnd() - result = getQueueData_result() - result.success = self._handler.getQueueData() - oprot.writeMessageBegin("getQueueData", TMessageType.REPLY, seqid) + result = addToCollector_result() + self._handler.addToCollector(args.links) + oprot.writeMessageBegin("addToCollector", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getCollectorData(self, seqid, iprot, oprot): - args = getCollectorData_args() + def process_addFromCollector(self, seqid, iprot, oprot): + args = addFromCollector_args() args.read(iprot) iprot.readMessageEnd() - result = getCollectorData_result() - result.success = self._handler.getCollectorData() - oprot.writeMessageBegin("getCollectorData", TMessageType.REPLY, seqid) + result = addFromCollector_result() + result.success = self._handler.addFromCollector(args.name, args.paused) + oprot.writeMessageBegin("addFromCollector", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getPackageOrder(self, seqid, iprot, oprot): - args = getPackageOrder_args() + def process_renameCollPack(self, seqid, iprot, oprot): + args = renameCollPack_args() args.read(iprot) iprot.readMessageEnd() - result = getPackageOrder_result() - result.success = self._handler.getPackageOrder(args.destination) - oprot.writeMessageBegin("getPackageOrder", TMessageType.REPLY, seqid) + result = renameCollPack_result() + self._handler.renameCollPack(args.name, args.new_name) + oprot.writeMessageBegin("renameCollPack", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getFileOrder(self, seqid, iprot, oprot): - args = getFileOrder_args() + def process_deleteCollPack(self, seqid, iprot, oprot): + args = deleteCollPack_args() args.read(iprot) iprot.readMessageEnd() - result = getFileOrder_result() - result.success = self._handler.getFileOrder(args.pid) - oprot.writeMessageBegin("getFileOrder", TMessageType.REPLY, seqid) + result = deleteCollPack_result() + self._handler.deleteCollPack(args.name) + oprot.writeMessageBegin("deleteCollPack", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_generateAndAddPackages(self, seqid, iprot, oprot): - args = generateAndAddPackages_args() + def process_deleteCollLink(self, seqid, iprot, oprot): + args = deleteCollLink_args() args.read(iprot) iprot.readMessageEnd() - result = generateAndAddPackages_result() - result.success = self._handler.generateAndAddPackages(args.links, args.dest) - oprot.writeMessageBegin("generateAndAddPackages", TMessageType.REPLY, seqid) + result = deleteCollLink_result() + self._handler.deleteCollLink(args.url) + oprot.writeMessageBegin("deleteCollLink", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_addPackage(self, seqid, iprot, oprot): - args = addPackage_args() + def process_getAllFiles(self, seqid, iprot, oprot): + args = getAllFiles_args() args.read(iprot) iprot.readMessageEnd() - result = addPackage_result() - result.success = self._handler.addPackage(args.name, args.links, args.dest) - oprot.writeMessageBegin("addPackage", TMessageType.REPLY, seqid) + result = getAllFiles_result() + result.success = self._handler.getAllFiles() + oprot.writeMessageBegin("getAllFiles", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_addFiles(self, seqid, iprot, oprot): - args = addFiles_args() + def process_getAllUnfinishedFiles(self, seqid, iprot, oprot): + args = getAllUnfinishedFiles_args() args.read(iprot) iprot.readMessageEnd() - result = addFiles_result() - self._handler.addFiles(args.pid, args.links) - oprot.writeMessageBegin("addFiles", TMessageType.REPLY, seqid) + result = getAllUnfinishedFiles_result() + result.success = self._handler.getAllUnfinishedFiles() + oprot.writeMessageBegin("getAllUnfinishedFiles", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_uploadContainer(self, seqid, iprot, oprot): - args = uploadContainer_args() + def process_getFileTree(self, seqid, iprot, oprot): + args = getFileTree_args() args.read(iprot) iprot.readMessageEnd() - result = uploadContainer_result() - self._handler.uploadContainer(args.filename, args.data) - oprot.writeMessageBegin("uploadContainer", TMessageType.REPLY, seqid) + result = getFileTree_result() + result.success = self._handler.getFileTree(args.pid, args.full) + oprot.writeMessageBegin("getFileTree", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_deleteFiles(self, seqid, iprot, oprot): - args = deleteFiles_args() + def process_getUnfinishedFileTree(self, seqid, iprot, oprot): + args = getUnfinishedFileTree_args() args.read(iprot) iprot.readMessageEnd() - result = deleteFiles_result() - self._handler.deleteFiles(args.fids) - oprot.writeMessageBegin("deleteFiles", TMessageType.REPLY, seqid) + result = getUnfinishedFileTree_result() + result.success = self._handler.getUnfinishedFileTree(args.pid, args.full) + oprot.writeMessageBegin("getUnfinishedFileTree", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_deletePackages(self, seqid, iprot, oprot): - args = deletePackages_args() + def process_getPackageContent(self, seqid, iprot, oprot): + args = getPackageContent_args() args.read(iprot) iprot.readMessageEnd() - result = deletePackages_result() - self._handler.deletePackages(args.pids) - oprot.writeMessageBegin("deletePackages", TMessageType.REPLY, seqid) + result = getPackageContent_result() + result.success = self._handler.getPackageContent(args.pid) + oprot.writeMessageBegin("getPackageContent", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_getPackageInfo(self, seqid, iprot, oprot): + args = getPackageInfo_args() + args.read(iprot) + iprot.readMessageEnd() + result = getPackageInfo_result() + try: + result.success = self._handler.getPackageInfo(args.pid) + except PackageDoesNotExists, e: + result.e = e + oprot.writeMessageBegin("getPackageInfo", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_pushToQueue(self, seqid, iprot, oprot): - args = pushToQueue_args() + def process_getFileInfo(self, seqid, iprot, oprot): + args = getFileInfo_args() args.read(iprot) iprot.readMessageEnd() - result = pushToQueue_result() - self._handler.pushToQueue(args.pid) - oprot.writeMessageBegin("pushToQueue", TMessageType.REPLY, seqid) + result = getFileInfo_result() + try: + result.success = self._handler.getFileInfo(args.fid) + except FileDoesNotExists, e: + result.e = e + oprot.writeMessageBegin("getFileInfo", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_pullFromQueue(self, seqid, iprot, oprot): - args = pullFromQueue_args() + def process_findFiles(self, seqid, iprot, oprot): + args = findFiles_args() args.read(iprot) iprot.readMessageEnd() - result = pullFromQueue_result() - self._handler.pullFromQueue(args.pid) - oprot.writeMessageBegin("pullFromQueue", TMessageType.REPLY, seqid) + result = findFiles_result() + result.success = self._handler.findFiles(args.pattern) + oprot.writeMessageBegin("findFiles", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -2991,13 +3822,13 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_stopAllDownloads(self, seqid, iprot, oprot): - args = stopAllDownloads_args() + def process_restartFailed(self, seqid, iprot, oprot): + args = restartFailed_args() args.read(iprot) iprot.readMessageEnd() - result = stopAllDownloads_result() - self._handler.stopAllDownloads() - oprot.writeMessageBegin("stopAllDownloads", TMessageType.REPLY, seqid) + result = restartFailed_result() + self._handler.restartFailed() + oprot.writeMessageBegin("restartFailed", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -3013,13 +3844,55 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_setPackageName(self, seqid, iprot, oprot): - args = setPackageName_args() + def process_stopAllDownloads(self, seqid, iprot, oprot): + args = stopAllDownloads_args() + args.read(iprot) + iprot.readMessageEnd() + result = stopAllDownloads_result() + self._handler.stopAllDownloads() + oprot.writeMessageBegin("stopAllDownloads", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_setPackagePaused(self, seqid, iprot, oprot): + args = setPackagePaused_args() + args.read(iprot) + iprot.readMessageEnd() + result = setPackagePaused_result() + try: + self._handler.setPackagePaused(args.pid, args.paused) + except PackageDoesNotExists, e: + result.e = e + oprot.writeMessageBegin("setPackagePaused", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_setPackageFolder(self, seqid, iprot, oprot): + args = setPackageFolder_args() args.read(iprot) iprot.readMessageEnd() - result = setPackageName_result() - self._handler.setPackageName(args.pid, args.name) - oprot.writeMessageBegin("setPackageName", TMessageType.REPLY, seqid) + result = setPackageFolder_result() + try: + result.success = self._handler.setPackageFolder(args.pid, args.path) + except PackageDoesNotExists, e: + result.e = e + oprot.writeMessageBegin("setPackageFolder", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_setPackageData(self, seqid, iprot, oprot): + args = setPackageData_args() + args.read(iprot) + iprot.readMessageEnd() + result = setPackageData_result() + try: + self._handler.setPackageData(args.pid, args.data) + except PackageDoesNotExists, e: + result.e = e + oprot.writeMessageBegin("setPackageData", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -3029,7 +3902,10 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = movePackage_result() - self._handler.movePackage(args.destination, args.pid) + try: + result.success = self._handler.movePackage(args.pid, args.root) + except PackageDoesNotExists, e: + result.e = e oprot.writeMessageBegin("movePackage", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() @@ -3040,7 +3916,10 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = moveFiles_result() - self._handler.moveFiles(args.fids, args.pid) + try: + result.success = self._handler.moveFiles(args.fids, args.pid) + except PackageDoesNotExists, e: + result.e = e oprot.writeMessageBegin("moveFiles", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() @@ -3051,55 +3930,74 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = orderPackage_result() - self._handler.orderPackage(args.pid, args.position) + self._handler.orderPackage(args.pids, args.position) oprot.writeMessageBegin("orderPackage", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_orderFile(self, seqid, iprot, oprot): - args = orderFile_args() + def process_orderFiles(self, seqid, iprot, oprot): + args = orderFiles_args() args.read(iprot) iprot.readMessageEnd() - result = orderFile_result() - self._handler.orderFile(args.fid, args.position) - oprot.writeMessageBegin("orderFile", TMessageType.REPLY, seqid) + result = orderFiles_result() + self._handler.orderFiles(args.fids, args.pid, args.position) + oprot.writeMessageBegin("orderFiles", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_setPackageData(self, seqid, iprot, oprot): - args = setPackageData_args() + def process_isInteractionWaiting(self, seqid, iprot, oprot): + args = isInteractionWaiting_args() args.read(iprot) iprot.readMessageEnd() - result = setPackageData_result() - try: - self._handler.setPackageData(args.pid, args.data) - except PackageDoesNotExists, e: - result.e = e - oprot.writeMessageBegin("setPackageData", TMessageType.REPLY, seqid) + result = isInteractionWaiting_result() + result.success = self._handler.isInteractionWaiting(args.mode) + oprot.writeMessageBegin("isInteractionWaiting", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_deleteFinished(self, seqid, iprot, oprot): - args = deleteFinished_args() + def process_getInteractionTask(self, seqid, iprot, oprot): + args = getInteractionTask_args() args.read(iprot) iprot.readMessageEnd() - result = deleteFinished_result() - result.success = self._handler.deleteFinished() - oprot.writeMessageBegin("deleteFinished", TMessageType.REPLY, seqid) + result = getInteractionTask_result() + result.success = self._handler.getInteractionTask(args.mode) + oprot.writeMessageBegin("getInteractionTask", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_restartFailed(self, seqid, iprot, oprot): - args = restartFailed_args() + def process_setInteractionResult(self, seqid, iprot, oprot): + args = setInteractionResult_args() args.read(iprot) iprot.readMessageEnd() - result = restartFailed_result() - self._handler.restartFailed() - oprot.writeMessageBegin("restartFailed", TMessageType.REPLY, seqid) + result = setInteractionResult_result() + self._handler.setInteractionResult(args.iid, args.result) + oprot.writeMessageBegin("setInteractionResult", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_generateDownloadLink(self, seqid, iprot, oprot): + args = generateDownloadLink_args() + args.read(iprot) + iprot.readMessageEnd() + result = generateDownloadLink_result() + result.success = self._handler.generateDownloadLink(args.fid, args.timeout) + oprot.writeMessageBegin("generateDownloadLink", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_getNotifications(self, seqid, iprot, oprot): + args = getNotifications_args() + args.read(iprot) + iprot.readMessageEnd() + result = getNotifications_result() + result.success = self._handler.getNotifications() + oprot.writeMessageBegin("getNotifications", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -3142,12 +4040,23 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = updateAccount_result() - self._handler.updateAccount(args.plugin, args.account, args.password, args.options) + self._handler.updateAccount(args.plugin, args.account, args.password) oprot.writeMessageBegin("updateAccount", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() + def process_updateAccountInfo(self, seqid, iprot, oprot): + args = updateAccountInfo_args() + args.read(iprot) + iprot.readMessageEnd() + result = updateAccountInfo_result() + self._handler.updateAccountInfo(args.account) + oprot.writeMessageBegin("updateAccountInfo", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_removeAccount(self, seqid, iprot, oprot): args = removeAccount_args() args.read(iprot) @@ -3175,7 +4084,7 @@ class Processor(Iface, TProcessor): args.read(iprot) iprot.readMessageEnd() result = getUserData_result() - result.success = self._handler.getUserData(args.username, args.password) + result.success = self._handler.getUserData() oprot.writeMessageBegin("getUserData", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() @@ -3192,40 +4101,46 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_getServices(self, seqid, iprot, oprot): - args = getServices_args() + def process_addUser(self, seqid, iprot, oprot): + args = addUser_args() args.read(iprot) iprot.readMessageEnd() - result = getServices_result() - result.success = self._handler.getServices() - oprot.writeMessageBegin("getServices", TMessageType.REPLY, seqid) + result = addUser_result() + result.success = self._handler.addUser(args.username, args.password) + oprot.writeMessageBegin("addUser", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_hasService(self, seqid, iprot, oprot): - args = hasService_args() + def process_updateUserData(self, seqid, iprot, oprot): + args = updateUserData_args() args.read(iprot) iprot.readMessageEnd() - result = hasService_result() - result.success = self._handler.hasService(args.plugin, args.func) - oprot.writeMessageBegin("hasService", TMessageType.REPLY, seqid) + result = updateUserData_result() + self._handler.updateUserData(args.data) + oprot.writeMessageBegin("updateUserData", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_call(self, seqid, iprot, oprot): - args = call_args() + def process_removeUser(self, seqid, iprot, oprot): + args = removeUser_args() args.read(iprot) iprot.readMessageEnd() - result = call_result() - try: - result.success = self._handler.call(args.info) - except ServiceDoesNotExists, ex: - result.ex = ex - except ServiceException, e: - result.e = e - oprot.writeMessageBegin("call", TMessageType.REPLY, seqid) + result = removeUser_result() + self._handler.removeUser(args.uid) + oprot.writeMessageBegin("removeUser", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_setPassword(self, seqid, iprot, oprot): + args = setPassword_args() + args.read(iprot) + iprot.readMessageEnd() + result = setPassword_result() + result.success = self._handler.setPassword(args.username, args.old_password, args.new_password) + oprot.writeMessageBegin("setPassword", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -3252,46 +4167,56 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() - def process_isCaptchaWaiting(self, seqid, iprot, oprot): - args = isCaptchaWaiting_args() + def process_getAddonHandler(self, seqid, iprot, oprot): + args = getAddonHandler_args() args.read(iprot) iprot.readMessageEnd() - result = isCaptchaWaiting_result() - result.success = self._handler.isCaptchaWaiting() - oprot.writeMessageBegin("isCaptchaWaiting", TMessageType.REPLY, seqid) + result = getAddonHandler_result() + result.success = self._handler.getAddonHandler() + oprot.writeMessageBegin("getAddonHandler", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getCaptchaTask(self, seqid, iprot, oprot): - args = getCaptchaTask_args() + def process_hasAddonHandler(self, seqid, iprot, oprot): + args = hasAddonHandler_args() args.read(iprot) iprot.readMessageEnd() - result = getCaptchaTask_result() - result.success = self._handler.getCaptchaTask(args.exclusive) - oprot.writeMessageBegin("getCaptchaTask", TMessageType.REPLY, seqid) + result = hasAddonHandler_result() + result.success = self._handler.hasAddonHandler(args.plugin, args.func) + oprot.writeMessageBegin("hasAddonHandler", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_getCaptchaTaskStatus(self, seqid, iprot, oprot): - args = getCaptchaTaskStatus_args() + def process_callAddon(self, seqid, iprot, oprot): + args = callAddon_args() args.read(iprot) iprot.readMessageEnd() - result = getCaptchaTaskStatus_result() - result.success = self._handler.getCaptchaTaskStatus(args.tid) - oprot.writeMessageBegin("getCaptchaTaskStatus", TMessageType.REPLY, seqid) + result = callAddon_result() + try: + self._handler.callAddon(args.plugin, args.func, args.arguments) + except ServiceDoesNotExists, e: + result.e = e + except ServiceException, ex: + result.ex = ex + oprot.writeMessageBegin("callAddon", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() - def process_setCaptchaResult(self, seqid, iprot, oprot): - args = setCaptchaResult_args() + def process_callAddonHandler(self, seqid, iprot, oprot): + args = callAddonHandler_args() args.read(iprot) iprot.readMessageEnd() - result = setCaptchaResult_result() - self._handler.setCaptchaResult(args.tid, args.result) - oprot.writeMessageBegin("setCaptchaResult", TMessageType.REPLY, seqid) + result = callAddonHandler_result() + try: + self._handler.callAddonHandler(args.plugin, args.func, args.pid_or_fid) + except ServiceDoesNotExists, e: + result.e = e + except ServiceException, ex: + result.ex = ex + oprot.writeMessageBegin("callAddonHandler", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -3299,34 +4224,16 @@ class Processor(Iface, TProcessor): # HELPER FUNCTIONS AND STRUCTURES -class getConfigValue_args(TBase): - """ - Attributes: - - category - - option - - section - """ +class getServerVersion_args(TBase): __slots__ = [ - 'category', - 'option', - 'section', ] thrift_spec = ( - None, # 0 - (1, TType.STRING, 'category', None, None, ), # 1 - (2, TType.STRING, 'option', None, None, ), # 2 - (3, TType.STRING, 'section', None, None, ), # 3 ) - def __init__(self, category=None, option=None, section=None,): - self.category = category - self.option = option - self.section = section - -class getConfigValue_result(TBase): +class getServerVersion_result(TBase): """ Attributes: - success @@ -3344,38 +4251,34 @@ class getConfigValue_result(TBase): self.success = success -class setConfigValue_args(TBase): +class statusServer_args(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class statusServer_result(TBase): """ Attributes: - - category - - option - - value - - section + - success """ __slots__ = [ - 'category', - 'option', - 'value', - 'section', + 'success', ] thrift_spec = ( - None, # 0 - (1, TType.STRING, 'category', None, None, ), # 1 - (2, TType.STRING, 'option', None, None, ), # 2 - (3, TType.STRING, 'value', None, None, ), # 3 - (4, TType.STRING, 'section', None, None, ), # 4 + (0, TType.STRUCT, 'success', (ServerStatus, ServerStatus.thrift_spec), None, ), # 0 ) - def __init__(self, category=None, option=None, value=None, section=None,): - self.category = category - self.option = option - self.value = value - self.section = section + def __init__(self, success=None,): + self.success = success -class setConfigValue_result(TBase): +class pauseServer_args(TBase): __slots__ = [ ] @@ -3384,7 +4287,7 @@ class setConfigValue_result(TBase): ) -class getConfig_args(TBase): +class pauseServer_result(TBase): __slots__ = [ ] @@ -3393,7 +4296,34 @@ class getConfig_args(TBase): ) -class getConfig_result(TBase): +class unpauseServer_args(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class unpauseServer_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class togglePause_args(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class togglePause_result(TBase): """ Attributes: - success @@ -3404,14 +4334,14 @@ class getConfig_result(TBase): ] thrift_spec = ( - (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(ConfigSection, ConfigSection.thrift_spec)), None, ), # 0 + (0, TType.BOOL, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class getPluginConfig_args(TBase): +class freeSpace_args(TBase): __slots__ = [ ] @@ -3420,7 +4350,7 @@ class getPluginConfig_args(TBase): ) -class getPluginConfig_result(TBase): +class freeSpace_result(TBase): """ Attributes: - success @@ -3431,14 +4361,14 @@ class getPluginConfig_result(TBase): ] thrift_spec = ( - (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(ConfigSection, ConfigSection.thrift_spec)), None, ), # 0 + (0, TType.I64, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class pauseServer_args(TBase): +class kill_args(TBase): __slots__ = [ ] @@ -3447,7 +4377,7 @@ class pauseServer_args(TBase): ) -class pauseServer_result(TBase): +class kill_result(TBase): __slots__ = [ ] @@ -3456,7 +4386,7 @@ class pauseServer_result(TBase): ) -class unpauseServer_args(TBase): +class restart_args(TBase): __slots__ = [ ] @@ -3465,7 +4395,7 @@ class unpauseServer_args(TBase): ) -class unpauseServer_result(TBase): +class restart_result(TBase): __slots__ = [ ] @@ -3474,16 +4404,26 @@ class unpauseServer_result(TBase): ) -class togglePause_args(TBase): +class getLog_args(TBase): + """ + Attributes: + - offset + """ __slots__ = [ + 'offset', ] thrift_spec = ( + None, # 0 + (1, TType.I32, 'offset', None, None, ), # 1 ) + def __init__(self, offset=None,): + self.offset = offset -class togglePause_result(TBase): + +class getLog_result(TBase): """ Attributes: - success @@ -3494,14 +4434,14 @@ class togglePause_result(TBase): ] thrift_spec = ( - (0, TType.BOOL, 'success', None, None, ), # 0 + (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0 ) def __init__(self, success=None,): self.success = success -class statusServer_args(TBase): +class isTimeDownload_args(TBase): __slots__ = [ ] @@ -3510,7 +4450,7 @@ class statusServer_args(TBase): ) -class statusServer_result(TBase): +class isTimeDownload_result(TBase): """ Attributes: - success @@ -3521,14 +4461,14 @@ class statusServer_result(TBase): ] thrift_spec = ( - (0, TType.STRUCT, 'success', (ServerStatus, ServerStatus.thrift_spec), None, ), # 0 + (0, TType.BOOL, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class freeSpace_args(TBase): +class isTimeReconnect_args(TBase): __slots__ = [ ] @@ -3537,7 +4477,7 @@ class freeSpace_args(TBase): ) -class freeSpace_result(TBase): +class isTimeReconnect_result(TBase): """ Attributes: - success @@ -3548,14 +4488,14 @@ class freeSpace_result(TBase): ] thrift_spec = ( - (0, TType.I64, 'success', None, None, ), # 0 + (0, TType.BOOL, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class getServerVersion_args(TBase): +class toggleReconnect_args(TBase): __slots__ = [ ] @@ -3564,7 +4504,7 @@ class getServerVersion_args(TBase): ) -class getServerVersion_result(TBase): +class toggleReconnect_result(TBase): """ Attributes: - success @@ -3575,14 +4515,14 @@ class getServerVersion_result(TBase): ] thrift_spec = ( - (0, TType.STRING, 'success', None, None, ), # 0 + (0, TType.BOOL, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class kill_args(TBase): +class getProgressInfo_args(TBase): __slots__ = [ ] @@ -3591,16 +4531,25 @@ class kill_args(TBase): ) -class kill_result(TBase): +class getProgressInfo_result(TBase): + """ + Attributes: + - success + """ __slots__ = [ + 'success', ] thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRUCT,(ProgressInfo, ProgressInfo.thrift_spec)), None, ), # 0 ) + def __init__(self, success=None,): + self.success = success -class restart_args(TBase): + +class getConfig_args(TBase): __slots__ = [ ] @@ -3609,35 +4558,34 @@ class restart_args(TBase): ) -class restart_result(TBase): +class getConfig_result(TBase): + """ + Attributes: + - success + """ __slots__ = [ + 'success', ] thrift_spec = ( + (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(ConfigHolder, ConfigHolder.thrift_spec)), None, ), # 0 ) + def __init__(self, success=None,): + self.success = success -class getLog_args(TBase): - """ - Attributes: - - offset - """ + +class getGlobalPlugins_args(TBase): __slots__ = [ - 'offset', ] thrift_spec = ( - None, # 0 - (1, TType.I32, 'offset', None, None, ), # 1 ) - def __init__(self, offset=None,): - self.offset = offset - -class getLog_result(TBase): +class getGlobalPlugins_result(TBase): """ Attributes: - success @@ -3648,14 +4596,14 @@ class getLog_result(TBase): ] thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(ConfigInfo, ConfigInfo.thrift_spec)), None, ), # 0 ) def __init__(self, success=None,): self.success = success -class isTimeDownload_args(TBase): +class getUserPlugins_args(TBase): __slots__ = [ ] @@ -3664,7 +4612,7 @@ class isTimeDownload_args(TBase): ) -class isTimeDownload_result(TBase): +class getUserPlugins_result(TBase): """ Attributes: - success @@ -3675,23 +4623,33 @@ class isTimeDownload_result(TBase): ] thrift_spec = ( - (0, TType.BOOL, 'success', None, None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(ConfigInfo, ConfigInfo.thrift_spec)), None, ), # 0 ) def __init__(self, success=None,): self.success = success -class isTimeReconnect_args(TBase): +class configurePlugin_args(TBase): + """ + Attributes: + - plugin + """ __slots__ = [ + 'plugin', ] thrift_spec = ( + None, # 0 + (1, TType.STRING, 'plugin', None, None, ), # 1 ) + def __init__(self, plugin=None,): + self.plugin = plugin -class isTimeReconnect_result(TBase): + +class configurePlugin_result(TBase): """ Attributes: - success @@ -3702,75 +4660,103 @@ class isTimeReconnect_result(TBase): ] thrift_spec = ( - (0, TType.BOOL, 'success', None, None, ), # 0 + (0, TType.STRUCT, 'success', (ConfigHolder, ConfigHolder.thrift_spec), None, ), # 0 ) def __init__(self, success=None,): self.success = success -class toggleReconnect_args(TBase): +class saveConfig_args(TBase): + """ + Attributes: + - config + """ __slots__ = [ + 'config', ] thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'config', (ConfigHolder, ConfigHolder.thrift_spec), None, ), # 1 ) + def __init__(self, config=None,): + self.config = config -class toggleReconnect_result(TBase): - """ - Attributes: - - success - """ + +class saveConfig_result(TBase): __slots__ = [ - 'success', ] thrift_spec = ( - (0, TType.BOOL, 'success', None, None, ), # 0 ) - def __init__(self, success=None,): - self.success = success - -class generatePackages_args(TBase): +class deleteConfig_args(TBase): """ Attributes: - - links + - plugin """ __slots__ = [ - 'links', + 'plugin', ] thrift_spec = ( None, # 0 - (1, TType.LIST, 'links', (TType.STRING,None), None, ), # 1 + (1, TType.STRING, 'plugin', None, None, ), # 1 ) - def __init__(self, links=None,): - self.links = links + def __init__(self, plugin=None,): + self.plugin = plugin -class generatePackages_result(TBase): +class deleteConfig_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class setConfigHandler_args(TBase): """ Attributes: - - success + - plugin + - iid + - value """ __slots__ = [ - 'success', + 'plugin', + 'iid', + 'value', ] thrift_spec = ( - (0, TType.MAP, 'success', (TType.STRING,None,TType.LIST,(TType.STRING,None)), None, ), # 0 + None, # 0 + (1, TType.STRING, 'plugin', None, None, ), # 1 + (2, TType.I32, 'iid', None, None, ), # 2 + (3, TType.STRING, 'value', None, None, ), # 3 ) - def __init__(self, success=None,): - self.success = success + def __init__(self, plugin=None, iid=None, value=None,): + self.plugin = plugin + self.iid = iid + self.value = value + + +class setConfigHandler_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) class checkURLs_args(TBase): @@ -3970,16 +4956,26 @@ class pollResults_result(TBase): self.success = success -class statusDownloads_args(TBase): +class generatePackages_args(TBase): + """ + Attributes: + - links + """ __slots__ = [ + 'links', ] thrift_spec = ( + None, # 0 + (1, TType.LIST, 'links', (TType.STRING,None), None, ), # 1 ) + def __init__(self, links=None,): + self.links = links + -class statusDownloads_result(TBase): +class generatePackages_result(TBase): """ Attributes: - success @@ -3990,146 +4986,192 @@ class statusDownloads_result(TBase): ] thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(DownloadInfo, DownloadInfo.thrift_spec)), None, ), # 0 + (0, TType.MAP, 'success', (TType.STRING,None,TType.LIST,(TType.STRING,None)), None, ), # 0 ) def __init__(self, success=None,): self.success = success -class getPackageData_args(TBase): +class generateAndAddPackages_args(TBase): """ Attributes: - - pid + - links + - paused """ __slots__ = [ - 'pid', + 'links', + 'paused', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'pid', None, None, ), # 1 + (1, TType.LIST, 'links', (TType.STRING,None), None, ), # 1 + (2, TType.BOOL, 'paused', None, None, ), # 2 ) - def __init__(self, pid=None,): - self.pid = pid + def __init__(self, links=None, paused=None,): + self.links = links + self.paused = paused -class getPackageData_result(TBase): +class generateAndAddPackages_result(TBase): """ Attributes: - success - - e """ __slots__ = [ 'success', - 'e', ] thrift_spec = ( - (0, TType.STRUCT, 'success', (PackageData, PackageData.thrift_spec), None, ), # 0 - (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 + (0, TType.LIST, 'success', (TType.I32,None), None, ), # 0 ) - def __init__(self, success=None, e=None,): + def __init__(self, success=None,): self.success = success - self.e = e -class getPackageInfo_args(TBase): +class createPackage_args(TBase): """ Attributes: - - pid + - name + - folder + - root + - password + - site + - comment + - paused """ __slots__ = [ - 'pid', + 'name', + 'folder', + 'root', + 'password', + 'site', + 'comment', + 'paused', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'pid', None, None, ), # 1 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.STRING, 'folder', None, None, ), # 2 + (3, TType.I32, 'root', None, None, ), # 3 + (4, TType.STRING, 'password', None, None, ), # 4 + (5, TType.STRING, 'site', None, None, ), # 5 + (6, TType.STRING, 'comment', None, None, ), # 6 + (7, TType.BOOL, 'paused', None, None, ), # 7 ) - def __init__(self, pid=None,): - self.pid = pid + def __init__(self, name=None, folder=None, root=None, password=None, site=None, comment=None, paused=None,): + self.name = name + self.folder = folder + self.root = root + self.password = password + self.site = site + self.comment = comment + self.paused = paused -class getPackageInfo_result(TBase): +class createPackage_result(TBase): """ Attributes: - success - - e """ __slots__ = [ 'success', - 'e', ] thrift_spec = ( - (0, TType.STRUCT, 'success', (PackageData, PackageData.thrift_spec), None, ), # 0 - (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 + (0, TType.I32, 'success', None, None, ), # 0 ) - def __init__(self, success=None, e=None,): + def __init__(self, success=None,): self.success = success - self.e = e -class getFileData_args(TBase): +class addPackage_args(TBase): """ Attributes: - - fid + - name + - links + - password """ __slots__ = [ - 'fid', + 'name', + 'links', + 'password', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'fid', None, None, ), # 1 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2 + (3, TType.STRING, 'password', None, None, ), # 3 ) - def __init__(self, fid=None,): - self.fid = fid + def __init__(self, name=None, links=None, password=None,): + self.name = name + self.links = links + self.password = password -class getFileData_result(TBase): +class addPackage_result(TBase): """ Attributes: - success - - e """ __slots__ = [ 'success', - 'e', ] thrift_spec = ( - (0, TType.STRUCT, 'success', (FileData, FileData.thrift_spec), None, ), # 0 - (1, TType.STRUCT, 'e', (FileDoesNotExists, FileDoesNotExists.thrift_spec), None, ), # 1 + (0, TType.I32, 'success', None, None, ), # 0 ) - def __init__(self, success=None, e=None,): + def __init__(self, success=None,): self.success = success - self.e = e -class getQueue_args(TBase): +class addPackageP_args(TBase): + """ + Attributes: + - name + - links + - password + - paused + """ __slots__ = [ + 'name', + 'links', + 'password', + 'paused', ] thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2 + (3, TType.STRING, 'password', None, None, ), # 3 + (4, TType.BOOL, 'paused', None, None, ), # 4 ) + def __init__(self, name=None, links=None, password=None, paused=None,): + self.name = name + self.links = links + self.password = password + self.paused = paused + -class getQueue_result(TBase): +class addPackageP_result(TBase): """ Attributes: - success @@ -4140,23 +5182,49 @@ class getQueue_result(TBase): ] thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(PackageData, PackageData.thrift_spec)), None, ), # 0 + (0, TType.I32, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class getCollector_args(TBase): +class addPackageChild_args(TBase): + """ + Attributes: + - name + - links + - password + - root + - paused + """ __slots__ = [ + 'name', + 'links', + 'password', + 'root', + 'paused', ] thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2 + (3, TType.STRING, 'password', None, None, ), # 3 + (4, TType.I32, 'root', None, None, ), # 4 + (5, TType.BOOL, 'paused', None, None, ), # 5 ) + def __init__(self, name=None, links=None, password=None, root=None, paused=None,): + self.name = name + self.links = links + self.password = password + self.root = root + self.paused = paused -class getCollector_result(TBase): + +class addPackageChild_result(TBase): """ Attributes: - success @@ -4167,23 +5235,37 @@ class getCollector_result(TBase): ] thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(PackageData, PackageData.thrift_spec)), None, ), # 0 + (0, TType.I32, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class getQueueData_args(TBase): +class uploadContainer_args(TBase): + """ + Attributes: + - filename + - data + """ __slots__ = [ + 'filename', + 'data', ] thrift_spec = ( + None, # 0 + (1, TType.STRING, 'filename', None, None, ), # 1 + (2, TType.STRING, 'data', None, None, ), # 2 ) + def __init__(self, filename=None, data=None,): + self.filename = filename + self.data = data + -class getQueueData_result(TBase): +class uploadContainer_result(TBase): """ Attributes: - success @@ -4194,97 +5276,167 @@ class getQueueData_result(TBase): ] thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(PackageData, PackageData.thrift_spec)), None, ), # 0 + (0, TType.I32, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class getCollectorData_args(TBase): +class addLinks_args(TBase): + """ + Attributes: + - pid + - links + """ __slots__ = [ + 'pid', + 'links', ] thrift_spec = ( + None, # 0 + (1, TType.I32, 'pid', None, None, ), # 1 + (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2 ) + def __init__(self, pid=None, links=None,): + self.pid = pid + self.links = links + -class getCollectorData_result(TBase): +class addLinks_result(TBase): """ Attributes: - - success + - e """ __slots__ = [ - 'success', + 'e', ] thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(PackageData, PackageData.thrift_spec)), None, ), # 0 + None, # 0 + (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 ) - def __init__(self, success=None,): - self.success = success + def __init__(self, e=None,): + self.e = e -class getPackageOrder_args(TBase): +class addLocalFile_args(TBase): """ Attributes: - - destination + - pid + - name + - path """ __slots__ = [ - 'destination', + 'pid', + 'name', + 'path', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'destination', None, None, ), # 1 + (1, TType.I32, 'pid', None, None, ), # 1 + (2, TType.STRING, 'name', None, None, ), # 2 + (3, TType.STRING, 'path', None, None, ), # 3 ) - def __init__(self, destination=None,): - self.destination = destination + def __init__(self, pid=None, name=None, path=None,): + self.pid = pid + self.name = name + self.path = path -class getPackageOrder_result(TBase): +class addLocalFile_result(TBase): """ Attributes: - - success + - e """ __slots__ = [ - 'success', + 'e', ] thrift_spec = ( - (0, TType.MAP, 'success', (TType.I16,None,TType.I32,None), None, ), # 0 + None, # 0 + (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 ) - def __init__(self, success=None,): - self.success = success + def __init__(self, e=None,): + self.e = e -class getFileOrder_args(TBase): +class deleteFiles_args(TBase): """ Attributes: - - pid + - fids """ __slots__ = [ - 'pid', + 'fids', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'pid', None, None, ), # 1 + (1, TType.LIST, 'fids', (TType.I32,None), None, ), # 1 ) - def __init__(self, pid=None,): - self.pid = pid + def __init__(self, fids=None,): + self.fids = fids + + +class deleteFiles_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) -class getFileOrder_result(TBase): +class deletePackages_args(TBase): + """ + Attributes: + - pids + """ + + __slots__ = [ + 'pids', + ] + + thrift_spec = ( + None, # 0 + (1, TType.LIST, 'pids', (TType.I32,None), None, ), # 1 + ) + + def __init__(self, pids=None,): + self.pids = pids + + +class deletePackages_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class getCollector_args(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class getCollector_result(TBase): """ Attributes: - success @@ -4295,37 +5447,65 @@ class getFileOrder_result(TBase): ] thrift_spec = ( - (0, TType.MAP, 'success', (TType.I16,None,TType.I32,None), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(LinkStatus, LinkStatus.thrift_spec)), None, ), # 0 ) def __init__(self, success=None,): self.success = success -class generateAndAddPackages_args(TBase): +class addToCollector_args(TBase): """ Attributes: - links - - dest """ __slots__ = [ 'links', - 'dest', ] thrift_spec = ( None, # 0 (1, TType.LIST, 'links', (TType.STRING,None), None, ), # 1 - (2, TType.I32, 'dest', None, None, ), # 2 ) - def __init__(self, links=None, dest=None,): + def __init__(self, links=None,): self.links = links - self.dest = dest -class generateAndAddPackages_result(TBase): +class addToCollector_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class addFromCollector_args(TBase): + """ + Attributes: + - name + - paused + """ + + __slots__ = [ + 'name', + 'paused', + ] + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 + (2, TType.BOOL, 'paused', None, None, ), # 2 + ) + + def __init__(self, name=None, paused=None,): + self.name = name + self.paused = paused + + +class addFromCollector_result(TBase): """ Attributes: - success @@ -4336,82 +5516,93 @@ class generateAndAddPackages_result(TBase): ] thrift_spec = ( - (0, TType.LIST, 'success', (TType.I32,None), None, ), # 0 + (0, TType.I32, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class addPackage_args(TBase): +class renameCollPack_args(TBase): """ Attributes: - name - - links - - dest + - new_name """ __slots__ = [ 'name', - 'links', - 'dest', + 'new_name', ] thrift_spec = ( None, # 0 (1, TType.STRING, 'name', None, None, ), # 1 - (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2 - (3, TType.I32, 'dest', None, None, ), # 3 + (2, TType.STRING, 'new_name', None, None, ), # 2 ) - def __init__(self, name=None, links=None, dest=None,): + def __init__(self, name=None, new_name=None,): self.name = name - self.links = links - self.dest = dest + self.new_name = new_name -class addPackage_result(TBase): +class renameCollPack_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class deleteCollPack_args(TBase): """ Attributes: - - success + - name """ __slots__ = [ - 'success', + 'name', ] thrift_spec = ( - (0, TType.I32, 'success', None, None, ), # 0 + None, # 0 + (1, TType.STRING, 'name', None, None, ), # 1 ) - def __init__(self, success=None,): - self.success = success + def __init__(self, name=None,): + self.name = name + + +class deleteCollPack_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) -class addFiles_args(TBase): +class deleteCollLink_args(TBase): """ Attributes: - - pid - - links + - url """ __slots__ = [ - 'pid', - 'links', + 'url', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'pid', None, None, ), # 1 - (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2 + (1, TType.STRING, 'url', None, None, ), # 1 ) - def __init__(self, pid=None, links=None,): - self.pid = pid - self.links = links + def __init__(self, url=None,): + self.url = url -class addFiles_result(TBase): +class deleteCollLink_result(TBase): __slots__ = [ ] @@ -4420,30 +5611,34 @@ class addFiles_result(TBase): ) -class uploadContainer_args(TBase): +class getAllFiles_args(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class getAllFiles_result(TBase): """ Attributes: - - filename - - data + - success """ __slots__ = [ - 'filename', - 'data', + 'success', ] thrift_spec = ( - None, # 0 - (1, TType.STRING, 'filename', None, None, ), # 1 - (2, TType.STRING, 'data', None, None, ), # 2 + (0, TType.STRUCT, 'success', (TreeCollection, TreeCollection.thrift_spec), None, ), # 0 ) - def __init__(self, filename=None, data=None,): - self.filename = filename - self.data = data + def __init__(self, success=None,): + self.success = success -class uploadContainer_result(TBase): +class getAllUnfinishedFiles_args(TBase): __slots__ = [ ] @@ -4452,63 +5647,107 @@ class uploadContainer_result(TBase): ) -class deleteFiles_args(TBase): +class getAllUnfinishedFiles_result(TBase): """ Attributes: - - fids + - success """ __slots__ = [ - 'fids', + 'success', + ] + + thrift_spec = ( + (0, TType.STRUCT, 'success', (TreeCollection, TreeCollection.thrift_spec), None, ), # 0 + ) + + def __init__(self, success=None,): + self.success = success + + +class getFileTree_args(TBase): + """ + Attributes: + - pid + - full + """ + + __slots__ = [ + 'pid', + 'full', ] thrift_spec = ( None, # 0 - (1, TType.LIST, 'fids', (TType.I32,None), None, ), # 1 + (1, TType.I32, 'pid', None, None, ), # 1 + (2, TType.BOOL, 'full', None, None, ), # 2 ) - def __init__(self, fids=None,): - self.fids = fids + def __init__(self, pid=None, full=None,): + self.pid = pid + self.full = full -class deleteFiles_result(TBase): +class getFileTree_result(TBase): + """ + Attributes: + - success + """ __slots__ = [ + 'success', ] thrift_spec = ( + (0, TType.STRUCT, 'success', (TreeCollection, TreeCollection.thrift_spec), None, ), # 0 ) + def __init__(self, success=None,): + self.success = success -class deletePackages_args(TBase): + +class getUnfinishedFileTree_args(TBase): """ Attributes: - - pids + - pid + - full """ __slots__ = [ - 'pids', + 'pid', + 'full', ] thrift_spec = ( None, # 0 - (1, TType.LIST, 'pids', (TType.I32,None), None, ), # 1 + (1, TType.I32, 'pid', None, None, ), # 1 + (2, TType.BOOL, 'full', None, None, ), # 2 ) - def __init__(self, pids=None,): - self.pids = pids + def __init__(self, pid=None, full=None,): + self.pid = pid + self.full = full -class deletePackages_result(TBase): +class getUnfinishedFileTree_result(TBase): + """ + Attributes: + - success + """ __slots__ = [ + 'success', ] thrift_spec = ( + (0, TType.STRUCT, 'success', (TreeCollection, TreeCollection.thrift_spec), None, ), # 0 ) + def __init__(self, success=None,): + self.success = success + -class pushToQueue_args(TBase): +class getPackageContent_args(TBase): """ Attributes: - pid @@ -4527,16 +5766,25 @@ class pushToQueue_args(TBase): self.pid = pid -class pushToQueue_result(TBase): +class getPackageContent_result(TBase): + """ + Attributes: + - success + """ __slots__ = [ + 'success', ] thrift_spec = ( + (0, TType.STRUCT, 'success', (TreeCollection, TreeCollection.thrift_spec), None, ), # 0 ) + def __init__(self, success=None,): + self.success = success + -class pullFromQueue_args(TBase): +class getPackageInfo_args(TBase): """ Attributes: - pid @@ -4555,14 +5803,105 @@ class pullFromQueue_args(TBase): self.pid = pid -class pullFromQueue_result(TBase): +class getPackageInfo_result(TBase): + """ + Attributes: + - success + - e + """ + + __slots__ = [ + 'success', + 'e', + ] + + thrift_spec = ( + (0, TType.STRUCT, 'success', (PackageInfo, PackageInfo.thrift_spec), None, ), # 0 + (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 + ) + + def __init__(self, success=None, e=None,): + self.success = success + self.e = e + + +class getFileInfo_args(TBase): + """ + Attributes: + - fid + """ + + __slots__ = [ + 'fid', + ] + + thrift_spec = ( + None, # 0 + (1, TType.I32, 'fid', None, None, ), # 1 + ) + + def __init__(self, fid=None,): + self.fid = fid + + +class getFileInfo_result(TBase): + """ + Attributes: + - success + - e + """ + + __slots__ = [ + 'success', + 'e', + ] + + thrift_spec = ( + (0, TType.STRUCT, 'success', (FileInfo, FileInfo.thrift_spec), None, ), # 0 + (1, TType.STRUCT, 'e', (FileDoesNotExists, FileDoesNotExists.thrift_spec), None, ), # 1 + ) + + def __init__(self, success=None, e=None,): + self.success = success + self.e = e + + +class findFiles_args(TBase): + """ + Attributes: + - pattern + """ + + __slots__ = [ + 'pattern', + ] + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'pattern', None, None, ), # 1 + ) + + def __init__(self, pattern=None,): + self.pattern = pattern + + +class findFiles_result(TBase): + """ + Attributes: + - success + """ __slots__ = [ + 'success', ] thrift_spec = ( + (0, TType.STRUCT, 'success', (TreeCollection, TreeCollection.thrift_spec), None, ), # 0 ) + def __init__(self, success=None,): + self.success = success + class restartPackage_args(TBase): """ @@ -4648,7 +5987,7 @@ class recheckPackage_result(TBase): ) -class stopAllDownloads_args(TBase): +class restartFailed_args(TBase): __slots__ = [ ] @@ -4657,7 +5996,7 @@ class stopAllDownloads_args(TBase): ) -class stopAllDownloads_result(TBase): +class restartFailed_result(TBase): __slots__ = [ ] @@ -4694,69 +6033,197 @@ class stopDownloads_result(TBase): ) -class setPackageName_args(TBase): +class stopAllDownloads_args(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class stopAllDownloads_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class setPackagePaused_args(TBase): """ Attributes: - pid - - name + - paused """ __slots__ = [ 'pid', - 'name', + 'paused', ] thrift_spec = ( None, # 0 (1, TType.I32, 'pid', None, None, ), # 1 - (2, TType.STRING, 'name', None, None, ), # 2 + (2, TType.BOOL, 'paused', None, None, ), # 2 ) - def __init__(self, pid=None, name=None,): + def __init__(self, pid=None, paused=None,): self.pid = pid - self.name = name + self.paused = paused + + +class setPackagePaused_result(TBase): + """ + Attributes: + - e + """ + + __slots__ = [ + 'e', + ] + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 + ) + + def __init__(self, e=None,): + self.e = e -class setPackageName_result(TBase): +class setPackageFolder_args(TBase): + """ + Attributes: + - pid + - path + """ __slots__ = [ + 'pid', + 'path', ] thrift_spec = ( + None, # 0 + (1, TType.I32, 'pid', None, None, ), # 1 + (2, TType.STRING, 'path', None, None, ), # 2 ) + def __init__(self, pid=None, path=None,): + self.pid = pid + self.path = path + + +class setPackageFolder_result(TBase): + """ + Attributes: + - success + - e + """ + + __slots__ = [ + 'success', + 'e', + ] + + thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 + ) + + def __init__(self, success=None, e=None,): + self.success = success + self.e = e + + +class setPackageData_args(TBase): + """ + Attributes: + - pid + - data + """ + + __slots__ = [ + 'pid', + 'data', + ] + + thrift_spec = ( + None, # 0 + (1, TType.I32, 'pid', None, None, ), # 1 + (2, TType.MAP, 'data', (TType.STRING,None,TType.STRING,None), None, ), # 2 + ) + + def __init__(self, pid=None, data=None,): + self.pid = pid + self.data = data + + +class setPackageData_result(TBase): + """ + Attributes: + - e + """ + + __slots__ = [ + 'e', + ] + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 + ) + + def __init__(self, e=None,): + self.e = e + class movePackage_args(TBase): """ Attributes: - - destination - pid + - root """ __slots__ = [ - 'destination', 'pid', + 'root', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'destination', None, None, ), # 1 - (2, TType.I32, 'pid', None, None, ), # 2 + (1, TType.I32, 'pid', None, None, ), # 1 + (2, TType.I32, 'root', None, None, ), # 2 ) - def __init__(self, destination=None, pid=None,): - self.destination = destination + def __init__(self, pid=None, root=None,): self.pid = pid + self.root = root class movePackage_result(TBase): + """ + Attributes: + - success + - e + """ __slots__ = [ + 'success', + 'e', ] thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 ) + def __init__(self, success=None, e=None,): + self.success = success + self.e = e + class moveFiles_args(TBase): """ @@ -4782,34 +6249,47 @@ class moveFiles_args(TBase): class moveFiles_result(TBase): + """ + Attributes: + - success + - e + """ __slots__ = [ + 'success', + 'e', ] thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 ) + def __init__(self, success=None, e=None,): + self.success = success + self.e = e + class orderPackage_args(TBase): """ Attributes: - - pid + - pids - position """ __slots__ = [ - 'pid', + 'pids', 'position', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'pid', None, None, ), # 1 + (1, TType.LIST, 'pids', (TType.I32,None), None, ), # 1 (2, TType.I16, 'position', None, None, ), # 2 ) - def __init__(self, pid=None, position=None,): - self.pid = pid + def __init__(self, pids=None, position=None,): + self.pids = pids self.position = position @@ -4822,30 +6302,34 @@ class orderPackage_result(TBase): ) -class orderFile_args(TBase): +class orderFiles_args(TBase): """ Attributes: - - fid + - fids + - pid - position """ __slots__ = [ - 'fid', + 'fids', + 'pid', 'position', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'fid', None, None, ), # 1 - (2, TType.I16, 'position', None, None, ), # 2 + (1, TType.LIST, 'fids', (TType.I32,None), None, ), # 1 + (2, TType.I32, 'pid', None, None, ), # 2 + (3, TType.I16, 'position', None, None, ), # 3 ) - def __init__(self, fid=None, position=None,): - self.fid = fid + def __init__(self, fids=None, pid=None, position=None,): + self.fids = fids + self.pid = pid self.position = position -class orderFile_result(TBase): +class orderFiles_result(TBase): __slots__ = [ ] @@ -4854,58 +6338,136 @@ class orderFile_result(TBase): ) -class setPackageData_args(TBase): +class isInteractionWaiting_args(TBase): """ Attributes: - - pid - - data + - mode """ __slots__ = [ - 'pid', - 'data', + 'mode', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'pid', None, None, ), # 1 - (2, TType.MAP, 'data', (TType.STRING,None,TType.STRING,None), None, ), # 2 + (1, TType.I16, 'mode', None, None, ), # 1 ) - def __init__(self, pid=None, data=None,): - self.pid = pid - self.data = data + def __init__(self, mode=None,): + self.mode = mode -class setPackageData_result(TBase): +class isInteractionWaiting_result(TBase): """ Attributes: - - e + - success """ __slots__ = [ - 'e', + 'success', + ] + + thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + ) + + def __init__(self, success=None,): + self.success = success + + +class getInteractionTask_args(TBase): + """ + Attributes: + - mode + """ + + __slots__ = [ + 'mode', ] thrift_spec = ( None, # 0 - (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1 + (1, TType.I16, 'mode', None, None, ), # 1 ) - def __init__(self, e=None,): - self.e = e + def __init__(self, mode=None,): + self.mode = mode -class deleteFinished_args(TBase): +class getInteractionTask_result(TBase): + """ + Attributes: + - success + """ __slots__ = [ + 'success', ] thrift_spec = ( + (0, TType.STRUCT, 'success', (InteractionTask, InteractionTask.thrift_spec), None, ), # 0 ) + def __init__(self, success=None,): + self.success = success -class deleteFinished_result(TBase): + +class setInteractionResult_args(TBase): + """ + Attributes: + - iid + - result + """ + + __slots__ = [ + 'iid', + 'result', + ] + + thrift_spec = ( + None, # 0 + (1, TType.I32, 'iid', None, None, ), # 1 + (2, TType.STRING, 'result', None, None, ), # 2 + ) + + def __init__(self, iid=None, result=None,): + self.iid = iid + self.result = result + + +class setInteractionResult_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class generateDownloadLink_args(TBase): + """ + Attributes: + - fid + - timeout + """ + + __slots__ = [ + 'fid', + 'timeout', + ] + + thrift_spec = ( + None, # 0 + (1, TType.I32, 'fid', None, None, ), # 1 + (2, TType.I16, 'timeout', None, None, ), # 2 + ) + + def __init__(self, fid=None, timeout=None,): + self.fid = fid + self.timeout = timeout + + +class generateDownloadLink_result(TBase): """ Attributes: - success @@ -4916,14 +6478,14 @@ class deleteFinished_result(TBase): ] thrift_spec = ( - (0, TType.LIST, 'success', (TType.I32,None), None, ), # 0 + (0, TType.STRING, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class restartFailed_args(TBase): +class getNotifications_args(TBase): __slots__ = [ ] @@ -4932,14 +6494,23 @@ class restartFailed_args(TBase): ) -class restartFailed_result(TBase): +class getNotifications_result(TBase): + """ + Attributes: + - success + """ __slots__ = [ + 'success', ] thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRUCT,(InteractionTask, InteractionTask.thrift_spec)), None, ), # 0 ) + def __init__(self, success=None,): + self.success = success + class getEvents_args(TBase): """ @@ -5048,14 +6619,12 @@ class updateAccount_args(TBase): - plugin - account - password - - options """ __slots__ = [ 'plugin', 'account', 'password', - 'options', ] thrift_spec = ( @@ -5063,14 +6632,12 @@ class updateAccount_args(TBase): (1, TType.STRING, 'plugin', None, None, ), # 1 (2, TType.STRING, 'account', None, None, ), # 2 (3, TType.STRING, 'password', None, None, ), # 3 - (4, TType.MAP, 'options', (TType.STRING,None,TType.STRING,None), None, ), # 4 ) - def __init__(self, plugin=None, account=None, password=None, options=None,): + def __init__(self, plugin=None, account=None, password=None,): self.plugin = plugin self.account = account self.password = password - self.options = options class updateAccount_result(TBase): @@ -5082,6 +6649,34 @@ class updateAccount_result(TBase): ) +class updateAccountInfo_args(TBase): + """ + Attributes: + - account + """ + + __slots__ = [ + 'account', + ] + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'account', (AccountInfo, AccountInfo.thrift_spec), None, ), # 1 + ) + + def __init__(self, account=None,): + self.account = account + + +class updateAccountInfo_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) + + class removeAccount_args(TBase): """ Attributes: @@ -5156,27 +6751,13 @@ class login_result(TBase): class getUserData_args(TBase): - """ - Attributes: - - username - - password - """ __slots__ = [ - 'username', - 'password', ] thrift_spec = ( - None, # 0 - (1, TType.STRING, 'username', None, None, ), # 1 - (2, TType.STRING, 'password', None, None, ), # 2 ) - def __init__(self, username=None, password=None,): - self.username = username - self.password = password - class getUserData_result(TBase): """ @@ -5216,23 +6797,37 @@ class getAllUserData_result(TBase): ] thrift_spec = ( - (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(UserData, UserData.thrift_spec)), None, ), # 0 + (0, TType.MAP, 'success', (TType.I32,None,TType.STRUCT,(UserData, UserData.thrift_spec)), None, ), # 0 ) def __init__(self, success=None,): self.success = success -class getServices_args(TBase): +class addUser_args(TBase): + """ + Attributes: + - username + - password + """ __slots__ = [ + 'username', + 'password', ] thrift_spec = ( + None, # 0 + (1, TType.STRING, 'username', None, None, ), # 1 + (2, TType.STRING, 'password', None, None, ), # 2 ) + def __init__(self, username=None, password=None,): + self.username = username + self.password = password + -class getServices_result(TBase): +class addUser_result(TBase): """ Attributes: - success @@ -5243,97 +6838,112 @@ class getServices_result(TBase): ] thrift_spec = ( - (0, TType.MAP, 'success', (TType.STRING,None,TType.MAP,(TType.STRING,None,TType.STRING,None)), None, ), # 0 + (0, TType.STRUCT, 'success', (UserData, UserData.thrift_spec), None, ), # 0 ) def __init__(self, success=None,): self.success = success -class hasService_args(TBase): +class updateUserData_args(TBase): """ Attributes: - - plugin - - func + - data """ __slots__ = [ - 'plugin', - 'func', + 'data', ] thrift_spec = ( None, # 0 - (1, TType.STRING, 'plugin', None, None, ), # 1 - (2, TType.STRING, 'func', None, None, ), # 2 + (1, TType.STRUCT, 'data', (UserData, UserData.thrift_spec), None, ), # 1 ) - def __init__(self, plugin=None, func=None,): - self.plugin = plugin - self.func = func + def __init__(self, data=None,): + self.data = data + +class updateUserData_result(TBase): -class hasService_result(TBase): + __slots__ = [ + ] + + thrift_spec = ( + ) + + +class removeUser_args(TBase): """ Attributes: - - success + - uid """ __slots__ = [ - 'success', + 'uid', ] thrift_spec = ( - (0, TType.BOOL, 'success', None, None, ), # 0 + None, # 0 + (1, TType.I32, 'uid', None, None, ), # 1 ) - def __init__(self, success=None,): - self.success = success + def __init__(self, uid=None,): + self.uid = uid + + +class removeUser_result(TBase): + + __slots__ = [ + ] + + thrift_spec = ( + ) -class call_args(TBase): +class setPassword_args(TBase): """ Attributes: - - info + - username + - old_password + - new_password """ __slots__ = [ - 'info', + 'username', + 'old_password', + 'new_password', ] thrift_spec = ( None, # 0 - (1, TType.STRUCT, 'info', (ServiceCall, ServiceCall.thrift_spec), None, ), # 1 + (1, TType.STRING, 'username', None, None, ), # 1 + (2, TType.STRING, 'old_password', None, None, ), # 2 + (3, TType.STRING, 'new_password', None, None, ), # 3 ) - def __init__(self, info=None,): - self.info = info + def __init__(self, username=None, old_password=None, new_password=None,): + self.username = username + self.old_password = old_password + self.new_password = new_password -class call_result(TBase): +class setPassword_result(TBase): """ Attributes: - success - - ex - - e """ __slots__ = [ 'success', - 'ex', - 'e', ] thrift_spec = ( - (0, TType.STRING, 'success', None, None, ), # 0 - (1, TType.STRUCT, 'ex', (ServiceDoesNotExists, ServiceDoesNotExists.thrift_spec), None, ), # 1 - (2, TType.STRUCT, 'e', (ServiceException, ServiceException.thrift_spec), None, ), # 2 + (0, TType.BOOL, 'success', None, None, ), # 0 ) - def __init__(self, success=None, ex=None, e=None,): + def __init__(self, success=None,): self.success = success - self.ex = ex - self.e = e class getAllInfo_args(TBase): @@ -5356,7 +6966,7 @@ class getAllInfo_result(TBase): ] thrift_spec = ( - (0, TType.MAP, 'success', (TType.STRING,None,TType.MAP,(TType.STRING,None,TType.STRING,None)), None, ), # 0 + (0, TType.MAP, 'success', (TType.STRING,None,TType.LIST,(TType.STRUCT,(AddonInfo, AddonInfo.thrift_spec))), None, ), # 0 ) def __init__(self, success=None,): @@ -5393,14 +7003,14 @@ class getInfoByPlugin_result(TBase): ] thrift_spec = ( - (0, TType.MAP, 'success', (TType.STRING,None,TType.STRING,None), None, ), # 0 + (0, TType.LIST, 'success', (TType.STRUCT,(AddonInfo, AddonInfo.thrift_spec)), None, ), # 0 ) def __init__(self, success=None,): self.success = success -class isCaptchaWaiting_args(TBase): +class getAddonHandler_args(TBase): __slots__ = [ ] @@ -5409,7 +7019,7 @@ class isCaptchaWaiting_args(TBase): ) -class isCaptchaWaiting_result(TBase): +class getAddonHandler_result(TBase): """ Attributes: - success @@ -5420,33 +7030,37 @@ class isCaptchaWaiting_result(TBase): ] thrift_spec = ( - (0, TType.BOOL, 'success', None, None, ), # 0 + (0, TType.MAP, 'success', (TType.STRING,None,TType.LIST,(TType.STRUCT,(AddonService, AddonService.thrift_spec))), None, ), # 0 ) def __init__(self, success=None,): self.success = success -class getCaptchaTask_args(TBase): +class hasAddonHandler_args(TBase): """ Attributes: - - exclusive + - plugin + - func """ __slots__ = [ - 'exclusive', + 'plugin', + 'func', ] thrift_spec = ( None, # 0 - (1, TType.BOOL, 'exclusive', None, None, ), # 1 + (1, TType.STRING, 'plugin', None, None, ), # 1 + (2, TType.STRING, 'func', None, None, ), # 2 ) - def __init__(self, exclusive=None,): - self.exclusive = exclusive + def __init__(self, plugin=None, func=None,): + self.plugin = plugin + self.func = func -class getCaptchaTask_result(TBase): +class hasAddonHandler_result(TBase): """ Attributes: - success @@ -5457,78 +7071,109 @@ class getCaptchaTask_result(TBase): ] thrift_spec = ( - (0, TType.STRUCT, 'success', (CaptchaTask, CaptchaTask.thrift_spec), None, ), # 0 + (0, TType.BOOL, 'success', None, None, ), # 0 ) def __init__(self, success=None,): self.success = success -class getCaptchaTaskStatus_args(TBase): +class callAddon_args(TBase): """ Attributes: - - tid + - plugin + - func + - arguments """ __slots__ = [ - 'tid', + 'plugin', + 'func', + 'arguments', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'tid', None, None, ), # 1 + (1, TType.STRING, 'plugin', None, None, ), # 1 + (2, TType.STRING, 'func', None, None, ), # 2 + (3, TType.LIST, 'arguments', (TType.STRING,None), None, ), # 3 ) - def __init__(self, tid=None,): - self.tid = tid + def __init__(self, plugin=None, func=None, arguments=None,): + self.plugin = plugin + self.func = func + self.arguments = arguments -class getCaptchaTaskStatus_result(TBase): +class callAddon_result(TBase): """ Attributes: - - success + - e + - ex """ __slots__ = [ - 'success', + 'e', + 'ex', ] thrift_spec = ( - (0, TType.STRING, 'success', None, None, ), # 0 + None, # 0 + (1, TType.STRUCT, 'e', (ServiceDoesNotExists, ServiceDoesNotExists.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ex', (ServiceException, ServiceException.thrift_spec), None, ), # 2 ) - def __init__(self, success=None,): - self.success = success + def __init__(self, e=None, ex=None,): + self.e = e + self.ex = ex -class setCaptchaResult_args(TBase): +class callAddonHandler_args(TBase): """ Attributes: - - tid - - result + - plugin + - func + - pid_or_fid """ __slots__ = [ - 'tid', - 'result', + 'plugin', + 'func', + 'pid_or_fid', ] thrift_spec = ( None, # 0 - (1, TType.I32, 'tid', None, None, ), # 1 - (2, TType.STRING, 'result', None, None, ), # 2 + (1, TType.STRING, 'plugin', None, None, ), # 1 + (2, TType.STRING, 'func', None, None, ), # 2 + (3, TType.I32, 'pid_or_fid', None, None, ), # 3 ) - def __init__(self, tid=None, result=None,): - self.tid = tid - self.result = result + def __init__(self, plugin=None, func=None, pid_or_fid=None,): + self.plugin = plugin + self.func = func + self.pid_or_fid = pid_or_fid -class setCaptchaResult_result(TBase): +class callAddonHandler_result(TBase): + """ + Attributes: + - e + - ex + """ __slots__ = [ + 'e', + 'ex', ] thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'e', (ServiceDoesNotExists, ServiceDoesNotExists.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'ex', (ServiceException, ServiceException.thrift_spec), None, ), # 2 ) + def __init__(self, e=None, ex=None,): + self.e = e + self.ex = ex + |