mirror of
https://github.com/Chia-Network/chia-blockchain.git
synced 2024-09-20 16:08:51 +03:00
3b084a165b
* configure isort to add the future annotations import * apply the new isort setting * remove type ignores for new mypy (#13539) https://pypi.org/project/mypy/0.981/ * another
75 lines
3.0 KiB
Python
75 lines
3.0 KiB
Python
from __future__ import annotations
|
|
|
|
from secrets import token_bytes
|
|
|
|
import pytest
|
|
from blspy import AugSchemeMPL
|
|
|
|
from chia.util.ints import uint32
|
|
from chia.wallet.derivation_record import DerivationRecord
|
|
from chia.wallet.util.wallet_types import WalletType
|
|
from chia.wallet.wallet_puzzle_store import WalletPuzzleStore
|
|
from tests.util.db_connection import DBConnection
|
|
|
|
|
|
class TestPuzzleStore:
|
|
@pytest.mark.asyncio
|
|
async def test_puzzle_store(self):
|
|
|
|
async with DBConnection(1) as wrapper:
|
|
|
|
db = await WalletPuzzleStore.create(wrapper)
|
|
derivation_recs = []
|
|
# wallet_types = [t for t in WalletType]
|
|
[t for t in WalletType]
|
|
|
|
for i in range(1000):
|
|
derivation_recs.append(
|
|
DerivationRecord(
|
|
uint32(i),
|
|
token_bytes(32),
|
|
AugSchemeMPL.key_gen(token_bytes(32)).get_g1(),
|
|
WalletType.STANDARD_WALLET,
|
|
uint32(1),
|
|
False,
|
|
)
|
|
)
|
|
derivation_recs.append(
|
|
DerivationRecord(
|
|
uint32(i),
|
|
token_bytes(32),
|
|
AugSchemeMPL.key_gen(token_bytes(32)).get_g1(),
|
|
WalletType.CAT,
|
|
uint32(2),
|
|
False,
|
|
)
|
|
)
|
|
assert await db.puzzle_hash_exists(derivation_recs[0].puzzle_hash) is False
|
|
assert await db.index_for_pubkey(derivation_recs[0].pubkey) is None
|
|
assert await db.index_for_puzzle_hash(derivation_recs[2].puzzle_hash) is None
|
|
assert await db.wallet_info_for_puzzle_hash(derivation_recs[2].puzzle_hash) is None
|
|
assert len((await db.get_all_puzzle_hashes())) == 0
|
|
assert await db.get_last_derivation_path() is None
|
|
assert await db.get_unused_derivation_path() is None
|
|
assert await db.get_derivation_record(0, 2, False) is None
|
|
|
|
await db.add_derivation_paths(derivation_recs)
|
|
|
|
assert await db.puzzle_hash_exists(derivation_recs[0].puzzle_hash) is True
|
|
|
|
assert await db.index_for_pubkey(derivation_recs[4].pubkey) == 2
|
|
assert await db.index_for_puzzle_hash(derivation_recs[2].puzzle_hash) == 1
|
|
assert await db.wallet_info_for_puzzle_hash(derivation_recs[2].puzzle_hash) == (
|
|
derivation_recs[2].wallet_id,
|
|
derivation_recs[2].wallet_type,
|
|
)
|
|
assert len((await db.get_all_puzzle_hashes())) == 2000
|
|
assert await db.get_last_derivation_path() == 999
|
|
assert await db.get_unused_derivation_path() == 0
|
|
assert await db.get_derivation_record(0, 2, False) == derivation_recs[1]
|
|
|
|
# Indeces up to 250
|
|
await db.set_used_up_to(249)
|
|
|
|
assert await db.get_unused_derivation_path() == 250
|