chore(all): fix DeepSource reported issues (#2692)

- Fix Hidden goroutine GO-E1007
- Fix Using a deprecated function, variable, constant or field SCC-SA1019
- Fix Found `x.Sub(time.Now())` instead of `time.Until(x)` SCC-S1024
- Fix Unused code SCC-U1000
- Fix Simplify slice expression to sliced value itself CRT-A0016
- Fix Control-coupled functions detected RVV-A0005
- Fix Exit inside non-main function detected RVV-A0003
- Fix Redefinition of built-in detected RVV-B0009
- Fix Unused method receiver detected RVV-B0013
- Fix `append` possibly assigns to a wrong variable CRT-D0001
- Fix Unused parameter detected in function RVV-B0012
- Fix Confusing naming of struct fields or methods RVV-B0001
- Fix Importing the same package multiple times GO-W5021
- Rename trie node method `Type()` to `Kind()`

Author: qdm12

dot/build_spec.go

@@ -4,7 +4,6 @@
 package dot
 
 import (
-	"context"
 	"encoding/json"
 	"fmt"
 	"os"
@@ -95,21 +94,15 @@ func BuildFromDB(path string) (*BuildSpec, error) {
 	tmpGen.Genesis.Raw = make(map[string]map[string]string)
 	tmpGen.Genesis.Runtime = make(map[string]map[string]interface{})
 
-	// BootstrapMailer should not return an error here since there is no URLs to connect to
-	disabledTelemetry, err := telemetry.BootstrapMailer(context.TODO(), nil, false, nil)
-	if err != nil {
-		panic("telemetry should not fail at BuildFromDB function: " + err.Error())
-	}
-
 	config := state.Config{
 		Path:      path,
 		LogLevel:  log.Info,
-		Telemetry: disabledTelemetry,
+		Telemetry: telemetry.NewNoopMailer(),
 	}
 
 	stateSrvc := state.NewService(config)
 
-	err = stateSrvc.SetupBase()
+	err := stateSrvc.SetupBase()
 	if err != nil {
 		return nil, fmt.Errorf("cannot setup state database: %w", err)
 	}

dot/build_spec_integration_test.go

@@ -22,7 +22,15 @@ const codeHex = "0x3a636f6465"
 func TestBuildFromGenesis_Integration(t *testing.T) {
 	t.Parallel()
 
-	file := genesis.CreateTestGenesisJSONFile(t, false)
+	genesisFields := genesis.Fields{
+		Raw: map[string]map[string]string{},
+		Runtime: map[string]map[string]interface{}{
+			"System": {
+				"code": "mocktestcode",
+			},
+		},
+	}
+	file := genesis.CreateTestGenesisJSONFile(t, genesisFields)
 	bs, err := BuildFromGenesis(file, 0)
 
 	const expectedChainType = "TESTCHAINTYPE"
@@ -43,7 +51,7 @@ func TestBuildFromGenesis_Integration(t *testing.T) {
 	jGen := genesis.Genesis{}
 	err = json.Unmarshal(hr, &jGen)
 	require.NoError(t, err)
-	genesis.TestGenesis.Genesis = genesis.TestFieldsHR
+	genesis.TestGenesis.Genesis = genesisFields
 	require.Equal(t, genesis.TestGenesis.Genesis.Runtime, jGen.Genesis.Runtime)
 	require.Equal(t, expectedChainType, jGen.ChainType)
 	require.Equal(t, expectedProperties, jGen.Properties)

dot/build_spec_test.go

@@ -167,7 +167,15 @@ func TestBuildFromDB(t *testing.T) {
 }
 
 func TestBuildFromGenesis(t *testing.T) {
-	testGenesisPath := genesis.CreateTestGenesisJSONFile(t, false)
+	genesisFields := genesis.Fields{
+		Raw: map[string]map[string]string{},
+		Runtime: map[string]map[string]interface{}{
+			"System": {
+				"code": "mocktestcode",
+			},
+		},
+	}
+	testGenesisPath := genesis.CreateTestGenesisJSONFile(t, genesisFields)
 
 	type args struct {
 		path      string

dot/network/config.go

@@ -97,8 +97,6 @@ type Config struct {
 	// telemetryInterval how often to send telemetry metrics
 	telemetryInterval time.Duration
 
-	noPreAllocate bool // internal option
-
 	batchSize int // internal option
 
 	// SlotDuration is the slot duration to produce a block

dot/network/connmgr.go

@@ -110,18 +110,6 @@ func (cm *ConnManager) ListenClose(n network.Network, addr ma.Multiaddr) {
 		"Host %s stopped listening on address %s", n.LocalPeer(), addr)
 }
 
-// returns a slice of peers that are unprotected and may be pruned.
-func (cm *ConnManager) unprotectedPeers(peers []peer.ID) []peer.ID {
-	unprot := []peer.ID{}
-	for _, id := range peers {
-		if !cm.IsProtected(id, "") && !cm.isPersistent(id) {
-			unprot = append(unprot, id)
-		}
-	}
-
-	return unprot
-}
-
 // Connected is called when a connection opened
 func (cm *ConnManager) Connected(n network.Network, c network.Conn) {
 	logger.Tracef(
@@ -141,8 +129,3 @@ func (cm *ConnManager) Disconnected(_ network.Network, c network.Conn) {
 		cm.disconnectHandler(c.RemotePeer())
 	}
 }
-
-func (cm *ConnManager) isPersistent(p peer.ID) bool {
-	_, ok := cm.persistentPeers.Load(p)
-	return ok
-}

dot/network/connmgr_test.go

@@ -115,13 +115,13 @@ func TestProtectUnprotectPeer(t *testing.T) {
 	require.True(t, cm.IsProtected(p1, ""))
 	require.True(t, cm.IsProtected(p2, ""))
 
-	unprot := cm.unprotectedPeers([]peer.ID{p1, p2, p3, p4})
+	unprot := unprotectedPeers(cm, []peer.ID{p1, p2, p3, p4})
 	require.Equal(t, unprot, []peer.ID{p3, p4})
 
 	cm.Unprotect(p1, "")
 	cm.Unprotect(p2, "")
 
-	unprot = cm.unprotectedPeers([]peer.ID{p1, p2, p3, p4})
+	unprot = unprotectedPeers(cm, []peer.ID{p1, p2, p3, p4})
 	require.Equal(t, unprot, []peer.ID{p1, p2, p3, p4})
 }
 
@@ -224,7 +224,7 @@ func TestSetReservedPeer(t *testing.T) {
 
 	addrA := nodes[0].host.multiaddrs()[0]
 	addrB := nodes[1].host.multiaddrs()[0]
-	addrC := nodes[2].host.addrInfo()
+	addrC := addrInfo(nodes[2].host)
 
 	config := &Config{
 		BasePath:        t.TempDir(),

dot/network/discovery_test.go

@@ -121,7 +121,7 @@ func TestBeginDiscovery(t *testing.T) {
 	nodeB := createTestService(t, configB)
 	nodeB.noGossip = true
 
-	addrInfoB := nodeB.host.addrInfo()
+	addrInfoB := addrInfo(nodeB.host)
 	err := nodeA.host.connect(addrInfoB)
 	if failedToDial(err) {
 		time.Sleep(TestBackoffTimeout)
@@ -170,7 +170,7 @@ func TestBeginDiscovery_ThreeNodes(t *testing.T) {
 	nodeC.noGossip = true
 
 	// connect A and B
-	addrInfoB := nodeB.host.addrInfo()
+	addrInfoB := addrInfo(nodeB.host)
 	err := nodeA.host.connect(addrInfoB)
 	if failedToDial(err) {
 		time.Sleep(TestBackoffTimeout)
@@ -179,7 +179,7 @@ func TestBeginDiscovery_ThreeNodes(t *testing.T) {
 	require.NoError(t, err)
 
 	// connect A and C
-	addrInfoC := nodeC.host.addrInfo()
+	addrInfoC := addrInfo(nodeC.host)
 	err = nodeA.host.connect(addrInfoC)
 	if failedToDial(err) {
 		time.Sleep(TestBackoffTimeout)

dot/network/gossip_test.go

@@ -42,7 +42,7 @@ func TestGossip(t *testing.T) {
 	handlerB := newTestStreamHandler(testBlockAnnounceMessageDecoder)
 	nodeB.host.registerStreamHandler(nodeB.host.protocolID, handlerB.handleStream)
 
-	addrInfoA := nodeA.host.addrInfo()
+	addrInfoA := addrInfo(nodeA.host)
 	err := nodeB.host.connect(addrInfoA)
 	// retry connect if "failed to dial" error
 	if failedToDial(err) {
@@ -70,7 +70,7 @@ func TestGossip(t *testing.T) {
 	}
 	require.NoError(t, err)
 
-	addrInfoB := nodeB.host.addrInfo()
+	addrInfoB := addrInfo(nodeB.host)
 	err = nodeC.host.connect(addrInfoB)
 	// retry connect if "failed to dial" error
 	if failedToDial(err) {

dot/network/helpers_test.go

@@ -147,3 +147,28 @@ func testBlockAnnounceHandshakeDecoder(in []byte, _ peer.ID, _ bool) (Message, e
 	err := msg.Decode(in)
 	return msg, err
 }
+
+// addrInfo returns the libp2p peer.AddrInfo of the host
+func addrInfo(h *host) peer.AddrInfo {
+	return peer.AddrInfo{
+		ID:    h.p2pHost.ID(),
+		Addrs: h.p2pHost.Addrs(),
+	}
+}
+
+// returns a slice of peers that are unprotected and may be pruned.
+func unprotectedPeers(cm *ConnManager, peers []peer.ID) []peer.ID {
+	unprot := []peer.ID{}
+	for _, id := range peers {
+		if cm.IsProtected(id, "") {
+			continue
+		}
+
+		_, isPersistent := cm.persistentPeers.Load(id)
+		if !isPersistent {
+			unprot = append(unprot, id)
+		}
+	}
+
+	return unprot
+}

dot/network/host.go

@@ -392,14 +392,6 @@ func (h *host) peerCount() int {
 	return len(peers)
 }
 
-// addrInfo returns the libp2p peer.AddrInfo of the host
-func (h *host) addrInfo() peer.AddrInfo {
-	return peer.AddrInfo{
-		ID:    h.p2pHost.ID(),
-		Addrs: h.p2pHost.Addrs(),
-	}
-}
-
 // multiaddrs returns the multiaddresses of the host
 func (h *host) multiaddrs() (multiaddrs []ma.Multiaddr) {
 	addrs := h.p2pHost.Addrs()