chore: add path name to logs in message processor (#1171)

cosmos · Apr 18, 2023 · e594d2a · e594d2a
1 parent 314056b
commit e594d2a
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/relayer/processor/message_processor.go b/relayer/processor/message_processor.go
@@ -332,6 +332,7 @@ func (mp *messageProcessor) sendClientUpdate(
 
 	if err := dst.chainProvider.SendMessagesToMempool(broadcastCtx, msgs, mp.memo, ctx, nil); err != nil {
 		mp.log.Error("Error sending client update message",
+			zap.String("path_name", src.info.PathName),
 			zap.String("src_chain_id", src.info.ChainID),
 			zap.String("dst_chain_id", dst.info.ChainID),
 			zap.String("src_client_id", src.info.ClientID),
@@ -388,6 +389,7 @@ func (mp *messageProcessor) sendBatchMessages(
 
 	if err := dst.chainProvider.SendMessagesToMempool(broadcastCtx, msgs, mp.memo, ctx, callback); err != nil {
 		errFields := []zapcore.Field{
+			zap.String("path_name", src.info.PathName),
 			zap.String("src_chain_id", src.info.ChainID),
 			zap.String("dst_chain_id", dst.info.ChainID),
 			zap.String("src_client_id", src.info.ClientID),
@@ -442,6 +444,7 @@ func (mp *messageProcessor) sendSingleMessage(
 	err := dst.chainProvider.SendMessagesToMempool(broadcastCtx, msgs, mp.memo, ctx, callback)
 	if err != nil {
 		errFields := []zapcore.Field{
+			zap.String("path_name", src.info.PathName),
 			zap.String("src_chain_id", src.info.ChainID),
 			zap.String("dst_chain_id", dst.info.ChainID),
 			zap.String("src_client_id", src.info.ClientID),