LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-09-01 09:45:18 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

network: restore previous API for broadcast_transaction

Browse source
This commit is contained in:
SomberNight 2018-09-07 17:07:15 +02:00
parent 52b877ac3d
commit 1fa07c920c
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9
1 changed files with 11 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
electrum/network.py
View file

@ -734,9 +734,18 @@ class Network(PrintError):
async def get_merkle_for_transaction(self, tx_hash, tx_height): async def get_merkle_for_transaction(self, tx_hash, tx_height):
return await self.interface.session.send_request('blockchain.transaction.get_merkle', [tx_hash, tx_height]) return await self.interface.session.send_request('blockchain.transaction.get_merkle', [tx_hash, tx_height])
def broadcast_transaction(self, tx): def broadcast_transaction(self, tx, timeout=5):
fut = asyncio.run_coroutine_threadsafe(self.interface.session.send_request('blockchain.transaction.broadcast', [str(tx)]), self.asyncio_loop) fut = asyncio.run_coroutine_threadsafe(self.interface.session.send_request('blockchain.transaction.broadcast', [str(tx)]), self.asyncio_loop)
return True, fut.result(1) try:
out = fut.result(timeout)
except asyncio.TimeoutError as e:
return False, "error: operation timed out"
except Exception as e:
return False, "error: " + str(e)
if out != tx.txid():
return False, "error: " + out
return True, out
async def request_chunk(self, height, tip, session=None): async def request_chunk(self, height, tip, session=None):
if session is None: session = self.interface.session if session is None: session = self.interface.session