mirror of
https://github.com/lightningnetwork/lnd.git
synced 2025-01-19 05:45:21 +01:00
3e36adf476
This commit removes the call toe `ListLeasedOutputs` in `LeaseOutput` - the returned info from `ListLeasedOutputs` can easily be accessed via `FetchInputInfo` and this info is only used at one callsite. `ListLeasedOutputs` then becomes unnecessary here, plus it's very slow and needs to be refactored in `btcwallet` instead.
96 lines
2.3 KiB
Go
96 lines
2.3 KiB
Go
//go:build walletrpc
|
|
// +build walletrpc
|
|
|
|
package walletrpc
|
|
|
|
import (
|
|
"fmt"
|
|
"math"
|
|
|
|
"github.com/btcsuite/btcd/wire"
|
|
base "github.com/btcsuite/btcwallet/wallet"
|
|
"github.com/btcsuite/btcwallet/wtxmgr"
|
|
"github.com/lightningnetwork/lnd/lnwallet"
|
|
"github.com/lightningnetwork/lnd/lnwallet/chanfunding"
|
|
)
|
|
|
|
const (
|
|
defaultMaxConf = math.MaxInt32
|
|
)
|
|
|
|
// verifyInputsUnspent checks that all inputs are contained in the list of
|
|
// known, non-locked UTXOs given.
|
|
func verifyInputsUnspent(inputs []*wire.TxIn, utxos []*lnwallet.Utxo) error {
|
|
// TODO(guggero): Pass in UTXOs as a map to make lookup more efficient.
|
|
for idx, txIn := range inputs {
|
|
found := false
|
|
for _, u := range utxos {
|
|
if u.OutPoint == txIn.PreviousOutPoint {
|
|
found = true
|
|
break
|
|
}
|
|
}
|
|
|
|
if !found {
|
|
return fmt.Errorf("input %d not found in list of non-"+
|
|
"locked UTXO", idx)
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// lockInputs requests a lock lease for all inputs specified in a PSBT packet
|
|
// by using the internal, static lock ID of lnd's wallet.
|
|
func lockInputs(w lnwallet.WalletController,
|
|
outpoints []wire.OutPoint) ([]*base.ListLeasedOutputResult, error) {
|
|
|
|
locks := make(
|
|
[]*base.ListLeasedOutputResult, len(outpoints),
|
|
)
|
|
for idx := range outpoints {
|
|
lock := &base.ListLeasedOutputResult{
|
|
LockedOutput: &wtxmgr.LockedOutput{
|
|
LockID: chanfunding.LndInternalLockID,
|
|
Outpoint: outpoints[idx],
|
|
},
|
|
}
|
|
|
|
// Get the details about this outpoint.
|
|
utxo, err := w.FetchOutpointInfo(&lock.Outpoint)
|
|
if err != nil {
|
|
return nil, fmt.Errorf("fetch outpoint info: %w", err)
|
|
}
|
|
|
|
expiration, err := w.LeaseOutput(
|
|
lock.LockID, lock.Outpoint,
|
|
chanfunding.DefaultLockDuration,
|
|
)
|
|
if err != nil {
|
|
// If we run into a problem with locking one output, we
|
|
// should try to unlock those that we successfully
|
|
// locked so far. If that fails as well, there's not
|
|
// much we can do.
|
|
for i := 0; i < idx; i++ {
|
|
op := locks[i].Outpoint
|
|
if err := w.ReleaseOutput(
|
|
chanfunding.LndInternalLockID, op,
|
|
); err != nil {
|
|
log.Errorf("could not release the "+
|
|
"lock on %v: %v", op, err)
|
|
}
|
|
}
|
|
|
|
return nil, fmt.Errorf("could not lease a lock on "+
|
|
"UTXO: %v", err)
|
|
}
|
|
|
|
lock.Expiration = expiration
|
|
lock.PkScript = utxo.PkScript
|
|
lock.Value = int64(utxo.Value)
|
|
locks[idx] = lock
|
|
}
|
|
|
|
return locks, nil
|
|
}
|