From b11060153ee1b0e36cc91c1aecb23db4ef6c6c0c Mon Sep 17 00:00:00 2001 From: William Banfield Date: Thu, 20 Oct 2022 16:37:03 -0400 Subject: [PATCH] put wrap into receive --- p2p/peer.go | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/p2p/peer.go b/p2p/peer.go index 11742fd66..8a49668ef 100644 --- a/p2p/peer.go +++ b/p2p/peer.go @@ -420,6 +420,13 @@ func createMConnection( "peer_id", string(p.ID()), "chID", fmt.Sprintf("%#x", chID), } + if w, ok := msg.(Wrapper); ok { + msg, err = w.Unwrap() + if err != nil { + // TODO(williambanfield) add error log line. + return + } + } p.metrics.PeerReceiveBytesTotal.With(labels...).Add(float64(len(msgBytes))) p.metrics.MessageReceiveBytesTotal.With("message_type", "tmp").Add(float64(len(msgBytes))) reactor.Receive(Envelope{