Node: Polygon checkpoint logging
Change-Id: I31305812cc784845aa98497ada24b2a2041cad71
This commit is contained in:
parent
3e0cabc70f
commit
16e8bb347e
|
@ -108,6 +108,8 @@ func (c *PolygonConnector) SubscribeForBlocks(ctx context.Context, sink chan<- *
|
||||||
return nil, fmt.Errorf("failed to get initial block: %w", err)
|
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 {
|
if err = c.postBlock(ctx, initialBlock, sink); err != nil {
|
||||||
return nil, fmt.Errorf("failed to post initial block: %w", err)
|
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)
|
var bigOne = big.NewInt(1)
|
||||||
|
|
||||||
func (c *PolygonConnector) processCheckpoint(ctx context.Context, sink chan<- *NewBlock, checkpoint *rootAbi.AbiRootChainNewHeaderBlock) error {
|
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) {
|
for blockNum := checkpoint.Start; blockNum.Cmp(checkpoint.End) <= 0; blockNum.Add(blockNum, bigOne) {
|
||||||
if err := c.postBlock(ctx, blockNum, sink); err != nil {
|
if err := c.postBlock(ctx, blockNum, sink); err != nil {
|
||||||
return fmt.Errorf("failed to post block %s: %w", blockNum.String(), err)
|
return fmt.Errorf("failed to post block %s: %w", blockNum.String(), err)
|
||||||
|
|
Loading…
Reference in New Issue