lbry-sdk/tests/integration/wallet/test_transactions.py

98 lines
3.7 KiB
Python
Raw Normal View History

2018-11-04 07:24:41 +01:00
import logging
2018-06-12 17:53:29 +02:00
import asyncio
2018-11-04 07:24:41 +01:00
from torba.testcase import IntegrationTestCase
from lbrynet.schema.claim import ClaimDict
from lbrynet.extras.wallet.transaction import Transaction
from lbrynet.extras.wallet.account import generate_certificate
from lbrynet.extras.wallet.dewies import dewies_to_lbc as d2l, lbc_to_dewies as l2d
import lbrynet.schema
lbrynet.schema.BLOCKCHAIN_NAME = 'lbrycrd_regtest'
2018-06-12 17:53:29 +02:00
example_claim_dict = {
"version": "_0_0_1",
"claimType": "streamType",
"stream": {
"source": {
"source": "d5169241150022f996fa7cd6a9a1c421937276a3275eb912790bd07ba7aec1fac5fd45431d226b8fb402691e79aeb24b",
"version": "_0_0_1",
"contentType": "video/mp4",
"sourceType": "lbry_sd_hash"
},
"version": "_0_0_1",
"metadata": {
"license": "LBRY Inc",
"description": "What is LBRY? An introduction with Alex Tabarrok",
"language": "en",
"title": "What is LBRY?",
"author": "Samuel Bryan",
"version": "_0_1_0",
"nsfw": False,
"licenseUrl": "",
"preview": "",
"thumbnail": "https://s3.amazonaws.com/files.lbry.io/logo.png"
}
}
}
class BasicTransactionTest(IntegrationTestCase):
2018-06-12 17:53:29 +02:00
2018-11-04 07:24:41 +01:00
VERBOSITY = logging.WARN
2018-06-12 17:53:29 +02:00
async def test_creating_updating_and_abandoning_claim_with_channel(self):
2018-06-12 17:53:29 +02:00
2018-10-15 23:16:43 +02:00
await self.account.ensure_address_gap()
2018-06-12 17:53:29 +02:00
2018-10-15 23:16:43 +02:00
address1, address2 = await self.account.receiving.get_addresses(limit=2, only_usable=True)
2018-07-15 05:03:51 +02:00
sendtxid1 = await self.blockchain.send_to_address(address1, 5)
sendtxid2 = await self.blockchain.send_to_address(address2, 5)
2018-06-14 07:32:11 +02:00
await self.blockchain.generate(1)
await asyncio.wait([
self.on_transaction_id(sendtxid1),
2018-10-17 03:28:47 +02:00
self.on_transaction_id(sendtxid2)
])
2018-06-14 07:32:11 +02:00
2018-10-15 23:16:43 +02:00
self.assertEqual(d2l(await self.account.get_balance()), '10.0')
2018-06-12 17:53:29 +02:00
cert, key = generate_certificate()
2018-10-15 23:16:43 +02:00
cert_tx = await Transaction.claim('@bar', cert, l2d('1.0'), address1, [self.account], self.account)
2018-06-12 17:53:29 +02:00
claim = ClaimDict.load_dict(example_claim_dict)
claim = claim.sign(key, address1, cert_tx.outputs[0].claim_id)
2018-10-15 23:16:43 +02:00
claim_tx = await Transaction.claim('foo', claim, l2d('1.0'), address1, [self.account], self.account)
await self.broadcast(cert_tx)
await self.broadcast(claim_tx)
await asyncio.wait([ # mempool
2018-10-10 03:32:32 +02:00
self.on_transaction(claim_tx),
2018-10-17 03:28:47 +02:00
self.on_transaction(cert_tx)
])
2018-06-14 07:32:11 +02:00
await self.blockchain.generate(1)
await asyncio.wait([ # confirmed
2018-10-10 03:32:32 +02:00
self.on_transaction(claim_tx),
2018-10-17 03:28:47 +02:00
self.on_transaction(cert_tx)
])
2018-06-12 17:53:29 +02:00
2018-10-17 03:28:47 +02:00
self.assertEqual(d2l(await self.account.get_balance()), '7.985786')
2018-10-15 23:16:43 +02:00
self.assertEqual(d2l(await self.account.get_balance(include_claims=True)), '9.985786')
2018-06-12 17:53:29 +02:00
2018-10-15 23:16:43 +02:00
response = await self.ledger.resolve(0, 10, 'lbry://@bar/foo')
self.assertIn('lbry://@bar/foo', response)
2018-08-04 03:27:08 +02:00
self.assertIn('claim', response['lbry://@bar/foo'])
2018-06-12 17:53:29 +02:00
2018-10-15 23:16:43 +02:00
abandon_tx = await Transaction.abandon([claim_tx.outputs[0]], [self.account], self.account)
await self.broadcast(abandon_tx)
await self.on_transaction(abandon_tx)
await self.blockchain.generate(1)
await self.on_transaction(abandon_tx)
2018-06-12 17:53:29 +02:00
2018-10-15 23:16:43 +02:00
response = await self.ledger.resolve(0, 10, 'lbry://@bar/foo')
2018-08-04 03:27:08 +02:00
self.assertNotIn('claim', response['lbry://@bar/foo'])
# checks for expected format in inexistent URIs
2018-10-15 23:16:43 +02:00
response = await self.ledger.resolve(0, 10, 'lbry://404', 'lbry://@404')
self.assertEqual('URI lbry://404 cannot be resolved', response['lbry://404']['error'])
self.assertEqual('URI lbry://@404 cannot be resolved', response['lbry://@404']['error'])