Skip to content

Commit 7344ebd

Browse files
committed
lnd: Include kvdbStorage in server and peer config
Signed-off-by: Ononiwu <[email protected]>
1 parent 97e2a23 commit 7344ebd

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

server.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -323,6 +323,8 @@ type server struct {
323323

324324
customMessageServer *subscribe.Server
325325

326+
kvdbPeerStorage *kvdbPeerStorage
327+
326328
quit chan struct{}
327329

328330
wg sync.WaitGroup
@@ -1492,6 +1494,11 @@ func newServer(cfg *Config, listenAddrs []net.Addr,
14921494
return nil, err
14931495
}
14941496

1497+
s.kvdbPeerStorage, err = newKvdbPeerStorage(&peerStorageConfig{
1498+
chainNotifier: s.cc.ChainNotifier,
1499+
db: dbs.PeerStorageDB,
1500+
blockViewer: s.cc.BestBlockTracker,
1501+
})
14951502
// Assemble a peer notifier which will provide clients with subscriptions
14961503
// to peer online and offline events.
14971504
s.peerNotifier = peernotifier.New()
@@ -3868,6 +3875,7 @@ func (s *server) peerConnected(conn net.Conn, connReq *connmgr.ConnReq,
38683875
GetAliases: s.aliasMgr.GetAliases,
38693876
RequestAlias: s.aliasMgr.RequestAlias,
38703877
AddLocalAlias: s.aliasMgr.AddLocalAlias,
3878+
PeerDataStore: s.kvdbPeerStorage,
38713879
Quit: s.quit,
38723880
}
38733881

0 commit comments

Comments
 (0)