diff --git a/chains/evm/chain.go b/chains/evm/chain.go index 3ff9e143..a09ea060 100644 --- a/chains/evm/chain.go +++ b/chains/evm/chain.go @@ -62,7 +62,7 @@ func (c *EVMChain) ReceiveMessage(m *message.Message) (*proposal.Proposal, error func (c *EVMChain) Write(props []*proposal.Proposal) error { err := c.executor.Execute(props) if err != nil { - c.logger.Err(err).Msgf("error writing proposals %+v on network %d", props, c.DomainID()) + c.logger.Err(err).Str("messageID", props[0].MessageID).Msgf("error writing proposals %+v on network %d", props, c.DomainID()) return err } diff --git a/chains/substrate/chain.go b/chains/substrate/chain.go index 09c80c67..9c72f922 100644 --- a/chains/substrate/chain.go +++ b/chains/substrate/chain.go @@ -57,7 +57,7 @@ func (c *SubstrateChain) ReceiveMessage(m *message.Message) (*proposal.Proposal, func (c *SubstrateChain) Write(props []*proposal.Proposal) error { err := c.executor.Execute(props) if err != nil { - c.logger.Err(err).Msgf("error writing proposals %+v on network %d", props, c.DomainID()) + c.logger.Err(err).Str("messageID", props[0].MessageID).Msgf("error writing proposals %+v on network %d", props, c.DomainID()) return err } diff --git a/relayer/relayer.go b/relayer/relayer.go index 948250c1..634a7c5d 100644 --- a/relayer/relayer.go +++ b/relayer/relayer.go @@ -64,11 +64,16 @@ func (r *Relayer) route(msgs []*message.Message) { log := log.With().Uint8("domainID", destChain.DomainID()).Str("messageID", msgs[0].ID).Logger() props := make([]*proposal.Proposal, 0) for _, m := range msgs { + log.Debug().Msgf("Sending message") + prop, err := destChain.ReceiveMessage(m) if err != nil { log.Err(err).Msgf("Failed receiving message %+v", m) continue } + + log.Debug().Msgf("Received message") + if prop != nil { props = append(props, prop) } @@ -77,6 +82,7 @@ func (r *Relayer) route(msgs []*message.Message) { return } + log.Debug().Msgf("Writing message") err := destChain.Write(props) if err != nil { log.Err(err).Msgf("Failed writing message")