AaronFiore/electrum
1
0
Fork 0
Code Activity

lnchannel: reflect frozen amounts and disconnected channels

Browse Source 
in the num_sats_can_send/receive methods of the lnwallet.
This commit is contained in:
bitromortac
2020-12-18 07:09:48 +01:00
parent d44581e072
commit 7a62074f8e
2 changed files with 17 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
electrum/lnchannel.py
View File

@@ -530,6 +530,9 @@ class Channel(AbstractChannel):
def is_initiator(self): def is_initiator(self):
return self.constraints.is_initiator return self.constraints.is_initiator
def is_active(self):
return self.get_state() == ChannelState.OPEN and self.peer_state == PeerState.GOOD
def funding_txn_minimum_depth(self): def funding_txn_minimum_depth(self):
return self.constraints.funding_txn_minimum_depth return self.constraints.funding_txn_minimum_depth

20
electrum/lnworker.py
View File

@@ -1376,15 +1376,23 @@ class LNWallet(LNWorker):
return Decimal(sum(chan.balance(LOCAL) if not chan.is_closed() else 0 return Decimal(sum(chan.balance(LOCAL) if not chan.is_closed() else 0
for chan in self.channels.values())) / 1000 for chan in self.channels.values())) / 1000
def num_sats_can_send(self) -> Union[Decimal, int]: def num_sats_can_send(self) -> Decimal:
send_values = [Decimal(0)]
with self.lock: with self.lock:
return Decimal(max(chan.available_to_spend(LOCAL) if chan.is_open() else 0 if self.channels:
for chan in self.channels.values()))/1000 if self.channels else 0 for c in self.channels.values():
if c.is_active() and not c.is_frozen_for_sending():
send_values.append(Decimal(c.available_to_spend(LOCAL)) / 1000)
return max(send_values)
def num_sats_can_receive(self) -> Union[Decimal, int]: def num_sats_can_receive(self) -> Decimal:
receive_values = [Decimal(0)]
with self.lock: with self.lock:
return Decimal(max(chan.available_to_spend(REMOTE) if chan.is_open() else 0 if self.channels:
for chan in self.channels.values()))/1000 if self.channels else 0 for c in self.channels.values():
if c.is_active() and not c.is_frozen_for_receiving():
receive_values.append(Decimal(c.available_to_spend(REMOTE)) / 1000)
return max(receive_values)
def can_pay_invoice(self, invoice: LNInvoice) -> bool: def can_pay_invoice(self, invoice: LNInvoice) -> bool:
return invoice.get_amount_sat() <= self.num_sats_can_send() return invoice.get_amount_sat() <= self.num_sats_can_send()