mirror of
https://github.com/lightninglabs/loop.git
synced 2026-08-15 12:50:28 +02:00
e02e5bc258
Add a TxOutChecker interface for testing whether an original deposit outpoint is still available before a static loop-in signs its HTLC transaction. Implement the checker using lnd's wallet transaction view so wallet-known spends, including mempool spends when requested, cause the outpoint to be reported unavailable.
98 lines
2.2 KiB
Go
98 lines
2.2 KiB
Go
package loopin
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"testing"
|
|
|
|
"github.com/btcsuite/btcd/wire"
|
|
"github.com/lightninglabs/lndclient"
|
|
"github.com/lightningnetwork/lnd/lnrpc"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestLndTxOutChecker(t *testing.T) {
|
|
fundingTx := wire.NewMsgTx(2)
|
|
fundingTx.AddTxOut(wire.NewTxOut(1000, []byte{0x01}))
|
|
fundingTx.AddTxOut(wire.NewTxOut(2000, []byte{0x02}))
|
|
|
|
outpoint := wire.OutPoint{
|
|
Hash: fundingTx.TxHash(),
|
|
Index: 1,
|
|
}
|
|
|
|
t.Run("returns live tx output", func(t *testing.T) {
|
|
client := &mockTxListLightningClient{
|
|
txs: []lndclient.Transaction{{
|
|
Tx: fundingTx,
|
|
}},
|
|
}
|
|
|
|
checker := NewLndTxOutChecker(client)
|
|
txOut, err := checker.GetTxOut(t.Context(), outpoint, false)
|
|
require.NoError(t, err)
|
|
require.Equal(t, fundingTx.TxOut[outpoint.Index], txOut)
|
|
require.Equal(t, []txListCall{{
|
|
startHeight: 0,
|
|
endHeight: 0,
|
|
}}, client.calls)
|
|
})
|
|
|
|
t.Run("returns nil for known spend", func(t *testing.T) {
|
|
client := &mockTxListLightningClient{
|
|
txs: []lndclient.Transaction{{
|
|
Tx: fundingTx,
|
|
}, {
|
|
PreviousOutpoints: []*lnrpc.PreviousOutPoint{{
|
|
Outpoint: outpoint.String(),
|
|
}},
|
|
}},
|
|
}
|
|
|
|
checker := NewLndTxOutChecker(client)
|
|
txOut, err := checker.GetTxOut(t.Context(), outpoint, true)
|
|
require.NoError(t, err)
|
|
require.Nil(t, txOut)
|
|
require.Equal(t, []txListCall{{
|
|
startHeight: 0,
|
|
endHeight: -1,
|
|
}}, client.calls)
|
|
})
|
|
|
|
t.Run("returns error", func(t *testing.T) {
|
|
expectedErr := errors.New("list transactions failed")
|
|
client := &mockTxListLightningClient{
|
|
err: expectedErr,
|
|
}
|
|
|
|
checker := NewLndTxOutChecker(client)
|
|
txOut, err := checker.GetTxOut(t.Context(), outpoint, false)
|
|
require.ErrorIs(t, err, expectedErr)
|
|
require.Nil(t, txOut)
|
|
})
|
|
}
|
|
|
|
type txListCall struct {
|
|
startHeight int32
|
|
endHeight int32
|
|
}
|
|
|
|
type mockTxListLightningClient struct {
|
|
lndclient.LightningClient
|
|
|
|
txs []lndclient.Transaction
|
|
err error
|
|
calls []txListCall
|
|
}
|
|
|
|
func (m *mockTxListLightningClient) ListTransactions(_ context.Context,
|
|
startHeight, endHeight int32, _ ...lndclient.ListTransactionsOption) (
|
|
[]lndclient.Transaction, error) {
|
|
|
|
m.calls = append(m.calls, txListCall{
|
|
startHeight: startHeight,
|
|
endHeight: endHeight,
|
|
})
|
|
|
|
return m.txs, m.err
|
|
}
|