Merge branch 'development' into eclesio/rpc-sync-state

Author: EclesioMeloJunior

chain/gssmr/genesis.json

@@ -70,7 +70,7 @@ type TransactionState interface {
 
 // Network is the interface for the network service
 type Network interface {
-	SendMessage(network.NotificationsMessage)
+	GossipMessage(network.NotificationsMessage)
 }
 
 // EpochState is the interface for state.EpochState

dot/core/interface.go

@@ -110,8 +110,7 @@ func TestService_ProcessBlockAnnounceMessage(t *testing.T) {
 		BestBlock:      true,
 	}
 
-	//setup the SendMessage function
-	net.On("SendMessage", expected)
+	net.On("GossipMessage", expected)
 
 	state, err := s.storageState.TrieState(nil)
 	require.NoError(t, err)
@@ -120,7 +119,7 @@ func TestService_ProcessBlockAnnounceMessage(t *testing.T) {
 	require.NoError(t, err)
 
 	time.Sleep(time.Second)
-	net.AssertCalled(t, "SendMessage", expected)
+	net.AssertCalled(t, "GossipMessage", expected)
 }
 
 func TestService_HandleTransactionMessage(t *testing.T) {

dot/core/messages_test.go

@@ -204,7 +204,7 @@ func (s *Service) HandleBlockProduced(block *types.Block, state *rtstorage.TrieS
 		BestBlock:      true,
 	}
 
-	s.net.SendMessage(msg)
+	s.net.GossipMessage(msg)
 	return s.handleBlock(block, state)
 }
 
@@ -553,7 +553,7 @@ func (s *Service) HandleSubmittedExtrinsic(ext types.Extrinsic) error {
 
 	// broadcast transaction
 	msg := &network.TransactionMessage{Extrinsics: []types.Extrinsic{ext}}
-	s.net.SendMessage(msg)
+	s.net.GossipMessage(msg)
 	return nil
 }
 

dot/core/mocks/network.go

@@ -129,7 +129,7 @@ func TestAnnounceBlock(t *testing.T) {
 		BestBlock:      true,
 	}
 
-	net.On("SendMessage", expected)
+	net.On("GossipMessage", expected)
 
 	state, err := s.storageState.TrieState(nil)
 	require.NoError(t, err)
@@ -138,7 +138,7 @@ func TestAnnounceBlock(t *testing.T) {
 	require.NoError(t, err)
 
 	time.Sleep(time.Second)
-	net.AssertCalled(t, "SendMessage", expected)
+	net.AssertCalled(t, "GossipMessage", expected)
 }
 
 func TestService_HasKey(t *testing.T) {

dot/core/service.go

@@ -286,7 +286,7 @@ func Test_HandshakeTimeout(t *testing.T) {
 		BestBlockHash:   common.Hash{1},
 		GenesisHash:     common.Hash{2},
 	}
-	nodeA.SendMessage(testHandshakeMsg)
+	nodeA.GossipMessage(testHandshakeMsg)
 
 	go nodeA.sendData(nodeB.host.id(), testHandshakeMsg, info, nil)
 

dot/core/service_test.go

@@ -480,8 +480,8 @@ func (s *Service) IsStopped() bool {
 	return s.ctx.Err() != nil
 }
 
-// SendMessage implementation of interface to handle receiving messages
-func (s *Service) SendMessage(msg NotificationsMessage) {
+// GossipMessage gossips a notifications protocol message to our peers
+func (s *Service) GossipMessage(msg NotificationsMessage) {
 	if s.host == nil || msg == nil || s.IsStopped() {
 		return
 	}
@@ -509,6 +509,23 @@ func (s *Service) SendMessage(msg NotificationsMessage) {
 	logger.Error("message not supported by any notifications protocol", "msg type", msg.Type())
 }
 
+// SendMessage sends a message to the given peer
+func (s *Service) SendMessage(to peer.ID, msg NotificationsMessage) error {
+	s.notificationsMu.Lock()
+	defer s.notificationsMu.Unlock()
+	for msgID, prtl := range s.notificationsProtocols {
+		if msg.Type() != msgID || prtl == nil {
+			continue
+		}
+		hs, err := prtl.getHandshake()
+		if err != nil {
+			return err
+		}
+		s.sendData(to, hs, prtl, msg)
+	}
+	return errors.New("message not supported by any notifications protocol")
+}
+
 // handleLightStream handles streams with the <protocol-id>/light/2 protocol ID
 func (s *Service) handleLightStream(stream libp2pnetwork.Stream) {
 	s.readStream(stream, s.decodeLightMessage, s.handleLightMsg)

dot/network/notifications_test.go

@@ -175,7 +175,7 @@ func TestBroadcastMessages(t *testing.T) {
 	require.NoError(t, err)
 
 	// simulate message sent from core service
-	nodeA.SendMessage(testBlockAnnounceMessage)
+	nodeA.GossipMessage(testBlockAnnounceMessage)
 	time.Sleep(time.Second * 2)
 	require.NotNil(t, handler.messages[nodeA.host.id()])
 }
@@ -232,7 +232,7 @@ func TestBroadcastDuplicateMessage(t *testing.T) {
 
 	// Only one message will be sent.
 	for i := 0; i < 5; i++ {
-		nodeA.SendMessage(testBlockAnnounceMessage)
+		nodeA.GossipMessage(testBlockAnnounceMessage)
 		time.Sleep(time.Millisecond * 10)
 	}
 
@@ -243,7 +243,7 @@ func TestBroadcastDuplicateMessage(t *testing.T) {
 
 	// All 5 message will be sent since cache is disabled.
 	for i := 0; i < 5; i++ {
-		nodeA.SendMessage(testBlockAnnounceMessage)
+		nodeA.GossipMessage(testBlockAnnounceMessage)
 		time.Sleep(time.Millisecond * 10)
 	}
 	require.Equal(t, 6, len(handler.messages[nodeA.host.id()]))

dot/network/service.go

@@ -40,7 +40,7 @@ func TestStateModule_GetRuntimeVersion(t *testing.T) {
 		SpecName:         "node",
 		ImplName:         "substrate-node",
 		AuthoringVersion: 10,
-		SpecVersion:      260,
+		SpecVersion:      264,
 		ImplVersion:      0,
 		Apis: []interface{}{
 			[]interface{}{"0xdf6acb689907609b", uint32(3)},
@@ -54,9 +54,10 @@ func TestStateModule_GetRuntimeVersion(t *testing.T) {
 			[]interface{}{"0xbc9d89904f5b923f", uint32(1)},
 			[]interface{}{"0x68b66ba122c93fa7", uint32(1)},
 			[]interface{}{"0x37c8bb1350a9a2a8", uint32(1)},
+			[]interface{}{"0x91d5df18b0d2cf58", uint32(1)},
 			[]interface{}{"0xab3c0572291feb8b", uint32(1)},
 		},
-		TransactionVersion: 1,
+		TransactionVersion: 2,
 	}
 
 	sm, hash, _ := setupStateModule(t)
@@ -315,6 +316,7 @@ func TestStateModule_GetStorageSize(t *testing.T) {
 }
 
 func TestStateModule_GetMetadata(t *testing.T) {
+	t.Skip() // TODO: update expected_metadata
 	sm, hash, _ := setupStateModule(t)
 	randomHash, err := common.HexToHash(RandomHash)
 	require.NoError(t, err)