twallet: implement wait_for_address_history_to_change API - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit 9bbea9bf2f257ac9feccd2b4acd170b10276437c
DIR parent 55e6830cfcdf215b0f6abe62df25ae7c0137401e
HTML Author: SomberNight <somber.night@protonmail.com>
Date: Wed, 30 Jan 2019 21:30:25 +0100
wallet: implement wait_for_address_history_to_change API
Diffstat:
M electrum/address_synchronizer.py | 17 +++++++++++++++++
1 file changed, 17 insertions(+), 0 deletions(-)
---
DIR diff --git a/electrum/address_synchronizer.py b/electrum/address_synchronizer.py
t@@ -403,6 +403,7 @@ class AddressSynchronizer(PrintError):
@profiler
def load_local_history(self):
self._history_local = {} # address -> set(txid)
+ self._address_history_changed_events = defaultdict(asyncio.Event) # address -> Event
for txid in itertools.chain(self.txi, self.txo):
self._add_tx_to_local_history(txid)
t@@ -542,6 +543,7 @@ class AddressSynchronizer(PrintError):
cur_hist = self._history_local.get(addr, set())
cur_hist.add(txid)
self._history_local[addr] = cur_hist
+ self._mark_address_history_changed(addr)
def _remove_tx_from_local_history(self, txid):
with self.transaction_lock:
t@@ -554,6 +556,21 @@ class AddressSynchronizer(PrintError):
else:
self._history_local[addr] = cur_hist
+ def _mark_address_history_changed(self, addr: str) -> None:
+ # history for this address changed, wake up coroutines:
+ self._address_history_changed_events[addr].set()
+ # clear event immediately so that coroutines can wait() for the next change:
+ self._address_history_changed_events[addr].clear()
+
+ async def wait_for_address_history_to_change(self, addr: str) -> None:
+ """Wait until the server tells us about a new transaction related to addr.
+
+ Unconfirmed and confirmed transactions are not distinguished, and so e.g. SPV
+ is not taken into account.
+ """
+ assert self.is_mine(addr), "address needs to be is_mine to be watched"
+ await self._address_history_changed_events[addr].wait()
+
def add_unverified_tx(self, tx_hash, tx_height):
if tx_hash in self.verified_tx:
if tx_height in (TX_HEIGHT_UNCONFIRMED, TX_HEIGHT_UNCONF_PARENT):