Skip to content

Commit

Permalink
Fix tests
Browse files Browse the repository at this point in the history
  • Loading branch information
mpetrun5 committed Apr 11, 2024
1 parent 364798f commit c88573f
Showing 1 changed file with 3 additions and 4 deletions.
7 changes: 3 additions & 4 deletions relayer/relayer.go
Original file line number Diff line number Diff line change
Expand Up @@ -64,15 +64,15 @@ 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 to chain: %d", destChain.DomainID())
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 on chain: %d", destChain.DomainID())
log.Debug().Msgf("Received message")

if prop != nil {
props = append(props, prop)
Expand All @@ -82,8 +82,7 @@ func (r *Relayer) route(msgs []*message.Message) {
return
}

log.Debug().Msgf("Writing message on chain: %d", destChain.DomainID())

log.Debug().Msgf("Writing message")
err := destChain.Write(props)
if err != nil {
log.Err(err).Msgf("Failed writing message")
Expand Down

0 comments on commit c88573f

Please sign in to comment.