feat(lib/parachain): added parachain service and registering protocols (

#3277)

- Added parachain service
- Registered collation and validation protocol
- Confirmed that we can communicate with collators by talking to them in `run()` function

dot/network/message.go

@@ -27,6 +27,8 @@ const (
 	blockAnnounceMsgType MessageType = iota + 3
 	transactionMsgType
 	ConsensusMsgType
+	CollationMsgType
+	ValidationMsgType
 )
 
 // Message must be implemented by all network messages

dot/node.go

@@ -33,6 +33,7 @@ import (
 	"github.com/ChainSafe/gossamer/lib/genesis"
 	"github.com/ChainSafe/gossamer/lib/grandpa"
 	"github.com/ChainSafe/gossamer/lib/keystore"
+	"github.com/ChainSafe/gossamer/lib/parachain"
 	"github.com/ChainSafe/gossamer/lib/runtime"
 	"github.com/ChainSafe/gossamer/lib/services"
 )
@@ -63,6 +64,7 @@ type nodeBuilderIface interface {
 		dh *digest.Handler) (*core.Service, error)
 	createGRANDPAService(config *cfg.Config, st *state.Service, ks KeyStore,
 		net *network.Service, telemetryMailer Telemetry) (*grandpa.Service, error)
+	createParachainHostService(net *network.Service, genesishHash common.Hash) (*parachain.Service, error)
 	newSyncService(config *cfg.Config, st *state.Service, finalityGadget BlockJustificationVerifier,
 		verifier *babe.VerificationManager, cs *core.Service, net *network.Service,
 		telemetryMailer Telemetry) (*dotsync.Service, error)
@@ -379,6 +381,12 @@ func newNode(config *cfg.Config,
 	}
 	nodeSrvcs = append(nodeSrvcs, fg)
 
+	phs, err := builder.createParachainHostService(networkSrvc, stateSrvc.Block.GenesisHash())
+	if err != nil {
+		return nil, err
+	}
+	nodeSrvcs = append(nodeSrvcs, phs)
+
 	syncer, err := builder.newSyncService(config, stateSrvc, fg, ver, coreSrvc, networkSrvc, telemetryMailer)
 	if err != nil {
 		return nil, err

dot/node_integration_test.go

@@ -33,6 +33,7 @@ import (
 	"github.com/ChainSafe/gossamer/lib/genesis"
 	"github.com/ChainSafe/gossamer/lib/grandpa"
 	"github.com/ChainSafe/gossamer/lib/keystore"
+	"github.com/ChainSafe/gossamer/lib/parachain"
 	"github.com/ChainSafe/gossamer/lib/runtime"
 	wazero_runtime "github.com/ChainSafe/gossamer/lib/runtime/wazero"
 	"github.com/ChainSafe/gossamer/lib/trie"
@@ -85,7 +86,7 @@ func TestNewNode(t *testing.T) {
 	assert.NoError(t, err)
 
 	mockServiceRegistry := NewMockServiceRegisterer(ctrl)
-	mockServiceRegistry.EXPECT().RegisterService(gomock.Any()).Times(8)
+	mockServiceRegistry.EXPECT().RegisterService(gomock.Any()).Times(9)
 
 	m := NewMocknodeBuilderIface(ctrl)
 	m.EXPECT().isNodeInitialised(initConfig.BasePath).Return(false, nil)
@@ -119,6 +120,9 @@ func TestNewNode(t *testing.T) {
 		return stateSrvc, nil
 	})
 
+	phs, err := parachain.NewService(testNetworkService, common.Hash{})
+	require.NoError(t, err)
+
 	m.EXPECT().createRuntimeStorage(gomock.AssignableToTypeOf(&state.Service{})).Return(&runtime.
 		NodeStorage{}, nil)
 	m.EXPECT().loadRuntime(initConfig, &runtime.NodeStorage{}, gomock.AssignableToTypeOf(&state.Service{}),
@@ -149,6 +153,8 @@ func TestNewNode(t *testing.T) {
 		})
 	m.EXPECT().createNetworkService(initConfig, gomock.AssignableToTypeOf(&state.Service{}),
 		gomock.AssignableToTypeOf(&telemetry.Mailer{})).Return(testNetworkService, nil)
+	m.EXPECT().createParachainHostService(gomock.AssignableToTypeOf(&network.Service{}),
+		gomock.AssignableToTypeOf(common.Hash{})).Return(phs, nil)
 
 	got, err := newNode(initConfig, ks, m, mockServiceRegistry)
 	assert.NoError(t, err)

dot/services.go

@@ -31,6 +31,7 @@ import (
 	"github.com/ChainSafe/gossamer/lib/crypto/sr25519"
 	"github.com/ChainSafe/gossamer/lib/grandpa"
 	"github.com/ChainSafe/gossamer/lib/keystore"
+	"github.com/ChainSafe/gossamer/lib/parachain"
 	"github.com/ChainSafe/gossamer/lib/runtime"
 	wazero_runtime "github.com/ChainSafe/gossamer/lib/runtime/wazero"
 )
@@ -455,6 +456,11 @@ func (nodeBuilder) createGRANDPAService(config *cfg.Config, st *state.Service, k
 	return grandpa.NewService(gsCfg)
 }
 
+func (nodeBuilder) createParachainHostService(net *network.Service, genesisHash common.Hash) (
+	*parachain.Service, error) {
+	return parachain.NewService(net, genesisHash)
+}
+
 func (nodeBuilder) createBlockVerifier(st *state.Service) *babe.VerificationManager {
 	return babe.NewVerificationManager(st.Block, st.Slot, st.Epoch)
 }

lib/babe/inherents/parachain_inherents.go

@@ -8,6 +8,7 @@ import (
 
 	"github.com/ChainSafe/gossamer/dot/types"
 	"github.com/ChainSafe/gossamer/lib/common"
+	"github.com/ChainSafe/gossamer/lib/crypto/sr25519"
 	"github.com/ChainSafe/gossamer/pkg/scale"
 )
 
@@ -240,7 +241,7 @@ func newDisputeStatement() disputeStatement { //skipcq
 }
 
 // collatorID is the collator's relay-chain account ID
-type collatorID []byte
+type collatorID sr25519.PublicKey
 
 // collatorSignature is the signature on a candidate's block data signed by a collator.
 type collatorSignature signature