mirrors/lnd
1
0
Fork 0
mirror of https://github.com/lightningnetwork/lnd.git synced 2024-11-19 01:43:16 +01:00
Code Issues Projects Releases Wiki Activity

invoicesrpc: add HTLC modifier to invoices RPC server

Browse Source 
This commit integrates the HTLC modifier service into the
invoices RPC server.
This commit is contained in:
ffranr 2024-04-23 14:48:42 +01:00 committed by Oliver Gugger
parent 7e8a3b0df7
commit 73f52c8b11
No known key found for this signature in database
GPG Key ID: 8E4256593F177720
4 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
lnd.go
View File

@ -618,6 +618,7 @@ func Main(cfg *Config, lisCfg ListenerCfg, implCfg *ImplementationCfg,
err = rpcServer.addDeps( err = rpcServer.addDeps(
server, interceptorChain.MacaroonService(), cfg.SubRPCServers, server, interceptorChain.MacaroonService(), cfg.SubRPCServers,
atplManager, server.invoices, tower, multiAcceptor, atplManager, server.invoices, tower, multiAcceptor,
server.invoiceHtlcModifier,
) )
if err != nil { if err != nil {
return mkErr("unable to add deps to RPC server: %v", err) return mkErr("unable to add deps to RPC server: %v", err)

5
lnrpc/invoicesrpc/config_active.go
View File

@ -30,6 +30,11 @@ type Config struct {
// created by the daemon. // created by the daemon.
InvoiceRegistry *invoices.InvoiceRegistry InvoiceRegistry *invoices.InvoiceRegistry
// HtlcModifier is a service which intercepts invoice HTLCs during the
// settlement phase, enabling a subscribed client to modify certain
// aspects of those HTLCs.
HtlcModifier invoices.HtlcModifier
// IsChannelActive is used to generate valid hop hints. // IsChannelActive is used to generate valid hop hints.
IsChannelActive func(chanID lnwire.ChannelID) bool IsChannelActive func(chanID lnwire.ChannelID) bool

5
rpcserver.go
View File

@ -673,7 +673,8 @@ func newRPCServer(cfg *Config, interceptorChain *rpcperms.InterceptorChain,
func (r *rpcServer) addDeps(s *server, macService *macaroons.Service, func (r *rpcServer) addDeps(s *server, macService *macaroons.Service,
subServerCgs *subRPCServerConfigs, atpl *autopilot.Manager, subServerCgs *subRPCServerConfigs, atpl *autopilot.Manager,
invoiceRegistry *invoices.InvoiceRegistry, tower *watchtower.Standalone, invoiceRegistry *invoices.InvoiceRegistry, tower *watchtower.Standalone,
chanPredicate chanacceptor.MultiplexAcceptor) error { chanPredicate chanacceptor.MultiplexAcceptor,
invoiceHtlcModifier *invoices.HtlcModificationInterceptor) error {
// Set up router rpc backend. // Set up router rpc backend.
selfNode, err := s.graphDB.SourceNode() selfNode, err := s.graphDB.SourceNode()
@ -776,7 +777,7 @@ func (r *rpcServer) addDeps(s *server, macService *macaroons.Service,
s.sweeper, tower, s.towerClientMgr, r.cfg.net.ResolveTCPAddr, s.sweeper, tower, s.towerClientMgr, r.cfg.net.ResolveTCPAddr,
genInvoiceFeatures, genAmpInvoiceFeatures, genInvoiceFeatures, genAmpInvoiceFeatures,
s.getNodeAnnouncement, s.updateAndBrodcastSelfNode, parseAddr, s.getNodeAnnouncement, s.updateAndBrodcastSelfNode, parseAddr,
rpcsLog, s.aliasMgr, rpcsLog, s.aliasMgr, invoiceHtlcModifier,
) )
if err != nil { if err != nil {
return err return err

7
subrpcserver_config.go
View File

@ -122,8 +122,8 @@ func (s *subRPCServerConfigs) PopulateDependencies(cfg *Config,
updateNodeAnnouncement func(features *lnwire.RawFeatureVector, updateNodeAnnouncement func(features *lnwire.RawFeatureVector,
modifiers ...netann.NodeAnnModifier) error, modifiers ...netann.NodeAnnModifier) error,
parseAddr func(addr string) (net.Addr, error), parseAddr func(addr string) (net.Addr, error),
rpcLogger btclog.Logger, rpcLogger btclog.Logger, aliasMgr *aliasmgr.Manager,
aliasMgr *aliasmgr.Manager) error { invoiceHtlcModifier *invoices.HtlcModificationInterceptor) error {
// First, we'll use reflect to obtain a version of the config struct // First, we'll use reflect to obtain a version of the config struct
// that allows us to programmatically inspect its fields. // that allows us to programmatically inspect its fields.
@ -239,6 +239,9 @@ func (s *subRPCServerConfigs) PopulateDependencies(cfg *Config,
subCfgValue.FieldByName("InvoiceRegistry").Set( subCfgValue.FieldByName("InvoiceRegistry").Set(
reflect.ValueOf(invoiceRegistry), reflect.ValueOf(invoiceRegistry),
) )
subCfgValue.FieldByName("HtlcModifier").Set(
reflect.ValueOf(invoiceHtlcModifier),
)
subCfgValue.FieldByName("IsChannelActive").Set( subCfgValue.FieldByName("IsChannelActive").Set(
reflect.ValueOf(htlcSwitch.HasActiveLink), reflect.ValueOf(htlcSwitch.HasActiveLink),
) )