File tree Expand file tree Collapse file tree 8 files changed +17
-12
lines changed
Expand file tree Collapse file tree 8 files changed +17
-12
lines changed Original file line number Diff line number Diff line change 1- // File: chain_poller/chain_poller.go
1+ // File: internal/ chain_poller/chain_poller.go
22package chain_poller
33
44import (
Original file line number Diff line number Diff line change 1- // File: chain_poller/chain_poller_interface.go
1+ // File: internal/ chain_poller/chain_poller_interface.go
22package chain_poller
33
44import (
Original file line number Diff line number Diff line change 1- // File: chain_poller/chain_poller_test.go
1+ // File: internal/ chain_poller/chain_poller_test.go
22package chain_poller
33
44import (
Original file line number Diff line number Diff line change 1- // File: chain_poller_service/chain_poller_service.go
1+ // File: internal/ chain_poller_service/chain_poller_service.go
22package chain_poller_service
33
44import (
@@ -12,9 +12,9 @@ import (
1212 "github.com/ethereum/go-ethereum/common"
1313 "github.com/rs/zerolog"
1414 "github.com/smartcontractkit/chainlink-testing-framework/sentinel/api"
15- "github.com/smartcontractkit/chainlink-testing-framework/sentinel/chain_poller"
1615 "github.com/smartcontractkit/chainlink-testing-framework/sentinel/internal"
17- "github.com/smartcontractkit/chainlink-testing-framework/sentinel/subscription_manager"
16+ "github.com/smartcontractkit/chainlink-testing-framework/sentinel/internal/chain_poller"
17+ "github.com/smartcontractkit/chainlink-testing-framework/sentinel/internal/subscription_manager"
1818)
1919
2020// ChainPollerServiceConfig holds the configuration for the ChainPollerService.
@@ -152,7 +152,12 @@ func (eps *ChainPollerService) pollCycle() {
152152 // Fetch the latest block number
153153 latestBlock , err := eps .config .BlockchainClient .BlockNumber (eps .ctx )
154154 if err != nil {
155- eps .config .Logger .Error ().Err (err ).Msg ("Failed to get latest block" )
155+ if errors .Is (err , context .Canceled ) {
156+ eps .config .Logger .Debug ().Msg ("Fetching latest block number canceled due to shutdown" )
157+ } else {
158+ eps .config .Logger .Error ().Err (err ).Msg ("Failed to get latest block" )
159+ }
160+
156161 return
157162 }
158163
Original file line number Diff line number Diff line change 1- // File: chain_poller_service/chain_poller_service_test.go
1+ // File: internal/ chain_poller_service/chain_poller_service_test.go
22package chain_poller_service_test
33
44import (
@@ -14,8 +14,8 @@ import (
1414
1515 "github.com/smartcontractkit/chainlink-testing-framework/lib/logging"
1616 "github.com/smartcontractkit/chainlink-testing-framework/sentinel/api"
17- "github.com/smartcontractkit/chainlink-testing-framework/sentinel/chain_poller_service"
1817 "github.com/smartcontractkit/chainlink-testing-framework/sentinel/internal"
18+ "github.com/smartcontractkit/chainlink-testing-framework/sentinel/internal/chain_poller_service"
1919)
2020
2121// MockChainPoller implements the ChainPollerInterface for testing.
Original file line number Diff line number Diff line change 1- // File: subscription_manager/subscription_manager.go
1+ // File: internal/ subscription_manager/subscription_manager.go
22package subscription_manager
33
44import (
Original file line number Diff line number Diff line change 1- // File: subscription_manager/subscription_manager_test.go
1+ // File: internal/ subscription_manager/subscription_manager_test.go
22package subscription_manager
33
44import (
Original file line number Diff line number Diff line change 99 "github.com/ethereum/go-ethereum/common"
1010 "github.com/rs/zerolog"
1111 "github.com/smartcontractkit/chainlink-testing-framework/sentinel/api"
12- "github.com/smartcontractkit/chainlink-testing-framework/sentinel/chain_poller_service"
12+ "github.com/smartcontractkit/chainlink-testing-framework/sentinel/internal/ chain_poller_service"
1313)
1414
1515// SentinelConfig holds configuration for the Sentinel.
You can’t perform that action at this time.
0 commit comments