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

apply refactor suggested on review by removing .out calls

Browse source
This commit is contained in:
Victor Shyba 2019-11-11 01:20:14 -03:00 • committed by Lex Berezhny
parent 745bc24343
commit 423b48866f
1 changed files with 17 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
lbry/tests/integration/test_claim_commands.py
View file

@ -710,19 +710,19 @@ class StreamCommands(ClaimTestCase):
) )
async def test_preview_works_with_signed_streams(self): async def test_preview_works_with_signed_streams(self):
await self.out(self.channel_create('@spam', '1.0')) await self.channel_create('@spam', '1.0')
signed = await self.out(self.stream_create('bar', '1.0', channel_name='@spam', preview=True, confirm=False)) signed = await self.stream_create('bar', '1.0', channel_name='@spam', preview=True, confirm=False)
self.assertTrue(signed['outputs'][0]['is_channel_signature_valid']) self.assertTrue(signed['outputs'][0]['is_channel_signature_valid'])
async def test_repost(self): async def test_repost(self):
await self.out(self.channel_create('@goodies', '1.0')) await self.channel_create('@goodies', '1.0')
tx = await self.out(self.stream_create('newstuff', '1.1', channel_name='@goodies')) tx = await self.stream_create('newstuff', '1.1', channel_name='@goodies')
claim_id = tx['outputs'][0]['claim_id'] claim_id = tx['outputs'][0]['claim_id']
await self.stream_repost(claim_id, 'newstuff-again', '1.1') await self.stream_repost(claim_id, 'newstuff-again', '1.1')
claim_list = (await self.out(self.daemon.jsonrpc_claim_list()))['items'] claim_list = (await self.out(self.daemon.jsonrpc_claim_list()))['items']
reposts_on_claim_list = [claim for claim in claim_list if claim['value_type'] == 'repost'] reposts_on_claim_list = [claim for claim in claim_list if claim['value_type'] == 'repost']
self.assertEqual(len(reposts_on_claim_list), 1) self.assertEqual(len(reposts_on_claim_list), 1)
await self.out(self.channel_create('@reposting-goodies', '1.0')) await self.channel_create('@reposting-goodies', '1.0')
await self.stream_repost(claim_id, 'repost-on-channel', '1.1', channel_name='@reposting-goodies') await self.stream_repost(claim_id, 'repost-on-channel', '1.1', channel_name='@reposting-goodies')
claim_list = (await self.out(self.daemon.jsonrpc_claim_list()))['items'] claim_list = (await self.out(self.daemon.jsonrpc_claim_list()))['items']
reposts_on_claim_list = [claim for claim in claim_list if claim['value_type'] == 'repost'] reposts_on_claim_list = [claim for claim in claim_list if claim['value_type'] == 'repost']
@ -757,14 +757,14 @@ class StreamCommands(ClaimTestCase):
) )
async def test_filtering_channels_for_removing_content(self): async def test_filtering_channels_for_removing_content(self):
await self.out(self.channel_create('@badstuff', '1.0')) await self.channel_create('@badstuff', '1.0')
await self.out(self.stream_create('not_bad', '1.1', channel_name='@badstuff')) await self.stream_create('not_bad', '1.1', channel_name='@badstuff')
tx = await self.out(self.stream_create('too_bad', '1.1', channel_name='@badstuff')) tx = await self.stream_create('too_bad', '1.1', channel_name='@badstuff')
claim_id = tx['outputs'][0]['claim_id'] claim_id = self.get_claim_id(tx)
await self.out(self.channel_create('@reposts', '1.0')) await self.channel_create('@reposts', '1.0')
await self.stream_repost(claim_id, 'normal_repost', '1.2', channel_name='@reposts') await self.stream_repost(claim_id, 'normal_repost', '1.2', channel_name='@reposts')
filtering1 = await self.out(self.channel_create('@filtering1', '1.0')) filtering1 = await self.channel_create('@filtering1', '1.0')
filtering1 = filtering1['outputs'][0]['claim_id'] filtering1 = self.get_claim_id(filtering1)
await self.stream_repost(claim_id, 'filter1', '1.1', channel_name='@filtering1') await self.stream_repost(claim_id, 'filter1', '1.1', channel_name='@filtering1')
await self.conductor.spv_node.stop() await self.conductor.spv_node.stop()
await self.conductor.spv_node.start( await self.conductor.spv_node.start(
@ -776,9 +776,11 @@ class StreamCommands(ClaimTestCase):
self.assertEqual(filtered_claim_search, []) self.assertEqual(filtered_claim_search, [])
filtered_claim_search = await self.claim_search(name='not_bad') filtered_claim_search = await self.claim_search(name='not_bad')
self.assertEqual(len(filtered_claim_search), 1) self.assertEqual(len(filtered_claim_search), 1)
filtered_claim_search = await self.claim_search(name='normal_repost')
self.assertEqual(len(filtered_claim_search), 1)
async def test_publish_updates_file_list(self): async def test_publish_updates_file_list(self):
tx = await self.out(self.stream_create(title='created')) tx = await self.stream_create(title='created')
txo = tx['outputs'][0] txo = tx['outputs'][0]
claim_id, expected = txo['claim_id'], txo['value'] claim_id, expected = txo['claim_id'], txo['value']
files = await self.file_list() files = await self.file_list()
@ -787,7 +789,7 @@ class StreamCommands(ClaimTestCase):
self.assertEqual(expected, files[0]['metadata']) self.assertEqual(expected, files[0]['metadata'])
# update with metadata-only changes # update with metadata-only changes
tx = await self.out(self.stream_update(claim_id, title='update 1')) tx = await self.stream_update(claim_id, title='update 1')
files = await self.file_list() files = await self.file_list()
expected['title'] = 'update 1' expected['title'] = 'update 1'
self.assertEqual(1, len(files)) self.assertEqual(1, len(files))
@ -795,7 +797,7 @@ class StreamCommands(ClaimTestCase):
self.assertEqual(expected, files[0]['metadata']) self.assertEqual(expected, files[0]['metadata'])
# update with new data # update with new data
tx = await self.out(self.stream_update(claim_id, title='update 2', data=b'updated data')) tx = await self.stream_update(claim_id, title='update 2', data=b'updated data')
expected = tx['outputs'][0]['value'] expected = tx['outputs'][0]['value']
files = await self.file_list() files = await self.file_list()
self.assertEqual(1, len(files)) self.assertEqual(1, len(files))