From d6481ca08cbc36b5960eb31af3138e7837f7c59b Mon Sep 17 00:00:00 2001
From: Bruce Riley <bruce@wormholelabs.xyz>
Date: Fri, 30 Aug 2024 09:58:41 -0500
Subject: [PATCH] Node/Processor: Peg observation metric for us

---
 node/pkg/processor/message.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/node/pkg/processor/message.go b/node/pkg/processor/message.go
index 65e947678a..e58f7dfc04 100644
--- a/node/pkg/processor/message.go
+++ b/node/pkg/processor/message.go
@@ -95,6 +95,10 @@ func (p *Processor) handleMessage(k *common.MessagePublication) {
 	// Broadcast the signature.
 	ourObs, msg := p.broadcastSignature(v.MessageID(), k.TxHash.Bytes(), digest, signature, shouldPublishImmediately)
 
+	// Indicate that we observed this one.
+	observationsReceivedTotal.Inc()
+	observationsReceivedByGuardianAddressTotal.WithLabelValues(p.ourAddr.Hex()).Inc()
+
 	// Get / create our state entry.
 	s := p.state.signatures[hash]
 	if s == nil {