refactor: fix linter

bitcoin-sv · Nov 12, 2024 · ea6b386 · ea6b386
1 parent a3d99af
commit ea6b386
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 7 deletions.
diff --git a/internal/blocktx/health_check_test.go b/internal/blocktx/health_check_test.go
@@ -71,7 +71,7 @@ func TestCheck(t *testing.T) {
 			peerMq := &better_p2p_mocks.PeerIMock{}
 			peerMq.NetworkFunc = func() wire.BitcoinNet { return wire.TestNet }
 			peerMq.ConnectedFunc = func() bool { return false }
-			pm.AddPeer(peerMq)
+			_ = pm.AddPeer(peerMq)
 
 			sut, err := blocktx.NewServer("", 0, logger, storeMock, pm, 0, nil)
 			require.NoError(t, err)
@@ -140,7 +140,7 @@ func TestWatch(t *testing.T) {
 			peerMq := &better_p2p_mocks.PeerIMock{}
 			peerMq.NetworkFunc = func() wire.BitcoinNet { return wire.TestNet }
 			peerMq.ConnectedFunc = func() bool { return false }
-			pm.AddPeer(peerMq)
+			_ = pm.AddPeer(peerMq)
 
 			sut, err := blocktx.NewServer("", 0, logger, storeMock, pm, 0, nil)
 			require.NoError(t, err)

diff --git a/internal/blocktx/p2p/message_handler.go b/internal/blocktx/p2p/message_handler.go
@@ -62,6 +62,6 @@ func (h *PeerMsgHandler) OnReceive(wireMsg wire.Message, peer better_p2p.PeerI)
 	}
 }
 
-func (h *PeerMsgHandler) OnSend(msg wire.Message, peer better_p2p.PeerI) {
+func (h *PeerMsgHandler) OnSend(_ wire.Message, _ better_p2p.PeerI) {
 	// ignore
 }
diff --git a/internal/metamorph/p2p/message_handler.go b/internal/metamorph/p2p/message_handler.go
@@ -61,7 +61,6 @@ func (h *PeerMsgHandler) OnReceive(wireMsg wire.Message, peer better_p2p.PeerI)
 				}:
 				default: // Ensure that writing to channel is non-blocking
 				}
-
 			}
 		}
 
@@ -139,7 +138,6 @@ func (h *PeerMsgHandler) OnReceive(wireMsg wire.Message, peer better_p2p.PeerI)
 func (h *PeerMsgHandler) OnSend(wireMsg wire.Message, peer better_p2p.PeerI) {
 	cmd := wireMsg.Command()
 	switch cmd {
-
 	case wire.CmdTx:
 		msg, ok := wireMsg.(*wire.MsgTx)
 		if !ok {

diff --git a/internal/metamorph/processor.go b/internal/metamorph/processor.go
@@ -626,7 +626,6 @@ func (p *Processor) StartProcessExpiredTransactions() {
 							requested++
 							//continue
 						} else {
-
 							p.logger.Debug("Re-announcing expired tx", slog.String("hash", tx.Hash.String()))
 							toAnnounce = append(toAnnounce, tx.Hash)
 							//	peers := p.pm.AnnounceTransaction(tx.Hash, nil)
@@ -658,7 +657,6 @@ func (p *Processor) StartProcessExpiredTransactions() {
 							p.logger.Warn("transaction was not announced to any peer during rebroadcast")
 						}
 					}
-
 				}
 
 				if announced > 0 || requested > 0 {