diff --git a/core/cmd/shell.go b/core/cmd/shell.go index 8cba34ab3f0..652d68006f7 100644 --- a/core/cmd/shell.go +++ b/core/cmd/shell.go @@ -129,6 +129,7 @@ func initGlobals(cfgProm config.Prometheus, cfgTracing config.Tracing, cfgTeleme ChipIngressEmitterEnabled: cfgTelemetry.ChipIngressEndpoint() != "", ChipIngressEmitterGRPCEndpoint: cfgTelemetry.ChipIngressEndpoint(), ChipIngressInsecureConnection: cfgTelemetry.ChipIngressInsecureConnection(), + ChipIngressLogger: lggr, LogStreamingEnabled: cfgTelemetry.LogStreamingEnabled(), LogLevel: cfgTelemetry.LogLevel(), LogBatchProcessor: cfgTelemetry.LogBatchProcessor(), diff --git a/core/scripts/go.mod b/core/scripts/go.mod index 344e7cd94c1..4c917d941cd 100644 --- a/core/scripts/go.mod +++ b/core/scripts/go.mod @@ -43,7 +43,7 @@ require ( github.com/smartcontractkit/chain-selectors v1.0.100 github.com/smartcontractkit/chainlink-automation v0.8.1 github.com/smartcontractkit/chainlink-ccip/chains/evm v0.0.0-20260506144252-c100eabfda74 - github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 + github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 github.com/smartcontractkit/chainlink-common/keystore v1.1.0 github.com/smartcontractkit/chainlink-data-streams v0.1.14 github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 @@ -480,7 +480,7 @@ require ( github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260506144252-c100eabfda74 // indirect github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20260511195239-0f6e1b177fc7 // indirect github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd // indirect - github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260511200925-b94130438417 // indirect + github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 // indirect github.com/smartcontractkit/chainlink-evm/contracts/cre/gobindings v0.0.0-20260403151002-2c91155b5501 // indirect github.com/smartcontractkit/chainlink-feeds v0.1.2-0.20250227211209-7cd000095135 // indirect github.com/smartcontractkit/chainlink-framework/capabilities v0.0.0-20260423135514-5b1a7565a99c // indirect diff --git a/core/scripts/go.sum b/core/scripts/go.sum index 5c50d1fc63b..64a959933ac 100644 --- a/core/scripts/go.sum +++ b/core/scripts/go.sum @@ -1577,12 +1577,12 @@ github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20260504204047-af98 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20260504204047-af9826978b72/go.mod h1:Ls0oszLvhzV3/D0ivG85sh8qmmcsVhKplmepQdFq98E= github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd h1:IMopuENFVS63AerRELdfWo6o60UNUidcldJOxJLmk24= github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd/go.mod h1:SBN8Urnh5sQvrQRbSo1Nr8coWatHg8LZoPw3R/42sho= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 h1:r4sH0uvOoSXegOQPVaMEsu27q1dfWplIwO4WvdcEtKM= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264/go.mod h1:B+eYJSQmOc28kzs7OwJjwo0DEV2f01HnUk89r9R1d/Y= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 h1:mczpkU4vzgqXZ11qHN/kf95x5zDnASbmZZvozvT8YBE= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738/go.mod h1:Pu4czYGiGRAJo+a1M3ZXY+wEyItMe9wtJCVp0pBgAzg= github.com/smartcontractkit/chainlink-common/keystore v1.1.0 h1:2wzySccgk2fpWusPKO0bpeAZzfSU9eq6CS5U+JwYaVo= github.com/smartcontractkit/chainlink-common/keystore v1.1.0/go.mod h1:6JexOOhPhknQ0QMuppFIlOpm6wCp54yZMxai+tWugwY= -github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260511200925-b94130438417 h1:y1lYPEpZZrb1PQwrOWBFvOnJnTmhxmbRo2HfyJ6CoLA= -github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260511200925-b94130438417/go.mod h1:S3pRAqlhLZGJWRFOV8AqHRfl3dluPHYRJ19ndJMhAH4= +github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 h1:PlkA7NGpBm5sc2P//crDFgMIQ0qsQhKcpjWV7Qzwqz8= +github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146/go.mod h1:HmUyH2oD9m+GRpKq7q3vuRnm1F2Uczf/Nd1v3ipMSK8= github.com/smartcontractkit/chainlink-data-streams v0.1.14 h1:Tt71W/EwiDaNbic/5YV2pW2pU4XRbGZUqUa5EtJoA8E= github.com/smartcontractkit/chainlink-data-streams v0.1.14/go.mod h1:r+B/n6mBaHgusPs2va/9VL/W/ZuKQK4vJpNx5n8vD/E= github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 h1:Vp4EwkvxcBzgahIZdbWyCExDXLha93cS63xvwd2xwx8= diff --git a/core/services/beholder/durable_event_store_orm_test.go b/core/services/beholder/durable_event_store_orm_test.go index 128e89a4e2c..74eb130e4c3 100644 --- a/core/services/beholder/durable_event_store_orm_test.go +++ b/core/services/beholder/durable_event_store_orm_test.go @@ -9,9 +9,8 @@ import ( "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" - beholdersvc "github.com/smartcontractkit/chainlink/v2/core/services/beholder" + "github.com/smartcontractkit/chainlink-common/pkg/beholder/beholderstore" - "github.com/smartcontractkit/chainlink/v2/core/internal/testutils" "github.com/smartcontractkit/chainlink/v2/core/internal/testutils/pgtest" ) @@ -24,11 +23,11 @@ func truncateChipDurableEvents(t *testing.T, db *sqlx.DB) { require.NoError(t, err) } -func TestPgDurableEventStore_InsertDeleteRoundTrip(t *testing.T) { +func TestPGDurableEventStore_InsertDeleteRoundTrip(t *testing.T) { db := pgtest.NewSqlxDB(t) truncateChipDurableEvents(t, db) ctx := t.Context() - store := beholdersvc.NewPgDurableEventStore(db) + store := beholderstore.New(db) id, err := store.Insert(ctx, []byte("test-payload")) require.NoError(t, err) @@ -47,11 +46,11 @@ func TestPgDurableEventStore_InsertDeleteRoundTrip(t *testing.T) { assert.Empty(t, events) } -func TestPgDurableEventStore_ListPending_RespectsCreatedBefore(t *testing.T) { +func TestPGDurableEventStore_ListPending_RespectsCreatedBefore(t *testing.T) { db := pgtest.NewSqlxDB(t) truncateChipDurableEvents(t, db) ctx := t.Context() - store := beholdersvc.NewPgDurableEventStore(db) + store := beholderstore.New(db) _, err := store.Insert(ctx, []byte("event-1")) require.NoError(t, err) @@ -67,11 +66,11 @@ func TestPgDurableEventStore_ListPending_RespectsCreatedBefore(t *testing.T) { assert.Len(t, events, 1) } -func TestPgDurableEventStore_ListPending_RespectsLimit(t *testing.T) { +func TestPGDurableEventStore_ListPending_RespectsLimit(t *testing.T) { db := pgtest.NewSqlxDB(t) truncateChipDurableEvents(t, db) ctx := t.Context() - store := beholdersvc.NewPgDurableEventStore(db) + store := beholderstore.New(db) for i := 0; i < 20; i++ { _, err := store.Insert(ctx, []byte(fmt.Sprintf("event-%d", i))) @@ -83,11 +82,11 @@ func TestPgDurableEventStore_ListPending_RespectsLimit(t *testing.T) { assert.Len(t, events, 5) } -func TestPgDurableEventStore_DeleteExpired(t *testing.T) { +func TestPGDurableEventStore_DeleteExpired(t *testing.T) { db := pgtest.NewSqlxDB(t) truncateChipDurableEvents(t, db) ctx := t.Context() - store := beholdersvc.NewPgDurableEventStore(db) + store := beholderstore.New(db) _, err := store.Insert(ctx, []byte("will-expire")) require.NoError(t, err) @@ -103,11 +102,11 @@ func TestPgDurableEventStore_DeleteExpired(t *testing.T) { assert.Equal(t, int64(1), deleted) } -func TestPgDurableEventStore_ObserveDurableQueue(t *testing.T) { +func TestPGDurableEventStore_ObserveDurableQueue(t *testing.T) { db := pgtest.NewSqlxDB(t) truncateChipDurableEvents(t, db) - ctx := testutils.Context(t) - store := beholdersvc.NewPgDurableEventStore(db) + ctx := t.Context() + store := beholderstore.New(db) st, err := store.ObserveDurableQueue(ctx, time.Hour, time.Minute) require.NoError(t, err) @@ -122,11 +121,11 @@ func TestPgDurableEventStore_ObserveDurableQueue(t *testing.T) { assert.Positive(t, st.OldestPendingAge) } -func TestPgDurableEventStore_MarkDeliveredAndPurgeDelivered(t *testing.T) { +func TestPGDurableEventStore_MarkDeliveredAndPurgeDelivered(t *testing.T) { db := pgtest.NewSqlxDB(t) truncateChipDurableEvents(t, db) - ctx := testutils.Context(t) - store := beholdersvc.NewPgDurableEventStore(db) + ctx := t.Context() + store := beholderstore.New(db) id, err := store.Insert(ctx, []byte("payload")) require.NoError(t, err) diff --git a/core/services/chainlink/application.go b/core/services/chainlink/application.go index 04c12ad18d6..59b8c78bd23 100644 --- a/core/services/chainlink/application.go +++ b/core/services/chainlink/application.go @@ -27,6 +27,7 @@ import ( "go.uber.org/zap/zapcore" "github.com/smartcontractkit/chainlink-common/pkg/beholder" + "github.com/smartcontractkit/chainlink-common/pkg/beholder/beholderstore" "github.com/smartcontractkit/chainlink-common/pkg/chipingress" "github.com/smartcontractkit/chainlink-common/pkg/loop" nodeauthjwt "github.com/smartcontractkit/chainlink-common/pkg/nodeauth/jwt" @@ -379,9 +380,13 @@ func NewApplication(ctx context.Context, opts ApplicationOpts) (Application, err // Wire DurableEmitter for persistent chip ingress delivery when enabled. if cfg.Telemetry().DurableEmitterEnabled() && cfg.Telemetry().ChipIngressEndpoint() != "" { - if err = setupDurableEmitter(ctx, opts.DS, globalLogger, cfg.Telemetry()); err != nil { + beholderClient := beholder.GetClient() + if err = beholderClient.SetupDurableEmitter(beholderstore.New(opts.DS), true); err != nil { return nil, fmt.Errorf("failed to set up chip durable emitter: %w", err) } + if err = beholderClient.StartDurableEmitter(ctx); err != nil { + return nil, fmt.Errorf("failed to start chip durable emitter: %w", err) + } } creServices, err := cre.NewServices( diff --git a/deployment/go.mod b/deployment/go.mod index 1a57310b057..aa8002b86aa 100644 --- a/deployment/go.mod +++ b/deployment/go.mod @@ -42,7 +42,7 @@ require ( github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260415165642-49f23e4d76cc github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20260511195239-0f6e1b177fc7 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20260504204047-af9826978b72 - github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 + github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 github.com/smartcontractkit/chainlink-common/keystore v1.1.0 github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260519153648-e22912dab374 @@ -417,7 +417,7 @@ require ( github.com/smartcontractkit/chainlink-automation v0.8.1 // indirect github.com/smartcontractkit/chainlink-ccip/ccv/chains/evm v0.0.0-20260408145530-22e2d05695cd // indirect github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd // indirect - github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10 // indirect + github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 // indirect github.com/smartcontractkit/chainlink-data-streams v0.1.14 // indirect github.com/smartcontractkit/chainlink-feeds v0.1.2-0.20250227211209-7cd000095135 // indirect github.com/smartcontractkit/chainlink-framework/capabilities v0.0.0-20260423135514-5b1a7565a99c // indirect diff --git a/deployment/go.sum b/deployment/go.sum index dc0e90fd57d..a93f38425f5 100644 --- a/deployment/go.sum +++ b/deployment/go.sum @@ -1378,12 +1378,12 @@ github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd h github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd/go.mod h1:SBN8Urnh5sQvrQRbSo1Nr8coWatHg8LZoPw3R/42sho= github.com/smartcontractkit/chainlink-ccv/deployment v0.0.2-0.20260428205321-9ce8f4c44d23 h1:1Rt4HLpwbRN1YtBFcbsxSJYIiUP2wJ11qizevOEeCrs= github.com/smartcontractkit/chainlink-ccv/deployment v0.0.2-0.20260428205321-9ce8f4c44d23/go.mod h1:V+wrhuNve+JiFwoBr25d6y0lL1rYSCSJhTFyloL3ueo= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 h1:r4sH0uvOoSXegOQPVaMEsu27q1dfWplIwO4WvdcEtKM= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264/go.mod h1:B+eYJSQmOc28kzs7OwJjwo0DEV2f01HnUk89r9R1d/Y= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 h1:mczpkU4vzgqXZ11qHN/kf95x5zDnASbmZZvozvT8YBE= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738/go.mod h1:Pu4czYGiGRAJo+a1M3ZXY+wEyItMe9wtJCVp0pBgAzg= github.com/smartcontractkit/chainlink-common/keystore v1.1.0 h1:2wzySccgk2fpWusPKO0bpeAZzfSU9eq6CS5U+JwYaVo= github.com/smartcontractkit/chainlink-common/keystore v1.1.0/go.mod h1:6JexOOhPhknQ0QMuppFIlOpm6wCp54yZMxai+tWugwY= -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/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 h1:PlkA7NGpBm5sc2P//crDFgMIQ0qsQhKcpjWV7Qzwqz8= +github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146/go.mod h1:HmUyH2oD9m+GRpKq7q3vuRnm1F2Uczf/Nd1v3ipMSK8= github.com/smartcontractkit/chainlink-data-streams v0.1.14 h1:Tt71W/EwiDaNbic/5YV2pW2pU4XRbGZUqUa5EtJoA8E= github.com/smartcontractkit/chainlink-data-streams v0.1.14/go.mod h1:r+B/n6mBaHgusPs2va/9VL/W/ZuKQK4vJpNx5n8vD/E= github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 h1:Vp4EwkvxcBzgahIZdbWyCExDXLha93cS63xvwd2xwx8= diff --git a/go.mod b/go.mod index 1a181fdf9c3..2b0c3fb4cc6 100644 --- a/go.mod +++ b/go.mod @@ -85,9 +85,9 @@ require ( github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260415165642-49f23e4d76cc github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20260415165642-49f23e4d76cc github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd - github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 + github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 github.com/smartcontractkit/chainlink-common/keystore v1.1.0 - github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10 + github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 github.com/smartcontractkit/chainlink-data-streams v0.1.14 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260519153648-e22912dab374 github.com/smartcontractkit/chainlink-evm/contracts/cre/gobindings v0.0.0-20260403151002-2c91155b5501 diff --git a/go.sum b/go.sum index 78f08198d8f..a430c30f293 100644 --- a/go.sum +++ b/go.sum @@ -1177,12 +1177,12 @@ github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20260 github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20260415165642-49f23e4d76cc/go.mod h1:67YbnoglYD61Pz/jTVCgav9wFq7S35OU8UyQSvPllRw= github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd h1:IMopuENFVS63AerRELdfWo6o60UNUidcldJOxJLmk24= github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd/go.mod h1:SBN8Urnh5sQvrQRbSo1Nr8coWatHg8LZoPw3R/42sho= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 h1:r4sH0uvOoSXegOQPVaMEsu27q1dfWplIwO4WvdcEtKM= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264/go.mod h1:B+eYJSQmOc28kzs7OwJjwo0DEV2f01HnUk89r9R1d/Y= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 h1:mczpkU4vzgqXZ11qHN/kf95x5zDnASbmZZvozvT8YBE= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738/go.mod h1:Pu4czYGiGRAJo+a1M3ZXY+wEyItMe9wtJCVp0pBgAzg= github.com/smartcontractkit/chainlink-common/keystore v1.1.0 h1:2wzySccgk2fpWusPKO0bpeAZzfSU9eq6CS5U+JwYaVo= github.com/smartcontractkit/chainlink-common/keystore v1.1.0/go.mod h1:6JexOOhPhknQ0QMuppFIlOpm6wCp54yZMxai+tWugwY= -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/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 h1:PlkA7NGpBm5sc2P//crDFgMIQ0qsQhKcpjWV7Qzwqz8= +github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146/go.mod h1:HmUyH2oD9m+GRpKq7q3vuRnm1F2Uczf/Nd1v3ipMSK8= github.com/smartcontractkit/chainlink-data-streams v0.1.14 h1:Tt71W/EwiDaNbic/5YV2pW2pU4XRbGZUqUa5EtJoA8E= github.com/smartcontractkit/chainlink-data-streams v0.1.14/go.mod h1:r+B/n6mBaHgusPs2va/9VL/W/ZuKQK4vJpNx5n8vD/E= github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260519153648-e22912dab374 h1:dWBveDfyBhtLJNaSAVJdHyYSEtTdxmAueMet2XFBHF0= diff --git a/integration-tests/go.mod b/integration-tests/go.mod index cfb311ea67d..4f05ba8871e 100644 --- a/integration-tests/go.mod +++ b/integration-tests/go.mod @@ -29,7 +29,7 @@ require ( github.com/smartcontractkit/chainlink-ccip/chains/evm v0.0.0-20260506144252-c100eabfda74 github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260506144252-c100eabfda74 github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20260511195239-0f6e1b177fc7 - github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 + github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 github.com/smartcontractkit/chainlink-common/keystore v1.1.0 github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260519153648-e22912dab374 @@ -394,7 +394,7 @@ require ( github.com/smartcontractkit/chainlink-ccip/ccv/chains/evm v0.0.0-20260408145530-22e2d05695cd // indirect github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20260504204047-af9826978b72 // indirect github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd // indirect - github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10 // indirect + github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 // indirect github.com/smartcontractkit/chainlink-data-streams v0.1.14 // indirect github.com/smartcontractkit/chainlink-evm/contracts/cre/gobindings v0.0.0-20260403151002-2c91155b5501 // indirect github.com/smartcontractkit/chainlink-feeds v0.1.2-0.20250227211209-7cd000095135 // indirect diff --git a/integration-tests/go.sum b/integration-tests/go.sum index b6c48faa71d..e11cf8376a1 100644 --- a/integration-tests/go.sum +++ b/integration-tests/go.sum @@ -1363,12 +1363,12 @@ github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd h github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd/go.mod h1:SBN8Urnh5sQvrQRbSo1Nr8coWatHg8LZoPw3R/42sho= github.com/smartcontractkit/chainlink-ccv/deployment v0.0.2-0.20260428205321-9ce8f4c44d23 h1:1Rt4HLpwbRN1YtBFcbsxSJYIiUP2wJ11qizevOEeCrs= github.com/smartcontractkit/chainlink-ccv/deployment v0.0.2-0.20260428205321-9ce8f4c44d23/go.mod h1:V+wrhuNve+JiFwoBr25d6y0lL1rYSCSJhTFyloL3ueo= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 h1:r4sH0uvOoSXegOQPVaMEsu27q1dfWplIwO4WvdcEtKM= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264/go.mod h1:B+eYJSQmOc28kzs7OwJjwo0DEV2f01HnUk89r9R1d/Y= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 h1:mczpkU4vzgqXZ11qHN/kf95x5zDnASbmZZvozvT8YBE= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738/go.mod h1:Pu4czYGiGRAJo+a1M3ZXY+wEyItMe9wtJCVp0pBgAzg= github.com/smartcontractkit/chainlink-common/keystore v1.1.0 h1:2wzySccgk2fpWusPKO0bpeAZzfSU9eq6CS5U+JwYaVo= github.com/smartcontractkit/chainlink-common/keystore v1.1.0/go.mod h1:6JexOOhPhknQ0QMuppFIlOpm6wCp54yZMxai+tWugwY= -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/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 h1:PlkA7NGpBm5sc2P//crDFgMIQ0qsQhKcpjWV7Qzwqz8= +github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146/go.mod h1:HmUyH2oD9m+GRpKq7q3vuRnm1F2Uczf/Nd1v3ipMSK8= github.com/smartcontractkit/chainlink-data-streams v0.1.14 h1:Tt71W/EwiDaNbic/5YV2pW2pU4XRbGZUqUa5EtJoA8E= github.com/smartcontractkit/chainlink-data-streams v0.1.14/go.mod h1:r+B/n6mBaHgusPs2va/9VL/W/ZuKQK4vJpNx5n8vD/E= github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 h1:Vp4EwkvxcBzgahIZdbWyCExDXLha93cS63xvwd2xwx8= diff --git a/integration-tests/load/go.mod b/integration-tests/load/go.mod index 245a045b273..b05bd803763 100644 --- a/integration-tests/load/go.mod +++ b/integration-tests/load/go.mod @@ -20,7 +20,7 @@ require ( github.com/smartcontractkit/chainlink-ccip/chains/evm v0.0.0-20260506144252-c100eabfda74 github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260506144252-c100eabfda74 github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20260511195239-0f6e1b177fc7 - github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 + github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260519153648-e22912dab374 github.com/smartcontractkit/chainlink-testing-framework/framework v0.16.1 @@ -475,7 +475,7 @@ require ( github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20260504204047-af9826978b72 // indirect github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd // indirect github.com/smartcontractkit/chainlink-common/keystore v1.1.0 // indirect - github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10 // indirect + github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 // indirect github.com/smartcontractkit/chainlink-data-streams v0.1.14 // indirect github.com/smartcontractkit/chainlink-evm/contracts/cre/gobindings v0.0.0-20260403151002-2c91155b5501 // indirect github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20260512150409-b4068bf735e6 // indirect diff --git a/integration-tests/load/go.sum b/integration-tests/load/go.sum index 421afb08c6e..775f652e708 100644 --- a/integration-tests/load/go.sum +++ b/integration-tests/load/go.sum @@ -1629,12 +1629,12 @@ github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd h github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd/go.mod h1:SBN8Urnh5sQvrQRbSo1Nr8coWatHg8LZoPw3R/42sho= github.com/smartcontractkit/chainlink-ccv/deployment v0.0.2-0.20260428205321-9ce8f4c44d23 h1:1Rt4HLpwbRN1YtBFcbsxSJYIiUP2wJ11qizevOEeCrs= github.com/smartcontractkit/chainlink-ccv/deployment v0.0.2-0.20260428205321-9ce8f4c44d23/go.mod h1:V+wrhuNve+JiFwoBr25d6y0lL1rYSCSJhTFyloL3ueo= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 h1:r4sH0uvOoSXegOQPVaMEsu27q1dfWplIwO4WvdcEtKM= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264/go.mod h1:B+eYJSQmOc28kzs7OwJjwo0DEV2f01HnUk89r9R1d/Y= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 h1:mczpkU4vzgqXZ11qHN/kf95x5zDnASbmZZvozvT8YBE= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738/go.mod h1:Pu4czYGiGRAJo+a1M3ZXY+wEyItMe9wtJCVp0pBgAzg= github.com/smartcontractkit/chainlink-common/keystore v1.1.0 h1:2wzySccgk2fpWusPKO0bpeAZzfSU9eq6CS5U+JwYaVo= github.com/smartcontractkit/chainlink-common/keystore v1.1.0/go.mod h1:6JexOOhPhknQ0QMuppFIlOpm6wCp54yZMxai+tWugwY= -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/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 h1:PlkA7NGpBm5sc2P//crDFgMIQ0qsQhKcpjWV7Qzwqz8= +github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146/go.mod h1:HmUyH2oD9m+GRpKq7q3vuRnm1F2Uczf/Nd1v3ipMSK8= github.com/smartcontractkit/chainlink-data-streams v0.1.14 h1:Tt71W/EwiDaNbic/5YV2pW2pU4XRbGZUqUa5EtJoA8E= github.com/smartcontractkit/chainlink-data-streams v0.1.14/go.mod h1:r+B/n6mBaHgusPs2va/9VL/W/ZuKQK4vJpNx5n8vD/E= github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 h1:Vp4EwkvxcBzgahIZdbWyCExDXLha93cS63xvwd2xwx8= diff --git a/plugins/loop_registry.go b/plugins/loop_registry.go index 5727b399426..13e23ea73df 100644 --- a/plugins/loop_registry.go +++ b/plugins/loop_registry.go @@ -152,6 +152,7 @@ func (m *LoopRegistry) Register(id string) (*RegisteredLoop, error) { envCfg.TelemetryEmitterExportTimeout = m.cfgTelemetry.EmitterExportTimeout() envCfg.TelemetryAuthPubKeyHex = m.telemetryAuthPubKeyHex envCfg.ChipIngressEndpoint = m.cfgTelemetry.ChipIngressEndpoint() + envCfg.ChipIngressDurableEmitterEnabled = m.cfgTelemetry.DurableEmitterEnabled() envCfg.ChipIngressInsecureConnection = m.cfgTelemetry.ChipIngressInsecureConnection() envCfg.TelemetryLogStreamingEnabled = m.cfgTelemetry.LogStreamingEnabled() envCfg.TelemetryLogLevel = m.cfgTelemetry.LogLevel() diff --git a/system-tests/lib/go.mod b/system-tests/lib/go.mod index d366a5ab4e7..ddcdee91d15 100644 --- a/system-tests/lib/go.mod +++ b/system-tests/lib/go.mod @@ -33,7 +33,7 @@ require ( github.com/smartcontractkit/chain-selectors v1.0.100 github.com/smartcontractkit/chainlink-aptos v0.0.0-20260507123701-77fc93b573bb github.com/smartcontractkit/chainlink-ccip/chains/solana v0.0.0-20260415165642-49f23e4d76cc - github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 + github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 github.com/smartcontractkit/chainlink-common/keystore v1.1.0 github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260519153648-e22912dab374 @@ -446,7 +446,7 @@ require ( github.com/smartcontractkit/chainlink-ccip/chains/evm v0.0.0-20260506144252-c100eabfda74 // indirect github.com/smartcontractkit/chainlink-ccip/chains/solana/gobindings v0.0.0-20260511195239-0f6e1b177fc7 // indirect github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd // indirect - github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20251211140724-319861e514c4 // indirect + github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 // indirect github.com/smartcontractkit/chainlink-data-streams v0.1.14 // indirect github.com/smartcontractkit/chainlink-evm/contracts/cre/gobindings v0.0.0-20260403151002-2c91155b5501 // indirect github.com/smartcontractkit/chainlink-feeds v0.1.2-0.20250227211209-7cd000095135 // indirect diff --git a/system-tests/lib/go.sum b/system-tests/lib/go.sum index d92c299685c..3d448db6426 100644 --- a/system-tests/lib/go.sum +++ b/system-tests/lib/go.sum @@ -1544,12 +1544,12 @@ github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20260504204047-af98 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20260504204047-af9826978b72/go.mod h1:Ls0oszLvhzV3/D0ivG85sh8qmmcsVhKplmepQdFq98E= github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd h1:IMopuENFVS63AerRELdfWo6o60UNUidcldJOxJLmk24= github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd/go.mod h1:SBN8Urnh5sQvrQRbSo1Nr8coWatHg8LZoPw3R/42sho= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 h1:r4sH0uvOoSXegOQPVaMEsu27q1dfWplIwO4WvdcEtKM= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264/go.mod h1:B+eYJSQmOc28kzs7OwJjwo0DEV2f01HnUk89r9R1d/Y= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 h1:mczpkU4vzgqXZ11qHN/kf95x5zDnASbmZZvozvT8YBE= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738/go.mod h1:Pu4czYGiGRAJo+a1M3ZXY+wEyItMe9wtJCVp0pBgAzg= github.com/smartcontractkit/chainlink-common/keystore v1.1.0 h1:2wzySccgk2fpWusPKO0bpeAZzfSU9eq6CS5U+JwYaVo= github.com/smartcontractkit/chainlink-common/keystore v1.1.0/go.mod h1:6JexOOhPhknQ0QMuppFIlOpm6wCp54yZMxai+tWugwY= -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/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 h1:PlkA7NGpBm5sc2P//crDFgMIQ0qsQhKcpjWV7Qzwqz8= +github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146/go.mod h1:HmUyH2oD9m+GRpKq7q3vuRnm1F2Uczf/Nd1v3ipMSK8= github.com/smartcontractkit/chainlink-data-streams v0.1.14 h1:Tt71W/EwiDaNbic/5YV2pW2pU4XRbGZUqUa5EtJoA8E= github.com/smartcontractkit/chainlink-data-streams v0.1.14/go.mod h1:r+B/n6mBaHgusPs2va/9VL/W/ZuKQK4vJpNx5n8vD/E= github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 h1:Vp4EwkvxcBzgahIZdbWyCExDXLha93cS63xvwd2xwx8= diff --git a/system-tests/tests/go.mod b/system-tests/tests/go.mod index 8fd8d198fcc..2ae6bd66780 100644 --- a/system-tests/tests/go.mod +++ b/system-tests/tests/go.mod @@ -55,7 +55,7 @@ require ( github.com/pkg/errors v0.9.1 github.com/rs/zerolog v1.34.0 github.com/smartcontractkit/chain-selectors v1.0.100 - github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 + github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 github.com/smartcontractkit/chainlink-common/keystore v1.1.0 github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 github.com/smartcontractkit/chainlink-evm/contracts/cre/gobindings v0.0.0-20260403151002-2c91155b5501 @@ -510,7 +510,7 @@ require ( github.com/smartcontractkit/chainlink-aptos v0.0.0-20260507123701-77fc93b573bb github.com/smartcontractkit/chainlink-automation v0.8.1 // indirect github.com/smartcontractkit/chainlink-ccip v0.1.1-solana.0.20260428205619-2db1389501a1 // indirect - github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20251211140724-319861e514c4 + github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 github.com/smartcontractkit/chainlink-evm v0.3.4-0.20260519153648-e22912dab374 // indirect github.com/smartcontractkit/chainlink-feeds v0.1.2-0.20250227211209-7cd000095135 // indirect github.com/smartcontractkit/chainlink-framework/capabilities v0.0.0-20260423135514-5b1a7565a99c // indirect diff --git a/system-tests/tests/go.sum b/system-tests/tests/go.sum index b91e44ea3a4..f38b3658d5b 100644 --- a/system-tests/tests/go.sum +++ b/system-tests/tests/go.sum @@ -1558,12 +1558,12 @@ github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20260504204047-af98 github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20260504204047-af9826978b72/go.mod h1:Ls0oszLvhzV3/D0ivG85sh8qmmcsVhKplmepQdFq98E= github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd h1:IMopuENFVS63AerRELdfWo6o60UNUidcldJOxJLmk24= github.com/smartcontractkit/chainlink-ccv v0.0.2-0.20260428133800-3b1484e8b1fd/go.mod h1:SBN8Urnh5sQvrQRbSo1Nr8coWatHg8LZoPw3R/42sho= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264 h1:r4sH0uvOoSXegOQPVaMEsu27q1dfWplIwO4WvdcEtKM= -github.com/smartcontractkit/chainlink-common v0.11.2-0.20260518100439-9564f35fd264/go.mod h1:B+eYJSQmOc28kzs7OwJjwo0DEV2f01HnUk89r9R1d/Y= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738 h1:mczpkU4vzgqXZ11qHN/kf95x5zDnASbmZZvozvT8YBE= +github.com/smartcontractkit/chainlink-common v0.11.2-0.20260520174852-16779f420738/go.mod h1:Pu4czYGiGRAJo+a1M3ZXY+wEyItMe9wtJCVp0pBgAzg= github.com/smartcontractkit/chainlink-common/keystore v1.1.0 h1:2wzySccgk2fpWusPKO0bpeAZzfSU9eq6CS5U+JwYaVo= github.com/smartcontractkit/chainlink-common/keystore v1.1.0/go.mod h1:6JexOOhPhknQ0QMuppFIlOpm6wCp54yZMxai+tWugwY= -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/chipingress v0.0.11-0.20260518142424-bacfb6ba4146 h1:PlkA7NGpBm5sc2P//crDFgMIQ0qsQhKcpjWV7Qzwqz8= +github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.11-0.20260518142424-bacfb6ba4146/go.mod h1:HmUyH2oD9m+GRpKq7q3vuRnm1F2Uczf/Nd1v3ipMSK8= github.com/smartcontractkit/chainlink-data-streams v0.1.14 h1:Tt71W/EwiDaNbic/5YV2pW2pU4XRbGZUqUa5EtJoA8E= github.com/smartcontractkit/chainlink-data-streams v0.1.14/go.mod h1:r+B/n6mBaHgusPs2va/9VL/W/ZuKQK4vJpNx5n8vD/E= github.com/smartcontractkit/chainlink-deployments-framework v0.105.0 h1:Vp4EwkvxcBzgahIZdbWyCExDXLha93cS63xvwd2xwx8=