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

claim_list doesnt blow up

Browse source
This commit is contained in:
Lex Berezhny 2019-07-16 21:08:31 -04:00
parent 578f8f4062
commit e4aeb66257
1 changed files with 20 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -3416,7 +3416,7 @@ class Daemon(metaclass=JSONRPCServerType):
] ]
} }
""" """
cmnt_list: dict = await jsonrpc_post( result = await jsonrpc_post(
self.conf.comment_server, self.conf.comment_server,
"get_claim_comments", "get_claim_comments",
claim_id=claim_id, claim_id=claim_id,
@ -3425,20 +3425,25 @@ class Daemon(metaclass=JSONRPCServerType):
page_size=page_size, page_size=page_size,
top_level=not include_replies top_level=not include_replies
) )
if cmnt_list.get('items', None):
items = cmnt_list['items'] for comment in result.get('items', []):
chnl_uris = {cmnt['channel_url'] for cmnt in items if 'channel_url' in cmnt} channel_url = comment.get('channel_url')
claims = await self.resolve(tuple(chnl_uris)) if not channel_url:
for cmnt in cmnt_list['items']:
if 'channel_url' in cmnt:
if cmnt['channel_url'] in claims:
channel = claims[cmnt['channel_url']]
cmnt['is_channel_signature_valid'] = is_comment_signed_by_channel(cmnt, channel)
continue continue
cmnt['is_channel_signature_valid'] = False resolve_response = await self.resolve([channel_url])
if 'error' not in resolve_response[channel_url]:
comment['is_channel_signature_valid'] = is_comment_signed_by_channel(
comment, resolve_response[channel_url]
)
else:
comment['is_channel_signature_valid'] = False
if is_channel_signature_valid: if is_channel_signature_valid:
cmnt_list['items'] = [c for c in cmnt_list['items'] if c['is_channel_signature_valid']] result['items'] = [
return cmnt_list c for c in result.get('items', []) if c['is_channel_signature_valid']
]
return result
async def jsonrpc_comment_create(self, claim_id, comment, parent_id=None, channel_account_id=None, async def jsonrpc_comment_create(self, claim_id, comment, parent_id=None, channel_account_id=None,
channel_name=None, channel_id=None) -> dict: channel_name=None, channel_id=None) -> dict: