diff options
| -rw-r--r-- | module/HookManager.py | 38 | ||||
| -rw-r--r-- | module/Utils.py | 3 | ||||
| -rw-r--r-- | module/plugins/Account.py | 14 | ||||
| -rw-r--r-- | module/plugins/Hook.py | 14 | ||||
| -rw-r--r-- | module/plugins/Plugin.py | 4 | ||||
| -rw-r--r-- | module/plugins/hooks/UpdateManager.py | 9 | ||||
| -rw-r--r-- | module/plugins/hoster/MegauploadCom.py | 2 | ||||
| -rw-r--r-- | module/remote/thriftbackend/Handler.py | 28 | ||||
| -rw-r--r-- | module/remote/thriftbackend/ThriftClient.py | 12 | ||||
| -rw-r--r-- | module/remote/thriftbackend/pyload.thrift | 29 | ||||
| -rwxr-xr-x | module/remote/thriftbackend/thriftgen/pyload/Pyload-remote | 21 | ||||
| -rw-r--r-- | module/remote/thriftbackend/thriftgen/pyload/Pyload.py | 819 | ||||
| -rw-r--r-- | module/remote/thriftbackend/thriftgen/pyload/ttypes.py | 308 |
13 files changed, 1132 insertions, 169 deletions
diff --git a/module/HookManager.py b/module/HookManager.py index 2a40d18a2..c3da485a9 100644 --- a/module/HookManager.py +++ b/module/HookManager.py @@ -14,23 +14,30 @@ You should have received a copy of the GNU General Public License along with this program; if not, see <http://www.gnu.org/licenses/>. - @author: mkaay + @author: RaNaN, mkaay @interface-version: 0.1 """ +import __builtin__ import traceback from threading import RLock -from module.PluginThread import HookThread from time import time -class HookManager(): + +from module.PluginThread import HookThread +from module.plugins.PluginManager import literal_eval + +class HookManager: def __init__(self, core): self.core = core - self.config = self.core.config + __builtin__.hookManager = self #needed to let hooks register themself + self.log = self.core.log self.plugins = [] + self.pluginMap = {} + self.methods = {} #dict of names and list of methods usable by rpc self.lock = RLock() self.createIndex() @@ -52,6 +59,28 @@ class HookManager(): traceback.print_exc() return new + + def addRPC(self, plugin, func, doc): + plugin = plugin.rpartition(".")[2] + doc = doc.strip() + + if self.methods.has_key(plugin): + self.methods[plugin][func] = doc + else: + self.methods[plugin] = {func: doc} + + print self.methods + + def callRPC(self, plugin, func, args, parse): + if not args: args = tuple() + if parse is not False: + args = tuple([literal_eval(x) for x in args]) + + plugin = self.pluginMap[plugin] + f = getattr(plugin, func) + return f(*args) + + def createIndex(self): plugins = [] @@ -62,6 +91,7 @@ class HookManager(): if self.core.config.getPlugin(pluginClass.__name__, "load"): plugin = pluginClass(self.core) plugins.append(plugin) + self.pluginMap[pluginClass.__name__] = plugin self.log.info(_("%(name)s loaded, activated %(value)s") % {"name": pluginClass.__name__, "value": plugin.isActivated() }) except: self.log.warning(_("Failed activating %(name)s") % {"name":pluginClass.__name__}) diff --git a/module/Utils.py b/module/Utils.py index fee1dee0f..63ae9488f 100644 --- a/module/Utils.py +++ b/module/Utils.py @@ -7,6 +7,7 @@ import sys import time import re from os.path import join +from string import maketrans def chmod(*args): try: @@ -24,7 +25,7 @@ def decode(string): def removeChars(string, repl): """ removes all chars in repl from string""" if type(string) == str: - return string.translate(None, repl) + return string.translate(maketrans("", ""), repl) elif type(string) == unicode: return string.translate(dict([(ord(s), None) for s in repl])) diff --git a/module/plugins/Account.py b/module/plugins/Account.py index b8de4ddf0..e8ca26749 100644 --- a/module/plugins/Account.py +++ b/module/plugins/Account.py @@ -22,7 +22,7 @@ from random import choice from time import time from traceback import print_exc -from module.utils import compare_time +from module.utils import compare_time, parseFileSize class WrongPassword(Exception): pass @@ -189,17 +189,7 @@ class Account(): return False if self.selectAccount() == (None, None) else True def parseTraffic(self, string): #returns kbyte - string = string.strip().lower() - p = re.compile(r"(\d+[\.,]\d+)(.*)") - m = p.match(string) - if m: - traffic = float(m.group(1).replace(",", ".")) - unit = m.group(2).strip() - if unit == "gb" or unit == "gig" or unit == "gbyte" or unit == "gigabyte": - traffic *= 1024*1024 - elif unit == "mb" or unit == "megabyte" or unit == "mbyte" or unit == "mib": - traffic *= 1024 - return traffic + return parseFileSize(string) / 1024 def wrongPassword(self): raise WrongPassword diff --git a/module/plugins/Hook.py b/module/plugins/Hook.py index 4af6a0ed4..c9d9c8778 100644 --- a/module/plugins/Hook.py +++ b/module/plugins/Hook.py @@ -20,6 +20,20 @@ from thread import start_new_thread + +class Expose(object): + """ used for decoration to declare rpc services """ + def __init__(self, *args, **kwargs): + self._f = args[0] + hookManager.addRPC(self._f.__module__, self._f.func_name, self._f.func_doc) + + def __get__(self, obj, klass): + self._obj = obj + return self + + def __call__(self, *args, **kwargs): + return self._f(self._obj, *args, **kwargs) + def threaded(f): def run(*args,**kwargs): return start_new_thread(f, args, kwargs) diff --git a/module/plugins/Plugin.py b/module/plugins/Plugin.py index 4d8766250..cef839861 100644 --- a/module/plugins/Plugin.py +++ b/module/plugins/Plugin.py @@ -437,6 +437,10 @@ class Plugin(object): self.lastCheck = m return name + + def getPassword(self): + return self.pyfile.package().password + def clean(self): """ clean everything and remove references """ if hasattr(self, "pyfile"): diff --git a/module/plugins/hooks/UpdateManager.py b/module/plugins/hooks/UpdateManager.py index df81ebbe7..026cd0c9f 100644 --- a/module/plugins/hooks/UpdateManager.py +++ b/module/plugins/hooks/UpdateManager.py @@ -20,7 +20,7 @@ from os.path import join from module.network.RequestFactory import getURL -from module.plugins.Hook import threaded, Hook +from module.plugins.Hook import threaded, Expose, Hook class UpdateManager(Hook): __name__ = "UpdateManager" @@ -48,8 +48,13 @@ class UpdateManager(Hook): else: self.log.info(_("No plugin updates available")) + @Expose + def recheckForUpdates(self): + """recheck if updates are available""" + self.periodical() + def checkForUpdate(self): - """ checks if an update is available""" + """checks if an update is available""" try: version_check = getURL("http://get.pyload.org/check/%s/" % self.core.server_methods.get_server_version()) diff --git a/module/plugins/hoster/MegauploadCom.py b/module/plugins/hoster/MegauploadCom.py index f73ecf308..5c893f5df 100644 --- a/module/plugins/hoster/MegauploadCom.py +++ b/module/plugins/hoster/MegauploadCom.py @@ -130,7 +130,7 @@ class MegauploadCom(Hoster): self.fail(_("You need premium to download files larger than 1 GB")) if r'Please enter the password below' in self.html[0]: - pw = self.pyfile.package().password + pw = self.getPassword() if not pw: self.fail(_("The file is password protected, enter a password and restart.")) diff --git a/module/remote/thriftbackend/Handler.py b/module/remote/thriftbackend/Handler.py index bd37c7eb2..9d38109db 100644 --- a/module/remote/thriftbackend/Handler.py +++ b/module/remote/thriftbackend/Handler.py @@ -537,3 +537,31 @@ class Handler(Iface): def getUserData(self): return self.serverMethods.checkAuth(username, password) + + + def getServices(self): + data = {} + for plugin, funcs in self.core.hookManager.methods.iteritems(): + data[plugin] = ServiceInfo(funcs) + + return data + + def hasService(self, plugin, func): + cont = self.core.hookManager.methods + return cont.has_key(plugin) and cont[plugin].has_key(func) + + def call(self, info): + plugin = info.plugin + func = info.func + args = info.arguments + parse = info.parseArguments + + if not self.hasService(plugin, func): + raise ServiceDoesNotExists(plugin, func) + + try: + ret = self.core.hookManager.callRPC(plugin, func, args, parse) + return str(ret) + except Exception, e: + raise ServiceException(e.message) +
\ No newline at end of file diff --git a/module/remote/thriftbackend/ThriftClient.py b/module/remote/thriftbackend/ThriftClient.py index e1238274d..6bdbeea90 100644 --- a/module/remote/thriftbackend/ThriftClient.py +++ b/module/remote/thriftbackend/ThriftClient.py @@ -93,9 +93,13 @@ if __name__ == "__main__": print client.statusDownloads() q = client.getQueue() - for p in q: - data = client.getPackageData(p.pid) - print data - print "Package Name: ", data.name +# for p in q: +# data = client.getPackageData(p.pid) +# print data +# print "Package Name: ", data.name + + + print client.getServices() + print client.call(Pyload.ServiceCall("UpdateManager", "recheckForUpdates")) client.close()
\ No newline at end of file diff --git a/module/remote/thriftbackend/pyload.thrift b/module/remote/thriftbackend/pyload.thrift index 8c17c7451..8e399062d 100644 --- a/module/remote/thriftbackend/pyload.thrift +++ b/module/remote/thriftbackend/pyload.thrift @@ -154,6 +154,17 @@ struct AccountData { 4: optional map<string, string> options } +struct ServiceInfo { + 1: map <string, string> funcs +} + +struct ServiceCall { + 1: string plugin, + 2: string func, + 3: optional list<string> arguments, + 4: optional bool parseArguments, //default True +} + exception PackageDoesNotExists{ 1: PackageID pid } @@ -162,6 +173,14 @@ exception FileDoesNotExists{ 1: FileID fid } +exception ServiceDoesNotExists{ + 1: string plugin + 2: string func +} + +exception ServiceException{ + 1: string msg +} service Pyload { //general @@ -227,9 +246,15 @@ service Pyload { list<AccountInfo> getAccounts(1: bool refresh), list<string> getAccountTypes() void updateAccounts(1: AccountData data), - void removeAccount(1: string plugin, 2: string account) + void removeAccount(1: string plugin, 2: string account), //auth bool login(1: string username, 2: string password), - UserData getUserData() + UserData getUserData(), + + //services + map<string, ServiceInfo> getServices(), + bool hasService(1: string plugin, 2: string func), + string call(1: ServiceCall info) throws (1: ServiceDoesNotExists ex, 2: ServiceException e), + } diff --git a/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote b/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote index 2e597604e..a9311d32b 100755 --- a/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote +++ b/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote @@ -78,6 +78,9 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help': print ' void removeAccount(string plugin, string account)' print ' bool login(string username, string password)' print ' UserData getUserData()' + print ' getServices()' + print ' bool hasService(string plugin, string func)' + print ' string call(ServiceCall info)' print '' sys.exit(0) @@ -470,6 +473,24 @@ elif cmd == 'getUserData': sys.exit(1) pp.pprint(client.getUserData()) +elif cmd == 'getServices': + if len(args) != 0: + print 'getServices requires 0 args' + sys.exit(1) + pp.pprint(client.getServices()) + +elif cmd == 'hasService': + if len(args) != 2: + print 'hasService requires 2 args' + sys.exit(1) + pp.pprint(client.hasService(args[0],args[1],)) + +elif cmd == 'call': + if len(args) != 1: + print 'call requires 1 args' + sys.exit(1) + pp.pprint(client.call(eval(args[0]),)) + else: print 'Unrecognized method %s' % cmd sys.exit(1) diff --git a/module/remote/thriftbackend/thriftgen/pyload/Pyload.py b/module/remote/thriftbackend/thriftgen/pyload/Pyload.py index 4a3a52cae..ba9d6a7a2 100644 --- a/module/remote/thriftbackend/thriftgen/pyload/Pyload.py +++ b/module/remote/thriftbackend/thriftgen/pyload/Pyload.py @@ -337,6 +337,24 @@ class Iface: def getUserData(self, ): pass + def getServices(self, ): + pass + + def hasService(self, plugin, func): + """ + Parameters: + - plugin + - func + """ + pass + + def call(self, info): + """ + Parameters: + - info + """ + pass + class Client(Iface): def __init__(self, iprot, oprot=None): @@ -1921,6 +1939,97 @@ class Client(Iface): return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserData failed: unknown result"); + def getServices(self, ): + self.send_getServices() + return self.recv_getServices() + + def send_getServices(self, ): + self._oprot.writeMessageBegin('getServices', TMessageType.CALL, self._seqid) + args = getServices_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getServices(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.read(self._iprot) + self._iprot.readMessageEnd() + if result.success != None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "getServices failed: unknown result"); + + def hasService(self, plugin, func): + """ + Parameters: + - plugin + - func + """ + self.send_hasService(plugin, func) + return self.recv_hasService() + + def send_hasService(self, plugin, func): + self._oprot.writeMessageBegin('hasService', TMessageType.CALL, self._seqid) + args = hasService_args() + args.plugin = plugin + args.func = func + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_hasService(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.read(self._iprot) + self._iprot.readMessageEnd() + if result.success != None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "hasService failed: unknown result"); + + def call(self, info): + """ + Parameters: + - info + """ + self.send_call(info) + return self.recv_call() + + def send_call(self, info): + self._oprot.writeMessageBegin('call', TMessageType.CALL, self._seqid) + args = call_args() + args.info = info + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_call(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.read(self._iprot) + self._iprot.readMessageEnd() + if result.success != None: + return result.success + if result.ex != None: + raise result.ex + if result.e != None: + raise result.e + raise TApplicationException(TApplicationException.MISSING_RESULT, "call failed: unknown result"); + class Processor(Iface, TProcessor): def __init__(self, handler): @@ -1983,6 +2092,9 @@ class Processor(Iface, TProcessor): self._processMap["removeAccount"] = Processor.process_removeAccount self._processMap["login"] = Processor.process_login self._processMap["getUserData"] = Processor.process_getUserData + self._processMap["getServices"] = Processor.process_getServices + self._processMap["hasService"] = Processor.process_hasService + self._processMap["call"] = Processor.process_call def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() @@ -2632,6 +2744,44 @@ class Processor(Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_getServices(self, seqid, iprot, oprot): + args = getServices_args() + args.read(iprot) + iprot.readMessageEnd() + result = getServices_result() + result.success = self._handler.getServices() + oprot.writeMessageBegin("getServices", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_hasService(self, seqid, iprot, oprot): + args = hasService_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.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_call(self, seqid, iprot, oprot): + args = call_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.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + # HELPER FUNCTIONS AND STRUCTURES @@ -2978,11 +3128,11 @@ class getConfig_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype42, _size39) = iprot.readListBegin() - for _i43 in xrange(_size39): - _elem44 = ConfigSection() - _elem44.read(iprot) - self.success.append(_elem44) + (_etype58, _size55) = iprot.readListBegin() + for _i59 in xrange(_size55): + _elem60 = ConfigSection() + _elem60.read(iprot) + self.success.append(_elem60) iprot.readListEnd() else: iprot.skip(ftype) @@ -2999,8 +3149,8 @@ class getConfig_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter45 in self.success: - iter45.write(oprot) + for iter61 in self.success: + iter61.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -3086,11 +3236,11 @@ class getPluginConfig_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype49, _size46) = iprot.readListBegin() - for _i50 in xrange(_size46): - _elem51 = ConfigSection() - _elem51.read(iprot) - self.success.append(_elem51) + (_etype65, _size62) = iprot.readListBegin() + for _i66 in xrange(_size62): + _elem67 = ConfigSection() + _elem67.read(iprot) + self.success.append(_elem67) iprot.readListEnd() else: iprot.skip(ftype) @@ -3107,8 +3257,8 @@ class getPluginConfig_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter52 in self.success: - iter52.write(oprot) + for iter68 in self.success: + iter68.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -3937,10 +4087,10 @@ class getLog_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype56, _size53) = iprot.readListBegin() - for _i57 in xrange(_size53): - _elem58 = iprot.readString(); - self.success.append(_elem58) + (_etype72, _size69) = iprot.readListBegin() + for _i73 in xrange(_size69): + _elem74 = iprot.readString(); + self.success.append(_elem74) iprot.readListEnd() else: iprot.skip(ftype) @@ -3957,8 +4107,8 @@ class getLog_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter59 in self.success: - oprot.writeString(iter59) + for iter75 in self.success: + oprot.writeString(iter75) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -4004,10 +4154,10 @@ class checkURL_args: if fid == 1: if ftype == TType.LIST: self.urls = [] - (_etype63, _size60) = iprot.readListBegin() - for _i64 in xrange(_size60): - _elem65 = iprot.readString(); - self.urls.append(_elem65) + (_etype79, _size76) = iprot.readListBegin() + for _i80 in xrange(_size76): + _elem81 = iprot.readString(); + self.urls.append(_elem81) iprot.readListEnd() else: iprot.skip(ftype) @@ -4024,8 +4174,8 @@ class checkURL_args: if self.urls != None: oprot.writeFieldBegin('urls', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.urls)) - for iter66 in self.urls: - oprot.writeString(iter66) + for iter82 in self.urls: + oprot.writeString(iter82) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -4070,11 +4220,11 @@ class checkURL_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype68, _vtype69, _size67 ) = iprot.readMapBegin() - for _i71 in xrange(_size67): - _key72 = iprot.readString(); - _val73 = iprot.readString(); - self.success[_key72] = _val73 + (_ktype84, _vtype85, _size83 ) = iprot.readMapBegin() + for _i87 in xrange(_size83): + _key88 = iprot.readString(); + _val89 = iprot.readString(); + self.success[_key88] = _val89 iprot.readMapEnd() else: iprot.skip(ftype) @@ -4091,9 +4241,9 @@ class checkURL_result: if self.success != None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success)) - for kiter74,viter75 in self.success.items(): - oprot.writeString(kiter74) - oprot.writeString(viter75) + for kiter90,viter91 in self.success.items(): + oprot.writeString(kiter90) + oprot.writeString(viter91) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -4476,11 +4626,11 @@ class statusDownloads_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype79, _size76) = iprot.readListBegin() - for _i80 in xrange(_size76): - _elem81 = DownloadInfo() - _elem81.read(iprot) - self.success.append(_elem81) + (_etype95, _size92) = iprot.readListBegin() + for _i96 in xrange(_size92): + _elem97 = DownloadInfo() + _elem97.read(iprot) + self.success.append(_elem97) iprot.readListEnd() else: iprot.skip(ftype) @@ -4497,8 +4647,8 @@ class statusDownloads_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter82 in self.success: - iter82.write(oprot) + for iter98 in self.success: + iter98.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -4555,10 +4705,10 @@ class addPackage_args: elif fid == 2: if ftype == TType.LIST: self.links = [] - (_etype86, _size83) = iprot.readListBegin() - for _i87 in xrange(_size83): - _elem88 = iprot.readString(); - self.links.append(_elem88) + (_etype102, _size99) = iprot.readListBegin() + for _i103 in xrange(_size99): + _elem104 = iprot.readString(); + self.links.append(_elem104) iprot.readListEnd() else: iprot.skip(ftype) @@ -4584,8 +4734,8 @@ class addPackage_args: if self.links != None: oprot.writeFieldBegin('links', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.links)) - for iter89 in self.links: - oprot.writeString(iter89) + for iter105 in self.links: + oprot.writeString(iter105) oprot.writeListEnd() oprot.writeFieldEnd() if self.dest != None: @@ -4955,10 +5105,10 @@ class deleteFiles_args: if fid == 1: if ftype == TType.LIST: self.fids = [] - (_etype93, _size90) = iprot.readListBegin() - for _i94 in xrange(_size90): - _elem95 = iprot.readI32(); - self.fids.append(_elem95) + (_etype109, _size106) = iprot.readListBegin() + for _i110 in xrange(_size106): + _elem111 = iprot.readI32(); + self.fids.append(_elem111) iprot.readListEnd() else: iprot.skip(ftype) @@ -4975,8 +5125,8 @@ class deleteFiles_args: if self.fids != None: oprot.writeFieldBegin('fids', TType.LIST, 1) oprot.writeListBegin(TType.I32, len(self.fids)) - for iter96 in self.fids: - oprot.writeI32(iter96) + for iter112 in self.fids: + oprot.writeI32(iter112) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -5063,10 +5213,10 @@ class deletePackages_args: if fid == 1: if ftype == TType.LIST: self.pids = [] - (_etype100, _size97) = iprot.readListBegin() - for _i101 in xrange(_size97): - _elem102 = iprot.readI32(); - self.pids.append(_elem102) + (_etype116, _size113) = iprot.readListBegin() + for _i117 in xrange(_size113): + _elem118 = iprot.readI32(); + self.pids.append(_elem118) iprot.readListEnd() else: iprot.skip(ftype) @@ -5083,8 +5233,8 @@ class deletePackages_args: if self.pids != None: oprot.writeFieldBegin('pids', TType.LIST, 1) oprot.writeListBegin(TType.I32, len(self.pids)) - for iter103 in self.pids: - oprot.writeI32(iter103) + for iter119 in self.pids: + oprot.writeI32(iter119) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -5211,11 +5361,11 @@ class getQueue_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype107, _size104) = iprot.readListBegin() - for _i108 in xrange(_size104): - _elem109 = PackageInfo() - _elem109.read(iprot) - self.success.append(_elem109) + (_etype123, _size120) = iprot.readListBegin() + for _i124 in xrange(_size120): + _elem125 = PackageInfo() + _elem125.read(iprot) + self.success.append(_elem125) iprot.readListEnd() else: iprot.skip(ftype) @@ -5232,8 +5382,8 @@ class getQueue_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter110 in self.success: - iter110.write(oprot) + for iter126 in self.success: + iter126.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -5319,11 +5469,11 @@ class getCollector_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype114, _size111) = iprot.readListBegin() - for _i115 in xrange(_size111): - _elem116 = PackageInfo() - _elem116.read(iprot) - self.success.append(_elem116) + (_etype130, _size127) = iprot.readListBegin() + for _i131 in xrange(_size127): + _elem132 = PackageInfo() + _elem132.read(iprot) + self.success.append(_elem132) iprot.readListEnd() else: iprot.skip(ftype) @@ -5340,8 +5490,8 @@ class getCollector_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter117 in self.success: - iter117.write(oprot) + for iter133 in self.success: + iter133.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -5427,11 +5577,11 @@ class getQueueData_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype121, _size118) = iprot.readListBegin() - for _i122 in xrange(_size118): - _elem123 = PackageData() - _elem123.read(iprot) - self.success.append(_elem123) + (_etype137, _size134) = iprot.readListBegin() + for _i138 in xrange(_size134): + _elem139 = PackageData() + _elem139.read(iprot) + self.success.append(_elem139) iprot.readListEnd() else: iprot.skip(ftype) @@ -5448,8 +5598,8 @@ class getQueueData_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter124 in self.success: - iter124.write(oprot) + for iter140 in self.success: + iter140.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -5535,11 +5685,11 @@ class getCollectorData_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype128, _size125) = iprot.readListBegin() - for _i129 in xrange(_size125): - _elem130 = PackageData() - _elem130.read(iprot) - self.success.append(_elem130) + (_etype144, _size141) = iprot.readListBegin() + for _i145 in xrange(_size141): + _elem146 = PackageData() + _elem146.read(iprot) + self.success.append(_elem146) iprot.readListEnd() else: iprot.skip(ftype) @@ -5556,8 +5706,8 @@ class getCollectorData_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter131 in self.success: - iter131.write(oprot) + for iter147 in self.success: + iter147.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -5611,10 +5761,10 @@ class addFiles_args: elif fid == 2: if ftype == TType.LIST: self.links = [] - (_etype135, _size132) = iprot.readListBegin() - for _i136 in xrange(_size132): - _elem137 = iprot.readString(); - self.links.append(_elem137) + (_etype151, _size148) = iprot.readListBegin() + for _i152 in xrange(_size148): + _elem153 = iprot.readString(); + self.links.append(_elem153) iprot.readListEnd() else: iprot.skip(ftype) @@ -5635,8 +5785,8 @@ class addFiles_args: if self.links != None: oprot.writeFieldBegin('links', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.links)) - for iter138 in self.links: - oprot.writeString(iter138) + for iter154 in self.links: + oprot.writeString(iter154) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -6305,10 +6455,10 @@ class stopDownloads_args: if fid == 1: if ftype == TType.LIST: self.fids = [] - (_etype142, _size139) = iprot.readListBegin() - for _i143 in xrange(_size139): - _elem144 = iprot.readI32(); - self.fids.append(_elem144) + (_etype158, _size155) = iprot.readListBegin() + for _i159 in xrange(_size155): + _elem160 = iprot.readI32(); + self.fids.append(_elem160) iprot.readListEnd() else: iprot.skip(ftype) @@ -6325,8 +6475,8 @@ class stopDownloads_args: if self.fids != None: oprot.writeFieldBegin('fids', TType.LIST, 1) oprot.writeListBegin(TType.I32, len(self.fids)) - for iter145 in self.fids: - oprot.writeI32(iter145) + for iter161 in self.fids: + oprot.writeI32(iter161) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -7093,11 +7243,11 @@ class setPackageData_args: elif fid == 2: if ftype == TType.MAP: self.data = {} - (_ktype147, _vtype148, _size146 ) = iprot.readMapBegin() - for _i150 in xrange(_size146): - _key151 = iprot.readString(); - _val152 = iprot.readString(); - self.data[_key151] = _val152 + (_ktype163, _vtype164, _size162 ) = iprot.readMapBegin() + for _i166 in xrange(_size162): + _key167 = iprot.readString(); + _val168 = iprot.readString(); + self.data[_key167] = _val168 iprot.readMapEnd() else: iprot.skip(ftype) @@ -7118,9 +7268,9 @@ class setPackageData_args: if self.data != None: oprot.writeFieldBegin('data', TType.MAP, 2) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.data)) - for kiter153,viter154 in self.data.items(): - oprot.writeString(kiter153) - oprot.writeString(viter154) + for kiter169,viter170 in self.data.items(): + oprot.writeString(kiter169) + oprot.writeString(viter170) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -7429,11 +7579,11 @@ class getPackageOrder_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype156, _vtype157, _size155 ) = iprot.readMapBegin() - for _i159 in xrange(_size155): - _key160 = iprot.readI16(); - _val161 = iprot.readI32(); - self.success[_key160] = _val161 + (_ktype172, _vtype173, _size171 ) = iprot.readMapBegin() + for _i175 in xrange(_size171): + _key176 = iprot.readI16(); + _val177 = iprot.readI32(); + self.success[_key176] = _val177 iprot.readMapEnd() else: iprot.skip(ftype) @@ -7450,9 +7600,9 @@ class getPackageOrder_result: if self.success != None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.I16, TType.I32, len(self.success)) - for kiter162,viter163 in self.success.items(): - oprot.writeI16(kiter162) - oprot.writeI32(viter163) + for kiter178,viter179 in self.success.items(): + oprot.writeI16(kiter178) + oprot.writeI32(viter179) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -7556,11 +7706,11 @@ class getFileOrder_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype165, _vtype166, _size164 ) = iprot.readMapBegin() - for _i168 in xrange(_size164): - _key169 = iprot.readI16(); - _val170 = iprot.readI32(); - self.success[_key169] = _val170 + (_ktype181, _vtype182, _size180 ) = iprot.readMapBegin() + for _i184 in xrange(_size180): + _key185 = iprot.readI16(); + _val186 = iprot.readI32(); + self.success[_key185] = _val186 iprot.readMapEnd() else: iprot.skip(ftype) @@ -7577,9 +7727,9 @@ class getFileOrder_result: if self.success != None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.I16, TType.I32, len(self.success)) - for kiter171,viter172 in self.success.items(): - oprot.writeI16(kiter171) - oprot.writeI32(viter172) + for kiter187,viter188 in self.success.items(): + oprot.writeI16(kiter187) + oprot.writeI32(viter188) oprot.writeMapEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8129,11 +8279,11 @@ class getEvents_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype176, _size173) = iprot.readListBegin() - for _i177 in xrange(_size173): - _elem178 = Event() - _elem178.read(iprot) - self.success.append(_elem178) + (_etype192, _size189) = iprot.readListBegin() + for _i193 in xrange(_size189): + _elem194 = Event() + _elem194.read(iprot) + self.success.append(_elem194) iprot.readListEnd() else: iprot.skip(ftype) @@ -8150,8 +8300,8 @@ class getEvents_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter179 in self.success: - iter179.write(oprot) + for iter195 in self.success: + iter195.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8255,11 +8405,11 @@ class getAccounts_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype183, _size180) = iprot.readListBegin() - for _i184 in xrange(_size180): - _elem185 = AccountInfo() - _elem185.read(iprot) - self.success.append(_elem185) + (_etype199, _size196) = iprot.readListBegin() + for _i200 in xrange(_size196): + _elem201 = AccountInfo() + _elem201.read(iprot) + self.success.append(_elem201) iprot.readListEnd() else: iprot.skip(ftype) @@ -8276,8 +8426,8 @@ class getAccounts_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter186 in self.success: - iter186.write(oprot) + for iter202 in self.success: + iter202.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8363,10 +8513,10 @@ class getAccountTypes_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype190, _size187) = iprot.readListBegin() - for _i191 in xrange(_size187): - _elem192 = iprot.readString(); - self.success.append(_elem192) + (_etype206, _size203) = iprot.readListBegin() + for _i207 in xrange(_size203): + _elem208 = iprot.readString(); + self.success.append(_elem208) iprot.readListEnd() else: iprot.skip(ftype) @@ -8383,8 +8533,8 @@ class getAccountTypes_result: if self.success != None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter193 in self.success: - oprot.writeString(iter193) + for iter209 in self.success: + oprot.writeString(iter209) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -8845,3 +8995,386 @@ class getUserData_result: def __ne__(self, other): return not (self == other) + +class getServices_args: + + thrift_spec = ( + ) + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('getServices_args') + oprot.writeFieldStop() + oprot.writeStructEnd() + def validate(self): + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class getServices_result: + """ + Attributes: + - success + """ + + thrift_spec = ( + (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(ServiceInfo, ServiceInfo.thrift_spec)), None, ), # 0 + ) + + def __init__(self, success=None,): + self.success = success + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.MAP: + self.success = {} + (_ktype211, _vtype212, _size210 ) = iprot.readMapBegin() + for _i214 in xrange(_size210): + _key215 = iprot.readString(); + _val216 = ServiceInfo() + _val216.read(iprot) + self.success[_key215] = _val216 + iprot.readMapEnd() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('getServices_result') + if self.success != None: + oprot.writeFieldBegin('success', TType.MAP, 0) + oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) + for kiter217,viter218 in self.success.items(): + oprot.writeString(kiter217) + viter218.write(oprot) + oprot.writeMapEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + def validate(self): + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class hasService_args: + """ + Attributes: + - plugin + - func + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'plugin', None, None, ), # 1 + (2, TType.STRING, 'func', None, None, ), # 2 + ) + + def __init__(self, plugin=None, func=None,): + self.plugin = plugin + self.func = func + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + self.plugin = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.func = iprot.readString(); + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('hasService_args') + if self.plugin != None: + oprot.writeFieldBegin('plugin', TType.STRING, 1) + oprot.writeString(self.plugin) + oprot.writeFieldEnd() + if self.func != None: + oprot.writeFieldBegin('func', TType.STRING, 2) + oprot.writeString(self.func) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + def validate(self): + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class hasService_result: + """ + Attributes: + - success + """ + + thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + ) + + def __init__(self, success=None,): + self.success = success + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.BOOL: + self.success = iprot.readBool(); + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('hasService_result') + if self.success != None: + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + def validate(self): + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class call_args: + """ + Attributes: + - info + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'info', (ServiceCall, ServiceCall.thrift_spec), None, ), # 1 + ) + + def __init__(self, info=None,): + self.info = info + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRUCT: + self.info = ServiceCall() + self.info.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('call_args') + if self.info != None: + oprot.writeFieldBegin('info', TType.STRUCT, 1) + self.info.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + def validate(self): + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class call_result: + """ + Attributes: + - 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 + ) + + def __init__(self, success=None, ex=None, e=None,): + self.success = success + self.ex = ex + self.e = e + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.STRING: + self.success = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.ex = ServiceDoesNotExists() + self.ex.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.e = ServiceException() + self.e.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('call_result') + if self.success != None: + oprot.writeFieldBegin('success', TType.STRING, 0) + oprot.writeString(self.success) + oprot.writeFieldEnd() + if self.ex != None: + oprot.writeFieldBegin('ex', TType.STRUCT, 1) + self.ex.write(oprot) + oprot.writeFieldEnd() + if self.e != None: + oprot.writeFieldBegin('e', TType.STRUCT, 2) + self.e.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + def validate(self): + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) diff --git a/module/remote/thriftbackend/thriftgen/pyload/ttypes.py b/module/remote/thriftbackend/thriftgen/pyload/ttypes.py index c207c7bc4..b3ef98de3 100644 --- a/module/remote/thriftbackend/thriftgen/pyload/ttypes.py +++ b/module/remote/thriftbackend/thriftgen/pyload/ttypes.py @@ -1690,6 +1690,178 @@ class AccountData: def __ne__(self, other): return not (self == other) +class ServiceInfo: + """ + Attributes: + - funcs + """ + + thrift_spec = ( + None, # 0 + (1, TType.MAP, 'funcs', (TType.STRING,None,TType.STRING,None), None, ), # 1 + ) + + def __init__(self, funcs=None,): + self.funcs = funcs + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.MAP: + self.funcs = {} + (_ktype40, _vtype41, _size39 ) = iprot.readMapBegin() + for _i43 in xrange(_size39): + _key44 = iprot.readString(); + _val45 = iprot.readString(); + self.funcs[_key44] = _val45 + iprot.readMapEnd() + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('ServiceInfo') + if self.funcs != None: + oprot.writeFieldBegin('funcs', TType.MAP, 1) + oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.funcs)) + for kiter46,viter47 in self.funcs.items(): + oprot.writeString(kiter46) + oprot.writeString(viter47) + oprot.writeMapEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + def validate(self): + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ServiceCall: + """ + Attributes: + - plugin + - func + - arguments + - parseArguments + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'plugin', None, None, ), # 1 + (2, TType.STRING, 'func', None, None, ), # 2 + (3, TType.LIST, 'arguments', (TType.STRING,None), None, ), # 3 + (4, TType.BOOL, 'parseArguments', None, None, ), # 4 + ) + + def __init__(self, plugin=None, func=None, arguments=None, parseArguments=None,): + self.plugin = plugin + self.func = func + self.arguments = arguments + self.parseArguments = parseArguments + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + self.plugin = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.func = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.LIST: + self.arguments = [] + (_etype51, _size48) = iprot.readListBegin() + for _i52 in xrange(_size48): + _elem53 = iprot.readString(); + self.arguments.append(_elem53) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.BOOL: + self.parseArguments = iprot.readBool(); + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('ServiceCall') + if self.plugin != None: + oprot.writeFieldBegin('plugin', TType.STRING, 1) + oprot.writeString(self.plugin) + oprot.writeFieldEnd() + if self.func != None: + oprot.writeFieldBegin('func', TType.STRING, 2) + oprot.writeString(self.func) + oprot.writeFieldEnd() + if self.arguments != None: + oprot.writeFieldBegin('arguments', TType.LIST, 3) + oprot.writeListBegin(TType.STRING, len(self.arguments)) + for iter54 in self.arguments: + oprot.writeString(iter54) + oprot.writeListEnd() + oprot.writeFieldEnd() + if self.parseArguments != None: + oprot.writeFieldBegin('parseArguments', TType.BOOL, 4) + oprot.writeBool(self.parseArguments) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + def validate(self): + return + + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + class PackageDoesNotExists(Exception): """ Attributes: @@ -1813,3 +1985,139 @@ class FileDoesNotExists(Exception): def __ne__(self, other): return not (self == other) + +class ServiceDoesNotExists(Exception): + """ + Attributes: + - plugin + - func + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'plugin', None, None, ), # 1 + (2, TType.STRING, 'func', None, None, ), # 2 + ) + + def __init__(self, plugin=None, func=None,): + self.plugin = plugin + self.func = func + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + self.plugin = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.func = iprot.readString(); + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('ServiceDoesNotExists') + if self.plugin != None: + oprot.writeFieldBegin('plugin', TType.STRING, 1) + oprot.writeString(self.plugin) + oprot.writeFieldEnd() + if self.func != None: + oprot.writeFieldBegin('func', TType.STRING, 2) + oprot.writeString(self.func) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + def validate(self): + return + + + def __str__(self): + return repr(self) + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class ServiceException(Exception): + """ + Attributes: + - msg + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'msg', None, None, ), # 1 + ) + + def __init__(self, msg=None,): + self.msg = msg + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 1: + if ftype == TType.STRING: + self.msg = iprot.readString(); + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('ServiceException') + if self.msg != None: + oprot.writeFieldBegin('msg', TType.STRING, 1) + oprot.writeString(self.msg) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + def validate(self): + return + + + def __str__(self): + return repr(self) + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) |