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

if possible, batch new transaction with existing rbf transaction

Browse source
This commit is contained in:
ThomasV 2018-11-09 16:33:29 +01:00
parent bd32b88f62
commit 2b8d801b36
5 changed files with 55 additions and 29 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
electrum/address_synchronizer.py
View file

@ -484,6 +484,12 @@ class AddressSynchronizer(PrintError):
self.threadlocal_cache.local_height = orig_val
return f
def get_unconfirmed_tx(self):
for tx_hash, tx_mined_status, delta, balance in self.get_history():
if tx_mined_status.conf <= 0 and delta < 0:
tx = self.transactions.get(tx_hash)
return tx
@with_local_height_cached
def get_history(self, domain=None):
# get domain

8
electrum/coinchooser.py
View file

@ -187,7 +187,7 @@ class CoinChooserBase(PrintError):
self.print_error('not keeping dust', dust)
return change
def make_tx(self, coins, outputs, change_addrs, fee_estimator,
def make_tx(self, coins, inputs, outputs, change_addrs, fee_estimator,
dust_threshold):
"""Select unspent coins to spend to pay outputs. If the change is
greater than dust_threshold (after adding the change output to
@ -202,7 +202,9 @@ class CoinChooserBase(PrintError):
self.p = PRNG(''.join(sorted(utxos)))
# Copy the outputs so when adding change we don't modify "outputs"
tx = Transaction.from_io([], outputs[:])
tx = Transaction.from_io(inputs[:], outputs[:])
v = tx.input_value()
# Weight of the transaction with no inputs and no change
# Note: this will use legacy tx serialization as the need for "segwit"
# would be detected from inputs. The only side effect should be that the
@ -230,7 +232,7 @@ class CoinChooserBase(PrintError):
def sufficient_funds(buckets):
'''Given a list of buckets, return True if it has enough
value to pay for the transaction'''
total_input = sum(bucket.value for bucket in buckets)
total_input = v + sum(bucket.value for bucket in buckets)
total_weight = get_tx_weight(buckets)
return total_input >= spent_amount + fee_estimator_w(total_weight)

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

@ -87,7 +87,7 @@ class TxDialog(QDialog, MessageBoxMixin):
# if the wallet can populate the inputs with more info, do it now.
# as a result, e.g. we might learn an imported address tx is segwit,
# in which case it's ok to display txid
self.wallet.add_input_info_to_all_inputs(tx)
tx.add_inputs_info(self.wallet)
self.setMinimumWidth(950)
self.setWindowTitle(_("Transaction"))

13
electrum/transaction.py
View file

@ -763,6 +763,17 @@ class Transaction:
txin['witness'] = None # force re-serialization
self.raw = None
def add_inputs_info(self, wallet):
if self.is_complete():
return
for txin in self.inputs():
wallet.add_input_info(txin)
def remove_signatures(self):
for txin in self.inputs():
txin['signatures'] = [None] * len(txin['signatures'])
assert not self.is_complete()
def deserialize(self, force_full_parse=False):
if self.raw is None:
return
@ -1199,8 +1210,6 @@ class Transaction:
return s, r
def is_complete(self):
if not self.is_partial_originally:
return True
s, r = self.signature_count()
return r == s

55
electrum/wallet.py
View file

@ -536,7 +536,7 @@ class Abstract_Wallet(AddressSynchronizer):
def dust_threshold(self):
return dust_threshold(self.network)
def make_unsigned_transaction(self, inputs, outputs, config, fixed_fee=None,
def make_unsigned_transaction(self, coins, outputs, config, fixed_fee=None,
change_addr=None, is_sweep=False):
# check outputs
i_max = None
@ -550,13 +550,13 @@ class Abstract_Wallet(AddressSynchronizer):
i_max = i
# Avoid index-out-of-range with inputs[0] below
if not inputs:
if not coins:
raise NotEnoughFunds()
if fixed_fee is None and config.fee_per_kb() is None:
raise NoDynamicFeeEstimates()
for item in inputs:
for item in coins:
self.add_input_info(item)
# change address
@ -591,19 +591,34 @@ class Abstract_Wallet(AddressSynchronizer):
# Let the coin chooser select the coins to spend
max_change = self.max_change_outputs if self.multiple_change else 1
coin_chooser = coinchooser.get_coin_chooser(config)
tx = coin_chooser.make_tx(inputs, outputs, change_addrs[:max_change],
# If there is an unconfirmed RBF tx, merge with it
base_tx = self.get_unconfirmed_tx()
if base_tx and not base_tx.is_final():
base_tx = Transaction(base_tx.serialize())
base_tx.deserialize(force_full_parse=True)
base_tx.remove_signatures()
base_tx.add_inputs_info(self)
base_fee = base_tx.get_fee()
fee_per_byte = Decimal(base_fee) / base_tx.estimated_size()
fee_estimator = lambda size: base_fee + round(fee_per_byte * size)
txi = base_tx.inputs()
txo = list(filter(lambda x: not self.is_change(x[1]), base_tx.outputs()))
else:
txi = []
txo = []
tx = coin_chooser.make_tx(coins, txi, outputs[:] + txo, change_addrs[:max_change],
fee_estimator, self.dust_threshold())
else:
# FIXME?? this might spend inputs with negative effective value...
sendable = sum(map(lambda x:x['value'], inputs))
sendable = sum(map(lambda x:x['value'], coins))
outputs[i_max] = outputs[i_max]._replace(value=0)
tx = Transaction.from_io(inputs, outputs[:])
tx = Transaction.from_io(coins, outputs[:])
fee = fee_estimator(tx.estimated_size())
amount = sendable - tx.output_value() - fee
if amount < 0:
raise NotEnoughFunds()
outputs[i_max] = outputs[i_max]._replace(value=amount)
tx = Transaction.from_io(inputs, outputs[:])
tx = Transaction.from_io(coins, outputs[:])
# Timelock tx to current height.
tx.locktime = self.get_local_height()
@ -679,11 +694,10 @@ class Abstract_Wallet(AddressSynchronizer):
raise CannotBumpFee(_('Cannot bump fee') + ': ' + _('transaction is final'))
tx = Transaction(tx.serialize())
tx.deserialize(force_full_parse=True) # need to parse inputs
inputs = copy.deepcopy(tx.inputs())
outputs = copy.deepcopy(tx.outputs())
for txin in inputs:
txin['signatures'] = [None] * len(txin['signatures'])
self.add_input_info(txin)
tx.remove_signatures()
tx.add_inputs_info(self)
inputs = tx.inputs()
outputs = tx.outputs()
# use own outputs
s = list(filter(lambda x: self.is_mine(x[1]), outputs))
# ... unless there is none
@ -738,26 +752,21 @@ class Abstract_Wallet(AddressSynchronizer):
def add_input_info(self, txin):
address = self.get_txin_address(txin)
if self.is_mine(address):
txin['address'] = address
txin['type'] = self.get_txin_type(address)
# segwit needs value to sign
if txin.get('value') is None and Transaction.is_input_value_needed(txin):
if txin.get('value') is None:
received, spent = self.get_addr_io(address)
item = received.get(txin['prevout_hash']+':%d'%txin['prevout_n'])
tx_height, value, is_cb = item
txin['value'] = value
if item:
txin['value'] = item[1]
self.add_input_sig_info(txin, address)
def add_input_info_to_all_inputs(self, tx):
if tx.is_complete():
return
for txin in tx.inputs():
self.add_input_info(txin)
def can_sign(self, tx):
if tx.is_complete():
return False
# add info to inputs if we can; otherwise we might return a false negative:
self.add_input_info_to_all_inputs(tx) # though note that this is a side-effect
tx.add_inputs_info(self)
for k in self.get_keystores():
if k.can_sign(tx):
return True
@ -804,7 +813,7 @@ class Abstract_Wallet(AddressSynchronizer):
def sign_transaction(self, tx, password):
if self.is_watching_only():
return
self.add_input_info_to_all_inputs(tx)
tx.add_inputs_info(self)
# hardware wallets require extra info
if any([(isinstance(k, Hardware_KeyStore) and k.can_sign(tx)) for k in self.get_keystores()]):
self.add_hw_info(tx)