Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

paginates file_list

Browse source
This commit is contained in:
Oleg Silkin 2019-08-28 13:33:17 -04:00 committed by Lex Berezhny
parent 4a8b96a6d2
commit 7c074e1cd4
1 changed files with 21 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
lbry/lbry/extras/daemon/Daemon.py
View file

@ -1763,7 +1763,7 @@ class Daemon(metaclass=JSONRPCServerType):
""" """
@requires(STREAM_MANAGER_COMPONENT) @requires(STREAM_MANAGER_COMPONENT)
def jsonrpc_file_list(self, sort=None, reverse=False, comparison=None, **kwargs): def jsonrpc_file_list(self, sort=None, reverse=False, comparison=None, page=None, page_size=None, **kwargs):
""" """
List files limited by optional filters List files limited by optional filters
@ -1774,6 +1774,7 @@ class Daemon(metaclass=JSONRPCServerType):
[--claim_name=<claim_name>] [--blobs_in_stream=<blobs_in_stream>] [--claim_name=<claim_name>] [--blobs_in_stream=<blobs_in_stream>]
[--blobs_remaining=<blobs_remaining>] [--sort=<sort_by>] [--blobs_remaining=<blobs_remaining>] [--sort=<sort_by>]
[--comparison=<comparison>] [--full_status=<full_status>] [--reverse] [--comparison=<comparison>] [--full_status=<full_status>] [--reverse]
[--page=<page>] [--page_size=<page_size>]
Options: Options:
--sd_hash=<sd_hash> : (str) get file with matching sd hash --sd_hash=<sd_hash> : (str) get file with matching sd hash
@ -1792,15 +1793,32 @@ class Daemon(metaclass=JSONRPCServerType):
--blobs_remaining=<blobs_remaining> : (int) amount of remaining blobs to download --blobs_remaining=<blobs_remaining> : (int) amount of remaining blobs to download
--sort=<sort_by> : (str) field to sort by (one of the above filter fields) --sort=<sort_by> : (str) field to sort by (one of the above filter fields)
--comparison=<comparison> : (str) logical comparison, (eq | ne | g | ge | l | le) --comparison=<comparison> : (str) logical comparison, (eq | ne | g | ge | l | le)
--page=<page> : (int) page to view within paginated output
--page_size=<page_size> : (int) size of each page within paginated output
Returns: {List[File]} Returns: {Paginated[Output]}
""" """
sort = sort or 'rowid' sort = sort or 'rowid'
comparison = comparison or 'eq' comparison = comparison or 'eq'
return self.stream_manager.get_filtered_streams(
file_list = self.stream_manager.get_filtered_streams(
sort, reverse, comparison, **kwargs sort, reverse, comparison, **kwargs
) )
if None not in (page, page_size):
total_items = len(file_list)
offset = page_size * (page-1)
return {
'total_items': total_items,
'total_pages': int((total_items + (page_size-1)) / page_size),
'page': page,
'page_size': page_size,
'items': file_list[offset:offset+page_size]
}
return file_list
@requires(STREAM_MANAGER_COMPONENT) @requires(STREAM_MANAGER_COMPONENT)
async def jsonrpc_file_set_status(self, status, **kwargs): async def jsonrpc_file_set_status(self, status, **kwargs):
""" """