From dd777dca4b784394d1ee09c023ce5acfd46725ea Mon Sep 17 00:00:00 2001 From: nick Date: Tue, 2 Jul 2024 17:46:47 +0900 Subject: [PATCH] fix: update based on feedbacks --- node/pkg/chain/websocketchainreader/websocketreader.go | 6 ++++-- node/pkg/dal/utils/utils.go | 2 +- 2 files changed, 5 insertions(+), 3 deletions(-) diff --git a/node/pkg/chain/websocketchainreader/websocketreader.go b/node/pkg/chain/websocketchainreader/websocketreader.go index 67a136759..db8aafb94 100644 --- a/node/pkg/chain/websocketchainreader/websocketreader.go +++ b/node/pkg/chain/websocketchainreader/websocketreader.go @@ -16,7 +16,9 @@ import ( ) func New(opts ...ChainReaderOption) (*ChainReader, error) { - config := &ChainReaderConfig{} + config := &ChainReaderConfig{ + RetryInterval: 1 * time.Second, + } for _, opt := range opts { opt(config) } @@ -64,7 +66,7 @@ func New(opts ...ChainReaderOption) (*ChainReader, error) { return &ChainReader{ EthClient: ethClient, KaiaClient: kaiaClient, - RetryPeriod: 1 * time.Second, + RetryPeriod: config.RetryInterval, ChainIdToChainType: chainIdToChainType, }, nil } diff --git a/node/pkg/dal/utils/utils.go b/node/pkg/dal/utils/utils.go index 655c3c3a2..ac02e230c 100644 --- a/node/pkg/dal/utils/utils.go +++ b/node/pkg/dal/utils/utils.go @@ -64,7 +64,7 @@ func CustomErrorHandler(c *fiber.Ctx, err error) error { // | ${status} | ${ip} | ${method} | ${path} | ${error}", log. - Info(). + Error(). Err(err). Int("status", code). Str("ip", c.IP()).