From 0dcec4b545d8a04496ecb3e63298dbd9545f81a3 Mon Sep 17 00:00:00 2001
From: William Banfield <wbanfield@gmail.com>
Date: Wed, 19 Oct 2022 21:07:55 -0400
Subject: [PATCH] shim receive bytes metric

---
 p2p/peer.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/p2p/peer.go b/p2p/peer.go
index b2f61048a..e9239d377 100644
--- a/p2p/peer.go
+++ b/p2p/peer.go
@@ -416,10 +416,15 @@ func createMConnection(
 			"chID", fmt.Sprintf("%#x", chID),
 		}
 		p.metrics.PeerReceiveBytesTotal.With(labels...).Add(float64(len(msgBytes)))
+		p.metrics.MessageReceiveBytesTotal.With("message_type", "tmp").Add(float64(len(msgBytes)))
+		mt := msgTypeByChID[chID]
+		msg := proto.Clone(mt)
+		proto.Unmarshal(msgBytes, msg)
 		reactor.Receive(chID, p, msgBytes)
 		reactor.NewReceive(Envelope{
 			ChannelID: chID,
 			Src:       p,
+			Message:   msg,
 		})
 	}