mirror of
https://github.com/lightninglabs/loop.git
synced 2026-08-13 12:33:03 +02:00
7287da1559
Keep replacement UTXOs as fresh deposits while preserving the original deposit record and selected outpoint snapshot for pending swaps. Before signing a static loop-in HTLC, check each original selected outpoint with GetTxOut(..., includeMempool=true). Cancel the pending invoice only when that check reports an original outpoint unavailable; lookup errors fail the action without canceling so transient chain backend errors do not incorrectly abandon the swap. Keep recovered loop-ins using their stored outpoint snapshot and cover replacement discovery and cancellation in tests.
125 lines
4.8 KiB
Go
125 lines
4.8 KiB
Go
package loopin
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/btcsuite/btcd/btcutil"
|
|
"github.com/btcsuite/btcd/wire"
|
|
"github.com/lightninglabs/loop"
|
|
"github.com/lightninglabs/loop/fsm"
|
|
"github.com/lightninglabs/loop/staticaddr/deposit"
|
|
"github.com/lightninglabs/loop/staticaddr/script"
|
|
"github.com/lightninglabs/loop/swapserverrpc"
|
|
"github.com/lightningnetwork/lnd/lntypes"
|
|
"github.com/lightningnetwork/lnd/routing/route"
|
|
"github.com/lightningnetwork/lnd/zpay32"
|
|
)
|
|
|
|
const (
|
|
// DefaultLoopInOnChainCltvDelta is the time lock relative to current
|
|
// block height that swap server will accept on the swap initiation
|
|
// call.
|
|
DefaultLoopInOnChainCltvDelta = 1000
|
|
|
|
// DepositHtlcDelta is a safety buffer of blocks that needs to exist
|
|
// between the deposit expiry height and the htlc expiry height.
|
|
DepositHtlcDelta = 50
|
|
)
|
|
|
|
type (
|
|
// ValidateLoopInContract validates the contract parameters against our
|
|
// request.
|
|
ValidateLoopInContract func(height int32, htlcExpiry int32) error
|
|
)
|
|
|
|
// AddressManager handles fetching of address parameters.
|
|
type AddressManager interface {
|
|
// GetStaticAddressParameters returns the static address parameters.
|
|
GetStaticAddressParameters(ctx context.Context) (*script.Parameters,
|
|
error)
|
|
|
|
// GetStaticAddress returns the deposit address for the given client and
|
|
// server public keys.
|
|
GetStaticAddress(ctx context.Context) (*script.StaticAddress, error)
|
|
}
|
|
|
|
// DepositManager handles the interaction of loop-ins with deposits.
|
|
type DepositManager interface {
|
|
// GetAllDeposits returns all known deposits from the database store.
|
|
GetAllDeposits(ctx context.Context) ([]*deposit.Deposit, error)
|
|
|
|
// AllStringOutpointsActiveDeposits returns all deposits that have the
|
|
// given outpoints and are in the given state. If any of the outpoints
|
|
// does not correspond to an active deposit, the function returns false.
|
|
AllStringOutpointsActiveDeposits(outpoints []string,
|
|
stateFilter fsm.StateType) ([]*deposit.Deposit, bool)
|
|
|
|
// TransitionDeposits transitions the given deposits to the next state
|
|
// based on the given event. It returns an error if the transition is
|
|
// invalid.
|
|
TransitionDeposits(ctx context.Context, deposits []*deposit.Deposit,
|
|
event fsm.EventType, expectedFinalState fsm.StateType) error
|
|
|
|
// DepositsForOutpoints returns all deposits that behind the given
|
|
// outpoints. If ignoreUnknown is false, the function returns an error
|
|
// if any of the outpoints is not known, no error otherwise.
|
|
DepositsForOutpoints(ctx context.Context, outpoints []string,
|
|
ignoreUnknown bool) ([]*deposit.Deposit, error)
|
|
|
|
// GetActiveDepositsInState returns all active deposits in the given
|
|
// state.
|
|
GetActiveDepositsInState(stateFilter fsm.StateType) ([]*deposit.Deposit,
|
|
error)
|
|
}
|
|
|
|
// StaticAddressLoopInStore provides access to the static address loop-in DB.
|
|
type StaticAddressLoopInStore interface {
|
|
// CreateLoopIn creates a loop-in record in the database.
|
|
CreateLoopIn(ctx context.Context, loopIn *StaticAddressLoopIn) error
|
|
|
|
// UpdateLoopIn updates a loop-in record in the database.
|
|
UpdateLoopIn(ctx context.Context, loopIn *StaticAddressLoopIn) error
|
|
|
|
// GetStaticAddressLoopInSwapsByStates returns all loop-ins with given
|
|
// states.
|
|
GetStaticAddressLoopInSwapsByStates(ctx context.Context,
|
|
states []fsm.StateType) ([]*StaticAddressLoopIn, error)
|
|
|
|
// IsStored checks if the loop-in is already stored in the database.
|
|
IsStored(ctx context.Context, swapHash lntypes.Hash) (bool, error)
|
|
|
|
// GetLoopInByHash returns the loop-in swap with the given hash.
|
|
GetLoopInByHash(ctx context.Context, swapHash lntypes.Hash) (
|
|
*StaticAddressLoopIn, error)
|
|
|
|
// SwapHashesForDepositIDs returns a map of swap hashes to deposit IDs
|
|
// for the given deposit IDs.
|
|
SwapHashesForDepositIDs(ctx context.Context,
|
|
depositIDs []deposit.ID) (map[lntypes.Hash][]deposit.ID, error)
|
|
}
|
|
|
|
type QuoteGetter interface {
|
|
// GetLoopInQuote returns a quote for a loop-in swap.
|
|
GetLoopInQuote(ctx context.Context, amt btcutil.Amount,
|
|
pubKey route.Vertex, lastHop *route.Vertex,
|
|
routeHints [][]zpay32.HopHint, initiator string,
|
|
numDeposits uint32, fast bool) (*loop.LoopInQuote, error)
|
|
}
|
|
|
|
// TxOutChecker checks whether an outpoint is still available in the chain
|
|
// backend's UTXO view.
|
|
type TxOutChecker interface {
|
|
// GetTxOut returns nil if the outpoint is unavailable or spent. The
|
|
// includeMempool flag must be passed through to the underlying chain
|
|
// backend.
|
|
GetTxOut(ctx context.Context, outpoint wire.OutPoint,
|
|
includeMempool bool) (*wire.TxOut, error)
|
|
}
|
|
|
|
type NotificationManager interface {
|
|
// SubscribeStaticLoopInSweepRequests subscribes to the static loop in
|
|
// sweep requests. These are sent by the server to the client to request
|
|
// a sweep of a static loop in that has been finished.
|
|
SubscribeStaticLoopInSweepRequests(ctx context.Context,
|
|
) <-chan *swapserverrpc.ServerStaticLoopInSweepNotification
|
|
}
|