mirror of
https://github.com/lightningnetwork/lnd.git
synced 2026-08-15 12:50:15 +02:00
8047149c6a
Migrate all btcd dependencies to the new per-package v2 modules (wire/v2, txscript/v2, chaincfg/v2, chainhash/v2, btcutil/v2, psbt/v2, btcec/v2) introduced by btcd v0.26.0, and pin the tagged ecosystem versions: btcwallet v0.17.0, neutrino v0.18.0 and lightning-onion v1.4.0. The bulk of the import rewrite was produced by the scripted diff from https://github.com/btcsuite/btcd/pull/2547 (followed by 'make rpc'). The address symbols that moved out of btcutil into the new address package are imported as btcaddr where a local "address" variable would otherwise shadow them. The go.mod/go.sum updates and the remaining manual compilation fixes are folded into this single commit so it builds on its own (the migration was previously split into a reproducible scripted-diff plus follow-ups, intended to be squashed on merge).
77 lines
3.4 KiB
Go
77 lines
3.4 KiB
Go
package chainview
|
|
|
|
import (
|
|
"github.com/btcsuite/btcd/chainhash/v2"
|
|
"github.com/btcsuite/btcd/wire/v2"
|
|
graphdb "github.com/lightningnetwork/lnd/graph/db"
|
|
)
|
|
|
|
// FilteredChainView represents a subscription to a certain subset of the
|
|
// UTXO set for a particular chain. This interface is useful from the point of
|
|
// view of maintaining an up-to-date channel graph for the Lightning Network.
|
|
// The subset of the UTXO to be subscribed is that of all the currently opened
|
|
// channels. Each time a channel is closed (the output is spent), a
|
|
// notification is to be sent allowing the graph to be pruned.
|
|
//
|
|
// NOTE: As FilteredBlocks are generated, it is recommended that
|
|
// implementations reclaim the space occupied by newly spent outputs.
|
|
type FilteredChainView interface {
|
|
// FilteredBlocks returns the channel that filtered blocks are to be
|
|
// sent over. Each time a block is connected to the end of a main
|
|
// chain, and appropriate FilteredBlock which contains the transactions
|
|
// which mutate our watched UTXO set is to be returned. In case of a
|
|
// UpdateFilter call with an updateHeight lower than the current best
|
|
// height, blocks with the updated filter will be resent, and must be
|
|
// handled by the receiver as an update to an already known block, NOT
|
|
// as a new block being connected to the chain.
|
|
FilteredBlocks() <-chan *FilteredBlock
|
|
|
|
// DisconnectedBlocks returns a receive only channel which will be sent
|
|
// upon with the empty filtered blocks of blocks which are disconnected
|
|
// from the main chain in the case of a re-org.
|
|
// NOTE: In case of a reorg, connected blocks will not be available to
|
|
// read from the FilteredBlocks() channel before all disconnected block
|
|
// have been received.
|
|
DisconnectedBlocks() <-chan *FilteredBlock
|
|
|
|
// UpdateFilter updates the UTXO filter which is to be consulted when
|
|
// creating FilteredBlocks to be sent to subscribed clients. This
|
|
// method is cumulative meaning repeated calls to this method should
|
|
// _expand_ the size of the UTXO sub-set currently being watched. If
|
|
// the set updateHeight is _lower_ than the best known height of the
|
|
// implementation, then the state should be rewound to ensure all
|
|
// relevant notifications are dispatched, meaning blocks with a height
|
|
// lower than the best known height might be sent over the
|
|
// FilteredBlocks() channel.
|
|
UpdateFilter(ops []graphdb.EdgePoint, updateHeight uint32) error
|
|
|
|
// FilterBlock takes a block hash, and returns a FilteredBlocks which
|
|
// is the result of applying the current registered UTXO sub-set on the
|
|
// block corresponding to that block hash.
|
|
//
|
|
// TODO(roasbeef): make a version that does by height also?
|
|
FilterBlock(blockHash *chainhash.Hash) (*FilteredBlock, error)
|
|
|
|
// Start starts all goroutine necessary for the operation of the
|
|
// FilteredChainView implementation.
|
|
Start() error
|
|
|
|
// Stop stops all goroutines which we launched by the prior call to the
|
|
// Start method.
|
|
Stop() error
|
|
}
|
|
|
|
// FilteredBlock is a block which includes the transactions that modify the
|
|
// subscribed sub-set of the UTXO set registered to the current
|
|
// FilteredChainView concrete implementation.
|
|
type FilteredBlock struct {
|
|
// Hash is the hash of the newly filtered block.
|
|
Hash chainhash.Hash
|
|
|
|
// Height is the height of the newly filtered block.
|
|
Height uint32
|
|
|
|
// Transactions is the set of transactions which modify (spend) the
|
|
// subscribed UTXO subset.
|
|
Transactions []*wire.MsgTx
|
|
}
|