From 8290f29be51dbe190e3a737d5cef494ee07d64c4 Mon Sep 17 00:00:00 2001 From: Jordan Krage Date: Mon, 26 Jan 2026 17:26:29 -0600 Subject: [PATCH] core/services: resolve CRE org ID for limits --- core/scripts/go.mod | 2 +- core/scripts/go.sum | 4 ++-- core/services/chainlink/application.go | 1 + .../capabilities/v2/http_trigger_handler.go | 2 ++ core/services/ocr2/plugins/vault/plugin.go | 1 + core/services/workflows/engine.go | 4 ++-- core/services/workflows/syncer/v2/handler.go | 6 ++++- core/services/workflows/v2/config.go | 7 +++--- core/services/workflows/v2/engine.go | 22 +++++++++---------- core/services/workflows/v2/engine_test.go | 1 + core/services/workflows/v2/secrets.go | 6 ++++- core/services/workflows/v2/secrets_test.go | 7 ++++++ deployment/go.mod | 2 +- deployment/go.sum | 4 ++-- go.mod | 2 +- go.sum | 4 ++-- integration-tests/go.mod | 2 +- integration-tests/go.sum | 4 ++-- integration-tests/load/go.mod | 2 +- integration-tests/load/go.sum | 4 ++-- system-tests/lib/go.mod | 2 +- system-tests/lib/go.sum | 4 ++-- system-tests/tests/go.mod | 2 +- system-tests/tests/go.sum | 4 ++-- 24 files changed, 59 insertions(+), 40 deletions(-) diff --git a/core/scripts/go.mod b/core/scripts/go.mod index d25c5809656..38abdb3ee6a 100644 --- a/core/scripts/go.mod +++ b/core/scripts/go.mod @@ -48,7 +48,7 @@ require ( github.com/shopspring/decimal v1.4.0 github.com/smartcontractkit/chainlink-automation v0.8.1 github.com/smartcontractkit/chainlink-ccip v0.1.1-solana.0.20260127052127-9e53e86176d3 - github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a + github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d github.com/smartcontractkit/chainlink-data-streams v0.1.11 github.com/smartcontractkit/chainlink-deployments-framework v0.75.0 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260127143834-21d7db9955ee diff --git a/core/scripts/go.sum b/core/scripts/go.sum index db70f61a6f1..bf169017960 100644 --- a/core/scripts/go.sum +++ b/core/scripts/go.sum @@ -1629,8 +1629,8 @@ github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e9 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e93cab86b5/go.mod h1:kDMTKjZB4pnhQVAdwVMzA0THXAxjaON58JSO+CYLYBg= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a h1:5FxRKkjXvQvPlKx60ELXgOsn7NQIkBj/Au1Z6jpMfjM= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a/go.mod h1:Xe0SH5IHtGkCW6sy/EdBRPKD5L+U52HgoGfl0KDP/lw= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a h1:802owE4JWLyTMEJOMPyX9vD/ikw35w9Lga9to+9y1rY= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a/go.mod h1:Eg5rz/fQINjR9H0TxHw7j+zGZeYxprUpEQZzC5JGHG4= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d h1:vHPgWL6HzM0cY8Qf1nue0t0P8OvCB6Pkp3h9lMtBsSo= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d/go.mod h1:zBuRC7el/pQQB95t7JnLOvCfZ3lmi5jjXYRUY2XUD+g= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20251211140724-319861e514c4 h1:NOUsjsMzNecbjiPWUQGlRSRAutEvCFrqqyETDJeh5q4= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20251211140724-319861e514c4/go.mod h1:Zpvul9sTcZNAZOVzt5vBl1XZGNvQebFpnpn3/KOQvOQ= github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20251215152504-b1e41f508340 h1:PsjEI+5jZIz9AS4eOsLS5VpSWJINf38clXV3wryPyMk= diff --git a/core/services/chainlink/application.go b/core/services/chainlink/application.go index 769bf024a4f..d3c6baa227f 100644 --- a/core/services/chainlink/application.go +++ b/core/services/chainlink/application.go @@ -1040,6 +1040,7 @@ func newCREServices( if err != nil { return nil, fmt.Errorf("failed to create org resolver: %w", err) } + orgResolver = orgresolver.NewCache(orgResolver) srvcs = append(srvcs, orgResolver) } else { globalLogger.Warn("OrgResolver not created - no linking service URL configured") diff --git a/core/services/gateway/handlers/capabilities/v2/http_trigger_handler.go b/core/services/gateway/handlers/capabilities/v2/http_trigger_handler.go index 3bc88ffddba..1e34e354b8f 100644 --- a/core/services/gateway/handlers/capabilities/v2/http_trigger_handler.go +++ b/core/services/gateway/handlers/capabilities/v2/http_trigger_handler.go @@ -359,6 +359,8 @@ func (h *httpTriggerHandler) checkRateLimit(ctx context.Context, workflowID, req h.handleUserError(ctx, requestID, jsonrpc.ErrInvalidRequest, "workflow reference not found", callback) return errors.New("workflow reference not found") } + + // TODO orgID https://smartcontract-it.atlassian.net/browse/CRE-1707 ctx = contexts.WithCRE(ctx, contexts.CRE{Owner: workflowRef.workflowOwner, Workflow: workflowID}) if err := h.userRateLimiter.AllowErr(ctx); err != nil { lggr := logger.With(h.lggr, platform.KeyWorkflowID, workflowID, platform.KeyWorkflowOwner, workflowRef.workflowOwner, "requestID", requestID, "err", err) diff --git a/core/services/ocr2/plugins/vault/plugin.go b/core/services/ocr2/plugins/vault/plugin.go index 26f5d2ed550..312fee3ffbe 100644 --- a/core/services/ocr2/plugins/vault/plugin.go +++ b/core/services/ocr2/plugins/vault/plugin.go @@ -1626,6 +1626,7 @@ func (r *ReportingPlugin) stateTransitionCreateSecretsRequest(ctx context.Contex return nil, fmt.Errorf("failed to read secret identifiers count for owner: %w", err) } + // TODO orgID https://smartcontract-it.atlassian.net/browse/CRE-1707 ctx = contexts.WithCRE(ctx, contexts.CRE{Owner: req.Id.Owner}) if ierr := r.cfg.MaxSecretsPerOwner.Check(ctx, count+1); ierr != nil { var errBoundLimited limits.ErrorBoundLimited[int] diff --git a/core/services/workflows/engine.go b/core/services/workflows/engine.go index bb595ca8746..0d524875a1c 100644 --- a/core/services/workflows/engine.go +++ b/core/services/workflows/engine.go @@ -150,7 +150,7 @@ type Engine struct { } func (e *Engine) Start(ctx context.Context) error { - ctx = contexts.WithCRE(ctx, contexts.CRE{Owner: e.workflow.owner, Workflow: e.workflow.id}) // TODO org from cache + ctx = contexts.WithCRE(ctx, contexts.CRE{Owner: e.workflow.owner, Workflow: e.workflow.id}) return e.StartOnce("Engine", func() error { // validate if adding another workflow would exceed either the global or per owner engine count limit if err := e.workflowLimits.Use(ctx, 1); err != nil { @@ -1217,7 +1217,7 @@ func (e *Engine) heartbeat(ctx context.Context) { func (e *Engine) Close() error { return e.StopOnce("Engine", func() error { e.logger.Info("shutting down engine") - ctx := contexts.WithCRE(context.Background(), contexts.CRE{Owner: e.workflow.owner, Workflow: e.workflow.id}) // TODO org from cache + ctx := contexts.WithCRE(context.Background(), contexts.CRE{Owner: e.workflow.owner, Workflow: e.workflow.id}) // To shut down the engine, we'll start by deregistering // any triggers to ensure no new executions are triggered, // then we'll close down any background goroutines, diff --git a/core/services/workflows/syncer/v2/handler.go b/core/services/workflows/syncer/v2/handler.go index 3976767be19..2ab6f0e9b70 100644 --- a/core/services/workflows/syncer/v2/handler.go +++ b/core/services/workflows/syncer/v2/handler.go @@ -417,7 +417,11 @@ func (h *eventHandler) createWorkflowSpec(ctx context.Context, payload WorkflowR wfID := payload.WorkflowID.Hex() owner := hex.EncodeToString(payload.WorkflowOwner) - ctx = contexts.WithCRE(ctx, contexts.CRE{Owner: owner, Workflow: wfID}) + orgID, err := h.orgResolver.Get(ctx, owner) + if err != nil { + h.lggr.Warnw("Failed to resolve organization ID, continuing without it", "workflowOwner", owner, "err", err) + } + ctx = contexts.WithCRE(ctx, contexts.CRE{Org: orgID, Owner: owner, Workflow: wfID}) // With Workflow Registry contract v2 the BinaryURL and ConfigURL are expected to be identifiers that put through the Storage Service. decodedBinary, config, err := h.workflowArtifactsStore.FetchWorkflowArtifacts(ctx, wfID, payload.BinaryURL, payload.ConfigURL) diff --git a/core/services/workflows/v2/config.go b/core/services/workflows/v2/config.go index c4b7c68f2c1..bd8fd25005c 100644 --- a/core/services/workflows/v2/config.go +++ b/core/services/workflows/v2/config.go @@ -9,18 +9,17 @@ import ( commoncap "github.com/smartcontractkit/chainlink-common/pkg/capabilities" "github.com/smartcontractkit/chainlink-common/pkg/config" "github.com/smartcontractkit/chainlink-common/pkg/custmsg" + "github.com/smartcontractkit/chainlink-common/pkg/logger" + "github.com/smartcontractkit/chainlink-common/pkg/services/orgresolver" "github.com/smartcontractkit/chainlink-common/pkg/settings/cresettings" "github.com/smartcontractkit/chainlink-common/pkg/settings/limits" "github.com/smartcontractkit/chainlink-common/pkg/types/core" "github.com/smartcontractkit/chainlink-common/pkg/workflows/dontime" "github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/host" sdkpb "github.com/smartcontractkit/chainlink-protos/cre/go/sdk" - "github.com/smartcontractkit/chainlink/v2/core/services" - "github.com/smartcontractkit/chainlink-common/pkg/logger" - - "github.com/smartcontractkit/chainlink-common/pkg/services/orgresolver" "github.com/smartcontractkit/chainlink/v2/core/capabilities" + "github.com/smartcontractkit/chainlink/v2/core/services" "github.com/smartcontractkit/chainlink/v2/core/services/keystore/keys/workflowkey" "github.com/smartcontractkit/chainlink/v2/core/services/workflows/metering" "github.com/smartcontractkit/chainlink/v2/core/services/workflows/store" diff --git a/core/services/workflows/v2/engine.go b/core/services/workflows/v2/engine.go index 5f22ca59a19..58c29779b5a 100644 --- a/core/services/workflows/v2/engine.go +++ b/core/services/workflows/v2/engine.go @@ -353,7 +353,7 @@ func (e *Engine) runTriggerSubscriptionPhase(ctx context.Context) error { Request: &sdkpb.ExecuteRequest_Subscribe{}, MaxResponseSize: uint64(moduleExecuteMaxResponseSizeBytes), //nolint:gosec // G115 Config: e.cfg.WorkflowConfig, - }, NewDisallowedExecutionHelper(e.logger(), userLogChan, timeProvider, e.secretsFetcher(e.cfg.WorkflowID))) + }, NewDisallowedExecutionHelper(e.logger(), userLogChan, timeProvider, e.secretsFetcher(contexts.CREValue(ctx).Org, e.cfg.WorkflowID))) if err != nil { return fmt.Errorf("failed to execute subscribe: %w", err) } @@ -578,23 +578,20 @@ func (e *Engine) startExecution(ctx context.Context, wrappedTriggerEvent enqueue } // Fetch organization ID for this execution - organizationID := contexts.CREValue(ctx).Org + creCtx := contexts.CREValue(ctx) if e.cfg.OrgResolver != nil { orgID, gerr := e.cfg.OrgResolver.Get(ctx, e.cfg.WorkflowOwner) if gerr != nil { e.logger().Warnw("Failed to resolve organization ID, continuing without it", "workflowOwner", e.cfg.WorkflowOwner, "err", gerr) } else { - organizationID = orgID - - creCtx := contexts.CREValue(ctx) - creCtx.Org = organizationID + creCtx.Org = orgID ctx = contexts.WithCRE(ctx, creCtx) } } loggerLabels := maps.Clone(*e.loggerLabels.Load()) - loggerLabels[platform.KeyOrganizationID] = organizationID + loggerLabels[platform.KeyOrganizationID] = creCtx.Org e.loggerLabels.Store(&loggerLabels) - lggr := e.logger().With(platform.KeyOrganizationID, organizationID) + lggr := e.logger().With(platform.KeyOrganizationID, creCtx.Org) e.metrics.UpdateTotalWorkflowsGauge(ctx, executingWorkflows.Add(1)) defer e.metrics.UpdateTotalWorkflowsGauge(ctx, executingWorkflows.Add(-1)) @@ -664,7 +661,7 @@ func (e *Engine) startExecution(ctx context.Context, wrappedTriggerEvent enqueue } execHelper := &ExecutionHelper{ Engine: e, WorkflowExecutionID: executionID, UserLogChan: userLogChan, - TimeProvider: timeProvider, SecretsFetcher: e.secretsFetcher(executionID), + TimeProvider: timeProvider, SecretsFetcher: e.secretsFetcher(creCtx.Org, executionID), } execHelper.initLimiters(e.cfg.LocalLimiters) result, execErr := e.cfg.Module.Execute(execCtx, &sdkpb.ExecuteRequest{ @@ -742,7 +739,7 @@ func (e *Engine) startExecution(ctx context.Context, wrappedTriggerEvent enqueue e.cfg.Hooks.OnExecutionFinished(executionID, executionStatus) } -func (e *Engine) secretsFetcher(phaseID string) SecretsFetcher { +func (e *Engine) secretsFetcher(orgID string, phaseID string) SecretsFetcher { if e.cfg.SecretsFetcher != nil { return e.cfg.SecretsFetcher } @@ -753,6 +750,7 @@ func (e *Engine) secretsFetcher(phaseID string) SecretsFetcher { e.logger(), e.cfg.LocalLimiters.SecretsConcurrency, e.cfg.LocalLimiters.SecretsCalls, + orgID, e.cfg.WorkflowOwner, e.cfg.WorkflowName.String(), e.cfg.WorkflowID, @@ -766,7 +764,9 @@ func (e *Engine) secretsFetcher(phaseID string) SecretsFetcher { func (e *Engine) close() error { ctx, cancel := context.WithTimeout(context.Background(), time.Millisecond*time.Duration(e.cfg.LocalLimits.ShutdownTimeoutMs)) defer cancel() - ctx = contexts.WithCRE(ctx, contexts.CRE{Owner: e.cfg.WorkflowOwner, Workflow: e.cfg.WorkflowID}) // TODO org? + + // Note: we don't bother with org ID here since it has no effect when only calling [limits.ResourceLimiter.Free] + ctx = contexts.WithCRE(ctx, contexts.CRE{Owner: e.cfg.WorkflowOwner, Workflow: e.cfg.WorkflowID}) e.triggersRegMu.Lock() e.unregisterAllTriggers(ctx) e.triggersRegMu.Unlock() diff --git a/core/services/workflows/v2/engine_test.go b/core/services/workflows/v2/engine_test.go index 594f9c229c7..c84432d832f 100644 --- a/core/services/workflows/v2/engine_test.go +++ b/core/services/workflows/v2/engine_test.go @@ -1538,6 +1538,7 @@ func TestSecretsFetcher_Integration(t *testing.T) { cfg.Lggr, cfg.LocalLimiters.SecretsConcurrency, cfg.LocalLimiters.SecretsCalls, + "workflowOrg", cfg.WorkflowOwner, cfg.WorkflowName.String(), cfg.WorkflowID, diff --git a/core/services/workflows/v2/secrets.go b/core/services/workflows/v2/secrets.go index 531def77751..acd967b32e7 100644 --- a/core/services/workflows/v2/secrets.go +++ b/core/services/workflows/v2/secrets.go @@ -42,6 +42,7 @@ type secretsFetcher struct { secretsCalled int mu sync.Mutex + workflowOrg string workflowOwner string workflowName string workflowID string @@ -57,6 +58,7 @@ func NewSecretsFetcher( lggr logger.Logger, semaphore limits.ResourcePoolLimiter[int], secretsCalls limits.BoundLimiter[int], + workflowOrg string, workflowOwner string, workflowName string, workflowID string, @@ -70,6 +72,7 @@ func NewSecretsFetcher( lggr: lggr, semaphore: semaphore, secretsCallsLimit: secretsCalls, + workflowOrg: workflowOrg, workflowOwner: workflowOwner, workflowName: workflowName, phaseID: phaseID, @@ -84,8 +87,9 @@ func keyFor(owner, namespace, id string) string { func (s *secretsFetcher) GetSecrets(ctx context.Context, request *sdkpb.GetSecretsRequest) ([]*sdkpb.SecretResponse, error) { ctx = contexts.WithCRE(ctx, contexts.CRE{ + Org: s.workflowOrg, Owner: s.workflowOwner, - Workflow: s.workflowName, + Workflow: s.workflowID, }) s.mu.Lock() secretsCalled := s.secretsCalled + 1 diff --git a/core/services/workflows/v2/secrets_test.go b/core/services/workflows/v2/secrets_test.go index ba1b89e25c9..224865dfaed 100644 --- a/core/services/workflows/v2/secrets_test.go +++ b/core/services/workflows/v2/secrets_test.go @@ -174,6 +174,7 @@ func TestSecretsFetcher_BulkFetchesSecretsFromCapability(t *testing.T) { limits.WorkflowResourcePoolLimiter[int](5), limits.NewBoundLimiter[int](5), owner, + "workflowOrg", "workflowName", "workflowID", "workflowExecID", @@ -233,6 +234,7 @@ func TestSecretsFetcher_ReturnsErrorIfCapabilityNoFound(t *testing.T) { limits.WorkflowResourcePoolLimiter[int](5), limits.NewBoundLimiter[int](5), owner, + "workflowOrg", "workflowName", "workflowID", "workflowExecID", @@ -278,6 +280,7 @@ func TestSecretsFetcher_ReturnsErrorIfCapabilityErrors(t *testing.T) { limits.WorkflowResourcePoolLimiter[int](5), limits.NewBoundLimiter[int](5), owner, + "workflowOrg", "workflowName", "workflowID", "workflowExecID", @@ -327,6 +330,7 @@ func TestSecretsFetcher_ReturnsErrorIfNoResponseForRequest(t *testing.T) { limits.WorkflowResourcePoolLimiter[int](5), limits.NewBoundLimiter[int](5), owner, + "workflowOrg", "workflowName", "workflowID", "workflowExecID", @@ -399,6 +403,7 @@ func TestSecretsFetcher_ReturnsErrorIfMissingEncryptionSharesForNode(t *testing. limits.WorkflowResourcePoolLimiter[int](5), limits.NewBoundLimiter[int](5), owner, + "workflowOrg", "workflowName", "workflowID", "workflowExecID", @@ -499,6 +504,7 @@ func TestSecretsFetcher_ReturnsErrorIfCantCombineShares(t *testing.T) { limits.WorkflowResourcePoolLimiter[int](5), limits.NewBoundLimiter[int](5), owner, + "workflowOrg", "workflowName", "workflowID", "workflowExecID", @@ -664,6 +670,7 @@ func TestSecretsFetcher_EnforcesSecretsCallsLimit(t *testing.T) { lggr, semaphore, secretsCallsLimit, + "workflowOrg", "0x1111111111111111111111111111111111111111", "wf", "wfID", diff --git a/deployment/go.mod b/deployment/go.mod index 37598e59dff..1dad39e814b 100644 --- a/deployment/go.mod +++ b/deployment/go.mod @@ -43,7 +43,7 @@ require ( github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260119161343-499241536dea github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20250912190424-fd2e35d7deb5 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e93cab86b5 - github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a + github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d github.com/smartcontractkit/chainlink-deployments-framework v0.75.0 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260127143834-21d7db9955ee github.com/smartcontractkit/chainlink-evm/contracts/cre/gobindings v0.0.0-20260107191744-4b93f62cffe3 diff --git a/deployment/go.sum b/deployment/go.sum index f43aac5772a..4707fc03743 100644 --- a/deployment/go.sum +++ b/deployment/go.sum @@ -1366,8 +1366,8 @@ github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e9 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e93cab86b5/go.mod h1:kDMTKjZB4pnhQVAdwVMzA0THXAxjaON58JSO+CYLYBg= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a h1:5FxRKkjXvQvPlKx60ELXgOsn7NQIkBj/Au1Z6jpMfjM= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a/go.mod h1:Xe0SH5IHtGkCW6sy/EdBRPKD5L+U52HgoGfl0KDP/lw= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a h1:802owE4JWLyTMEJOMPyX9vD/ikw35w9Lga9to+9y1rY= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a/go.mod h1:Eg5rz/fQINjR9H0TxHw7j+zGZeYxprUpEQZzC5JGHG4= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d h1:vHPgWL6HzM0cY8Qf1nue0t0P8OvCB6Pkp3h9lMtBsSo= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d/go.mod h1:zBuRC7el/pQQB95t7JnLOvCfZ3lmi5jjXYRUY2XUD+g= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10 h1:FJAFgXS9oqASnkS03RE1HQwYQQxrO4l46O5JSzxqLgg= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10/go.mod h1:oiDa54M0FwxevWwyAX773lwdWvFYYlYHHQV1LQ5HpWY= github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20251215152504-b1e41f508340 h1:PsjEI+5jZIz9AS4eOsLS5VpSWJINf38clXV3wryPyMk= diff --git a/go.mod b/go.mod index 0bfa8c75ebd..dc1d13d1d28 100644 --- a/go.mod +++ b/go.mod @@ -88,7 +88,7 @@ require ( github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260119161343-499241536dea github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20250912190424-fd2e35d7deb5 github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a - github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a + github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10 github.com/smartcontractkit/chainlink-data-streams v0.1.11 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260127143834-21d7db9955ee diff --git a/go.sum b/go.sum index 2d789637a23..6fc0fb4f511 100644 --- a/go.sum +++ b/go.sum @@ -1180,8 +1180,8 @@ github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20250 github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20250912190424-fd2e35d7deb5/go.mod h1:xtZNi6pOKdC3sLvokDvXOhgHzT+cyBqH/gWwvxTxqrg= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a h1:5FxRKkjXvQvPlKx60ELXgOsn7NQIkBj/Au1Z6jpMfjM= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a/go.mod h1:Xe0SH5IHtGkCW6sy/EdBRPKD5L+U52HgoGfl0KDP/lw= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a h1:802owE4JWLyTMEJOMPyX9vD/ikw35w9Lga9to+9y1rY= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a/go.mod h1:Eg5rz/fQINjR9H0TxHw7j+zGZeYxprUpEQZzC5JGHG4= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d h1:vHPgWL6HzM0cY8Qf1nue0t0P8OvCB6Pkp3h9lMtBsSo= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d/go.mod h1:zBuRC7el/pQQB95t7JnLOvCfZ3lmi5jjXYRUY2XUD+g= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10 h1:FJAFgXS9oqASnkS03RE1HQwYQQxrO4l46O5JSzxqLgg= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10/go.mod h1:oiDa54M0FwxevWwyAX773lwdWvFYYlYHHQV1LQ5HpWY= github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20251215152504-b1e41f508340 h1:PsjEI+5jZIz9AS4eOsLS5VpSWJINf38clXV3wryPyMk= diff --git a/integration-tests/go.mod b/integration-tests/go.mod index 724ef8c412a..d81bfa6e84b 100644 --- a/integration-tests/go.mod +++ b/integration-tests/go.mod @@ -51,7 +51,7 @@ require ( github.com/smartcontractkit/chainlink-ccip v0.1.1-solana.0.20260127052127-9e53e86176d3 github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260119161343-499241536dea github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20250912190424-fd2e35d7deb5 - github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a + github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d github.com/smartcontractkit/chainlink-deployments-framework v0.75.0 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260127143834-21d7db9955ee github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251222115927-36a18321243c diff --git a/integration-tests/go.sum b/integration-tests/go.sum index 883040a117c..9138b6d778d 100644 --- a/integration-tests/go.sum +++ b/integration-tests/go.sum @@ -1610,8 +1610,8 @@ github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e9 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e93cab86b5/go.mod h1:kDMTKjZB4pnhQVAdwVMzA0THXAxjaON58JSO+CYLYBg= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a h1:5FxRKkjXvQvPlKx60ELXgOsn7NQIkBj/Au1Z6jpMfjM= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a/go.mod h1:Xe0SH5IHtGkCW6sy/EdBRPKD5L+U52HgoGfl0KDP/lw= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a h1:802owE4JWLyTMEJOMPyX9vD/ikw35w9Lga9to+9y1rY= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a/go.mod h1:Eg5rz/fQINjR9H0TxHw7j+zGZeYxprUpEQZzC5JGHG4= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d h1:vHPgWL6HzM0cY8Qf1nue0t0P8OvCB6Pkp3h9lMtBsSo= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d/go.mod h1:zBuRC7el/pQQB95t7JnLOvCfZ3lmi5jjXYRUY2XUD+g= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10 h1:FJAFgXS9oqASnkS03RE1HQwYQQxrO4l46O5JSzxqLgg= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10/go.mod h1:oiDa54M0FwxevWwyAX773lwdWvFYYlYHHQV1LQ5HpWY= github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20251215152504-b1e41f508340 h1:PsjEI+5jZIz9AS4eOsLS5VpSWJINf38clXV3wryPyMk= diff --git a/integration-tests/load/go.mod b/integration-tests/load/go.mod index e229fcbf77a..304432846b7 100644 --- a/integration-tests/load/go.mod +++ b/integration-tests/load/go.mod @@ -32,7 +32,7 @@ require ( github.com/smartcontractkit/chainlink-ccip v0.1.1-solana.0.20260127052127-9e53e86176d3 github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260119161343-499241536dea github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20250912190424-fd2e35d7deb5 - github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a + github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d github.com/smartcontractkit/chainlink-deployments-framework v0.75.0 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260127143834-21d7db9955ee github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251222115927-36a18321243c diff --git a/integration-tests/load/go.sum b/integration-tests/load/go.sum index 6aa3c3906fd..0ea721b7681 100644 --- a/integration-tests/load/go.sum +++ b/integration-tests/load/go.sum @@ -1588,8 +1588,8 @@ github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e9 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e93cab86b5/go.mod h1:kDMTKjZB4pnhQVAdwVMzA0THXAxjaON58JSO+CYLYBg= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a h1:5FxRKkjXvQvPlKx60ELXgOsn7NQIkBj/Au1Z6jpMfjM= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a/go.mod h1:Xe0SH5IHtGkCW6sy/EdBRPKD5L+U52HgoGfl0KDP/lw= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a h1:802owE4JWLyTMEJOMPyX9vD/ikw35w9Lga9to+9y1rY= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a/go.mod h1:Eg5rz/fQINjR9H0TxHw7j+zGZeYxprUpEQZzC5JGHG4= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d h1:vHPgWL6HzM0cY8Qf1nue0t0P8OvCB6Pkp3h9lMtBsSo= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d/go.mod h1:zBuRC7el/pQQB95t7JnLOvCfZ3lmi5jjXYRUY2XUD+g= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10 h1:FJAFgXS9oqASnkS03RE1HQwYQQxrO4l46O5JSzxqLgg= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10/go.mod h1:oiDa54M0FwxevWwyAX773lwdWvFYYlYHHQV1LQ5HpWY= github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20251215152504-b1e41f508340 h1:PsjEI+5jZIz9AS4eOsLS5VpSWJINf38clXV3wryPyMk= diff --git a/system-tests/lib/go.mod b/system-tests/lib/go.mod index 8ab6af9bf10..60ada1de1ef 100644 --- a/system-tests/lib/go.mod +++ b/system-tests/lib/go.mod @@ -32,7 +32,7 @@ require ( github.com/sethvargo/go-retry v0.3.0 github.com/smartcontractkit/chain-selectors v1.0.90 github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260119161343-499241536dea - github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a + github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d github.com/smartcontractkit/chainlink-deployments-framework v0.75.0 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260127143834-21d7db9955ee github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251222115927-36a18321243c diff --git a/system-tests/lib/go.sum b/system-tests/lib/go.sum index 672db5d5739..c8b061ddbed 100644 --- a/system-tests/lib/go.sum +++ b/system-tests/lib/go.sum @@ -1595,8 +1595,8 @@ github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e9 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e93cab86b5/go.mod h1:kDMTKjZB4pnhQVAdwVMzA0THXAxjaON58JSO+CYLYBg= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a h1:5FxRKkjXvQvPlKx60ELXgOsn7NQIkBj/Au1Z6jpMfjM= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a/go.mod h1:Xe0SH5IHtGkCW6sy/EdBRPKD5L+U52HgoGfl0KDP/lw= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a h1:802owE4JWLyTMEJOMPyX9vD/ikw35w9Lga9to+9y1rY= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a/go.mod h1:Eg5rz/fQINjR9H0TxHw7j+zGZeYxprUpEQZzC5JGHG4= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d h1:vHPgWL6HzM0cY8Qf1nue0t0P8OvCB6Pkp3h9lMtBsSo= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d/go.mod h1:zBuRC7el/pQQB95t7JnLOvCfZ3lmi5jjXYRUY2XUD+g= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20251211140724-319861e514c4 h1:NOUsjsMzNecbjiPWUQGlRSRAutEvCFrqqyETDJeh5q4= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20251211140724-319861e514c4/go.mod h1:Zpvul9sTcZNAZOVzt5vBl1XZGNvQebFpnpn3/KOQvOQ= github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20251215152504-b1e41f508340 h1:PsjEI+5jZIz9AS4eOsLS5VpSWJINf38clXV3wryPyMk= diff --git a/system-tests/tests/go.mod b/system-tests/tests/go.mod index a0a6d80a13c..42b3c1b1c39 100644 --- a/system-tests/tests/go.mod +++ b/system-tests/tests/go.mod @@ -52,7 +52,7 @@ require ( github.com/rs/zerolog v1.34.0 github.com/shopspring/decimal v1.4.0 github.com/smartcontractkit/chain-selectors v1.0.90 - github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a + github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d github.com/smartcontractkit/chainlink-data-streams v0.1.11 github.com/smartcontractkit/chainlink-deployments-framework v0.75.0 github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251222115927-36a18321243c diff --git a/system-tests/tests/go.sum b/system-tests/tests/go.sum index 155b4b31be8..17ff30ae6ef 100644 --- a/system-tests/tests/go.sum +++ b/system-tests/tests/go.sum @@ -1792,8 +1792,8 @@ github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e9 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251222203705-84e93cab86b5/go.mod h1:kDMTKjZB4pnhQVAdwVMzA0THXAxjaON58JSO+CYLYBg= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a h1:5FxRKkjXvQvPlKx60ELXgOsn7NQIkBj/Au1Z6jpMfjM= github.com/smartcontractkit/chainlink-ccv v0.0.0-20260122132406-0ada7a3fe04a/go.mod h1:Xe0SH5IHtGkCW6sy/EdBRPKD5L+U52HgoGfl0KDP/lw= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a h1:802owE4JWLyTMEJOMPyX9vD/ikw35w9Lga9to+9y1rY= -github.com/smartcontractkit/chainlink-common v0.9.6-0.20260129031639-d791b142161a/go.mod h1:Eg5rz/fQINjR9H0TxHw7j+zGZeYxprUpEQZzC5JGHG4= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d h1:vHPgWL6HzM0cY8Qf1nue0t0P8OvCB6Pkp3h9lMtBsSo= +github.com/smartcontractkit/chainlink-common v0.9.6-0.20260203132106-254b3c07980d/go.mod h1:zBuRC7el/pQQB95t7JnLOvCfZ3lmi5jjXYRUY2XUD+g= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20251211140724-319861e514c4 h1:NOUsjsMzNecbjiPWUQGlRSRAutEvCFrqqyETDJeh5q4= github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20251211140724-319861e514c4/go.mod h1:Zpvul9sTcZNAZOVzt5vBl1XZGNvQebFpnpn3/KOQvOQ= github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20251215152504-b1e41f508340 h1:PsjEI+5jZIz9AS4eOsLS5VpSWJINf38clXV3wryPyMk=