Skip to content

Commit 51b4f8d

Browse files
committed
bumping common to merge commit
2 parents a93ac9e + 980d280 commit 51b4f8d

66 files changed

Lines changed: 1929 additions & 2022 deletions

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

.changeset/quick-kiwis-tease.md

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
---
2+
"chainlink": minor
3+
---
4+
5+
#internal LLO Observation loop

.tool-versions

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
golang 1.24.5
1+
golang 1.25.3
22
mockery 2.53.0
33
nodejs 20.13.1
44
pnpm 10.6.5

core/scripts/cre/environment/environment/billing.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -199,12 +199,12 @@ func startBilling(_ context.Context, cleanupWait time.Duration, setupOutput *env
199199

200200
// Select the appropriate chain for billing service from available chains in the environment.
201201
// otherwise, if RPCURL is defined, billing service can be used standalone
202-
if len(setupOutput.BlockchainOutput) != 0 {
202+
if len(setupOutput.Blockchains) != 0 {
203203
var selectedChain *blockchain.Output
204204

205-
for _, chain := range setupOutput.BlockchainOutput {
206-
if chain.ChainSelector == in.BillingService.ChainSelector {
207-
selectedChain = chain.BlockchainOutput
205+
for _, chain := range setupOutput.Blockchains {
206+
if chain.ChainSelector() == in.BillingService.ChainSelector {
207+
selectedChain = chain.CtfOutput()
208208
}
209209
}
210210

core/scripts/cre/environment/environment/environment.go

Lines changed: 22 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -28,9 +28,13 @@ import (
2828
cldlogger "github.com/smartcontractkit/chainlink/deployment/logger"
2929

3030
"github.com/smartcontractkit/chainlink/system-tests/lib/cre/capabilities/sets"
31+
"github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment/blockchains"
32+
"github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment/blockchains/evm"
33+
blockchains_sets "github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment/blockchains/sets"
3134
envconfig "github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment/config"
3235
"github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment/stagegen"
3336
"github.com/smartcontractkit/chainlink/system-tests/lib/cre/flags"
37+
"github.com/smartcontractkit/chainlink/system-tests/lib/infra"
3438

3539
keystone_changeset "github.com/smartcontractkit/chainlink/deployment/keystone/changeset"
3640
libc "github.com/smartcontractkit/chainlink/system-tests/lib/conversions"
@@ -42,7 +46,6 @@ import (
4246
libformat "github.com/smartcontractkit/chainlink/system-tests/lib/format"
4347

4448
"github.com/smartcontractkit/chainlink-testing-framework/framework"
45-
"github.com/smartcontractkit/chainlink-testing-framework/framework/components/blockchain"
4649
billingplatformservice "github.com/smartcontractkit/chainlink-testing-framework/framework/components/dockercompose/billing_platform_service"
4750
chipingressset "github.com/smartcontractkit/chainlink-testing-framework/framework/components/dockercompose/chip_ingress_set"
4851
"github.com/smartcontractkit/chainlink-testing-framework/framework/tracking"
@@ -179,18 +182,23 @@ var StartCmdRecoverHandlerFunc = func(p any, cleanupWait time.Duration) {
179182
}
180183
}
181184

182-
var StartCmdGenerateSettingsFile = func(homeChainOut *cre.WrappedBlockchainOutput, output *creenv.SetupOutput) error {
185+
var StartCmdGenerateSettingsFile = func(registryChain blockchains.Blockchain, output *creenv.SetupOutput) error {
183186
rpcs := map[uint64]string{}
184-
for _, bcOut := range output.BlockchainOutput {
185-
rpcs[bcOut.ChainSelector] = bcOut.BlockchainOutput.Nodes[0].ExternalHTTPUrl
187+
for _, bcOut := range output.Blockchains {
188+
rpcs[bcOut.ChainSelector()] = bcOut.CtfOutput().Nodes[0].ExternalHTTPUrl
189+
}
190+
191+
regChainEVM, isEVM := registryChain.(*evm.Blockchain)
192+
if !isEVM {
193+
return fmt.Errorf("registry chain is not EVM, but %T, cannot generate CRE CLI settings file", registryChain)
186194
}
187195

188196
creCLISettingsFile, settingsErr := crecli.PrepareCRECLISettingsFile(
189197
crecli.CRECLIProfile,
190-
homeChainOut.SethClient.MustGetRootKeyAddress(),
198+
regChainEVM.SethClient.MustGetRootKeyAddress(),
191199
output.CldEnvironment.ExistingAddresses, //nolint:staticcheck,nolintlint // SA1019: deprecated but we don't want to migrate now
192200
output.DonTopology.WorkflowDonID,
193-
homeChainOut.ChainSelector,
201+
regChainEVM.ChainSelector(),
194202
rpcs,
195203
output.S3ProviderOutput,
196204
)
@@ -266,10 +274,6 @@ func startCmd() *cobra.Command {
266274
return errors.Wrap(err, "failed to set default CTF configs")
267275
}
268276

269-
if pkErr := creenv.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
270-
return errors.Wrap(pkErr, "failed to set default private key")
271-
}
272-
273277
cleanUpErr := envconfig.RemoveAllEnvironmentStateDir(relativePathToRepoRoot)
274278
if cleanUpErr != nil {
275279
return errors.Wrap(cleanUpErr, "failed to clean up environment state files")
@@ -352,7 +356,7 @@ func startCmd() *cobra.Command {
352356
return errors.Wrap(startErr, "failed to start environment")
353357
}
354358

355-
homeChainOut := output.BlockchainOutput[0]
359+
homeChainOut := output.Blockchains[0]
356360

357361
sErr := StartCmdGenerateSettingsFile(homeChainOut, output)
358362
if sErr != nil {
@@ -446,7 +450,7 @@ func startCmd() *cobra.Command {
446450

447451
wfRegAddr := libcontracts.MustFindAddressesForChain(
448452
output.CldEnvironment.ExistingAddresses, //nolint:staticcheck,nolintlint // SA1019: deprecated but we don't want to migrate now
449-
output.BlockchainOutput[0].ChainSelector,
453+
output.Blockchains[0].ChainSelector(),
450454
keystone_changeset.WorkflowRegistry.String())
451455

452456
var workflowDonID uint32
@@ -461,7 +465,7 @@ func startCmd() *cobra.Command {
461465
return errors.New("no workflow DON found")
462466
}
463467

464-
deployErr := deployAndVerifyExampleWorkflow(cmdContext, homeChainOut.BlockchainOutput.Nodes[0].ExternalHTTPUrl, gatewayURL, output.DonTopology.GatewayConnectorOutput.Configurations[0].Dons[0].ID, workflowDonID, exampleWorkflowTimeout, exampleWorkflowTrigger, wfRegAddr.Hex())
468+
deployErr := deployAndVerifyExampleWorkflow(cmdContext, homeChainOut.CtfOutput().Nodes[0].ExternalHTTPUrl, gatewayURL, output.DonTopology.GatewayConnectorOutput.Configurations[0].Dons[0].ID, workflowDonID, exampleWorkflowTimeout, exampleWorkflowTrigger, wfRegAddr.Hex())
465469
if deployErr != nil {
466470
fmt.Printf("Failed to deploy and verify example workflow: %s\n", deployErr)
467471
}
@@ -692,6 +696,9 @@ func StartCLIEnvironment(
692696
in.JD.CSAEncryptionKey = hex.EncodeToString(crypto.FromECDSA(key)[:32])
693697
fmt.Printf("Generated new CSA encryption key for JD: %s\n", in.JD.CSAEncryptionKey)
694698
}
699+
700+
singleFileLogger := cldlogger.NewSingleFileLogger(nil)
701+
695702
universalSetupInput := &creenv.SetupInput{
696703
CapabilitiesAwareNodeSets: in.NodeSets,
697704
BlockchainsInput: in.Blockchains,
@@ -705,11 +712,12 @@ func StartCLIEnvironment(
705712
Capabilities: capabilities,
706713
JobSpecFactoryFunctions: extraJobSpecFunctions,
707714
StageGen: initLocalCREStageGen(in),
715+
BlockchainDeployers: blockchains_sets.NewDeployerSet(testLogger, in.Infra, infra.CribConfigsDir),
708716
}
709717

710718
ctx, cancel := context.WithTimeout(cmdContext, 10*time.Minute)
711719
defer cancel()
712-
universalSetupOutput, setupErr := creenv.SetupTestEnvironment(ctx, testLogger, cldlogger.NewSingleFileLogger(nil), universalSetupInput, relativePathToRepoRoot)
720+
universalSetupOutput, setupErr := creenv.SetupTestEnvironment(ctx, testLogger, singleFileLogger, universalSetupInput, relativePathToRepoRoot)
713721
if setupErr != nil {
714722
return nil, fmt.Errorf("failed to setup test environment: %w", setupErr)
715723
}

core/scripts/cre/environment/environment/examples.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ import (
2020
"github.com/smartcontractkit/chainlink/core/scripts/cre/environment/examples/pkg/verify"
2121
cronbasedtypes "github.com/smartcontractkit/chainlink/core/scripts/cre/environment/examples/workflows/v1/proof-of-reserve/cron-based/types"
2222
webapitriggerbasedtypes "github.com/smartcontractkit/chainlink/core/scripts/cre/environment/examples/workflows/v1/proof-of-reserve/web-trigger-based/types"
23-
creenv "github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment"
23+
"github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment"
2424
creworkflow "github.com/smartcontractkit/chainlink/system-tests/lib/cre/workflow"
2525
libformat "github.com/smartcontractkit/chainlink/system-tests/lib/format"
2626
)
@@ -116,7 +116,7 @@ func deployAndVerifyExampleWorkflow(cmdContext context.Context, rpcURL, gatewayU
116116
totalStart := time.Now()
117117
start := time.Now()
118118

119-
if pkErr := creenv.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
119+
if pkErr := environment.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
120120
return pkErr
121121
}
122122

@@ -195,7 +195,7 @@ func deployAndVerifyExampleWorkflow(cmdContext context.Context, rpcURL, gatewayU
195195
}
196196
defer pauseWorkflow()
197197

198-
if pkErr := creenv.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
198+
if pkErr := environment.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
199199
return pkErr
200200
}
201201

core/scripts/cre/environment/environment/workflow.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ import (
2020
"github.com/smartcontractkit/chainlink-testing-framework/framework/components/blockchain"
2121
"github.com/smartcontractkit/chainlink-testing-framework/seth"
2222

23-
creenv "github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment"
23+
"github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment"
2424
creconfig "github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment/config"
2525
creworkflow "github.com/smartcontractkit/chainlink/system-tests/lib/cre/workflow"
2626
)
@@ -66,7 +66,7 @@ func workflowCmds() *cobra.Command {
6666
}
6767

6868
func deleteAllWorkflows(ctx context.Context, rpcURL, workflowRegistryAddress, contractsVersion string) error {
69-
if pkErr := creenv.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
69+
if pkErr := environment.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
7070
return pkErr
7171
}
7272

@@ -438,7 +438,7 @@ func deployWorkflow(ctx context.Context, wasmWorkflowFilePathFlag, workflowNameF
438438
fmt.Printf("\n✅ Workflow copied to Docker containers\n")
439439
fmt.Printf("\n⚙️ Creating Seth client\n\n")
440440

441-
if pkErr := creenv.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
441+
if pkErr := environment.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
442442
return pkErr
443443
}
444444

core/scripts/cre/environment/examples/pkg/deploy/consumer.go

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -12,12 +12,11 @@ import (
1212

1313
"github.com/smartcontractkit/chainlink-evm/gethwrappers/keystone/generated/balance_reader"
1414
"github.com/smartcontractkit/chainlink/core/scripts/cre/environment/examples/contracts/permissionless_feeds_consumer"
15-
16-
creenv "github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment"
15+
"github.com/smartcontractkit/chainlink/system-tests/lib/cre/environment"
1716
)
1817

1918
func PermissionlessFeedsConsumer(rpcURL string) (*common.Address, error) {
20-
if pkErr := creenv.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
19+
if pkErr := environment.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
2120
return nil, pkErr
2221
}
2322

@@ -45,7 +44,7 @@ func PermissionlessFeedsConsumer(rpcURL string) (*common.Address, error) {
4544
}
4645

4746
func BalanceReader(rpcURL string) (*common.Address, error) {
48-
if pkErr := creenv.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
47+
if pkErr := environment.SetDefaultPrivateKeyIfEmpty(blockchain.DefaultAnvilPrivateKey); pkErr != nil {
4948
return nil, pkErr
5049
}
5150

core/scripts/go.mod

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -47,8 +47,8 @@ require (
4747
github.com/shopspring/decimal v1.4.0
4848
github.com/smartcontractkit/chainlink-automation v0.8.1
4949
github.com/smartcontractkit/chainlink-ccip v0.1.1-solana.0.20251009203201-900123a5c46a
50-
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251016213956-9a6afcd1532a
51-
github.com/smartcontractkit/chainlink-data-streams v0.1.5
50+
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251020150656-d5b6b6c0ab1b
51+
github.com/smartcontractkit/chainlink-data-streams v0.1.6
5252
github.com/smartcontractkit/chainlink-deployments-framework v0.56.0
5353
github.com/smartcontractkit/chainlink-evm v0.3.4-0.20251017190323-e749d4a05491
5454
github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251015115541-729ba0b2b1c1
@@ -485,13 +485,13 @@ require (
485485
github.com/smartcontractkit/chainlink-framework/chains v0.0.0-20250717121125-2350c82883e2 // indirect
486486
github.com/smartcontractkit/chainlink-framework/metrics v0.0.0-20250717121125-2350c82883e2 // indirect
487487
github.com/smartcontractkit/chainlink-framework/multinode v0.0.0-20250729142306-508e798f6a5d // indirect
488-
github.com/smartcontractkit/chainlink-protos/billing/go v0.0.0-20250807135425-a2c09896d609 // indirect
488+
github.com/smartcontractkit/chainlink-protos/billing/go v0.0.0-20251020004840-4638e4262066 // indirect
489489
github.com/smartcontractkit/chainlink-protos/linking-service/go v0.0.0-20251002192024-d2ad9222409b // indirect
490490
github.com/smartcontractkit/chainlink-protos/orchestrator v0.10.0 // indirect
491491
github.com/smartcontractkit/chainlink-protos/rmn/v1.6/go v0.0.0-20250131130834-15e0d4cde2a6 // indirect
492492
github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 // indirect
493493
github.com/smartcontractkit/chainlink-protos/svr v1.1.0 // indirect
494-
github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20251008185222-47a7460f5207 // indirect
494+
github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20251020004840-4638e4262066 // indirect
495495
github.com/smartcontractkit/chainlink-solana v1.1.2-0.20251007010318-c9a7b2d44524 // indirect
496496
github.com/smartcontractkit/chainlink-sui v0.0.0-20251012014843-5d44e7731854 // indirect
497497
github.com/smartcontractkit/chainlink-sui/deployment v0.0.0-20251012014843-5d44e7731854 // indirect

core/scripts/go.sum

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1599,14 +1599,14 @@ github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20250912190424-f
15991599
github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20250912190424-fd2e35d7deb5/go.mod h1:Ve1xD71bl193YIZQEoJMmBqLGQJdNs29bwbuObwvbhQ=
16001600
github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20250912190424-fd2e35d7deb5 h1:Z4t2ZY+ZyGWxtcXvPr11y4o3CGqhg3frJB5jXkCSvWA=
16011601
github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20250912190424-fd2e35d7deb5/go.mod h1:xtZNi6pOKdC3sLvokDvXOhgHzT+cyBqH/gWwvxTxqrg=
1602-
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251016213956-9a6afcd1532a h1:78io0EdIrI3/ZOJxHJWXGDguz5sbeoKZKlB0VTgN3O8=
1603-
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251016213956-9a6afcd1532a/go.mod h1:4InnO+pggA5q4DzsKOvAKkCp1EEi12wUs4T9YClg2+g=
1602+
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251020150656-d5b6b6c0ab1b h1:0zymdJbS/+UHOSCccdIoX7B7F3DBmk778VerPE1Lz8g=
1603+
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251020150656-d5b6b6c0ab1b/go.mod h1:zxiqKMTgvXupUYWBAMUMq+DvnfAH0ZYZB7qbxD9bs8c=
16041604
github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.6 h1:INTd6uKc/QO11B0Vx7Ze17xgW3bqYbWuQcBQa9ixicQ=
16051605
github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.6/go.mod h1:eKGyfTKzr0/PeR7qKN4l2FcW9p+HzyKUwAfGhm/5YZc=
16061606
github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20250415235644-8703639403c7 h1:9wh1G+WbXwPVqf0cfSRSgwIcaXTQgvYezylEAfwmrbw=
16071607
github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20250415235644-8703639403c7/go.mod h1:yaDOAZF6MNB+NGYpxGCUc+owIdKrjvFW0JODdTcQ3V0=
1608-
github.com/smartcontractkit/chainlink-data-streams v0.1.5 h1:hdc5yy20ylaDML3NGYp/tivm2a5Y+Ysw/e7sJK6eBTc=
1609-
github.com/smartcontractkit/chainlink-data-streams v0.1.5/go.mod h1:e9jETTzrVO8iu9Zp5gDuTCmBVhSJwUOk6K4Q/VFrJ6o=
1608+
github.com/smartcontractkit/chainlink-data-streams v0.1.6 h1:B3cwmJrVYoJVAjPOyQWTNaGD+V30HI1vFHhC2dQpWDo=
1609+
github.com/smartcontractkit/chainlink-data-streams v0.1.6/go.mod h1:e9jETTzrVO8iu9Zp5gDuTCmBVhSJwUOk6K4Q/VFrJ6o=
16101610
github.com/smartcontractkit/chainlink-deployments-framework v0.56.0 h1:VkzslEC/a7Ze5qqLdX1ZNL7ug0TwVd5w3hL5jA/DvWE=
16111611
github.com/smartcontractkit/chainlink-deployments-framework v0.56.0/go.mod h1:ObH5HJ4yXzTmQLc6Af+ufrTVcQ+ocasHJ0YBZjw5ZCM=
16121612
github.com/smartcontractkit/chainlink-evm v0.3.4-0.20251017190323-e749d4a05491 h1:X+c+LdCI9Dc4EfpitByVnGODtwoV+rAdFKCG0y4gAag=
@@ -1623,8 +1623,8 @@ github.com/smartcontractkit/chainlink-framework/metrics v0.0.0-20250717121125-23
16231623
github.com/smartcontractkit/chainlink-framework/metrics v0.0.0-20250717121125-2350c82883e2/go.mod h1:jo+cUqNcHwN8IF7SInQNXDZ8qzBsyMpnLdYbDswviFc=
16241624
github.com/smartcontractkit/chainlink-framework/multinode v0.0.0-20250729142306-508e798f6a5d h1:pTYIcsWHTMG5fAcbRUA8Qk5yscXKdSpopQ0DUEOjPik=
16251625
github.com/smartcontractkit/chainlink-framework/multinode v0.0.0-20250729142306-508e798f6a5d/go.mod h1:2JTBNp3FlRdO/nHc4dsc9bfxxMClMO1Qt8sLJgtreBY=
1626-
github.com/smartcontractkit/chainlink-protos/billing/go v0.0.0-20250807135425-a2c09896d609 h1:7U8t4Ytj2rRnkkdAp4eFUTU34lXCCT7WYuKQWaJZfw0=
1627-
github.com/smartcontractkit/chainlink-protos/billing/go v0.0.0-20250807135425-a2c09896d609/go.mod h1:HHGeDUpAsPa0pmOx7wrByCitjQ0mbUxf0R9v+g67uCA=
1626+
github.com/smartcontractkit/chainlink-protos/billing/go v0.0.0-20251020004840-4638e4262066 h1:D7fFxHtPZNKKh1eWcTqpasb/aBGxnQ2REssEP49l1lg=
1627+
github.com/smartcontractkit/chainlink-protos/billing/go v0.0.0-20251020004840-4638e4262066/go.mod h1:HHGeDUpAsPa0pmOx7wrByCitjQ0mbUxf0R9v+g67uCA=
16281628
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20251008161434-22d9bd439bba h1:M+tG22TF6jpfeGifM4UpjUzbfD2JDD3ixIX9MdZ0qH8=
16291629
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20251008161434-22d9bd439bba/go.mod h1:jUC52kZzEnWF9tddHh85zolKybmLpbQ1oNA4FjOHt1Q=
16301630
github.com/smartcontractkit/chainlink-protos/job-distributor v0.13.1 h1:PWwLGimBt37eDzpbfZ9V/ZkW4oCjcwKjKiAwKlSfPc0=
@@ -1639,8 +1639,8 @@ github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0 h1:B7itmjy+C
16391639
github.com/smartcontractkit/chainlink-protos/storage-service v0.3.0/go.mod h1:h6kqaGajbNRrezm56zhx03p0mVmmA2xxj7E/M4ytLUA=
16401640
github.com/smartcontractkit/chainlink-protos/svr v1.1.0 h1:79Z9N9dMbMVRGaLoDPAQ+vOwbM+Hnx8tIN2xCPG8H4o=
16411641
github.com/smartcontractkit/chainlink-protos/svr v1.1.0/go.mod h1:TcOliTQU6r59DwG4lo3U+mFM9WWyBHGuFkkxQpvSujo=
1642-
github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20251008185222-47a7460f5207 h1:bZ+3mm/yy2wd9ydtDRnO6Opy4QAhNZVIw/SujQb1wpU=
1643-
github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20251008185222-47a7460f5207/go.mod h1:HIpGvF6nKCdtZ30xhdkKWGM9+4Z4CVqJH8ZBL1FTEiY=
1642+
github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20251020004840-4638e4262066 h1:Lrc0+uegqasIFgsGXHy4tzdENT+zH2AbkTV4F7e3otU=
1643+
github.com/smartcontractkit/chainlink-protos/workflows/go v0.0.0-20251020004840-4638e4262066/go.mod h1:HIpGvF6nKCdtZ30xhdkKWGM9+4Z4CVqJH8ZBL1FTEiY=
16441644
github.com/smartcontractkit/chainlink-solana v1.1.2-0.20251007010318-c9a7b2d44524 h1:QgjF+S64bGDyaNcz11zDg7GC7FwNmYrsHN6jiJPRVkk=
16451645
github.com/smartcontractkit/chainlink-solana v1.1.2-0.20251007010318-c9a7b2d44524/go.mod h1:vcms/UPnfg7LZ2txinn59yJR6rXZ31XOk5++03LOeys=
16461646
github.com/smartcontractkit/chainlink-sui v0.0.0-20251012014843-5d44e7731854 h1:7KMcSEptDirqBY/jzNhxFvWmDE2s5KQE6uMPQ1inad4=

core/services/llo/delegate.go

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@ import (
55
"errors"
66
"fmt"
77
"strconv"
8-
"time"
98

109
"github.com/prometheus/client_golang/prometheus"
1110
ocrcommontypes "github.com/smartcontractkit/libocr/commontypes"
@@ -121,20 +120,15 @@ func NewDelegate(cfg DelegateConfig) (job.ServiceCtx, error) {
121120
CaptureReportTelemetry: cfg.CaptureReportTelemetry,
122121
})
123122

124-
cache := observation.NewCache(500*time.Millisecond, time.Minute)
125123
ds := observation.NewDataSource(
126124
logger.Named(lggr, "DataSource"),
127125
cfg.Registry,
128126
t,
129-
cache,
130127
)
131128

132129
notifier, ok := cfg.ContractTransmitter.(TransmitNotifier)
133130
if ok {
134131
notifier.OnTransmit(t.TrackSeqNr)
135-
notifier.OnTransmit(func(digest ocr2types.ConfigDigest, seqNr uint64) {
136-
cache.SetLastTransmissionSeqNr(seqNr)
137-
})
138132
}
139133

140134
return &delegate{services.StateMachine{}, cfg, reportCodecs, cfg.ShouldRetireCache, ds, t, []Closer{}}, nil
@@ -223,6 +217,9 @@ func (d *delegate) Close() error {
223217
for _, oracle := range d.oracles {
224218
merr = errors.Join(merr, oracle.Close())
225219
}
220+
if closer, ok := d.ds.(Closer); ok {
221+
merr = errors.Join(merr, closer.Close())
222+
}
226223
merr = errors.Join(merr, d.telem.Close())
227224
return merr
228225
})

0 commit comments

Comments
 (0)