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

integrate lnbase with network

Browse source
This commit is contained in:
ThomasV 2018-04-11 11:02:10 +02:00
parent 0fac793735
commit 3795770b37
1 changed files with 20 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
lib/lnbase.py
View file

@ -18,6 +18,7 @@ import cryptography.hazmat.primitives.ciphers.aead as AEAD
from electrum.bitcoin import public_key_from_private_key, ser_to_point, point_to_ser, string_to_number from electrum.bitcoin import public_key_from_private_key, ser_to_point, point_to_ser, string_to_number
from electrum.bitcoin import int_to_hex, bfh, rev_hex from electrum.bitcoin import int_to_hex, bfh, rev_hex
from electrum.util import PrintError from electrum.util import PrintError
from electrum.wallet import Wallet
tcp_socket_timeout = 10 tcp_socket_timeout = 10
server_response_timeout = 60 server_response_timeout = 60
@ -111,7 +112,6 @@ def gen_msg(msg_type, **kwargs):
data += param data += param
return data return data
###############################
def decode(string): def decode(string):
@ -309,6 +309,9 @@ class Peer(PrintError):
elif message == 'channel_update': elif message == 'channel_update':
pass pass
def open_channel(self):
pass
async def main_loop(self, loop): async def main_loop(self, loop):
self.reader, self.writer = await asyncio.open_connection(self.host, self.port, loop=loop) self.reader, self.writer = await asyncio.open_connection(self.host, self.port, loop=loop)
await self.handshake() await self.handshake()
@ -323,12 +326,20 @@ class Peer(PrintError):
msg = await self.read_message() msg = await self.read_message()
self.process_message(msg) self.process_message(msg)
# close socket # close socket
self.print_error('closing lnbase')
self.writer.close() self.writer.close()
# replacement for lightningCall
class LNWallet(Wallet):
def run(self): def __init__(self, wallet, peer):
loop = asyncio.get_event_loop() self.wallet = wallet
loop.run_until_complete(self.main_loop(loop)) self.peer = peer
loop.close()
def openchannel(self):
# todo: get utxo from wallet
self.peer.open_channel()
node_list = [ node_list = [
@ -346,4 +357,7 @@ if __name__ == "__main__":
port = int(port) port = int(port)
privkey = b"\x21"*32 + b"\x01" privkey = b"\x21"*32 + b"\x01"
peer = Peer(privkey, host, port, pubkey) peer = Peer(privkey, host, port, pubkey)
peer.run() loop = asyncio.get_event_loop()
loop.run_until_complete(peer.main_loop(loop))
loop.close()