feat: enable messages both ways

Makefile

@@ -39,3 +39,4 @@ genmocks:
 	mockgen -source=chains/evm/transactor/transact.go -destination=./mock/transact.go -package mock
 	mockgen -source=chains/evm/transactor/signAndSend/signAndSend.go -destination=./mock/signAndSend.go -package mock
 	mockgen -source=./store/store.go -destination=./mock/store.go -package mock
+	mockgen -source=./relayer/message/handler.go -destination=./mock/message.go -package mock

chains/evm/chain.go

@@ -7,8 +7,8 @@ import (
 	"context"
 	"math/big"
 
-	"github.com/ChainSafe/sygma-core/store"
-	"github.com/ChainSafe/sygma-core/types"
+	"github.com/ChainSafe/sygma-core/relayer/message"
+	"github.com/ChainSafe/sygma-core/relayer/proposal"
 	"github.com/rs/zerolog"
 	"github.com/rs/zerolog/log"
 )
@@ -18,29 +18,33 @@ type EventListener interface {
 }
 
 type ProposalExecutor interface {
-	Execute(messages []*types.Message) error
+	Execute(props []*proposal.Proposal) error
+}
+
+type MessageHandler interface {
+	HandleMessage(m *message.Message) (*proposal.Proposal, error)
 }
 
 // EVMChain is struct that aggregates all data required for
 type EVMChain struct {
-	listener   EventListener
-	executor   ProposalExecutor
-	blockstore *store.BlockStore
+	listener       EventListener
+	executor       ProposalExecutor
+	messageHandler MessageHandler
 
 	domainID   uint8
 	startBlock *big.Int
 
 	logger zerolog.Logger
 }
 
-func NewEVMChain(listener EventListener, executor ProposalExecutor, blockstore *store.BlockStore, domainID uint8, startBlock *big.Int) *EVMChain {
+func NewEVMChain(listener EventListener, messageHandler MessageHandler, executor ProposalExecutor, domainID uint8, startBlock *big.Int) *EVMChain {
 	return &EVMChain{
-		listener:   listener,
-		executor:   executor,
-		blockstore: blockstore,
-		domainID:   domainID,
-		startBlock: startBlock,
-		logger:     log.With().Uint8("domainID", domainID).Logger(),
+		listener:       listener,
+		executor:       executor,
+		domainID:       domainID,
+		startBlock:     startBlock,
+		messageHandler: messageHandler,
+		logger:         log.With().Uint8("domainID", domainID).Logger(),
 	}
 }
 
@@ -51,10 +55,14 @@ func (c *EVMChain) PollEvents(ctx context.Context) {
 	go c.listener.ListenToEvents(ctx, c.startBlock)
 }
 
-func (c *EVMChain) Write(msgs []*types.Message) error {
-	err := c.executor.Execute(msgs)
+func (c *EVMChain) ReceiveMessage(m *message.Message) (*proposal.Proposal, error) {
+	return c.messageHandler.HandleMessage(m)
+}
+
+func (c *EVMChain) Write(props []*proposal.Proposal) error {
+	err := c.executor.Execute(props)
 	if err != nil {
-		c.logger.Err(err).Msgf("error writing messages %+v on network %d", msgs, c.DomainID())
+		c.logger.Err(err).Msgf("error writing proposals %+v on network %d", props, c.DomainID())
 		return err
 	}
 

chains/substrate/chain.go

@@ -4,41 +4,41 @@ import (
 	"context"
 	"math/big"
 
-	"github.com/ChainSafe/sygma-core/chains/substrate/client"
-	"github.com/ChainSafe/sygma-core/store"
-	"github.com/ChainSafe/sygma-core/types"
+	"github.com/ChainSafe/sygma-core/relayer/message"
+	"github.com/ChainSafe/sygma-core/relayer/proposal"
 	"github.com/rs/zerolog"
 	"github.com/rs/zerolog/log"
 )
 
-type BatchProposalExecutor interface {
-	Execute(msgs []*types.Message) error
+type ProposalExecutor interface {
+	Execute(props []*proposal.Proposal) error
 }
 
-type SubstrateChain struct {
-	client *client.SubstrateClient
+type MessageHandler interface {
+	HandleMessage(m *message.Message) (*proposal.Proposal, error)
+}
 
-	listener EventListener
-	executor BatchProposalExecutor
+type EventListener interface {
+	ListenToEvents(ctx context.Context, startBlock *big.Int)
+}
 
-	blockstore *store.BlockStore
+type SubstrateChain struct {
+	listener       EventListener
+	messageHandler MessageHandler
+	executor       ProposalExecutor
 
 	domainID   uint8
 	startBlock *big.Int
 
 	logger zerolog.Logger
 }
 
-type EventListener interface {
-	ListenToEvents(ctx context.Context, startBlock *big.Int)
-}
-
-func NewSubstrateChain(client *client.SubstrateClient, listener EventListener, blockstore *store.BlockStore, executor BatchProposalExecutor, domainID uint8, startBlock *big.Int) *SubstrateChain {
+func NewSubstrateChain(listener EventListener, messageHandler MessageHandler, executor ProposalExecutor, domainID uint8, startBlock *big.Int) *SubstrateChain {
 	return &SubstrateChain{
-		client:     client,
 		listener:   listener,
-		blockstore: blockstore,
 		executor:   executor,
+		domainID:   domainID,
+		startBlock: startBlock,
 		logger:     log.With().Uint8("domainID", domainID).Logger()}
 }
 
@@ -49,10 +49,14 @@ func (c *SubstrateChain) PollEvents(ctx context.Context) {
 	go c.listener.ListenToEvents(ctx, c.startBlock)
 }
 
-func (c *SubstrateChain) Write(msgs []*types.Message) error {
-	err := c.executor.Execute(msgs)
+func (c *SubstrateChain) ReceiveMessage(m *message.Message) (*proposal.Proposal, error) {
+	return c.messageHandler.HandleMessage(m)
+}
+
+func (c *SubstrateChain) Write(props []*proposal.Proposal) error {
+	err := c.executor.Execute(props)
 	if err != nil {
-		c.logger.Err(err).Msgf("error writing messages %+v on network %d", msgs, c.DomainID())
+		c.logger.Err(err).Msgf("error writing proposals %+v on network %d", props, c.DomainID())
 		return err
 	}