chore: add slow block log (#124)

Author: lehainam-dev

internal/app/app.go

@@ -129,7 +129,8 @@ func NewListener(c *cli.Context) (*listener.Listener, error) {
 	msgEncoder := getMessageEncoder()
 
 	l.Infow("Setup handler", "topic", topic)
-	handler := listener.NewHandler(l, topic, httpEVMClient, blockKeeper, publisher, msgEncoder,
+	handler := listener.NewHandler(listener.HandlerConfig{BlockSlowWarningThreshold: blockSlowWarningThresholdFlag.Value},
+		l, topic, httpEVMClient, blockKeeper, publisher, msgEncoder,
 		listener.WithEventLogs(nil, nil))
 
 	l.Infow("Setup listener")

internal/app/flags.go

@@ -49,6 +49,12 @@ var (
 		Value:   24 * time.Second, //nolint:gomnd
 		Usage:   "Interval time for running santity check, default: 24s",
 	}
+	blockSlowWarningThresholdFlag = &cli.DurationFlag{
+		Name:    "block-slow-warning-threshold",
+		EnvVars: []string{"BLOCK_SLOW_WARNING_THRESHOLD"},
+		Value:   5 * time.Minute, //nolint:gomnd
+		Usage:   "Threshold for warning slow block",
+	}
 
 	sentryDSNFlag = &cli.StringFlag{
 		Name:    "sentry-dsn",
@@ -228,6 +234,7 @@ func NewFlags() []cli.Flag {
 		rpcRequestTimeoutFlag,
 		sanityNodeRPCFlag,
 		sanityCheckIntervalFlag,
+		blockSlowWarningThresholdFlag,
 	}
 	flags = append(flags, NewSentryFlags()...)
 	flags = append(flags, NewRedisFlags()...)

pkg/listener/handler.go

@@ -3,6 +3,7 @@ package listener
 import (
 	"context"
 	"math/big"
+	"time"
 
 	"github.com/KyberNetwork/evmlistener/pkg/block"
 	"github.com/KyberNetwork/evmlistener/pkg/encoder"
@@ -13,8 +14,13 @@ import (
 	"go.uber.org/zap"
 )
 
+type HandlerConfig struct {
+	BlockSlowWarningThreshold time.Duration
+}
+
 // Handler ...
 type Handler struct {
+	cfg   HandlerConfig
 	topic string
 
 	evmClient   evmclient.IClient
@@ -27,7 +33,7 @@ type Handler struct {
 
 // NewHandler ...
 func NewHandler(
-	l *zap.SugaredLogger, topic string, evmClient evmclient.IClient,
+	cfg HandlerConfig, l *zap.SugaredLogger, topic string, evmClient evmclient.IClient,
 	blockKeeper block.Keeper, publisher publisher.Publisher, encoder encoder.Encoder,
 	options ...Option,
 ) *Handler {
@@ -37,6 +43,7 @@ func NewHandler(
 	}
 
 	return &Handler{
+		cfg:         cfg,
 		topic:       topic,
 		evmClient:   evmClient,
 		blockKeeper: blockKeeper,
@@ -212,6 +219,11 @@ func (h *Handler) handleNewBlock(ctx context.Context, b types.Block) error {
 	)
 
 	log.Infow("Handling new block")
+	now := time.Now()
+	blockTime := time.Unix(int64(b.Timestamp), 0)
+	if now.Sub(blockTime) > h.cfg.BlockSlowWarningThreshold {
+		log.Warnw("Block is slow", "blockTime", blockTime)
+	}
 
 	isReorg, err := h.blockKeeper.IsReorg(b)
 	if err != nil {

pkg/listener/handler_test.go

@@ -36,13 +36,13 @@ func (ts *HandlerTestSuite) SetupTest() {
 	ts.blockKeeper = block.NewBaseBlockKeeper(32)
 	ts.publisher = NewPublisherMock(1000)
 	ts.encoder = encoder.NewJSONEncoder()
-	ts.handler = NewHandler(zap.S(), "test-topic", ts.evmClient, ts.blockKeeper, ts.publisher, ts.encoder)
+	ts.handler = NewHandler(HandlerConfig{}, zap.S(), "test-topic", ts.evmClient, ts.blockKeeper, ts.publisher, ts.encoder)
 }
 
 func (ts *HandlerTestSuite) TestInit() {
 	ts.evmClient.SetHead(34)
 	blockKeeper := NewBlockKeeperMock(32)
-	handler := NewHandler(zap.S(), "test-topic", ts.evmClient, blockKeeper, ts.publisher, ts.encoder)
+	handler := NewHandler(HandlerConfig{}, zap.S(), "test-topic", ts.evmClient, blockKeeper, ts.publisher, ts.encoder)
 
 	// Init handler without saved data.
 	err := handler.Init(context.Background())

pkg/listener/listener_test.go

@@ -36,7 +36,7 @@ func (ts *ListenerTestSuite) SetupTest() {
 	ts.publisher = NewPublisherMock(1000)
 	ts.encoder = encoder.NewJSONEncoder()
 	blockKeeper := block.NewBaseBlockKeeper(32)
-	handler := NewHandler(zap.S(), "test-topic", ts.evmClient, blockKeeper, ts.publisher, ts.encoder)
+	handler := NewHandler(HandlerConfig{}, zap.S(), "test-topic", ts.evmClient, blockKeeper, ts.publisher, ts.encoder)
 	ts.listener = New(zap.S(), evmClient, evmClient, handler, nil, 0)
 }