RanchiMall/pyflo
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

connector

Browse Source
This commit is contained in:
4tochka 2019-05-01 00:02:54 +04:00
parent e5e70a48a0
commit 4a91ac3f31
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pybtc/connector.py
View File

@ -500,14 +500,14 @@ class Connector:
async def _new_transaction(self, tx, block_time = None, block_height = None, block_index = None): async def _new_transaction(self, tx, block_time = None, block_height = None, block_index = None):
if not(tx["txId"] in self.tx_in_process or self.tx_cache.get(tx["txId"])): if not(tx["txId"] in self.tx_in_process or self.tx_cache.get(tx["txId"])):
try: try:
stxo = None
self.tx_in_process.add(tx["txId"]) self.tx_in_process.add(tx["txId"])
if not tx["coinbase"]: if not tx["coinbase"]:
if block_height is not None: if block_height is not None:
await self.wait_block_dependences(tx) await self.wait_block_dependences(tx)
if self.utxo: if self.utxo:
stxo = await self.get_stxo(tx, block_height, block_index) stxo = await self.get_stxo(tx, block_height, block_index)
else:
stxo = None
if self.tx_handler and not self.cache_loading: if self.tx_handler and not self.cache_loading:
await self.tx_handler(tx, stxo, block_time, block_height, block_index) await self.tx_handler(tx, stxo, block_time, block_height, block_index)
@ -768,7 +768,8 @@ class UTXO():
self.load_utxo_future = asyncio.Future() self.load_utxo_future = asyncio.Future()
l = set(self.missed) l = set(self.missed)
async with self._db_pool.acquire() as conn: async with self._db_pool.acquire() as conn:
rows = await conn.fetch("SELECT outpoint, utxo.data FROM connector_utxo " rows = await conn.fetch("SELECT outpoint, connector_utxo.data "
"FROM connector_utxo "
"WHERE outpoint = ANY($1);", l) "WHERE outpoint = ANY($1);", l)
for i in l: for i in l:
try: try: