mirror of
https://github.com/Chia-Network/chia-blockchain.git
synced 2026-08-28 18:14:19 -05:00
Matt HauffandGitHub
40db4635a8
* Enable PEP604 Ruff rules * Fix harcoded signature in test * Hack CLVMStreamable test with note to fast follow
54 lines
2.3 KiB
Python
54 lines
2.3 KiB
Python
from __future__ import annotations
|
|
|
|
from typing import Protocol
|
|
|
|
from chia_rs import BlockRecord, HeaderBlock, SubEpochChallengeSegment, SubEpochSummary
|
|
from chia_rs.sized_bytes import bytes32
|
|
from chia_rs.sized_ints import uint32
|
|
|
|
|
|
class BlockRecordsProtocol(Protocol):
|
|
def try_block_record(self, header_hash: bytes32) -> BlockRecord | None: ...
|
|
def block_record(self, header_hash: bytes32) -> BlockRecord: ...
|
|
def contains_height(self, height: uint32) -> bool: ...
|
|
def contains_block(self, header_hash: bytes32, height: uint32) -> bool: ...
|
|
def height_to_hash(self, height: uint32) -> bytes32 | None: ...
|
|
def height_to_block_record(self, height: uint32) -> BlockRecord: ...
|
|
|
|
# given a list of block header hashes, return the header hashes of their
|
|
# previous blocks. This is not limited to the block record cache, but must
|
|
# allow any block in the database to be referenced
|
|
async def prev_block_hash(self, header_hashes: list[bytes32]) -> list[bytes32]: ...
|
|
|
|
|
|
class BlocksProtocol(BlockRecordsProtocol, Protocol):
|
|
async def lookup_block_generators(
|
|
self, header_hash: bytes32, generator_refs: set[uint32]
|
|
) -> dict[uint32, bytes]: ...
|
|
async def get_block_record_from_db(self, header_hash: bytes32) -> BlockRecord | None: ...
|
|
def add_block_record(self, block_record: BlockRecord) -> None: ...
|
|
|
|
|
|
class BlockchainInterface(BlocksProtocol, Protocol):
|
|
def get_peak(self) -> BlockRecord | None: ...
|
|
def get_peak_height(self) -> uint32 | None: ...
|
|
def get_ses_heights(self) -> list[uint32]: ...
|
|
def get_ses(self, height: uint32) -> SubEpochSummary: ...
|
|
async def contains_block_from_db(self, header_hash: bytes32) -> bool: ...
|
|
async def get_block_records_in_range(self, start: int, stop: int) -> dict[bytes32, BlockRecord]: ...
|
|
|
|
async def get_header_blocks_in_range(
|
|
self, start: int, stop: int, tx_filter: bool = True
|
|
) -> dict[bytes32, HeaderBlock]: ...
|
|
|
|
async def get_block_records_at(self, heights: list[uint32]) -> list[BlockRecord]: ...
|
|
|
|
async def persist_sub_epoch_challenge_segments(
|
|
self, sub_epoch_summary_hash: bytes32, segments: list[SubEpochChallengeSegment]
|
|
) -> None: ...
|
|
|
|
async def get_sub_epoch_challenge_segments(
|
|
self,
|
|
sub_epoch_summary_hash: bytes32,
|
|
) -> list[SubEpochChallengeSegment] | None: ...
|