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

lightning: store network view

Browse source
This commit is contained in:
ThomasV 2018-04-15 22:37:45 +02:00
parent e4b188c714
commit 1c3e9b0cf8
1 changed files with 20 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
lib/lnbase.py
View file

@ -310,8 +310,11 @@ class Peer(PrintError):
self.temporary_channel_id_to_incoming_funding_signed = {} self.temporary_channel_id_to_incoming_funding_signed = {}
self.init_message_received_future = asyncio.Future() self.init_message_received_future = asyncio.Future()
self.localfeatures = 0x08 # request initial sync self.localfeatures = 0x08 # request initial sync
# view of the network
self.nodes = {} # received node announcements self.nodes = {} # received node announcements
self.channels = {} # received channel announcements self.channels = {} # received channel announcements
self.channel_u_origin = {}
self.channel_u_final = {}
def diagnostic_name(self): def diagnostic_name(self):
return self.host return self.host
@ -466,17 +469,30 @@ class Peer(PrintError):
else: else:
pass pass
continue continue
self.print_error('node announcement', binascii.hexlify(pubkey), addresses) alias = payload['alias'].rstrip(b'\x00')
self.nodes[pubkey] = {'addresses': addresses} self.nodes[pubkey] = {
'aliass': alias,
'addresses': addresses
}
self.print_error('node announcement', binascii.hexlify(pubkey), alias, addresses)
def on_init(self, payload): def on_init(self, payload):
pass pass
def on_channel_update(self, payload): def on_channel_update(self, payload):
self.print_error('channel update') flags = int.from_bytes(payload['flags'], byteorder="big")
direction = bool(flags & 1)
short_channel_id = payload['short_channel_id']
if direction:
self.channel_u_origin[short_channel_id] = payload
else:
self.channel_u_final[short_channel_id] = payload
self.print_error('channel update', binascii.hexlify(short_channel_id), flags)
def on_channel_announcement(self, payload): def on_channel_announcement(self, payload):
self.print_error('channel announcement') short_channel_id = payload['short_channel_id']
self.print_error('channel announcement', binascii.hexlify(short_channel_id))
self.channels[short_channel_id] = payload
#def open_channel(self, funding_sat, push_msat): #def open_channel(self, funding_sat, push_msat):
# self.send_message(gen_msg('open_channel', funding_satoshis=funding_sat, push_msat=push_msat)) # self.send_message(gen_msg('open_channel', funding_satoshis=funding_sat, push_msat=push_msat))