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

fixes #3166

Browse source
This commit is contained in:
Lex Berezhny 2021-01-25 10:14:34 -05:00
parent 24c9a167d7
commit eedcc2034d
2 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lbry/wallet/database.py
View file

@ -704,6 +704,9 @@ class Database(SQLiteMixin):
row['txo_type'] = TXO_TYPES['stream'] row['txo_type'] = TXO_TYPES['stream']
elif txo.is_support: elif txo.is_support:
row['txo_type'] = TXO_TYPES['support'] row['txo_type'] = TXO_TYPES['support']
support = txo.can_decode_support
if support and support.is_signed:
row['channel_id'] = support.signing_channel_id
elif txo.purchase is not None: elif txo.purchase is not None:
row['txo_type'] = TXO_TYPES['purchase'] row['txo_type'] = TXO_TYPES['purchase']
row['claim_id'] = txo.purchased_claim_id row['claim_id'] = txo.purchased_claim_id

7
tests/integration/blockchain/test_claim_commands.py
View file

@ -468,6 +468,8 @@ class TransactionOutputCommands(ClaimTestCase):
stream_b = self.get_claim_id(await self.stream_create('b', channel_id=channel_foo)) stream_b = self.get_claim_id(await self.stream_create('b', channel_id=channel_foo))
stream_c = self.get_claim_id(await self.stream_create('c', channel_id=channel_bar)) stream_c = self.get_claim_id(await self.stream_create('c', channel_id=channel_bar))
stream_d = self.get_claim_id(await self.stream_create('d')) stream_d = self.get_claim_id(await self.stream_create('d'))
support_c = await self.support_create(stream_c, '0.3', channel_id=channel_foo)
support_d = await self.support_create(stream_d, '0.3', channel_id=channel_bar)
r = await self.txo_list(type='stream') r = await self.txo_list(type='stream')
self.assertEqual({stream_a, stream_b, stream_c, stream_d}, {c['claim_id'] for c in r}) self.assertEqual({stream_a, stream_b, stream_c, stream_d}, {c['claim_id'] for c in r})
@ -475,6 +477,11 @@ class TransactionOutputCommands(ClaimTestCase):
r = await self.txo_list(type='stream', channel_id=channel_foo) r = await self.txo_list(type='stream', channel_id=channel_foo)
self.assertEqual({stream_a, stream_b}, {c['claim_id'] for c in r}) self.assertEqual({stream_a, stream_b}, {c['claim_id'] for c in r})
r = await self.txo_list(type='support', channel_id=channel_foo)
self.assertEqual({support_c['txid']}, {s['txid'] for s in r})
r = await self.txo_list(type='support', channel_id=channel_bar)
self.assertEqual({support_d['txid']}, {s['txid'] for s in r})
r = await self.txo_list(type='stream', channel_id=[channel_foo, channel_bar]) r = await self.txo_list(type='stream', channel_id=[channel_foo, channel_bar])
self.assertEqual({stream_a, stream_b, stream_c}, {c['claim_id'] for c in r}) self.assertEqual({stream_a, stream_b, stream_c}, {c['claim_id'] for c in r})