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

lnworker.pay(): lightning-integration support

Browse source
This commit is contained in:
Janus 2018-10-01 18:06:47 +02:00 • committed by SomberNight
parent e3d7cf7035
commit cfc566c93c
No known key found for this signature in database
GPG key ID: B33B5F232C6271E9
4 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
electrum/commands.py
View file

@ -756,7 +756,7 @@ class Commands:
@command('wn')
def lnpay(self, invoice):
f = self.wallet.lnworker.pay(invoice)
addr, peer, f = self.wallet.lnworker.pay(invoice)
return f.result()
@command('wn')

2
electrum/gui/qt/main_window.py
View file

@ -1586,7 +1586,7 @@ class ElectrumWindow(QMainWindow, MessageBoxMixin, PrintError):
failure_list = []
for i in range(LN_NUM_PAYMENT_ATTEMPTS):
try:
future = self.wallet.lnworker.pay(invoice, amount_sat=amount)
addr, peer, future = self.wallet.lnworker.pay(invoice, amount_sat=amount)
future.result()
break
except PaymentFailure as e:

4
electrum/lnbase.py
View file

@ -289,6 +289,7 @@ class Peer(PrintError):
self.commitment_signed = defaultdict(asyncio.Queue)
self.announcement_signatures = defaultdict(asyncio.Queue)
self.closing_signed = defaultdict(asyncio.Queue)
self.payment_preimages = defaultdict(asyncio.Queue)
self.localfeatures = (0x08 if request_initial_sync else 0)
self.invoices = lnworker.invoices
self.attempted_route = {}
@ -959,6 +960,9 @@ class Peer(PrintError):
await self.receive_revoke(chan)
self.lnworker.save_channel(chan)
# used in lightning-integration
self.payment_preimages[sha256(preimage)].put_nowait(preimage)
def on_update_fail_malformed_htlc(self, payload):
self.on_error(payload)

2
electrum/lnworker.py
View file

@ -227,7 +227,7 @@ class LNWorker(PrintError):
else:
raise Exception("ChannelDB returned path with short_channel_id {} that is not in channel list".format(bh2u(short_channel_id)))
coro = peer.pay(path, chan, amount_msat, payment_hash, invoice_pubkey, addr.min_final_cltv_expiry)
return asyncio.run_coroutine_threadsafe(coro, self.network.asyncio_loop)
return addr, peer, asyncio.run_coroutine_threadsafe(coro, self.network.asyncio_loop)
def add_invoice(self, amount_sat, message):
payment_preimage = os.urandom(32)