From 16e8bb347e8bd95f7565e03b0f4d634fe08ebe93 Mon Sep 17 00:00:00 2001 From: Bruce Riley Date: Fri, 2 Dec 2022 14:56:07 +0000 Subject: [PATCH] Node: Polygon checkpoint logging Change-Id: I31305812cc784845aa98497ada24b2a2041cad71 --- node/pkg/watchers/evm/connectors/polygon.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/node/pkg/watchers/evm/connectors/polygon.go b/node/pkg/watchers/evm/connectors/polygon.go index 4c29a646e..40971b2b5 100644 --- a/node/pkg/watchers/evm/connectors/polygon.go +++ b/node/pkg/watchers/evm/connectors/polygon.go @@ -108,6 +108,8 @@ func (c *PolygonConnector) SubscribeForBlocks(ctx context.Context, sink chan<- * return nil, fmt.Errorf("failed to get initial block: %w", err) } + c.logger.Info("queried initial block", zap.Uint64("initialBlock", initialBlock.Uint64())) + if err = c.postBlock(ctx, initialBlock, sink); err != nil { return nil, fmt.Errorf("failed to post initial block: %w", err) } @@ -133,6 +135,7 @@ func (c *PolygonConnector) SubscribeForBlocks(ctx context.Context, sink chan<- * var bigOne = big.NewInt(1) func (c *PolygonConnector) processCheckpoint(ctx context.Context, sink chan<- *NewBlock, checkpoint *rootAbi.AbiRootChainNewHeaderBlock) error { + c.logger.Info("processing checkpoint", zap.Uint64("start", checkpoint.Start.Uint64()), zap.Uint64("end", checkpoint.End.Uint64())) for blockNum := checkpoint.Start; blockNum.Cmp(checkpoint.End) <= 0; blockNum.Add(blockNum, bigOne) { if err := c.postBlock(ctx, blockNum, sink); err != nil { return fmt.Errorf("failed to post block %s: %w", blockNum.String(), err)