← Watch feed
lnwallet+walletrpc: add SubmitPackage for v3 CPFP package relay
Public commit record
73/100 · Adequate
What the developer wrote
Authored by Elle Mouton
lnwallet+walletrpc: add SubmitPackage for v3 CPFP package relay
Add SubmitPackage to the lnwallet.WalletController interface and a new
WalletKit.SubmitPackage RPC, so a client of lnd can relay a package of
related transactions (parents first, child last) through lnd's own chain
connection. This lets a zero-fee v3/TRUC parent be accepted via its
fee-paying CPFP child without the caller needing a separate connection to
the chain backend.
BtcWallet.SubmitPackage forwards to the chain backend's submitpackage for
bitcoind/btcd, and broadcasts each transaction individually for neutrino
(no mempool; relies on the peer's 1p1c package relay). The WalletKit
handler maps the proto request/response to the btcjson result and is
gated by the onchain:write macaroon permission. Mock controllers and the
no-chain backend gain trivial implementations.
✓ Specific, descriptive subject✓ Names a concrete action or component✓ Provides detailed explanatory context
What changed, and why it matters
This commit adds a new RPC called SubmitPackage to LND's WalletKit. It lets users submit a group of related Bitcoin transactions together so a zero-fee parent can be accepted because a later child transaction pays its fee. This is a feature addition, not a fix for a known vulnerability. The code is careful about limits and permissions, but it does expose a new on-chain write capability that could be misused if an attacker already has a valid macaroon.
Recommended action
Review the new SubmitPackage RPC handler for robustness: ensure transaction deserialization cannot be abused for resource exhaustion, confirm the onchain:write macaroon gating is appropriate, and verify that the fee-rate conversion and neutrino fallback behavior are documented for callers. No immediate security patch appears necessary.
Security signals we found
01
New RPC endpoint gated by onchain:write macaroon permission
02
Package size bounded to 25 transactions to limit deserialization work
03
Fee-rate ceiling passed through to backend; explicit 0 disables limit
04
Neutrino path rejects caller-provided max fee rate rather than silently ignoring it
05
btcd backend unsupported for real package submission
06
No input validation beyond transaction deserialization and count limit
Evidence from the diff
The change introduces WalletKit.SubmitPackage, a new gRPC/REST endpoint gated by the onchain:write macaroon permission. It accepts a list of raw transactions and an optional sat/vByte fee-rate ceiling, deserializes them, enforces a 25-transaction package limit, and forwards to the chain backend. For bitcoind it uses submitpackage; for btcd it returns an error; for neutrino it broadcasts each transaction individually and returns a deliberately non-success ‘broadcast-unverified’ result. The commit also updates btcwallet from v0.17.0 to v0.18.0 and adds interface methods, mocks, and a unit test for the fee-rate conversion.
Changed components
lnrpc/walletrpc/walletkit.protolnrpc/walletrpc/walletkit_server.golnwallet/btcwallet/btcwallet.golnwallet/interface.gochainreg/no_chain_backend.golnmock/chain.golntest/mock/walletcontroller.golnwallet/mock.goInspect captured patch +1019 / −215
diff --git a/chainreg/no_chain_backend.go b/chainreg/no_chain_backend.go
index 02dfed5..5e55553 100644
--- a/chainreg/no_chain_backend.go
+++ b/chainreg/no_chain_backend.go
@@ -221,6 +221,15 @@ func (n *NoChainSource) TestMempoolAccept([]*wire.MsgTx,
return nil, nil
}
+// SubmitPackage is a stub implementation of the chain.Interface method for
+// NoChainSource; there is no chain backend, so it always returns
+// errNotImplemented.
+func (n *NoChainSource) SubmitPackage([]*wire.MsgTx,
+ *float64) (*btcjson.SubmitPackageResult, error) {
+
+ return nil, errNotImplemented
+}
+
func (n *NoChainSource) MapRPCErr(err error) error {
return err
}
diff --git a/go.mod b/go.mod
index d17815d..5eceb3a 100644
--- a/go.mod
+++ b/go.mod
@@ -15,7 +15,7 @@ require (
github.com/btcsuite/btcd/wire/v2 v2.0.0
github.com/btcsuite/btclog v1.0.0
github.com/btcsuite/btclog/v2 v2.0.1-0.20250728225537-6090e87c6c5b
- github.com/btcsuite/btcwallet v0.17.0
+ github.com/btcsuite/btcwallet v0.18.0
github.com/btcsuite/btcwallet/wallet/txauthor v1.4.0
github.com/btcsuite/btcwallet/wallet/txrules v1.3.0
github.com/btcsuite/btcwallet/walletdb v1.6.0
diff --git a/go.sum b/go.sum
index 835874d..45f40ca 100644
--- a/go.sum
+++ b/go.sum
@@ -55,8 +55,8 @@ github.com/btcsuite/btclog v1.0.0 h1:sEkpKJMmfGiyZjADwEIgB1NSwMyfdD1FB8v6+w1T0Ns
github.com/btcsuite/btclog v1.0.0/go.mod h1:w7xnGOhwT3lmrS4H3b/D1XAXxvh+tbhUm8xeHN2y3TQ=
github.com/btcsuite/btclog/v2 v2.0.1-0.20250728225537-6090e87c6c5b h1:MQ+Q6sDy37V1wP1Yu79A5KqJutolqUGwA99UZWQDWZM=
github.com/btcsuite/btclog/v2 v2.0.1-0.20250728225537-6090e87c6c5b/go.mod h1:XItGUfVOxotJL8kkuk2Hj3EVow5KCugXl3wWfQ6K0AE=
-github.com/btcsuite/btcwallet v0.17.0 h1:uDHH/4BLWMz3nEGmfVEPepcidKWq4CQ+ZfWY/w71PKk=
-github.com/btcsuite/btcwallet v0.17.0/go.mod h1:1ZMc1EEskov+AKKv4kCMZqN8BwVh9rpXwEyxbeWy2A4=
+github.com/btcsuite/btcwallet v0.18.0 h1:VSRClNLT7NX0wmJEGALz3jOZRRjWPpUdp7VI1Akie1o=
+github.com/btcsuite/btcwallet v0.18.0/go.mod h1:1ZMc1EEskov+AKKv4kCMZqN8BwVh9rpXwEyxbeWy2A4=
github.com/btcsuite/btcwallet/wallet/txauthor v1.4.0 h1:oIkGj32YK1CvWaJGlVwZA1f+y/KVHkfrd2PoST0ZpQs=
github.com/btcsuite/btcwallet/wallet/txauthor v1.4.0/go.mod h1:sGrBjcqQ8UPexuRajFs72+o544CJn3Pavv/5H0VAWVk=
github.com/btcsuite/btcwallet/wallet/txrules v1.3.0 h1:D5aGMwWIxdqek3xEJs4eOdMoh6iga2EI2xSlaXCdnNo=
diff --git a/lnmock/chain.go b/lnmock/chain.go
index cdc007d..84fda00 100644
--- a/lnmock/chain.go
+++ b/lnmock/chain.go
@@ -172,6 +172,19 @@ func (m *MockChain) TestMempoolAccept(txns []*wire.MsgTx, maxFeeRate float64) (
return args.Get(0).([]*btcjson.TestMempoolAcceptResult), args.Error(1)
}
+// SubmitPackage is a mock implementation of the chain.Interface method.
+func (m *MockChain) SubmitPackage(txns []*wire.MsgTx,
+ maxFeeRate *float64) (*btcjson.SubmitPackageResult, error) {
+
+ args := m.Called(txns, maxFeeRate)
+
+ if args.Get(0) == nil {
+ return nil, args.Error(1)
+ }
+
+ return args.Get(0).(*btcjson.SubmitPackageResult), args.Error(1)
+}
+
func (m *MockChain) MapRPCErr(err error) error {
args := m.Called(err)
diff --git a/lnrpc/walletrpc/walletkit.pb.go b/lnrpc/walletrpc/walletkit.pb.go
index 347a38f..40e9506 100644
--- a/lnrpc/walletrpc/walletkit.pb.go
+++ b/lnrpc/walletrpc/walletkit.pb.go
@@ -2461,6 +2461,192 @@ func (x *PublishResponse) GetPublishError() string {
return ""
}
+type SubmitPackageRequest struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ // The raw serialized transactions forming the package, topologically sorted
+ // with unconfirmed parents first and the child last.
+ RawTxs [][]byte `protobuf:"bytes,1,rep,name=raw_txs,json=rawTxs,proto3" json:"raw_txs,omitempty"`
+ // Optional per-transaction fee-rate ceiling in sat/vByte (mapped onto the
+ // submitpackage maxfeerate). When unset the node's default is used; an
+ // explicit 0 means no limit, which is required for a CPFP child whose
+ // standalone feerate is high.
+ SatPerVbyte *uint64 `protobuf:"varint,2,opt,name=sat_per_vbyte,json=satPerVbyte,proto3,oneof" json:"sat_per_vbyte,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *SubmitPackageRequest) Reset() {
+ *x = SubmitPackageRequest{}
+ mi := &file_walletrpc_walletkit_proto_msgTypes[34]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *SubmitPackageRequest) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*SubmitPackageRequest) ProtoMessage() {}
+
+func (x *SubmitPackageRequest) ProtoReflect() protoreflect.Message {
+ mi := &file_walletrpc_walletkit_proto_msgTypes[34]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use SubmitPackageRequest.ProtoReflect.Descriptor instead.
+func (*SubmitPackageRequest) Descriptor() ([]byte, []int) {
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{34}
+}
+
+func (x *SubmitPackageRequest) GetRawTxs() [][]byte {
+ if x != nil {
+ return x.RawTxs
+ }
+ return nil
+}
+
+func (x *SubmitPackageRequest) GetSatPerVbyte() uint64 {
+ if x != nil && x.SatPerVbyte != nil {
+ return *x.SatPerVbyte
+ }
+ return 0
+}
+
+type SubmitPackageTxResult struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ // The transaction id (txid) in hex.
+ Txid string `protobuf:"bytes,1,opt,name=txid,proto3" json:"txid,omitempty"`
+ // If non-empty, the reason this transaction was rejected.
+ Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
+ // If non-empty, the wtxid (in hex) of a transaction with the same txid but a
+ // different witness that was already in the mempool; the submitted
+ // transaction was ignored as a duplicate (witness replacement).
+ OtherWtxid string `protobuf:"bytes,3,opt,name=other_wtxid,json=otherWtxid,proto3" json:"other_wtxid,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *SubmitPackageTxResult) Reset() {
+ *x = SubmitPackageTxResult{}
+ mi := &file_walletrpc_walletkit_proto_msgTypes[35]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *SubmitPackageTxResult) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*SubmitPackageTxResult) ProtoMessage() {}
+
+func (x *SubmitPackageTxResult) ProtoReflect() protoreflect.Message {
+ mi := &file_walletrpc_walletkit_proto_msgTypes[35]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use SubmitPackageTxResult.ProtoReflect.Descriptor instead.
+func (*SubmitPackageTxResult) Descriptor() ([]byte, []int) {
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{35}
+}
+
+func (x *SubmitPackageTxResult) GetTxid() string {
+ if x != nil {
+ return x.Txid
+ }
+ return ""
+}
+
+func (x *SubmitPackageTxResult) GetError() string {
+ if x != nil {
+ return x.Error
+ }
+ return ""
+}
+
+func (x *SubmitPackageTxResult) GetOtherWtxid() string {
+ if x != nil {
+ return x.OtherWtxid
+ }
+ return ""
+}
+
+type SubmitPackageResponse struct {
+ state protoimpl.MessageState `protogen:"open.v1"`
+ // A summary message; "success" when the whole package was accepted.
+ PackageMsg string `protobuf:"bytes,1,opt,name=package_msg,json=packageMsg,proto3" json:"package_msg,omitempty"`
+ // Per-transaction results keyed by wtxid (hex).
+ TxResults map[string]*SubmitPackageTxResult `protobuf:"bytes,2,rep,name=tx_results,json=txResults,proto3" json:"tx_results,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
+ // The txids of transactions evicted via package RBF.
+ ReplacedTransactions []string `protobuf:"bytes,3,rep,name=replaced_transactions,json=replacedTransactions,proto3" json:"replaced_transactions,omitempty"`
+ unknownFields protoimpl.UnknownFields
+ sizeCache protoimpl.SizeCache
+}
+
+func (x *SubmitPackageResponse) Reset() {
+ *x = SubmitPackageResponse{}
+ mi := &file_walletrpc_walletkit_proto_msgTypes[36]
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ ms.StoreMessageInfo(mi)
+}
+
+func (x *SubmitPackageResponse) String() string {
+ return protoimpl.X.MessageStringOf(x)
+}
+
+func (*SubmitPackageResponse) ProtoMessage() {}
+
+func (x *SubmitPackageResponse) ProtoReflect() protoreflect.Message {
+ mi := &file_walletrpc_walletkit_proto_msgTypes[36]
+ if x != nil {
+ ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
+ if ms.LoadMessageInfo() == nil {
+ ms.StoreMessageInfo(mi)
+ }
+ return ms
+ }
+ return mi.MessageOf(x)
+}
+
+// Deprecated: Use SubmitPackageResponse.ProtoReflect.Descriptor instead.
+func (*SubmitPackageResponse) Descriptor() ([]byte, []int) {
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{36}
+}
+
+func (x *SubmitPackageResponse) GetPackageMsg() string {
+ if x != nil {
+ return x.PackageMsg
+ }
+ return ""
+}
+
+func (x *SubmitPackageResponse) GetTxResults() map[string]*SubmitPackageTxResult {
+ if x != nil {
+ return x.TxResults
+ }
+ return nil
+}
+
+func (x *SubmitPackageResponse) GetReplacedTransactions() []string {
+ if x != nil {
+ return x.ReplacedTransactions
+ }
+ return nil
+}
+
type RemoveTransactionResponse struct {
state protoimpl.MessageState `protogen:"open.v1"`
// The status of the remove transaction operation.
@@ -2471,7 +2657,7 @@ type RemoveTransactionResponse struct {
func (x *RemoveTransactionResponse) Reset() {
*x = RemoveTransactionResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[34]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[37]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -2483,7 +2669,7 @@ func (x *RemoveTransactionResponse) String() string {
func (*RemoveTransactionResponse) ProtoMessage() {}
func (x *RemoveTransactionResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[34]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[37]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -2496,7 +2682,7 @@ func (x *RemoveTransactionResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use RemoveTransactionResponse.ProtoReflect.Descriptor instead.
func (*RemoveTransactionResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{34}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{37}
}
func (x *RemoveTransactionResponse) GetStatus() string {
@@ -2528,7 +2714,7 @@ type SendOutputsRequest struct {
func (x *SendOutputsRequest) Reset() {
*x = SendOutputsRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[35]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[38]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -2540,7 +2726,7 @@ func (x *SendOutputsRequest) String() string {
func (*SendOutputsRequest) ProtoMessage() {}
func (x *SendOutputsRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[35]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[38]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -2553,7 +2739,7 @@ func (x *SendOutputsRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use SendOutputsRequest.ProtoReflect.Descriptor instead.
func (*SendOutputsRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{35}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{38}
}
func (x *SendOutputsRequest) GetSatPerKw() int64 {
@@ -2608,7 +2794,7 @@ type SendOutputsResponse struct {
func (x *SendOutputsResponse) Reset() {
*x = SendOutputsResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[36]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[39]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -2620,7 +2806,7 @@ func (x *SendOutputsResponse) String() string {
func (*SendOutputsResponse) ProtoMessage() {}
func (x *SendOutputsResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[36]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[39]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -2633,7 +2819,7 @@ func (x *SendOutputsResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use SendOutputsResponse.ProtoReflect.Descriptor instead.
func (*SendOutputsResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{36}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{39}
}
func (x *SendOutputsResponse) GetRawTx() []byte {
@@ -2653,7 +2839,7 @@ type EstimateFeeRequest struct {
func (x *EstimateFeeRequest) Reset() {
*x = EstimateFeeRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[37]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[40]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -2665,7 +2851,7 @@ func (x *EstimateFeeRequest) String() string {
func (*EstimateFeeRequest) ProtoMessage() {}
func (x *EstimateFeeRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[37]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[40]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -2678,7 +2864,7 @@ func (x *EstimateFeeRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use EstimateFeeRequest.ProtoReflect.Descriptor instead.
func (*EstimateFeeRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{37}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{40}
}
func (x *EstimateFeeRequest) GetConfTarget() int32 {
@@ -2701,7 +2887,7 @@ type EstimateFeeResponse struct {
func (x *EstimateFeeResponse) Reset() {
*x = EstimateFeeResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[38]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[41]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -2713,7 +2899,7 @@ func (x *EstimateFeeResponse) String() string {
func (*EstimateFeeResponse) ProtoMessage() {}
func (x *EstimateFeeResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[38]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[41]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -2726,7 +2912,7 @@ func (x *EstimateFeeResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use EstimateFeeResponse.ProtoReflect.Descriptor instead.
func (*EstimateFeeResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{38}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{41}
}
func (x *EstimateFeeResponse) GetSatPerKw() int64 {
@@ -2806,7 +2992,7 @@ type PendingSweep struct {
func (x *PendingSweep) Reset() {
*x = PendingSweep{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[39]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[42]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -2818,7 +3004,7 @@ func (x *PendingSweep) String() string {
func (*PendingSweep) ProtoMessage() {}
func (x *PendingSweep) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[39]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[42]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -2831,7 +3017,7 @@ func (x *PendingSweep) ProtoReflect() protoreflect.Message {
// Deprecated: Use PendingSweep.ProtoReflect.Descriptor instead.
func (*PendingSweep) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{39}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{42}
}
func (x *PendingSweep) GetOutpoint() *lnrpc.OutPoint {
@@ -2952,7 +3138,7 @@ type PendingSweepsRequest struct {
func (x *PendingSweepsRequest) Reset() {
*x = PendingSweepsRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[40]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[43]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -2964,7 +3150,7 @@ func (x *PendingSweepsRequest) String() string {
func (*PendingSweepsRequest) ProtoMessage() {}
func (x *PendingSweepsRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[40]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[43]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -2977,7 +3163,7 @@ func (x *PendingSweepsRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use PendingSweepsRequest.ProtoReflect.Descriptor instead.
func (*PendingSweepsRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{40}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{43}
}
type PendingSweepsResponse struct {
@@ -2990,7 +3176,7 @@ type PendingSweepsResponse struct {
func (x *PendingSweepsResponse) Reset() {
*x = PendingSweepsResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[41]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[44]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3002,7 +3188,7 @@ func (x *PendingSweepsResponse) String() string {
func (*PendingSweepsResponse) ProtoMessage() {}
func (x *PendingSweepsResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[41]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[44]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3015,7 +3201,7 @@ func (x *PendingSweepsResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use PendingSweepsResponse.ProtoReflect.Descriptor instead.
func (*PendingSweepsResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{41}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{44}
}
func (x *PendingSweepsResponse) GetPendingSweeps() []*PendingSweep {
@@ -3070,7 +3256,7 @@ type BumpFeeRequest struct {
func (x *BumpFeeRequest) Reset() {
*x = BumpFeeRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[42]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[45]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3082,7 +3268,7 @@ func (x *BumpFeeRequest) String() string {
func (*BumpFeeRequest) ProtoMessage() {}
func (x *BumpFeeRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[42]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[45]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3095,7 +3281,7 @@ func (x *BumpFeeRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use BumpFeeRequest.ProtoReflect.Descriptor instead.
func (*BumpFeeRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{42}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{45}
}
func (x *BumpFeeRequest) GetOutpoint() *lnrpc.OutPoint {
@@ -3166,7 +3352,7 @@ type BumpFeeResponse struct {
func (x *BumpFeeResponse) Reset() {
*x = BumpFeeResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[43]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[46]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3178,7 +3364,7 @@ func (x *BumpFeeResponse) String() string {
func (*BumpFeeResponse) ProtoMessage() {}
func (x *BumpFeeResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[43]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[46]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3191,7 +3377,7 @@ func (x *BumpFeeResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use BumpFeeResponse.ProtoReflect.Descriptor instead.
func (*BumpFeeResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{43}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{46}
}
func (x *BumpFeeResponse) GetStatus() string {
@@ -3235,7 +3421,7 @@ type BumpForceCloseFeeRequest struct {
func (x *BumpForceCloseFeeRequest) Reset() {
*x = BumpForceCloseFeeRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[44]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[47]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3247,7 +3433,7 @@ func (x *BumpForceCloseFeeRequest) String() string {
func (*BumpForceCloseFeeRequest) ProtoMessage() {}
func (x *BumpForceCloseFeeRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[44]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[47]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3260,7 +3446,7 @@ func (x *BumpForceCloseFeeRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use BumpForceCloseFeeRequest.ProtoReflect.Descriptor instead.
func (*BumpForceCloseFeeRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{44}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{47}
}
func (x *BumpForceCloseFeeRequest) GetChanPoint() *lnrpc.ChannelPoint {
@@ -3315,7 +3501,7 @@ type BumpForceCloseFeeResponse struct {
func (x *BumpForceCloseFeeResponse) Reset() {
*x = BumpForceCloseFeeResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[45]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[48]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3327,7 +3513,7 @@ func (x *BumpForceCloseFeeResponse) String() string {
func (*BumpForceCloseFeeResponse) ProtoMessage() {}
func (x *BumpForceCloseFeeResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[45]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[48]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3340,7 +3526,7 @@ func (x *BumpForceCloseFeeResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use BumpForceCloseFeeResponse.ProtoReflect.Descriptor instead.
func (*BumpForceCloseFeeResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{45}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{48}
}
func (x *BumpForceCloseFeeResponse) GetStatus() string {
@@ -3366,7 +3552,7 @@ type ListSweepsRequest struct {
func (x *ListSweepsRequest) Reset() {
*x = ListSweepsRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[46]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[49]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3378,7 +3564,7 @@ func (x *ListSweepsRequest) String() string {
func (*ListSweepsRequest) ProtoMessage() {}
func (x *ListSweepsRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[46]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[49]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3391,7 +3577,7 @@ func (x *ListSweepsRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use ListSweepsRequest.ProtoReflect.Descriptor instead.
func (*ListSweepsRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{46}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{49}
}
func (x *ListSweepsRequest) GetVerbose() bool {
@@ -3421,7 +3607,7 @@ type ListSweepsResponse struct {
func (x *ListSweepsResponse) Reset() {
*x = ListSweepsResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[47]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[50]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3433,7 +3619,7 @@ func (x *ListSweepsResponse) String() string {
func (*ListSweepsResponse) ProtoMessage() {}
func (x *ListSweepsResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[47]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[50]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3446,7 +3632,7 @@ func (x *ListSweepsResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use ListSweepsResponse.ProtoReflect.Descriptor instead.
func (*ListSweepsResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{47}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{50}
}
func (x *ListSweepsResponse) GetSweeps() isListSweepsResponse_Sweeps {
@@ -3505,7 +3691,7 @@ type LabelTransactionRequest struct {
func (x *LabelTransactionRequest) Reset() {
*x = LabelTransactionRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[48]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[51]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3517,7 +3703,7 @@ func (x *LabelTransactionRequest) String() string {
func (*LabelTransactionRequest) ProtoMessage() {}
func (x *LabelTransactionRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[48]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[51]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3530,7 +3716,7 @@ func (x *LabelTransactionRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use LabelTransactionRequest.ProtoReflect.Descriptor instead.
func (*LabelTransactionRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{48}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{51}
}
func (x *LabelTransactionRequest) GetTxid() []byte {
@@ -3564,7 +3750,7 @@ type LabelTransactionResponse struct {
func (x *LabelTransactionResponse) Reset() {
*x = LabelTransactionResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[49]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[52]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3576,7 +3762,7 @@ func (x *LabelTransactionResponse) String() string {
func (*LabelTransactionResponse) ProtoMessage() {}
func (x *LabelTransactionResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[49]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[52]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3589,7 +3775,7 @@ func (x *LabelTransactionResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use LabelTransactionResponse.ProtoReflect.Descriptor instead.
func (*LabelTransactionResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{49}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{52}
}
func (x *LabelTransactionResponse) GetStatus() string {
@@ -3644,7 +3830,7 @@ type FundPsbtRequest struct {
func (x *FundPsbtRequest) Reset() {
*x = FundPsbtRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[50]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[53]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3656,7 +3842,7 @@ func (x *FundPsbtRequest) String() string {
func (*FundPsbtRequest) ProtoMessage() {}
func (x *FundPsbtRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[50]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[53]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3669,7 +3855,7 @@ func (x *FundPsbtRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use FundPsbtRequest.ProtoReflect.Descriptor instead.
func (*FundPsbtRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{50}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{53}
}
func (x *FundPsbtRequest) GetTemplate() isFundPsbtRequest_Template {
@@ -3886,7 +4072,7 @@ type FundPsbtResponse struct {
func (x *FundPsbtResponse) Reset() {
*x = FundPsbtResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[51]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[54]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3898,7 +4084,7 @@ func (x *FundPsbtResponse) String() string {
func (*FundPsbtResponse) ProtoMessage() {}
func (x *FundPsbtResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[51]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[54]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3911,7 +4097,7 @@ func (x *FundPsbtResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use FundPsbtResponse.ProtoReflect.Descriptor instead.
func (*FundPsbtResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{51}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{54}
}
func (x *FundPsbtResponse) GetFundedPsbt() []byte {
@@ -3953,7 +4139,7 @@ type TxTemplate struct {
func (x *TxTemplate) Reset() {
*x = TxTemplate{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[52]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[55]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -3965,7 +4151,7 @@ func (x *TxTemplate) String() string {
func (*TxTemplate) ProtoMessage() {}
func (x *TxTemplate) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[52]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[55]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -3978,7 +4164,7 @@ func (x *TxTemplate) ProtoReflect() protoreflect.Message {
// Deprecated: Use TxTemplate.ProtoReflect.Descriptor instead.
func (*TxTemplate) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{52}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{55}
}
func (x *TxTemplate) GetInputs() []*lnrpc.OutPoint {
@@ -4018,7 +4204,7 @@ type PsbtCoinSelect struct {
func (x *PsbtCoinSelect) Reset() {
*x = PsbtCoinSelect{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[53]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[56]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -4030,7 +4216,7 @@ func (x *PsbtCoinSelect) String() string {
func (*PsbtCoinSelect) ProtoMessage() {}
func (x *PsbtCoinSelect) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[53]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[56]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -4043,7 +4229,7 @@ func (x *PsbtCoinSelect) ProtoReflect() protoreflect.Message {
// Deprecated: Use PsbtCoinSelect.ProtoReflect.Descriptor instead.
func (*PsbtCoinSelect) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{53}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{56}
}
func (x *PsbtCoinSelect) GetPsbt() []byte {
@@ -4119,7 +4305,7 @@ type UtxoLease struct {
func (x *UtxoLease) Reset() {
*x = UtxoLease{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[54]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[57]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -4131,7 +4317,7 @@ func (x *UtxoLease) String() string {
func (*UtxoLease) ProtoMessage() {}
func (x *UtxoLease) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[54]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[57]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -4144,7 +4330,7 @@ func (x *UtxoLease) ProtoReflect() protoreflect.Message {
// Deprecated: Use UtxoLease.ProtoReflect.Descriptor instead.
func (*UtxoLease) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{54}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{57}
}
func (x *UtxoLease) GetId() []byte {
@@ -4193,7 +4379,7 @@ type SignPsbtRequest struct {
func (x *SignPsbtRequest) Reset() {
*x = SignPsbtRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[55]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[58]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -4205,7 +4391,7 @@ func (x *SignPsbtRequest) String() string {
func (*SignPsbtRequest) ProtoMessage() {}
func (x *SignPsbtRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[55]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[58]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -4218,7 +4404,7 @@ func (x *SignPsbtRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use SignPsbtRequest.ProtoReflect.Descriptor instead.
func (*SignPsbtRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{55}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{58}
}
func (x *SignPsbtRequest) GetFundedPsbt() []byte {
@@ -4240,7 +4426,7 @@ type SignPsbtResponse struct {
func (x *SignPsbtResponse) Reset() {
*x = SignPsbtResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[56]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[59]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -4252,7 +4438,7 @@ func (x *SignPsbtResponse) String() string {
func (*SignPsbtResponse) ProtoMessage() {}
func (x *SignPsbtResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[56]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[59]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -4265,7 +4451,7 @@ func (x *SignPsbtResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use SignPsbtResponse.ProtoReflect.Descriptor instead.
func (*SignPsbtResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{56}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{59}
}
func (x *SignPsbtResponse) GetSignedPsbt() []byte {
@@ -4297,7 +4483,7 @@ type FinalizePsbtRequest struct {
func (x *FinalizePsbtRequest) Reset() {
*x = FinalizePsbtRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[57]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[60]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -4309,7 +4495,7 @@ func (x *FinalizePsbtRequest) String() string {
func (*FinalizePsbtRequest) ProtoMessage() {}
func (x *FinalizePsbtRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[57]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[60]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -4322,7 +4508,7 @@ func (x *FinalizePsbtRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use FinalizePsbtRequest.ProtoReflect.Descriptor instead.
func (*FinalizePsbtRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{57}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{60}
}
func (x *FinalizePsbtRequest) GetFundedPsbt() []byte {
@@ -4351,7 +4537,7 @@ type FinalizePsbtResponse struct {
func (x *FinalizePsbtResponse) Reset() {
*x = FinalizePsbtResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[58]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[61]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -4363,7 +4549,7 @@ func (x *FinalizePsbtResponse) String() string {
func (*FinalizePsbtResponse) ProtoMessage() {}
func (x *FinalizePsbtResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[58]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[61]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -4376,7 +4562,7 @@ func (x *FinalizePsbtResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use FinalizePsbtResponse.ProtoReflect.Descriptor instead.
func (*FinalizePsbtResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{58}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{61}
}
func (x *FinalizePsbtResponse) GetSignedPsbt() []byte {
@@ -4401,7 +4587,7 @@ type ListLeasesRequest struct {
func (x *ListLeasesRequest) Reset() {
*x = ListLeasesRequest{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[59]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[62]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -4413,7 +4599,7 @@ func (x *ListLeasesRequest) String() string {
func (*ListLeasesRequest) ProtoMessage() {}
func (x *ListLeasesRequest) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[59]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[62]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -4426,7 +4612,7 @@ func (x *ListLeasesRequest) ProtoReflect() protoreflect.Message {
// Deprecated: Use ListLeasesRequest.ProtoReflect.Descriptor instead.
func (*ListLeasesRequest) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{59}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{62}
}
type ListLeasesResponse struct {
@@ -4439,7 +4625,7 @@ type ListLeasesResponse struct {
func (x *ListLeasesResponse) Reset() {
*x = ListLeasesResponse{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[60]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[63]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -4451,7 +4637,7 @@ func (x *ListLeasesResponse) String() string {
func (*ListLeasesResponse) ProtoMessage() {}
func (x *ListLeasesResponse) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[60]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[63]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -4464,7 +4650,7 @@ func (x *ListLeasesResponse) ProtoReflect() protoreflect.Message {
// Deprecated: Use ListLeasesResponse.ProtoReflect.Descriptor instead.
func (*ListLeasesResponse) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{60}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{63}
}
func (x *ListLeasesResponse) GetLockedUtxos() []*UtxoLease {
@@ -4486,7 +4672,7 @@ type ListSweepsResponse_TransactionIDs struct {
func (x *ListSweepsResponse_TransactionIDs) Reset() {
*x = ListSweepsResponse_TransactionIDs{}
- mi := &file_walletrpc_walletkit_proto_msgTypes[61]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[65]
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
ms.StoreMessageInfo(mi)
}
@@ -4498,7 +4684,7 @@ func (x *ListSweepsResponse_TransactionIDs) String() string {
func (*ListSweepsResponse_TransactionIDs) ProtoMessage() {}
func (x *ListSweepsResponse_TransactionIDs) ProtoReflect() protoreflect.Message {
- mi := &file_walletrpc_walletkit_proto_msgTypes[61]
+ mi := &file_walletrpc_walletkit_proto_msgTypes[65]
if x != nil {
ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x))
if ms.LoadMessageInfo() == nil {
@@ -4511,7 +4697,7 @@ func (x *ListSweepsResponse_TransactionIDs) ProtoReflect() protoreflect.Message
// Deprecated: Use ListSweepsResponse_TransactionIDs.ProtoReflect.Descriptor instead.
func (*ListSweepsResponse_TransactionIDs) Descriptor() ([]byte, []int) {
- return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{47, 0}
+ return file_walletrpc_walletkit_proto_rawDescGZIP(), []int{50, 0}
}
func (x *ListSweepsResponse_TransactionIDs) GetTransactionIds() []string {
@@ -4645,7 +4831,25 @@ const file_walletrpc_walletkit_proto_rawDesc = "" +
"\x06tx_hex\x18\x01 \x01(\fR\x05txHex\x12\x14\n" +
"\x05label\x18\x02 \x01(\tR\x05label\"6\n" +
"\x0fPublishResponse\x12#\n" +
- "\rpublish_error\x18\x01 \x01(\tR\fpublishError\"3\n" +
+ "\rpublish_error\x18\x01 \x01(\tR\fpublishError\"j\n" +
+ "\x14SubmitPackageRequest\x12\x17\n" +
+ "\araw_txs\x18\x01 \x03(\fR\x06rawTxs\x12'\n" +
+ "\rsat_per_vbyte\x18\x02 \x01(\x04H\x00R\vsatPerVbyte\x88\x01\x01B\x10\n" +
+ "\x0e_sat_per_vbyte\"b\n" +
+ "\x15SubmitPackageTxResult\x12\x12\n" +
+ "\x04txid\x18\x01 \x01(\tR\x04txid\x12\x14\n" +
+ "\x05error\x18\x02 \x01(\tR\x05error\x12\x1f\n" +
+ "\vother_wtxid\x18\x03 \x01(\tR\n" +
+ "otherWtxid\"\x9d\x02\n" +
+ "\x15SubmitPackageResponse\x12\x1f\n" +
+ "\vpackage_msg\x18\x01 \x01(\tR\n" +
+ "packageMsg\x12N\n" +
+ "\n" +
+ "tx_results\x18\x02 \x03(\v2/.walletrpc.SubmitPackageResponse.TxResultsEntryR\ttxResults\x123\n" +
+ "\x15replaced_transactions\x18\x03 \x03(\tR\x14replacedTransactions\x1a^\n" +
+ "\x0eTxResultsEntry\x12\x10\n" +
+ "\x03key\x18\x01 \x01(\tR\x03key\x126\n" +
+ "\x05value\x18\x02 \x01(\v2 .walletrpc.SubmitPackageTxResultR\x05value:\x028\x01\"3\n" +
"\x19RemoveTransactionResponse\x12\x16\n" +
"\x06status\x18\x01 \x01(\tR\x06status\"\x92\x02\n" +
"\x12SendOutputsRequest\x12\x1c\n" +
@@ -4846,7 +5050,7 @@ const file_walletrpc_walletkit_proto_rawDesc = "" +
"\x1fTAPROOT_COMMITMENT_REVOKE_FINAL\x10**V\n" +
"\x11ChangeAddressType\x12#\n" +
"\x1fCHANGE_ADDRESS_TYPE_UNSPECIFIED\x10\x00\x12\x1c\n" +
- "\x18CHANGE_ADDRESS_TYPE_P2TR\x10\x012\xd6\x11\n" +
+ "\x18CHANGE_ADDRESS_TYPE_P2TR\x10\x012\xaa\x12\n" +
"\tWalletKit\x12L\n" +
"\vListUnspent\x12\x1d.walletrpc.ListUnspentRequest\x1a\x1e.walletrpc.ListUnspentResponse\x12L\n" +
"\vLeaseOutput\x12\x1d.walletrpc.LeaseOutputRequest\x1a\x1e.walletrpc.LeaseOutputResponse\x12R\n" +
@@ -4865,7 +5069,8 @@ const file_walletrpc_walletkit_proto_rawDesc = "" +
"\rImportAccount\x12\x1f.walletrpc.ImportAccountRequest\x1a .walletrpc.ImportAccountResponse\x12X\n" +
"\x0fImportPublicKey\x12!.walletrpc.ImportPublicKeyRequest\x1a\".walletrpc.ImportPublicKeyResponse\x12X\n" +
"\x0fImportTapscript\x12!.walletrpc.ImportTapscriptRequest\x1a\".walletrpc.ImportTapscriptResponse\x12H\n" +
- "\x12PublishTransaction\x12\x16.walletrpc.Transaction\x1a\x1a.walletrpc.PublishResponse\x12[\n" +
+ "\x12PublishTransaction\x12\x16.walletrpc.Transaction\x1a\x1a.walletrpc.PublishResponse\x12R\n" +
+ "\rSubmitPackage\x12\x1f.walletrpc.SubmitPackageRequest\x1a .walletrpc.SubmitPackageResponse\x12[\n" +
"\x11RemoveTransaction\x12 .walletrpc.GetTransactionRequest\x1a$.walletrpc.RemoveTransactionResponse\x12L\n" +
"\vSendOutputs\x12\x1d.walletrpc.SendOutputsRequest\x1a\x1e.walletrpc.SendOutputsResponse\x12L\n" +
"\vEstimateFee\x12\x1d.walletrpc.EstimateFeeRequest\x1a\x1e.walletrpc.EstimateFeeResponse\x12R\n" +
@@ -4892,7 +5097,7 @@ func file_walletrpc_walletkit_proto_rawDescGZIP() []byte {
}
var file_walletrpc_walletkit_proto_enumTypes = make([]protoimpl.EnumInfo, 3)
-var file_walletrpc_walletkit_proto_msgTypes = make([]protoimpl.MessageInfo, 63)
+var file_walletrpc_walletkit_proto_msgTypes = make([]protoimpl.MessageInfo, 67)
var file_walletrpc_walletkit_proto_goTypes = []any{
(AddressType)(0), // 0: walletrpc.AddressType
(WitnessType)(0), // 1: walletrpc.WitnessType
@@ -4931,49 +5136,53 @@ var file_walletrpc_walletkit_proto_goTypes = []any{
(*ImportTapscriptResponse)(nil), // 34: walletrpc.ImportTapscriptResponse
(*Transaction)(nil), // 35: walletrpc.Transaction
(*PublishResponse)(nil), // 36: walletrpc.PublishResponse
- (*RemoveTransactionResponse)(nil), // 37: walletrpc.RemoveTransactionResponse
- (*SendOutputsRequest)(nil), // 38: walletrpc.SendOutputsRequest
- (*SendOutputsResponse)(nil), // 39: walletrpc.SendOutputsResponse
- (*EstimateFeeRequest)(nil), // 40: walletrpc.EstimateFeeRequest
- (*EstimateFeeResponse)(nil), // 41: walletrpc.EstimateFeeResponse
- (*PendingSweep)(nil), // 42: walletrpc.PendingSweep
- (*PendingSweepsRequest)(nil), // 43: walletrpc.PendingSweepsRequest
- (*PendingSweepsResponse)(nil), // 44: walletrpc.PendingSweepsResponse
- (*BumpFeeRequest)(nil), // 45: walletrpc.BumpFeeRequest
- (*BumpFeeResponse)(nil), // 46: walletrpc.BumpFeeResponse
- (*BumpForceCloseFeeRequest)(nil), // 47: walletrpc.BumpForceCloseFeeRequest
- (*BumpForceCloseFeeResponse)(nil), // 48: walletrpc.BumpForceCloseFeeResponse
- (*ListSweepsRequest)(nil), // 49: walletrpc.ListSweepsRequest
- (*ListSweepsResponse)(nil), // 50: walletrpc.ListSweepsResponse
- (*LabelTransactionRequest)(nil), // 51: walletrpc.LabelTransactionRequest
- (*LabelTransactionResponse)(nil), // 52: walletrpc.LabelTransactionResponse
- (*FundPsbtRequest)(nil), // 53: walletrpc.FundPsbtRequest
- (*FundPsbtResponse)(nil), // 54: walletrpc.FundPsbtResponse
- (*TxTemplate)(nil), // 55: walletrpc.TxTemplate
- (*PsbtCoinSelect)(nil), // 56: walletrpc.PsbtCoinSelect
- (*UtxoLease)(nil), // 57: walletrpc.UtxoLease
- (*SignPsbtRequest)(nil), // 58: walletrpc.SignPsbtRequest
- (*SignPsbtResponse)(nil), // 59: walletrpc.SignPsbtResponse
- (*FinalizePsbtRequest)(nil), // 60: walletrpc.FinalizePsbtRequest
- (*FinalizePsbtResponse)(nil), // 61: walletrpc.FinalizePsbtResponse
- (*ListLeasesRequest)(nil), // 62: walletrpc.ListLeasesRequest
- (*ListLeasesResponse)(nil), // 63: walletrpc.ListLeasesResponse
- (*ListSweepsResponse_TransactionIDs)(nil), // 64: walletrpc.ListSweepsResponse.TransactionIDs
- nil, // 65: walletrpc.TxTemplate.OutputsEntry
- (*lnrpc.Utxo)(nil), // 66: lnrpc.Utxo
- (*lnrpc.OutPoint)(nil), // 67: lnrpc.OutPoint
- (*signrpc.TxOut)(nil), // 68: signrpc.TxOut
- (lnrpc.CoinSelectionStrategy)(0), // 69: lnrpc.CoinSelectionStrategy
- (*lnrpc.ChannelPoint)(nil), // 70: lnrpc.ChannelPoint
- (*lnrpc.TransactionDetails)(nil), // 71: lnrpc.TransactionDetails
- (*signrpc.KeyLocator)(nil), // 72: signrpc.KeyLocator
- (*signrpc.KeyDescriptor)(nil), // 73: signrpc.KeyDescriptor
- (*lnrpc.Transaction)(nil), // 74: lnrpc.Transaction
+ (*SubmitPackageRequest)(nil), // 37: walletrpc.SubmitPackageRequest
+ (*SubmitPackageTxResult)(nil), // 38: walletrpc.SubmitPackageTxResult
+ (*SubmitPackageResponse)(nil), // 39: walletrpc.SubmitPackageResponse
+ (*RemoveTransactionResponse)(nil), // 40: walletrpc.RemoveTransactionResponse
+ (*SendOutputsRequest)(nil), // 41: walletrpc.SendOutputsRequest
+ (*SendOutputsResponse)(nil), // 42: walletrpc.SendOutputsResponse
+ (*EstimateFeeRequest)(nil), // 43: walletrpc.EstimateFeeRequest
+ (*EstimateFeeResponse)(nil), // 44: walletrpc.EstimateFeeResponse
+ (*PendingSweep)(nil), // 45: walletrpc.PendingSweep
+ (*PendingSweepsRequest)(nil), // 46: walletrpc.PendingSweepsRequest
+ (*PendingSweepsResponse)(nil), // 47: walletrpc.PendingSweepsResponse
+ (*BumpFeeRequest)(nil), // 48: walletrpc.BumpFeeRequest
+ (*BumpFeeResponse)(nil), // 49: walletrpc.BumpFeeResponse
+ (*BumpForceCloseFeeRequest)(nil), // 50: walletrpc.BumpForceCloseFeeRequest
+ (*BumpForceCloseFeeResponse)(nil), // 51: walletrpc.BumpForceCloseFeeResponse
+ (*ListSweepsRequest)(nil), // 52: walletrpc.ListSweepsRequest
+ (*ListSweepsResponse)(nil), // 53: walletrpc.ListSweepsResponse
+ (*LabelTransactionRequest)(nil), // 54: walletrpc.LabelTransactionRequest
+ (*LabelTransactionResponse)(nil), // 55: walletrpc.LabelTransactionResponse
+ (*FundPsbtRequest)(nil), // 56: walletrpc.FundPsbtRequest
+ (*FundPsbtResponse)(nil), // 57: walletrpc.FundPsbtResponse
+ (*TxTemplate)(nil), // 58: walletrpc.TxTemplate
+ (*PsbtCoinSelect)(nil), // 59: walletrpc.PsbtCoinSelect
+ (*UtxoLease)(nil), // 60: walletrpc.UtxoLease
+ (*SignPsbtRequest)(nil), // 61: walletrpc.SignPsbtRequest
+ (*SignPsbtResponse)(nil), // 62: walletrpc.SignPsbtResponse
+ (*FinalizePsbtRequest)(nil), // 63: walletrpc.FinalizePsbtRequest
+ (*FinalizePsbtResponse)(nil), // 64: walletrpc.FinalizePsbtResponse
+ (*ListLeasesRequest)(nil), // 65: walletrpc.ListLeasesRequest
+ (*ListLeasesResponse)(nil), // 66: walletrpc.ListLeasesResponse
+ nil, // 67: walletrpc.SubmitPackageResponse.TxResultsEntry
+ (*ListSweepsResponse_TransactionIDs)(nil), // 68: walletrpc.ListSweepsResponse.TransactionIDs
+ nil, // 69: walletrpc.TxTemplate.OutputsEntry
+ (*lnrpc.Utxo)(nil), // 70: lnrpc.Utxo
+ (*lnrpc.OutPoint)(nil), // 71: lnrpc.OutPoint
+ (*signrpc.TxOut)(nil), // 72: signrpc.TxOut
+ (lnrpc.CoinSelectionStrategy)(0), // 73: lnrpc.CoinSelectionStrategy
+ (*lnrpc.ChannelPoint)(nil), // 74: lnrpc.ChannelPoint
+ (*lnrpc.TransactionDetails)(nil), // 75: lnrpc.TransactionDetails
+ (*signrpc.KeyLocator)(nil), // 76: signrpc.KeyLocator
+ (*signrpc.KeyDescriptor)(nil), // 77: signrpc.KeyDescriptor
+ (*lnrpc.Transaction)(nil), // 78: lnrpc.Transaction
}
var file_walletrpc_walletkit_proto_depIdxs = []int32{
- 66, // 0: walletrpc.ListUnspentResponse.utxos:type_name -> lnrpc.Utxo
- 67, // 1: walletrpc.LeaseOutputRequest.outpoint:type_name -> lnrpc.OutPoint
- 67, // 2: walletrpc.ReleaseOutputRequest.outpoint:type_name -> lnrpc.OutPoint
+ 70, // 0: walletrpc.ListUnspentResponse.utxos:type_name -> lnrpc.Utxo
+ 71, // 1: walletrpc.LeaseOutputRequest.outpoint:type_name -> lnrpc.OutPoint
+ 71, // 2: walletrpc.ReleaseOutputRequest.outpoint:type_name -> lnrpc.OutPoint
0, // 3: walletrpc.AddrRequest.type:type_name -> walletrpc.AddressType
0, // 4: walletrpc.Account.address_type:type_name -> walletrpc.AddressType
0, // 5: walletrpc.AccountWithAddresses.address_type:type_name -> walletrpc.AddressType
@@ -4988,85 +5197,89 @@ var file_walletrpc_walletkit_proto_depIdxs = []int32{
33, // 14: walletrpc.ImportTapscriptRequest.partial_reveal:type_name -> walletrpc.TapscriptPartialReveal
32, // 15: walletrpc.TapscriptFullTree.all_leaves:type_name -> walletrpc.TapLeaf
32, // 16: walletrpc.TapscriptPartialReveal.revealed_leaf:type_name -> walletrpc.TapLeaf
- 68, // 17: walletrpc.SendOutputsRequest.outputs:type_name -> signrpc.TxOut
- 69, // 18: walletrpc.SendOutputsRequest.coin_selection_strategy:type_name -> lnrpc.CoinSelectionStrategy
- 67, // 19: walletrpc.PendingSweep.outpoint:type_name -> lnrpc.OutPoint
- 1, // 20: walletrpc.PendingSweep.witness_type:type_name -> walletrpc.WitnessType
- 42, // 21: walletrpc.PendingSweepsResponse.pending_sweeps:type_name -> walletrpc.PendingSweep
- 67, // 22: walletrpc.BumpFeeRequest.outpoint:type_name -> lnrpc.OutPoint
- 70, // 23: walletrpc.BumpForceCloseFeeRequest.chan_point:type_name -> lnrpc.ChannelPoint
- 71, // 24: walletrpc.ListSweepsResponse.transaction_details:type_name -> lnrpc.TransactionDetails
- 64, // 25: walletrpc.ListSweepsResponse.transaction_ids:type_name -> walletrpc.ListSweepsResponse.TransactionIDs
- 55, // 26: walletrpc.FundPsbtRequest.raw:type_name -> walletrpc.TxTemplate
- 56, // 27: walletrpc.FundPsbtRequest.coin_select:type_name -> walletrpc.PsbtCoinSelect
- 2, // 28: walletrpc.FundPsbtRequest.change_type:type_name -> walletrpc.ChangeAddressType
- 69, // 29: walletrpc.FundPsbtRequest.coin_selection_strategy:type_name -> lnrpc.CoinSelectionStrategy
- 57, // 30: walletrpc.FundPsbtResponse.locked_utxos:type_name -> walletrpc.UtxoLease
- 67, // 31: walletrpc.TxTemplate.inputs:type_name -> lnrpc.OutPoint
- 65, // 32: walletrpc.TxTemplate.outputs:type_name -> walletrpc.TxTemplate.OutputsEntry
- 67, // 33: walletrpc.UtxoLease.outpoint:type_name -> lnrpc.OutPoint
- 57, // 34: walletrpc.ListLeasesResponse.locked_utxos:type_name -> walletrpc.UtxoLease
- 3, // 35: walletrpc.WalletKit.ListUnspent:input_type -> walletrpc.ListUnspentRequest
- 5, // 36: walletrpc.WalletKit.LeaseOutput:input_type -> walletrpc.LeaseOutputRequest
- 7, // 37: walletrpc.WalletKit.ReleaseOutput:input_type -> walletrpc.ReleaseOutputRequest
- 62, // 38: walletrpc.WalletKit.ListLeases:input_type -> walletrpc.ListLeasesRequest
- 9, // 39: walletrpc.WalletKit.DeriveNextKey:input_type -> walletrpc.KeyReq
- 72, // 40: walletrpc.WalletKit.DeriveKey:input_type -> signrpc.KeyLocator
- 10, // 41: walletrpc.WalletKit.NextAddr:input_type -> walletrpc.AddrRequest
- 21, // 42: walletrpc.WalletKit.GetTransaction:input_type -> walletrpc.GetTransactionRequest
- 15, // 43: walletrpc.WalletKit.ListAccounts:input_type -> walletrpc.ListAccountsRequest
- 17, // 44: walletrpc.WalletKit.RequiredReserve:input_type -> walletrpc.RequiredReserveRequest
- 19, // 45: walletrpc.WalletKit.ListAddresses:input_type -> walletrpc.ListAddressesRequest
- 22, // 46: walletrpc.WalletKit.SignMessageWithAddr:input_type -> walletrpc.SignMessageWithAddrRequest
- 24, // 47: walletrpc.WalletKit.VerifyMessageWithAddr:input_type -> walletrpc.VerifyMessageWithAddrRequest
- 26, // 48: walletrpc.WalletKit.ImportAccount:input_type -> walletrpc.ImportAccountRequest
- 28, // 49: walletrpc.WalletKit.ImportPublicKey:input_type -> walletrpc.ImportPublicKeyRequest
- 30, // 50: walletrpc.WalletKit.ImportTapscript:input_type -> walletrpc.ImportTapscriptRequest
- 35, // 51: walletrpc.WalletKit.PublishTransaction:input_type -> walletrpc.Transaction
- 21, // 52: walletrpc.WalletKit.RemoveTransaction:input_type -> walletrpc.GetTransactionRequest
- 38, // 53: walletrpc.WalletKit.SendOutputs:input_type -> walletrpc.SendOutputsRequest
- 40, // 54: walletrpc.WalletKit.EstimateFee:input_type -> walletrpc.EstimateFeeRequest
- 43, // 55: walletrpc.WalletKit.PendingSweeps:input_type -> walletrpc.PendingSweepsRequest
- 45, // 56: walletrpc.WalletKit.BumpFee:input_type -> walletrpc.BumpFeeRequest
- 47, // 57: walletrpc.WalletKit.BumpForceCloseFee:input_type -> walletrpc.BumpForceCloseFeeRequest
- 49, // 58: walletrpc.WalletKit.ListSweeps:input_type -> walletrpc.ListSweepsRequest
- 51, // 59: walletrpc.WalletKit.LabelTransaction:input_type -> walletrpc.LabelTransactionRequest
- 53, // 60: walletrpc.WalletKit.FundPsbt:input_type -> walletrpc.FundPsbtRequest
- 58, // 61: walletrpc.WalletKit.SignPsbt:input_type -> walletrpc.SignPsbtRequest
- 60, // 62: walletrpc.WalletKit.FinalizePsbt:input_type -> walletrpc.FinalizePsbtRequest
- 4, // 63: walletrpc.WalletKit.ListUnspent:output_type -> walletrpc.ListUnspentResponse
- 6, // 64: walletrpc.WalletKit.LeaseOutput:output_type -> walletrpc.LeaseOutputResponse
- 8, // 65: walletrpc.WalletKit.ReleaseOutput:output_type -> walletrpc.ReleaseOutputResponse
- 63, // 66: walletrpc.WalletKit.ListLeases:output_type -> walletrpc.ListLeasesResponse
- 73, // 67: walletrpc.WalletKit.DeriveNextKey:output_type -> signrpc.KeyDescriptor
- 73, // 68: walletrpc.WalletKit.DeriveKey:output_type -> signrpc.KeyDescriptor
- 11, // 69: walletrpc.WalletKit.NextAddr:output_type -> walletrpc.AddrResponse
- 74, // 70: walletrpc.WalletKit.GetTransaction:output_type -> lnrpc.Transaction
- 16, // 71: walletrpc.WalletKit.ListAccounts:output_type -> walletrpc.ListAccountsResponse
- 18, // 72: walletrpc.WalletKit.RequiredReserve:output_type -> walletrpc.RequiredReserveResponse
- 20, // 73: walletrpc.WalletKit.ListAddresses:output_type -> walletrpc.ListAddressesResponse
- 23, // 74: walletrpc.WalletKit.SignMessageWithAddr:output_type -> walletrpc.SignMessageWithAddrResponse
- 25, // 75: walletrpc.WalletKit.VerifyMessageWithAddr:output_type -> walletrpc.VerifyMessageWithAddrResponse
- 27, // 76: walletrpc.WalletKit.ImportAccount:output_type -> walletrpc.ImportAccountResponse
- 29, // 77: walletrpc.WalletKit.ImportPublicKey:output_type -> walletrpc.ImportPublicKeyResponse
- 34, // 78: walletrpc.WalletKit.ImportTapscript:output_type -> walletrpc.ImportTapscriptResponse
- 36, // 79: walletrpc.WalletKit.PublishTransaction:output_type -> walletrpc.PublishResponse
- 37, // 80: walletrpc.WalletKit.RemoveTransaction:output_type -> walletrpc.RemoveTransactionResponse
- 39, // 81: walletrpc.WalletKit.SendOutputs:output_type -> walletrpc.SendOutputsResponse
- 41, // 82: walletrpc.WalletKit.EstimateFee:output_type -> walletrpc.EstimateFeeResponse
- 44, // 83: walletrpc.WalletKit.PendingSweeps:output_type -> walletrpc.PendingSweepsResponse
- 46, // 84: walletrpc.WalletKit.BumpFee:output_type -> walletrpc.BumpFeeResponse
- 48, // 85: walletrpc.WalletKit.BumpForceCloseFee:output_type -> walletrpc.BumpForceCloseFeeResponse
- 50, // 86: walletrpc.WalletKit.ListSweeps:output_type -> walletrpc.ListSweepsResponse
- 52, // 87: walletrpc.WalletKit.LabelTransaction:output_type -> walletrpc.LabelTransactionResponse
- 54, // 88: walletrpc.WalletKit.FundPsbt:output_type -> walletrpc.FundPsbtResponse
- 59, // 89: walletrpc.WalletKit.SignPsbt:output_type -> walletrpc.SignPsbtResponse
- 61, // 90: walletrpc.WalletKit.FinalizePsbt:output_type -> walletrpc.FinalizePsbtResponse
- 63, // [63:91] is the sub-list for method output_type
- 35, // [35:63] is the sub-list for method input_type
- 35, // [35:35] is the sub-list for extension type_name
- 35, // [35:35] is the sub-list for extension extendee
- 0, // [0:35] is the sub-list for field type_name
+ 67, // 17: walletrpc.SubmitPackageResponse.tx_results:type_name -> walletrpc.SubmitPackageResponse.TxResultsEntry
+ 72, // 18: walletrpc.SendOutputsRequest.outputs:type_name -> signrpc.TxOut
+ 73, // 19: walletrpc.SendOutputsRequest.coin_selection_strategy:type_name -> lnrpc.CoinSelectionStrategy
+ 71, // 20: walletrpc.PendingSweep.outpoint:type_name -> lnrpc.OutPoint
+ 1, // 21: walletrpc.PendingSweep.witness_type:type_name -> walletrpc.WitnessType
+ 45, // 22: walletrpc.PendingSweepsResponse.pending_sweeps:type_name -> walletrpc.PendingSweep
+ 71, // 23: walletrpc.BumpFeeRequest.outpoint:type_name -> lnrpc.OutPoint
+ 74, // 24: walletrpc.BumpForceCloseFeeRequest.chan_point:type_name -> lnrpc.ChannelPoint
+ 75, // 25: walletrpc.ListSweepsResponse.transaction_details:type_name -> lnrpc.TransactionDetails
+ 68, // 26: walletrpc.ListSweepsResponse.transaction_ids:type_name -> walletrpc.ListSweepsResponse.TransactionIDs
+ 58, // 27: walletrpc.FundPsbtRequest.raw:type_name -> walletrpc.TxTemplate
+ 59, // 28: walletrpc.FundPsbtRequest.coin_select:type_name -> walletrpc.PsbtCoinSelect
+ 2, // 29: walletrpc.FundPsbtRequest.change_type:type_name -> walletrpc.ChangeAddressType
+ 73, // 30: walletrpc.FundPsbtRequest.coin_selection_strategy:type_name -> lnrpc.CoinSelectionStrategy
+ 60, // 31: walletrpc.FundPsbtResponse.locked_utxos:type_name -> walletrpc.UtxoLease
+ 71, // 32: walletrpc.TxTemplate.inputs:type_name -> lnrpc.OutPoint
+ 69, // 33: walletrpc.TxTemplate.outputs:type_name -> walletrpc.TxTemplate.OutputsEntry
+ 71, // 34: walletrpc.UtxoLease.outpoint:type_name -> lnrpc.OutPoint
+ 60, // 35: walletrpc.ListLeasesResponse.locked_utxos:type_name -> walletrpc.UtxoLease
+ 38, // 36: walletrpc.SubmitPackageResponse.TxResultsEntry.value:type_name -> walletrpc.SubmitPackageTxResult
+ 3, // 37: walletrpc.WalletKit.ListUnspent:input_type -> walletrpc.ListUnspentRequest
+ 5, // 38: walletrpc.WalletKit.LeaseOutput:input_type -> walletrpc.LeaseOutputRequest
+ 7, // 39: walletrpc.WalletKit.ReleaseOutput:input_type -> walletrpc.ReleaseOutputRequest
+ 65, // 40: walletrpc.WalletKit.ListLeases:input_type -> walletrpc.ListLeasesRequest
+ 9, // 41: walletrpc.WalletKit.DeriveNextKey:input_type -> walletrpc.KeyReq
+ 76, // 42: walletrpc.WalletKit.DeriveKey:input_type -> signrpc.KeyLocator
+ 10, // 43: walletrpc.WalletKit.NextAddr:input_type -> walletrpc.AddrRequest
+ 21, // 44: walletrpc.WalletKit.GetTransaction:input_type -> walletrpc.GetTransactionRequest
+ 15, // 45: walletrpc.WalletKit.ListAccounts:input_type -> walletrpc.ListAccountsRequest
+ 17, // 46: walletrpc.WalletKit.RequiredReserve:input_type -> walletrpc.RequiredReserveRequest
+ 19, // 47: walletrpc.WalletKit.ListAddresses:input_type -> walletrpc.ListAddressesRequest
+ 22, // 48: walletrpc.WalletKit.SignMessageWithAddr:input_type -> walletrpc.SignMessageWithAddrRequest
+ 24, // 49: walletrpc.WalletKit.VerifyMessageWithAddr:input_type -> walletrpc.VerifyMessageWithAddrRequest
+ 26, // 50: walletrpc.WalletKit.ImportAccount:input_type -> walletrpc.ImportAccountRequest
+ 28, // 51: walletrpc.WalletKit.ImportPublicKey:input_type -> walletrpc.ImportPublicKeyRequest
+ 30, // 52: walletrpc.WalletKit.ImportTapscript:input_type -> walletrpc.ImportTapscriptRequest
+ 35, // 53: walletrpc.WalletKit.PublishTransaction:input_type -> walletrpc.Transaction
+ 37, // 54: walletrpc.WalletKit.SubmitPackage:input_type -> walletrpc.SubmitPackageRequest
+ 21, // 55: walletrpc.WalletKit.RemoveTransaction:input_type -> walletrpc.GetTransactionRequest
+ 41, // 56: walletrpc.WalletKit.SendOutputs:input_type -> walletrpc.SendOutputsRequest
+ 43, // 57: walletrpc.WalletKit.EstimateFee:input_type -> walletrpc.EstimateFeeRequest
+ 46, // 58: walletrpc.WalletKit.PendingSweeps:input_type -> walletrpc.PendingSweepsRequest
+ 48, // 59: walletrpc.WalletKit.BumpFee:input_type -> walletrpc.BumpFeeRequest
+ 50, // 60: walletrpc.WalletKit.BumpForceCloseFee:input_type -> walletrpc.BumpForceCloseFeeRequest
+ 52, // 61: walletrpc.WalletKit.ListSweeps:input_type -> walletrpc.ListSweepsRequest
+ 54, // 62: walletrpc.WalletKit.LabelTransaction:input_type -> walletrpc.LabelTransactionRequest
+ 56, // 63: walletrpc.WalletKit.FundPsbt:input_type -> walletrpc.FundPsbtRequest
+ 61, // 64: walletrpc.WalletKit.SignPsbt:input_type -> walletrpc.SignPsbtRequest
+ 63, // 65: walletrpc.WalletKit.FinalizePsbt:input_type -> walletrpc.FinalizePsbtRequest
+ 4, // 66: walletrpc.WalletKit.ListUnspent:output_type -> walletrpc.ListUnspentResponse
+ 6, // 67: walletrpc.WalletKit.LeaseOutput:output_type -> walletrpc.LeaseOutputResponse
+ 8, // 68: walletrpc.WalletKit.ReleaseOutput:output_type -> walletrpc.ReleaseOutputResponse
+ 66, // 69: walletrpc.WalletKit.ListLeases:output_type -> walletrpc.ListLeasesResponse
+ 77, // 70: walletrpc.WalletKit.DeriveNextKey:output_type -> signrpc.KeyDescriptor
+ 77, // 71: walletrpc.WalletKit.DeriveKey:output_type -> signrpc.KeyDescriptor
+ 11, // 72: walletrpc.WalletKit.NextAddr:output_type -> walletrpc.AddrResponse
+ 78, // 73: walletrpc.WalletKit.GetTransaction:output_type -> lnrpc.Transaction
+ 16, // 74: walletrpc.WalletKit.ListAccounts:output_type -> walletrpc.ListAccountsResponse
+ 18, // 75: walletrpc.WalletKit.RequiredReserve:output_type -> walletrpc.RequiredReserveResponse
+ 20, // 76: walletrpc.WalletKit.ListAddresses:output_type -> walletrpc.ListAddressesResponse
+ 23, // 77: walletrpc.WalletKit.SignMessageWithAddr:output_type -> walletrpc.SignMessageWithAddrResponse
+ 25, // 78: walletrpc.WalletKit.VerifyMessageWithAddr:output_type -> walletrpc.VerifyMessageWithAddrResponse
+ 27, // 79: walletrpc.WalletKit.ImportAccount:output_type -> walletrpc.ImportAccountResponse
+ 29, // 80: walletrpc.WalletKit.ImportPublicKey:output_type -> walletrpc.ImportPublicKeyResponse
+ 34, // 81: walletrpc.WalletKit.ImportTapscript:output_type -> walletrpc.ImportTapscriptResponse
+ 36, // 82: walletrpc.WalletKit.PublishTransaction:output_type -> walletrpc.PublishResponse
+ 39, // 83: walletrpc.WalletKit.SubmitPackage:output_type -> walletrpc.SubmitPackageResponse
+ 40, // 84: walletrpc.WalletKit.RemoveTransaction:output_type -> walletrpc.RemoveTransactionResponse
+ 42, // 85: walletrpc.WalletKit.SendOutputs:output_type -> walletrpc.SendOutputsResponse
+ 44, // 86: walletrpc.WalletKit.EstimateFee:output_type -> walletrpc.EstimateFeeResponse
+ 47, // 87: walletrpc.WalletKit.PendingSweeps:output_type -> walletrpc.PendingSweepsResponse
+ 49, // 88: walletrpc.WalletKit.BumpFee:output_type -> walletrpc.BumpFeeResponse
+ 51, // 89: walletrpc.WalletKit.BumpForceCloseFee:output_type -> walletrpc.BumpForceCloseFeeResponse
+ 53, // 90: walletrpc.WalletKit.ListSweeps:output_type -> walletrpc.ListSweepsResponse
+ 55, // 91: walletrpc.WalletKit.LabelTransaction:output_type -> walletrpc.LabelTransactionResponse
+ 57, // 92: walletrpc.WalletKit.FundPsbt:output_type -> walletrpc.FundPsbtResponse
+ 62, // 93: walletrpc.WalletKit.SignPsbt:output_type -> walletrpc.SignPsbtResponse
+ 64, // 94: walletrpc.WalletKit.FinalizePsbt:output_type -> walletrpc.FinalizePsbtResponse
+ 66, // [66:95] is the sub-list for method output_type
+ 37, // [37:66] is the sub-list for method input_type
+ 37, // [37:37] is the sub-list for extension type_name
+ 37, // [37:37] is the sub-list for extension extendee
+ 0, // [0:37] is the sub-list for field type_name
}
func init() { file_walletrpc_walletkit_proto_init() }
@@ -5080,11 +5293,12 @@ func file_walletrpc_walletkit_proto_init() {
(*ImportTapscriptRequest_RootHashOnly)(nil),
(*ImportTapscriptRequest_FullKeyOnly)(nil),
}
- file_walletrpc_walletkit_proto_msgTypes[47].OneofWrappers = []any{
+ file_walletrpc_walletkit_proto_msgTypes[34].OneofWrappers = []any{}
+ file_walletrpc_walletkit_proto_msgTypes[50].OneofWrappers = []any{
(*ListSweepsResponse_TransactionDetails)(nil),
(*ListSweepsResponse_TransactionIds)(nil),
}
- file_walletrpc_walletkit_proto_msgTypes[50].OneofWrappers = []any{
+ file_walletrpc_walletkit_proto_msgTypes[53].OneofWrappers = []any{
(*FundPsbtRequest_Psbt)(nil),
(*FundPsbtRequest_Raw)(nil),
(*FundPsbtRequest_CoinSelect)(nil),
@@ -5092,7 +5306,7 @@ func file_walletrpc_walletkit_proto_init() {
(*FundPsbtRequest_SatPerVbyte)(nil),
(*FundPsbtRequest_SatPerKw)(nil),
}
- file_walletrpc_walletkit_proto_msgTypes[53].OneofWrappers = []any{
+ file_walletrpc_walletkit_proto_msgTypes[56].OneofWrappers = []any{
(*PsbtCoinSelect_ExistingOutputIndex)(nil),
(*PsbtCoinSelect_Add)(nil),
}
@@ -5102,7 +5316,7 @@ func file_walletrpc_walletkit_proto_init() {
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: unsafe.Slice(unsafe.StringData(file_walletrpc_walletkit_proto_rawDesc), len(file_walletrpc_walletkit_proto_rawDesc)),
NumEnums: 3,
- NumMessages: 63,
+ NumMessages: 67,
NumExtensions: 0,
NumServices: 1,
},
diff --git a/lnrpc/walletrpc/walletkit.pb.gw.go b/lnrpc/walletrpc/walletkit.pb.gw.go
index c4c4db9..32cfdc3 100644
--- a/lnrpc/walletrpc/walletkit.pb.gw.go
+++ b/lnrpc/walletrpc/walletkit.pb.gw.go
@@ -602,6 +602,40 @@ func local_request_WalletKit_PublishTransaction_0(ctx context.Context, marshaler
}
+func request_WalletKit_SubmitPackage_0(ctx context.Context, marshaler runtime.Marshaler, client WalletKitClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
+ var protoReq SubmitPackageRequest
+ var metadata runtime.ServerMetadata
+
+ newReader, berr := utilities.IOReaderFactory(req.Body)
+ if berr != nil {
+ return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
+ }
+ if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
+ return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
+ }
+
+ msg, err := client.SubmitPackage(ctx, &protoReq, grpc.Header(&metadata.HeaderMD), grpc.Trailer(&metadata.TrailerMD))
+ return msg, metadata, err
+
+}
+
+func local_request_WalletKit_SubmitPackage_0(ctx context.Context, marshaler runtime.Marshaler, server WalletKitServer, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
+ var protoReq SubmitPackageRequest
+ var metadata runtime.ServerMetadata
+
+ newReader, berr := utilities.IOReaderFactory(req.Body)
+ if berr != nil {
+ return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", berr)
+ }
+ if err := marshaler.NewDecoder(newReader()).Decode(&protoReq); err != nil && err != io.EOF {
+ return nil, metadata, status.Errorf(codes.InvalidArgument, "%v", err)
+ }
+
+ msg, err := server.SubmitPackage(ctx, &protoReq)
+ return msg, metadata, err
+
+}
+
func request_WalletKit_RemoveTransaction_0(ctx context.Context, marshaler runtime.Marshaler, client WalletKitClient, req *http.Request, pathParams map[string]string) (proto.Message, runtime.ServerMetadata, error) {
var protoReq GetTransactionRequest
var metadata runtime.ServerMetadata
@@ -1411,6 +1445,31 @@ func RegisterWalletKitHandlerServer(ctx context.Context, mux *runtime.ServeMux,
})
+ mux.Handle("POST", pattern_WalletKit_SubmitPackage_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
+ ctx, cancel := context.WithCancel(req.Context())
+ defer cancel()
+ var stream runtime.ServerTransportStream
+ ctx = grpc.NewContextWithServerTransportStream(ctx, &stream)
+ inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
+ var err error
+ var annotatedContext context.Context
+ annotatedContext, err = runtime.AnnotateIncomingContext(ctx, mux, req, "/walletrpc.WalletKit/SubmitPackage", runtime.WithHTTPPathPattern("/v2/wallet/tx/package"))
+ if err != nil {
+ runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
+ return
+ }
+ resp, md, err := local_request_WalletKit_SubmitPackage_0(annotatedContext, inboundMarshaler, server, req, pathParams)
+ md.HeaderMD, md.TrailerMD = metadata.Join(md.HeaderMD, stream.Header()), metadata.Join(md.TrailerMD, stream.Trailer())
+ annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
+ if err != nil {
+ runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
+ return
+ }
+
+ forward_WalletKit_SubmitPackage_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
+
+ })
+
mux.Handle("POST", pattern_WalletKit_RemoveTransaction_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(req.Context())
defer cancel()
@@ -2101,6 +2160,28 @@ func RegisterWalletKitHandlerClient(ctx context.Context, mux *runtime.ServeMux,
})
+ mux.Handle("POST", pattern_WalletKit_SubmitPackage_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
+ ctx, cancel := context.WithCancel(req.Context())
+ defer cancel()
+ inboundMarshaler, outboundMarshaler := runtime.MarshalerForRequest(mux, req)
+ var err error
+ var annotatedContext context.Context
+ annotatedContext, err = runtime.AnnotateContext(ctx, mux, req, "/walletrpc.WalletKit/SubmitPackage", runtime.WithHTTPPathPattern("/v2/wallet/tx/package"))
+ if err != nil {
+ runtime.HTTPError(ctx, mux, outboundMarshaler, w, req, err)
+ return
+ }
+ resp, md, err := request_WalletKit_SubmitPackage_0(annotatedContext, inboundMarshaler, client, req, pathParams)
+ annotatedContext = runtime.NewServerMetadataContext(annotatedContext, md)
+ if err != nil {
+ runtime.HTTPError(annotatedContext, mux, outboundMarshaler, w, req, err)
+ return
+ }
+
+ forward_WalletKit_SubmitPackage_0(annotatedContext, mux, outboundMarshaler, w, req, resp, mux.GetForwardResponseOptions()...)
+
+ })
+
mux.Handle("POST", pattern_WalletKit_RemoveTransaction_0, func(w http.ResponseWriter, req *http.Request, pathParams map[string]string) {
ctx, cancel := context.WithCancel(req.Context())
defer cancel()
@@ -2381,6 +2462,8 @@ var (
pattern_WalletKit_PublishTransaction_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v2", "wallet", "tx"}, ""))
+ pattern_WalletKit_SubmitPackage_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2, 2, 3}, []string{"v2", "wallet", "tx", "package"}, ""))
+
pattern_WalletKit_RemoveTransaction_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v2", "wallet", "removetx"}, ""))
pattern_WalletKit_SendOutputs_0 = runtime.MustPattern(runtime.NewPattern(1, []int{2, 0, 2, 1, 2, 2}, []string{"v2", "wallet", "send"}, ""))
@@ -2439,6 +2522,8 @@ var (
forward_WalletKit_PublishTransaction_0 = runtime.ForwardResponseMessage
+ forward_WalletKit_SubmitPackage_0 = runtime.ForwardResponseMessage
+
forward_WalletKit_RemoveTransaction_0 = runtime.ForwardResponseMessage
forward_WalletKit_SendOutputs_0 = runtime.ForwardResponseMessage
diff --git a/lnrpc/walletrpc/walletkit.pb.json.go b/lnrpc/walletrpc/walletkit.pb.json.go
index 8337806..ba427b0 100644
--- a/lnrpc/walletrpc/walletkit.pb.json.go
+++ b/lnrpc/walletrpc/walletkit.pb.json.go
@@ -447,6 +447,31 @@ func RegisterWalletKitJSONCallbacks(registry map[string]func(ctx context.Context
callback(string(respBytes), nil)
}
+ registry["walletrpc.WalletKit.SubmitPackage"] = func(ctx context.Context,
+ conn *grpc.ClientConn, reqJSON string, callback func(string, error)) {
+
+ req := &SubmitPackageRequest{}
+ err := marshaler.Unmarshal([]byte(reqJSON), req)
+ if err != nil {
+ callback("", err)
+ return
+ }
+
+ client := NewWalletKitClient(conn)
+ resp, err := client.SubmitPackage(ctx, req)
+ if err != nil {
+ callback("", err)
+ return
+ }
+
+ respBytes, err := marshaler.Marshal(resp)
+ if err != nil {
+ callback("", err)
+ return
+ }
+ callback(string(respBytes), nil)
+ }
+
registry["walletrpc.WalletKit.RemoveTransaction"] = func(ctx context.Context,
conn *grpc.ClientConn, reqJSON string, callback func(string, error)) {
diff --git a/lnrpc/walletrpc/walletkit.proto b/lnrpc/walletrpc/walletkit.proto
index 81176d9..540c571 100644
--- a/lnrpc/walletrpc/walletkit.proto
+++ b/lnrpc/walletrpc/walletkit.proto
@@ -208,6 +208,20 @@ service WalletKit {
*/
rpc PublishTransaction (Transaction) returns (PublishResponse);
+ /* lncli: `wallet submitpackage`
+ SubmitPackage submits a package of related transactions (topologically
+ sorted, unconfirmed parents first and the child last) for atomic
+ validation and acceptance. Real package submission is only performed by
+ the bitcoind backend, via the node's submitpackage RPC, which lets a
+ zero-fee v3/TRUC parent be accepted via its fee-paying CPFP child. The
+ btcd backend does not support submitpackage and returns an error. A
+ neutrino light client has no mempool and cannot atomically accept a
+ package; as a best effort it broadcasts the transactions individually and
+ relies on a peer's 1p1c package relay, returning an unverified result
+ (not a package-accept verdict).
+ */
+ rpc SubmitPackage (SubmitPackageRequest) returns (SubmitPackageResponse);
+
/* lncli: `wallet removetx`
RemoveTransaction attempts to remove the provided transaction from the
internal transaction store of the wallet.
@@ -801,6 +815,48 @@ message PublishResponse {
string publish_error = 1;
}
+message SubmitPackageRequest {
+ /*
+ The raw serialized transactions forming the package, topologically sorted
+ with unconfirmed parents first and the child last.
+ */
+ repeated bytes raw_txs = 1;
+
+ /*
+ Optional per-transaction fee-rate ceiling in sat/vByte (mapped onto the
+ submitpackage maxfeerate). When unset the node's default is used; an
+ explicit 0 means no limit, which is required for a CPFP child whose
+ standalone feerate is high.
+ */
+ optional uint64 sat_per_vbyte = 2;
+}
+
+message SubmitPackageTxResult {
+ // The transaction id (txid) in hex.
+ string txid = 1;
+
+ // If non-empty, the reason this transaction was rejected.
+ string error = 2;
+
+ /*
+ If non-empty, the wtxid (in hex) of a transaction with the same txid but a
+ different witness that was already in the mempool; the submitted
+ transaction was ignored as a duplicate (witness replacement).
+ */
+ string other_wtxid = 3;
+}
+
+message SubmitPackageResponse {
+ // A summary message; "success" when the whole package was accepted.
+ string package_msg = 1;
+
+ // Per-transaction results keyed by wtxid (hex).
+ map<string, SubmitPackageTxResult> tx_results = 2;
+
+ // The txids of transactions evicted via package RBF.
+ repeated string replaced_transactions = 3;
+}
+
message RemoveTransactionResponse {
// The status of the remove transaction operation.
string status = 1;
diff --git a/lnrpc/walletrpc/walletkit.swagger.json b/lnrpc/walletrpc/walletkit.swagger.json
index e5a0946..90365c3 100644
--- a/lnrpc/walletrpc/walletkit.swagger.json
+++ b/lnrpc/walletrpc/walletkit.swagger.json
@@ -832,6 +832,39 @@
]
}
},
+ "/v2/wallet/tx/package": {
+ "post": {
+ "summary": "lncli: `wallet submitpackage`\nSubmitPackage submits a package of related transactions (topologically\nsorted, unconfirmed parents first and the child last) for atomic\nvalidation and acceptance. Real package submission is only performed by\nthe bitcoind backend, via the node's submitpackage RPC, which lets a\nzero-fee v3/TRUC parent be accepted via its fee-paying CPFP child. The\nbtcd backend does not support submitpackage and returns an error. A\nneutrino light client has no mempool and cannot atomically accept a\npackage; as a best effort it broadcasts the transactions individually and\nrelies on a peer's 1p1c package relay, returning an unverified result\n(not a package-accept verdict).",
+ "operationId": "WalletKit_SubmitPackage",
+ "responses": {
+ "200": {
+ "description": "A successful response.",
+ "schema": {
+ "$ref": "#/definitions/walletrpcSubmitPackageResponse"
+ }
+ },
+ "default": {
+ "description": "An unexpected error response.",
+ "schema": {
+ "$ref": "#/definitions/rpcStatus"
+ }
+ }
+ },
+ "parameters": [
+ {
+ "name": "body",
+ "in": "body",
+ "required": true,
+ "schema": {
+ "$ref": "#/definitions/walletrpcSubmitPackageRequest"
+ }
+ }
+ ],
+ "tags": [
+ "WalletKit"
+ ]
+ }
+ },
"/v2/wallet/utxos": {
"post": {
"summary": "ListUnspent returns a list of all utxos spendable by the wallet with a\nnumber of confirmations between the specified minimum and maximum. By\ndefault, all utxos are listed. To list only the unconfirmed utxos, set\nthe unconfirmed_only to true.",
@@ -2180,6 +2213,64 @@
}
}
},
+ "walletrpcSubmitPackageRequest": {
+ "type": "object",
+ "properties": {
+ "raw_txs": {
+ "type": "array",
+ "items": {
+ "type": "string",
+ "format": "byte"
+ },
+ "description": "The raw serialized transactions forming the package, topologically sorted\nwith unconfirmed parents first and the child last."
+ },
+ "sat_per_vbyte": {
+ "type": "string",
+ "format": "uint64",
+ "description": "Optional per-transaction fee-rate ceiling in sat/vByte (mapped onto the\nsubmitpackage maxfeerate). When unset the node's default is used; an\nexplicit 0 means no limit, which is required for a CPFP child whose\nstandalone feerate is high."
+ }
+ }
+ },
+ "walletrpcSubmitPackageResponse": {
+ "type": "object",
+ "properties": {
+ "package_msg": {
+ "type": "string",
+ "description": "A summary message; \"success\" when the whole package was accepted."
+ },
+ "tx_results": {
+ "type": "object",
+ "additionalProperties": {
+ "$ref": "#/definitions/walletrpcSubmitPackageTxResult"
+ },
+ "description": "Per-transaction results keyed by wtxid (hex)."
+ },
+ "replaced_transactions": {
+ "type": "array",
+ "items": {
+ "type": "string"
+ },
+ "description": "The txids of transactions evicted via package RBF."
+ }
+ }
+ },
+ "walletrpcSubmitPackageTxResult": {
+ "type": "object",
+ "properties": {
+ "txid": {
+ "type": "string",
+ "description": "The transaction id (txid) in hex."
+ },
+ "error": {
+ "type": "string",
+ "description": "If non-empty, the reason this transaction was rejected."
+ },
+ "other_wtxid": {
+ "type": "string",
+ "description": "If non-empty, the wtxid (in hex) of a transaction with the same txid but a\ndifferent witness that was already in the mempool; the submitted\ntransaction was ignored as a duplicate (witness replacement)."
+ }
+ }
+ },
"walletrpcTapLeaf": {
"type": "object",
"properties": {
diff --git a/lnrpc/walletrpc/walletkit.yaml b/lnrpc/walletrpc/walletkit.yaml
index b912fea..06c9089 100644
--- a/lnrpc/walletrpc/walletkit.yaml
+++ b/lnrpc/walletrpc/walletkit.yaml
@@ -34,6 +34,9 @@ http:
- selector: walletrpc.WalletKit.PublishTransaction
post: "/v2/wallet/tx"
body: "*"
+ - selector: walletrpc.WalletKit.SubmitPackage
+ post: "/v2/wallet/tx/package"
+ body: "*"
- selector: walletrpc.WalletKit.SendOutputs
post: "/v2/wallet/send"
body: "*"
diff --git a/lnrpc/walletrpc/walletkit_grpc.pb.go b/lnrpc/walletrpc/walletkit_grpc.pb.go
index 4cd79a4..8cd991c 100644
--- a/lnrpc/walletrpc/walletkit_grpc.pb.go
+++ b/lnrpc/walletrpc/walletkit_grpc.pb.go
@@ -156,6 +156,18 @@ type WalletKitClient interface {
// attempt to re-broadcast the transaction on start up, until it enters the
// chain.
PublishTransaction(ctx context.Context, in *Transaction, opts ...grpc.CallOption) (*PublishResponse, error)
+ // lncli: `wallet submitpackage`
+ // SubmitPackage submits a package of related transactions (topologically
+ // sorted, unconfirmed parents first and the child last) for atomic
+ // validation and acceptance. Real package submission is only performed by
+ // the bitcoind backend, via the node's submitpackage RPC, which lets a
+ // zero-fee v3/TRUC parent be accepted via its fee-paying CPFP child. The
+ // btcd backend does not support submitpackage and returns an error. A
+ // neutrino light client has no mempool and cannot atomically accept a
+ // package; as a best effort it broadcasts the transactions individually and
+ // relies on a peer's 1p1c package relay, returning an unverified result
+ // (not a package-accept verdict).
+ SubmitPackage(ctx context.Context, in *SubmitPackageRequest, opts ...grpc.CallOption) (*SubmitPackageResponse, error)
// lncli: `wallet removetx`
// RemoveTransaction attempts to remove the provided transaction from the
// internal transaction store of the wallet.
@@ -443,6 +455,15 @@ func (c *walletKitClient) PublishTransaction(ctx context.Context, in *Transactio
return out, nil
}
+func (c *walletKitClient) SubmitPackage(ctx context.Context, in *SubmitPackageRequest, opts ...grpc.CallOption) (*SubmitPackageResponse, error) {
+ out := new(SubmitPackageResponse)
+ err := c.cc.Invoke(ctx, "/walletrpc.WalletKit/SubmitPackage", in, out, opts...)
+ if err != nil {
+ return nil, err
+ }
+ return out, nil
+}
+
func (c *walletKitClient) RemoveTransaction(ctx context.Context, in *GetTransactionRequest, opts ...grpc.CallOption) (*RemoveTransactionResponse, error) {
out := new(RemoveTransactionResponse)
err := c.cc.Invoke(ctx, "/walletrpc.WalletKit/RemoveTransaction", in, out, opts...)
@@ -682,6 +703,18 @@ type WalletKitServer interface {
// attempt to re-broadcast the transaction on start up, until it enters the
// chain.
PublishTransaction(context.Context, *Transaction) (*PublishResponse, error)
+ // lncli: `wallet submitpackage`
+ // SubmitPackage submits a package of related transactions (topologically
+ // sorted, unconfirmed parents first and the child last) for atomic
+ // validation and acceptance. Real package submission is only performed by
+ // the bitcoind backend, via the node's submitpackage RPC, which lets a
+ // zero-fee v3/TRUC parent be accepted via its fee-paying CPFP child. The
+ // btcd backend does not support submitpackage and returns an error. A
+ // neutrino light client has no mempool and cannot atomically accept a
+ // package; as a best effort it broadcasts the transactions individually and
+ // relies on a peer's 1p1c package relay, returning an unverified result
+ // (not a package-accept verdict).
+ SubmitPackage(context.Context, *SubmitPackageRequest) (*SubmitPackageResponse, error)
// lncli: `wallet removetx`
// RemoveTransaction attempts to remove the provided transaction from the
// internal transaction store of the wallet.
@@ -864,6 +897,9 @@ func (UnimplementedWalletKitServer) ImportTapscript(context.Context, *ImportTaps
func (UnimplementedWalletKitServer) PublishTransaction(context.Context, *Transaction) (*PublishResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method PublishTransaction not implemented")
}
+func (UnimplementedWalletKitServer) SubmitPackage(context.Context, *SubmitPackageRequest) (*SubmitPackageResponse, error) {
+ return nil, status.Errorf(codes.Unimplemented, "method SubmitPackage not implemented")
+}
func (UnimplementedWalletKitServer) RemoveTransaction(context.Context, *GetTransactionRequest) (*RemoveTransactionResponse, error) {
return nil, status.Errorf(codes.Unimplemented, "method RemoveTransaction not implemented")
}
@@ -1216,6 +1252,24 @@ func _WalletKit_PublishTransaction_Handler(srv interface{}, ctx context.Context,
return interceptor(ctx, in, info, handler)
}
+func _WalletKit_SubmitPackage_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+ in := new(SubmitPackageRequest)
+ if err := dec(in); err != nil {
+ return nil, err
+ }
+ if interceptor == nil {
+ return srv.(WalletKitServer).SubmitPackage(ctx, in)
+ }
+ info := &grpc.UnaryServerInfo{
+ Server: srv,
+ FullMethod: "/walletrpc.WalletKit/SubmitPackage",
+ }
+ handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+ return srv.(WalletKitServer).SubmitPackage(ctx, req.(*SubmitPackageRequest))
+ }
+ return interceptor(ctx, in, info, handler)
+}
+
func _WalletKit_RemoveTransaction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(GetTransactionRequest)
if err := dec(in); err != nil {
@@ -1489,6 +1543,10 @@ var WalletKit_ServiceDesc = grpc.ServiceDesc{
MethodName: "PublishTransaction",
Handler: _WalletKit_PublishTransaction_Handler,
},
+ {
+ MethodName: "SubmitPackage",
+ Handler: _WalletKit_SubmitPackage_Handler,
+ },
{
MethodName: "RemoveTransaction",
Handler: _WalletKit_RemoveTransaction_Handler,
diff --git a/lnrpc/walletrpc/walletkit_server.go b/lnrpc/walletrpc/walletkit_server.go
index 1bed7e9..456fb20 100644
--- a/lnrpc/walletrpc/walletkit_server.go
+++ b/lnrpc/walletrpc/walletkit_server.go
@@ -94,6 +94,10 @@ var (
Entity: "onchain",
Action: "write",
}},
+ "/walletrpc.WalletKit/SubmitPackage": {{
+ Entity: "onchain",
+ Action: "write",
+ }},
"/walletrpc.WalletKit/SendOutputs": {{
Entity: "onchain",
Action: "write",
@@ -696,6 +700,87 @@ func (w *WalletKit) PublishTransaction(ctx context.Context,
return &PublishResponse{}, nil
}
+// maxPackageTxns is the maximum number of transactions accepted in a single
+// SubmitPackage request. It mirrors bitcoind's MAX_PACKAGE_COUNT (the limit
+// its submitpackage RPC enforces), so any package the backend could accept
+// fits, while bounding the work an authenticated caller can force from
+// deserializing an arbitrarily long raw_txs list.
+const maxPackageTxns = 25
+
+// SubmitPackage submits a package of related transactions (topologically
+// sorted, unconfirmed parents first and the child last) to the wallet's chain
+// backend for atomic validation and acceptance. This lets a zero-fee v3/TRUC
+// parent confirm via its fee-paying CPFP child without the caller needing a
+// separate connection to the chain backend.
+func (w *WalletKit) SubmitPackage(_ context.Context,
+ req *SubmitPackageRequest) (*SubmitPackageResponse, error) {
+
+ if len(req.RawTxs) == 0 {
+ return nil, fmt.Errorf("must provide at least one transaction")
+ }
+ if len(req.RawTxs) > maxPackageTxns {
+ return nil, fmt.Errorf("package of %d transactions exceeds "+
+ "the maximum of %d", len(req.RawTxs), maxPackageTxns)
+ }
+
+ txns := make([]*wire.MsgTx, 0, len(req.RawTxs))
+ for _, raw := range req.RawTxs {
+ tx := &wire.MsgTx{}
+ if err := tx.Deserialize(bytes.NewReader(raw)); err != nil {
+ return nil, fmt.Errorf("unable to decode tx: %w", err)
+ }
+
+ txns = append(txns, tx)
+ }
+
+ // Map the optional sat/vByte ceiling onto the backend. An unset value
+ // uses the node's default; an explicit value (including 0, meaning no
+ // limit) is passed through unchanged.
+ var maxFeeRate *chainfee.SatPerVByte
+ if req.SatPerVbyte != nil {
+ rate := chainfee.SatPerVByte(*req.SatPerVbyte)
+ maxFeeRate = &rate
+ }
+
+ result, err := w.cfg.Wallet.SubmitPackage(txns, maxFeeRate)
+ if err != nil {
+ return nil, err
+ }
+
+ // Some backends (e.g. the no-chain source or mocks) may return a nil
+ // result; guard against a nil dereference below.
+ if result == nil {
+ return nil, fmt.Errorf("nil result from wallet backend")
+ }
+
+ numResults := len(result.TxResults)
+ resp := &SubmitPackageResponse{
+ PackageMsg: result.PackageMsg,
+ TxResults: make(map[string]*SubmitPackageTxResult, numResults),
+ ReplacedTransactions: make(
+ []string, 0, len(result.ReplacedTransactions),
+ ),
+ }
+ for _, replaced := range result.ReplacedTransactions {
+ resp.ReplacedTransactions = append(
+ resp.ReplacedTransactions, replaced.String(),
+ )
+ }
+ for wtxid, txResult := range result.TxResults {
+ entry := &SubmitPackageTxResult{Txid: txResult.TxID.String()}
+ if txResult.Error != nil {
+ entry.Error = *txResult.Error
+ }
+ if txResult.OtherWtxid != nil {
+ entry.OtherWtxid = txResult.OtherWtxid.String()
+ }
+
+ resp.TxResults[wtxid] = entry
+ }
+
+ return resp, nil
+}
+
// RemoveTransaction attempts to remove the transaction and all of its
// descendants resulting from further spends of the outputs of the provided
// transaction id.
diff --git a/lntest/mock/walletcontroller.go b/lntest/mock/walletcontroller.go
index b553599..90a3310 100644
--- a/lntest/mock/walletcontroller.go
+++ b/lntest/mock/walletcontroller.go
@@ -7,6 +7,7 @@ import (
"github.com/btcsuite/btcd/address/v2"
"github.com/btcsuite/btcd/btcec/v2"
+ "github.com/btcsuite/btcd/btcjson"
"github.com/btcsuite/btcd/btcutil/v2"
"github.com/btcsuite/btcd/btcutil/v2/hdkeychain"
"github.com/btcsuite/btcd/chaincfg/v2"
@@ -241,6 +242,18 @@ func (w *WalletController) PublishTransaction(tx *wire.MsgTx, _ string) error {
return nil
}
+// SubmitPackage publishes each transaction in the package individually,
+// mirroring PublishTransaction.
+func (w *WalletController) SubmitPackage(txns []*wire.MsgTx,
+ _ *chainfee.SatPerVByte) (*btcjson.SubmitPackageResult, error) {
+
+ for _, tx := range txns {
+ w.PublishedTransactions <- tx
+ }
+
+ return &btcjson.SubmitPackageResult{}, nil
+}
+
// GetTransactionDetails currently does nothing.
func (w *WalletController) GetTransactionDetails(
txHash *chainhash.Hash) (*lnwallet.TransactionDetail, error) {
diff --git a/lnwallet/btcwallet/btcwallet.go b/lnwallet/btcwallet/btcwallet.go
index 74bc92c..ecb7b57 100644
--- a/lnwallet/btcwallet/btcwallet.go
+++ b/lnwallet/btcwallet/btcwallet.go
@@ -12,6 +12,7 @@ import (
"github.com/btcsuite/btcd/address/v2"
"github.com/btcsuite/btcd/btcec/v2"
+ "github.com/btcsuite/btcd/btcjson"
"github.com/btcsuite/btcd/btcutil/v2"
"github.com/btcsuite/btcd/btcutil/v2/hdkeychain"
"github.com/btcsuite/btcd/chaincfg/v2"
@@ -1231,6 +1232,91 @@ func (b *BtcWallet) PublishTransaction(tx *wire.MsgTx, label string) error {
return mapRpcclientError(err)
}
+// neutrinoBroadcastMsg is the PackageMsg returned by the neutrino best-effort
+// path. It is deliberately not "success": a neutrino light client has no
+// mempool, so it cannot confirm the package was accepted. It broadcasts the
+// transactions and reports them as broadcast-but-unverified, which callers
+// must treat as an unverified relay attempt, not a package-accept verdict.
+const neutrinoBroadcastMsg = "broadcast-unverified"
+
+// SubmitPackage submits a package of related transactions (topologically
+// sorted, parents first and child last) for atomic validation and acceptance.
+//
+// Only the bitcoind backend performs real package submission, via the node's
+// submitpackage RPC, which lets a zero-fee v3/TRUC parent be accepted via its
+// fee-paying CPFP child (which sendrawtransaction rejects on its own). The
+// btcd backend has no submitpackage handler and returns ErrUnimplemented.
+//
+// A neutrino light client has no mempool and cannot validate or atomically
+// accept a package. As a best effort it broadcasts each transaction
+// individually over the P2P network and relies on a peer's 1p1c package relay
+// to assemble them. The returned PackageMsg is deliberately not "success": a
+// light client cannot confirm acceptance, so callers must treat the result as
+// an unverified broadcast rather than a package-accept verdict.
+func (b *BtcWallet) SubmitPackage(txns []*wire.MsgTx,
+ maxFeeRate *chainfee.SatPerVByte) (*btcjson.SubmitPackageResult,
+ error) {
+
+ if b.chain.BackEnd() == "neutrino" {
+ // The best-effort neutrino broadcast goes through plain
+ // SendRawTransaction, which cannot enforce a fee-rate ceiling,
+ // so reject a caller-provided limit rather than silently
+ // ignoring it and giving a false sense of protection.
+ if maxFeeRate != nil {
+ return nil, fmt.Errorf("max fee rate is not " +
+ "supported for neutrino package broadcast")
+ }
+
+ for i, tx := range txns {
+ if err := b.PublishTransaction(tx, ""); err != nil {
+ return nil, fmt.Errorf("unable to "+
+ "broadcast package tx %d (%v): %w",
+ i, tx.TxHash(), err)
+ }
+ }
+
+ results := make(
+ map[string]btcjson.SubmitPackageTxResult, len(txns),
+ )
+ for _, tx := range txns {
+ results[tx.WitnessHash().String()] =
+ btcjson.SubmitPackageTxResult{TxID: tx.TxHash()}
+ }
+
+ return &btcjson.SubmitPackageResult{
+ PackageMsg: neutrinoBroadcastMsg,
+ TxResults: results,
+ }, nil
+ }
+
+ // bitcoind's submitpackage maxfeerate is expressed in BTC/kvB, so map
+ // the optional sat/vByte ceiling onto it. A nil ceiling leaves the node
+ // default unchanged; an explicit 0 disables the limit.
+ var maxFeeRateBTCPerKvB *float64
+ if maxFeeRate != nil {
+ btcPerKvB := satPerVByteToBTCPerKvB(*maxFeeRate)
+ maxFeeRateBTCPerKvB = &btcPerKvB
+ }
+
+ return b.chain.SubmitPackage(txns, maxFeeRateBTCPerKvB)
+}
+
+// vBytesPerKvB is the number of virtual bytes in a kilo-virtual-byte, used to
+// convert a sat/vByte fee rate into the per-kvB unit bitcoind expects.
+const vBytesPerKvB = 1000
+
+// satPerVByteToBTCPerKvB converts a sat/vByte fee rate into the BTC/kvB unit
+// expected by bitcoind's submitpackage maxfeerate argument: 1 sat/vByte is
+// 1000 sat/kvB, and SatoshiPerBitcoin sats make a BTC, so
+// BTC/kvB = sat/vByte * 1000 / SatoshiPerBitcoin.
+//
+// NOTE: the sat/vByte input is integer, so only whole-sat/vByte ceilings are
+// expressible, and very large values lose precision once the float64 product
+// exceeds 2^53.
+func satPerVByteToBTCPerKvB(rate chainfee.SatPerVByte) float64 {
+ return float64(rate) * vBytesPerKvB / btcutil.SatoshiPerBitcoin
+}
+
// LabelTransaction adds a label to a transaction. If the tx already
// has a label, this call will fail unless the overwrite parameter
// is set. Labels must not be empty, and they are limited to 500 chars.
diff --git a/lnwallet/btcwallet/submitpackage_test.go b/lnwallet/btcwallet/submitpackage_test.go
new file mode 100644
index 0000000..63286f0
--- /dev/null
+++ b/lnwallet/btcwallet/submitpackage_test.go
@@ -0,0 +1,38 @@
+package btcwallet
+
+import (
+ "testing"
+
+ "github.com/lightningnetwork/lnd/lnwallet/chainfee"
+ "github.com/stretchr/testify/require"
+)
+
+// TestSatPerVByteToBTCPerKvB checks the sat/vByte -> BTC/kvB conversion used to
+// map an lnd fee-rate ceiling onto bitcoind's submitpackage maxfeerate
+// argument. A regression here would silently relax or tighten the user's fee
+// ceiling, so the known reference points are pinned.
+func TestSatPerVByteToBTCPerKvB(t *testing.T) {
+ t.Parallel()
+
+ tests := []struct {
+ name string
+ rate chainfee.SatPerVByte
+ want float64
+ }{
+ {name: "zero", rate: 0, want: 0},
+ {name: "1 sat/vByte", rate: 1, want: 0.00001},
+ {name: "10 sat/vByte", rate: 10, want: 0.0001},
+ {name: "250 sat/vByte", rate: 250, want: 0.0025},
+ }
+
+ for _, tc := range tests {
+ t.Run(tc.name, func(t *testing.T) {
+ t.Parallel()
+
+ require.InDelta(
+ t, tc.want, satPerVByteToBTCPerKvB(tc.rate),
+ 1e-12,
+ )
+ })
+ }
+}
diff --git a/lnwallet/interface.go b/lnwallet/interface.go
index b0be6fe..d2adfd2 100644
--- a/lnwallet/interface.go
+++ b/lnwallet/interface.go
@@ -9,6 +9,7 @@ import (
"github.com/btcsuite/btcd/address/v2"
"github.com/btcsuite/btcd/btcec/v2"
"github.com/btcsuite/btcd/btcec/v2/ecdsa"
+ "github.com/btcsuite/btcd/btcjson"
"github.com/btcsuite/btcd/btcutil/v2"
"github.com/btcsuite/btcd/btcutil/v2/hdkeychain"
"github.com/btcsuite/btcd/chaincfg/v2"
@@ -441,6 +442,19 @@ type WalletController interface {
// published transaction.
PublishTransaction(tx *wire.MsgTx, label string) error
+ // SubmitPackage submits a package of related transactions
+ // (topologically sorted, unconfirmed parents first and the child
+ // last) to the chain backend for atomic validation and acceptance.
+ // This lets a zero-fee v3/TRUC parent be accepted via its fee-paying
+ // CPFP child, which a standalone broadcast rejects. maxFeeRate is an
+ // optional per-transaction fee-rate ceiling in sat/vByte (nil leaves
+ // the node default unchanged). Backends without a mempool (e.g.
+ // neutrino) broadcast each transaction individually and rely on P2P
+ // 1p1c package relay instead.
+ SubmitPackage(txns []*wire.MsgTx,
+ maxFeeRate *chainfee.SatPerVByte) (*btcjson.SubmitPackageResult,
+ error)
+
// LabelTransaction adds a label to a transaction. If the tx already
// has a label, this call will fail unless the overwrite parameter
// is set. Labels must not be empty, and they are limited to 500 chars.
diff --git a/lnwallet/mock.go b/lnwallet/mock.go
index 2204167..5583073 100644
--- a/lnwallet/mock.go
+++ b/lnwallet/mock.go
@@ -7,6 +7,7 @@ import (
"github.com/btcsuite/btcd/address/v2"
"github.com/btcsuite/btcd/btcec/v2"
+ "github.com/btcsuite/btcd/btcjson"
"github.com/btcsuite/btcd/btcutil/v2"
"github.com/btcsuite/btcd/btcutil/v2/hdkeychain"
"github.com/btcsuite/btcd/chaincfg/v2"
@@ -256,6 +257,19 @@ func (w *mockWalletController) PublishTransaction(tx *wire.MsgTx,
return nil
}
+// SubmitPackage publishes each transaction in the package individually,
+// mirroring PublishTransaction. The mock has no real chain backend so it
+// returns an empty result.
+func (w *mockWalletController) SubmitPackage(txns []*wire.MsgTx,
+ _ *chainfee.SatPerVByte) (*btcjson.SubmitPackageResult, error) {
+
+ for _, tx := range txns {
+ w.PublishedTransactions <- tx
+ }
+
+ return &btcjson.SubmitPackageResult{}, nil
+}
+
// GetTransactionDetails currently does nothing.
func (w *mockWalletController) GetTransactionDetails(*chainhash.Hash) (
*TransactionDetail, error) {
Risk score
Our methodology →Why this scored 30/100
Human-validated context
Community notes
Notes can correct, qualify, or add evidence to the AI analysis. Every note shown here has been validated by a human moderator.
No validated notes yet.
The AI analysis stands alone for now. Submit a note if you can add evidence or important context.