fix(ci): fix dot/network unit tests

.github/workflows/integration-tests.yml

@@ -27,6 +27,7 @@ jobs:
             github.com/ChainSafe/gossamer/dot/core,
             github.com/ChainSafe/gossamer/dot/rpc/modules,
             github.com/ChainSafe/gossamer/lib/babe,
+            github.com/ChainSafe/gossamer/dot/network
           ]
     runs-on: ubuntu-latest
     steps:

dot/network/gossip_integration_test.go

@@ -0,0 +1,111 @@
+// Copyright 2021 ChainSafe Systems (ON)
+// SPDX-License-Identifier: LGPL-3.0-only
+
+//go:build integration
+
+package network
+
+import (
+	"testing"
+	"time"
+
+	"github.com/ChainSafe/gossamer/dot/types"
+
+	"github.com/stretchr/testify/require"
+)
+
+// test gossip messages to connected peers
+func TestGossip(t *testing.T) {
+	if testing.Short() {
+		t.Skip("skipping TestGossip; currently, nothing is gossiped")
+	}
+
+	t.Parallel()
+
+	configA := &Config{
+		BasePath:    t.TempDir(),
+		Port:        availablePort(t),
+		NoBootstrap: true,
+		NoMDNS:      true,
+	}
+
+	nodeA := createTestService(t, configA)
+	handlerA := newTestStreamHandler(testBlockAnnounceMessageDecoder)
+	nodeA.host.registerStreamHandler(nodeA.host.protocolID, handlerA.handleStream)
+
+	configB := &Config{
+		BasePath:    t.TempDir(),
+		Port:        availablePort(t),
+		NoBootstrap: true,
+		NoMDNS:      true,
+	}
+
+	nodeB := createTestService(t, configB)
+	handlerB := newTestStreamHandler(testBlockAnnounceMessageDecoder)
+	nodeB.host.registerStreamHandler(nodeB.host.protocolID, handlerB.handleStream)
+
+	addrInfoA := nodeA.host.addrInfo()
+	err := nodeB.host.connect(addrInfoA)
+	// retry connect if "failed to dial" error
+	if failedToDial(err) {
+		time.Sleep(TestBackoffTimeout)
+		err = nodeB.host.connect(addrInfoA)
+	}
+	require.NoError(t, err)
+
+	configC := &Config{
+		BasePath:    t.TempDir(),
+		Port:        availablePort(t),
+		NoBootstrap: true,
+		NoMDNS:      true,
+	}
+
+	nodeC := createTestService(t, configC)
+	handlerC := newTestStreamHandler(testBlockAnnounceMessageDecoder)
+	nodeC.host.registerStreamHandler(nodeC.host.protocolID, handlerC.handleStream)
+
+	err = nodeC.host.connect(addrInfoA)
+	// retry connect if "failed to dial" error
+	if failedToDial(err) {
+		time.Sleep(TestBackoffTimeout)
+		err = nodeC.host.connect(addrInfoA)
+	}
+	require.NoError(t, err)
+
+	addrInfoB := nodeB.host.addrInfo()
+	err = nodeC.host.connect(addrInfoB)
+	// retry connect if "failed to dial" error
+	if failedToDial(err) {
+		time.Sleep(TestBackoffTimeout)
+		err = nodeC.host.connect(addrInfoB)
+	}
+	require.NoError(t, err)
+
+	announceMessage := &BlockAnnounceMessage{
+		Number: 128 * 7,
+		Digest: types.NewDigest(),
+	}
+
+	time.Sleep(10 * time.Second)
+
+	_, err = nodeA.host.send(addrInfoB.ID, "/gossamer/test/0/block-announces/1", announceMessage)
+	require.NoError(t, err)
+
+	time.Sleep(10 * time.Second)
+
+	hash, err := announceMessage.Hash()
+	require.NoError(t, err)
+
+	t.Logf("B %+v\n", nodeB.gossip.seenMap)
+	t.Logf("C %+v\n", nodeC.gossip.seenMap)
+	t.Logf("A %+v\n", nodeA.gossip.seenMap)
+
+	_, ok := nodeB.gossip.seenMap[hash]
+	require.True(t, ok, "node B did not receive block request message from node A")
+
+	_, ok = nodeC.gossip.seenMap[hash]
+	require.True(t, ok, "node C did not receive block request message from node B")
+
+	_, ok = nodeA.gossip.seenMap[hash]
+	require.True(t, ok, "node A did not receive block request message from node C")
+}