fix msgbody

cmd/process.go

@@ -188,9 +188,9 @@ func filterInvalidDestinationCallers(registeredDomains map[types.Domain]types.Ch
 }
 
 func filterLowTransfers(cfg *types.Config, logger log.Logger, msg *types.MessageState) bool {
-	bm, err := new(cctptypes.BurnMessage).Parse(msg.MsgSentBytes)
+	bm, err := new(cctptypes.BurnMessage).Parse(msg.MsgBody)
 	if err != nil {
-		logger.Error("Error parsing burn message", "err", err)
+		logger.Info("This is not a burn message", "err", err)
 		return true
 	}
 

noble/message_state.go

@@ -66,6 +66,7 @@ func txToMessageState(tx *ctypes.ResultTx) ([]*types.MessageState, error) {
 						Nonce:             msg.Nonce,
 						SourceTxHash:      tx.Hash.String(),
 						MsgSentBytes:      rawMessageSentBytes,
+						MsgBody:           msg.MessageBody,
 						DestinationCaller: msg.DestinationCaller,
 						Created:           now,
 						Updated:           now,

types/message_state.go

@@ -41,6 +41,7 @@ type MessageState struct {
 	SourceTxHash      string
 	DestTxHash        string
 	MsgSentBytes      []byte // bytes of the MessageSent message transmitter event
+	MsgBody           []byte // bytes of the MessageBody
 	DestinationCaller []byte // address authorized to call transaction
 	Channel           string // "channel-%d" if a forward, empty if not a forward
 	Created           time.Time
@@ -68,6 +69,7 @@ func EvmLogToMessageState(abi abi.ABI, messageSent abi.Event, log *ethtypes.Log)
 		DestDomain:        Domain(message.DestinationDomain),
 		SourceTxHash:      log.TxHash.Hex(),
 		MsgSentBytes:      rawMessageSentBytes,
+		MsgBody:           message.MessageBody,
 		DestinationCaller: message.DestinationCaller,
 		Nonce:             message.Nonce,
 		Created:           time.Now(),