certusone
/
wormhole
mirror of https://github.com/certusone/wormhole.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Node: Disable more PythNet logging (#1829) 

* Node: Disable more PythNet logging

* Node: Undo governor change caused by rebase
This commit is contained in:
bruce-riley 2022-11-03 11:09:20 -05:00 committed by GitHub
parent 8bbf8a19b5
commit b129fcb52d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 14 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
node/pkg/processor/observation.go
View File

@ -53,7 +53,7 @@ func (p *Processor) handleObservation(ctx context.Context, m *gossipv1.SignedObs
hash := hex.EncodeToString(m.Hash) hash := hex.EncodeToString(m.Hash)
p.logger.Info("received observation", p.logger.Debug("received observation",
zap.String("digest", hash), zap.String("digest", hash),
zap.String("signature", hex.EncodeToString(m.Signature)), zap.String("signature", hex.EncodeToString(m.Signature)),
zap.String("addr", hex.EncodeToString(m.Addr)), zap.String("addr", hex.EncodeToString(m.Addr)),

29
node/pkg/watchers/solana/client.go
View File

@ -183,20 +183,17 @@ func (s *SolanaWatcher) Run(ctx context.Context) error {
Height: int64(slot), Height: int64(slot),
ContractAddress: contractAddr, 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 rangeStart := lastSlot + 1
rangeEnd := slot 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.Uint64("from", rangeStart), zap.Uint64("to", rangeEnd),
zap.Duration("took", time.Since(start)), zap.Duration("took", time.Since(start)))
zap.String("commitment", string(s.commitment)))
// Requesting each slot // Requesting each slot
for slot := rangeStart; slot <= rangeEnd; slot++ { for slot := rangeStart; slot <= rangeEnd; slot++ {
@ -298,7 +295,7 @@ func (s *SolanaWatcher) fetchBlock(ctx context.Context, logger *zap.Logger, slot
return false return false
} }
logger.Info("fetched block", logger.Debug("fetched block",
zap.Uint64("slot", slot), zap.Uint64("slot", slot),
zap.Int("num_tx", len(out.Transactions)), zap.Int("num_tx", len(out.Transactions)),
zap.Duration("took", time.Since(start)), zap.Duration("took", time.Since(start)),
@ -343,7 +340,7 @@ OUTER:
continue continue
} }
logger.Info("found Wormhole transaction", logger.Debug("found Wormhole transaction",
zap.Stringer("signature", signature), zap.Stringer("signature", signature),
zap.Uint64("slot", slot), zap.Uint64("slot", slot),
zap.String("commitment", string(s.commitment))) zap.String("commitment", string(s.commitment)))
@ -388,7 +385,7 @@ OUTER:
return false return false
} }
logger.Info("fetched transaction", logger.Debug("fetched transaction",
zap.Uint64("slot", slot), zap.Uint64("slot", slot),
zap.String("commitment", string(s.commitment)), zap.String("commitment", string(s.commitment)),
zap.Stringer("signature", signature), 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) 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)) zap.Stringer("signature", signature), zap.Uint64("slot", slot), zap.Int("idx", idx))
level, err := data.ConsistencyLevel.Commitment() 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. // The second account in a well-formed Wormhole instruction is the VAA program account.
acc := tx.Message.AccountKeys[inst.Accounts[1]] 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)) zap.Stringer("signature", signature), zap.Uint64("slot", slot), zap.Int("idx", idx))
go s.retryFetchMessageAccount(ctx, logger, acc, slot, 0) go s.retryFetchMessageAccount(ctx, logger, acc, slot, 0)
@ -534,7 +531,7 @@ func (s *SolanaWatcher) fetchMessageAccount(ctx context.Context, logger *zap.Log
return false return false
} }
logger.Info("found valid VAA account", logger.Debug("found valid VAA account",
zap.Uint64("slot", slot), zap.Uint64("slot", slot),
zap.String("commitment", string(s.commitment)), zap.String("commitment", string(s.commitment)),
zap.Stringer("account", acc), zap.Stringer("account", acc),
@ -583,7 +580,7 @@ func (s *SolanaWatcher) processMessageAccount(logger *zap.Logger, data []byte, a
solanaMessagesConfirmed.WithLabelValues(s.networkName).Inc() solanaMessagesConfirmed.WithLabelValues(s.networkName).Inc()
logger.Info("message observed", logger.Debug("message observed",
zap.Stringer("account", acc), zap.Stringer("account", acc),
zap.Time("timestamp", observation.Timestamp), zap.Time("timestamp", observation.Timestamp),
zap.Uint32("nonce", observation.Nonce), zap.Uint32("nonce", observation.Nonce),