LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

more async parts

Browse source
This commit is contained in:
Victor Shyba 2020-03-18 00:59:03 -03:00
parent ec8e243323
commit e45375dc26
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lbry/wallet/header.py
View file

@ -111,12 +111,12 @@ class Headers:
raise NotImplementedError("Slicing of header chain has not been implemented yet.") raise NotImplementedError("Slicing of header chain has not been implemented yet.")
if not 0 <= height <= self.height: if not 0 <= height <= self.height:
raise IndexError(f"{height} is out of bounds, current height: {self.height}") raise IndexError(f"{height} is out of bounds, current height: {self.height}")
return self.deserialize(height, self.get_raw_header(height)) return self.deserialize(height, await self.get_raw_header(height))
def estimated_timestamp(self, height): def estimated_timestamp(self, height):
return self.first_block_timestamp + (height * self.timestamp_average_offset) return self.first_block_timestamp + (height * self.timestamp_average_offset)
def get_raw_header(self, height) -> bytes: async def get_raw_header(self, height) -> bytes:
self.io.seek(height * self.header_size, os.SEEK_SET) self.io.seek(height * self.header_size, os.SEEK_SET)
return self.io.read(self.header_size) return self.io.read(self.header_size)
@ -128,9 +128,9 @@ class Headers:
def bytes_size(self): def bytes_size(self):
return len(self) * self.header_size return len(self) * self.header_size
def hash(self, height=None) -> bytes: async def hash(self, height=None) -> bytes:
return self.hash_header( return self.hash_header(
self.get_raw_header(height if height is not None else self.height) await self.get_raw_header(height if height is not None else self.height)
) )
@staticmethod @staticmethod
@ -195,7 +195,7 @@ class Headers:
previous_hash, previous_header, previous_previous_header = None, None, None previous_hash, previous_header, previous_previous_header = None, None, None
if height > 0: if height > 0:
previous_header = await self.get(height-1) previous_header = await self.get(height-1)
previous_hash = self.hash(height-1) previous_hash = await self.hash(height-1)
if height > 1: if height > 1:
previous_previous_header = await self.get(height-2) previous_previous_header = await self.get(height-2)
chunk_target = self.get_next_chunk_target(height // 2016 - 1) chunk_target = self.get_next_chunk_target(height // 2016 - 1)