tapchannel

package

Go to main page

Versions in this module

v0

v0.5.0

Dec 19, 2024

Changes in this version

+ var ErrNoPeer = errors.New("peer not found")

+ func AddTweakWithIndex(maybeTweak []byte, index input.HtlcIndex) []byte

+ func ScriptKeyTweakFromHtlcIndex(index input.HtlcIndex) *secp256k1.ModNScalar

+ func TweakHtlcTree(tree input.ScriptTree, index input.HtlcIndex) input.ScriptTree

+ func TweakPubKeyWithIndex(pubKey *btcec.PublicKey, index input.HtlcIndex) *btcec.PublicKey

+ func TweakedRevocationKeyRing(keyRing *lnwallet.CommitmentKeyRing, index input.HtlcIndex) *lnwallet.CommitmentKeyRing

type AssetSyncer

+ FetchAssetMetaForAsset func(ctx context.Context, assetID asset.ID) (*proof.MetaReveal, error)

type AuxInvoiceManager

+ func (s *AuxInvoiceManager) RfqPeerFromScid(scid uint64) (route.Vertex, error)

type AuxSweeper

+ func (a *AuxSweeper) ExtraBudgetForInputs(inputs []input.Input) lfn.Result[btcutil.Amount]

type AuxTrafficShaper

+ func (s *AuxTrafficShaper) ShouldHandleTraffic(_ lnwire.ShortChannelID, fundingBlob lfn.Option[tlv.Blob]) (bool, error)

+ type FeatureBitVerifer interface

+ HasFeature func(ctx context.Context, peerPub btcec.PublicKey, bit lnwire.FeatureBit) (bool, error)

type FundingControllerCfg

+ ErrChan chan<- error

+ FeatureBits FeatureBitVerifer

type OpenChanReq

+ RemoteMaxHtlc uint32

type PsbtChannelFunder

+ ChannelAcceptor func(ctx context.Context, acceptor lndclient.AcceptorFunction) (chan error, error)

+ type RfqLookup interface

+ RfqPeerFromScid func(scid uint64) (route.Vertex, error)

+ type RfqManager interface

+ LocalAcceptedSellQuotes func() rfq.SellAcceptMap

+ PeerAcceptedBuyQuotes func() rfq.BuyAcceptMap

v0.5.0-rc2

Dec 11, 2024

v0.5.0-rc1

Nov 27, 2024

v0.4.1

Jul 25, 2024

v0.4.0

Jul 23, 2024

Changes in this version

+ const DefaultTimeout

+ const MsgEndpointName

+ const Subsystem

+ var DefaultOnChainHtlcAmount = lnwallet.DustLimitForSize(input.UnknownWitnessSize)

+ var ErrCommitmentNotSet = fmt.Errorf("output commitment not set")

+ var ErrInputOutputSumMismatch = fmt.Errorf("input and output sum mismatch")

+ var ErrMissingAllocations = fmt.Errorf("no allocations provided")

+ var ErrMissingInputs = fmt.Errorf("no inputs provided")

+ var ErrNormalAssetsOnly = fmt.Errorf("only normal assets are supported")

+ func ApplyHtlcView(chainParams *address.ChainParams, chanState *channeldb.OpenChannel, ...) (lfn.Option[tlv.Blob], error)

+ func AssignOutputCommitments(allocations []*Allocation, outCommitments tappsbt.OutputCommitments) error

+ func CreateSecondLevelHtlcTx(chanState *channeldb.OpenChannel, commitTx *wire.MsgTx, htlcAmt btcutil.Amount, ...) (input.AuxTapLeaf, error)

+ func DisableLog()

+ func DistributeCoins(inputs []*proof.Proof, allocations []*Allocation, ...) ([]*tappsbt.VPacket, error)

+ func FakeCommitTx(fundingOutpoint wire.OutPoint, allocations []*Allocation) (*wire.MsgTx, error)

+ func FetchLeavesFromCommit(chainParams *address.ChainParams, chanState *channeldb.OpenChannel, ...) (lfn.Option[lnwallet.CommitAuxLeaves], error)

+ func FetchLeavesFromRevocation(rev *channeldb.RevocationLog) (lfn.Option[lnwallet.CommitAuxLeaves], error)

+ func FetchLeavesFromView(chainParams *address.ChainParams, chanState *channeldb.OpenChannel, ...) (lfn.Option[lnwallet.CommitAuxLeaves], lnwallet.CommitSortFunc, error)

+ func FilterByType(allocType AllocationType) func(a *Allocation) bool

+ func FilterByTypeExclude(excludeAllocType AllocationType) func(a *Allocation) bool

+ func InPlaceAllocationSort(allocations []*Allocation)

+ func InPlaceCustomCommitSort(tx *wire.MsgTx, cltvs []uint32, htlcIndexes []input.HtlcIndex, ...) error

+ func LeavesFromTapscriptScriptTree(scriptTree input.ScriptDescriptor) ([]txscript.TapLeaf, input.ScriptTree, error)

+ func NonAssetExclusionProofs(allocations []*Allocation) tapsend.ExclusionProofGenerator

+ func PackSigs(sigBlob []lfn.Option[tlv.Blob]) (lfn.Option[tlv.Blob], error)

+ func SanityCheckAmounts(ourBalance, theirBalance btcutil.Amount, ...) (bool, bool, error)

+ func ToCommitment(allocations []*Allocation, vPackets []*tappsbt.VPacket) (*cmsg.Commitment, error)

+ func UnpackSigs(blob lfn.Option[tlv.Blob]) ([]lfn.Option[tlv.Blob], error)

+ func UseLogger(logger btclog.Logger)

+ func VerifySecondLevelSigs(chainParams *address.ChainParams, chanState *channeldb.OpenChannel, ...) error

+ type Allocation struct

+ Amount uint64

+ AssetVersion asset.Version

+ BtcAmount btcutil.Amount

+ CLTV uint32

+ HtlcIndex input.HtlcIndex

+ InternalKey *btcec.PublicKey

+ NonAssetLeaves []txscript.TapLeaf

+ OutputCommitment *commitment.TapCommitment

+ OutputIndex uint32

+ ProofDeliveryAddress *url.URL

+ ScriptKey asset.ScriptKey

+ Sequence uint32

+ SortTaprootKeyBytes []byte

+ SplitRoot bool

+ Type AllocationType

+ func CreateAllocations(chanState *channeldb.OpenChannel, ourBalance, theirBalance btcutil.Amount, ...) ([]*Allocation, error)

+ func CreateSecondLevelHtlcPackets(chanState *channeldb.OpenChannel, commitTx *wire.MsgTx, htlcAmt btcutil.Amount, ...) ([]*tappsbt.VPacket, []*Allocation, error)

+ func GenerateCommitmentAllocations(prevState *cmsg.Commitment, chanState *channeldb.OpenChannel, ...) ([]*Allocation, *cmsg.Commitment, error)

+ func (a *Allocation) AuxLeaf() (txscript.TapLeaf, error)

+ func (a *Allocation) MatchesOutput(pkScript []byte, value int64, cltv uint32, htlcIndex input.HtlcIndex) (bool, error)

+ type AllocationType uint8

+ const AllocationTypeNoAssets

+ const CommitAllocationHtlcIncoming

+ const CommitAllocationHtlcOutgoing

+ const CommitAllocationToLocal

+ const CommitAllocationToRemote

+ const SecondLevelHtlcAllocation

+ type AssetChanIntent interface

+ BindPsbt func(context.Context, *psbt.Packet) error

+ FundingPsbt func() (*psbt.Packet, error)

+ type AssetSyncer interface

+ QueryAssetInfo func(ctx context.Context, id asset.ID) (*asset.AssetGroup, error)

+ type AuxChanCloser struct

+ func NewAuxChanCloser(cfg AuxChanCloserCfg) *AuxChanCloser

+ func (a *AuxChanCloser) AuxCloseOutputs(desc chancloser.AuxCloseDesc) (lfn.Option[chancloser.AuxCloseOutputs], error)

+ func (a *AuxChanCloser) FinalizeClose(desc chancloser.AuxCloseDesc, closeTx *wire.MsgTx) error

+ func (a *AuxChanCloser) ShutdownBlob(req chancloser.AuxShutdownReq) (lfn.Option[lnwire.CustomRecords], error)

+ type AuxChanCloserCfg struct

+ AddrBook *address.Book

+ ChainBridge tapgarden.ChainBridge

+ ChainParams *address.ChainParams

+ DefaultCourierAddr *url.URL

+ GroupVerifier proof.GroupVerifier

+ HeaderVerifier proof.HeaderVerifier

+ ProofArchive proof.Archiver

+ ProofFetcher proof.CourierDispatch

+ TxSender tapfreighter.Porter

+ type AuxInvoiceManager struct

+ func NewAuxInvoiceManager(cfg *InvoiceManagerConfig) *AuxInvoiceManager

+ func (s *AuxInvoiceManager) Start() error

+ func (s *AuxInvoiceManager) Stop() error

+ type AuxLeafSigner struct

+ func NewAuxLeafSigner(cfg *LeafSignerConfig) *AuxLeafSigner

+ func (s *AuxLeafSigner) Start() error

+ func (s *AuxLeafSigner) Stop() error

+ func (s *AuxLeafSigner) SubmitSecondLevelSigBatch(chanState *channeldb.OpenChannel, commitTx *wire.MsgTx, ...) error

+ type AuxSweeper struct

+ func NewAuxSweeper(cfg *AuxSweeperCfg) *AuxSweeper

+ func (a *AuxSweeper) DeriveSweepAddr(inputs []input.Input, change lnwallet.AddrWithKey) lfn.Result[sweep.SweepOutput]

+ func (a *AuxSweeper) NotifyBroadcast(req *sweep.BumpRequest, tx *wire.MsgTx, fee btcutil.Amount) error

+ func (a *AuxSweeper) ResolveContract(req lnwallet.ResolutionReq) lfn.Result[tlv.Blob]

+ func (a *AuxSweeper) Start() error

+ func (a *AuxSweeper) Stop() error

+ type AuxSweeperCfg struct

+ AddrBook *address.Book

+ ChainBridge tapgarden.ChainBridge

+ ChainParams address.ChainParams

+ DefaultCourierAddr *url.URL

+ GroupVerifier proof.GroupVerifier

+ HeaderVerifier proof.HeaderVerifier

+ ProofArchive proof.Archiver

+ ProofFetcher proof.CourierDispatch

+ Signer VirtualPacketSigner

+ TxSender tapfreighter.Porter

+ type AuxTrafficShaper struct

+ func NewAuxTrafficShaper(cfg *TrafficShaperConfig) *AuxTrafficShaper

+ func (s *AuxTrafficShaper) HandleTraffic(_ lnwire.ShortChannelID, fundingBlob lfn.Option[tlv.Blob]) (bool, error)

+ func (s *AuxTrafficShaper) PaymentBandwidth(htlcBlob, commitmentBlob lfn.Option[tlv.Blob], ...) (lnwire.MilliSatoshi, error)

+ func (s *AuxTrafficShaper) ProduceHtlcExtraData(totalAmount lnwire.MilliSatoshi, htlcCustomRecords lnwire.CustomRecords) (lnwire.MilliSatoshi, tlv.Blob, error)

+ func (s *AuxTrafficShaper) Start() error

+ func (s *AuxTrafficShaper) Stop() error

+ type DecodedDescriptor struct

+ AssetBalances []*rfqmsg.AssetBalance

+ type DecodedView struct

+ FeePerKw chainfee.SatPerKWeight

+ OurUpdates []*DecodedDescriptor

+ TheirUpdates []*DecodedDescriptor

+ func ComputeView(ourBalance, theirBalance uint64, isOurCommit bool, original *lnwallet.HtlcView) (uint64, uint64, *DecodedView, *lnwallet.HtlcView, error)

+ type ErrorReporter interface

+ ReportError func(ctx context.Context, peer btcec.PublicKey, pid funding.PendingChanID, ...)

+ type FundReq struct

+ AssetAmount uint64

+ AssetID asset.ID

+ FeeRate chainfee.SatPerVByte

+ PeerPub btcec.PublicKey

+ PushAmount btcutil.Amount

+ type FundingController struct

+ func NewFundingController(cfg FundingControllerCfg) *FundingController

+ func (f *FundingController) CanHandle(msg protofsm.PeerMsg) bool

+ func (f *FundingController) ChannelFinalized(pid funding.PendingChanID) error

+ func (f *FundingController) ChannelReady(channel *channeldb.OpenChannel) error

+ func (f *FundingController) DeriveTapscriptRoot(pid funding.PendingChanID) (lfn.Option[chainhash.Hash], error)

+ func (f *FundingController) DescFromPendingChanID(pid funding.PendingChanID, openChan *channeldb.OpenChannel, ...) (lfn.Option[lnwallet.AuxFundingDesc], error)

+ func (f *FundingController) FundChannel(ctx context.Context, req FundReq) (*wire.OutPoint, error)

+ func (f *FundingController) Name() string

+ func (f *FundingController) SendMessage(msg protofsm.PeerMsg) bool

+ func (f *FundingController) Start() error

+ func (f *FundingController) Stop() error

+ type FundingControllerCfg struct

+ AddrBook *tapdb.TapAddressBook

+ AssetSyncer AssetSyncer

+ AssetWallet tapfreighter.Wallet

+ ChainBridge tapfreighter.ChainBridge

+ ChainParams address.ChainParams

+ ChainWallet tapfreighter.WalletAnchor

+ ChannelFunder PsbtChannelFunder

+ CoinSelector tapfreighter.CoinSelector

+ DefaultCourierAddr *url.URL

+ ErrReporter ErrorReporter

+ GroupKeyIndex tapsend.AssetGroupQuerier

+ GroupVerifier proof.GroupVerifier

+ HeaderVerifier proof.HeaderVerifier

+ PeerMessenger PeerMessenger

+ RfqManager *rfq.Manager

+ TxPublisher TxPublisher

+ TxSender tapfreighter.Porter

+ type FundingScriptTree struct

+ func NewFundingScriptTree() *FundingScriptTree

+ type InvoiceHtlcModifier interface

+ HtlcModifier func(ctx context.Context, handler lndclient.InvoiceHtlcModifyHandler) error

+ type InvoiceManagerConfig struct

+ ChainParams *address.ChainParams

+ InvoiceHtlcModifier InvoiceHtlcModifier

+ RfqManager *rfq.Manager

+ type LeafSignerConfig struct

+ ChainParams *address.ChainParams

+ Signer VirtualPacketSigner

+ type OpenChanReq struct

+ ChanAmt btcutil.Amount

+ PeerPub btcec.PublicKey

+ PsbtTemplate *psbt.Packet

+ PushAmt btcutil.Amount

+ TempPID funding.PendingChanID

+ type PeerMessenger interface

+ SendMessage func(ctx context.Context, peer btcec.PublicKey, msg lnwire.Message) error

+ type PsbtChannelFunder interface

+ OpenChannel func(context.Context, OpenChanReq) (AssetChanIntent, error)

+ type TrafficShaperConfig struct

+ ChainParams *address.ChainParams

+ RfqManager *rfq.Manager

+ type TxPublisher interface

+ PublishTransaction func(context.Context, *wire.MsgTx) error

+ type VirtualPacketSigner interface

+ SignVirtualPacket func(vPkt *tappsbt.VPacket, signOpts ...tapfreighter.SignVirtualPacketOption) ([]uint32, error)

v0.4.0-rc4

Jul 12, 2024

v0.4.0-rc1

Jun 27, 2024

v0.4.0-alpha.rc3

Jul 10, 2024

v0.4.0-alpha.rc2

Jul 3, 2024

v0.4.0-alpha.rc1

Jun 27, 2024

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL