LBRYFoundation/LBRY-Vault
1
0
Fork 0
mirror of https://github.com/LBRYFoundation/LBRY-Vault.git synced 2025-08-23 17:47:31 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

LNPeerAddr: fix equality tests and hence lnworker._last_tried_peer

Browse source 
follow-up 13d6997355
This commit is contained in:
SomberNight 2019-11-29 00:53:18 +01:00
parent 2ce8dd460b
commit adaa016e78
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9
2 changed files with 14 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
electrum/lnutil.py
View file

@ -684,6 +684,19 @@ class LNPeerAddr:
def net_addr_str(self) -> str: def net_addr_str(self) -> str:
return self._net_addr_str return self._net_addr_str
def __eq__(self, other):
if not isinstance(other, LNPeerAddr):
return False
return (self.host == other.host
and self.port == other.port
and self.pubkey == other.pubkey)
def __ne__(self, other):
return not (self == other)
def __hash__(self):
return hash((self.host, self.port, self.pubkey))
def get_compressed_pubkey_from_bech32(bech32_pubkey: str) -> bytes: def get_compressed_pubkey_from_bech32(bech32_pubkey: str) -> bytes:
hrp, data_5bits = segwit_addr.bech32_decode(bech32_pubkey) hrp, data_5bits = segwit_addr.bech32_decode(bech32_pubkey)

2
electrum/lnworker.py
View file

@ -186,7 +186,7 @@ class LNWorker(Logger):
self.network = network self.network = network
self.config = network.config self.config = network.config
self.channel_db = self.network.channel_db self.channel_db = self.network.channel_db
self._last_tried_peer = {} # LNPeerAddr -> unix timestamp self._last_tried_peer = {} # type: Dict[LNPeerAddr, float] # LNPeerAddr -> unix timestamp
self._add_peers_from_config() self._add_peers_from_config()
asyncio.run_coroutine_threadsafe(self.network.main_taskgroup.spawn(self.main_loop()), self.network.asyncio_loop) asyncio.run_coroutine_threadsafe(self.network.main_taskgroup.spawn(self.main_loop()), self.network.asyncio_loop)