Browse Source
move LNPeer handshake back into initialize
regtest_lnd
ThomasV
6 years ago
committed by
SomberNight
No known key found for this signature in database
GPG Key ID: B33B5F232C6271E9
3 changed files with
4 additions and
5 deletions
-
electrum/lnbase.py
-
electrum/lntransport.py
-
electrum/lnworker.py
|
|
@ -232,6 +232,9 @@ class Peer(PrintError): |
|
|
|
self.transport.send_bytes(gen_msg(message_name, **kwargs)) |
|
|
|
|
|
|
|
async def initialize(self): |
|
|
|
if isinstance(self.transport, LNTransport): |
|
|
|
await self.transport.handshake() |
|
|
|
self.channel_db.add_recent_peer(self.transport.peer_addr) |
|
|
|
self.send_message("init", gflen=0, lflen=1, localfeatures=self.localfeatures) |
|
|
|
|
|
|
|
@property |
|
|
|
|
|
@ -214,6 +214,7 @@ class LNTransport(LNTransportBase): |
|
|
|
self.remote_pubkey = peer_addr.pubkey |
|
|
|
self.host = peer_addr.host |
|
|
|
self.port = peer_addr.port |
|
|
|
self.peer_addr = peer_addr |
|
|
|
|
|
|
|
def name(self): |
|
|
|
return str(self.host) + ':' + str(self.port) |
|
|
|
|
|
@ -249,11 +249,6 @@ class LNWorker(PrintError): |
|
|
|
port = int(port) |
|
|
|
peer_addr = LNPeerAddr(host, port, node_id) |
|
|
|
transport = LNTransport(self.node_keypair.privkey, peer_addr) |
|
|
|
try: |
|
|
|
await transport.handshake() |
|
|
|
except: |
|
|
|
return |
|
|
|
self.channel_db.add_recent_peer(peer_addr) |
|
|
|
self._last_tried_peer[peer_addr] = time.time() |
|
|
|
self.print_error("adding peer", peer_addr) |
|
|
|
peer = Peer(self, node_id, transport, request_initial_sync=self.config.get("request_initial_sync", True)) |
|
|
|