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

Node: CCQ logging changes (#4153)

This commit is contained in:
bruce-riley 2024-11-06 10:13:54 -06:00 committed by GitHub
parent 7247a0fc0c
commit e717f53872
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
node/pkg/p2p/ccq_p2p.go
View File

@ -109,6 +109,7 @@ func (ccq *ccqP2p) run(
ps, err := pubsub.NewGossipSub(ctx, ccq.h,
// We only want to accept subscribes from peers in the allow list.
pubsub.WithPeerFilter(func(peerID peer.ID, topic string) bool {
ccq.logger.Info("peer request received", zap.String("peerID", peerID.String()), zap.String("topic", topic))
if len(ccq.allowedPeers) == 0 {
return true
}

6
node/pkg/watchers/evm/ccq.go
View File

@ -143,7 +143,7 @@ func (w *Watcher) ccqHandleEthCallQueryRequest(ctx context.Context, queryRequest
// Verify that the block read was successful.
if err := w.ccqVerifyBlockResult(blockError, blockResult); err != nil {
w.ccqLogger.Error("failed to verify block for eth_call query",
w.ccqLogger.Debug("failed to verify block for eth_call query",
zap.String("requestId", requestId),
zap.String("block", block),
zap.Any("batch", batch),
@ -388,7 +388,7 @@ func (w *Watcher) ccqHandleEthCallByTimestampQueryRequest(ctx context.Context, q
// Verify the following block read was successful.
if err := w.ccqVerifyBlockResult(nextBlockError, nextBlockResult); err != nil {
w.ccqLogger.Error("failed to verify next block for eth_call_by_timestamp query",
w.ccqLogger.Debug("failed to verify next block for eth_call_by_timestamp query",
zap.String("requestId", requestId),
zap.String("block", block),
zap.String("nextBlock", nextBlock),
@ -557,7 +557,7 @@ func (w *Watcher) ccqHandleEthCallWithFinalityQueryRequest(ctx context.Context,
// Verify that the block read was successful.
if err := w.ccqVerifyBlockResult(blockError, blockResult); err != nil {
w.ccqLogger.Error("failed to verify block for eth_call_with_finality query",
w.ccqLogger.Debug("failed to verify block for eth_call_with_finality query",
zap.String("requestId", requestId),
zap.String("block", block),
zap.Any("batch", batch),