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

fix support reorg error

Browse source
This commit is contained in:
Lex Berezhny 2019-06-23 10:56:59 -04:00
parent 2b514a9df7
commit 816cde32a9
2 changed files with 29 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lbry/lbry/wallet/server/db.py
View file

@ -394,7 +394,7 @@ class SQLDB:
))
if supports:
self.db.executemany(
"INSERT INTO support ("
"INSERT OR IGNORE INTO support ("
" txo_hash, tx_position, height, claim_hash, amount"
") "
"VALUES (?, ?, ?, ?, ?)", supports

34
lbry/tests/integration/test_resolve_command.py
View file

@ -322,18 +322,40 @@ class ResolveAfterReorg(BaseResolveTestCase):
async def test_reorg(self):
self.assertEqual(self.ledger.headers.height, 206)
name = '@abc'
channel_name = '@abc'
channel_id = self.get_claim_id(
await self.channel_create(name, '0.01')
await self.channel_create(channel_name, '0.01')
)
self.assertNotIn('error', (await self.resolve(name))[name])
self.assertNotIn('error', (await self.resolve(channel_name))[channel_name])
await self.reorg(206)
self.assertNotIn('error', (await self.resolve(name))[name])
self.assertNotIn('error', (await self.resolve(channel_name))[channel_name])
stream_name = 'foo'
stream_id = self.get_claim_id(
await self.stream_create(stream_name, '0.01', channel_id=channel_id)
)
self.assertNotIn('error', (await self.resolve(stream_name))[stream_name])
await self.reorg(206)
self.assertNotIn('error', (await self.resolve(stream_name))[stream_name])
await self.support_create(stream_id, '0.01')
self.assertNotIn('error', (await self.resolve(stream_name))[stream_name])
await self.reorg(206)
self.assertNotIn('error', (await self.resolve(stream_name))[stream_name])
await self.stream_abandon(stream_id)
self.assertNotIn('error', (await self.resolve(channel_name))[channel_name])
self.assertIn('error', (await self.resolve(stream_name))[stream_name])
await self.reorg(206)
self.assertNotIn('error', (await self.resolve(channel_name))[channel_name])
self.assertIn('error', (await self.resolve(stream_name))[stream_name])
await self.channel_abandon(channel_id)
self.assertIn('error', (await self.resolve(name))[name])
self.assertIn('error', (await self.resolve(channel_name))[channel_name])
self.assertIn('error', (await self.resolve(stream_name))[stream_name])
await self.reorg(206)
self.assertIn('error', (await self.resolve(name))[name])
self.assertIn('error', (await self.resolve(channel_name))[channel_name])
self.assertIn('error', (await self.resolve(stream_name))[stream_name])
def generate_signed_legacy(address: bytes, output: Output):