shim in new receive to the reactor interface

p2p/base_reactor.go

@@ -45,6 +45,8 @@ type Reactor interface {
 	//
 	// CONTRACT: msgBytes are not nil.
 	Receive(chID byte, peer Peer, msgBytes []byte)
+
+	NewReceive(Envelope)
 }
 
 //--------------------------------------

p2p/peer.go

@@ -414,6 +414,10 @@ func createMConnection(
 		}
 		p.metrics.PeerReceiveBytesTotal.With(labels...).Add(float64(len(msgBytes)))
 		reactor.Receive(chID, p, msgBytes)
+		reactor.NewReceive(Envelope{
+			ChannelID: chID,
+			Src:       p,
+		})
 	}
 
 	onError := func(r interface{}) {