From b129fcb52dc531bdc7b8459cca9c9ec5d7e2863a Mon Sep 17 00:00:00 2001
From: bruce-riley <96066700+bruce-riley@users.noreply.github.com>
Date: Thu, 3 Nov 2022 11:09:20 -0500
Subject: [PATCH] Node: Disable more PythNet logging (#1829)

* Node: Disable more PythNet logging

* Node: Undo governor change caused by rebase
---
 node/pkg/processor/observation.go  |  2 +-
 node/pkg/watchers/solana/client.go | 29 +++++++++++++----------------
 2 files changed, 14 insertions(+), 17 deletions(-)

diff --git a/node/pkg/processor/observation.go b/node/pkg/processor/observation.go
index fe0806c51..4d860fa40 100644
--- a/node/pkg/processor/observation.go
+++ b/node/pkg/processor/observation.go
@@ -53,7 +53,7 @@ func (p *Processor) handleObservation(ctx context.Context, m *gossipv1.SignedObs
 
 	hash := hex.EncodeToString(m.Hash)
 
-	p.logger.Info("received observation",
+	p.logger.Debug("received observation",
 		zap.String("digest", hash),
 		zap.String("signature", hex.EncodeToString(m.Signature)),
 		zap.String("addr", hex.EncodeToString(m.Addr)),
diff --git a/node/pkg/watchers/solana/client.go b/node/pkg/watchers/solana/client.go
index 64d3de2b7..a07a93e4f 100644
--- a/node/pkg/watchers/solana/client.go
+++ b/node/pkg/watchers/solana/client.go
@@ -183,20 +183,17 @@ func (s *SolanaWatcher) Run(ctx context.Context) error {
 					Height:          int64(slot),
 					ContractAddress: contractAddr,
 				})
-				logger.Info("fetched current Solana height",
-					zap.String("commitment", string(s.commitment)),
-					zap.Uint64("slot", slot),
-					zap.Uint64("lastSlot", lastSlot),
-					zap.Uint64("pendingSlots", slot-lastSlot),
-					zap.Duration("took", time.Since(start)))
 
 				rangeStart := lastSlot + 1
 				rangeEnd := slot
 
-				logger.Info("fetching slots in range",
+				logger.Debug("fetched current Solana height",
+					zap.String("commitment", string(s.commitment)),
+					zap.Uint64("slot", slot),
+					zap.Uint64("lastSlot", lastSlot),
+					zap.Uint64("pendingSlots", slot-lastSlot),
 					zap.Uint64("from", rangeStart), zap.Uint64("to", rangeEnd),
-					zap.Duration("took", time.Since(start)),
-					zap.String("commitment", string(s.commitment)))
+					zap.Duration("took", time.Since(start)))
 
 				// Requesting each slot
 				for slot := rangeStart; slot <= rangeEnd; slot++ {
@@ -298,7 +295,7 @@ func (s *SolanaWatcher) fetchBlock(ctx context.Context, logger *zap.Logger, slot
 		return false
 	}
 
-	logger.Info("fetched block",
+	logger.Debug("fetched block",
 		zap.Uint64("slot", slot),
 		zap.Int("num_tx", len(out.Transactions)),
 		zap.Duration("took", time.Since(start)),
@@ -343,7 +340,7 @@ OUTER:
 			continue
 		}
 
-		logger.Info("found Wormhole transaction",
+		logger.Debug("found Wormhole transaction",
 			zap.Stringer("signature", signature),
 			zap.Uint64("slot", slot),
 			zap.String("commitment", string(s.commitment)))
@@ -388,7 +385,7 @@ OUTER:
 			return false
 		}
 
-		logger.Info("fetched transaction",
+		logger.Debug("fetched transaction",
 			zap.Uint64("slot", slot),
 			zap.String("commitment", string(s.commitment)),
 			zap.Stringer("signature", signature),
@@ -443,7 +440,7 @@ func (s *SolanaWatcher) processInstruction(ctx context.Context, logger *zap.Logg
 		return false, fmt.Errorf("failed to deserialize instruction data: %w", err)
 	}
 
-	logger.Info("post message data", zap.Any("deserialized_data", data),
+	logger.Debug("post message data", zap.Any("deserialized_data", data),
 		zap.Stringer("signature", signature), zap.Uint64("slot", slot), zap.Int("idx", idx))
 
 	level, err := data.ConsistencyLevel.Commitment()
@@ -458,7 +455,7 @@ func (s *SolanaWatcher) processInstruction(ctx context.Context, logger *zap.Logg
 	// The second account in a well-formed Wormhole instruction is the VAA program account.
 	acc := tx.Message.AccountKeys[inst.Accounts[1]]
 
-	logger.Info("fetching VAA account", zap.Stringer("acc", acc),
+	logger.Debug("fetching VAA account", zap.Stringer("acc", acc),
 		zap.Stringer("signature", signature), zap.Uint64("slot", slot), zap.Int("idx", idx))
 
 	go s.retryFetchMessageAccount(ctx, logger, acc, slot, 0)
@@ -534,7 +531,7 @@ func (s *SolanaWatcher) fetchMessageAccount(ctx context.Context, logger *zap.Log
 		return false
 	}
 
-	logger.Info("found valid VAA account",
+	logger.Debug("found valid VAA account",
 		zap.Uint64("slot", slot),
 		zap.String("commitment", string(s.commitment)),
 		zap.Stringer("account", acc),
@@ -583,7 +580,7 @@ func (s *SolanaWatcher) processMessageAccount(logger *zap.Logger, data []byte, a
 
 	solanaMessagesConfirmed.WithLabelValues(s.networkName).Inc()
 
-	logger.Info("message observed",
+	logger.Debug("message observed",
 		zap.Stringer("account", acc),
 		zap.Time("timestamp", observation.Timestamp),
 		zap.Uint32("nonce", observation.Nonce),