node/pkg/processor: log quorum for unsubmitted nil VAAs

Change-Id: I4b29e2813209195c7e1698afb6772f2b18ebfde9

node/pkg/processor/cleanup.go

@@ -102,7 +102,19 @@ func (p *Processor) handleCleanup(ctx context.Context) {
 				s.retryCount += 1
 				aggregationStateRetries.Inc()
 			} else {
-				p.logger.Info("expiring unsubmitted nil VAA", zap.String("digest", hash), zap.Duration("delta", delta))
+				// For nil state entries, we log the quorum to determine whether the
+				// network reached consensus without us. We don't know the correct guardian
+				// set, so we simply use the most recent one.
+				hasSigs := len(s.signatures)
+				wantSigs := CalculateQuorum(len(p.gs.Keys))
+
+				p.logger.Info("expiring unsubmitted nil VAA",
+					zap.String("digest", hash),
+					zap.Duration("delta", delta),
+					zap.Int("have_sigs", hasSigs),
+					zap.Int("required_sigs", wantSigs),
+					zap.Bool("quorum", hasSigs >= wantSigs),
+				)
 				delete(p.state.vaaSignatures, hash)
 				aggregationStateUnobserved.Inc()
 			}

node/pkg/processor/observation.go

@@ -227,6 +227,7 @@ func (p *Processor) handleObservation(ctx context.Context, m *gossipv1.SignedObs
 			zap.Bools("aggregation", agg),
 			zap.Int("required_sigs", quorum),
 			zap.Int("have_sigs", len(sigs)),
+			zap.Bool("quorum", len(sigs) >= quorum),
 		)
 
 		if len(sigs) >= quorum && !p.state.vaaSignatures[hash].submitted {