summaryrefslogtreecommitdiffstats
path: root/pyload/remote/thriftbackend
diff options
context:
space:
mode:
authorGravatar Walter Purcaro <vuolter@users.noreply.github.com> 2015-04-13 17:20:59 +0200
committerGravatar Walter Purcaro <vuolter@users.noreply.github.com> 2015-04-13 17:20:59 +0200
commite00ef98491f79ae8aa972ae1473dae4a7b78c07e (patch)
tree31be0c7cdcebb61525bcc387bcf15d265a1c494a /pyload/remote/thriftbackend
parentFix except (diff)
downloadpyload-e00ef98491f79ae8aa972ae1473dae4a7b78c07e.tar.xz
Cleanup
Diffstat (limited to 'pyload/remote/thriftbackend')
-rw-r--r--pyload/remote/thriftbackend/Processor.py3
-rw-r--r--pyload/remote/thriftbackend/Protocol.py2
-rw-r--r--pyload/remote/thriftbackend/Socket.py13
-rw-r--r--pyload/remote/thriftbackend/ThriftClient.py4
-rw-r--r--pyload/remote/thriftbackend/Transport.py4
-rw-r--r--pyload/remote/thriftbackend/thriftgen/pyload/Pyload.py442
-rw-r--r--pyload/remote/thriftbackend/thriftgen/pyload/ttypes.py22
7 files changed, 490 insertions, 0 deletions
diff --git a/pyload/remote/thriftbackend/Processor.py b/pyload/remote/thriftbackend/Processor.py
index 683697d1c..24a0c05b6 100644
--- a/pyload/remote/thriftbackend/Processor.py
+++ b/pyload/remote/thriftbackend/Processor.py
@@ -3,16 +3,19 @@
from pyload.remote.thriftbackend.thriftgen.pyload import Pyload
class Processor(Pyload.Processor):
+
def __init__(self, *args, **kwargs):
Pyload.Processor.__init__(self, *args, **kwargs)
self.authenticated = {}
+
def process(self, iprot, oprot):
trans = oprot.trans
if trans not in self.authenticated:
self.authenticated[trans] = False
oldclose = trans.close
+
def wrap():
if self in self.authenticated:
del self.authenticated[trans]
diff --git a/pyload/remote/thriftbackend/Protocol.py b/pyload/remote/thriftbackend/Protocol.py
index 417b45834..c020e7a23 100644
--- a/pyload/remote/thriftbackend/Protocol.py
+++ b/pyload/remote/thriftbackend/Protocol.py
@@ -3,6 +3,7 @@
from thrift.protocol import TBinaryProtocol
class Protocol(TBinaryProtocol.TBinaryProtocol):
+
def writeString(self, str):
try:
str = str.encode("utf8", "ignore")
@@ -12,6 +13,7 @@ class Protocol(TBinaryProtocol.TBinaryProtocol):
self.writeI32(len(str))
self.trans.write(str)
+
def readString(self):
len = self.readI32()
str = self.trans.readAll(len)
diff --git a/pyload/remote/thriftbackend/Socket.py b/pyload/remote/thriftbackend/Socket.py
index f6edc8408..7e1268c5c 100644
--- a/pyload/remote/thriftbackend/Socket.py
+++ b/pyload/remote/thriftbackend/Socket.py
@@ -11,22 +11,28 @@ from thrift.transport.TSocket import TSocket, TServerSocket, TTransportException
WantReadError = Exception #overwritten when ssl is used
class SecureSocketConnection(object):
+
def __init__(self, connection):
self.__dict__["connection"] = connection
+
def __getattr__(self, name):
return getattr(self.__dict__["connection"], name)
+
def __setattr__(self, name, value):
setattr(self.__dict__["connection"], name, value)
+
def shutdown(self, how=1):
self.__dict__["connection"].shutdown()
+
def accept(self):
connection, address = self.__dict__["connection"].accept()
return SecureSocketConnection(connection), address
+
def send(self, buff):
try:
return self.__dict__["connection"].send(buff)
@@ -34,6 +40,7 @@ class SecureSocketConnection(object):
sleep(0.1)
return self.send(buff)
+
def recv(self, buff):
try:
return self.__dict__["connection"].recv(buff)
@@ -42,10 +49,12 @@ class SecureSocketConnection(object):
return self.recv(buff)
class Socket(TSocket):
+
def __init__(self, host='localhost', port=7228, ssl=False):
TSocket.__init__(self, host, port)
self.ssl = ssl
+
def open(self):
if self.ssl:
SSL = __import__("OpenSSL", globals(), locals(), "SSL", -1).SSL
@@ -62,6 +71,7 @@ class Socket(TSocket):
self.handle.settimeout(self._timeout)
self.handle.connect((self.host, self.port))
+
def read(self, sz):
try:
buff = self.handle.recv(sz)
@@ -93,6 +103,7 @@ class Socket(TSocket):
class ServerSocket(TServerSocket, Socket):
+
def __init__(self, port=7228, host="0.0.0.0", key="", cert=""):
self.host = host
self.port = port
@@ -100,6 +111,7 @@ class ServerSocket(TServerSocket, Socket):
self.cert = cert
self.handle = None
+
def listen(self):
if self.cert and self.key:
SSL = __import__("OpenSSL", globals(), locals(), "SSL", -1).SSL
@@ -122,6 +134,7 @@ class ServerSocket(TServerSocket, Socket):
self.handle.bind((self.host, self.port))
self.handle.listen(128)
+
def accept(self):
client, addr = self.handle.accept()
result = Socket()
diff --git a/pyload/remote/thriftbackend/ThriftClient.py b/pyload/remote/thriftbackend/ThriftClient.py
index 26658e341..c779c9b9c 100644
--- a/pyload/remote/thriftbackend/ThriftClient.py
+++ b/pyload/remote/thriftbackend/ThriftClient.py
@@ -36,6 +36,7 @@ class NoSSL(Exception):
pass
class ThriftClient(object):
+
def __init__(self, host="localhost", port=7227, user="", password=""):
self.createConnection(host, port)
@@ -76,6 +77,7 @@ class ThriftClient(object):
self.transport.close()
raise WrongLogin
+
def createConnection(self, host, port, ssl=False):
self.socket = Socket(host, port, ssl)
self.transport = TTransport.TBufferedTransport(self.socket)
@@ -84,8 +86,10 @@ class ThriftClient(object):
protocol = Protocol(self.transport)
self.client = Pyload.Client(protocol)
+
def close(self):
self.transport.close()
+
def __getattr__(self, item):
return getattr(self.client, item)
diff --git a/pyload/remote/thriftbackend/Transport.py b/pyload/remote/thriftbackend/Transport.py
index 7db4ba9d7..7ecb16746 100644
--- a/pyload/remote/thriftbackend/Transport.py
+++ b/pyload/remote/thriftbackend/Transport.py
@@ -6,6 +6,7 @@ from thrift.transport.TZlibTransport import TZlibTransport
class Transport(TBufferedTransport):
DEFAULT_BUFFER = 4096
+
def __init__(self, trans, rbuf_size = DEFAULT_BUFFER):
TBufferedTransport.__init__(self, trans, rbuf_size)
self.handle = trans.handle
@@ -14,12 +15,14 @@ class Transport(TBufferedTransport):
class TransportCompressed(TZlibTransport):
DEFAULT_BUFFER = 4096
+
def __init__(self, trans, rbuf_size = DEFAULT_BUFFER):
TZlibTransport.__init__(self, trans, rbuf_size)
self.handle = trans.handle
self.remoteaddr = trans.handle.getpeername()
class TransportFactory(object):
+
def getTransport(self, trans):
buffered = Transport(trans)
return buffered
@@ -28,6 +31,7 @@ class TransportFactoryCompressed(object):
_last_trans = None
_last_z = None
+
def getTransport(self, trans, compresslevel=9):
if trans == self._last_trans:
return self._last_z
diff --git a/pyload/remote/thriftbackend/thriftgen/pyload/Pyload.py b/pyload/remote/thriftbackend/thriftgen/pyload/Pyload.py
index e8d2cf9af..874b705ba 100644
--- a/pyload/remote/thriftbackend/thriftgen/pyload/Pyload.py
+++ b/pyload/remote/thriftbackend/thriftgen/pyload/Pyload.py
@@ -13,6 +13,7 @@ from thrift.protocol.TBase import TBase, TExceptionBase
class Iface(object):
+
def getConfigValue(self, category, option, section):
"""
Parameters:
@@ -22,6 +23,7 @@ class Iface(object):
"""
pass
+
def setConfigValue(self, category, option, value, section):
"""
Parameters:
@@ -32,36 +34,47 @@ class Iface(object):
"""
pass
+
def getConfig(self,):
pass
+
def getPluginConfig(self,):
pass
+
def pauseServer(self,):
pass
+
def unpauseServer(self,):
pass
+
def togglePause(self,):
pass
+
def statusServer(self,):
pass
+
def freeSpace(self,):
pass
+
def getServerVersion(self,):
pass
+
def kill(self,):
pass
+
def restart(self,):
pass
+
def getLog(self, offset):
"""
Parameters:
@@ -69,15 +82,19 @@ class Iface(object):
"""
pass
+
def isTimeDownload(self,):
pass
+
def isTimeReconnect(self,):
pass
+
def toggleReconnect(self,):
pass
+
def generatePackages(self, links):
"""
Parameters:
@@ -85,6 +102,7 @@ class Iface(object):
"""
pass
+
def checkURLs(self, urls):
"""
Parameters:
@@ -92,6 +110,7 @@ class Iface(object):
"""
pass
+
def parseURLs(self, html, url):
"""
Parameters:
@@ -100,6 +119,7 @@ class Iface(object):
"""
pass
+
def checkOnlineStatus(self, urls):
"""
Parameters:
@@ -107,6 +127,7 @@ class Iface(object):
"""
pass
+
def checkOnlineStatusContainer(self, urls, filename, data):
"""
Parameters:
@@ -116,6 +137,7 @@ class Iface(object):
"""
pass
+
def pollResults(self, rid):
"""
Parameters:
@@ -123,9 +145,11 @@ class Iface(object):
"""
pass
+
def statusDownloads(self,):
pass
+
def getPackageData(self, pid):
"""
Parameters:
@@ -133,6 +157,7 @@ class Iface(object):
"""
pass
+
def getPackageInfo(self, pid):
"""
Parameters:
@@ -140,6 +165,7 @@ class Iface(object):
"""
pass
+
def getFileData(self, fid):
"""
Parameters:
@@ -147,18 +173,23 @@ class Iface(object):
"""
pass
+
def getQueue(self,):
pass
+
def getCollector(self,):
pass
+
def getQueueData(self,):
pass
+
def getCollectorData(self,):
pass
+
def getPackageOrder(self, destination):
"""
Parameters:
@@ -166,6 +197,7 @@ class Iface(object):
"""
pass
+
def getFileOrder(self, pid):
"""
Parameters:
@@ -173,6 +205,7 @@ class Iface(object):
"""
pass
+
def generateAndAddPackages(self, links, dest):
"""
Parameters:
@@ -181,6 +214,7 @@ class Iface(object):
"""
pass
+
def addPackage(self, name, links, dest):
"""
Parameters:
@@ -190,6 +224,7 @@ class Iface(object):
"""
pass
+
def addFiles(self, pid, links):
"""
Parameters:
@@ -198,6 +233,7 @@ class Iface(object):
"""
pass
+
def uploadContainer(self, filename, data):
"""
Parameters:
@@ -206,6 +242,7 @@ class Iface(object):
"""
pass
+
def deleteFiles(self, fids):
"""
Parameters:
@@ -213,6 +250,7 @@ class Iface(object):
"""
pass
+
def deletePackages(self, pids):
"""
Parameters:
@@ -220,6 +258,7 @@ class Iface(object):
"""
pass
+
def pushToQueue(self, pid):
"""
Parameters:
@@ -227,6 +266,7 @@ class Iface(object):
"""
pass
+
def pullFromQueue(self, pid):
"""
Parameters:
@@ -234,6 +274,7 @@ class Iface(object):
"""
pass
+
def restartPackage(self, pid):
"""
Parameters:
@@ -241,6 +282,7 @@ class Iface(object):
"""
pass
+
def restartFile(self, fid):
"""
Parameters:
@@ -248,6 +290,7 @@ class Iface(object):
"""
pass
+
def recheckPackage(self, pid):
"""
Parameters:
@@ -255,9 +298,11 @@ class Iface(object):
"""
pass
+
def stopAllDownloads(self,):
pass
+
def stopDownloads(self, fids):
"""
Parameters:
@@ -265,6 +310,7 @@ class Iface(object):
"""
pass
+
def setPackageName(self, pid, name):
"""
Parameters:
@@ -273,6 +319,7 @@ class Iface(object):
"""
pass
+
def movePackage(self, destination, pid):
"""
Parameters:
@@ -281,6 +328,7 @@ class Iface(object):
"""
pass
+
def moveFiles(self, fids, pid):
"""
Parameters:
@@ -289,6 +337,7 @@ class Iface(object):
"""
pass
+
def orderPackage(self, pid, position):
"""
Parameters:
@@ -297,6 +346,7 @@ class Iface(object):
"""
pass
+
def orderFile(self, fid, position):
"""
Parameters:
@@ -305,6 +355,7 @@ class Iface(object):
"""
pass
+
def setPackageData(self, pid, data):
"""
Parameters:
@@ -313,12 +364,15 @@ class Iface(object):
"""
pass
+
def deleteFinished(self,):
pass
+
def restartFailed(self,):
pass
+
def getEvents(self, uuid):
"""
Parameters:
@@ -326,6 +380,7 @@ class Iface(object):
"""
pass
+
def getAccounts(self, refresh):
"""
Parameters:
@@ -333,9 +388,11 @@ class Iface(object):
"""
pass
+
def getAccountTypes(self,):
pass
+
def updateAccount(self, plugin, account, password, options):
"""
Parameters:
@@ -346,6 +403,7 @@ class Iface(object):
"""
pass
+
def removeAccount(self, plugin, account):
"""
Parameters:
@@ -354,6 +412,7 @@ class Iface(object):
"""
pass
+
def login(self, username, password):
"""
Parameters:
@@ -362,6 +421,7 @@ class Iface(object):
"""
pass
+
def getUserData(self, username, password):
"""
Parameters:
@@ -370,12 +430,15 @@ class Iface(object):
"""
pass
+
def getAllUserData(self,):
pass
+
def getServices(self,):
pass
+
def hasService(self, plugin, func):
"""
Parameters:
@@ -384,6 +447,7 @@ class Iface(object):
"""
pass
+
def call(self, info):
"""
Parameters:
@@ -391,9 +455,11 @@ class Iface(object):
"""
pass
+
def getAllInfo(self,):
pass
+
def getInfoByPlugin(self, plugin):
"""
Parameters:
@@ -401,9 +467,11 @@ class Iface(object):
"""
pass
+
def isCaptchaWaiting(self,):
pass
+
def getCaptchaTask(self, exclusive):
"""
Parameters:
@@ -411,6 +479,7 @@ class Iface(object):
"""
pass
+
def getCaptchaTaskStatus(self, tid):
"""
Parameters:
@@ -418,6 +487,7 @@ class Iface(object):
"""
pass
+
def setCaptchaResult(self, tid, result):
"""
Parameters:
@@ -428,12 +498,14 @@ class Iface(object):
class Client(Iface):
+
def __init__(self, iprot, oprot=None):
self._iprot = self._oprot = iprot
if oprot is not None:
self._oprot = oprot
self._seqid = 0
+
def getConfigValue(self, category, option, section):
"""
Parameters:
@@ -444,6 +516,7 @@ class Client(Iface):
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()
@@ -454,6 +527,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getConfigValue(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -468,6 +542,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfigValue failed: unknown result");
+
def setConfigValue(self, category, option, value, section):
"""
Parameters:
@@ -479,6 +554,7 @@ class Client(Iface):
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()
@@ -490,6 +566,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_setConfigValue(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -502,10 +579,12 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
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()
@@ -513,6 +592,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getConfig(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -527,10 +607,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfig failed: unknown result");
+
def getPluginConfig(self,):
self.send_getPluginConfig()
return self.recv_getPluginConfig()
+
def send_getPluginConfig(self,):
self._oprot.writeMessageBegin('getPluginConfig', TMessageType.CALL, self._seqid)
args = getPluginConfig_args()
@@ -538,6 +620,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getPluginConfig(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -552,10 +635,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getPluginConfig failed: unknown result");
+
def pauseServer(self,):
self.send_pauseServer()
self.recv_pauseServer()
+
def send_pauseServer(self,):
self._oprot.writeMessageBegin('pauseServer', TMessageType.CALL, self._seqid)
args = pauseServer_args()
@@ -563,6 +648,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_pauseServer(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -575,10 +661,12 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def unpauseServer(self,):
self.send_unpauseServer()
self.recv_unpauseServer()
+
def send_unpauseServer(self,):
self._oprot.writeMessageBegin('unpauseServer', TMessageType.CALL, self._seqid)
args = unpauseServer_args()
@@ -586,6 +674,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_unpauseServer(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -598,10 +687,12 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def togglePause(self,):
self.send_togglePause()
return self.recv_togglePause()
+
def send_togglePause(self,):
self._oprot.writeMessageBegin('togglePause', TMessageType.CALL, self._seqid)
args = togglePause_args()
@@ -609,6 +700,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_togglePause(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -623,10 +715,12 @@ 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()
@@ -634,6 +728,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_statusServer(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -648,10 +743,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "statusServer failed: unknown result");
+
def freeSpace(self,):
self.send_freeSpace()
return self.recv_freeSpace()
+
def send_freeSpace(self,):
self._oprot.writeMessageBegin('freeSpace', TMessageType.CALL, self._seqid)
args = freeSpace_args()
@@ -659,6 +756,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_freeSpace(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -673,10 +771,12 @@ 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()
@@ -684,6 +784,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getServerVersion(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -698,10 +799,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getServerVersion failed: unknown result");
+
def kill(self,):
self.send_kill()
self.recv_kill()
+
def send_kill(self,):
self._oprot.writeMessageBegin('kill', TMessageType.CALL, self._seqid)
args = kill_args()
@@ -709,6 +812,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_kill(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -721,10 +825,12 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def restart(self,):
self.send_restart()
self.recv_restart()
+
def send_restart(self,):
self._oprot.writeMessageBegin('restart', TMessageType.CALL, self._seqid)
args = restart_args()
@@ -732,6 +838,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_restart(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -744,6 +851,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def getLog(self, offset):
"""
Parameters:
@@ -752,6 +860,7 @@ class Client(Iface):
self.send_getLog(offset)
return self.recv_getLog()
+
def send_getLog(self, offset):
self._oprot.writeMessageBegin('getLog', TMessageType.CALL, self._seqid)
args = getLog_args()
@@ -760,6 +869,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getLog(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -774,10 +884,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getLog failed: unknown result");
+
def isTimeDownload(self,):
self.send_isTimeDownload()
return self.recv_isTimeDownload()
+
def send_isTimeDownload(self,):
self._oprot.writeMessageBegin('isTimeDownload', TMessageType.CALL, self._seqid)
args = isTimeDownload_args()
@@ -785,6 +897,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_isTimeDownload(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -799,10 +912,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "isTimeDownload failed: unknown result");
+
def isTimeReconnect(self,):
self.send_isTimeReconnect()
return self.recv_isTimeReconnect()
+
def send_isTimeReconnect(self,):
self._oprot.writeMessageBegin('isTimeReconnect', TMessageType.CALL, self._seqid)
args = isTimeReconnect_args()
@@ -810,6 +925,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_isTimeReconnect(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -824,10 +940,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "isTimeReconnect failed: unknown result");
+
def toggleReconnect(self,):
self.send_toggleReconnect()
return self.recv_toggleReconnect()
+
def send_toggleReconnect(self,):
self._oprot.writeMessageBegin('toggleReconnect', TMessageType.CALL, self._seqid)
args = toggleReconnect_args()
@@ -835,6 +953,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_toggleReconnect(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -849,6 +968,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "toggleReconnect failed: unknown result");
+
def generatePackages(self, links):
"""
Parameters:
@@ -857,6 +977,7 @@ class Client(Iface):
self.send_generatePackages(links)
return self.recv_generatePackages()
+
def send_generatePackages(self, links):
self._oprot.writeMessageBegin('generatePackages', TMessageType.CALL, self._seqid)
args = generatePackages_args()
@@ -865,6 +986,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_generatePackages(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -879,6 +1001,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "generatePackages failed: unknown result");
+
def checkURLs(self, urls):
"""
Parameters:
@@ -887,6 +1010,7 @@ class Client(Iface):
self.send_checkURLs(urls)
return self.recv_checkURLs()
+
def send_checkURLs(self, urls):
self._oprot.writeMessageBegin('checkURLs', TMessageType.CALL, self._seqid)
args = checkURLs_args()
@@ -895,6 +1019,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_checkURLs(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -909,6 +1034,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "checkURLs failed: unknown result");
+
def parseURLs(self, html, url):
"""
Parameters:
@@ -918,6 +1044,7 @@ class Client(Iface):
self.send_parseURLs(html, url)
return self.recv_parseURLs()
+
def send_parseURLs(self, html, url):
self._oprot.writeMessageBegin('parseURLs', TMessageType.CALL, self._seqid)
args = parseURLs_args()
@@ -927,6 +1054,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_parseURLs(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -941,6 +1069,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "parseURLs failed: unknown result");
+
def checkOnlineStatus(self, urls):
"""
Parameters:
@@ -949,6 +1078,7 @@ class Client(Iface):
self.send_checkOnlineStatus(urls)
return self.recv_checkOnlineStatus()
+
def send_checkOnlineStatus(self, urls):
self._oprot.writeMessageBegin('checkOnlineStatus', TMessageType.CALL, self._seqid)
args = checkOnlineStatus_args()
@@ -957,6 +1087,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_checkOnlineStatus(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -971,6 +1102,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "checkOnlineStatus failed: unknown result");
+
def checkOnlineStatusContainer(self, urls, filename, data):
"""
Parameters:
@@ -981,6 +1113,7 @@ class Client(Iface):
self.send_checkOnlineStatusContainer(urls, filename, data)
return self.recv_checkOnlineStatusContainer()
+
def send_checkOnlineStatusContainer(self, urls, filename, data):
self._oprot.writeMessageBegin('checkOnlineStatusContainer', TMessageType.CALL, self._seqid)
args = checkOnlineStatusContainer_args()
@@ -991,6 +1124,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_checkOnlineStatusContainer(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1005,6 +1139,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "checkOnlineStatusContainer failed: unknown result");
+
def pollResults(self, rid):
"""
Parameters:
@@ -1013,6 +1148,7 @@ class Client(Iface):
self.send_pollResults(rid)
return self.recv_pollResults()
+
def send_pollResults(self, rid):
self._oprot.writeMessageBegin('pollResults', TMessageType.CALL, self._seqid)
args = pollResults_args()
@@ -1021,6 +1157,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_pollResults(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1035,10 +1172,12 @@ 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 send_statusDownloads(self,):
self._oprot.writeMessageBegin('statusDownloads', TMessageType.CALL, self._seqid)
args = statusDownloads_args()
@@ -1046,6 +1185,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_statusDownloads(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1060,6 +1200,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "statusDownloads failed: unknown result");
+
def getPackageData(self, pid):
"""
Parameters:
@@ -1068,6 +1209,7 @@ class Client(Iface):
self.send_getPackageData(pid)
return self.recv_getPackageData()
+
def send_getPackageData(self, pid):
self._oprot.writeMessageBegin('getPackageData', TMessageType.CALL, self._seqid)
args = getPackageData_args()
@@ -1076,6 +1218,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getPackageData(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1092,6 +1235,7 @@ class Client(Iface):
raise result.e
raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageData failed: unknown result");
+
def getPackageInfo(self, pid):
"""
Parameters:
@@ -1100,6 +1244,7 @@ class Client(Iface):
self.send_getPackageInfo(pid)
return self.recv_getPackageInfo()
+
def send_getPackageInfo(self, pid):
self._oprot.writeMessageBegin('getPackageInfo', TMessageType.CALL, self._seqid)
args = getPackageInfo_args()
@@ -1108,6 +1253,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getPackageInfo(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1124,6 +1270,7 @@ class Client(Iface):
raise result.e
raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageInfo failed: unknown result");
+
def getFileData(self, fid):
"""
Parameters:
@@ -1132,6 +1279,7 @@ class Client(Iface):
self.send_getFileData(fid)
return self.recv_getFileData()
+
def send_getFileData(self, fid):
self._oprot.writeMessageBegin('getFileData', TMessageType.CALL, self._seqid)
args = getFileData_args()
@@ -1140,6 +1288,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getFileData(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1156,10 +1305,12 @@ class Client(Iface):
raise result.e
raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileData failed: unknown result");
+
def getQueue(self,):
self.send_getQueue()
return self.recv_getQueue()
+
def send_getQueue(self,):
self._oprot.writeMessageBegin('getQueue', TMessageType.CALL, self._seqid)
args = getQueue_args()
@@ -1167,6 +1318,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getQueue(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1181,10 +1333,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueue failed: unknown result");
+
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()
@@ -1192,6 +1346,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getCollector(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1206,10 +1361,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getCollector failed: unknown result");
+
def getQueueData(self,):
self.send_getQueueData()
return self.recv_getQueueData()
+
def send_getQueueData(self,):
self._oprot.writeMessageBegin('getQueueData', TMessageType.CALL, self._seqid)
args = getQueueData_args()
@@ -1217,6 +1374,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getQueueData(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1231,10 +1389,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueueData failed: unknown result");
+
def getCollectorData(self,):
self.send_getCollectorData()
return self.recv_getCollectorData()
+
def send_getCollectorData(self,):
self._oprot.writeMessageBegin('getCollectorData', TMessageType.CALL, self._seqid)
args = getCollectorData_args()
@@ -1242,6 +1402,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getCollectorData(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1256,6 +1417,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getCollectorData failed: unknown result");
+
def getPackageOrder(self, destination):
"""
Parameters:
@@ -1264,6 +1426,7 @@ class Client(Iface):
self.send_getPackageOrder(destination)
return self.recv_getPackageOrder()
+
def send_getPackageOrder(self, destination):
self._oprot.writeMessageBegin('getPackageOrder', TMessageType.CALL, self._seqid)
args = getPackageOrder_args()
@@ -1272,6 +1435,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getPackageOrder(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1286,6 +1450,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageOrder failed: unknown result");
+
def getFileOrder(self, pid):
"""
Parameters:
@@ -1294,6 +1459,7 @@ class Client(Iface):
self.send_getFileOrder(pid)
return self.recv_getFileOrder()
+
def send_getFileOrder(self, pid):
self._oprot.writeMessageBegin('getFileOrder', TMessageType.CALL, self._seqid)
args = getFileOrder_args()
@@ -1302,6 +1468,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getFileOrder(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1316,6 +1483,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileOrder failed: unknown result");
+
def generateAndAddPackages(self, links, dest):
"""
Parameters:
@@ -1325,6 +1493,7 @@ class Client(Iface):
self.send_generateAndAddPackages(links, dest)
return self.recv_generateAndAddPackages()
+
def send_generateAndAddPackages(self, links, dest):
self._oprot.writeMessageBegin('generateAndAddPackages', TMessageType.CALL, self._seqid)
args = generateAndAddPackages_args()
@@ -1334,6 +1503,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_generateAndAddPackages(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1348,6 +1518,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndAddPackages failed: unknown result");
+
def addPackage(self, name, links, dest):
"""
Parameters:
@@ -1358,6 +1529,7 @@ class Client(Iface):
self.send_addPackage(name, links, dest)
return self.recv_addPackage()
+
def send_addPackage(self, name, links, dest):
self._oprot.writeMessageBegin('addPackage', TMessageType.CALL, self._seqid)
args = addPackage_args()
@@ -1368,6 +1540,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_addPackage(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1382,6 +1555,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "addPackage failed: unknown result");
+
def addFiles(self, pid, links):
"""
Parameters:
@@ -1391,6 +1565,7 @@ class Client(Iface):
self.send_addFiles(pid, links)
self.recv_addFiles()
+
def send_addFiles(self, pid, links):
self._oprot.writeMessageBegin('addFiles', TMessageType.CALL, self._seqid)
args = addFiles_args()
@@ -1400,6 +1575,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_addFiles(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1412,6 +1588,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def uploadContainer(self, filename, data):
"""
Parameters:
@@ -1421,6 +1598,7 @@ class Client(Iface):
self.send_uploadContainer(filename, data)
self.recv_uploadContainer()
+
def send_uploadContainer(self, filename, data):
self._oprot.writeMessageBegin('uploadContainer', TMessageType.CALL, self._seqid)
args = uploadContainer_args()
@@ -1430,6 +1608,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_uploadContainer(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1442,6 +1621,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def deleteFiles(self, fids):
"""
Parameters:
@@ -1450,6 +1630,7 @@ class Client(Iface):
self.send_deleteFiles(fids)
self.recv_deleteFiles()
+
def send_deleteFiles(self, fids):
self._oprot.writeMessageBegin('deleteFiles', TMessageType.CALL, self._seqid)
args = deleteFiles_args()
@@ -1458,6 +1639,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_deleteFiles(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1470,6 +1652,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def deletePackages(self, pids):
"""
Parameters:
@@ -1478,6 +1661,7 @@ class Client(Iface):
self.send_deletePackages(pids)
self.recv_deletePackages()
+
def send_deletePackages(self, pids):
self._oprot.writeMessageBegin('deletePackages', TMessageType.CALL, self._seqid)
args = deletePackages_args()
@@ -1486,6 +1670,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_deletePackages(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1498,6 +1683,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def pushToQueue(self, pid):
"""
Parameters:
@@ -1506,6 +1692,7 @@ class Client(Iface):
self.send_pushToQueue(pid)
self.recv_pushToQueue()
+
def send_pushToQueue(self, pid):
self._oprot.writeMessageBegin('pushToQueue', TMessageType.CALL, self._seqid)
args = pushToQueue_args()
@@ -1514,6 +1701,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_pushToQueue(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1526,6 +1714,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def pullFromQueue(self, pid):
"""
Parameters:
@@ -1534,6 +1723,7 @@ class Client(Iface):
self.send_pullFromQueue(pid)
self.recv_pullFromQueue()
+
def send_pullFromQueue(self, pid):
self._oprot.writeMessageBegin('pullFromQueue', TMessageType.CALL, self._seqid)
args = pullFromQueue_args()
@@ -1542,6 +1732,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_pullFromQueue(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1554,6 +1745,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def restartPackage(self, pid):
"""
Parameters:
@@ -1562,6 +1754,7 @@ class Client(Iface):
self.send_restartPackage(pid)
self.recv_restartPackage()
+
def send_restartPackage(self, pid):
self._oprot.writeMessageBegin('restartPackage', TMessageType.CALL, self._seqid)
args = restartPackage_args()
@@ -1570,6 +1763,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_restartPackage(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1582,6 +1776,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def restartFile(self, fid):
"""
Parameters:
@@ -1590,6 +1785,7 @@ class Client(Iface):
self.send_restartFile(fid)
self.recv_restartFile()
+
def send_restartFile(self, fid):
self._oprot.writeMessageBegin('restartFile', TMessageType.CALL, self._seqid)
args = restartFile_args()
@@ -1598,6 +1794,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_restartFile(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1610,6 +1807,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def recheckPackage(self, pid):
"""
Parameters:
@@ -1618,6 +1816,7 @@ class Client(Iface):
self.send_recheckPackage(pid)
self.recv_recheckPackage()
+
def send_recheckPackage(self, pid):
self._oprot.writeMessageBegin('recheckPackage', TMessageType.CALL, self._seqid)
args = recheckPackage_args()
@@ -1626,6 +1825,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_recheckPackage(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1638,10 +1838,12 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def stopAllDownloads(self,):
self.send_stopAllDownloads()
self.recv_stopAllDownloads()
+
def send_stopAllDownloads(self,):
self._oprot.writeMessageBegin('stopAllDownloads', TMessageType.CALL, self._seqid)
args = stopAllDownloads_args()
@@ -1649,6 +1851,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_stopAllDownloads(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1661,6 +1864,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def stopDownloads(self, fids):
"""
Parameters:
@@ -1669,6 +1873,7 @@ class Client(Iface):
self.send_stopDownloads(fids)
self.recv_stopDownloads()
+
def send_stopDownloads(self, fids):
self._oprot.writeMessageBegin('stopDownloads', TMessageType.CALL, self._seqid)
args = stopDownloads_args()
@@ -1677,6 +1882,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_stopDownloads(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1689,6 +1895,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def setPackageName(self, pid, name):
"""
Parameters:
@@ -1698,6 +1905,7 @@ class Client(Iface):
self.send_setPackageName(pid, name)
self.recv_setPackageName()
+
def send_setPackageName(self, pid, name):
self._oprot.writeMessageBegin('setPackageName', TMessageType.CALL, self._seqid)
args = setPackageName_args()
@@ -1707,6 +1915,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_setPackageName(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1719,6 +1928,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def movePackage(self, destination, pid):
"""
Parameters:
@@ -1728,6 +1938,7 @@ class Client(Iface):
self.send_movePackage(destination, pid)
self.recv_movePackage()
+
def send_movePackage(self, destination, pid):
self._oprot.writeMessageBegin('movePackage', TMessageType.CALL, self._seqid)
args = movePackage_args()
@@ -1737,6 +1948,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_movePackage(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1749,6 +1961,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def moveFiles(self, fids, pid):
"""
Parameters:
@@ -1758,6 +1971,7 @@ class Client(Iface):
self.send_moveFiles(fids, pid)
self.recv_moveFiles()
+
def send_moveFiles(self, fids, pid):
self._oprot.writeMessageBegin('moveFiles', TMessageType.CALL, self._seqid)
args = moveFiles_args()
@@ -1767,6 +1981,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_moveFiles(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1779,6 +1994,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def orderPackage(self, pid, position):
"""
Parameters:
@@ -1788,6 +2004,7 @@ class Client(Iface):
self.send_orderPackage(pid, position)
self.recv_orderPackage()
+
def send_orderPackage(self, pid, position):
self._oprot.writeMessageBegin('orderPackage', TMessageType.CALL, self._seqid)
args = orderPackage_args()
@@ -1797,6 +2014,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_orderPackage(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1809,6 +2027,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def orderFile(self, fid, position):
"""
Parameters:
@@ -1818,6 +2037,7 @@ class Client(Iface):
self.send_orderFile(fid, position)
self.recv_orderFile()
+
def send_orderFile(self, fid, position):
self._oprot.writeMessageBegin('orderFile', TMessageType.CALL, self._seqid)
args = orderFile_args()
@@ -1827,6 +2047,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_orderFile(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1839,6 +2060,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def setPackageData(self, pid, data):
"""
Parameters:
@@ -1848,6 +2070,7 @@ class Client(Iface):
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()
@@ -1857,6 +2080,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_setPackageData(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1871,10 +2095,12 @@ class Client(Iface):
raise result.e
return
+
def deleteFinished(self,):
self.send_deleteFinished()
return self.recv_deleteFinished()
+
def send_deleteFinished(self,):
self._oprot.writeMessageBegin('deleteFinished', TMessageType.CALL, self._seqid)
args = deleteFinished_args()
@@ -1882,6 +2108,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_deleteFinished(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1896,10 +2123,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteFinished failed: unknown result");
+
def restartFailed(self,):
self.send_restartFailed()
self.recv_restartFailed()
+
def send_restartFailed(self,):
self._oprot.writeMessageBegin('restartFailed', TMessageType.CALL, self._seqid)
args = restartFailed_args()
@@ -1907,6 +2136,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_restartFailed(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1919,6 +2149,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def getEvents(self, uuid):
"""
Parameters:
@@ -1927,6 +2158,7 @@ class Client(Iface):
self.send_getEvents(uuid)
return self.recv_getEvents()
+
def send_getEvents(self, uuid):
self._oprot.writeMessageBegin('getEvents', TMessageType.CALL, self._seqid)
args = getEvents_args()
@@ -1935,6 +2167,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getEvents(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1949,6 +2182,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getEvents failed: unknown result");
+
def getAccounts(self, refresh):
"""
Parameters:
@@ -1957,6 +2191,7 @@ class Client(Iface):
self.send_getAccounts(refresh)
return self.recv_getAccounts()
+
def send_getAccounts(self, refresh):
self._oprot.writeMessageBegin('getAccounts', TMessageType.CALL, self._seqid)
args = getAccounts_args()
@@ -1965,6 +2200,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getAccounts(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -1979,10 +2215,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getAccounts failed: unknown result");
+
def getAccountTypes(self,):
self.send_getAccountTypes()
return self.recv_getAccountTypes()
+
def send_getAccountTypes(self,):
self._oprot.writeMessageBegin('getAccountTypes', TMessageType.CALL, self._seqid)
args = getAccountTypes_args()
@@ -1990,6 +2228,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getAccountTypes(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2004,6 +2243,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getAccountTypes failed: unknown result");
+
def updateAccount(self, plugin, account, password, options):
"""
Parameters:
@@ -2015,6 +2255,7 @@ class Client(Iface):
self.send_updateAccount(plugin, account, password, options)
self.recv_updateAccount()
+
def send_updateAccount(self, plugin, account, password, options):
self._oprot.writeMessageBegin('updateAccount', TMessageType.CALL, self._seqid)
args = updateAccount_args()
@@ -2026,6 +2267,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_updateAccount(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2038,6 +2280,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def removeAccount(self, plugin, account):
"""
Parameters:
@@ -2047,6 +2290,7 @@ class Client(Iface):
self.send_removeAccount(plugin, account)
self.recv_removeAccount()
+
def send_removeAccount(self, plugin, account):
self._oprot.writeMessageBegin('removeAccount', TMessageType.CALL, self._seqid)
args = removeAccount_args()
@@ -2056,6 +2300,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_removeAccount(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2068,6 +2313,7 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+
def login(self, username, password):
"""
Parameters:
@@ -2077,6 +2323,7 @@ class Client(Iface):
self.send_login(username, password)
return self.recv_login()
+
def send_login(self, username, password):
self._oprot.writeMessageBegin('login', TMessageType.CALL, self._seqid)
args = login_args()
@@ -2086,6 +2333,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_login(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2100,6 +2348,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "login failed: unknown result");
+
def getUserData(self, username, password):
"""
Parameters:
@@ -2109,6 +2358,7 @@ class Client(Iface):
self.send_getUserData(username, password)
return self.recv_getUserData()
+
def send_getUserData(self, username, password):
self._oprot.writeMessageBegin('getUserData', TMessageType.CALL, self._seqid)
args = getUserData_args()
@@ -2118,6 +2368,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getUserData(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2132,10 +2383,12 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getUserData failed: unknown result");
+
def getAllUserData(self,):
self.send_getAllUserData()
return self.recv_getAllUserData()
+
def send_getAllUserData(self,):
self._oprot.writeMessageBegin('getAllUserData', TMessageType.CALL, self._seqid)
args = getAllUserData_args()
@@ -2143,6 +2396,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getAllUserData(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2157,10 +2411,12 @@ 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 send_getServices(self,):
self._oprot.writeMessageBegin('getServices', TMessageType.CALL, self._seqid)
args = getServices_args()
@@ -2168,6 +2424,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getServices(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2182,6 +2439,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getServices failed: unknown result");
+
def hasService(self, plugin, func):
"""
Parameters:
@@ -2191,6 +2449,7 @@ class Client(Iface):
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()
@@ -2200,6 +2459,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_hasService(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2214,6 +2474,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "hasService failed: unknown result");
+
def call(self, info):
"""
Parameters:
@@ -2222,6 +2483,7 @@ class Client(Iface):
self.send_call(info)
return self.recv_call()
+
def send_call(self, info):
self._oprot.writeMessageBegin('call', TMessageType.CALL, self._seqid)
args = call_args()
@@ -2230,6 +2492,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_call(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2248,10 +2511,12 @@ class Client(Iface):
raise result.e
raise TApplicationException(TApplicationException.MISSING_RESULT, "call failed: unknown result");
+
def getAllInfo(self,):
self.send_getAllInfo()
return self.recv_getAllInfo()
+
def send_getAllInfo(self,):
self._oprot.writeMessageBegin('getAllInfo', TMessageType.CALL, self._seqid)
args = getAllInfo_args()
@@ -2259,6 +2524,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getAllInfo(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2273,6 +2539,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllInfo failed: unknown result");
+
def getInfoByPlugin(self, plugin):
"""
Parameters:
@@ -2281,6 +2548,7 @@ class Client(Iface):
self.send_getInfoByPlugin(plugin)
return self.recv_getInfoByPlugin()
+
def send_getInfoByPlugin(self, plugin):
self._oprot.writeMessageBegin('getInfoByPlugin', TMessageType.CALL, self._seqid)
args = getInfoByPlugin_args()
@@ -2289,6 +2557,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getInfoByPlugin(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2303,10 +2572,12 @@ 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 send_isCaptchaWaiting(self,):
self._oprot.writeMessageBegin('isCaptchaWaiting', TMessageType.CALL, self._seqid)
args = isCaptchaWaiting_args()
@@ -2314,6 +2585,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_isCaptchaWaiting(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2328,6 +2600,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "isCaptchaWaiting failed: unknown result");
+
def getCaptchaTask(self, exclusive):
"""
Parameters:
@@ -2336,6 +2609,7 @@ class Client(Iface):
self.send_getCaptchaTask(exclusive)
return self.recv_getCaptchaTask()
+
def send_getCaptchaTask(self, exclusive):
self._oprot.writeMessageBegin('getCaptchaTask', TMessageType.CALL, self._seqid)
args = getCaptchaTask_args()
@@ -2344,6 +2618,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getCaptchaTask(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2358,6 +2633,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getCaptchaTask failed: unknown result");
+
def getCaptchaTaskStatus(self, tid):
"""
Parameters:
@@ -2366,6 +2642,7 @@ class Client(Iface):
self.send_getCaptchaTaskStatus(tid)
return self.recv_getCaptchaTaskStatus()
+
def send_getCaptchaTaskStatus(self, tid):
self._oprot.writeMessageBegin('getCaptchaTaskStatus', TMessageType.CALL, self._seqid)
args = getCaptchaTaskStatus_args()
@@ -2374,6 +2651,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_getCaptchaTaskStatus(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2388,6 +2666,7 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "getCaptchaTaskStatus failed: unknown result");
+
def setCaptchaResult(self, tid, result):
"""
Parameters:
@@ -2397,6 +2676,7 @@ class Client(Iface):
self.send_setCaptchaResult(tid, result)
self.recv_setCaptchaResult()
+
def send_setCaptchaResult(self, tid, result):
self._oprot.writeMessageBegin('setCaptchaResult', TMessageType.CALL, self._seqid)
args = setCaptchaResult_args()
@@ -2406,6 +2686,7 @@ class Client(Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
+
def recv_setCaptchaResult(self,):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
@@ -2420,6 +2701,7 @@ class Client(Iface):
class Processor(Iface, TProcessor):
+
def __init__(self, handler):
self._handler = handler
self._processMap = {}
@@ -2494,6 +2776,7 @@ class Processor(Iface, TProcessor):
self._processMap["getCaptchaTaskStatus"] = Processor.process_getCaptchaTaskStatus
self._processMap["setCaptchaResult"] = Processor.process_setCaptchaResult
+
def process(self, iprot, oprot):
(name, type, seqid) = iprot.readMessageBegin()
if name not in self._processMap:
@@ -2509,6 +2792,7 @@ 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)
@@ -2520,6 +2804,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_setConfigValue(self, seqid, iprot, oprot):
args = setConfigValue_args()
args.read(iprot)
@@ -2531,6 +2816,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getConfig(self, seqid, iprot, oprot):
args = getConfig_args()
args.read(iprot)
@@ -2542,6 +2828,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getPluginConfig(self, seqid, iprot, oprot):
args = getPluginConfig_args()
args.read(iprot)
@@ -2553,6 +2840,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_pauseServer(self, seqid, iprot, oprot):
args = pauseServer_args()
args.read(iprot)
@@ -2564,6 +2852,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_unpauseServer(self, seqid, iprot, oprot):
args = unpauseServer_args()
args.read(iprot)
@@ -2575,6 +2864,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_togglePause(self, seqid, iprot, oprot):
args = togglePause_args()
args.read(iprot)
@@ -2586,6 +2876,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_statusServer(self, seqid, iprot, oprot):
args = statusServer_args()
args.read(iprot)
@@ -2597,6 +2888,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_freeSpace(self, seqid, iprot, oprot):
args = freeSpace_args()
args.read(iprot)
@@ -2608,6 +2900,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getServerVersion(self, seqid, iprot, oprot):
args = getServerVersion_args()
args.read(iprot)
@@ -2619,6 +2912,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_kill(self, seqid, iprot, oprot):
args = kill_args()
args.read(iprot)
@@ -2630,6 +2924,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_restart(self, seqid, iprot, oprot):
args = restart_args()
args.read(iprot)
@@ -2641,6 +2936,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getLog(self, seqid, iprot, oprot):
args = getLog_args()
args.read(iprot)
@@ -2652,6 +2948,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_isTimeDownload(self, seqid, iprot, oprot):
args = isTimeDownload_args()
args.read(iprot)
@@ -2663,6 +2960,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_isTimeReconnect(self, seqid, iprot, oprot):
args = isTimeReconnect_args()
args.read(iprot)
@@ -2674,6 +2972,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_toggleReconnect(self, seqid, iprot, oprot):
args = toggleReconnect_args()
args.read(iprot)
@@ -2685,6 +2984,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_generatePackages(self, seqid, iprot, oprot):
args = generatePackages_args()
args.read(iprot)
@@ -2696,6 +2996,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_checkURLs(self, seqid, iprot, oprot):
args = checkURLs_args()
args.read(iprot)
@@ -2707,6 +3008,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_parseURLs(self, seqid, iprot, oprot):
args = parseURLs_args()
args.read(iprot)
@@ -2718,6 +3020,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_checkOnlineStatus(self, seqid, iprot, oprot):
args = checkOnlineStatus_args()
args.read(iprot)
@@ -2729,6 +3032,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_checkOnlineStatusContainer(self, seqid, iprot, oprot):
args = checkOnlineStatusContainer_args()
args.read(iprot)
@@ -2740,6 +3044,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_pollResults(self, seqid, iprot, oprot):
args = pollResults_args()
args.read(iprot)
@@ -2751,6 +3056,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_statusDownloads(self, seqid, iprot, oprot):
args = statusDownloads_args()
args.read(iprot)
@@ -2762,6 +3068,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getPackageData(self, seqid, iprot, oprot):
args = getPackageData_args()
args.read(iprot)
@@ -2776,6 +3083,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getPackageInfo(self, seqid, iprot, oprot):
args = getPackageInfo_args()
args.read(iprot)
@@ -2790,6 +3098,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getFileData(self, seqid, iprot, oprot):
args = getFileData_args()
args.read(iprot)
@@ -2804,6 +3113,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getQueue(self, seqid, iprot, oprot):
args = getQueue_args()
args.read(iprot)
@@ -2815,6 +3125,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getCollector(self, seqid, iprot, oprot):
args = getCollector_args()
args.read(iprot)
@@ -2826,6 +3137,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getQueueData(self, seqid, iprot, oprot):
args = getQueueData_args()
args.read(iprot)
@@ -2837,6 +3149,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getCollectorData(self, seqid, iprot, oprot):
args = getCollectorData_args()
args.read(iprot)
@@ -2848,6 +3161,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getPackageOrder(self, seqid, iprot, oprot):
args = getPackageOrder_args()
args.read(iprot)
@@ -2859,6 +3173,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getFileOrder(self, seqid, iprot, oprot):
args = getFileOrder_args()
args.read(iprot)
@@ -2870,6 +3185,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_generateAndAddPackages(self, seqid, iprot, oprot):
args = generateAndAddPackages_args()
args.read(iprot)
@@ -2881,6 +3197,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_addPackage(self, seqid, iprot, oprot):
args = addPackage_args()
args.read(iprot)
@@ -2892,6 +3209,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_addFiles(self, seqid, iprot, oprot):
args = addFiles_args()
args.read(iprot)
@@ -2903,6 +3221,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_uploadContainer(self, seqid, iprot, oprot):
args = uploadContainer_args()
args.read(iprot)
@@ -2914,6 +3233,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_deleteFiles(self, seqid, iprot, oprot):
args = deleteFiles_args()
args.read(iprot)
@@ -2925,6 +3245,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_deletePackages(self, seqid, iprot, oprot):
args = deletePackages_args()
args.read(iprot)
@@ -2936,6 +3257,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_pushToQueue(self, seqid, iprot, oprot):
args = pushToQueue_args()
args.read(iprot)
@@ -2947,6 +3269,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_pullFromQueue(self, seqid, iprot, oprot):
args = pullFromQueue_args()
args.read(iprot)
@@ -2958,6 +3281,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_restartPackage(self, seqid, iprot, oprot):
args = restartPackage_args()
args.read(iprot)
@@ -2969,6 +3293,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_restartFile(self, seqid, iprot, oprot):
args = restartFile_args()
args.read(iprot)
@@ -2980,6 +3305,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_recheckPackage(self, seqid, iprot, oprot):
args = recheckPackage_args()
args.read(iprot)
@@ -2991,6 +3317,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_stopAllDownloads(self, seqid, iprot, oprot):
args = stopAllDownloads_args()
args.read(iprot)
@@ -3002,6 +3329,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_stopDownloads(self, seqid, iprot, oprot):
args = stopDownloads_args()
args.read(iprot)
@@ -3013,6 +3341,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_setPackageName(self, seqid, iprot, oprot):
args = setPackageName_args()
args.read(iprot)
@@ -3024,6 +3353,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_movePackage(self, seqid, iprot, oprot):
args = movePackage_args()
args.read(iprot)
@@ -3035,6 +3365,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_moveFiles(self, seqid, iprot, oprot):
args = moveFiles_args()
args.read(iprot)
@@ -3046,6 +3377,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_orderPackage(self, seqid, iprot, oprot):
args = orderPackage_args()
args.read(iprot)
@@ -3057,6 +3389,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_orderFile(self, seqid, iprot, oprot):
args = orderFile_args()
args.read(iprot)
@@ -3068,6 +3401,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_setPackageData(self, seqid, iprot, oprot):
args = setPackageData_args()
args.read(iprot)
@@ -3082,6 +3416,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_deleteFinished(self, seqid, iprot, oprot):
args = deleteFinished_args()
args.read(iprot)
@@ -3093,6 +3428,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_restartFailed(self, seqid, iprot, oprot):
args = restartFailed_args()
args.read(iprot)
@@ -3104,6 +3440,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getEvents(self, seqid, iprot, oprot):
args = getEvents_args()
args.read(iprot)
@@ -3115,6 +3452,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getAccounts(self, seqid, iprot, oprot):
args = getAccounts_args()
args.read(iprot)
@@ -3126,6 +3464,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getAccountTypes(self, seqid, iprot, oprot):
args = getAccountTypes_args()
args.read(iprot)
@@ -3137,6 +3476,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_updateAccount(self, seqid, iprot, oprot):
args = updateAccount_args()
args.read(iprot)
@@ -3148,6 +3488,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_removeAccount(self, seqid, iprot, oprot):
args = removeAccount_args()
args.read(iprot)
@@ -3159,6 +3500,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_login(self, seqid, iprot, oprot):
args = login_args()
args.read(iprot)
@@ -3170,6 +3512,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getUserData(self, seqid, iprot, oprot):
args = getUserData_args()
args.read(iprot)
@@ -3181,6 +3524,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getAllUserData(self, seqid, iprot, oprot):
args = getAllUserData_args()
args.read(iprot)
@@ -3192,6 +3536,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getServices(self, seqid, iprot, oprot):
args = getServices_args()
args.read(iprot)
@@ -3203,6 +3548,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_hasService(self, seqid, iprot, oprot):
args = hasService_args()
args.read(iprot)
@@ -3214,6 +3560,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_call(self, seqid, iprot, oprot):
args = call_args()
args.read(iprot)
@@ -3230,6 +3577,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getAllInfo(self, seqid, iprot, oprot):
args = getAllInfo_args()
args.read(iprot)
@@ -3241,6 +3589,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getInfoByPlugin(self, seqid, iprot, oprot):
args = getInfoByPlugin_args()
args.read(iprot)
@@ -3252,6 +3601,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_isCaptchaWaiting(self, seqid, iprot, oprot):
args = isCaptchaWaiting_args()
args.read(iprot)
@@ -3263,6 +3613,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getCaptchaTask(self, seqid, iprot, oprot):
args = getCaptchaTask_args()
args.read(iprot)
@@ -3274,6 +3625,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_getCaptchaTaskStatus(self, seqid, iprot, oprot):
args = getCaptchaTaskStatus_args()
args.read(iprot)
@@ -3285,6 +3637,7 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+
def process_setCaptchaResult(self, seqid, iprot, oprot):
args = setCaptchaResult_args()
args.read(iprot)
@@ -3320,6 +3673,7 @@ class getConfigValue_args(TBase):
(3, TType.STRING, 'section', None, None,), # 3
)
+
def __init__(self, category=None, option=None, section=None,):
self.category = category
self.option = option
@@ -3340,6 +3694,7 @@ class getConfigValue_result(TBase):
(0, TType.STRING, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3368,6 +3723,7 @@ class setConfigValue_args(TBase):
(4, TType.STRING, 'section', None, None,), # 4
)
+
def __init__(self, category=None, option=None, value=None, section=None,):
self.category = category
self.option = option
@@ -3407,6 +3763,7 @@ class getConfig_result(TBase):
(0, TType.MAP, 'success', (TType.STRING, None, TType.STRUCT, (ConfigSection, ConfigSection.thrift_spec)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3434,6 +3791,7 @@ class getPluginConfig_result(TBase):
(0, TType.MAP, 'success', (TType.STRING, None, TType.STRUCT, (ConfigSection, ConfigSection.thrift_spec)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3497,6 +3855,7 @@ class togglePause_result(TBase):
(0, TType.BOOL, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3524,6 +3883,7 @@ class statusServer_result(TBase):
(0, TType.STRUCT, 'success', (ServerStatus, ServerStatus.thrift_spec), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3551,6 +3911,7 @@ class freeSpace_result(TBase):
(0, TType.I64, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3578,6 +3939,7 @@ class getServerVersion_result(TBase):
(0, TType.STRING, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3633,6 +3995,7 @@ class getLog_args(TBase):
(1, TType.I32, 'offset', None, None,), # 1
)
+
def __init__(self, offset=None,):
self.offset = offset
@@ -3651,6 +4014,7 @@ class getLog_result(TBase):
(0, TType.LIST, 'success', (TType.STRING, None), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3678,6 +4042,7 @@ class isTimeDownload_result(TBase):
(0, TType.BOOL, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3705,6 +4070,7 @@ class isTimeReconnect_result(TBase):
(0, TType.BOOL, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3732,6 +4098,7 @@ class toggleReconnect_result(TBase):
(0, TType.BOOL, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3751,6 +4118,7 @@ class generatePackages_args(TBase):
(1, TType.LIST, 'links', (TType.STRING, None), None,), # 1
)
+
def __init__(self, links=None,):
self.links = links
@@ -3769,6 +4137,7 @@ class generatePackages_result(TBase):
(0, TType.MAP, 'success', (TType.STRING, None, TType.LIST, (TType.STRING, None)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3788,6 +4157,7 @@ class checkURLs_args(TBase):
(1, TType.LIST, 'urls', (TType.STRING, None), None,), # 1
)
+
def __init__(self, urls=None,):
self.urls = urls
@@ -3806,6 +4176,7 @@ class checkURLs_result(TBase):
(0, TType.MAP, 'success', (TType.STRING, None, TType.LIST, (TType.STRING, None)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3828,6 +4199,7 @@ class parseURLs_args(TBase):
(2, TType.STRING, 'url', None, None,), # 2
)
+
def __init__(self, html=None, url=None,):
self.html = html
self.url = url
@@ -3847,6 +4219,7 @@ class parseURLs_result(TBase):
(0, TType.MAP, 'success', (TType.STRING, None, TType.LIST, (TType.STRING, None)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3866,6 +4239,7 @@ class checkOnlineStatus_args(TBase):
(1, TType.LIST, 'urls', (TType.STRING, None), None,), # 1
)
+
def __init__(self, urls=None,):
self.urls = urls
@@ -3884,6 +4258,7 @@ class checkOnlineStatus_result(TBase):
(0, TType.STRUCT, 'success', (OnlineCheck, OnlineCheck.thrift_spec), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3909,6 +4284,7 @@ class checkOnlineStatusContainer_args(TBase):
(3, TType.STRING, 'data', None, None,), # 3
)
+
def __init__(self, urls=None, filename=None, data=None,):
self.urls = urls
self.filename = filename
@@ -3929,6 +4305,7 @@ class checkOnlineStatusContainer_result(TBase):
(0, TType.STRUCT, 'success', (OnlineCheck, OnlineCheck.thrift_spec), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3948,6 +4325,7 @@ class pollResults_args(TBase):
(1, TType.I32, 'rid', None, None,), # 1
)
+
def __init__(self, rid=None,):
self.rid = rid
@@ -3966,6 +4344,7 @@ class pollResults_result(TBase):
(0, TType.STRUCT, 'success', (OnlineCheck, OnlineCheck.thrift_spec), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -3993,6 +4372,7 @@ class statusDownloads_result(TBase):
(0, TType.LIST, 'success', (TType.STRUCT, (DownloadInfo, DownloadInfo.thrift_spec)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4012,6 +4392,7 @@ class getPackageData_args(TBase):
(1, TType.I32, 'pid', None, None,), # 1
)
+
def __init__(self, pid=None,):
self.pid = pid
@@ -4033,6 +4414,7 @@ class getPackageData_result(TBase):
(1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None,), # 1
)
+
def __init__(self, success=None, e=None,):
self.success = success
self.e = e
@@ -4053,6 +4435,7 @@ class getPackageInfo_args(TBase):
(1, TType.I32, 'pid', None, None,), # 1
)
+
def __init__(self, pid=None,):
self.pid = pid
@@ -4074,6 +4457,7 @@ class getPackageInfo_result(TBase):
(1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None,), # 1
)
+
def __init__(self, success=None, e=None,):
self.success = success
self.e = e
@@ -4094,6 +4478,7 @@ class getFileData_args(TBase):
(1, TType.I32, 'fid', None, None,), # 1
)
+
def __init__(self, fid=None,):
self.fid = fid
@@ -4115,6 +4500,7 @@ class getFileData_result(TBase):
(1, TType.STRUCT, 'e', (FileDoesNotExists, FileDoesNotExists.thrift_spec), None,), # 1
)
+
def __init__(self, success=None, e=None,):
self.success = success
self.e = e
@@ -4143,6 +4529,7 @@ class getQueue_result(TBase):
(0, TType.LIST, 'success', (TType.STRUCT, (PackageData, PackageData.thrift_spec)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4170,6 +4557,7 @@ class getCollector_result(TBase):
(0, TType.LIST, 'success', (TType.STRUCT, (PackageData, PackageData.thrift_spec)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4197,6 +4585,7 @@ class getQueueData_result(TBase):
(0, TType.LIST, 'success', (TType.STRUCT, (PackageData, PackageData.thrift_spec)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4224,6 +4613,7 @@ class getCollectorData_result(TBase):
(0, TType.LIST, 'success', (TType.STRUCT, (PackageData, PackageData.thrift_spec)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4243,6 +4633,7 @@ class getPackageOrder_args(TBase):
(1, TType.I32, 'destination', None, None,), # 1
)
+
def __init__(self, destination=None,):
self.destination = destination
@@ -4261,6 +4652,7 @@ class getPackageOrder_result(TBase):
(0, TType.MAP, 'success', (TType.I16, None, TType.I32, None), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4280,6 +4672,7 @@ class getFileOrder_args(TBase):
(1, TType.I32, 'pid', None, None,), # 1
)
+
def __init__(self, pid=None,):
self.pid = pid
@@ -4298,6 +4691,7 @@ class getFileOrder_result(TBase):
(0, TType.MAP, 'success', (TType.I16, None, TType.I32, None), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4320,6 +4714,7 @@ class generateAndAddPackages_args(TBase):
(2, TType.I32, 'dest', None, None,), # 2
)
+
def __init__(self, links=None, dest=None,):
self.links = links
self.dest = dest
@@ -4339,6 +4734,7 @@ class generateAndAddPackages_result(TBase):
(0, TType.LIST, 'success', (TType.I32, None), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4364,6 +4760,7 @@ class addPackage_args(TBase):
(3, TType.I32, 'dest', None, None,), # 3
)
+
def __init__(self, name=None, links=None, dest=None,):
self.name = name
self.links = links
@@ -4384,6 +4781,7 @@ class addPackage_result(TBase):
(0, TType.I32, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4406,6 +4804,7 @@ class addFiles_args(TBase):
(2, TType.LIST, 'links', (TType.STRING, None), None,), # 2
)
+
def __init__(self, pid=None, links=None,):
self.pid = pid
self.links = links
@@ -4438,6 +4837,7 @@ class uploadContainer_args(TBase):
(2, TType.STRING, 'data', None, None,), # 2
)
+
def __init__(self, filename=None, data=None,):
self.filename = filename
self.data = data
@@ -4467,6 +4867,7 @@ class deleteFiles_args(TBase):
(1, TType.LIST, 'fids', (TType.I32, None), None,), # 1
)
+
def __init__(self, fids=None,):
self.fids = fids
@@ -4495,6 +4896,7 @@ class deletePackages_args(TBase):
(1, TType.LIST, 'pids', (TType.I32, None), None,), # 1
)
+
def __init__(self, pids=None,):
self.pids = pids
@@ -4523,6 +4925,7 @@ class pushToQueue_args(TBase):
(1, TType.I32, 'pid', None, None,), # 1
)
+
def __init__(self, pid=None,):
self.pid = pid
@@ -4551,6 +4954,7 @@ class pullFromQueue_args(TBase):
(1, TType.I32, 'pid', None, None,), # 1
)
+
def __init__(self, pid=None,):
self.pid = pid
@@ -4579,6 +4983,7 @@ class restartPackage_args(TBase):
(1, TType.I32, 'pid', None, None,), # 1
)
+
def __init__(self, pid=None,):
self.pid = pid
@@ -4607,6 +5012,7 @@ class restartFile_args(TBase):
(1, TType.I32, 'fid', None, None,), # 1
)
+
def __init__(self, fid=None,):
self.fid = fid
@@ -4635,6 +5041,7 @@ class recheckPackage_args(TBase):
(1, TType.I32, 'pid', None, None,), # 1
)
+
def __init__(self, pid=None,):
self.pid = pid
@@ -4681,6 +5088,7 @@ class stopDownloads_args(TBase):
(1, TType.LIST, 'fids', (TType.I32, None), None,), # 1
)
+
def __init__(self, fids=None,):
self.fids = fids
@@ -4712,6 +5120,7 @@ class setPackageName_args(TBase):
(2, TType.STRING, 'name', None, None,), # 2
)
+
def __init__(self, pid=None, name=None,):
self.pid = pid
self.name = name
@@ -4744,6 +5153,7 @@ class movePackage_args(TBase):
(2, TType.I32, 'pid', None, None,), # 2
)
+
def __init__(self, destination=None, pid=None,):
self.destination = destination
self.pid = pid
@@ -4776,6 +5186,7 @@ class moveFiles_args(TBase):
(2, TType.I32, 'pid', None, None,), # 2
)
+
def __init__(self, fids=None, pid=None,):
self.fids = fids
self.pid = pid
@@ -4808,6 +5219,7 @@ class orderPackage_args(TBase):
(2, TType.I16, 'position', None, None,), # 2
)
+
def __init__(self, pid=None, position=None,):
self.pid = pid
self.position = position
@@ -4840,6 +5252,7 @@ class orderFile_args(TBase):
(2, TType.I16, 'position', None, None,), # 2
)
+
def __init__(self, fid=None, position=None,):
self.fid = fid
self.position = position
@@ -4872,6 +5285,7 @@ class setPackageData_args(TBase):
(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
@@ -4892,6 +5306,7 @@ class setPackageData_result(TBase):
(1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None,), # 1
)
+
def __init__(self, e=None,):
self.e = e
@@ -4919,6 +5334,7 @@ class deleteFinished_result(TBase):
(0, TType.LIST, 'success', (TType.I32, None), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4956,6 +5372,7 @@ class getEvents_args(TBase):
(1, TType.STRING, 'uuid', None, None,), # 1
)
+
def __init__(self, uuid=None,):
self.uuid = uuid
@@ -4974,6 +5391,7 @@ class getEvents_result(TBase):
(0, TType.LIST, 'success', (TType.STRUCT, (EventInfo, EventInfo.thrift_spec)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -4993,6 +5411,7 @@ class getAccounts_args(TBase):
(1, TType.BOOL, 'refresh', None, None,), # 1
)
+
def __init__(self, refresh=None,):
self.refresh = refresh
@@ -5011,6 +5430,7 @@ class getAccounts_result(TBase):
(0, TType.LIST, 'success', (TType.STRUCT, (AccountInfo, AccountInfo.thrift_spec)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5038,6 +5458,7 @@ class getAccountTypes_result(TBase):
(0, TType.LIST, 'success', (TType.STRING, None), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5066,6 +5487,7 @@ class updateAccount_args(TBase):
(4, TType.MAP, 'options', (TType.STRING, None, TType.STRING, None), None,), # 4
)
+
def __init__(self, plugin=None, account=None, password=None, options=None,):
self.plugin = plugin
self.account = account
@@ -5100,6 +5522,7 @@ class removeAccount_args(TBase):
(2, TType.STRING, 'account', None, None,), # 2
)
+
def __init__(self, plugin=None, account=None,):
self.plugin = plugin
self.account = account
@@ -5132,6 +5555,7 @@ class login_args(TBase):
(2, TType.STRING, 'password', None, None,), # 2
)
+
def __init__(self, username=None, password=None,):
self.username = username
self.password = password
@@ -5151,6 +5575,7 @@ class login_result(TBase):
(0, TType.BOOL, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5173,6 +5598,7 @@ class getUserData_args(TBase):
(2, TType.STRING, 'password', None, None,), # 2
)
+
def __init__(self, username=None, password=None,):
self.username = username
self.password = password
@@ -5192,6 +5618,7 @@ class getUserData_result(TBase):
(0, TType.STRUCT, 'success', (UserData, UserData.thrift_spec), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5219,6 +5646,7 @@ class getAllUserData_result(TBase):
(0, TType.MAP, 'success', (TType.STRING, None, TType.STRUCT, (UserData, UserData.thrift_spec)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5246,6 +5674,7 @@ class getServices_result(TBase):
(0, TType.MAP, 'success', (TType.STRING, None, TType.MAP, (TType.STRING, None, TType.STRING, None)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5268,6 +5697,7 @@ class hasService_args(TBase):
(2, TType.STRING, 'func', None, None,), # 2
)
+
def __init__(self, plugin=None, func=None,):
self.plugin = plugin
self.func = func
@@ -5287,6 +5717,7 @@ class hasService_result(TBase):
(0, TType.BOOL, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5306,6 +5737,7 @@ class call_args(TBase):
(1, TType.STRUCT, 'info', (ServiceCall, ServiceCall.thrift_spec), None,), # 1
)
+
def __init__(self, info=None,):
self.info = info
@@ -5330,6 +5762,7 @@ class call_result(TBase):
(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
@@ -5359,6 +5792,7 @@ class getAllInfo_result(TBase):
(0, TType.MAP, 'success', (TType.STRING, None, TType.MAP, (TType.STRING, None, TType.STRING, None)), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5378,6 +5812,7 @@ class getInfoByPlugin_args(TBase):
(1, TType.STRING, 'plugin', None, None,), # 1
)
+
def __init__(self, plugin=None,):
self.plugin = plugin
@@ -5396,6 +5831,7 @@ class getInfoByPlugin_result(TBase):
(0, TType.MAP, 'success', (TType.STRING, None, TType.STRING, None), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5423,6 +5859,7 @@ class isCaptchaWaiting_result(TBase):
(0, TType.BOOL, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5442,6 +5879,7 @@ class getCaptchaTask_args(TBase):
(1, TType.BOOL, 'exclusive', None, None,), # 1
)
+
def __init__(self, exclusive=None,):
self.exclusive = exclusive
@@ -5460,6 +5898,7 @@ class getCaptchaTask_result(TBase):
(0, TType.STRUCT, 'success', (CaptchaTask, CaptchaTask.thrift_spec), None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5479,6 +5918,7 @@ class getCaptchaTaskStatus_args(TBase):
(1, TType.I32, 'tid', None, None,), # 1
)
+
def __init__(self, tid=None,):
self.tid = tid
@@ -5497,6 +5937,7 @@ class getCaptchaTaskStatus_result(TBase):
(0, TType.STRING, 'success', None, None,), # 0
)
+
def __init__(self, success=None,):
self.success = success
@@ -5519,6 +5960,7 @@ class setCaptchaResult_args(TBase):
(2, TType.STRING, 'result', None, None,), # 2
)
+
def __init__(self, tid=None, result=None,):
self.tid = tid
self.result = result
diff --git a/pyload/remote/thriftbackend/thriftgen/pyload/ttypes.py b/pyload/remote/thriftbackend/thriftgen/pyload/ttypes.py
index 67d23161d..70b29ff1e 100644
--- a/pyload/remote/thriftbackend/thriftgen/pyload/ttypes.py
+++ b/pyload/remote/thriftbackend/thriftgen/pyload/ttypes.py
@@ -208,6 +208,7 @@ class DownloadInfo(TBase):
(16, TType.STRING, 'plugin', None, None,), # 16
)
+
def __init__(self, fid=None, name=None, speed=None, eta=None, format_eta=None, bleft=None, size=None, format_size=None, percent=None, status=None, statusmsg=None, format_wait=None, wait_until=None, packageID=None, packageName=None, plugin=None,):
self.fid = fid
self.name = name
@@ -260,6 +261,7 @@ class ServerStatus(TBase):
(7, TType.BOOL, 'reconnect', None, None,), # 7
)
+
def __init__(self, pause=None, active=None, queue=None, total=None, speed=None, download=None, reconnect=None,):
self.pause = pause
self.active = active
@@ -294,6 +296,7 @@ class ConfigItem(TBase):
(4, TType.STRING, 'type', None, None,), # 4
)
+
def __init__(self, name=None, description=None, value=None, type=None,):
self.name = name
self.description = description
@@ -325,6 +328,7 @@ class ConfigSection(TBase):
(4, TType.STRING, 'outline', None, None,), # 4
)
+
def __init__(self, name=None, description=None, items=None, outline=None,):
self.name = name
self.description = description
@@ -377,6 +381,7 @@ class FileData(TBase):
(11, TType.I16, 'order', None, None,), # 11
)
+
def __init__(self, fid=None, url=None, name=None, plugin=None, size=None, format_size=None, status=None, statusmsg=None, packageID=None, error=None, order=None,):
self.fid = fid
self.url = url
@@ -442,6 +447,7 @@ class PackageData(TBase):
(13, TType.LIST, 'fids', (TType.I32, None), None,), # 13
)
+
def __init__(self, pid=None, name=None, folder=None, site=None, password=None, dest=None, order=None, linksdone=None, sizedone=None, sizetotal=None, linkstotal=None, links=None, fids=None,):
self.pid = pid
self.name = name
@@ -497,6 +503,7 @@ class InteractionTask(TBase):
(9, TType.STRING, 'plugin', None, None,), # 9
)
+
def __init__(self, iid=None, input=None, structure=None, preset=None, output=None, data=None, title=None, description=None, plugin=None,):
self.iid = iid
self.input = input
@@ -533,6 +540,7 @@ class CaptchaTask(TBase):
(4, TType.STRING, 'resultType', None, None,), # 4
)
+
def __init__(self, tid=None, data=None, type=None, resultType=None,):
self.tid = tid
self.data = data
@@ -564,6 +572,7 @@ class EventInfo(TBase):
(4, TType.I32, 'destination', None, None,), # 4
)
+
def __init__(self, eventname=None, id=None, type=None, destination=None,):
self.eventname = eventname
self.id = id
@@ -598,6 +607,7 @@ class UserData(TBase):
(5, TType.STRING, 'templateName', None, None,), # 5
)
+
def __init__(self, name=None, email=None, role=None, permission=None, templateName=None,):
self.name = name
self.email = email
@@ -642,6 +652,7 @@ class AccountInfo(TBase):
(8, TType.STRING, 'type', None, None,), # 8
)
+
def __init__(self, validuntil=None, login=None, options=None, valid=None, trafficleft=None, maxtraffic=None, premium=None, type=None,):
self.validuntil = validuntil
self.login = login
@@ -677,6 +688,7 @@ class ServiceCall(TBase):
(4, TType.BOOL, 'parseArguments', None, None,), # 4
)
+
def __init__(self, plugin=None, func=None, arguments=None, parseArguments=None,):
self.plugin = plugin
self.func = func
@@ -711,6 +723,7 @@ class OnlineStatus(TBase):
(5, TType.I64, 'size', None, None,), # 5
)
+
def __init__(self, name=None, plugin=None, packagename=None, status=None, size=None,):
self.name = name
self.plugin = plugin
@@ -737,6 +750,7 @@ class OnlineCheck(TBase):
(2, TType.MAP, 'data', (TType.STRING, None, TType.STRUCT, (OnlineStatus, OnlineStatus.thrift_spec)), None,), # 2
)
+
def __init__(self, rid=None, data=None,):
self.rid = rid
self.data = data
@@ -757,9 +771,11 @@ class PackageDoesNotExists(TExceptionBase):
(1, TType.I32, 'pid', None, None,), # 1
)
+
def __init__(self, pid=None,):
self.pid = pid
+
def __str__(self):
return repr(self)
@@ -779,9 +795,11 @@ class FileDoesNotExists(TExceptionBase):
(1, TType.I32, 'fid', None, None,), # 1
)
+
def __init__(self, fid=None,):
self.fid = fid
+
def __str__(self):
return repr(self)
@@ -804,10 +822,12 @@ class ServiceDoesNotExists(TExceptionBase):
(2, TType.STRING, 'func', None, None,), # 2
)
+
def __init__(self, plugin=None, func=None,):
self.plugin = plugin
self.func = func
+
def __str__(self):
return repr(self)
@@ -827,8 +847,10 @@ class ServiceException(TExceptionBase):
(1, TType.STRING, 'msg', None, None,), # 1
)
+
def __init__(self, msg=None,):
self.msg = msg
+
def __str__(self):
return repr(self)
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-23 14:31:21 +0100