summaryrefslogtreecommitdiffstats
path: root/module/remote
diff options
context:
space:
mode:
authorGravatar RaNaN <Mast3rRaNaN@hotmail.de> 2012-03-06 13:36:39 +0100
committerGravatar RaNaN <Mast3rRaNaN@hotmail.de> 2012-03-06 13:36:39 +0100
commit4df2b77fdf42046fe19bd371be7c7255986b5980 (patch)
tree2a7227a0d22e03dc2c085514eaab36a7e5e612c4 /module/remote
parentssl fix (diff)
downloadpyload-4df2b77fdf42046fe19bd371be7c7255986b5980.tar.xz
renamed hooks to addons, new filemanager and database, many new api methods
you will loose ALL your LINKS, webinterface will NOT work
Diffstat (limited to 'module/remote')
-rw-r--r--module/remote/socketbackend/ttypes.py347
-rw-r--r--module/remote/thriftbackend/pyload.thrift436
-rwxr-xr-xmodule/remote/thriftbackend/thriftgen/pyload/Pyload-remote448
-rw-r--r--module/remote/thriftbackend/thriftgen/pyload/Pyload.py4059
-rw-r--r--module/remote/thriftbackend/thriftgen/pyload/ttypes.py667
5 files changed, 3824 insertions, 2133 deletions
diff --git a/module/remote/socketbackend/ttypes.py b/module/remote/socketbackend/ttypes.py
index 682b2b52a..91430d720 100644
--- a/module/remote/socketbackend/ttypes.py
+++ b/module/remote/socketbackend/ttypes.py
@@ -6,43 +6,61 @@
class BaseObject(object):
__slots__ = []
-class Destination:
- Collector = 0
- Queue = 1
-
class DownloadStatus:
- Aborted = 9
- Custom = 11
- Decrypting = 10
- Downloading = 12
- Failed = 8
- Finished = 0
+ Aborted = 12
+ Custom = 15
+ Decrypting = 13
+ Downloading = 10
+ Failed = 7
+ Finished = 5
+ NA = 0
Offline = 1
Online = 2
- Processing = 13
+ Paused = 4
+ Processing = 14
Queued = 3
- Skipped = 4
- Starting = 7
- TempOffline = 6
- Unknown = 14
- Waiting = 5
+ Skipped = 6
+ Starting = 8
+ TempOffline = 11
+ Unknown = 16
+ Waiting = 9
+
+class FileStatus:
+ Missing = 1
+ Ok = 0
+ Remote = 2
class Input:
- BOOL = 4
- CHOICE = 6
- CLICK = 5
- LIST = 8
- MULTIPLE = 7
- NONE = 0
- PASSWORD = 3
- TABLE = 9
- TEXT = 1
- TEXTBOX = 2
+ Bool = 4
+ Choice = 6
+ Click = 5
+ List = 8
+ Multiple = 7
+ NA = 0
+ Password = 3
+ Table = 9
+ Text = 1
+ TextBox = 2
+
+class MediaType:
+ All = 0
+ Archive = 32
+ Audio = 2
+ Document = 16
+ Image = 4
+ Other = 1
+ Video = 8
class Output:
- CAPTCHA = 1
- NOTIFICATION = 4
- QUESTION = 2
+ All = 0
+ Captcha = 2
+ Notification = 1
+ Query = 4
+
+class PackageStatus:
+ Ok = 0
+ Paused = 1
+ Remote = 2
class AccountInfo(BaseObject):
__slots__ = ['plugin', 'loginname', 'valid', 'validuntil', 'trafficleft', 'maxtraffic', 'premium', 'activated', 'options']
@@ -58,57 +76,56 @@ class AccountInfo(BaseObject):
self.activated = activated
self.options = options
-class CaptchaTask(BaseObject):
- __slots__ = ['tid', 'data', 'type', 'resultType']
+class AddonInfo(BaseObject):
+ __slots__ = ['func_name', 'description', 'value']
- def __init__(self, tid=None, data=None, type=None, resultType=None):
- self.tid = tid
- self.data = data
- self.type = type
- self.resultType = resultType
+ def __init__(self, func_name=None, description=None, value=None):
+ self.func_name = func_name
+ self.description = description
+ self.value = value
+
+class AddonService(BaseObject):
+ __slots__ = ['func_name', 'description', 'media', 'package']
+
+ def __init__(self, func_name=None, description=None, media=None, package=None):
+ self.func_name = func_name
+ self.description = description
+ self.media = media
+ self.package = package
class ConfigItem(BaseObject):
- __slots__ = ['name', 'long_name', 'description', 'type', 'default_value', 'value']
+ __slots__ = ['name', 'display_name', 'description', 'type', 'default_value', 'value']
- def __init__(self, name=None, long_name=None, description=None, type=None, default_value=None, value=None):
+ def __init__(self, name=None, display_name=None, description=None, type=None, default_value=None, value=None):
self.name = name
- self.long_name = long_name
+ self.display_name = display_name
self.description = description
self.type = type
self.default_value = default_value
self.value = value
class ConfigSection(BaseObject):
- __slots__ = ['name', 'long_name', 'description', 'long_description', 'items', 'handler']
+ __slots__ = ['name', 'display_name', 'description', 'long_description', 'items', 'info', 'handler']
- def __init__(self, name=None, long_name=None, description=None, long_description=None, items=None, handler=None):
+ def __init__(self, name=None, display_name=None, description=None, long_description=None, items=None, info=None, handler=None):
self.name = name
- self.long_name = long_name
+ self.display_name = display_name
self.description = description
self.long_description = long_description
self.items = items
+ self.info = info
self.handler = handler
class DownloadInfo(BaseObject):
- __slots__ = ['fid', 'name', 'speed', 'eta', 'format_eta', 'bleft', 'size', 'format_size', 'percent', 'status', 'statusmsg', 'format_wait', 'wait_until', 'packageID', 'packageName', 'plugin']
+ __slots__ = ['url', 'plugin', 'hash', 'status', 'statusmsg', 'error']
- def __init__(self, fid=None, name=None, speed=None, eta=None, format_eta=None, bleft=None, size=None, format_size=None, percent=None, status=None, statusmsg=None, format_wait=None, wait_until=None, packageID=None, packageName=None, plugin=None):
- self.fid = fid
- self.name = name
- self.speed = speed
- self.eta = eta
- self.format_eta = format_eta
- self.bleft = bleft
- self.size = size
- self.format_size = format_size
- self.percent = percent
+ def __init__(self, url=None, plugin=None, hash=None, status=None, statusmsg=None, error=None):
+ self.url = url
+ self.plugin = plugin
+ self.hash = hash
self.status = status
self.statusmsg = statusmsg
- self.format_wait = format_wait
- self.wait_until = wait_until
- self.packageID = packageID
- self.packageName = packageName
- self.plugin = plugin
+ self.error = error
class EventInfo(BaseObject):
__slots__ = ['eventname', 'event_args']
@@ -117,42 +134,50 @@ class EventInfo(BaseObject):
self.eventname = eventname
self.event_args = event_args
-class FileData(BaseObject):
- __slots__ = ['fid', 'url', 'name', 'plugin', 'size', 'format_size', 'status', 'statusmsg', 'packageID', 'error', 'order']
-
- def __init__(self, fid=None, url=None, name=None, plugin=None, size=None, format_size=None, status=None, statusmsg=None, packageID=None, error=None, order=None):
- self.fid = fid
- self.url = url
- self.name = name
- self.plugin = plugin
- self.size = size
- self.format_size = format_size
- self.status = status
- self.statusmsg = statusmsg
- self.packageID = packageID
- self.error = error
- self.order = order
-
class FileDoesNotExists(Exception):
__slots__ = ['fid']
def __init__(self, fid=None):
self.fid = fid
+class FileInfo(BaseObject):
+ __slots__ = ['fid', 'name', 'package', 'size', 'status', 'media', 'added', 'fileorder', 'download']
+
+ def __init__(self, fid=None, name=None, package=None, size=None, status=None, media=None, added=None, fileorder=None, download=None):
+ self.fid = fid
+ self.name = name
+ self.package = package
+ self.size = size
+ self.status = status
+ self.media = media
+ self.added = added
+ self.fileorder = fileorder
+ self.download = download
+
class InteractionTask(BaseObject):
- __slots__ = ['iid', 'input', 'structure', 'preset', 'output', 'data', 'title', 'description', 'plugin']
+ __slots__ = ['iid', 'input', 'data', 'output', 'default_value', 'title', 'description', 'plugin']
- def __init__(self, iid=None, input=None, structure=None, preset=None, output=None, data=None, title=None, description=None, plugin=None):
+ def __init__(self, iid=None, input=None, data=None, output=None, default_value=None, title=None, description=None, plugin=None):
self.iid = iid
self.input = input
- self.structure = structure
- self.preset = preset
- self.output = output
self.data = data
+ self.output = output
+ self.default_value = default_value
self.title = title
self.description = description
self.plugin = plugin
+class LinkStatus(BaseObject):
+ __slots__ = ['url', 'name', 'plugin', 'size', 'status', 'packagename']
+
+ def __init__(self, url=None, name=None, plugin=None, size=None, status=None, packagename=None):
+ self.url = url
+ self.name = name
+ self.plugin = plugin
+ self.size = size
+ self.status = status
+ self.packagename = packagename
+
class OnlineCheck(BaseObject):
__slots__ = ['rid', 'data']
@@ -160,39 +185,67 @@ class OnlineCheck(BaseObject):
self.rid = rid
self.data = data
-class OnlineStatus(BaseObject):
- __slots__ = ['name', 'plugin', 'packagename', 'status', 'size']
+class PackageDoesNotExists(Exception):
+ __slots__ = ['pid']
- def __init__(self, name=None, plugin=None, packagename=None, status=None, size=None):
- self.name = name
- self.plugin = plugin
- self.packagename = packagename
- self.status = status
- self.size = size
+ def __init__(self, pid=None):
+ self.pid = pid
-class PackageData(BaseObject):
- __slots__ = ['pid', 'name', 'folder', 'site', 'password', 'dest', 'order', 'linksdone', 'sizedone', 'sizetotal', 'linkstotal', 'links', 'fids']
+class PackageInfo(BaseObject):
+ __slots__ = ['pid', 'name', 'folder', 'root', 'site', 'comment', 'password', 'added', 'status', 'packageorder', 'stats', 'fids', 'pids']
- 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):
+ def __init__(self, pid=None, name=None, folder=None, root=None, site=None, comment=None, password=None, added=None, status=None, packageorder=None, stats=None, fids=None, pids=None):
self.pid = pid
self.name = name
self.folder = folder
+ self.root = root
self.site = site
+ self.comment = comment
self.password = password
- self.dest = dest
- self.order = order
+ self.added = added
+ self.status = status
+ self.packageorder = packageorder
+ self.stats = stats
+ self.fids = fids
+ self.pids = pids
+
+class PackageStats(BaseObject):
+ __slots__ = ['linkstotal', 'linksdone', 'sizetotal', 'sizedone']
+
+ def __init__(self, linkstotal=None, linksdone=None, sizetotal=None, sizedone=None):
+ self.linkstotal = linkstotal
self.linksdone = linksdone
- self.sizedone = sizedone
self.sizetotal = sizetotal
- self.linkstotal = linkstotal
- self.links = links
- self.fids = fids
+ self.sizedone = sizedone
-class PackageDoesNotExists(Exception):
- __slots__ = ['pid']
+class PackageView(BaseObject):
+ __slots__ = ['root', 'files', 'packages']
- def __init__(self, pid=None):
- self.pid = pid
+ def __init__(self, root=None, files=None, packages=None):
+ self.root = root
+ self.files = files
+ self.packages = packages
+
+class ProgressInfo(BaseObject):
+ __slots__ = ['fid', 'name', 'speed', 'eta', 'format_eta', 'bleft', 'size', 'format_size', 'percent', 'status', 'statusmsg', 'format_wait', 'wait_until', 'packageID', 'packageName', 'plugin']
+
+ def __init__(self, fid=None, name=None, speed=None, eta=None, format_eta=None, bleft=None, size=None, format_size=None, percent=None, status=None, statusmsg=None, format_wait=None, wait_until=None, packageID=None, packageName=None, plugin=None):
+ self.fid = fid
+ self.name = name
+ self.speed = speed
+ self.eta = eta
+ self.format_eta = format_eta
+ self.bleft = bleft
+ self.size = size
+ self.format_size = format_size
+ self.percent = percent
+ self.status = status
+ self.statusmsg = statusmsg
+ self.format_wait = format_wait
+ self.wait_until = wait_until
+ self.packageID = packageID
+ self.packageName = packageName
+ self.plugin = plugin
class ServerStatus(BaseObject):
__slots__ = ['pause', 'active', 'queue', 'total', 'speed', 'download', 'reconnect']
@@ -206,14 +259,6 @@ class ServerStatus(BaseObject):
self.download = download
self.reconnect = reconnect
-class ServiceCall(BaseObject):
- __slots__ = ['plugin', 'func', 'arguments']
-
- def __init__(self, plugin=None, func=None, arguments=None):
- self.plugin = plugin
- self.func = func
- self.arguments = arguments
-
class ServiceDoesNotExists(Exception):
__slots__ = ['plugin', 'func']
@@ -244,11 +289,23 @@ class UserDoesNotExists(Exception):
self.user = user
class Iface:
- def addFiles(self, pid, links):
+ def addFromCollector(self, name, paused):
+ pass
+ def addLinks(self, pid, links):
+ pass
+ def addPackage(self, name, links, password):
+ pass
+ def addPackageChild(self, name, links, password, root, paused):
+ pass
+ def addPackageP(self, name, links, password, paused):
pass
- def addPackage(self, name, links, dest, password):
+ def addToCollector(self, links):
pass
- def call(self, info):
+ def autoAddLinks(self, links):
+ pass
+ def call(self, plugin, func, arguments):
+ pass
+ def callAddonHandler(self, plugin, func, pid_or_fid):
pass
def checkOnlineStatus(self, urls):
pass
@@ -258,15 +315,23 @@ class Iface:
pass
def configureSection(self, section):
pass
- def deleteFiles(self, fids):
+ def createPackage(self, name, folder, root, password, site, comment, paused):
+ pass
+ def deleteCollLink(self, url):
pass
- def deleteFinished(self):
+ def deleteCollPack(self, name):
+ pass
+ def deleteFiles(self, fids):
pass
def deletePackages(self, pids):
pass
+ def findFiles(self, pattern):
+ pass
def freeSpace(self):
pass
- def generateAndAddPackages(self, links, dest):
+ def generateAndAddPackages(self, links, paused):
+ pass
+ def generateDownloadLink(self, fid, timeout):
pass
def generatePackages(self, links):
pass
@@ -274,17 +339,17 @@ class Iface:
pass
def getAccounts(self, refresh):
pass
- def getAllInfo(self):
+ def getAddonHandler(self):
pass
- def getAllUserData(self):
+ def getAllFiles(self):
pass
- def getCaptchaTask(self, exclusive):
+ def getAllInfo(self):
pass
- def getCaptchaTaskStatus(self, tid):
+ def getAllUnfinishedFiles(self):
pass
- def getCollector(self):
+ def getAllUserData(self):
pass
- def getCollectorData(self):
+ def getCollector(self):
pass
def getConfig(self):
pass
@@ -292,35 +357,35 @@ class Iface:
pass
def getEvents(self, uuid):
pass
- def getFileData(self, fid):
+ def getFileInfo(self, fid):
pass
- def getFileOrder(self, pid):
+ def getFileTree(self, pid, full):
pass
def getInfoByPlugin(self, plugin):
pass
+ def getInteractionTask(self, mode):
+ pass
def getLog(self, offset):
pass
- def getPackageData(self, pid):
+ def getPackageContent(self, pid):
pass
def getPackageInfo(self, pid):
pass
- def getPackageOrder(self, destination):
- pass
def getPluginConfig(self):
pass
- def getQueue(self):
- pass
- def getQueueData(self):
+ def getProgressInfo(self):
pass
def getServerVersion(self):
pass
def getServices(self):
pass
+ def getUnfinishedFileTree(self, pid, full):
+ pass
def getUserData(self, username, password):
pass
def hasService(self, plugin, func):
pass
- def isCaptchaWaiting(self):
+ def isInteractionWaiting(self, mode):
pass
def isTimeDownload(self):
pass
@@ -332,11 +397,11 @@ class Iface:
pass
def moveFiles(self, fids, pid):
pass
- def movePackage(self, destination, pid):
+ def movePackage(self, pid, root):
pass
- def orderFile(self, fid, position):
+ def orderFiles(self, fids, pid, position):
pass
- def orderPackage(self, pid, position):
+ def orderPackage(self, pids, position):
pass
def parseURLs(self, html, url):
pass
@@ -344,14 +409,12 @@ class Iface:
pass
def pollResults(self, rid):
pass
- def pullFromQueue(self, pid):
- pass
- def pushToQueue(self, pid):
- pass
def recheckPackage(self, pid):
pass
def removeAccount(self, plugin, account):
pass
+ def renameCollPack(self, name, new_name):
+ pass
def restart(self):
pass
def restartFailed(self):
@@ -360,15 +423,21 @@ class Iface:
pass
def restartPackage(self, pid):
pass
- def setCaptchaResult(self, tid, result):
+ def scanDownloadFolder(self):
+ pass
+ def setConfigHandler(self, plugin, iid, value):
pass
def setConfigValue(self, section, option, value):
pass
+ def setFilePaused(self, fid, paused):
+ pass
+ def setInteractionResult(self, iid, result):
+ pass
def setPackageData(self, pid, data):
pass
- def setPackageName(self, pid, name):
+ def setPackageFolder(self, pid, path):
pass
- def statusDownloads(self):
+ def setPackagePaused(self, pid, paused):
pass
def statusServer(self):
pass
diff --git a/module/remote/thriftbackend/pyload.thrift b/module/remote/thriftbackend/pyload.thrift
index a1b328958..bcf96324c 100644
--- a/module/remote/thriftbackend/pyload.thrift
+++ b/module/remote/thriftbackend/pyload.thrift
@@ -4,74 +4,96 @@ typedef i32 FileID
typedef i32 PackageID
typedef i32 ResultID
typedef i32 InteractionID
+typedef i64 UTCDate
+typedef i64 ByteCount
typedef list<string> LinkList
+// a string that can represent multiple types int, bool, time, etc..
+typedef string ValueString
typedef string PluginName
-typedef byte Progress
-typedef byte Priority
-
+// NA - Not Available
enum DownloadStatus {
- Finished
+ NA,
Offline,
Online,
Queued,
+ Paused,
+ Finished,
Skipped,
+ Failed,
+ Starting,
Waiting,
+ Downloading,
TempOffline,
- Starting,
- Failed,
Aborted,
Decrypting,
- Custom,
- Downloading,
Processing,
+ Custom,
Unknown
}
-enum Destination {
- Collector,
- Queue
+enum MediaType {
+ All = 0
+ Other = 1,
+ Audio = 2,
+ Image = 4,
+ Video = 8,
+ Document = 16,
+ Archive = 32,
+}
+
+enum FileStatus {
+ Ok,
+ Missing,
+ Remote, // file is available at remote location
+}
+
+enum PackageStatus {
+ Ok,
+ Paused,
+ Remote,
}
// types for user interaction
// some may only be place holder currently not supported
// also all input - output combination are not reasonable, see InteractionManager for further info
enum Input {
- NONE,
- TEXT,
- TEXTBOX,
- PASSWORD,
- BOOL, // confirm like, yes or no dialog
- CLICK, // for positional captchas
- CHOICE, // choice from list
- MULTIPLE, // multiple choice from list of elements
- LIST, // arbitary list of elements
- TABLE // table like data structure
+ NA,
+ Text,
+ TextBox,
+ Password,
+ Bool, // confirm like, yes or no dialog
+ Click, // for positional captchas
+ Choice, // choice from list
+ Multiple, // multiple choice from list of elements
+ List, // arbitary list of elements
+ Table // table like data structure
}
// more can be implemented by need
// this describes the type of the outgoing interaction
// ensure they can be logcial or'ed
enum Output {
- CAPTCHA = 1,
- QUESTION = 2,
- NOTIFICATION = 4,
+ All = 0,
+ Notification = 1,
+ Captcha = 2,
+ Query = 4,
}
-struct DownloadInfo {
+struct ProgressInfo {
1: FileID fid,
2: string name,
- 3: i64 speed,
+ 3: ByteCount speed,
4: i32 eta,
5: string format_eta,
- 6: i64 bleft,
- 7: i64 size,
+ 6: ByteCount bleft,
+ 7: ByteCount size,
8: string format_size,
- 9: Progress percent,
+ 9: i16 percent,
10: DownloadStatus status,
11: string statusmsg,
12: string format_wait,
- 13: i64 wait_until,
+ 13: UTCDate wait_until,
14: PackageID packageID,
15: string packageName,
16: PluginName plugin,
@@ -82,76 +104,107 @@ struct ServerStatus {
2: i16 active,
3: i16 queue,
4: i16 total,
- 5: i64 speed,
+ 5: ByteCount speed,
6: bool download,
7: bool reconnect
}
-struct FileData {
+// download info for specific file
+struct DownloadInfo {
+ 1: string url,
+ 2: PluginName plugin,
+ 3: string hash,
+ 4: DownloadStatus status,
+ 5: string statusmsg,
+ 6: string error,
+}
+
+struct FileInfo {
1: FileID fid,
- 2: string url,
- 3: string name,
- 4: PluginName plugin,
- 5: i64 size,
- 6: string format_size,
- 7: DownloadStatus status,
- 8: string statusmsg,
- 9: PackageID packageID,
- 10: string error,
- 11: i16 order
+ 2: string name,
+ 3: PackageID package,
+ 4: ByteCount size,
+ 5: FileStatus status,
+ 6: MediaType media,
+ 7: UTCDate added,
+ 8: i16 fileorder,
+ 9: optional DownloadInfo download,
}
-struct PackageData {
+struct PackageStats {
+ 1: i16 linkstotal,
+ 2: i16 linksdone,
+ 3: ByteCount sizetotal,
+ 4: ByteCount sizedone,
+}
+
+struct PackageInfo {
1: PackageID pid,
2: string name,
3: string folder,
- 4: string site,
- 5: string password,
- 6: Destination dest,
- 7: i16 order,
- 8: optional i16 linksdone,
- 9: optional i64 sizedone,
- 10: optional i64 sizetotal,
- 11: optional i16 linkstotal,
- 12: optional list<FileData> links,
- 13: optional list<FileID> fids
+ 4: PackageID root,
+ 5: string site,
+ 6: string comment,
+ 7: string password,
+ 8: UTCDate added,
+ 9: PackageStatus status,
+ 10: i16 packageorder,
+ 11: PackageStats stats,
+ 12: list<FileID> fids,
+ 13: list<PackageID> pids,
+}
+
+// thrift does not allow recursive datatypes, so all data is accumulated and mapped with id
+struct PackageView {
+ 1: PackageInfo root,
+ 2: map<FileID, FileInfo> files,
+ 3: map<PackageID, PackageInfo> packages
+}
+
+// general info about link, used for collector and online results
+struct LinkStatus {
+ 1: string url,
+ 2: string name,
+ 3: PluginName plugin,
+ 4: ByteCount size, // size <= 0 : unknown
+ 5: DownloadStatus status,
+ 6: string packagename,
}
struct InteractionTask {
1: InteractionID iid,
2: Input input,
- 3: list<string> structure,
- 4: list<string> preset,
- 5: Output output,
- 6: list<string> data,
- 7: string title,
- 8: string description,
- 9: string plugin,
+ 3: list<string> data,
+ 4: Output output,
+ 5: optional ValueString default_value,
+ 6: string title,
+ 7: string description,
+ 8: PluginName plugin,
+}
+
+struct AddonInfo {
+ 1: string func_name,
+ 2: string description,
+ 3: ValueString value,
}
struct ConfigItem {
1: string name,
- 2: string long_name,
+ 2: string display_name,
3: string description,
4: string type,
- 5: string default_value,
- 6: string value,
+ 5: ValueString default_value,
+ 6: ValueString value,
}
struct ConfigSection {
1: string name,
- 2: string long_name,
+ 2: string display_name,
3: string description,
4: string long_description,
5: optional list<ConfigItem> items,
- 6: optional map<string, InteractionTask> handler,
-}
-
-struct CaptchaTask {
- 1: i16 tid,
- 2: binary data,
- 3: string type,
- 4: string resultType
+ 6: optional list<AddonInfo> info,
+ 7: optional list<InteractionTask> handler, // if null plugin is not loaded
}
struct EventInfo {
@@ -171,168 +224,239 @@ struct AccountInfo {
1: PluginName plugin,
2: string loginname,
3: bool valid,
- 4: i64 validuntil,
- 5: i64 trafficleft,
- 6: i64 maxtraffic,
+ 4: UTCDate validuntil,
+ 5: ByteCount trafficleft,
+ 6: ByteCount maxtraffic,
7: bool premium,
8: bool activated,
9: map<string, string> options,
}
-struct ServiceCall {
- 1: PluginName plugin,
- 2: string func,
- 3: string arguments, // empty string or json encoded list
-}
-
-struct OnlineStatus {
- 1: string name,
- 2: PluginName plugin,
- 3: string packagename,
- 4: DownloadStatus status,
- 5: i64 size, // size <= 0 : unknown
+struct AddonService {
+ 1: string func_name,
+ 2: string description,
+ 3: optional i16 media,
+ 4: optional bool package,
}
struct OnlineCheck {
- 1: ResultID rid, // -1 -> nothing more to get
- 2: map<string, OnlineStatus> data, //url to result
+ 1: ResultID rid, // -1 -> nothing more to get
+ 2: map<string, LinkStatus> data, //url to result
}
// exceptions
-exception PackageDoesNotExists{
+exception PackageDoesNotExists {
1: PackageID pid
}
-exception FileDoesNotExists{
+exception FileDoesNotExists {
1: FileID fid
}
-exception UserDoesNotExists{
+exception UserDoesNotExists {
1: string user
}
-exception ServiceDoesNotExists{
+exception ServiceDoesNotExists {
1: string plugin
2: string func
}
-exception ServiceException{
+exception ServiceException {
1: string msg
}
service Pyload {
- //config
- string getConfigValue(1: string section, 2: string option),
- void setConfigValue(1: string section, 2: string option, 3: string value),
- map<string, ConfigSection> getConfig(),
- map<PluginName, ConfigSection> getPluginConfig(),
- ConfigSection configureSection(1: string section),
+ ///////////////////////
+ // Server Status
+ ///////////////////////
- // server status
+ string getServerVersion(),
+ ServerStatus statusServer(),
void pauseServer(),
void unpauseServer(),
bool togglePause(),
- ServerStatus statusServer(),
- i64 freeSpace(),
- string getServerVersion(),
+ ByteCount freeSpace(),
void kill(),
void restart(),
list<string> getLog(1: i32 offset),
bool isTimeDownload(),
bool isTimeReconnect(),
bool toggleReconnect(),
+ void scanDownloadFolder(),
- // download preparing
+ // downloads - information
+ list<ProgressInfo> getProgressInfo(),
+
+ ///////////////////////
+ // Configuration
+ ///////////////////////
+
+ string getConfigValue(1: string section, 2: string option),
+ void setConfigValue(1: string section, 2: string option, 3: string value),
+ map<string, ConfigSection> getConfig(),
+ map<PluginName, ConfigSection> getPluginConfig(),
+ ConfigSection configureSection(1: string section),
+ void setConfigHandler(1: PluginName plugin, 2: InteractionID iid, 3: ValueString value),
+
+ ///////////////////////
+ // Download Preparing
+ ///////////////////////
- // packagename - urls
- map<string, LinkList> generatePackages(1: LinkList links),
map<PluginName, LinkList> checkURLs(1: LinkList urls),
map<PluginName, LinkList> parseURLs(1: string html, 2: string url),
+ // packagename - urls
// parses results and generates packages
OnlineCheck checkOnlineStatus(1: LinkList urls),
OnlineCheck checkOnlineStatusContainer(1: LinkList urls, 2: string filename, 3: binary data)
- // poll results from previosly started online check
+ // poll results from previously started online check
OnlineCheck pollResults(1: ResultID rid),
- // downloads - information
- list<DownloadInfo> statusDownloads(),
- PackageData getPackageData(1: PackageID pid) throws (1: PackageDoesNotExists e),
- PackageData getPackageInfo(1: PackageID pid) throws (1: PackageDoesNotExists e),
- FileData getFileData(1: FileID fid) throws (1: FileDoesNotExists e),
- list<PackageData> getQueue(),
- list<PackageData> getCollector(),
- list<PackageData> getQueueData(),
- list<PackageData> getCollectorData(),
- map<i16, PackageID> getPackageOrder(1: Destination destination),
- map<i16, FileID> getFileOrder(1: PackageID pid)
-
- // downloads - adding/deleting
- list<PackageID> generateAndAddPackages(1: LinkList links, 2: Destination dest),
- PackageID addPackage(1: string name, 2: LinkList links, 3: Destination dest, 4: string password),
+ map<string, LinkList> generatePackages(1: LinkList links),
+
+ ///////////////////////
+ // Adding/Deleting
+ ///////////////////////
+
+ list<PackageID> generateAndAddPackages(1: LinkList links, 2: bool paused),
+ list<FileID> autoAddLinks(1: LinkList links),
+
+ PackageID createPackage(1: string name, 2: string folder, 3: PackageID root, 4: string password,
+ 5: string site, 6: string comment, 7: bool paused),
+
+ PackageID addPackage(1: string name, 2: LinkList links, 3: string password),
+ // same as above with paused attribute
+ PackageID addPackageP(1: string name, 2: LinkList links, 3: string password, 4: bool paused),
+
+ // pid -1 is toplevel
+ PackageID addPackageChild(1: string name, 2: LinkList links, 3: string password, 4: PackageID root, 5: bool paused),
+
PackageID uploadContainer(1: string filename, 2: binary data),
- void addFiles(1: PackageID pid, 2: LinkList links),
+
+ void addLinks(1: PackageID pid, 2: LinkList links) throws (1: PackageDoesNotExists e),
+
+ // these are real file operations and WILL delete files on disk
void deleteFiles(1: list<FileID> fids),
void deletePackages(1: list<PackageID> pids),
- // downloads - modifying
- void pushToQueue(1: PackageID pid),
- void pullFromQueue(1: PackageID pid),
+ ///////////////////////
+ // Collector
+ ///////////////////////
+
+ list<LinkStatus> getCollector(),
+
+ void addToCollector(1: LinkList links),
+ PackageID addFromCollector(1: string name, 2: bool paused),
+ void renameCollPack(1: string name, 2: string new_name),
+ void deleteCollPack(1: string name),
+ void deleteCollLink(1: string url),
+
+ ////////////////////////////
+ // File Information retrival
+ ////////////////////////////
+
+ PackageView getAllFiles(),
+ PackageView getAllUnfinishedFiles(),
+
+ // pid -1 for root, full=False only delivers first level in tree
+ PackageView getFileTree(1: PackageID pid, 2: bool full),
+ PackageView getUnfinishedFileTree(1: PackageID pid, 2: bool full),
+
+ // same as above with full=False
+ PackageView getPackageContent(1: PackageID pid),
+
+ PackageInfo getPackageInfo(1: PackageID pid) throws (1: PackageDoesNotExists e),
+ FileInfo getFileInfo(1: FileID fid) throws (1: FileDoesNotExists e),
+ map<FileID, FileInfo> findFiles(1: string pattern),
+
+ ///////////////////////
+ // Modify Downloads
+ ///////////////////////
+
void restartPackage(1: PackageID pid),
void restartFile(1: FileID fid),
void recheckPackage(1: PackageID pid),
- void stopAllDownloads(),
void stopDownloads(1: list<FileID> fids),
- void setPackageName(1: PackageID pid, 2: string name),
- void movePackage(1: Destination destination, 2: PackageID pid),
- void moveFiles(1: list<FileID> fids, 2: PackageID pid),
- void orderPackage(1: PackageID pid, 2: i16 position),
- void orderFile(1: FileID fid, 2: i16 position),
- void setPackageData(1: PackageID pid, 2: map<string, string> data) throws (1: PackageDoesNotExists e),
- list<PackageID> deleteFinished(),
+ void stopAllDownloads(),
void restartFailed(),
- //events
- list<EventInfo> getEvents(1: string uuid)
+ /////////////////////////
+ // Modify Files/Packages
+ /////////////////////////
+
+ void setFilePaused(1: FileID fid, 2: bool paused) throws (1: FileDoesNotExists e),
+
+ // moving package while downloading is not possible, so they will return bool to indicate success
+ void setPackagePaused(1: PackageID pid, 2: bool paused) throws (1: PackageDoesNotExists e),
+ bool setPackageFolder(1: PackageID pid, 2: string path) throws (1: PackageDoesNotExists e),
+ void setPackageData(1: PackageID pid, 2: map<string, string> data) throws (1: PackageDoesNotExists e),
+
+ // as above, this will move files on disk
+ bool movePackage(1: PackageID pid, 2: PackageID root) throws (1: PackageDoesNotExists e),
+ bool moveFiles(1: list<FileID> fids, 2: PackageID pid) throws (1: PackageDoesNotExists e),
+
+ void orderPackage(1: list<PackageID> pids, 2: i16 position),
+ void orderFiles(1: list<FileID> fids, 2: PackageID pid, 3: i16 position),
+
+ ///////////////////////
+ // User Interaction
+ ///////////////////////
+
+ // mode = Output types binary ORed
+ bool isInteractionWaiting(1: i16 mode),
+ InteractionTask getInteractionTask(1: i16 mode),
+ void setInteractionResult(1: InteractionID iid, 2: ValueString result),
+
+ // generate a download link, everybody can download the file until timeout reached
+ string generateDownloadLink(1: FileID fid, 2: i16 timeout),
+
+ map<PluginName, list<AddonService>> getAddonHandler(),
+
+ void callAddonHandler(1: PluginName plugin, 2: string func, 3: PackageID pid_or_fid),
+
+ ///////////////////////
+ // Event Handling
+ ///////////////////////
+
+ list<EventInfo> getEvents(1: string uuid),
- //accounts
+ ///////////////////////
+ // Account Methods
+ ///////////////////////
+
list<AccountInfo> getAccounts(1: bool refresh),
list<string> getAccountTypes()
void updateAccount(1: PluginName plugin, 2: string account, 3: string password, 4: map<string, string> options),
void removeAccount(1: PluginName plugin, 2: string account),
- //auth
+ /////////////////////////
+ // Auth+User Information
+ /////////////////////////
+
bool login(1: string username, 2: string password),
- UserData getUserData(1: string username, 2:string password) throws (1: UserDoesNotExists ex),
+ UserData getUserData(1: string username, 2: string password) throws (1: UserDoesNotExists ex),
map<string, UserData> getAllUserData(),
- //services
+ ///////////////////////
+ // Addon Methods
+ ///////////////////////
- // servicename : description
- map<PluginName, map<string, string>> getServices(),
+ map<PluginName, list<AddonService>> getServices(),
bool hasService(1: PluginName plugin, 2: string func),
- string call(1: ServiceCall info) throws (1: ServiceDoesNotExists ex, 2: ServiceException e),
+ // empty string or json encoded list as args
+ string call(1: PluginName plugin, 2: string func, 3: string arguments) throws (1: ServiceDoesNotExists ex, 2: ServiceException e),
- //info
- // {plugin: {name: value}}
- map<PluginName, map<string,string>> getAllInfo(),
- map<string, string> getInfoByPlugin(1: PluginName plugin),
+ map<PluginName, list<AddonInfo>> getAllInfo(),
+ list<AddonInfo> getInfoByPlugin(1: PluginName plugin),
//scheduler
// TODO
-
- // User interaction
-
- //captcha
- bool isCaptchaWaiting(),
- CaptchaTask getCaptchaTask(1: bool exclusive),
- string getCaptchaTaskStatus(1: InteractionID tid),
- void setCaptchaResult(1: InteractionID tid, 2: string result),
}
diff --git a/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote b/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote
index 6ee40092d..6f0c09182 100755
--- a/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote
+++ b/module/remote/thriftbackend/thriftgen/pyload/Pyload-remote
@@ -23,60 +23,76 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
print 'Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] function [arg1 [arg2...]]'
print ''
print 'Functions:'
- print ' string getConfigValue(string section, string option)'
- print ' void setConfigValue(string section, string option, string value)'
- print ' getConfig()'
- print ' getPluginConfig()'
- print ' ConfigSection configureSection(string section)'
+ print ' string getServerVersion()'
+ print ' ServerStatus statusServer()'
print ' void pauseServer()'
print ' void unpauseServer()'
print ' bool togglePause()'
- print ' ServerStatus statusServer()'
- print ' i64 freeSpace()'
- print ' string getServerVersion()'
+ print ' ByteCount freeSpace()'
print ' void kill()'
print ' void restart()'
print ' getLog(i32 offset)'
print ' bool isTimeDownload()'
print ' bool isTimeReconnect()'
print ' bool toggleReconnect()'
- print ' generatePackages(LinkList links)'
+ print ' void scanDownloadFolder()'
+ print ' getProgressInfo()'
+ print ' string getConfigValue(string section, string option)'
+ print ' void setConfigValue(string section, string option, string value)'
+ print ' getConfig()'
+ print ' getPluginConfig()'
+ print ' ConfigSection configureSection(string section)'
+ print ' void setConfigHandler(PluginName plugin, InteractionID iid, ValueString value)'
print ' checkURLs(LinkList urls)'
print ' parseURLs(string html, string url)'
print ' OnlineCheck checkOnlineStatus(LinkList urls)'
print ' OnlineCheck checkOnlineStatusContainer(LinkList urls, string filename, string data)'
print ' OnlineCheck pollResults(ResultID rid)'
- print ' statusDownloads()'
- print ' PackageData getPackageData(PackageID pid)'
- print ' PackageData getPackageInfo(PackageID pid)'
- print ' FileData getFileData(FileID fid)'
- print ' getQueue()'
- print ' getCollector()'
- print ' getQueueData()'
- print ' getCollectorData()'
- print ' getPackageOrder(Destination destination)'
- print ' getFileOrder(PackageID pid)'
- print ' generateAndAddPackages(LinkList links, Destination dest)'
- print ' PackageID addPackage(string name, LinkList links, Destination dest, string password)'
- print ' void addFiles(PackageID pid, LinkList links)'
- print ' void uploadContainer(string filename, string data)'
+ print ' generatePackages(LinkList links)'
+ print ' generateAndAddPackages(LinkList links, bool paused)'
+ print ' autoAddLinks(LinkList links)'
+ print ' PackageID createPackage(string name, string folder, PackageID root, string password, string site, string comment, bool paused)'
+ print ' PackageID addPackage(string name, LinkList links, string password)'
+ print ' PackageID addPackageP(string name, LinkList links, string password, bool paused)'
+ print ' PackageID addPackageChild(string name, LinkList links, string password, PackageID root, bool paused)'
+ print ' PackageID uploadContainer(string filename, string data)'
+ print ' void addLinks(PackageID pid, LinkList links)'
print ' void deleteFiles( fids)'
print ' void deletePackages( pids)'
- print ' void pushToQueue(PackageID pid)'
- print ' void pullFromQueue(PackageID pid)'
+ print ' getCollector()'
+ print ' void addToCollector(LinkList links)'
+ print ' PackageID addFromCollector(string name, bool paused)'
+ print ' void renameCollPack(string name, string new_name)'
+ print ' void deleteCollPack(string name)'
+ print ' void deleteCollLink(string url)'
+ print ' PackageView getAllFiles()'
+ print ' PackageView getAllUnfinishedFiles()'
+ print ' PackageView getFileTree(PackageID pid, bool full)'
+ print ' PackageView getUnfinishedFileTree(PackageID pid, bool full)'
+ print ' PackageView getPackageContent(PackageID pid)'
+ print ' PackageInfo getPackageInfo(PackageID pid)'
+ print ' FileInfo getFileInfo(FileID fid)'
+ print ' findFiles(string pattern)'
print ' void restartPackage(PackageID pid)'
print ' void restartFile(FileID fid)'
print ' void recheckPackage(PackageID pid)'
- print ' void stopAllDownloads()'
print ' void stopDownloads( fids)'
- print ' void setPackageName(PackageID pid, string name)'
- print ' void movePackage(Destination destination, PackageID pid)'
- print ' void moveFiles( fids, PackageID pid)'
- print ' void orderPackage(PackageID pid, i16 position)'
- print ' void orderFile(FileID fid, i16 position)'
- print ' void setPackageData(PackageID pid, data)'
- print ' deleteFinished()'
+ print ' void stopAllDownloads()'
print ' void restartFailed()'
+ print ' void setFilePaused(FileID fid, bool paused)'
+ print ' void setPackagePaused(PackageID pid, bool paused)'
+ print ' bool setPackageFolder(PackageID pid, string path)'
+ print ' void setPackageData(PackageID pid, data)'
+ print ' bool movePackage(PackageID pid, PackageID root)'
+ print ' bool moveFiles( fids, PackageID pid)'
+ print ' void orderPackage( pids, i16 position)'
+ print ' void orderFiles( fids, PackageID pid, i16 position)'
+ print ' bool isInteractionWaiting(i16 mode)'
+ print ' InteractionTask getInteractionTask(i16 mode)'
+ print ' void setInteractionResult(InteractionID iid, ValueString result)'
+ print ' string generateDownloadLink(FileID fid, i16 timeout)'
+ print ' getAddonHandler()'
+ print ' void callAddonHandler(PluginName plugin, string func, PackageID pid_or_fid)'
print ' getEvents(string uuid)'
print ' getAccounts(bool refresh)'
print ' getAccountTypes()'
@@ -87,13 +103,9 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
print ' getAllUserData()'
print ' getServices()'
print ' bool hasService(PluginName plugin, string func)'
- print ' string call(ServiceCall info)'
+ print ' string call(PluginName plugin, string func, string arguments)'
print ' getAllInfo()'
print ' getInfoByPlugin(PluginName plugin)'
- print ' bool isCaptchaWaiting()'
- print ' CaptchaTask getCaptchaTask(bool exclusive)'
- print ' string getCaptchaTaskStatus(TaskID tid)'
- print ' void setCaptchaResult(TaskID tid, string result)'
print ''
sys.exit(0)
@@ -145,35 +157,17 @@ protocol = TBinaryProtocol.TBinaryProtocol(transport)
client = Pyload.Client(protocol)
transport.open()
-if cmd == 'getConfigValue':
- if len(args) != 2:
- print 'getConfigValue requires 2 args'
- sys.exit(1)
- pp.pprint(client.getConfigValue(args[0],args[1],))
-
-elif cmd == 'setConfigValue':
- if len(args) != 3:
- print 'setConfigValue requires 3 args'
- sys.exit(1)
- pp.pprint(client.setConfigValue(args[0],args[1],args[2],))
-
-elif cmd == 'getConfig':
+if cmd == 'getServerVersion':
if len(args) != 0:
- print 'getConfig requires 0 args'
+ print 'getServerVersion requires 0 args'
sys.exit(1)
- pp.pprint(client.getConfig())
+ pp.pprint(client.getServerVersion())
-elif cmd == 'getPluginConfig':
+elif cmd == 'statusServer':
if len(args) != 0:
- print 'getPluginConfig requires 0 args'
- sys.exit(1)
- pp.pprint(client.getPluginConfig())
-
-elif cmd == 'configureSection':
- if len(args) != 1:
- print 'configureSection requires 1 args'
+ print 'statusServer requires 0 args'
sys.exit(1)
- pp.pprint(client.configureSection(args[0],))
+ pp.pprint(client.statusServer())
elif cmd == 'pauseServer':
if len(args) != 0:
@@ -193,24 +187,12 @@ elif cmd == 'togglePause':
sys.exit(1)
pp.pprint(client.togglePause())
-elif cmd == 'statusServer':
- if len(args) != 0:
- print 'statusServer requires 0 args'
- sys.exit(1)
- pp.pprint(client.statusServer())
-
elif cmd == 'freeSpace':
if len(args) != 0:
print 'freeSpace requires 0 args'
sys.exit(1)
pp.pprint(client.freeSpace())
-elif cmd == 'getServerVersion':
- if len(args) != 0:
- print 'getServerVersion requires 0 args'
- sys.exit(1)
- pp.pprint(client.getServerVersion())
-
elif cmd == 'kill':
if len(args) != 0:
print 'kill requires 0 args'
@@ -247,11 +229,53 @@ elif cmd == 'toggleReconnect':
sys.exit(1)
pp.pprint(client.toggleReconnect())
-elif cmd == 'generatePackages':
+elif cmd == 'scanDownloadFolder':
+ if len(args) != 0:
+ print 'scanDownloadFolder requires 0 args'
+ sys.exit(1)
+ pp.pprint(client.scanDownloadFolder())
+
+elif cmd == 'getProgressInfo':
+ if len(args) != 0:
+ print 'getProgressInfo requires 0 args'
+ sys.exit(1)
+ pp.pprint(client.getProgressInfo())
+
+elif cmd == 'getConfigValue':
+ if len(args) != 2:
+ print 'getConfigValue requires 2 args'
+ sys.exit(1)
+ pp.pprint(client.getConfigValue(args[0],args[1],))
+
+elif cmd == 'setConfigValue':
+ if len(args) != 3:
+ print 'setConfigValue requires 3 args'
+ sys.exit(1)
+ pp.pprint(client.setConfigValue(args[0],args[1],args[2],))
+
+elif cmd == 'getConfig':
+ if len(args) != 0:
+ print 'getConfig requires 0 args'
+ sys.exit(1)
+ pp.pprint(client.getConfig())
+
+elif cmd == 'getPluginConfig':
+ if len(args) != 0:
+ print 'getPluginConfig requires 0 args'
+ sys.exit(1)
+ pp.pprint(client.getPluginConfig())
+
+elif cmd == 'configureSection':
if len(args) != 1:
- print 'generatePackages requires 1 args'
+ print 'configureSection requires 1 args'
sys.exit(1)
- pp.pprint(client.generatePackages(eval(args[0]),))
+ pp.pprint(client.configureSection(args[0],))
+
+elif cmd == 'setConfigHandler':
+ if len(args) != 3:
+ print 'setConfigHandler requires 3 args'
+ sys.exit(1)
+ pp.pprint(client.setConfigHandler(eval(args[0]),eval(args[1]),eval(args[2]),))
elif cmd == 'checkURLs':
if len(args) != 1:
@@ -283,35 +307,71 @@ elif cmd == 'pollResults':
sys.exit(1)
pp.pprint(client.pollResults(eval(args[0]),))
-elif cmd == 'statusDownloads':
- if len(args) != 0:
- print 'statusDownloads requires 0 args'
+elif cmd == 'generatePackages':
+ if len(args) != 1:
+ print 'generatePackages requires 1 args'
sys.exit(1)
- pp.pprint(client.statusDownloads())
+ pp.pprint(client.generatePackages(eval(args[0]),))
-elif cmd == 'getPackageData':
- if len(args) != 1:
- print 'getPackageData requires 1 args'
+elif cmd == 'generateAndAddPackages':
+ if len(args) != 2:
+ print 'generateAndAddPackages requires 2 args'
sys.exit(1)
- pp.pprint(client.getPackageData(eval(args[0]),))
+ pp.pprint(client.generateAndAddPackages(eval(args[0]),eval(args[1]),))
-elif cmd == 'getPackageInfo':
+elif cmd == 'autoAddLinks':
if len(args) != 1:
- print 'getPackageInfo requires 1 args'
+ print 'autoAddLinks requires 1 args'
sys.exit(1)
- pp.pprint(client.getPackageInfo(eval(args[0]),))
+ pp.pprint(client.autoAddLinks(eval(args[0]),))
-elif cmd == 'getFileData':
+elif cmd == 'createPackage':
+ if len(args) != 7:
+ print 'createPackage requires 7 args'
+ sys.exit(1)
+ pp.pprint(client.createPackage(args[0],args[1],eval(args[2]),args[3],args[4],args[5],eval(args[6]),))
+
+elif cmd == 'addPackage':
+ if len(args) != 3:
+ print 'addPackage requires 3 args'
+ sys.exit(1)
+ pp.pprint(client.addPackage(args[0],eval(args[1]),args[2],))
+
+elif cmd == 'addPackageP':
+ if len(args) != 4:
+ print 'addPackageP requires 4 args'
+ sys.exit(1)
+ pp.pprint(client.addPackageP(args[0],eval(args[1]),args[2],eval(args[3]),))
+
+elif cmd == 'addPackageChild':
+ if len(args) != 5:
+ print 'addPackageChild requires 5 args'
+ sys.exit(1)
+ pp.pprint(client.addPackageChild(args[0],eval(args[1]),args[2],eval(args[3]),eval(args[4]),))
+
+elif cmd == 'uploadContainer':
+ if len(args) != 2:
+ print 'uploadContainer requires 2 args'
+ sys.exit(1)
+ pp.pprint(client.uploadContainer(args[0],args[1],))
+
+elif cmd == 'addLinks':
+ if len(args) != 2:
+ print 'addLinks requires 2 args'
+ sys.exit(1)
+ pp.pprint(client.addLinks(eval(args[0]),eval(args[1]),))
+
+elif cmd == 'deleteFiles':
if len(args) != 1:
- print 'getFileData requires 1 args'
+ print 'deleteFiles requires 1 args'
sys.exit(1)
- pp.pprint(client.getFileData(eval(args[0]),))
+ pp.pprint(client.deleteFiles(eval(args[0]),))
-elif cmd == 'getQueue':
- if len(args) != 0:
- print 'getQueue requires 0 args'
+elif cmd == 'deletePackages':
+ if len(args) != 1:
+ print 'deletePackages requires 1 args'
sys.exit(1)
- pp.pprint(client.getQueue())
+ pp.pprint(client.deletePackages(eval(args[0]),))
elif cmd == 'getCollector':
if len(args) != 0:
@@ -319,77 +379,83 @@ elif cmd == 'getCollector':
sys.exit(1)
pp.pprint(client.getCollector())
-elif cmd == 'getQueueData':
- if len(args) != 0:
- print 'getQueueData requires 0 args'
+elif cmd == 'addToCollector':
+ if len(args) != 1:
+ print 'addToCollector requires 1 args'
sys.exit(1)
- pp.pprint(client.getQueueData())
+ pp.pprint(client.addToCollector(eval(args[0]),))
-elif cmd == 'getCollectorData':
- if len(args) != 0:
- print 'getCollectorData requires 0 args'
+elif cmd == 'addFromCollector':
+ if len(args) != 2:
+ print 'addFromCollector requires 2 args'
+ sys.exit(1)
+ pp.pprint(client.addFromCollector(args[0],eval(args[1]),))
+
+elif cmd == 'renameCollPack':
+ if len(args) != 2:
+ print 'renameCollPack requires 2 args'
sys.exit(1)
- pp.pprint(client.getCollectorData())
+ pp.pprint(client.renameCollPack(args[0],args[1],))
-elif cmd == 'getPackageOrder':
+elif cmd == 'deleteCollPack':
if len(args) != 1:
- print 'getPackageOrder requires 1 args'
+ print 'deleteCollPack requires 1 args'
sys.exit(1)
- pp.pprint(client.getPackageOrder(eval(args[0]),))
+ pp.pprint(client.deleteCollPack(args[0],))
-elif cmd == 'getFileOrder':
+elif cmd == 'deleteCollLink':
if len(args) != 1:
- print 'getFileOrder requires 1 args'
+ print 'deleteCollLink requires 1 args'
sys.exit(1)
- pp.pprint(client.getFileOrder(eval(args[0]),))
+ pp.pprint(client.deleteCollLink(args[0],))
-elif cmd == 'generateAndAddPackages':
- if len(args) != 2:
- print 'generateAndAddPackages requires 2 args'
+elif cmd == 'getAllFiles':
+ if len(args) != 0:
+ print 'getAllFiles requires 0 args'
sys.exit(1)
- pp.pprint(client.generateAndAddPackages(eval(args[0]),eval(args[1]),))
+ pp.pprint(client.getAllFiles())
-elif cmd == 'addPackage':
- if len(args) != 4:
- print 'addPackage requires 4 args'
+elif cmd == 'getAllUnfinishedFiles':
+ if len(args) != 0:
+ print 'getAllUnfinishedFiles requires 0 args'
sys.exit(1)
- pp.pprint(client.addPackage(args[0],eval(args[1]),eval(args[2]),args[3],))
+ pp.pprint(client.getAllUnfinishedFiles())
-elif cmd == 'addFiles':
+elif cmd == 'getFileTree':
if len(args) != 2:
- print 'addFiles requires 2 args'
+ print 'getFileTree requires 2 args'
sys.exit(1)
- pp.pprint(client.addFiles(eval(args[0]),eval(args[1]),))
+ pp.pprint(client.getFileTree(eval(args[0]),eval(args[1]),))
-elif cmd == 'uploadContainer':
+elif cmd == 'getUnfinishedFileTree':
if len(args) != 2:
- print 'uploadContainer requires 2 args'
+ print 'getUnfinishedFileTree requires 2 args'
sys.exit(1)
- pp.pprint(client.uploadContainer(args[0],args[1],))
+ pp.pprint(client.getUnfinishedFileTree(eval(args[0]),eval(args[1]),))
-elif cmd == 'deleteFiles':
+elif cmd == 'getPackageContent':
if len(args) != 1:
- print 'deleteFiles requires 1 args'
+ print 'getPackageContent requires 1 args'
sys.exit(1)
- pp.pprint(client.deleteFiles(eval(args[0]),))
+ pp.pprint(client.getPackageContent(eval(args[0]),))
-elif cmd == 'deletePackages':
+elif cmd == 'getPackageInfo':
if len(args) != 1:
- print 'deletePackages requires 1 args'
+ print 'getPackageInfo requires 1 args'
sys.exit(1)
- pp.pprint(client.deletePackages(eval(args[0]),))
+ pp.pprint(client.getPackageInfo(eval(args[0]),))
-elif cmd == 'pushToQueue':
+elif cmd == 'getFileInfo':
if len(args) != 1:
- print 'pushToQueue requires 1 args'
+ print 'getFileInfo requires 1 args'
sys.exit(1)
- pp.pprint(client.pushToQueue(eval(args[0]),))
+ pp.pprint(client.getFileInfo(eval(args[0]),))
-elif cmd == 'pullFromQueue':
+elif cmd == 'findFiles':
if len(args) != 1:
- print 'pullFromQueue requires 1 args'
+ print 'findFiles requires 1 args'
sys.exit(1)
- pp.pprint(client.pullFromQueue(eval(args[0]),))
+ pp.pprint(client.findFiles(args[0],))
elif cmd == 'restartPackage':
if len(args) != 1:
@@ -409,23 +475,47 @@ elif cmd == 'recheckPackage':
sys.exit(1)
pp.pprint(client.recheckPackage(eval(args[0]),))
+elif cmd == 'stopDownloads':
+ if len(args) != 1:
+ print 'stopDownloads requires 1 args'
+ sys.exit(1)
+ pp.pprint(client.stopDownloads(eval(args[0]),))
+
elif cmd == 'stopAllDownloads':
if len(args) != 0:
print 'stopAllDownloads requires 0 args'
sys.exit(1)
pp.pprint(client.stopAllDownloads())
-elif cmd == 'stopDownloads':
- if len(args) != 1:
- print 'stopDownloads requires 1 args'
+elif cmd == 'restartFailed':
+ if len(args) != 0:
+ print 'restartFailed requires 0 args'
sys.exit(1)
- pp.pprint(client.stopDownloads(eval(args[0]),))
+ pp.pprint(client.restartFailed())
+
+elif cmd == 'setFilePaused':
+ if len(args) != 2:
+ print 'setFilePaused requires 2 args'
+ sys.exit(1)
+ pp.pprint(client.setFilePaused(eval(args[0]),eval(args[1]),))
+
+elif cmd == 'setPackagePaused':
+ if len(args) != 2:
+ print 'setPackagePaused requires 2 args'
+ sys.exit(1)
+ pp.pprint(client.setPackagePaused(eval(args[0]),eval(args[1]),))
+
+elif cmd == 'setPackageFolder':
+ if len(args) != 2:
+ print 'setPackageFolder requires 2 args'
+ sys.exit(1)
+ pp.pprint(client.setPackageFolder(eval(args[0]),args[1],))
-elif cmd == 'setPackageName':
+elif cmd == 'setPackageData':
if len(args) != 2:
- print 'setPackageName requires 2 args'
+ print 'setPackageData requires 2 args'
sys.exit(1)
- pp.pprint(client.setPackageName(eval(args[0]),args[1],))
+ pp.pprint(client.setPackageData(eval(args[0]),eval(args[1]),))
elif cmd == 'movePackage':
if len(args) != 2:
@@ -445,29 +535,47 @@ elif cmd == 'orderPackage':
sys.exit(1)
pp.pprint(client.orderPackage(eval(args[0]),eval(args[1]),))
-elif cmd == 'orderFile':
+elif cmd == 'orderFiles':
+ if len(args) != 3:
+ print 'orderFiles requires 3 args'
+ sys.exit(1)
+ pp.pprint(client.orderFiles(eval(args[0]),eval(args[1]),eval(args[2]),))
+
+elif cmd == 'isInteractionWaiting':
+ if len(args) != 1:
+ print 'isInteractionWaiting requires 1 args'
+ sys.exit(1)
+ pp.pprint(client.isInteractionWaiting(eval(args[0]),))
+
+elif cmd == 'getInteractionTask':
+ if len(args) != 1:
+ print 'getInteractionTask requires 1 args'
+ sys.exit(1)
+ pp.pprint(client.getInteractionTask(eval(args[0]),))
+
+elif cmd == 'setInteractionResult':
if len(args) != 2:
- print 'orderFile requires 2 args'
+ print 'setInteractionResult requires 2 args'
sys.exit(1)
- pp.pprint(client.orderFile(eval(args[0]),eval(args[1]),))
+ pp.pprint(client.setInteractionResult(eval(args[0]),eval(args[1]),))
-elif cmd == 'setPackageData':
+elif cmd == 'generateDownloadLink':
if len(args) != 2:
- print 'setPackageData requires 2 args'
+ print 'generateDownloadLink requires 2 args'
sys.exit(1)
- pp.pprint(client.setPackageData(eval(args[0]),eval(args[1]),))
+ pp.pprint(client.generateDownloadLink(eval(args[0]),eval(args[1]),))
-elif cmd == 'deleteFinished':
+elif cmd == 'getAddonHandler':
if len(args) != 0:
- print 'deleteFinished requires 0 args'
+ print 'getAddonHandler requires 0 args'
sys.exit(1)
- pp.pprint(client.deleteFinished())
+ pp.pprint(client.getAddonHandler())
-elif cmd == 'restartFailed':
- if len(args) != 0:
- print 'restartFailed requires 0 args'
+elif cmd == 'callAddonHandler':
+ if len(args) != 3:
+ print 'callAddonHandler requires 3 args'
sys.exit(1)
- pp.pprint(client.restartFailed())
+ pp.pprint(client.callAddonHandler(eval(args[0]),args[1],eval(args[2]),))
elif cmd == 'getEvents':
if len(args) != 1:
@@ -530,10 +638,10 @@ elif cmd == 'hasService':
pp.pprint(client.hasService(eval(args[0]),args[1],))
elif cmd == 'call':
- if len(args) != 1:
- print 'call requires 1 args'
+ if len(args) != 3:
+ print 'call requires 3 args'
sys.exit(1)
- pp.pprint(client.call(eval(args[0]),))
+ pp.pprint(client.call(eval(args[0]),args[1],args[2],))
elif cmd == 'getAllInfo':
if len(args) != 0:
@@ -547,30 +655,6 @@ elif cmd == 'getInfoByPlugin':
sys.exit(1)
pp.pprint(client.getInfoByPlugin(eval(args[0]),))
-elif cmd == 'isCaptchaWaiting':
- if len(args) != 0:
- print 'isCaptchaWaiting requires 0 args'
- sys.exit(1)
- pp.pprint(client.isCaptchaWaiting())
-
-elif cmd == 'getCaptchaTask':
- if len(args) != 1:
- print 'getCaptchaTask requires 1 args'
- sys.exit(1)
- pp.pprint(client.getCaptchaTask(eval(args[0]),))
-
-elif cmd == 'getCaptchaTaskStatus':
- if len(args) != 1:
- print 'getCaptchaTaskStatus requires 1 args'
- sys.exit(1)
- pp.pprint(client.getCaptchaTaskStatus(eval(args[0]),))
-
-elif cmd == 'setCaptchaResult':
- if len(args) != 2:
- print 'setCaptchaResult requires 2 args'
- sys.exit(1)
- pp.pprint(client.setCaptchaResult(eval(args[0]),args[1],))
-
else:
print 'Unrecognized method %s' % cmd
sys.exit(1)
diff --git a/module/remote/thriftbackend/thriftgen/pyload/Pyload.py b/module/remote/thriftbackend/thriftgen/pyload/Pyload.py
index 3e0fe3bbc..e58070a59 100644
--- a/module/remote/thriftbackend/thriftgen/pyload/Pyload.py
+++ b/module/remote/thriftbackend/thriftgen/pyload/Pyload.py
@@ -9,38 +9,14 @@
from thrift.Thrift import TType, TMessageType, TException
from ttypes import *
from thrift.Thrift import TProcessor
-from thrift.protocol.TBase import TBase, TExceptionBase, TApplicationException
+from thrift.protocol.TBase import TBase, TExceptionBase
class Iface(object):
- def getConfigValue(self, section, option):
- """
- Parameters:
- - section
- - option
- """
- pass
-
- def setConfigValue(self, section, option, value):
- """
- Parameters:
- - section
- - option
- - value
- """
- pass
-
- def getConfig(self, ):
- pass
-
- def getPluginConfig(self, ):
+ def getServerVersion(self, ):
pass
- def configureSection(self, section):
- """
- Parameters:
- - section
- """
+ def statusServer(self, ):
pass
def pauseServer(self, ):
@@ -52,15 +28,9 @@ class Iface(object):
def togglePause(self, ):
pass
- def statusServer(self, ):
- pass
-
def freeSpace(self, ):
pass
- def getServerVersion(self, ):
- pass
-
def kill(self, ):
pass
@@ -83,10 +53,48 @@ class Iface(object):
def toggleReconnect(self, ):
pass
- def generatePackages(self, links):
+ def scanDownloadFolder(self, ):
+ pass
+
+ def getProgressInfo(self, ):
+ pass
+
+ def getConfigValue(self, section, option):
"""
Parameters:
- - links
+ - section
+ - option
+ """
+ pass
+
+ def setConfigValue(self, section, option, value):
+ """
+ Parameters:
+ - section
+ - option
+ - value
+ """
+ pass
+
+ def getConfig(self, ):
+ pass
+
+ def getPluginConfig(self, ):
+ pass
+
+ def configureSection(self, section):
+ """
+ Parameters:
+ - section
+ """
+ pass
+
+ def setConfigHandler(self, plugin, iid, value):
+ """
+ Parameters:
+ - plugin
+ - iid
+ - value
"""
pass
@@ -128,118 +136,191 @@ class Iface(object):
"""
pass
- def statusDownloads(self, ):
+ def generatePackages(self, links):
+ """
+ Parameters:
+ - links
+ """
pass
- def getPackageData(self, pid):
+ def generateAndAddPackages(self, links, paused):
"""
Parameters:
- - pid
+ - links
+ - paused
"""
pass
- def getPackageInfo(self, pid):
+ def autoAddLinks(self, links):
"""
Parameters:
- - pid
+ - links
"""
pass
- def getFileData(self, fid):
+ def createPackage(self, name, folder, root, password, site, comment, paused):
"""
Parameters:
- - fid
+ - name
+ - folder
+ - root
+ - password
+ - site
+ - comment
+ - paused
"""
pass
- def getQueue(self, ):
+ def addPackage(self, name, links, password):
+ """
+ Parameters:
+ - name
+ - links
+ - password
+ """
pass
- def getCollector(self, ):
+ def addPackageP(self, name, links, password, paused):
+ """
+ Parameters:
+ - name
+ - links
+ - password
+ - paused
+ """
pass
- def getQueueData(self, ):
+ def addPackageChild(self, name, links, password, root, paused):
+ """
+ Parameters:
+ - name
+ - links
+ - password
+ - root
+ - paused
+ """
pass
- def getCollectorData(self, ):
+ def uploadContainer(self, filename, data):
+ """
+ Parameters:
+ - filename
+ - data
+ """
pass
- def getPackageOrder(self, destination):
+ def addLinks(self, pid, links):
"""
Parameters:
- - destination
+ - pid
+ - links
"""
pass
- def getFileOrder(self, pid):
+ def deleteFiles(self, fids):
"""
Parameters:
- - pid
+ - fids
+ """
+ pass
+
+ def deletePackages(self, pids):
"""
+ Parameters:
+ - pids
+ """
+ pass
+
+ def getCollector(self, ):
pass
- def generateAndAddPackages(self, links, dest):
+ def addToCollector(self, links):
"""
Parameters:
- links
- - dest
"""
pass
- def addPackage(self, name, links, dest, password):
+ def addFromCollector(self, name, paused):
"""
Parameters:
- name
- - links
- - dest
- - password
+ - paused
"""
pass
- def addFiles(self, pid, links):
+ def renameCollPack(self, name, new_name):
"""
Parameters:
- - pid
- - links
+ - name
+ - new_name
"""
pass
- def uploadContainer(self, filename, data):
+ def deleteCollPack(self, name):
"""
Parameters:
- - filename
- - data
+ - name
"""
pass
- def deleteFiles(self, fids):
+ def deleteCollLink(self, url):
"""
Parameters:
- - fids
+ - url
"""
pass
- def deletePackages(self, pids):
+ def getAllFiles(self, ):
+ pass
+
+ def getAllUnfinishedFiles(self, ):
+ pass
+
+ def getFileTree(self, pid, full):
"""
Parameters:
- - pids
+ - pid
+ - full
+ """
+ pass
+
+ def getUnfinishedFileTree(self, pid, full):
+ """
+ Parameters:
+ - pid
+ - full
"""
pass
- def pushToQueue(self, pid):
+ def getPackageContent(self, pid):
"""
Parameters:
- pid
"""
pass
- def pullFromQueue(self, pid):
+ def getPackageInfo(self, pid):
"""
Parameters:
- pid
"""
pass
+ def getFileInfo(self, fid):
+ """
+ Parameters:
+ - fid
+ """
+ pass
+
+ def findFiles(self, pattern):
+ """
+ Parameters:
+ - pattern
+ """
+ pass
+
def restartPackage(self, pid):
"""
Parameters:
@@ -261,29 +342,56 @@ class Iface(object):
"""
pass
+ def stopDownloads(self, fids):
+ """
+ Parameters:
+ - fids
+ """
+ pass
+
def stopAllDownloads(self, ):
pass
- def stopDownloads(self, fids):
+ def restartFailed(self, ):
+ pass
+
+ def setFilePaused(self, fid, paused):
"""
Parameters:
- - fids
+ - fid
+ - paused
"""
pass
- def setPackageName(self, pid, name):
+ def setPackagePaused(self, pid, paused):
"""
Parameters:
- pid
- - name
+ - paused
"""
pass
- def movePackage(self, destination, pid):
+ def setPackageFolder(self, pid, path):
"""
Parameters:
- - destination
- pid
+ - path
+ """
+ pass
+
+ def setPackageData(self, pid, data):
+ """
+ Parameters:
+ - pid
+ - data
+ """
+ pass
+
+ def movePackage(self, pid, root):
+ """
+ Parameters:
+ - pid
+ - root
"""
pass
@@ -295,34 +403,63 @@ class Iface(object):
"""
pass
- def orderPackage(self, pid, position):
+ def orderPackage(self, pids, position):
"""
Parameters:
- - pid
+ - pids
- position
"""
pass
- def orderFile(self, fid, position):
+ def orderFiles(self, fids, pid, position):
"""
Parameters:
- - fid
+ - fids
+ - pid
- position
"""
pass
- def setPackageData(self, pid, data):
+ def isInteractionWaiting(self, mode):
"""
Parameters:
- - pid
- - data
+ - mode
"""
pass
- def deleteFinished(self, ):
+ def getInteractionTask(self, mode):
+ """
+ Parameters:
+ - mode
+ """
pass
- def restartFailed(self, ):
+ def setInteractionResult(self, iid, result):
+ """
+ Parameters:
+ - iid
+ - result
+ """
+ pass
+
+ def generateDownloadLink(self, fid, timeout):
+ """
+ Parameters:
+ - fid
+ - timeout
+ """
+ pass
+
+ def getAddonHandler(self, ):
+ pass
+
+ def callAddonHandler(self, plugin, func, pid_or_fid):
+ """
+ Parameters:
+ - plugin
+ - func
+ - pid_or_fid
+ """
pass
def getEvents(self, uuid):
@@ -390,10 +527,12 @@ class Iface(object):
"""
pass
- def call(self, info):
+ def call(self, plugin, func, arguments):
"""
Parameters:
- - info
+ - plugin
+ - func
+ - arguments
"""
pass
@@ -407,31 +546,6 @@ class Iface(object):
"""
pass
- def isCaptchaWaiting(self, ):
- pass
-
- def getCaptchaTask(self, exclusive):
- """
- Parameters:
- - exclusive
- """
- pass
-
- def getCaptchaTaskStatus(self, tid):
- """
- Parameters:
- - tid
- """
- pass
-
- def setCaptchaResult(self, tid, result):
- """
- Parameters:
- - tid
- - result
- """
- pass
-
class Client(Iface):
def __init__(self, iprot, oprot=None):
@@ -440,149 +554,55 @@ class Client(Iface):
self._oprot = oprot
self._seqid = 0
- def getConfigValue(self, section, option):
- """
- Parameters:
- - section
- - option
- """
- self.send_getConfigValue(section, option)
- return self.recv_getConfigValue()
-
- def send_getConfigValue(self, section, option):
- self._oprot.writeMessageBegin('getConfigValue', TMessageType.CALL, self._seqid)
- args = getConfigValue_args()
- args.section = section
- args.option = option
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_getConfigValue(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = getConfigValue_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfigValue failed: unknown result");
-
- def setConfigValue(self, section, option, value):
- """
- Parameters:
- - section
- - option
- - value
- """
- self.send_setConfigValue(section, option, value)
- self.recv_setConfigValue()
-
- def send_setConfigValue(self, section, option, value):
- self._oprot.writeMessageBegin('setConfigValue', TMessageType.CALL, self._seqid)
- args = setConfigValue_args()
- args.section = section
- args.option = option
- args.value = value
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_setConfigValue(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = setConfigValue_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- return
-
- def getConfig(self, ):
- self.send_getConfig()
- return self.recv_getConfig()
-
- def send_getConfig(self, ):
- self._oprot.writeMessageBegin('getConfig', TMessageType.CALL, self._seqid)
- args = getConfig_args()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_getConfig(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = getConfig_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfig failed: unknown result");
-
- def getPluginConfig(self, ):
- self.send_getPluginConfig()
- return self.recv_getPluginConfig()
+ def getServerVersion(self, ):
+ self.send_getServerVersion()
+ return self.recv_getServerVersion()
- def send_getPluginConfig(self, ):
- self._oprot.writeMessageBegin('getPluginConfig', TMessageType.CALL, self._seqid)
- args = getPluginConfig_args()
+ def send_getServerVersion(self, ):
+ self._oprot.writeMessageBegin('getServerVersion', TMessageType.CALL, self._seqid)
+ args = getServerVersion_args()
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getPluginConfig(self, ):
+ def recv_getServerVersion(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = getPluginConfig_result()
+ result = getServerVersion_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getPluginConfig failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getServerVersion failed: unknown result");
- def configureSection(self, section):
- """
- Parameters:
- - section
- """
- self.send_configureSection(section)
- return self.recv_configureSection()
+ def statusServer(self, ):
+ self.send_statusServer()
+ return self.recv_statusServer()
- def send_configureSection(self, section):
- self._oprot.writeMessageBegin('configureSection', TMessageType.CALL, self._seqid)
- args = configureSection_args()
- args.section = section
+ def send_statusServer(self, ):
+ self._oprot.writeMessageBegin('statusServer', TMessageType.CALL, self._seqid)
+ args = statusServer_args()
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_configureSection(self, ):
+ def recv_statusServer(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = configureSection_result()
+ result = statusServer_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "configureSection failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "statusServer failed: unknown result");
def pauseServer(self, ):
self.send_pauseServer()
@@ -655,31 +675,6 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "togglePause failed: unknown result");
- def statusServer(self, ):
- self.send_statusServer()
- return self.recv_statusServer()
-
- def send_statusServer(self, ):
- self._oprot.writeMessageBegin('statusServer', TMessageType.CALL, self._seqid)
- args = statusServer_args()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_statusServer(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = statusServer_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "statusServer failed: unknown result");
-
def freeSpace(self, ):
self.send_freeSpace()
return self.recv_freeSpace()
@@ -705,31 +700,6 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "freeSpace failed: unknown result");
- def getServerVersion(self, ):
- self.send_getServerVersion()
- return self.recv_getServerVersion()
-
- def send_getServerVersion(self, ):
- self._oprot.writeMessageBegin('getServerVersion', TMessageType.CALL, self._seqid)
- args = getServerVersion_args()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_getServerVersion(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = getServerVersion_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getServerVersion failed: unknown result");
-
def kill(self, ):
self.send_kill()
self.recv_kill()
@@ -881,35 +851,229 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "toggleReconnect failed: unknown result");
- def generatePackages(self, links):
+ def scanDownloadFolder(self, ):
+ self.send_scanDownloadFolder()
+ self.recv_scanDownloadFolder()
+
+ def send_scanDownloadFolder(self, ):
+ self._oprot.writeMessageBegin('scanDownloadFolder', TMessageType.CALL, self._seqid)
+ args = scanDownloadFolder_args()
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_scanDownloadFolder(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = scanDownloadFolder_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ return
+
+ def getProgressInfo(self, ):
+ self.send_getProgressInfo()
+ return self.recv_getProgressInfo()
+
+ def send_getProgressInfo(self, ):
+ self._oprot.writeMessageBegin('getProgressInfo', TMessageType.CALL, self._seqid)
+ args = getProgressInfo_args()
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_getProgressInfo(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = getProgressInfo_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getProgressInfo failed: unknown result");
+
+ def getConfigValue(self, section, option):
"""
Parameters:
- - links
+ - section
+ - option
"""
- self.send_generatePackages(links)
- return self.recv_generatePackages()
+ self.send_getConfigValue(section, option)
+ return self.recv_getConfigValue()
- def send_generatePackages(self, links):
- self._oprot.writeMessageBegin('generatePackages', TMessageType.CALL, self._seqid)
- args = generatePackages_args()
- args.links = links
+ def send_getConfigValue(self, section, option):
+ self._oprot.writeMessageBegin('getConfigValue', TMessageType.CALL, self._seqid)
+ args = getConfigValue_args()
+ args.section = section
+ args.option = option
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_generatePackages(self, ):
+ def recv_getConfigValue(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = generatePackages_result()
+ result = getConfigValue_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "generatePackages failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfigValue failed: unknown result");
+
+ def setConfigValue(self, section, option, value):
+ """
+ Parameters:
+ - section
+ - option
+ - value
+ """
+ self.send_setConfigValue(section, option, value)
+ self.recv_setConfigValue()
+
+ def send_setConfigValue(self, section, option, value):
+ self._oprot.writeMessageBegin('setConfigValue', TMessageType.CALL, self._seqid)
+ args = setConfigValue_args()
+ args.section = section
+ args.option = option
+ args.value = value
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_setConfigValue(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = setConfigValue_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ return
+
+ def getConfig(self, ):
+ self.send_getConfig()
+ return self.recv_getConfig()
+
+ def send_getConfig(self, ):
+ self._oprot.writeMessageBegin('getConfig', TMessageType.CALL, self._seqid)
+ args = getConfig_args()
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_getConfig(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = getConfig_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getConfig failed: unknown result");
+
+ def getPluginConfig(self, ):
+ self.send_getPluginConfig()
+ return self.recv_getPluginConfig()
+
+ def send_getPluginConfig(self, ):
+ self._oprot.writeMessageBegin('getPluginConfig', TMessageType.CALL, self._seqid)
+ args = getPluginConfig_args()
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_getPluginConfig(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = getPluginConfig_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getPluginConfig failed: unknown result");
+
+ def configureSection(self, section):
+ """
+ Parameters:
+ - section
+ """
+ self.send_configureSection(section)
+ return self.recv_configureSection()
+
+ def send_configureSection(self, section):
+ self._oprot.writeMessageBegin('configureSection', TMessageType.CALL, self._seqid)
+ args = configureSection_args()
+ args.section = section
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_configureSection(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = configureSection_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "configureSection failed: unknown result");
+
+ def setConfigHandler(self, plugin, iid, value):
+ """
+ Parameters:
+ - plugin
+ - iid
+ - value
+ """
+ self.send_setConfigHandler(plugin, iid, value)
+ self.recv_setConfigHandler()
+
+ def send_setConfigHandler(self, plugin, iid, value):
+ self._oprot.writeMessageBegin('setConfigHandler', TMessageType.CALL, self._seqid)
+ args = setConfigHandler_args()
+ args.plugin = plugin
+ args.iid = iid
+ args.value = value
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_setConfigHandler(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = setConfigHandler_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ return
def checkURLs(self, urls):
"""
@@ -1067,526 +1231,776 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "pollResults failed: unknown result");
- def statusDownloads(self, ):
- self.send_statusDownloads()
- return self.recv_statusDownloads()
+ def generatePackages(self, links):
+ """
+ Parameters:
+ - links
+ """
+ self.send_generatePackages(links)
+ return self.recv_generatePackages()
- def send_statusDownloads(self, ):
- self._oprot.writeMessageBegin('statusDownloads', TMessageType.CALL, self._seqid)
- args = statusDownloads_args()
+ def send_generatePackages(self, links):
+ self._oprot.writeMessageBegin('generatePackages', TMessageType.CALL, self._seqid)
+ args = generatePackages_args()
+ args.links = links
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_statusDownloads(self, ):
+ def recv_generatePackages(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = statusDownloads_result()
+ result = generatePackages_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "statusDownloads failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "generatePackages failed: unknown result");
- def getPackageData(self, pid):
+ def generateAndAddPackages(self, links, paused):
"""
Parameters:
- - pid
+ - links
+ - paused
"""
- self.send_getPackageData(pid)
- return self.recv_getPackageData()
+ self.send_generateAndAddPackages(links, paused)
+ return self.recv_generateAndAddPackages()
- def send_getPackageData(self, pid):
- self._oprot.writeMessageBegin('getPackageData', TMessageType.CALL, self._seqid)
- args = getPackageData_args()
- args.pid = pid
+ def send_generateAndAddPackages(self, links, paused):
+ self._oprot.writeMessageBegin('generateAndAddPackages', TMessageType.CALL, self._seqid)
+ args = generateAndAddPackages_args()
+ args.links = links
+ args.paused = paused
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getPackageData(self, ):
+ def recv_generateAndAddPackages(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = getPackageData_result()
+ result = generateAndAddPackages_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- if result.e is not None:
- raise result.e
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageData failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndAddPackages failed: unknown result");
- def getPackageInfo(self, pid):
+ def autoAddLinks(self, links):
"""
Parameters:
- - pid
+ - links
"""
- self.send_getPackageInfo(pid)
- return self.recv_getPackageInfo()
+ self.send_autoAddLinks(links)
+ return self.recv_autoAddLinks()
- def send_getPackageInfo(self, pid):
- self._oprot.writeMessageBegin('getPackageInfo', TMessageType.CALL, self._seqid)
- args = getPackageInfo_args()
- args.pid = pid
+ def send_autoAddLinks(self, links):
+ self._oprot.writeMessageBegin('autoAddLinks', TMessageType.CALL, self._seqid)
+ args = autoAddLinks_args()
+ args.links = links
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getPackageInfo(self, ):
+ def recv_autoAddLinks(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = getPackageInfo_result()
+ result = autoAddLinks_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- if result.e is not None:
- raise result.e
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageInfo failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "autoAddLinks failed: unknown result");
- def getFileData(self, fid):
+ def createPackage(self, name, folder, root, password, site, comment, paused):
"""
Parameters:
- - fid
+ - name
+ - folder
+ - root
+ - password
+ - site
+ - comment
+ - paused
"""
- self.send_getFileData(fid)
- return self.recv_getFileData()
+ self.send_createPackage(name, folder, root, password, site, comment, paused)
+ return self.recv_createPackage()
- def send_getFileData(self, fid):
- self._oprot.writeMessageBegin('getFileData', TMessageType.CALL, self._seqid)
- args = getFileData_args()
- args.fid = fid
+ def send_createPackage(self, name, folder, root, password, site, comment, paused):
+ self._oprot.writeMessageBegin('createPackage', TMessageType.CALL, self._seqid)
+ args = createPackage_args()
+ args.name = name
+ args.folder = folder
+ args.root = root
+ args.password = password
+ args.site = site
+ args.comment = comment
+ args.paused = paused
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getFileData(self, ):
+ def recv_createPackage(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = getFileData_result()
+ result = createPackage_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- if result.e is not None:
- raise result.e
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileData failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "createPackage failed: unknown result");
- def getQueue(self, ):
- self.send_getQueue()
- return self.recv_getQueue()
+ def addPackage(self, name, links, password):
+ """
+ Parameters:
+ - name
+ - links
+ - password
+ """
+ self.send_addPackage(name, links, password)
+ return self.recv_addPackage()
- def send_getQueue(self, ):
- self._oprot.writeMessageBegin('getQueue', TMessageType.CALL, self._seqid)
- args = getQueue_args()
+ def send_addPackage(self, name, links, password):
+ self._oprot.writeMessageBegin('addPackage', TMessageType.CALL, self._seqid)
+ args = addPackage_args()
+ args.name = name
+ args.links = links
+ args.password = password
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getQueue(self, ):
+ def recv_addPackage(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = getQueue_result()
+ result = addPackage_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueue failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "addPackage failed: unknown result");
- def getCollector(self, ):
- self.send_getCollector()
- return self.recv_getCollector()
+ def addPackageP(self, name, links, password, paused):
+ """
+ Parameters:
+ - name
+ - links
+ - password
+ - paused
+ """
+ self.send_addPackageP(name, links, password, paused)
+ return self.recv_addPackageP()
- def send_getCollector(self, ):
- self._oprot.writeMessageBegin('getCollector', TMessageType.CALL, self._seqid)
- args = getCollector_args()
+ def send_addPackageP(self, name, links, password, paused):
+ self._oprot.writeMessageBegin('addPackageP', TMessageType.CALL, self._seqid)
+ args = addPackageP_args()
+ args.name = name
+ args.links = links
+ args.password = password
+ args.paused = paused
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getCollector(self, ):
+ def recv_addPackageP(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = getCollector_result()
+ result = addPackageP_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getCollector failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "addPackageP failed: unknown result");
- def getQueueData(self, ):
- self.send_getQueueData()
- return self.recv_getQueueData()
+ def addPackageChild(self, name, links, password, root, paused):
+ """
+ Parameters:
+ - name
+ - links
+ - password
+ - root
+ - paused
+ """
+ self.send_addPackageChild(name, links, password, root, paused)
+ return self.recv_addPackageChild()
- def send_getQueueData(self, ):
- self._oprot.writeMessageBegin('getQueueData', TMessageType.CALL, self._seqid)
- args = getQueueData_args()
+ def send_addPackageChild(self, name, links, password, root, paused):
+ self._oprot.writeMessageBegin('addPackageChild', TMessageType.CALL, self._seqid)
+ args = addPackageChild_args()
+ args.name = name
+ args.links = links
+ args.password = password
+ args.root = root
+ args.paused = paused
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getQueueData(self, ):
+ def recv_addPackageChild(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = getQueueData_result()
+ result = addPackageChild_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getQueueData failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "addPackageChild failed: unknown result");
- def getCollectorData(self, ):
- self.send_getCollectorData()
- return self.recv_getCollectorData()
+ def uploadContainer(self, filename, data):
+ """
+ Parameters:
+ - filename
+ - data
+ """
+ self.send_uploadContainer(filename, data)
+ return self.recv_uploadContainer()
- def send_getCollectorData(self, ):
- self._oprot.writeMessageBegin('getCollectorData', TMessageType.CALL, self._seqid)
- args = getCollectorData_args()
+ def send_uploadContainer(self, filename, data):
+ self._oprot.writeMessageBegin('uploadContainer', TMessageType.CALL, self._seqid)
+ args = uploadContainer_args()
+ args.filename = filename
+ args.data = data
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getCollectorData(self, ):
+ def recv_uploadContainer(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = getCollectorData_result()
+ result = uploadContainer_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getCollectorData failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "uploadContainer failed: unknown result");
- def getPackageOrder(self, destination):
+ def addLinks(self, pid, links):
"""
Parameters:
- - destination
+ - pid
+ - links
"""
- self.send_getPackageOrder(destination)
- return self.recv_getPackageOrder()
+ self.send_addLinks(pid, links)
+ self.recv_addLinks()
- def send_getPackageOrder(self, destination):
- self._oprot.writeMessageBegin('getPackageOrder', TMessageType.CALL, self._seqid)
- args = getPackageOrder_args()
- args.destination = destination
+ def send_addLinks(self, pid, links):
+ self._oprot.writeMessageBegin('addLinks', TMessageType.CALL, self._seqid)
+ args = addLinks_args()
+ args.pid = pid
+ args.links = links
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getPackageOrder(self, ):
+ def recv_addLinks(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = getPackageOrder_result()
+ result = addLinks_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageOrder failed: unknown result");
+ if result.e is not None:
+ raise result.e
+ return
- def getFileOrder(self, pid):
+ def deleteFiles(self, fids):
"""
Parameters:
- - pid
+ - fids
"""
- self.send_getFileOrder(pid)
- return self.recv_getFileOrder()
+ self.send_deleteFiles(fids)
+ self.recv_deleteFiles()
- def send_getFileOrder(self, pid):
- self._oprot.writeMessageBegin('getFileOrder', TMessageType.CALL, self._seqid)
- args = getFileOrder_args()
- args.pid = pid
+ def send_deleteFiles(self, fids):
+ self._oprot.writeMessageBegin('deleteFiles', TMessageType.CALL, self._seqid)
+ args = deleteFiles_args()
+ args.fids = fids
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getFileOrder(self, ):
+ def recv_deleteFiles(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = getFileOrder_result()
+ result = deleteFiles_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ return
+
+ def deletePackages(self, pids):
+ """
+ Parameters:
+ - pids
+ """
+ self.send_deletePackages(pids)
+ self.recv_deletePackages()
+
+ def send_deletePackages(self, pids):
+ self._oprot.writeMessageBegin('deletePackages', TMessageType.CALL, self._seqid)
+ args = deletePackages_args()
+ args.pids = pids
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_deletePackages(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = deletePackages_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ return
+
+ def getCollector(self, ):
+ self.send_getCollector()
+ return self.recv_getCollector()
+
+ def send_getCollector(self, ):
+ self._oprot.writeMessageBegin('getCollector', TMessageType.CALL, self._seqid)
+ args = getCollector_args()
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_getCollector(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = getCollector_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileOrder failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getCollector failed: unknown result");
- def generateAndAddPackages(self, links, dest):
+ def addToCollector(self, links):
"""
Parameters:
- links
- - dest
"""
- self.send_generateAndAddPackages(links, dest)
- return self.recv_generateAndAddPackages()
+ self.send_addToCollector(links)
+ self.recv_addToCollector()
- def send_generateAndAddPackages(self, links, dest):
- self._oprot.writeMessageBegin('generateAndAddPackages', TMessageType.CALL, self._seqid)
- args = generateAndAddPackages_args()
+ def send_addToCollector(self, links):
+ self._oprot.writeMessageBegin('addToCollector', TMessageType.CALL, self._seqid)
+ args = addToCollector_args()
args.links = links
- args.dest = dest
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_generateAndAddPackages(self, ):
+ def recv_addToCollector(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = generateAndAddPackages_result()
+ result = addToCollector_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "generateAndAddPackages failed: unknown result");
+ return
- def addPackage(self, name, links, dest, password):
+ def addFromCollector(self, name, paused):
"""
Parameters:
- name
- - links
- - dest
- - password
+ - paused
"""
- self.send_addPackage(name, links, dest, password)
- return self.recv_addPackage()
+ self.send_addFromCollector(name, paused)
+ return self.recv_addFromCollector()
- def send_addPackage(self, name, links, dest, password):
- self._oprot.writeMessageBegin('addPackage', TMessageType.CALL, self._seqid)
- args = addPackage_args()
+ def send_addFromCollector(self, name, paused):
+ self._oprot.writeMessageBegin('addFromCollector', TMessageType.CALL, self._seqid)
+ args = addFromCollector_args()
args.name = name
- args.links = links
- args.dest = dest
- args.password = password
+ args.paused = paused
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_addPackage(self, ):
+ def recv_addFromCollector(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = addPackage_result()
+ result = addFromCollector_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "addPackage failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "addFromCollector failed: unknown result");
- def addFiles(self, pid, links):
+ def renameCollPack(self, name, new_name):
"""
Parameters:
- - pid
- - links
+ - name
+ - new_name
"""
- self.send_addFiles(pid, links)
- self.recv_addFiles()
+ self.send_renameCollPack(name, new_name)
+ self.recv_renameCollPack()
- def send_addFiles(self, pid, links):
- self._oprot.writeMessageBegin('addFiles', TMessageType.CALL, self._seqid)
- args = addFiles_args()
- args.pid = pid
- args.links = links
+ def send_renameCollPack(self, name, new_name):
+ self._oprot.writeMessageBegin('renameCollPack', TMessageType.CALL, self._seqid)
+ args = renameCollPack_args()
+ args.name = name
+ args.new_name = new_name
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_addFiles(self, ):
+ def recv_renameCollPack(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = addFiles_result()
+ result = renameCollPack_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
return
- def uploadContainer(self, filename, data):
+ def deleteCollPack(self, name):
"""
Parameters:
- - filename
- - data
+ - name
"""
- self.send_uploadContainer(filename, data)
- self.recv_uploadContainer()
+ self.send_deleteCollPack(name)
+ self.recv_deleteCollPack()
- def send_uploadContainer(self, filename, data):
- self._oprot.writeMessageBegin('uploadContainer', TMessageType.CALL, self._seqid)
- args = uploadContainer_args()
- args.filename = filename
- args.data = data
+ def send_deleteCollPack(self, name):
+ self._oprot.writeMessageBegin('deleteCollPack', TMessageType.CALL, self._seqid)
+ args = deleteCollPack_args()
+ args.name = name
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_uploadContainer(self, ):
+ def recv_deleteCollPack(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = uploadContainer_result()
+ result = deleteCollPack_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
return
- def deleteFiles(self, fids):
+ def deleteCollLink(self, url):
"""
Parameters:
- - fids
+ - url
"""
- self.send_deleteFiles(fids)
- self.recv_deleteFiles()
+ self.send_deleteCollLink(url)
+ self.recv_deleteCollLink()
- def send_deleteFiles(self, fids):
- self._oprot.writeMessageBegin('deleteFiles', TMessageType.CALL, self._seqid)
- args = deleteFiles_args()
- args.fids = fids
+ def send_deleteCollLink(self, url):
+ self._oprot.writeMessageBegin('deleteCollLink', TMessageType.CALL, self._seqid)
+ args = deleteCollLink_args()
+ args.url = url
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_deleteFiles(self, ):
+ def recv_deleteCollLink(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = deleteFiles_result()
+ result = deleteCollLink_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
return
- def deletePackages(self, pids):
+ def getAllFiles(self, ):
+ self.send_getAllFiles()
+ return self.recv_getAllFiles()
+
+ def send_getAllFiles(self, ):
+ self._oprot.writeMessageBegin('getAllFiles', TMessageType.CALL, self._seqid)
+ args = getAllFiles_args()
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_getAllFiles(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = getAllFiles_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllFiles failed: unknown result");
+
+ def getAllUnfinishedFiles(self, ):
+ self.send_getAllUnfinishedFiles()
+ return self.recv_getAllUnfinishedFiles()
+
+ def send_getAllUnfinishedFiles(self, ):
+ self._oprot.writeMessageBegin('getAllUnfinishedFiles', TMessageType.CALL, self._seqid)
+ args = getAllUnfinishedFiles_args()
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_getAllUnfinishedFiles(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = getAllUnfinishedFiles_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getAllUnfinishedFiles failed: unknown result");
+
+ def getFileTree(self, pid, full):
"""
Parameters:
- - pids
+ - pid
+ - full
"""
- self.send_deletePackages(pids)
- self.recv_deletePackages()
+ self.send_getFileTree(pid, full)
+ return self.recv_getFileTree()
- def send_deletePackages(self, pids):
- self._oprot.writeMessageBegin('deletePackages', TMessageType.CALL, self._seqid)
- args = deletePackages_args()
- args.pids = pids
+ def send_getFileTree(self, pid, full):
+ self._oprot.writeMessageBegin('getFileTree', TMessageType.CALL, self._seqid)
+ args = getFileTree_args()
+ args.pid = pid
+ args.full = full
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_deletePackages(self, ):
+ def recv_getFileTree(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = deletePackages_result()
+ result = getFileTree_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
- return
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileTree failed: unknown result");
- def pushToQueue(self, pid):
+ def getUnfinishedFileTree(self, pid, full):
"""
Parameters:
- pid
+ - full
"""
- self.send_pushToQueue(pid)
- self.recv_pushToQueue()
+ self.send_getUnfinishedFileTree(pid, full)
+ return self.recv_getUnfinishedFileTree()
- def send_pushToQueue(self, pid):
- self._oprot.writeMessageBegin('pushToQueue', TMessageType.CALL, self._seqid)
- args = pushToQueue_args()
+ def send_getUnfinishedFileTree(self, pid, full):
+ self._oprot.writeMessageBegin('getUnfinishedFileTree', TMessageType.CALL, self._seqid)
+ args = getUnfinishedFileTree_args()
args.pid = pid
+ args.full = full
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_pushToQueue(self, ):
+ def recv_getUnfinishedFileTree(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = pushToQueue_result()
+ result = getUnfinishedFileTree_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
- return
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getUnfinishedFileTree failed: unknown result");
- def pullFromQueue(self, pid):
+ def getPackageContent(self, pid):
"""
Parameters:
- pid
"""
- self.send_pullFromQueue(pid)
- self.recv_pullFromQueue()
+ self.send_getPackageContent(pid)
+ return self.recv_getPackageContent()
- def send_pullFromQueue(self, pid):
- self._oprot.writeMessageBegin('pullFromQueue', TMessageType.CALL, self._seqid)
- args = pullFromQueue_args()
+ def send_getPackageContent(self, pid):
+ self._oprot.writeMessageBegin('getPackageContent', TMessageType.CALL, self._seqid)
+ args = getPackageContent_args()
args.pid = pid
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_pullFromQueue(self, ):
+ def recv_getPackageContent(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = pullFromQueue_result()
+ result = getPackageContent_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
- return
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageContent failed: unknown result");
+
+ def getPackageInfo(self, pid):
+ """
+ Parameters:
+ - pid
+ """
+ self.send_getPackageInfo(pid)
+ return self.recv_getPackageInfo()
+
+ def send_getPackageInfo(self, pid):
+ self._oprot.writeMessageBegin('getPackageInfo', TMessageType.CALL, self._seqid)
+ args = getPackageInfo_args()
+ args.pid = pid
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_getPackageInfo(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = getPackageInfo_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.e is not None:
+ raise result.e
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getPackageInfo failed: unknown result");
+
+ def getFileInfo(self, fid):
+ """
+ Parameters:
+ - fid
+ """
+ self.send_getFileInfo(fid)
+ return self.recv_getFileInfo()
+
+ def send_getFileInfo(self, fid):
+ self._oprot.writeMessageBegin('getFileInfo', TMessageType.CALL, self._seqid)
+ args = getFileInfo_args()
+ args.fid = fid
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_getFileInfo(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = getFileInfo_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.e is not None:
+ raise result.e
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getFileInfo failed: unknown result");
+
+ def findFiles(self, pattern):
+ """
+ Parameters:
+ - pattern
+ """
+ self.send_findFiles(pattern)
+ return self.recv_findFiles()
+
+ def send_findFiles(self, pattern):
+ self._oprot.writeMessageBegin('findFiles', TMessageType.CALL, self._seqid)
+ args = findFiles_args()
+ args.pattern = pattern
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_findFiles(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = findFiles_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "findFiles failed: unknown result");
def restartPackage(self, pid):
"""
@@ -1672,6 +2086,34 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
+ def stopDownloads(self, fids):
+ """
+ Parameters:
+ - fids
+ """
+ self.send_stopDownloads(fids)
+ self.recv_stopDownloads()
+
+ def send_stopDownloads(self, fids):
+ self._oprot.writeMessageBegin('stopDownloads', TMessageType.CALL, self._seqid)
+ args = stopDownloads_args()
+ args.fids = fids
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_stopDownloads(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = stopDownloads_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ return
+
def stopAllDownloads(self, ):
self.send_stopAllDownloads()
self.recv_stopAllDownloads()
@@ -1695,78 +2137,173 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
- def stopDownloads(self, fids):
+ def restartFailed(self, ):
+ self.send_restartFailed()
+ self.recv_restartFailed()
+
+ def send_restartFailed(self, ):
+ self._oprot.writeMessageBegin('restartFailed', TMessageType.CALL, self._seqid)
+ args = restartFailed_args()
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_restartFailed(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = restartFailed_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ return
+
+ def setFilePaused(self, fid, paused):
"""
Parameters:
- - fids
+ - fid
+ - paused
"""
- self.send_stopDownloads(fids)
- self.recv_stopDownloads()
+ self.send_setFilePaused(fid, paused)
+ self.recv_setFilePaused()
- def send_stopDownloads(self, fids):
- self._oprot.writeMessageBegin('stopDownloads', TMessageType.CALL, self._seqid)
- args = stopDownloads_args()
- args.fids = fids
+ def send_setFilePaused(self, fid, paused):
+ self._oprot.writeMessageBegin('setFilePaused', TMessageType.CALL, self._seqid)
+ args = setFilePaused_args()
+ args.fid = fid
+ args.paused = paused
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_stopDownloads(self, ):
+ def recv_setFilePaused(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = stopDownloads_result()
+ result = setFilePaused_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
+ if result.e is not None:
+ raise result.e
return
- def setPackageName(self, pid, name):
+ def setPackagePaused(self, pid, paused):
"""
Parameters:
- pid
- - name
+ - paused
"""
- self.send_setPackageName(pid, name)
- self.recv_setPackageName()
+ self.send_setPackagePaused(pid, paused)
+ self.recv_setPackagePaused()
- def send_setPackageName(self, pid, name):
- self._oprot.writeMessageBegin('setPackageName', TMessageType.CALL, self._seqid)
- args = setPackageName_args()
+ def send_setPackagePaused(self, pid, paused):
+ self._oprot.writeMessageBegin('setPackagePaused', TMessageType.CALL, self._seqid)
+ args = setPackagePaused_args()
args.pid = pid
- args.name = name
+ args.paused = paused
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_setPackagePaused(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = setPackagePaused_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.e is not None:
+ raise result.e
+ return
+
+ def setPackageFolder(self, pid, path):
+ """
+ Parameters:
+ - pid
+ - path
+ """
+ self.send_setPackageFolder(pid, path)
+ return self.recv_setPackageFolder()
+
+ def send_setPackageFolder(self, pid, path):
+ self._oprot.writeMessageBegin('setPackageFolder', TMessageType.CALL, self._seqid)
+ args = setPackageFolder_args()
+ args.pid = pid
+ args.path = path
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_setPackageFolder(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = setPackageFolder_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.e is not None:
+ raise result.e
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "setPackageFolder failed: unknown result");
+
+ def setPackageData(self, pid, data):
+ """
+ Parameters:
+ - pid
+ - data
+ """
+ self.send_setPackageData(pid, data)
+ self.recv_setPackageData()
+
+ def send_setPackageData(self, pid, data):
+ self._oprot.writeMessageBegin('setPackageData', TMessageType.CALL, self._seqid)
+ args = setPackageData_args()
+ args.pid = pid
+ args.data = data
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_setPackageName(self, ):
+ def recv_setPackageData(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = setPackageName_result()
+ result = setPackageData_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
+ if result.e is not None:
+ raise result.e
return
- def movePackage(self, destination, pid):
+ def movePackage(self, pid, root):
"""
Parameters:
- - destination
- pid
+ - root
"""
- self.send_movePackage(destination, pid)
- self.recv_movePackage()
+ self.send_movePackage(pid, root)
+ return self.recv_movePackage()
- def send_movePackage(self, destination, pid):
+ def send_movePackage(self, pid, root):
self._oprot.writeMessageBegin('movePackage', TMessageType.CALL, self._seqid)
args = movePackage_args()
- args.destination = destination
args.pid = pid
+ args.root = root
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
@@ -1781,7 +2318,11 @@ class Client(Iface):
result = movePackage_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
- return
+ if result.success is not None:
+ return result.success
+ if result.e is not None:
+ raise result.e
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "movePackage failed: unknown result");
def moveFiles(self, fids, pid):
"""
@@ -1790,7 +2331,7 @@ class Client(Iface):
- pid
"""
self.send_moveFiles(fids, pid)
- self.recv_moveFiles()
+ return self.recv_moveFiles()
def send_moveFiles(self, fids, pid):
self._oprot.writeMessageBegin('moveFiles', TMessageType.CALL, self._seqid)
@@ -1811,21 +2352,25 @@ class Client(Iface):
result = moveFiles_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
- return
+ if result.success is not None:
+ return result.success
+ if result.e is not None:
+ raise result.e
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "moveFiles failed: unknown result");
- def orderPackage(self, pid, position):
+ def orderPackage(self, pids, position):
"""
Parameters:
- - pid
+ - pids
- position
"""
- self.send_orderPackage(pid, position)
+ self.send_orderPackage(pids, position)
self.recv_orderPackage()
- def send_orderPackage(self, pid, position):
+ def send_orderPackage(self, pids, position):
self._oprot.writeMessageBegin('orderPackage', TMessageType.CALL, self._seqid)
args = orderPackage_args()
- args.pid = pid
+ args.pids = pids
args.position = position
args.write(self._oprot)
self._oprot.writeMessageEnd()
@@ -1843,112 +2388,213 @@ class Client(Iface):
self._iprot.readMessageEnd()
return
- def orderFile(self, fid, position):
+ def orderFiles(self, fids, pid, position):
"""
Parameters:
- - fid
+ - fids
+ - pid
- position
"""
- self.send_orderFile(fid, position)
- self.recv_orderFile()
+ self.send_orderFiles(fids, pid, position)
+ self.recv_orderFiles()
- def send_orderFile(self, fid, position):
- self._oprot.writeMessageBegin('orderFile', TMessageType.CALL, self._seqid)
- args = orderFile_args()
- args.fid = fid
+ def send_orderFiles(self, fids, pid, position):
+ self._oprot.writeMessageBegin('orderFiles', TMessageType.CALL, self._seqid)
+ args = orderFiles_args()
+ args.fids = fids
+ args.pid = pid
args.position = position
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_orderFile(self, ):
+ def recv_orderFiles(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = orderFile_result()
+ result = orderFiles_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
return
- def setPackageData(self, pid, data):
+ def isInteractionWaiting(self, mode):
"""
Parameters:
- - pid
- - data
+ - mode
"""
- self.send_setPackageData(pid, data)
- self.recv_setPackageData()
+ self.send_isInteractionWaiting(mode)
+ return self.recv_isInteractionWaiting()
- def send_setPackageData(self, pid, data):
- self._oprot.writeMessageBegin('setPackageData', TMessageType.CALL, self._seqid)
- args = setPackageData_args()
- args.pid = pid
- args.data = data
+ def send_isInteractionWaiting(self, mode):
+ self._oprot.writeMessageBegin('isInteractionWaiting', TMessageType.CALL, self._seqid)
+ args = isInteractionWaiting_args()
+ args.mode = mode
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_setPackageData(self, ):
+ def recv_isInteractionWaiting(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = setPackageData_result()
+ result = isInteractionWaiting_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "isInteractionWaiting failed: unknown result");
+
+ def getInteractionTask(self, mode):
+ """
+ Parameters:
+ - mode
+ """
+ self.send_getInteractionTask(mode)
+ return self.recv_getInteractionTask()
+
+ def send_getInteractionTask(self, mode):
+ self._oprot.writeMessageBegin('getInteractionTask', TMessageType.CALL, self._seqid)
+ args = getInteractionTask_args()
+ args.mode = mode
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_getInteractionTask(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = getInteractionTask_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getInteractionTask failed: unknown result");
+
+ def setInteractionResult(self, iid, result):
+ """
+ Parameters:
+ - iid
+ - result
+ """
+ self.send_setInteractionResult(iid, result)
+ self.recv_setInteractionResult()
+
+ def send_setInteractionResult(self, iid, result):
+ self._oprot.writeMessageBegin('setInteractionResult', TMessageType.CALL, self._seqid)
+ args = setInteractionResult_args()
+ args.iid = iid
+ args.result = result
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_setInteractionResult(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = setInteractionResult_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
- if result.e is not None:
- raise result.e
return
- def deleteFinished(self, ):
- self.send_deleteFinished()
- return self.recv_deleteFinished()
+ def generateDownloadLink(self, fid, timeout):
+ """
+ Parameters:
+ - fid
+ - timeout
+ """
+ self.send_generateDownloadLink(fid, timeout)
+ return self.recv_generateDownloadLink()
- def send_deleteFinished(self, ):
- self._oprot.writeMessageBegin('deleteFinished', TMessageType.CALL, self._seqid)
- args = deleteFinished_args()
+ def send_generateDownloadLink(self, fid, timeout):
+ self._oprot.writeMessageBegin('generateDownloadLink', TMessageType.CALL, self._seqid)
+ args = generateDownloadLink_args()
+ args.fid = fid
+ args.timeout = timeout
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_deleteFinished(self, ):
+ def recv_generateDownloadLink(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = deleteFinished_result()
+ result = generateDownloadLink_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
if result.success is not None:
return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "deleteFinished failed: unknown result");
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "generateDownloadLink failed: unknown result");
- def restartFailed(self, ):
- self.send_restartFailed()
- self.recv_restartFailed()
+ def getAddonHandler(self, ):
+ self.send_getAddonHandler()
+ return self.recv_getAddonHandler()
- def send_restartFailed(self, ):
- self._oprot.writeMessageBegin('restartFailed', TMessageType.CALL, self._seqid)
- args = restartFailed_args()
+ def send_getAddonHandler(self, ):
+ self._oprot.writeMessageBegin('getAddonHandler', TMessageType.CALL, self._seqid)
+ args = getAddonHandler_args()
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_restartFailed(self, ):
+ def recv_getAddonHandler(self, ):
(fname, mtype, rseqid) = self._iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
x.read(self._iprot)
self._iprot.readMessageEnd()
raise x
- result = restartFailed_result()
+ result = getAddonHandler_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "getAddonHandler failed: unknown result");
+
+ def callAddonHandler(self, plugin, func, pid_or_fid):
+ """
+ Parameters:
+ - plugin
+ - func
+ - pid_or_fid
+ """
+ self.send_callAddonHandler(plugin, func, pid_or_fid)
+ self.recv_callAddonHandler()
+
+ def send_callAddonHandler(self, plugin, func, pid_or_fid):
+ self._oprot.writeMessageBegin('callAddonHandler', TMessageType.CALL, self._seqid)
+ args = callAddonHandler_args()
+ args.plugin = plugin
+ args.func = func
+ args.pid_or_fid = pid_or_fid
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_callAddonHandler(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = callAddonHandler_result()
result.read(self._iprot)
self._iprot.readMessageEnd()
return
@@ -2250,18 +2896,22 @@ class Client(Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "hasService failed: unknown result");
- def call(self, info):
+ def call(self, plugin, func, arguments):
"""
Parameters:
- - info
+ - plugin
+ - func
+ - arguments
"""
- self.send_call(info)
+ self.send_call(plugin, func, arguments)
return self.recv_call()
- def send_call(self, info):
+ def send_call(self, plugin, func, arguments):
self._oprot.writeMessageBegin('call', TMessageType.CALL, self._seqid)
args = call_args()
- args.info = info
+ args.plugin = plugin
+ args.func = func
+ args.arguments = arguments
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
@@ -2339,180 +2989,81 @@ 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()
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_isCaptchaWaiting(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = isCaptchaWaiting_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "isCaptchaWaiting failed: unknown result");
-
- def getCaptchaTask(self, exclusive):
- """
- Parameters:
- - exclusive
- """
- self.send_getCaptchaTask(exclusive)
- return self.recv_getCaptchaTask()
-
- def send_getCaptchaTask(self, exclusive):
- self._oprot.writeMessageBegin('getCaptchaTask', TMessageType.CALL, self._seqid)
- args = getCaptchaTask_args()
- args.exclusive = exclusive
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_getCaptchaTask(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = getCaptchaTask_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getCaptchaTask failed: unknown result");
-
- def getCaptchaTaskStatus(self, tid):
- """
- Parameters:
- - tid
- """
- self.send_getCaptchaTaskStatus(tid)
- return self.recv_getCaptchaTaskStatus()
-
- def send_getCaptchaTaskStatus(self, tid):
- self._oprot.writeMessageBegin('getCaptchaTaskStatus', TMessageType.CALL, self._seqid)
- args = getCaptchaTaskStatus_args()
- args.tid = tid
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_getCaptchaTaskStatus(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = getCaptchaTaskStatus_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- raise TApplicationException(TApplicationException.MISSING_RESULT, "getCaptchaTaskStatus failed: unknown result");
-
- def setCaptchaResult(self, tid, result):
- """
- Parameters:
- - tid
- - result
- """
- 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()
- args.tid = tid
- args.result = result
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_setCaptchaResult(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
- raise x
- result = setCaptchaResult_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
- return
-
class Processor(Iface, TProcessor):
def __init__(self, handler):
self._handler = handler
self._processMap = {}
- self._processMap["getConfigValue"] = Processor.process_getConfigValue
- self._processMap["setConfigValue"] = Processor.process_setConfigValue
- self._processMap["getConfig"] = Processor.process_getConfig
- self._processMap["getPluginConfig"] = Processor.process_getPluginConfig
- self._processMap["configureSection"] = Processor.process_configureSection
+ self._processMap["getServerVersion"] = Processor.process_getServerVersion
+ self._processMap["statusServer"] = Processor.process_statusServer
self._processMap["pauseServer"] = Processor.process_pauseServer
self._processMap["unpauseServer"] = Processor.process_unpauseServer
self._processMap["togglePause"] = Processor.process_togglePause
- self._processMap["statusServer"] = Processor.process_statusServer
self._processMap["freeSpace"] = Processor.process_freeSpace
- self._processMap["getServerVersion"] = Processor.process_getServerVersion
self._processMap["kill"] = Processor.process_kill
self._processMap["restart"] = Processor.process_restart
self._processMap["getLog"] = Processor.process_getLog
self._processMap["isTimeDownload"] = Processor.process_isTimeDownload
self._processMap["isTimeReconnect"] = Processor.process_isTimeReconnect
self._processMap["toggleReconnect"] = Processor.process_toggleReconnect
- self._processMap["generatePackages"] = Processor.process_generatePackages
+ self._processMap["scanDownloadFolder"] = Processor.process_scanDownloadFolder
+ self._processMap["getProgressInfo"] = Processor.process_getProgressInfo
+ self._processMap["getConfigValue"] = Processor.process_getConfigValue
+ self._processMap["setConfigValue"] = Processor.process_setConfigValue
+ self._processMap["getConfig"] = Processor.process_getConfig
+ self._processMap["getPluginConfig"] = Processor.process_getPluginConfig
+ self._processMap["configureSection"] = Processor.process_configureSection
+ self._processMap["setConfigHandler"] = Processor.process_setConfigHandler
self._processMap["checkURLs"] = Processor.process_checkURLs
self._processMap["parseURLs"] = Processor.process_parseURLs
self._processMap["checkOnlineStatus"] = Processor.process_checkOnlineStatus
self._processMap["checkOnlineStatusContainer"] = Processor.process_checkOnlineStatusContainer
self._processMap["pollResults"] = Processor.process_pollResults
- self._processMap["statusDownloads"] = Processor.process_statusDownloads
- self._processMap["getPackageData"] = Processor.process_getPackageData
- self._processMap["getPackageInfo"] = Processor.process_getPackageInfo
- self._processMap["getFileData"] = Processor.process_getFileData
- self._processMap["getQueue"] = Processor.process_getQueue
- self._processMap["getCollector"] = Processor.process_getCollector
- self._processMap["getQueueData"] = Processor.process_getQueueData
- self._processMap["getCollectorData"] = Processor.process_getCollectorData
- self._processMap["getPackageOrder"] = Processor.process_getPackageOrder
- self._processMap["getFileOrder"] = Processor.process_getFileOrder
+ self._processMap["generatePackages"] = Processor.process_generatePackages
self._processMap["generateAndAddPackages"] = Processor.process_generateAndAddPackages
+ self._processMap["autoAddLinks"] = Processor.process_autoAddLinks
+ self._processMap["createPackage"] = Processor.process_createPackage
self._processMap["addPackage"] = Processor.process_addPackage
- self._processMap["addFiles"] = Processor.process_addFiles
+ self._processMap["addPackageP"] = Processor.process_addPackageP
+ self._processMap["addPackageChild"] = Processor.process_addPackageChild
self._processMap["uploadContainer"] = Processor.process_uploadContainer
+ self._processMap["addLinks"] = Processor.process_addLinks
self._processMap["deleteFiles"] = Processor.process_deleteFiles
self._processMap["deletePackages"] = Processor.process_deletePackages
- self._processMap["pushToQueue"] = Processor.process_pushToQueue
- self._processMap["pullFromQueue"] = Processor.process_pullFromQueue
+ self._processMap["getCollector"] = Processor.process_getCollector
+ self._processMap["addToCollector"] = Processor.process_addToCollector
+ self._processMap["addFromCollector"] = Processor.process_addFromCollector
+ self._processMap["renameCollPack"] = Processor.process_renameCollPack
+ self._processMap["deleteCollPack"] = Processor.process_deleteCollPack
+ self._processMap["deleteCollLink"] = Processor.process_deleteCollLink
+ self._processMap["getAllFiles"] = Processor.process_getAllFiles
+ self._processMap["getAllUnfinishedFiles"] = Processor.process_getAllUnfinishedFiles
+ self._processMap["getFileTree"] = Processor.process_getFileTree
+ self._processMap["getUnfinishedFileTree"] = Processor.process_getUnfinishedFileTree
+ self._processMap["getPackageContent"] = Processor.process_getPackageContent
+ self._processMap["getPackageInfo"] = Processor.process_getPackageInfo
+ self._processMap["getFileInfo"] = Processor.process_getFileInfo
+ self._processMap["findFiles"] = Processor.process_findFiles
self._processMap["restartPackage"] = Processor.process_restartPackage
self._processMap["restartFile"] = Processor.process_restartFile
self._processMap["recheckPackage"] = Processor.process_recheckPackage
- self._processMap["stopAllDownloads"] = Processor.process_stopAllDownloads
self._processMap["stopDownloads"] = Processor.process_stopDownloads
- self._processMap["setPackageName"] = Processor.process_setPackageName
+ self._processMap["stopAllDownloads"] = Processor.process_stopAllDownloads
+ self._processMap["restartFailed"] = Processor.process_restartFailed
+ self._processMap["setFilePaused"] = Processor.process_setFilePaused
+ self._processMap["setPackagePaused"] = Processor.process_setPackagePaused
+ self._processMap["setPackageFolder"] = Processor.process_setPackageFolder
+ self._processMap["setPackageData"] = Processor.process_setPackageData
self._processMap["movePackage"] = Processor.process_movePackage
self._processMap["moveFiles"] = Processor.process_moveFiles
self._processMap["orderPackage"] = Processor.process_orderPackage
- self._processMap["orderFile"] = Processor.process_orderFile
- self._processMap["setPackageData"] = Processor.process_setPackageData
- self._processMap["deleteFinished"] = Processor.process_deleteFinished
- self._processMap["restartFailed"] = Processor.process_restartFailed
+ self._processMap["orderFiles"] = Processor.process_orderFiles
+ self._processMap["isInteractionWaiting"] = Processor.process_isInteractionWaiting
+ self._processMap["getInteractionTask"] = Processor.process_getInteractionTask
+ self._processMap["setInteractionResult"] = Processor.process_setInteractionResult
+ self._processMap["generateDownloadLink"] = Processor.process_generateDownloadLink
+ self._processMap["getAddonHandler"] = Processor.process_getAddonHandler
+ self._processMap["callAddonHandler"] = Processor.process_callAddonHandler
self._processMap["getEvents"] = Processor.process_getEvents
self._processMap["getAccounts"] = Processor.process_getAccounts
self._processMap["getAccountTypes"] = Processor.process_getAccountTypes
@@ -2526,10 +3077,6 @@ class Processor(Iface, TProcessor):
self._processMap["call"] = Processor.process_call
self._processMap["getAllInfo"] = Processor.process_getAllInfo
self._processMap["getInfoByPlugin"] = Processor.process_getInfoByPlugin
- self._processMap["isCaptchaWaiting"] = Processor.process_isCaptchaWaiting
- self._processMap["getCaptchaTask"] = Processor.process_getCaptchaTask
- self._processMap["getCaptchaTaskStatus"] = Processor.process_getCaptchaTaskStatus
- self._processMap["setCaptchaResult"] = Processor.process_setCaptchaResult
def process(self, iprot, oprot):
(name, type, seqid) = iprot.readMessageBegin()
@@ -2546,57 +3093,24 @@ class Processor(Iface, TProcessor):
self._processMap[name](self, seqid, iprot, oprot)
return True
- def process_getConfigValue(self, seqid, iprot, oprot):
- args = getConfigValue_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = getConfigValue_result()
- result.success = self._handler.getConfigValue(args.section, args.option)
- oprot.writeMessageBegin("getConfigValue", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_setConfigValue(self, seqid, iprot, oprot):
- args = setConfigValue_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = setConfigValue_result()
- self._handler.setConfigValue(args.section, args.option, args.value)
- oprot.writeMessageBegin("setConfigValue", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_getConfig(self, seqid, iprot, oprot):
- args = getConfig_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = getConfig_result()
- result.success = self._handler.getConfig()
- oprot.writeMessageBegin("getConfig", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_getPluginConfig(self, seqid, iprot, oprot):
- args = getPluginConfig_args()
+ def process_getServerVersion(self, seqid, iprot, oprot):
+ args = getServerVersion_args()
args.read(iprot)
iprot.readMessageEnd()
- result = getPluginConfig_result()
- result.success = self._handler.getPluginConfig()
- oprot.writeMessageBegin("getPluginConfig", TMessageType.REPLY, seqid)
+ result = getServerVersion_result()
+ result.success = self._handler.getServerVersion()
+ oprot.writeMessageBegin("getServerVersion", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_configureSection(self, seqid, iprot, oprot):
- args = configureSection_args()
+ def process_statusServer(self, seqid, iprot, oprot):
+ args = statusServer_args()
args.read(iprot)
iprot.readMessageEnd()
- result = configureSection_result()
- result.success = self._handler.configureSection(args.section)
- oprot.writeMessageBegin("configureSection", TMessageType.REPLY, seqid)
+ result = statusServer_result()
+ result.success = self._handler.statusServer()
+ oprot.writeMessageBegin("statusServer", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -2634,17 +3148,6 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_statusServer(self, seqid, iprot, oprot):
- args = statusServer_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = statusServer_result()
- result.success = self._handler.statusServer()
- oprot.writeMessageBegin("statusServer", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
def process_freeSpace(self, seqid, iprot, oprot):
args = freeSpace_args()
args.read(iprot)
@@ -2656,17 +3159,6 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_getServerVersion(self, seqid, iprot, oprot):
- args = getServerVersion_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = getServerVersion_result()
- result.success = self._handler.getServerVersion()
- oprot.writeMessageBegin("getServerVersion", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
def process_kill(self, seqid, iprot, oprot):
args = kill_args()
args.read(iprot)
@@ -2733,13 +3225,90 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_generatePackages(self, seqid, iprot, oprot):
- args = generatePackages_args()
+ def process_scanDownloadFolder(self, seqid, iprot, oprot):
+ args = scanDownloadFolder_args()
args.read(iprot)
iprot.readMessageEnd()
- result = generatePackages_result()
- result.success = self._handler.generatePackages(args.links)
- oprot.writeMessageBegin("generatePackages", TMessageType.REPLY, seqid)
+ result = scanDownloadFolder_result()
+ self._handler.scanDownloadFolder()
+ oprot.writeMessageBegin("scanDownloadFolder", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_getProgressInfo(self, seqid, iprot, oprot):
+ args = getProgressInfo_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = getProgressInfo_result()
+ result.success = self._handler.getProgressInfo()
+ oprot.writeMessageBegin("getProgressInfo", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_getConfigValue(self, seqid, iprot, oprot):
+ args = getConfigValue_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = getConfigValue_result()
+ result.success = self._handler.getConfigValue(args.section, args.option)
+ oprot.writeMessageBegin("getConfigValue", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_setConfigValue(self, seqid, iprot, oprot):
+ args = setConfigValue_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = setConfigValue_result()
+ self._handler.setConfigValue(args.section, args.option, args.value)
+ oprot.writeMessageBegin("setConfigValue", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_getConfig(self, seqid, iprot, oprot):
+ args = getConfig_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = getConfig_result()
+ result.success = self._handler.getConfig()
+ oprot.writeMessageBegin("getConfig", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_getPluginConfig(self, seqid, iprot, oprot):
+ args = getPluginConfig_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = getPluginConfig_result()
+ result.success = self._handler.getPluginConfig()
+ oprot.writeMessageBegin("getPluginConfig", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_configureSection(self, seqid, iprot, oprot):
+ args = configureSection_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = configureSection_result()
+ result.success = self._handler.configureSection(args.section)
+ oprot.writeMessageBegin("configureSection", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_setConfigHandler(self, seqid, iprot, oprot):
+ args = setConfigHandler_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = setConfigHandler_result()
+ self._handler.setConfigHandler(args.plugin, args.iid, args.value)
+ oprot.writeMessageBegin("setConfigHandler", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -2799,66 +3368,126 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_statusDownloads(self, seqid, iprot, oprot):
- args = statusDownloads_args()
+ def process_generatePackages(self, seqid, iprot, oprot):
+ args = generatePackages_args()
args.read(iprot)
iprot.readMessageEnd()
- result = statusDownloads_result()
- result.success = self._handler.statusDownloads()
- oprot.writeMessageBegin("statusDownloads", TMessageType.REPLY, seqid)
+ result = generatePackages_result()
+ result.success = self._handler.generatePackages(args.links)
+ oprot.writeMessageBegin("generatePackages", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_getPackageData(self, seqid, iprot, oprot):
- args = getPackageData_args()
+ def process_generateAndAddPackages(self, seqid, iprot, oprot):
+ args = generateAndAddPackages_args()
args.read(iprot)
iprot.readMessageEnd()
- result = getPackageData_result()
- try:
- result.success = self._handler.getPackageData(args.pid)
- except PackageDoesNotExists, e:
- result.e = e
- oprot.writeMessageBegin("getPackageData", TMessageType.REPLY, seqid)
+ result = generateAndAddPackages_result()
+ result.success = self._handler.generateAndAddPackages(args.links, args.paused)
+ oprot.writeMessageBegin("generateAndAddPackages", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_getPackageInfo(self, seqid, iprot, oprot):
- args = getPackageInfo_args()
+ def process_autoAddLinks(self, seqid, iprot, oprot):
+ args = autoAddLinks_args()
args.read(iprot)
iprot.readMessageEnd()
- result = getPackageInfo_result()
+ result = autoAddLinks_result()
+ result.success = self._handler.autoAddLinks(args.links)
+ oprot.writeMessageBegin("autoAddLinks", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_createPackage(self, seqid, iprot, oprot):
+ args = createPackage_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = createPackage_result()
+ result.success = self._handler.createPackage(args.name, args.folder, args.root, args.password, args.site, args.comment, args.paused)
+ oprot.writeMessageBegin("createPackage", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_addPackage(self, seqid, iprot, oprot):
+ args = addPackage_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = addPackage_result()
+ result.success = self._handler.addPackage(args.name, args.links, args.password)
+ oprot.writeMessageBegin("addPackage", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_addPackageP(self, seqid, iprot, oprot):
+ args = addPackageP_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = addPackageP_result()
+ result.success = self._handler.addPackageP(args.name, args.links, args.password, args.paused)
+ oprot.writeMessageBegin("addPackageP", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_addPackageChild(self, seqid, iprot, oprot):
+ args = addPackageChild_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = addPackageChild_result()
+ result.success = self._handler.addPackageChild(args.name, args.links, args.password, args.root, args.paused)
+ oprot.writeMessageBegin("addPackageChild", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_uploadContainer(self, seqid, iprot, oprot):
+ args = uploadContainer_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = uploadContainer_result()
+ result.success = self._handler.uploadContainer(args.filename, args.data)
+ oprot.writeMessageBegin("uploadContainer", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_addLinks(self, seqid, iprot, oprot):
+ args = addLinks_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = addLinks_result()
try:
- result.success = self._handler.getPackageInfo(args.pid)
+ self._handler.addLinks(args.pid, args.links)
except PackageDoesNotExists, e:
result.e = e
- oprot.writeMessageBegin("getPackageInfo", TMessageType.REPLY, seqid)
+ oprot.writeMessageBegin("addLinks", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_getFileData(self, seqid, iprot, oprot):
- args = getFileData_args()
+ def process_deleteFiles(self, seqid, iprot, oprot):
+ args = deleteFiles_args()
args.read(iprot)
iprot.readMessageEnd()
- result = getFileData_result()
- try:
- result.success = self._handler.getFileData(args.fid)
- except FileDoesNotExists, e:
- result.e = e
- oprot.writeMessageBegin("getFileData", TMessageType.REPLY, seqid)
+ result = deleteFiles_result()
+ self._handler.deleteFiles(args.fids)
+ oprot.writeMessageBegin("deleteFiles", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_getQueue(self, seqid, iprot, oprot):
- args = getQueue_args()
+ def process_deletePackages(self, seqid, iprot, oprot):
+ args = deletePackages_args()
args.read(iprot)
iprot.readMessageEnd()
- result = getQueue_result()
- result.success = self._handler.getQueue()
- oprot.writeMessageBegin("getQueue", TMessageType.REPLY, seqid)
+ result = deletePackages_result()
+ self._handler.deletePackages(args.pids)
+ oprot.writeMessageBegin("deletePackages", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -2874,134 +3503,151 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_getQueueData(self, seqid, iprot, oprot):
- args = getQueueData_args()
+ def process_addToCollector(self, seqid, iprot, oprot):
+ args = addToCollector_args()
args.read(iprot)
iprot.readMessageEnd()
- result = getQueueData_result()
- result.success = self._handler.getQueueData()
- oprot.writeMessageBegin("getQueueData", TMessageType.REPLY, seqid)
+ result = addToCollector_result()
+ self._handler.addToCollector(args.links)
+ oprot.writeMessageBegin("addToCollector", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_getCollectorData(self, seqid, iprot, oprot):
- args = getCollectorData_args()
+ def process_addFromCollector(self, seqid, iprot, oprot):
+ args = addFromCollector_args()
args.read(iprot)
iprot.readMessageEnd()
- result = getCollectorData_result()
- result.success = self._handler.getCollectorData()
- oprot.writeMessageBegin("getCollectorData", TMessageType.REPLY, seqid)
+ result = addFromCollector_result()
+ result.success = self._handler.addFromCollector(args.name, args.paused)
+ oprot.writeMessageBegin("addFromCollector", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_getPackageOrder(self, seqid, iprot, oprot):
- args = getPackageOrder_args()
+ def process_renameCollPack(self, seqid, iprot, oprot):
+ args = renameCollPack_args()
args.read(iprot)
iprot.readMessageEnd()
- result = getPackageOrder_result()
- result.success = self._handler.getPackageOrder(args.destination)
- oprot.writeMessageBegin("getPackageOrder", TMessageType.REPLY, seqid)
+ result = renameCollPack_result()
+ self._handler.renameCollPack(args.name, args.new_name)
+ oprot.writeMessageBegin("renameCollPack", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_getFileOrder(self, seqid, iprot, oprot):
- args = getFileOrder_args()
+ def process_deleteCollPack(self, seqid, iprot, oprot):
+ args = deleteCollPack_args()
args.read(iprot)
iprot.readMessageEnd()
- result = getFileOrder_result()
- result.success = self._handler.getFileOrder(args.pid)
- oprot.writeMessageBegin("getFileOrder", TMessageType.REPLY, seqid)
+ result = deleteCollPack_result()
+ self._handler.deleteCollPack(args.name)
+ oprot.writeMessageBegin("deleteCollPack", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_generateAndAddPackages(self, seqid, iprot, oprot):
- args = generateAndAddPackages_args()
+ def process_deleteCollLink(self, seqid, iprot, oprot):
+ args = deleteCollLink_args()
args.read(iprot)
iprot.readMessageEnd()
- result = generateAndAddPackages_result()
- result.success = self._handler.generateAndAddPackages(args.links, args.dest)
- oprot.writeMessageBegin("generateAndAddPackages", TMessageType.REPLY, seqid)
+ result = deleteCollLink_result()
+ self._handler.deleteCollLink(args.url)
+ oprot.writeMessageBegin("deleteCollLink", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_addPackage(self, seqid, iprot, oprot):
- args = addPackage_args()
+ def process_getAllFiles(self, seqid, iprot, oprot):
+ args = getAllFiles_args()
args.read(iprot)
iprot.readMessageEnd()
- result = addPackage_result()
- result.success = self._handler.addPackage(args.name, args.links, args.dest, args.password)
- oprot.writeMessageBegin("addPackage", TMessageType.REPLY, seqid)
+ result = getAllFiles_result()
+ result.success = self._handler.getAllFiles()
+ oprot.writeMessageBegin("getAllFiles", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_addFiles(self, seqid, iprot, oprot):
- args = addFiles_args()
+ def process_getAllUnfinishedFiles(self, seqid, iprot, oprot):
+ args = getAllUnfinishedFiles_args()
args.read(iprot)
iprot.readMessageEnd()
- result = addFiles_result()
- self._handler.addFiles(args.pid, args.links)
- oprot.writeMessageBegin("addFiles", TMessageType.REPLY, seqid)
+ result = getAllUnfinishedFiles_result()
+ result.success = self._handler.getAllUnfinishedFiles()
+ oprot.writeMessageBegin("getAllUnfinishedFiles", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_uploadContainer(self, seqid, iprot, oprot):
- args = uploadContainer_args()
+ def process_getFileTree(self, seqid, iprot, oprot):
+ args = getFileTree_args()
args.read(iprot)
iprot.readMessageEnd()
- result = uploadContainer_result()
- self._handler.uploadContainer(args.filename, args.data)
- oprot.writeMessageBegin("uploadContainer", TMessageType.REPLY, seqid)
+ result = getFileTree_result()
+ result.success = self._handler.getFileTree(args.pid, args.full)
+ oprot.writeMessageBegin("getFileTree", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_deleteFiles(self, seqid, iprot, oprot):
- args = deleteFiles_args()
+ def process_getUnfinishedFileTree(self, seqid, iprot, oprot):
+ args = getUnfinishedFileTree_args()
args.read(iprot)
iprot.readMessageEnd()
- result = deleteFiles_result()
- self._handler.deleteFiles(args.fids)
- oprot.writeMessageBegin("deleteFiles", TMessageType.REPLY, seqid)
+ result = getUnfinishedFileTree_result()
+ result.success = self._handler.getUnfinishedFileTree(args.pid, args.full)
+ oprot.writeMessageBegin("getUnfinishedFileTree", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_deletePackages(self, seqid, iprot, oprot):
- args = deletePackages_args()
+ def process_getPackageContent(self, seqid, iprot, oprot):
+ args = getPackageContent_args()
args.read(iprot)
iprot.readMessageEnd()
- result = deletePackages_result()
- self._handler.deletePackages(args.pids)
- oprot.writeMessageBegin("deletePackages", TMessageType.REPLY, seqid)
+ result = getPackageContent_result()
+ result.success = self._handler.getPackageContent(args.pid)
+ oprot.writeMessageBegin("getPackageContent", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_pushToQueue(self, seqid, iprot, oprot):
- args = pushToQueue_args()
+ def process_getPackageInfo(self, seqid, iprot, oprot):
+ args = getPackageInfo_args()
args.read(iprot)
iprot.readMessageEnd()
- result = pushToQueue_result()
- self._handler.pushToQueue(args.pid)
- oprot.writeMessageBegin("pushToQueue", TMessageType.REPLY, seqid)
+ result = getPackageInfo_result()
+ try:
+ result.success = self._handler.getPackageInfo(args.pid)
+ except PackageDoesNotExists, e:
+ result.e = e
+ oprot.writeMessageBegin("getPackageInfo", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_pullFromQueue(self, seqid, iprot, oprot):
- args = pullFromQueue_args()
+ def process_getFileInfo(self, seqid, iprot, oprot):
+ args = getFileInfo_args()
args.read(iprot)
iprot.readMessageEnd()
- result = pullFromQueue_result()
- self._handler.pullFromQueue(args.pid)
- oprot.writeMessageBegin("pullFromQueue", TMessageType.REPLY, seqid)
+ result = getFileInfo_result()
+ try:
+ result.success = self._handler.getFileInfo(args.fid)
+ except FileDoesNotExists, e:
+ result.e = e
+ oprot.writeMessageBegin("getFileInfo", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_findFiles(self, seqid, iprot, oprot):
+ args = findFiles_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = findFiles_result()
+ result.success = self._handler.findFiles(args.pattern)
+ oprot.writeMessageBegin("findFiles", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -3039,6 +3685,17 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_stopDownloads(self, seqid, iprot, oprot):
+ args = stopDownloads_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = stopDownloads_result()
+ self._handler.stopDownloads(args.fids)
+ oprot.writeMessageBegin("stopDownloads", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_stopAllDownloads(self, seqid, iprot, oprot):
args = stopAllDownloads_args()
args.read(iprot)
@@ -3050,24 +3707,69 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_stopDownloads(self, seqid, iprot, oprot):
- args = stopDownloads_args()
+ def process_restartFailed(self, seqid, iprot, oprot):
+ args = restartFailed_args()
args.read(iprot)
iprot.readMessageEnd()
- result = stopDownloads_result()
- self._handler.stopDownloads(args.fids)
- oprot.writeMessageBegin("stopDownloads", TMessageType.REPLY, seqid)
+ result = restartFailed_result()
+ self._handler.restartFailed()
+ oprot.writeMessageBegin("restartFailed", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_setFilePaused(self, seqid, iprot, oprot):
+ args = setFilePaused_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = setFilePaused_result()
+ try:
+ self._handler.setFilePaused(args.fid, args.paused)
+ except FileDoesNotExists, e:
+ result.e = e
+ oprot.writeMessageBegin("setFilePaused", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_setPackagePaused(self, seqid, iprot, oprot):
+ args = setPackagePaused_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = setPackagePaused_result()
+ try:
+ self._handler.setPackagePaused(args.pid, args.paused)
+ except PackageDoesNotExists, e:
+ result.e = e
+ oprot.writeMessageBegin("setPackagePaused", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_setPackageFolder(self, seqid, iprot, oprot):
+ args = setPackageFolder_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = setPackageFolder_result()
+ try:
+ result.success = self._handler.setPackageFolder(args.pid, args.path)
+ except PackageDoesNotExists, e:
+ result.e = e
+ oprot.writeMessageBegin("setPackageFolder", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_setPackageName(self, seqid, iprot, oprot):
- args = setPackageName_args()
+ def process_setPackageData(self, seqid, iprot, oprot):
+ args = setPackageData_args()
args.read(iprot)
iprot.readMessageEnd()
- result = setPackageName_result()
- self._handler.setPackageName(args.pid, args.name)
- oprot.writeMessageBegin("setPackageName", TMessageType.REPLY, seqid)
+ result = setPackageData_result()
+ try:
+ self._handler.setPackageData(args.pid, args.data)
+ except PackageDoesNotExists, e:
+ result.e = e
+ oprot.writeMessageBegin("setPackageData", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -3077,7 +3779,10 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = movePackage_result()
- self._handler.movePackage(args.destination, args.pid)
+ try:
+ result.success = self._handler.movePackage(args.pid, args.root)
+ except PackageDoesNotExists, e:
+ result.e = e
oprot.writeMessageBegin("movePackage", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
@@ -3088,7 +3793,10 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = moveFiles_result()
- self._handler.moveFiles(args.fids, args.pid)
+ try:
+ result.success = self._handler.moveFiles(args.fids, args.pid)
+ except PackageDoesNotExists, e:
+ result.e = e
oprot.writeMessageBegin("moveFiles", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
@@ -3099,55 +3807,85 @@ class Processor(Iface, TProcessor):
args.read(iprot)
iprot.readMessageEnd()
result = orderPackage_result()
- self._handler.orderPackage(args.pid, args.position)
+ self._handler.orderPackage(args.pids, args.position)
oprot.writeMessageBegin("orderPackage", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_orderFile(self, seqid, iprot, oprot):
- args = orderFile_args()
+ def process_orderFiles(self, seqid, iprot, oprot):
+ args = orderFiles_args()
args.read(iprot)
iprot.readMessageEnd()
- result = orderFile_result()
- self._handler.orderFile(args.fid, args.position)
- oprot.writeMessageBegin("orderFile", TMessageType.REPLY, seqid)
+ result = orderFiles_result()
+ self._handler.orderFiles(args.fids, args.pid, args.position)
+ oprot.writeMessageBegin("orderFiles", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_setPackageData(self, seqid, iprot, oprot):
- args = setPackageData_args()
+ def process_isInteractionWaiting(self, seqid, iprot, oprot):
+ args = isInteractionWaiting_args()
args.read(iprot)
iprot.readMessageEnd()
- result = setPackageData_result()
- try:
- self._handler.setPackageData(args.pid, args.data)
- except PackageDoesNotExists, e:
- result.e = e
- oprot.writeMessageBegin("setPackageData", TMessageType.REPLY, seqid)
+ result = isInteractionWaiting_result()
+ result.success = self._handler.isInteractionWaiting(args.mode)
+ oprot.writeMessageBegin("isInteractionWaiting", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_deleteFinished(self, seqid, iprot, oprot):
- args = deleteFinished_args()
+ def process_getInteractionTask(self, seqid, iprot, oprot):
+ args = getInteractionTask_args()
args.read(iprot)
iprot.readMessageEnd()
- result = deleteFinished_result()
- result.success = self._handler.deleteFinished()
- oprot.writeMessageBegin("deleteFinished", TMessageType.REPLY, seqid)
+ result = getInteractionTask_result()
+ result.success = self._handler.getInteractionTask(args.mode)
+ oprot.writeMessageBegin("getInteractionTask", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_restartFailed(self, seqid, iprot, oprot):
- args = restartFailed_args()
+ def process_setInteractionResult(self, seqid, iprot, oprot):
+ args = setInteractionResult_args()
args.read(iprot)
iprot.readMessageEnd()
- result = restartFailed_result()
- self._handler.restartFailed()
- oprot.writeMessageBegin("restartFailed", TMessageType.REPLY, seqid)
+ result = setInteractionResult_result()
+ self._handler.setInteractionResult(args.iid, args.result)
+ oprot.writeMessageBegin("setInteractionResult", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_generateDownloadLink(self, seqid, iprot, oprot):
+ args = generateDownloadLink_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = generateDownloadLink_result()
+ result.success = self._handler.generateDownloadLink(args.fid, args.timeout)
+ oprot.writeMessageBegin("generateDownloadLink", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_getAddonHandler(self, seqid, iprot, oprot):
+ args = getAddonHandler_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = getAddonHandler_result()
+ result.success = self._handler.getAddonHandler()
+ oprot.writeMessageBegin("getAddonHandler", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_callAddonHandler(self, seqid, iprot, oprot):
+ args = callAddonHandler_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = callAddonHandler_result()
+ self._handler.callAddonHandler(args.plugin, args.func, args.pid_or_fid)
+ oprot.writeMessageBegin("callAddonHandler", TMessageType.REPLY, seqid)
result.write(oprot)
oprot.writeMessageEnd()
oprot.trans.flush()
@@ -3271,7 +4009,7 @@ class Processor(Iface, TProcessor):
iprot.readMessageEnd()
result = call_result()
try:
- result.success = self._handler.call(args.info)
+ result.success = self._handler.call(args.plugin, args.func, args.arguments)
except ServiceDoesNotExists, ex:
result.ex = ex
except ServiceException, e:
@@ -3303,77 +4041,46 @@ class Processor(Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_isCaptchaWaiting(self, seqid, iprot, oprot):
- args = isCaptchaWaiting_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = isCaptchaWaiting_result()
- result.success = self._handler.isCaptchaWaiting()
- oprot.writeMessageBegin("isCaptchaWaiting", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
- def process_getCaptchaTask(self, seqid, iprot, oprot):
- args = getCaptchaTask_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = getCaptchaTask_result()
- result.success = self._handler.getCaptchaTask(args.exclusive)
- oprot.writeMessageBegin("getCaptchaTask", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
+# HELPER FUNCTIONS AND STRUCTURES
- def process_getCaptchaTaskStatus(self, seqid, iprot, oprot):
- args = getCaptchaTaskStatus_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = getCaptchaTaskStatus_result()
- result.success = self._handler.getCaptchaTaskStatus(args.tid)
- oprot.writeMessageBegin("getCaptchaTaskStatus", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
+class getServerVersion_args(TBase):
- def process_setCaptchaResult(self, seqid, iprot, oprot):
- args = setCaptchaResult_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = setCaptchaResult_result()
- self._handler.setCaptchaResult(args.tid, args.result)
- oprot.writeMessageBegin("setCaptchaResult", TMessageType.REPLY, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
+ __slots__ = [
+ ]
+ thrift_spec = (
+ )
-# HELPER FUNCTIONS AND STRUCTURES
-class getConfigValue_args(TBase):
+class getServerVersion_result(TBase):
"""
Attributes:
- - section
- - option
+ - success
"""
__slots__ = [
- 'section',
- 'option',
+ 'success',
]
thrift_spec = (
- None, # 0
- (1, TType.STRING, 'section', None, None, ), # 1
- (2, TType.STRING, 'option', None, None, ), # 2
+ (0, TType.STRING, 'success', None, None, ), # 0
)
- def __init__(self, section=None, option=None,):
- self.section = section
- self.option = option
+ def __init__(self, success=None,):
+ self.success = success
-class getConfigValue_result(TBase):
+class statusServer_args(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
+
+
+class statusServer_result(TBase):
"""
Attributes:
- success
@@ -3384,41 +4091,23 @@ class getConfigValue_result(TBase):
]
thrift_spec = (
- (0, TType.STRING, 'success', None, None, ), # 0
+ (0, TType.STRUCT, 'success', (ServerStatus, ServerStatus.thrift_spec), None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class setConfigValue_args(TBase):
- """
- Attributes:
- - section
- - option
- - value
- """
+class pauseServer_args(TBase):
__slots__ = [
- 'section',
- 'option',
- 'value',
]
thrift_spec = (
- None, # 0
- (1, TType.STRING, 'section', None, None, ), # 1
- (2, TType.STRING, 'option', None, None, ), # 2
- (3, TType.STRING, 'value', None, None, ), # 3
)
- def __init__(self, section=None, option=None, value=None,):
- self.section = section
- self.option = option
- self.value = value
-
-class setConfigValue_result(TBase):
+class pauseServer_result(TBase):
__slots__ = [
]
@@ -3427,7 +4116,7 @@ class setConfigValue_result(TBase):
)
-class getConfig_args(TBase):
+class unpauseServer_args(TBase):
__slots__ = [
]
@@ -3436,25 +4125,16 @@ class getConfig_args(TBase):
)
-class getConfig_result(TBase):
- """
- Attributes:
- - success
- """
+class unpauseServer_result(TBase):
__slots__ = [
- 'success',
]
thrift_spec = (
- (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(ConfigSection, ConfigSection.thrift_spec)), None, ), # 0
)
- def __init__(self, success=None,):
- self.success = success
-
-class getPluginConfig_args(TBase):
+class togglePause_args(TBase):
__slots__ = [
]
@@ -3463,7 +4143,7 @@ class getPluginConfig_args(TBase):
)
-class getPluginConfig_result(TBase):
+class togglePause_result(TBase):
"""
Attributes:
- success
@@ -3474,33 +4154,23 @@ class getPluginConfig_result(TBase):
]
thrift_spec = (
- (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(ConfigSection, ConfigSection.thrift_spec)), None, ), # 0
+ (0, TType.BOOL, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class configureSection_args(TBase):
- """
- Attributes:
- - section
- """
+class freeSpace_args(TBase):
__slots__ = [
- 'section',
]
thrift_spec = (
- None, # 0
- (1, TType.STRING, 'section', None, None, ), # 1
)
- def __init__(self, section=None,):
- self.section = section
-
-class configureSection_result(TBase):
+class freeSpace_result(TBase):
"""
Attributes:
- success
@@ -3511,14 +4181,14 @@ class configureSection_result(TBase):
]
thrift_spec = (
- (0, TType.STRUCT, 'success', (ConfigSection, ConfigSection.thrift_spec), None, ), # 0
+ (0, TType.I64, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class pauseServer_args(TBase):
+class kill_args(TBase):
__slots__ = [
]
@@ -3527,7 +4197,7 @@ class pauseServer_args(TBase):
)
-class pauseServer_result(TBase):
+class kill_result(TBase):
__slots__ = [
]
@@ -3536,7 +4206,7 @@ class pauseServer_result(TBase):
)
-class unpauseServer_args(TBase):
+class restart_args(TBase):
__slots__ = [
]
@@ -3545,7 +4215,7 @@ class unpauseServer_args(TBase):
)
-class unpauseServer_result(TBase):
+class restart_result(TBase):
__slots__ = [
]
@@ -3554,16 +4224,26 @@ class unpauseServer_result(TBase):
)
-class togglePause_args(TBase):
+class getLog_args(TBase):
+ """
+ Attributes:
+ - offset
+ """
__slots__ = [
+ 'offset',
]
thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'offset', None, None, ), # 1
)
+ def __init__(self, offset=None,):
+ self.offset = offset
-class togglePause_result(TBase):
+
+class getLog_result(TBase):
"""
Attributes:
- success
@@ -3574,14 +4254,14 @@ class togglePause_result(TBase):
]
thrift_spec = (
- (0, TType.BOOL, 'success', None, None, ), # 0
+ (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class statusServer_args(TBase):
+class isTimeDownload_args(TBase):
__slots__ = [
]
@@ -3590,7 +4270,7 @@ class statusServer_args(TBase):
)
-class statusServer_result(TBase):
+class isTimeDownload_result(TBase):
"""
Attributes:
- success
@@ -3601,14 +4281,14 @@ class statusServer_result(TBase):
]
thrift_spec = (
- (0, TType.STRUCT, 'success', (ServerStatus, ServerStatus.thrift_spec), None, ), # 0
+ (0, TType.BOOL, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class freeSpace_args(TBase):
+class isTimeReconnect_args(TBase):
__slots__ = [
]
@@ -3617,7 +4297,7 @@ class freeSpace_args(TBase):
)
-class freeSpace_result(TBase):
+class isTimeReconnect_result(TBase):
"""
Attributes:
- success
@@ -3628,14 +4308,14 @@ class freeSpace_result(TBase):
]
thrift_spec = (
- (0, TType.I64, 'success', None, None, ), # 0
+ (0, TType.BOOL, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class getServerVersion_args(TBase):
+class toggleReconnect_args(TBase):
__slots__ = [
]
@@ -3644,7 +4324,7 @@ class getServerVersion_args(TBase):
)
-class getServerVersion_result(TBase):
+class toggleReconnect_result(TBase):
"""
Attributes:
- success
@@ -3655,14 +4335,14 @@ class getServerVersion_result(TBase):
]
thrift_spec = (
- (0, TType.STRING, 'success', None, None, ), # 0
+ (0, TType.BOOL, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class kill_args(TBase):
+class scanDownloadFolder_args(TBase):
__slots__ = [
]
@@ -3671,7 +4351,7 @@ class kill_args(TBase):
)
-class kill_result(TBase):
+class scanDownloadFolder_result(TBase):
__slots__ = [
]
@@ -3680,7 +4360,7 @@ class kill_result(TBase):
)
-class restart_args(TBase):
+class getProgressInfo_args(TBase):
__slots__ = [
]
@@ -3689,35 +4369,48 @@ class restart_args(TBase):
)
-class restart_result(TBase):
+class getProgressInfo_result(TBase):
+ """
+ Attributes:
+ - success
+ """
__slots__ = [
+ 'success',
]
thrift_spec = (
+ (0, TType.LIST, 'success', (TType.STRUCT,(ProgressInfo, ProgressInfo.thrift_spec)), None, ), # 0
)
+ def __init__(self, success=None,):
+ self.success = success
-class getLog_args(TBase):
+
+class getConfigValue_args(TBase):
"""
Attributes:
- - offset
+ - section
+ - option
"""
__slots__ = [
- 'offset',
+ 'section',
+ 'option',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'offset', None, None, ), # 1
+ (1, TType.STRING, 'section', None, None, ), # 1
+ (2, TType.STRING, 'option', None, None, ), # 2
)
- def __init__(self, offset=None,):
- self.offset = offset
+ def __init__(self, section=None, option=None,):
+ self.section = section
+ self.option = option
-class getLog_result(TBase):
+class getConfigValue_result(TBase):
"""
Attributes:
- success
@@ -3728,41 +4421,50 @@ class getLog_result(TBase):
]
thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
+ (0, TType.STRING, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class isTimeDownload_args(TBase):
+class setConfigValue_args(TBase):
+ """
+ Attributes:
+ - section
+ - option
+ - value
+ """
__slots__ = [
+ 'section',
+ 'option',
+ 'value',
]
thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'section', None, None, ), # 1
+ (2, TType.STRING, 'option', None, None, ), # 2
+ (3, TType.STRING, 'value', None, None, ), # 3
)
+ def __init__(self, section=None, option=None, value=None,):
+ self.section = section
+ self.option = option
+ self.value = value
-class isTimeDownload_result(TBase):
- """
- Attributes:
- - success
- """
+
+class setConfigValue_result(TBase):
__slots__ = [
- 'success',
]
thrift_spec = (
- (0, TType.BOOL, 'success', None, None, ), # 0
)
- def __init__(self, success=None,):
- self.success = success
-
-class isTimeReconnect_args(TBase):
+class getConfig_args(TBase):
__slots__ = [
]
@@ -3771,7 +4473,7 @@ class isTimeReconnect_args(TBase):
)
-class isTimeReconnect_result(TBase):
+class getConfig_result(TBase):
"""
Attributes:
- success
@@ -3782,14 +4484,14 @@ class isTimeReconnect_result(TBase):
]
thrift_spec = (
- (0, TType.BOOL, 'success', None, None, ), # 0
+ (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(ConfigSection, ConfigSection.thrift_spec)), None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class toggleReconnect_args(TBase):
+class getPluginConfig_args(TBase):
__slots__ = [
]
@@ -3798,7 +4500,7 @@ class toggleReconnect_args(TBase):
)
-class toggleReconnect_result(TBase):
+class getPluginConfig_result(TBase):
"""
Attributes:
- success
@@ -3809,33 +4511,33 @@ class toggleReconnect_result(TBase):
]
thrift_spec = (
- (0, TType.BOOL, 'success', None, None, ), # 0
+ (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(ConfigSection, ConfigSection.thrift_spec)), None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class generatePackages_args(TBase):
+class configureSection_args(TBase):
"""
Attributes:
- - links
+ - section
"""
__slots__ = [
- 'links',
+ 'section',
]
thrift_spec = (
None, # 0
- (1, TType.LIST, 'links', (TType.STRING,None), None, ), # 1
+ (1, TType.STRING, 'section', None, None, ), # 1
)
- def __init__(self, links=None,):
- self.links = links
+ def __init__(self, section=None,):
+ self.section = section
-class generatePackages_result(TBase):
+class configureSection_result(TBase):
"""
Attributes:
- success
@@ -3846,13 +4548,49 @@ class generatePackages_result(TBase):
]
thrift_spec = (
- (0, TType.MAP, 'success', (TType.STRING,None,TType.LIST,(TType.STRING,None)), None, ), # 0
+ (0, TType.STRUCT, 'success', (ConfigSection, ConfigSection.thrift_spec), None, ), # 0
)
def __init__(self, success=None,):
self.success = success
+class setConfigHandler_args(TBase):
+ """
+ Attributes:
+ - plugin
+ - iid
+ - value
+ """
+
+ __slots__ = [
+ 'plugin',
+ 'iid',
+ 'value',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'plugin', None, None, ), # 1
+ (2, TType.I32, 'iid', None, None, ), # 2
+ (3, TType.STRING, 'value', None, None, ), # 3
+ )
+
+ def __init__(self, plugin=None, iid=None, value=None,):
+ self.plugin = plugin
+ self.iid = iid
+ self.value = value
+
+
+class setConfigHandler_result(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
+
+
class checkURLs_args(TBase):
"""
Attributes:
@@ -4050,16 +4788,26 @@ class pollResults_result(TBase):
self.success = success
-class statusDownloads_args(TBase):
+class generatePackages_args(TBase):
+ """
+ Attributes:
+ - links
+ """
__slots__ = [
+ 'links',
]
thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'links', (TType.STRING,None), None, ), # 1
)
+ def __init__(self, links=None,):
+ self.links = links
+
-class statusDownloads_result(TBase):
+class generatePackages_result(TBase):
"""
Attributes:
- success
@@ -4070,146 +4818,180 @@ class statusDownloads_result(TBase):
]
thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRUCT,(DownloadInfo, DownloadInfo.thrift_spec)), None, ), # 0
+ (0, TType.MAP, 'success', (TType.STRING,None,TType.LIST,(TType.STRING,None)), None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class getPackageData_args(TBase):
+class generateAndAddPackages_args(TBase):
"""
Attributes:
- - pid
+ - links
+ - paused
"""
__slots__ = [
- 'pid',
+ 'links',
+ 'paused',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'pid', None, None, ), # 1
+ (1, TType.LIST, 'links', (TType.STRING,None), None, ), # 1
+ (2, TType.BOOL, 'paused', None, None, ), # 2
)
- def __init__(self, pid=None,):
- self.pid = pid
+ def __init__(self, links=None, paused=None,):
+ self.links = links
+ self.paused = paused
-class getPackageData_result(TBase):
+class generateAndAddPackages_result(TBase):
"""
Attributes:
- success
- - e
"""
__slots__ = [
'success',
- 'e',
]
thrift_spec = (
- (0, TType.STRUCT, 'success', (PackageData, PackageData.thrift_spec), None, ), # 0
- (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1
+ (0, TType.LIST, 'success', (TType.I32,None), None, ), # 0
)
- def __init__(self, success=None, e=None,):
+ def __init__(self, success=None,):
self.success = success
- self.e = e
-class getPackageInfo_args(TBase):
+class autoAddLinks_args(TBase):
"""
Attributes:
- - pid
+ - links
"""
__slots__ = [
- 'pid',
+ 'links',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'pid', None, None, ), # 1
+ (1, TType.LIST, 'links', (TType.STRING,None), None, ), # 1
)
- def __init__(self, pid=None,):
- self.pid = pid
+ def __init__(self, links=None,):
+ self.links = links
-class getPackageInfo_result(TBase):
+class autoAddLinks_result(TBase):
"""
Attributes:
- success
- - e
"""
__slots__ = [
'success',
- 'e',
]
thrift_spec = (
- (0, TType.STRUCT, 'success', (PackageData, PackageData.thrift_spec), None, ), # 0
- (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1
+ (0, TType.LIST, 'success', (TType.I32,None), None, ), # 0
)
- def __init__(self, success=None, e=None,):
+ def __init__(self, success=None,):
self.success = success
- self.e = e
-class getFileData_args(TBase):
+class createPackage_args(TBase):
"""
Attributes:
- - fid
+ - name
+ - folder
+ - root
+ - password
+ - site
+ - comment
+ - paused
"""
__slots__ = [
- 'fid',
+ 'name',
+ 'folder',
+ 'root',
+ 'password',
+ 'site',
+ 'comment',
+ 'paused',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'fid', None, None, ), # 1
+ (1, TType.STRING, 'name', None, None, ), # 1
+ (2, TType.STRING, 'folder', None, None, ), # 2
+ (3, TType.I32, 'root', None, None, ), # 3
+ (4, TType.STRING, 'password', None, None, ), # 4
+ (5, TType.STRING, 'site', None, None, ), # 5
+ (6, TType.STRING, 'comment', None, None, ), # 6
+ (7, TType.BOOL, 'paused', None, None, ), # 7
)
- def __init__(self, fid=None,):
- self.fid = fid
+ def __init__(self, name=None, folder=None, root=None, password=None, site=None, comment=None, paused=None,):
+ self.name = name
+ self.folder = folder
+ self.root = root
+ self.password = password
+ self.site = site
+ self.comment = comment
+ self.paused = paused
-class getFileData_result(TBase):
+class createPackage_result(TBase):
"""
Attributes:
- success
- - e
"""
__slots__ = [
'success',
- 'e',
]
thrift_spec = (
- (0, TType.STRUCT, 'success', (FileData, FileData.thrift_spec), None, ), # 0
- (1, TType.STRUCT, 'e', (FileDoesNotExists, FileDoesNotExists.thrift_spec), None, ), # 1
+ (0, TType.I32, 'success', None, None, ), # 0
)
- def __init__(self, success=None, e=None,):
+ def __init__(self, success=None,):
self.success = success
- self.e = e
-class getQueue_args(TBase):
+class addPackage_args(TBase):
+ """
+ Attributes:
+ - name
+ - links
+ - password
+ """
__slots__ = [
+ 'name',
+ 'links',
+ 'password',
]
thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2
+ (3, TType.STRING, 'password', None, None, ), # 3
)
+ def __init__(self, name=None, links=None, password=None,):
+ self.name = name
+ self.links = links
+ self.password = password
+
-class getQueue_result(TBase):
+class addPackage_result(TBase):
"""
Attributes:
- success
@@ -4220,23 +5002,45 @@ class getQueue_result(TBase):
]
thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRUCT,(PackageData, PackageData.thrift_spec)), None, ), # 0
+ (0, TType.I32, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class getCollector_args(TBase):
+class addPackageP_args(TBase):
+ """
+ Attributes:
+ - name
+ - links
+ - password
+ - paused
+ """
__slots__ = [
+ 'name',
+ 'links',
+ 'password',
+ 'paused',
]
thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2
+ (3, TType.STRING, 'password', None, None, ), # 3
+ (4, TType.BOOL, 'paused', None, None, ), # 4
)
+ def __init__(self, name=None, links=None, password=None, paused=None,):
+ self.name = name
+ self.links = links
+ self.password = password
+ self.paused = paused
+
-class getCollector_result(TBase):
+class addPackageP_result(TBase):
"""
Attributes:
- success
@@ -4247,23 +5051,49 @@ class getCollector_result(TBase):
]
thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRUCT,(PackageData, PackageData.thrift_spec)), None, ), # 0
+ (0, TType.I32, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class getQueueData_args(TBase):
+class addPackageChild_args(TBase):
+ """
+ Attributes:
+ - name
+ - links
+ - password
+ - root
+ - paused
+ """
__slots__ = [
+ 'name',
+ 'links',
+ 'password',
+ 'root',
+ 'paused',
]
thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2
+ (3, TType.STRING, 'password', None, None, ), # 3
+ (4, TType.I32, 'root', None, None, ), # 4
+ (5, TType.BOOL, 'paused', None, None, ), # 5
)
+ def __init__(self, name=None, links=None, password=None, root=None, paused=None,):
+ self.name = name
+ self.links = links
+ self.password = password
+ self.root = root
+ self.paused = paused
+
-class getQueueData_result(TBase):
+class addPackageChild_result(TBase):
"""
Attributes:
- success
@@ -4274,23 +5104,37 @@ class getQueueData_result(TBase):
]
thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRUCT,(PackageData, PackageData.thrift_spec)), None, ), # 0
+ (0, TType.I32, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class getCollectorData_args(TBase):
+class uploadContainer_args(TBase):
+ """
+ Attributes:
+ - filename
+ - data
+ """
__slots__ = [
+ 'filename',
+ 'data',
]
thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'filename', None, None, ), # 1
+ (2, TType.STRING, 'data', None, None, ), # 2
)
+ def __init__(self, filename=None, data=None,):
+ self.filename = filename
+ self.data = data
-class getCollectorData_result(TBase):
+
+class uploadContainer_result(TBase):
"""
Attributes:
- success
@@ -4301,70 +5145,121 @@ class getCollectorData_result(TBase):
]
thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRUCT,(PackageData, PackageData.thrift_spec)), None, ), # 0
+ (0, TType.I32, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class getPackageOrder_args(TBase):
+class addLinks_args(TBase):
"""
Attributes:
- - destination
+ - pid
+ - links
"""
__slots__ = [
- 'destination',
+ 'pid',
+ 'links',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'destination', None, None, ), # 1
+ (1, TType.I32, 'pid', None, None, ), # 1
+ (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2
)
- def __init__(self, destination=None,):
- self.destination = destination
+ def __init__(self, pid=None, links=None,):
+ self.pid = pid
+ self.links = links
-class getPackageOrder_result(TBase):
+class addLinks_result(TBase):
"""
Attributes:
- - success
+ - e
"""
__slots__ = [
- 'success',
+ 'e',
]
thrift_spec = (
- (0, TType.MAP, 'success', (TType.I16,None,TType.I32,None), None, ), # 0
+ None, # 0
+ (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1
)
- def __init__(self, success=None,):
- self.success = success
+ def __init__(self, e=None,):
+ self.e = e
-class getFileOrder_args(TBase):
+class deleteFiles_args(TBase):
"""
Attributes:
- - pid
+ - fids
"""
__slots__ = [
- 'pid',
+ 'fids',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'pid', None, None, ), # 1
+ (1, TType.LIST, 'fids', (TType.I32,None), None, ), # 1
)
- def __init__(self, pid=None,):
- self.pid = pid
+ def __init__(self, fids=None,):
+ self.fids = fids
+
+
+class deleteFiles_result(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
+
+
+class deletePackages_args(TBase):
+ """
+ Attributes:
+ - pids
+ """
+
+ __slots__ = [
+ 'pids',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'pids', (TType.I32,None), None, ), # 1
+ )
+
+ def __init__(self, pids=None,):
+ self.pids = pids
+
+
+class deletePackages_result(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
+
+
+class getCollector_args(TBase):
+ __slots__ = [
+ ]
-class getFileOrder_result(TBase):
+ thrift_spec = (
+ )
+
+
+class getCollector_result(TBase):
"""
Attributes:
- success
@@ -4375,37 +5270,65 @@ class getFileOrder_result(TBase):
]
thrift_spec = (
- (0, TType.MAP, 'success', (TType.I16,None,TType.I32,None), None, ), # 0
+ (0, TType.LIST, 'success', (TType.STRUCT,(LinkStatus, LinkStatus.thrift_spec)), None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class generateAndAddPackages_args(TBase):
+class addToCollector_args(TBase):
"""
Attributes:
- links
- - dest
"""
__slots__ = [
'links',
- 'dest',
]
thrift_spec = (
None, # 0
(1, TType.LIST, 'links', (TType.STRING,None), None, ), # 1
- (2, TType.I32, 'dest', None, None, ), # 2
)
- def __init__(self, links=None, dest=None,):
+ def __init__(self, links=None,):
self.links = links
- self.dest = dest
-class generateAndAddPackages_result(TBase):
+class addToCollector_result(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
+
+
+class addFromCollector_args(TBase):
+ """
+ Attributes:
+ - name
+ - paused
+ """
+
+ __slots__ = [
+ 'name',
+ 'paused',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
+ (2, TType.BOOL, 'paused', None, None, ), # 2
+ )
+
+ def __init__(self, name=None, paused=None,):
+ self.name = name
+ self.paused = paused
+
+
+class addFromCollector_result(TBase):
"""
Attributes:
- success
@@ -4416,86 +5339,93 @@ class generateAndAddPackages_result(TBase):
]
thrift_spec = (
- (0, TType.LIST, 'success', (TType.I32,None), None, ), # 0
+ (0, TType.I32, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class addPackage_args(TBase):
+class renameCollPack_args(TBase):
"""
Attributes:
- name
- - links
- - dest
- - password
+ - new_name
"""
__slots__ = [
'name',
- 'links',
- 'dest',
- 'password',
+ 'new_name',
]
thrift_spec = (
None, # 0
(1, TType.STRING, 'name', None, None, ), # 1
- (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2
- (3, TType.I32, 'dest', None, None, ), # 3
- (4, TType.STRING, 'password', None, None, ), # 4
+ (2, TType.STRING, 'new_name', None, None, ), # 2
)
- def __init__(self, name=None, links=None, dest=None, password=None,):
+ def __init__(self, name=None, new_name=None,):
self.name = name
- self.links = links
- self.dest = dest
- self.password = password
+ self.new_name = new_name
-class addPackage_result(TBase):
+class renameCollPack_result(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
+
+
+class deleteCollPack_args(TBase):
"""
Attributes:
- - success
+ - name
"""
__slots__ = [
- 'success',
+ 'name',
]
thrift_spec = (
- (0, TType.I32, 'success', None, None, ), # 0
+ None, # 0
+ (1, TType.STRING, 'name', None, None, ), # 1
)
- def __init__(self, success=None,):
- self.success = success
+ def __init__(self, name=None,):
+ self.name = name
+
+
+class deleteCollPack_result(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
-class addFiles_args(TBase):
+class deleteCollLink_args(TBase):
"""
Attributes:
- - pid
- - links
+ - url
"""
__slots__ = [
- 'pid',
- 'links',
+ 'url',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'pid', None, None, ), # 1
- (2, TType.LIST, 'links', (TType.STRING,None), None, ), # 2
+ (1, TType.STRING, 'url', None, None, ), # 1
)
- def __init__(self, pid=None, links=None,):
- self.pid = pid
- self.links = links
+ def __init__(self, url=None,):
+ self.url = url
-class addFiles_result(TBase):
+class deleteCollLink_result(TBase):
__slots__ = [
]
@@ -4504,30 +5434,34 @@ class addFiles_result(TBase):
)
-class uploadContainer_args(TBase):
+class getAllFiles_args(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
+
+
+class getAllFiles_result(TBase):
"""
Attributes:
- - filename
- - data
+ - success
"""
__slots__ = [
- 'filename',
- 'data',
+ 'success',
]
thrift_spec = (
- None, # 0
- (1, TType.STRING, 'filename', None, None, ), # 1
- (2, TType.STRING, 'data', None, None, ), # 2
+ (0, TType.STRUCT, 'success', (PackageView, PackageView.thrift_spec), None, ), # 0
)
- def __init__(self, filename=None, data=None,):
- self.filename = filename
- self.data = data
+ def __init__(self, success=None,):
+ self.success = success
-class uploadContainer_result(TBase):
+class getAllUnfinishedFiles_args(TBase):
__slots__ = [
]
@@ -4536,63 +5470,107 @@ class uploadContainer_result(TBase):
)
-class deleteFiles_args(TBase):
+class getAllUnfinishedFiles_result(TBase):
"""
Attributes:
- - fids
+ - success
"""
__slots__ = [
- 'fids',
+ 'success',
+ ]
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (PackageView, PackageView.thrift_spec), None, ), # 0
+ )
+
+ def __init__(self, success=None,):
+ self.success = success
+
+
+class getFileTree_args(TBase):
+ """
+ Attributes:
+ - pid
+ - full
+ """
+
+ __slots__ = [
+ 'pid',
+ 'full',
]
thrift_spec = (
None, # 0
- (1, TType.LIST, 'fids', (TType.I32,None), None, ), # 1
+ (1, TType.I32, 'pid', None, None, ), # 1
+ (2, TType.BOOL, 'full', None, None, ), # 2
)
- def __init__(self, fids=None,):
- self.fids = fids
+ def __init__(self, pid=None, full=None,):
+ self.pid = pid
+ self.full = full
-class deleteFiles_result(TBase):
+class getFileTree_result(TBase):
+ """
+ Attributes:
+ - success
+ """
__slots__ = [
+ 'success',
]
thrift_spec = (
+ (0, TType.STRUCT, 'success', (PackageView, PackageView.thrift_spec), None, ), # 0
)
+ def __init__(self, success=None,):
+ self.success = success
-class deletePackages_args(TBase):
+
+class getUnfinishedFileTree_args(TBase):
"""
Attributes:
- - pids
+ - pid
+ - full
"""
__slots__ = [
- 'pids',
+ 'pid',
+ 'full',
]
thrift_spec = (
None, # 0
- (1, TType.LIST, 'pids', (TType.I32,None), None, ), # 1
+ (1, TType.I32, 'pid', None, None, ), # 1
+ (2, TType.BOOL, 'full', None, None, ), # 2
)
- def __init__(self, pids=None,):
- self.pids = pids
+ def __init__(self, pid=None, full=None,):
+ self.pid = pid
+ self.full = full
-class deletePackages_result(TBase):
+class getUnfinishedFileTree_result(TBase):
+ """
+ Attributes:
+ - success
+ """
__slots__ = [
+ 'success',
]
thrift_spec = (
+ (0, TType.STRUCT, 'success', (PackageView, PackageView.thrift_spec), None, ), # 0
)
+ def __init__(self, success=None,):
+ self.success = success
+
-class pushToQueue_args(TBase):
+class getPackageContent_args(TBase):
"""
Attributes:
- pid
@@ -4611,16 +5589,25 @@ class pushToQueue_args(TBase):
self.pid = pid
-class pushToQueue_result(TBase):
+class getPackageContent_result(TBase):
+ """
+ Attributes:
+ - success
+ """
__slots__ = [
+ 'success',
]
thrift_spec = (
+ (0, TType.STRUCT, 'success', (PackageView, PackageView.thrift_spec), None, ), # 0
)
+ def __init__(self, success=None,):
+ self.success = success
+
-class pullFromQueue_args(TBase):
+class getPackageInfo_args(TBase):
"""
Attributes:
- pid
@@ -4639,14 +5626,105 @@ class pullFromQueue_args(TBase):
self.pid = pid
-class pullFromQueue_result(TBase):
+class getPackageInfo_result(TBase):
+ """
+ Attributes:
+ - success
+ - e
+ """
__slots__ = [
+ 'success',
+ 'e',
]
thrift_spec = (
+ (0, TType.STRUCT, 'success', (PackageInfo, PackageInfo.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1
)
+ def __init__(self, success=None, e=None,):
+ self.success = success
+ self.e = e
+
+
+class getFileInfo_args(TBase):
+ """
+ Attributes:
+ - fid
+ """
+
+ __slots__ = [
+ 'fid',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'fid', None, None, ), # 1
+ )
+
+ def __init__(self, fid=None,):
+ self.fid = fid
+
+
+class getFileInfo_result(TBase):
+ """
+ Attributes:
+ - success
+ - e
+ """
+
+ __slots__ = [
+ 'success',
+ 'e',
+ ]
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (FileInfo, FileInfo.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'e', (FileDoesNotExists, FileDoesNotExists.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, success=None, e=None,):
+ self.success = success
+ self.e = e
+
+
+class findFiles_args(TBase):
+ """
+ Attributes:
+ - pattern
+ """
+
+ __slots__ = [
+ 'pattern',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'pattern', None, None, ), # 1
+ )
+
+ def __init__(self, pattern=None,):
+ self.pattern = pattern
+
+
+class findFiles_result(TBase):
+ """
+ Attributes:
+ - success
+ """
+
+ __slots__ = [
+ 'success',
+ ]
+
+ thrift_spec = (
+ (0, TType.MAP, 'success', (TType.I32,None,TType.STRUCT,(FileInfo, FileInfo.thrift_spec)), None, ), # 0
+ )
+
+ def __init__(self, success=None,):
+ self.success = success
+
class restartPackage_args(TBase):
"""
@@ -4732,6 +5810,34 @@ class recheckPackage_result(TBase):
)
+class stopDownloads_args(TBase):
+ """
+ Attributes:
+ - fids
+ """
+
+ __slots__ = [
+ 'fids',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.LIST, 'fids', (TType.I32,None), None, ), # 1
+ )
+
+ def __init__(self, fids=None,):
+ self.fids = fids
+
+
+class stopDownloads_result(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
+
+
class stopAllDownloads_args(TBase):
__slots__ = [
@@ -4750,97 +5856,239 @@ class stopAllDownloads_result(TBase):
)
-class stopDownloads_args(TBase):
+class restartFailed_args(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
+
+
+class restartFailed_result(TBase):
+
+ __slots__ = [
+ ]
+
+ thrift_spec = (
+ )
+
+
+class setFilePaused_args(TBase):
"""
Attributes:
- - fids
+ - fid
+ - paused
"""
__slots__ = [
- 'fids',
+ 'fid',
+ 'paused',
]
thrift_spec = (
None, # 0
- (1, TType.LIST, 'fids', (TType.I32,None), None, ), # 1
+ (1, TType.I32, 'fid', None, None, ), # 1
+ (2, TType.BOOL, 'paused', None, None, ), # 2
)
- def __init__(self, fids=None,):
- self.fids = fids
+ def __init__(self, fid=None, paused=None,):
+ self.fid = fid
+ self.paused = paused
-class stopDownloads_result(TBase):
+class setFilePaused_result(TBase):
+ """
+ Attributes:
+ - e
+ """
__slots__ = [
+ 'e',
]
thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'e', (FileDoesNotExists, FileDoesNotExists.thrift_spec), None, ), # 1
)
+ def __init__(self, e=None,):
+ self.e = e
+
-class setPackageName_args(TBase):
+class setPackagePaused_args(TBase):
"""
Attributes:
- pid
- - name
+ - paused
"""
__slots__ = [
'pid',
- 'name',
+ 'paused',
]
thrift_spec = (
None, # 0
(1, TType.I32, 'pid', None, None, ), # 1
- (2, TType.STRING, 'name', None, None, ), # 2
+ (2, TType.BOOL, 'paused', None, None, ), # 2
)
- def __init__(self, pid=None, name=None,):
+ def __init__(self, pid=None, paused=None,):
self.pid = pid
- self.name = name
+ self.paused = paused
+
+
+class setPackagePaused_result(TBase):
+ """
+ Attributes:
+ - e
+ """
+
+ __slots__ = [
+ 'e',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, e=None,):
+ self.e = e
+
+
+class setPackageFolder_args(TBase):
+ """
+ Attributes:
+ - pid
+ - path
+ """
+ __slots__ = [
+ 'pid',
+ 'path',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'pid', None, None, ), # 1
+ (2, TType.STRING, 'path', None, None, ), # 2
+ )
+
+ def __init__(self, pid=None, path=None,):
+ self.pid = pid
+ self.path = path
-class setPackageName_result(TBase):
+
+class setPackageFolder_result(TBase):
+ """
+ Attributes:
+ - success
+ - e
+ """
__slots__ = [
+ 'success',
+ 'e',
]
thrift_spec = (
+ (0, TType.BOOL, 'success', None, None, ), # 0
+ (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1
)
+ def __init__(self, success=None, e=None,):
+ self.success = success
+ self.e = e
+
+
+class setPackageData_args(TBase):
+ """
+ Attributes:
+ - pid
+ - data
+ """
+
+ __slots__ = [
+ 'pid',
+ 'data',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'pid', None, None, ), # 1
+ (2, TType.MAP, 'data', (TType.STRING,None,TType.STRING,None), None, ), # 2
+ )
+
+ def __init__(self, pid=None, data=None,):
+ self.pid = pid
+ self.data = data
+
+
+class setPackageData_result(TBase):
+ """
+ Attributes:
+ - e
+ """
+
+ __slots__ = [
+ 'e',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, e=None,):
+ self.e = e
+
class movePackage_args(TBase):
"""
Attributes:
- - destination
- pid
+ - root
"""
__slots__ = [
- 'destination',
'pid',
+ 'root',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'destination', None, None, ), # 1
- (2, TType.I32, 'pid', None, None, ), # 2
+ (1, TType.I32, 'pid', None, None, ), # 1
+ (2, TType.I32, 'root', None, None, ), # 2
)
- def __init__(self, destination=None, pid=None,):
- self.destination = destination
+ def __init__(self, pid=None, root=None,):
self.pid = pid
+ self.root = root
class movePackage_result(TBase):
+ """
+ Attributes:
+ - success
+ - e
+ """
__slots__ = [
+ 'success',
+ 'e',
]
thrift_spec = (
+ (0, TType.BOOL, 'success', None, None, ), # 0
+ (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1
)
+ def __init__(self, success=None, e=None,):
+ self.success = success
+ self.e = e
+
class moveFiles_args(TBase):
"""
@@ -4866,34 +6114,47 @@ class moveFiles_args(TBase):
class moveFiles_result(TBase):
+ """
+ Attributes:
+ - success
+ - e
+ """
__slots__ = [
+ 'success',
+ 'e',
]
thrift_spec = (
+ (0, TType.BOOL, 'success', None, None, ), # 0
+ (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1
)
+ def __init__(self, success=None, e=None,):
+ self.success = success
+ self.e = e
+
class orderPackage_args(TBase):
"""
Attributes:
- - pid
+ - pids
- position
"""
__slots__ = [
- 'pid',
+ 'pids',
'position',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'pid', None, None, ), # 1
+ (1, TType.LIST, 'pids', (TType.I32,None), None, ), # 1
(2, TType.I16, 'position', None, None, ), # 2
)
- def __init__(self, pid=None, position=None,):
- self.pid = pid
+ def __init__(self, pids=None, position=None,):
+ self.pids = pids
self.position = position
@@ -4906,30 +6167,34 @@ class orderPackage_result(TBase):
)
-class orderFile_args(TBase):
+class orderFiles_args(TBase):
"""
Attributes:
- - fid
+ - fids
+ - pid
- position
"""
__slots__ = [
- 'fid',
+ 'fids',
+ 'pid',
'position',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'fid', None, None, ), # 1
- (2, TType.I16, 'position', None, None, ), # 2
+ (1, TType.LIST, 'fids', (TType.I32,None), None, ), # 1
+ (2, TType.I32, 'pid', None, None, ), # 2
+ (3, TType.I16, 'position', None, None, ), # 3
)
- def __init__(self, fid=None, position=None,):
- self.fid = fid
+ def __init__(self, fids=None, pid=None, position=None,):
+ self.fids = fids
+ self.pid = pid
self.position = position
-class orderFile_result(TBase):
+class orderFiles_result(TBase):
__slots__ = [
]
@@ -4938,49 +6203,104 @@ class orderFile_result(TBase):
)
-class setPackageData_args(TBase):
+class isInteractionWaiting_args(TBase):
"""
Attributes:
- - pid
- - data
+ - mode
"""
__slots__ = [
- 'pid',
- 'data',
+ 'mode',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'pid', None, None, ), # 1
- (2, TType.MAP, 'data', (TType.STRING,None,TType.STRING,None), None, ), # 2
+ (1, TType.I16, 'mode', None, None, ), # 1
)
- def __init__(self, pid=None, data=None,):
- self.pid = pid
- self.data = data
+ def __init__(self, mode=None,):
+ self.mode = mode
-class setPackageData_result(TBase):
+class isInteractionWaiting_result(TBase):
"""
Attributes:
- - e
+ - success
"""
__slots__ = [
- 'e',
+ 'success',
+ ]
+
+ thrift_spec = (
+ (0, TType.BOOL, 'success', None, None, ), # 0
+ )
+
+ def __init__(self, success=None,):
+ self.success = success
+
+
+class getInteractionTask_args(TBase):
+ """
+ Attributes:
+ - mode
+ """
+
+ __slots__ = [
+ 'mode',
]
thrift_spec = (
None, # 0
- (1, TType.STRUCT, 'e', (PackageDoesNotExists, PackageDoesNotExists.thrift_spec), None, ), # 1
+ (1, TType.I16, 'mode', None, None, ), # 1
)
- def __init__(self, e=None,):
- self.e = e
+ def __init__(self, mode=None,):
+ self.mode = mode
+
+
+class getInteractionTask_result(TBase):
+ """
+ Attributes:
+ - success
+ """
+
+ __slots__ = [
+ 'success',
+ ]
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (InteractionTask, InteractionTask.thrift_spec), None, ), # 0
+ )
+
+ def __init__(self, success=None,):
+ self.success = success
+
+
+class setInteractionResult_args(TBase):
+ """
+ Attributes:
+ - iid
+ - result
+ """
+
+ __slots__ = [
+ 'iid',
+ 'result',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'iid', None, None, ), # 1
+ (2, TType.STRING, 'result', None, None, ), # 2
+ )
+
+ def __init__(self, iid=None, result=None,):
+ self.iid = iid
+ self.result = result
-class deleteFinished_args(TBase):
+class setInteractionResult_result(TBase):
__slots__ = [
]
@@ -4989,7 +6309,30 @@ class deleteFinished_args(TBase):
)
-class deleteFinished_result(TBase):
+class generateDownloadLink_args(TBase):
+ """
+ Attributes:
+ - fid
+ - timeout
+ """
+
+ __slots__ = [
+ 'fid',
+ 'timeout',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'fid', None, None, ), # 1
+ (2, TType.I16, 'timeout', None, None, ), # 2
+ )
+
+ def __init__(self, fid=None, timeout=None,):
+ self.fid = fid
+ self.timeout = timeout
+
+
+class generateDownloadLink_result(TBase):
"""
Attributes:
- success
@@ -5000,14 +6343,14 @@ class deleteFinished_result(TBase):
]
thrift_spec = (
- (0, TType.LIST, 'success', (TType.I32,None), None, ), # 0
+ (0, TType.STRING, 'success', None, None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-class restartFailed_args(TBase):
+class getAddonHandler_args(TBase):
__slots__ = [
]
@@ -5016,7 +6359,52 @@ class restartFailed_args(TBase):
)
-class restartFailed_result(TBase):
+class getAddonHandler_result(TBase):
+ """
+ Attributes:
+ - success
+ """
+
+ __slots__ = [
+ 'success',
+ ]
+
+ thrift_spec = (
+ (0, TType.MAP, 'success', (TType.STRING,None,TType.LIST,(TType.STRUCT,(AddonService, AddonService.thrift_spec))), None, ), # 0
+ )
+
+ def __init__(self, success=None,):
+ self.success = success
+
+
+class callAddonHandler_args(TBase):
+ """
+ Attributes:
+ - plugin
+ - func
+ - pid_or_fid
+ """
+
+ __slots__ = [
+ 'plugin',
+ 'func',
+ 'pid_or_fid',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'plugin', None, None, ), # 1
+ (2, TType.STRING, 'func', None, None, ), # 2
+ (3, TType.I32, 'pid_or_fid', None, None, ), # 3
+ )
+
+ def __init__(self, plugin=None, func=None, pid_or_fid=None,):
+ self.plugin = plugin
+ self.func = func
+ self.pid_or_fid = pid_or_fid
+
+
+class callAddonHandler_result(TBase):
__slots__ = [
]
@@ -5331,7 +6719,7 @@ class getServices_result(TBase):
]
thrift_spec = (
- (0, TType.MAP, 'success', (TType.STRING,None,TType.MAP,(TType.STRING,None,TType.STRING,None)), None, ), # 0
+ (0, TType.MAP, 'success', (TType.STRING,None,TType.LIST,(TType.STRUCT,(AddonService, AddonService.thrift_spec))), None, ), # 0
)
def __init__(self, success=None,):
@@ -5382,20 +6770,28 @@ class hasService_result(TBase):
class call_args(TBase):
"""
Attributes:
- - info
+ - plugin
+ - func
+ - arguments
"""
__slots__ = [
- 'info',
+ 'plugin',
+ 'func',
+ 'arguments',
]
thrift_spec = (
None, # 0
- (1, TType.STRUCT, 'info', (ServiceCall, ServiceCall.thrift_spec), None, ), # 1
+ (1, TType.STRING, 'plugin', None, None, ), # 1
+ (2, TType.STRING, 'func', None, None, ), # 2
+ (3, TType.STRING, 'arguments', None, None, ), # 3
)
- def __init__(self, info=None,):
- self.info = info
+ def __init__(self, plugin=None, func=None, arguments=None,):
+ self.plugin = plugin
+ self.func = func
+ self.arguments = arguments
class call_result(TBase):
@@ -5444,7 +6840,7 @@ class getAllInfo_result(TBase):
]
thrift_spec = (
- (0, TType.MAP, 'success', (TType.STRING,None,TType.MAP,(TType.STRING,None,TType.STRING,None)), None, ), # 0
+ (0, TType.MAP, 'success', (TType.STRING,None,TType.LIST,(TType.STRUCT,(AddonInfo, AddonInfo.thrift_spec))), None, ), # 0
)
def __init__(self, success=None,):
@@ -5481,142 +6877,9 @@ class getInfoByPlugin_result(TBase):
]
thrift_spec = (
- (0, TType.MAP, 'success', (TType.STRING,None,TType.STRING,None), None, ), # 0
- )
-
- def __init__(self, success=None,):
- self.success = success
-
-
-class isCaptchaWaiting_args(TBase):
-
- __slots__ = [
- ]
-
- thrift_spec = (
- )
-
-
-class isCaptchaWaiting_result(TBase):
- """
- Attributes:
- - success
- """
-
- __slots__ = [
- 'success',
- ]
-
- thrift_spec = (
- (0, TType.BOOL, 'success', None, None, ), # 0
+ (0, TType.LIST, 'success', (TType.STRUCT,(AddonInfo, AddonInfo.thrift_spec)), None, ), # 0
)
def __init__(self, success=None,):
self.success = success
-
-class getCaptchaTask_args(TBase):
- """
- Attributes:
- - exclusive
- """
-
- __slots__ = [
- 'exclusive',
- ]
-
- thrift_spec = (
- None, # 0
- (1, TType.BOOL, 'exclusive', None, None, ), # 1
- )
-
- def __init__(self, exclusive=None,):
- self.exclusive = exclusive
-
-
-class getCaptchaTask_result(TBase):
- """
- Attributes:
- - success
- """
-
- __slots__ = [
- 'success',
- ]
-
- thrift_spec = (
- (0, TType.STRUCT, 'success', (CaptchaTask, CaptchaTask.thrift_spec), None, ), # 0
- )
-
- def __init__(self, success=None,):
- self.success = success
-
-
-class getCaptchaTaskStatus_args(TBase):
- """
- Attributes:
- - tid
- """
-
- __slots__ = [
- 'tid',
- ]
-
- thrift_spec = (
- None, # 0
- (1, TType.I32, 'tid', None, None, ), # 1
- )
-
- def __init__(self, tid=None,):
- self.tid = tid
-
-
-class getCaptchaTaskStatus_result(TBase):
- """
- Attributes:
- - success
- """
-
- __slots__ = [
- 'success',
- ]
-
- thrift_spec = (
- (0, TType.STRING, 'success', None, None, ), # 0
- )
-
- def __init__(self, success=None,):
- self.success = success
-
-
-class setCaptchaResult_args(TBase):
- """
- Attributes:
- - tid
- - result
- """
-
- __slots__ = [
- 'tid',
- 'result',
- ]
-
- thrift_spec = (
- None, # 0
- (1, TType.I32, 'tid', None, None, ), # 1
- (2, TType.STRING, 'result', None, None, ), # 2
- )
-
- def __init__(self, tid=None, result=None,):
- self.tid = tid
- self.result = result
-
-
-class setCaptchaResult_result(TBase):
-
- __slots__ = [
- ]
-
- thrift_spec = (
- )
-
diff --git a/module/remote/thriftbackend/thriftgen/pyload/ttypes.py b/module/remote/thriftbackend/thriftgen/pyload/ttypes.py
index b2da9748d..fbbc599a8 100644
--- a/module/remote/thriftbackend/thriftgen/pyload/ttypes.py
+++ b/module/remote/thriftbackend/thriftgen/pyload/ttypes.py
@@ -12,129 +12,187 @@ from thrift.protocol.TBase import TBase, TExceptionBase
class DownloadStatus(TBase):
- Finished = 0
+ NA = 0
Offline = 1
Online = 2
Queued = 3
- Skipped = 4
- Waiting = 5
- TempOffline = 6
- Starting = 7
- Failed = 8
- Aborted = 9
- Decrypting = 10
- Custom = 11
- Downloading = 12
- Processing = 13
- Unknown = 14
+ Paused = 4
+ Finished = 5
+ Skipped = 6
+ Failed = 7
+ Starting = 8
+ Waiting = 9
+ Downloading = 10
+ TempOffline = 11
+ Aborted = 12
+ Decrypting = 13
+ Processing = 14
+ Custom = 15
+ Unknown = 16
_VALUES_TO_NAMES = {
- 0: "Finished",
+ 0: "NA",
1: "Offline",
2: "Online",
3: "Queued",
- 4: "Skipped",
- 5: "Waiting",
- 6: "TempOffline",
- 7: "Starting",
- 8: "Failed",
- 9: "Aborted",
- 10: "Decrypting",
- 11: "Custom",
- 12: "Downloading",
- 13: "Processing",
- 14: "Unknown",
+ 4: "Paused",
+ 5: "Finished",
+ 6: "Skipped",
+ 7: "Failed",
+ 8: "Starting",
+ 9: "Waiting",
+ 10: "Downloading",
+ 11: "TempOffline",
+ 12: "Aborted",
+ 13: "Decrypting",
+ 14: "Processing",
+ 15: "Custom",
+ 16: "Unknown",
}
_NAMES_TO_VALUES = {
- "Finished": 0,
+ "NA": 0,
"Offline": 1,
"Online": 2,
"Queued": 3,
- "Skipped": 4,
- "Waiting": 5,
- "TempOffline": 6,
- "Starting": 7,
- "Failed": 8,
- "Aborted": 9,
- "Decrypting": 10,
- "Custom": 11,
- "Downloading": 12,
- "Processing": 13,
- "Unknown": 14,
+ "Paused": 4,
+ "Finished": 5,
+ "Skipped": 6,
+ "Failed": 7,
+ "Starting": 8,
+ "Waiting": 9,
+ "Downloading": 10,
+ "TempOffline": 11,
+ "Aborted": 12,
+ "Decrypting": 13,
+ "Processing": 14,
+ "Custom": 15,
+ "Unknown": 16,
}
-class Destination(TBase):
- Collector = 0
- Queue = 1
+class MediaType(TBase):
+ All = 0
+ Other = 1
+ Audio = 2
+ Image = 4
+ Video = 8
+ Document = 16
+ Archive = 32
_VALUES_TO_NAMES = {
- 0: "Collector",
- 1: "Queue",
+ 0: "All",
+ 1: "Other",
+ 2: "Audio",
+ 4: "Image",
+ 8: "Video",
+ 16: "Document",
+ 32: "Archive",
}
_NAMES_TO_VALUES = {
- "Collector": 0,
- "Queue": 1,
+ "All": 0,
+ "Other": 1,
+ "Audio": 2,
+ "Image": 4,
+ "Video": 8,
+ "Document": 16,
+ "Archive": 32,
+ }
+
+class FileStatus(TBase):
+ Ok = 0
+ Missing = 1
+ Remote = 2
+
+ _VALUES_TO_NAMES = {
+ 0: "Ok",
+ 1: "Missing",
+ 2: "Remote",
+ }
+
+ _NAMES_TO_VALUES = {
+ "Ok": 0,
+ "Missing": 1,
+ "Remote": 2,
+ }
+
+class PackageStatus(TBase):
+ Ok = 0
+ Paused = 1
+ Remote = 2
+
+ _VALUES_TO_NAMES = {
+ 0: "Ok",
+ 1: "Paused",
+ 2: "Remote",
+ }
+
+ _NAMES_TO_VALUES = {
+ "Ok": 0,
+ "Paused": 1,
+ "Remote": 2,
}
class Input(TBase):
- NONE = 0
- TEXT = 1
- TEXTBOX = 2
- PASSWORD = 3
- BOOL = 4
- CLICK = 5
- CHOICE = 6
- MULTIPLE = 7
- LIST = 8
- TABLE = 9
+ NA = 0
+ Text = 1
+ TextBox = 2
+ Password = 3
+ Bool = 4
+ Click = 5
+ Choice = 6
+ Multiple = 7
+ List = 8
+ Table = 9
_VALUES_TO_NAMES = {
- 0: "NONE",
- 1: "TEXT",
- 2: "TEXTBOX",
- 3: "PASSWORD",
- 4: "BOOL",
- 5: "CLICK",
- 6: "CHOICE",
- 7: "MULTIPLE",
- 8: "LIST",
- 9: "TABLE",
+ 0: "NA",
+ 1: "Text",
+ 2: "TextBox",
+ 3: "Password",
+ 4: "Bool",
+ 5: "Click",
+ 6: "Choice",
+ 7: "Multiple",
+ 8: "List",
+ 9: "Table",
}
_NAMES_TO_VALUES = {
- "NONE": 0,
- "TEXT": 1,
- "TEXTBOX": 2,
- "PASSWORD": 3,
- "BOOL": 4,
- "CLICK": 5,
- "CHOICE": 6,
- "MULTIPLE": 7,
- "LIST": 8,
- "TABLE": 9,
+ "NA": 0,
+ "Text": 1,
+ "TextBox": 2,
+ "Password": 3,
+ "Bool": 4,
+ "Click": 5,
+ "Choice": 6,
+ "Multiple": 7,
+ "List": 8,
+ "Table": 9,
}
class Output(TBase):
- CAPTCHA = 1
- QUESTION = 2
- NOTIFICATION = 4
+ All = 0
+ Notification = 1
+ Captcha = 2
+ Query = 4
_VALUES_TO_NAMES = {
- 1: "CAPTCHA",
- 2: "QUESTION",
- 4: "NOTIFICATION",
+ 0: "All",
+ 1: "Notification",
+ 2: "Captcha",
+ 4: "Query",
}
_NAMES_TO_VALUES = {
- "CAPTCHA": 1,
- "QUESTION": 2,
- "NOTIFICATION": 4,
+ "All": 0,
+ "Notification": 1,
+ "Captcha": 2,
+ "Query": 4,
}
-class DownloadInfo(TBase):
+class ProgressInfo(TBase):
"""
Attributes:
- fid
@@ -184,7 +242,7 @@ class DownloadInfo(TBase):
(6, TType.I64, 'bleft', None, None, ), # 6
(7, TType.I64, 'size', None, None, ), # 7
(8, TType.STRING, 'format_size', None, None, ), # 8
- (9, TType.BYTE, 'percent', None, None, ), # 9
+ (9, TType.I16, 'percent', None, None, ), # 9
(10, TType.I32, 'status', None, None, ), # 10
(11, TType.STRING, 'statusmsg', None, None, ), # 11
(12, TType.STRING, 'format_wait', None, None, ), # 12
@@ -256,97 +314,159 @@ class ServerStatus(TBase):
self.reconnect = reconnect
-class FileData(TBase):
+class DownloadInfo(TBase):
"""
Attributes:
- - fid
- url
- - name
- plugin
- - size
- - format_size
+ - hash
- status
- statusmsg
- - packageID
- error
- - order
"""
__slots__ = [
- 'fid',
'url',
- 'name',
'plugin',
- 'size',
- 'format_size',
+ 'hash',
'status',
'statusmsg',
- 'packageID',
'error',
- 'order',
]
thrift_spec = (
None, # 0
- (1, TType.I32, 'fid', None, None, ), # 1
- (2, TType.STRING, 'url', None, None, ), # 2
- (3, TType.STRING, 'name', None, None, ), # 3
- (4, TType.STRING, 'plugin', None, None, ), # 4
- (5, TType.I64, 'size', None, None, ), # 5
- (6, TType.STRING, 'format_size', None, None, ), # 6
- (7, TType.I32, 'status', None, None, ), # 7
- (8, TType.STRING, 'statusmsg', None, None, ), # 8
- (9, TType.I32, 'packageID', None, None, ), # 9
- (10, TType.STRING, 'error', None, None, ), # 10
- (11, TType.I16, 'order', None, None, ), # 11
+ (1, TType.STRING, 'url', None, None, ), # 1
+ (2, TType.STRING, 'plugin', None, None, ), # 2
+ (3, TType.STRING, 'hash', None, None, ), # 3
+ (4, TType.I32, 'status', None, None, ), # 4
+ (5, TType.STRING, 'statusmsg', None, None, ), # 5
+ (6, TType.STRING, 'error', None, None, ), # 6
)
- 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
+ def __init__(self, url=None, plugin=None, hash=None, status=None, statusmsg=None, error=None,):
self.url = url
- self.name = name
self.plugin = plugin
- self.size = size
- self.format_size = format_size
+ self.hash = hash
self.status = status
self.statusmsg = statusmsg
- self.packageID = packageID
self.error = error
- self.order = order
-class PackageData(TBase):
+class FileInfo(TBase):
+ """
+ Attributes:
+ - fid
+ - name
+ - package
+ - size
+ - status
+ - media
+ - added
+ - fileorder
+ - download
+ """
+
+ __slots__ = [
+ 'fid',
+ 'name',
+ 'package',
+ 'size',
+ 'status',
+ 'media',
+ 'added',
+ 'fileorder',
+ 'download',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I32, 'fid', None, None, ), # 1
+ (2, TType.STRING, 'name', None, None, ), # 2
+ (3, TType.I32, 'package', None, None, ), # 3
+ (4, TType.I64, 'size', None, None, ), # 4
+ (5, TType.I32, 'status', None, None, ), # 5
+ (6, TType.I32, 'media', None, None, ), # 6
+ (7, TType.I64, 'added', None, None, ), # 7
+ (8, TType.I16, 'fileorder', None, None, ), # 8
+ (9, TType.STRUCT, 'download', (DownloadInfo, DownloadInfo.thrift_spec), None, ), # 9
+ )
+
+ def __init__(self, fid=None, name=None, package=None, size=None, status=None, media=None, added=None, fileorder=None, download=None,):
+ self.fid = fid
+ self.name = name
+ self.package = package
+ self.size = size
+ self.status = status
+ self.media = media
+ self.added = added
+ self.fileorder = fileorder
+ self.download = download
+
+
+class PackageStats(TBase):
+ """
+ Attributes:
+ - linkstotal
+ - linksdone
+ - sizetotal
+ - sizedone
+ """
+
+ __slots__ = [
+ 'linkstotal',
+ 'linksdone',
+ 'sizetotal',
+ 'sizedone',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I16, 'linkstotal', None, None, ), # 1
+ (2, TType.I16, 'linksdone', None, None, ), # 2
+ (3, TType.I64, 'sizetotal', None, None, ), # 3
+ (4, TType.I64, 'sizedone', None, None, ), # 4
+ )
+
+ def __init__(self, linkstotal=None, linksdone=None, sizetotal=None, sizedone=None,):
+ self.linkstotal = linkstotal
+ self.linksdone = linksdone
+ self.sizetotal = sizetotal
+ self.sizedone = sizedone
+
+
+class PackageInfo(TBase):
"""
Attributes:
- pid
- name
- folder
+ - root
- site
+ - comment
- password
- - dest
- - order
- - linksdone
- - sizedone
- - sizetotal
- - linkstotal
- - links
+ - added
+ - status
+ - packageorder
+ - stats
- fids
+ - pids
"""
__slots__ = [
'pid',
'name',
'folder',
+ 'root',
'site',
+ 'comment',
'password',
- 'dest',
- 'order',
- 'linksdone',
- 'sizedone',
- 'sizetotal',
- 'linkstotal',
- 'links',
+ 'added',
+ 'status',
+ 'packageorder',
+ 'stats',
'fids',
+ 'pids',
]
thrift_spec = (
@@ -354,32 +474,98 @@ class PackageData(TBase):
(1, TType.I32, 'pid', None, None, ), # 1
(2, TType.STRING, 'name', None, None, ), # 2
(3, TType.STRING, 'folder', None, None, ), # 3
- (4, TType.STRING, 'site', None, None, ), # 4
- (5, TType.STRING, 'password', None, None, ), # 5
- (6, TType.I32, 'dest', None, None, ), # 6
- (7, TType.I16, 'order', None, None, ), # 7
- (8, TType.I16, 'linksdone', None, None, ), # 8
- (9, TType.I64, 'sizedone', None, None, ), # 9
- (10, TType.I64, 'sizetotal', None, None, ), # 10
- (11, TType.I16, 'linkstotal', None, None, ), # 11
- (12, TType.LIST, 'links', (TType.STRUCT,(FileData, FileData.thrift_spec)), None, ), # 12
- (13, TType.LIST, 'fids', (TType.I32,None), None, ), # 13
+ (4, TType.I32, 'root', None, None, ), # 4
+ (5, TType.STRING, 'site', None, None, ), # 5
+ (6, TType.STRING, 'comment', None, None, ), # 6
+ (7, TType.STRING, 'password', None, None, ), # 7
+ (8, TType.I64, 'added', None, None, ), # 8
+ (9, TType.I32, 'status', None, None, ), # 9
+ (10, TType.I16, 'packageorder', None, None, ), # 10
+ (11, TType.STRUCT, 'stats', (PackageStats, PackageStats.thrift_spec), None, ), # 11
+ (12, TType.LIST, 'fids', (TType.I32,None), None, ), # 12
+ (13, TType.LIST, 'pids', (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,):
+ def __init__(self, pid=None, name=None, folder=None, root=None, site=None, comment=None, password=None, added=None, status=None, packageorder=None, stats=None, fids=None, pids=None,):
self.pid = pid
self.name = name
self.folder = folder
+ self.root = root
self.site = site
+ self.comment = comment
self.password = password
- self.dest = dest
- self.order = order
- self.linksdone = linksdone
- self.sizedone = sizedone
- self.sizetotal = sizetotal
- self.linkstotal = linkstotal
- self.links = links
+ self.added = added
+ self.status = status
+ self.packageorder = packageorder
+ self.stats = stats
self.fids = fids
+ self.pids = pids
+
+
+class PackageView(TBase):
+ """
+ Attributes:
+ - root
+ - files
+ - packages
+ """
+
+ __slots__ = [
+ 'root',
+ 'files',
+ 'packages',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'root', (PackageInfo, PackageInfo.thrift_spec), None, ), # 1
+ (2, TType.MAP, 'files', (TType.I32,None,TType.STRUCT,(FileInfo, FileInfo.thrift_spec)), None, ), # 2
+ (3, TType.MAP, 'packages', (TType.I32,None,TType.STRUCT,(PackageInfo, PackageInfo.thrift_spec)), None, ), # 3
+ )
+
+ def __init__(self, root=None, files=None, packages=None,):
+ self.root = root
+ self.files = files
+ self.packages = packages
+
+
+class LinkStatus(TBase):
+ """
+ Attributes:
+ - url
+ - name
+ - plugin
+ - size
+ - status
+ - packagename
+ """
+
+ __slots__ = [
+ 'url',
+ 'name',
+ 'plugin',
+ 'size',
+ 'status',
+ 'packagename',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'url', None, None, ), # 1
+ (2, TType.STRING, 'name', None, None, ), # 2
+ (3, TType.STRING, 'plugin', None, None, ), # 3
+ (4, TType.I64, 'size', None, None, ), # 4
+ (5, TType.I32, 'status', None, None, ), # 5
+ (6, TType.STRING, 'packagename', None, None, ), # 6
+ )
+
+ def __init__(self, url=None, name=None, plugin=None, size=None, status=None, packagename=None,):
+ self.url = url
+ self.name = name
+ self.plugin = plugin
+ self.size = size
+ self.status = status
+ self.packagename = packagename
class InteractionTask(TBase):
@@ -387,10 +573,9 @@ class InteractionTask(TBase):
Attributes:
- iid
- input
- - structure
- - preset
- - output
- data
+ - output
+ - default_value
- title
- description
- plugin
@@ -399,10 +584,9 @@ class InteractionTask(TBase):
__slots__ = [
'iid',
'input',
- 'structure',
- 'preset',
- 'output',
'data',
+ 'output',
+ 'default_value',
'title',
'description',
'plugin',
@@ -412,32 +596,57 @@ class InteractionTask(TBase):
None, # 0
(1, TType.I32, 'iid', None, None, ), # 1
(2, TType.I32, 'input', None, None, ), # 2
- (3, TType.LIST, 'structure', (TType.STRING,None), None, ), # 3
- (4, TType.LIST, 'preset', (TType.STRING,None), None, ), # 4
- (5, TType.I32, 'output', None, None, ), # 5
- (6, TType.LIST, 'data', (TType.STRING,None), None, ), # 6
- (7, TType.STRING, 'title', None, None, ), # 7
- (8, TType.STRING, 'description', None, None, ), # 8
- (9, TType.STRING, 'plugin', None, None, ), # 9
+ (3, TType.LIST, 'data', (TType.STRING,None), None, ), # 3
+ (4, TType.I32, 'output', None, None, ), # 4
+ (5, TType.STRING, 'default_value', None, None, ), # 5
+ (6, TType.STRING, 'title', None, None, ), # 6
+ (7, TType.STRING, 'description', None, None, ), # 7
+ (8, TType.STRING, 'plugin', None, None, ), # 8
)
- def __init__(self, iid=None, input=None, structure=None, preset=None, output=None, data=None, title=None, description=None, plugin=None,):
+ def __init__(self, iid=None, input=None, data=None, output=None, default_value=None, title=None, description=None, plugin=None,):
self.iid = iid
self.input = input
- self.structure = structure
- self.preset = preset
- self.output = output
self.data = data
+ self.output = output
+ self.default_value = default_value
self.title = title
self.description = description
self.plugin = plugin
+class AddonInfo(TBase):
+ """
+ Attributes:
+ - func_name
+ - description
+ - value
+ """
+
+ __slots__ = [
+ 'func_name',
+ 'description',
+ 'value',
+ ]
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'func_name', None, None, ), # 1
+ (2, TType.STRING, 'description', None, None, ), # 2
+ (3, TType.STRING, 'value', None, None, ), # 3
+ )
+
+ def __init__(self, func_name=None, description=None, value=None,):
+ self.func_name = func_name
+ self.description = description
+ self.value = value
+
+
class ConfigItem(TBase):
"""
Attributes:
- name
- - long_name
+ - display_name
- description
- type
- default_value
@@ -446,7 +655,7 @@ class ConfigItem(TBase):
__slots__ = [
'name',
- 'long_name',
+ 'display_name',
'description',
'type',
'default_value',
@@ -456,16 +665,16 @@ class ConfigItem(TBase):
thrift_spec = (
None, # 0
(1, TType.STRING, 'name', None, None, ), # 1
- (2, TType.STRING, 'long_name', None, None, ), # 2
+ (2, TType.STRING, 'display_name', None, None, ), # 2
(3, TType.STRING, 'description', None, None, ), # 3
(4, TType.STRING, 'type', None, None, ), # 4
(5, TType.STRING, 'default_value', None, None, ), # 5
(6, TType.STRING, 'value', None, None, ), # 6
)
- def __init__(self, name=None, long_name=None, description=None, type=None, default_value=None, value=None,):
+ def __init__(self, name=None, display_name=None, description=None, type=None, default_value=None, value=None,):
self.name = name
- self.long_name = long_name
+ self.display_name = display_name
self.description = description
self.type = type
self.default_value = default_value
@@ -476,72 +685,45 @@ class ConfigSection(TBase):
"""
Attributes:
- name
- - long_name
+ - display_name
- description
- long_description
- items
+ - info
- handler
"""
__slots__ = [
'name',
- 'long_name',
+ 'display_name',
'description',
'long_description',
'items',
+ 'info',
'handler',
]
thrift_spec = (
None, # 0
(1, TType.STRING, 'name', None, None, ), # 1
- (2, TType.STRING, 'long_name', None, None, ), # 2
+ (2, TType.STRING, 'display_name', None, None, ), # 2
(3, TType.STRING, 'description', None, None, ), # 3
(4, TType.STRING, 'long_description', None, None, ), # 4
(5, TType.LIST, 'items', (TType.STRUCT,(ConfigItem, ConfigItem.thrift_spec)), None, ), # 5
- (6, TType.MAP, 'handler', (TType.STRING,None,TType.STRUCT,(InteractionTask, InteractionTask.thrift_spec)), None, ), # 6
+ (6, TType.LIST, 'info', (TType.STRUCT,(AddonInfo, AddonInfo.thrift_spec)), None, ), # 6
+ (7, TType.LIST, 'handler', (TType.STRUCT,(InteractionTask, InteractionTask.thrift_spec)), None, ), # 7
)
- def __init__(self, name=None, long_name=None, description=None, long_description=None, items=None, handler=None,):
+ def __init__(self, name=None, display_name=None, description=None, long_description=None, items=None, info=None, handler=None,):
self.name = name
- self.long_name = long_name
+ self.display_name = display_name
self.description = description
self.long_description = long_description
self.items = items
+ self.info = info
self.handler = handler
-class CaptchaTask(TBase):
- """
- Attributes:
- - tid
- - data
- - type
- - resultType
- """
-
- __slots__ = [
- 'tid',
- 'data',
- 'type',
- 'resultType',
- ]
-
- thrift_spec = (
- None, # 0
- (1, TType.I16, 'tid', None, None, ), # 1
- (2, TType.STRING, 'data', None, None, ), # 2
- (3, TType.STRING, 'type', None, None, ), # 3
- (4, TType.STRING, 'resultType', None, None, ), # 4
- )
-
- def __init__(self, tid=None, data=None, type=None, resultType=None,):
- self.tid = tid
- self.data = data
- self.type = type
- self.resultType = resultType
-
-
class EventInfo(TBase):
"""
Attributes:
@@ -636,7 +818,7 @@ class AccountInfo(TBase):
(6, TType.I64, 'maxtraffic', None, None, ), # 6
(7, TType.BOOL, 'premium', None, None, ), # 7
(8, TType.BOOL, 'activated', None, None, ), # 8
- (9, TType.MAP, 'options', (TType.STRING,None,TType.LIST,(TType.STRING,None)), None, ), # 9
+ (9, TType.MAP, 'options', (TType.STRING,None,TType.STRING,None), None, ), # 9
)
def __init__(self, plugin=None, loginname=None, valid=None, validuntil=None, trafficleft=None, maxtraffic=None, premium=None, activated=None, options=None,):
@@ -651,66 +833,35 @@ class AccountInfo(TBase):
self.options = options
-class ServiceCall(TBase):
+class AddonService(TBase):
"""
Attributes:
- - plugin
- - func
- - arguments
- """
-
- __slots__ = [
- 'plugin',
- 'func',
- 'arguments',
- ]
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'plugin', None, None, ), # 1
- (2, TType.STRING, 'func', None, None, ), # 2
- (3, TType.STRING, 'arguments', None, None, ), # 3
- )
-
- def __init__(self, plugin=None, func=None, arguments=None,):
- self.plugin = plugin
- self.func = func
- self.arguments = arguments
-
-
-class OnlineStatus(TBase):
- """
- Attributes:
- - name
- - plugin
- - packagename
- - status
- - size
+ - func_name
+ - description
+ - media
+ - package
"""
__slots__ = [
- 'name',
- 'plugin',
- 'packagename',
- 'status',
- 'size',
+ 'func_name',
+ 'description',
+ 'media',
+ 'package',
]
thrift_spec = (
None, # 0
- (1, TType.STRING, 'name', None, None, ), # 1
- (2, TType.STRING, 'plugin', None, None, ), # 2
- (3, TType.STRING, 'packagename', None, None, ), # 3
- (4, TType.I32, 'status', None, None, ), # 4
- (5, TType.I64, 'size', None, None, ), # 5
+ (1, TType.STRING, 'func_name', None, None, ), # 1
+ (2, TType.STRING, 'description', None, None, ), # 2
+ (3, TType.I16, 'media', None, None, ), # 3
+ (4, TType.BOOL, 'package', None, None, ), # 4
)
- def __init__(self, name=None, plugin=None, packagename=None, status=None, size=None,):
- self.name = name
- self.plugin = plugin
- self.packagename = packagename
- self.status = status
- self.size = size
+ def __init__(self, func_name=None, description=None, media=None, package=None,):
+ self.func_name = func_name
+ self.description = description
+ self.media = media
+ self.package = package
class OnlineCheck(TBase):
@@ -728,7 +879,7 @@ class OnlineCheck(TBase):
thrift_spec = (
None, # 0
(1, TType.I32, 'rid', None, None, ), # 1
- (2, TType.MAP, 'data', (TType.STRING,None,TType.STRUCT,(OnlineStatus, OnlineStatus.thrift_spec)), None, ), # 2
+ (2, TType.MAP, 'data', (TType.STRING,None,TType.STRUCT,(LinkStatus, LinkStatus.thrift_spec)), None, ), # 2
)
def __init__(self, rid=None, data=None,):