@@ -90,10 +90,10 @@ func ConnectPeer(conn *brontide.Conn, connReq *connmgr.ConnReq,
9090 )
9191
9292 if err := writePool .Start (); err != nil {
93- return nil , fmt .Errorf ("unable to start write pool: %v " , err )
93+ return nil , fmt .Errorf ("unable to start write pool: %w " , err )
9494 }
9595 if err := readPool .Start (); err != nil {
96- return nil , fmt .Errorf ("unable to start read pool: %v " , err )
96+ return nil , fmt .Errorf ("unable to start read pool: %w " , err )
9797 }
9898
9999 channelDB , err := channeldb .Open (os .TempDir ())
@@ -108,24 +108,26 @@ func ConnectPeer(conn *brontide.Conn, connReq *connmgr.ConnReq,
108108
109109 return nil
110110 },
111- NotifyWhenOnline : func (peerPubKey [33 ]byte ,
112- peerChan chan <- lnpeer.Peer ) {
113-
111+ NotifyWhenOnline : func ([33 ]byte , chan <- lnpeer.Peer ) {
114112 },
115113 NotifyWhenOffline : func (peerPubKey [33 ]byte ) <- chan struct {} {
116114 return make (chan struct {})
117115 },
118- SelfNodeAnnouncement : func (
119- refresh bool ) (lnwire. NodeAnnouncement , error ) {
116+ SelfNodeAnnouncement : func (bool ) (lnwire. NodeAnnouncement ,
117+ error ) {
120118
121119 return lnwire.NodeAnnouncement {}, nil
122120 },
123- ProofMatureDelta : 0 ,
124- TrickleDelay : time .Millisecond * 50 ,
125- RetransmitTicker : ticker .New (time .Minute * 30 ),
126- RebroadcastInterval : time .Hour * 24 ,
127- RotateTicker : ticker .New (discovery .DefaultSyncerRotationInterval ),
128- HistoricalSyncTicker : ticker .New (discovery .DefaultHistoricalSyncInterval ),
121+ ProofMatureDelta : 0 ,
122+ TrickleDelay : time .Millisecond * 50 ,
123+ RetransmitTicker : ticker .New (time .Minute * 30 ),
124+ RebroadcastInterval : time .Hour * 24 ,
125+ RotateTicker : ticker .New (
126+ discovery .DefaultSyncerRotationInterval ,
127+ ),
128+ HistoricalSyncTicker : ticker .New (
129+ discovery .DefaultHistoricalSyncInterval ,
130+ ),
129131 NumActiveSyncers : 0 ,
130132 MinimumBatchSize : 10 ,
131133 SubBatchDelay : discovery .DefaultSubBatchDelay ,
@@ -134,17 +136,25 @@ func ConnectPeer(conn *brontide.Conn, connReq *connmgr.ConnReq,
134136 MaxChannelUpdateBurst : discovery .DefaultMaxChannelUpdateBurst ,
135137 ChannelUpdateInterval : discovery .DefaultChannelUpdateInterval ,
136138 IsAlias : aliasmgr .IsAlias ,
137- SignAliasUpdate : func (u * lnwire.ChannelUpdate ) (* ecdsa.Signature , error ) {
139+ SignAliasUpdate : func (
140+ * lnwire.ChannelUpdate ) (* ecdsa.Signature , error ) {
141+
138142 return nil , fmt .Errorf ("unimplemented" )
139143 },
140- FindBaseByAlias : func (alias lnwire.ShortChannelID ) (lnwire.ShortChannelID , error ) {
141- return lnwire.ShortChannelID {}, fmt .Errorf ("unimplemented" )
144+ FindBaseByAlias : func (
145+ lnwire.ShortChannelID ) (lnwire.ShortChannelID , error ) {
146+
147+ return lnwire.ShortChannelID {},
148+ fmt .Errorf ("unimplemented" )
142149 },
143- GetAlias : func (id lnwire.ChannelID ) (lnwire.ShortChannelID , error ) {
144- return lnwire.ShortChannelID {}, fmt .Errorf ("unimplemented" )
150+ GetAlias : func (id lnwire.ChannelID ) (lnwire.ShortChannelID ,
151+ error ) {
152+
153+ return lnwire.ShortChannelID {},
154+ fmt .Errorf ("unimplemented" )
145155 },
146- FindChannel : func (node * btcec.PublicKey ,
147- chanID lnwire.ChannelID ) (* channeldb.OpenChannel , error ) {
156+ FindChannel : func (* btcec.PublicKey ,
157+ lnwire.ChannelID ) (* channeldb.OpenChannel , error ) {
148158
149159 return nil , fmt .Errorf ("unimplemented" )
150160 },
0 commit comments