diff --git a/core/capabilities/compute/compute.go b/core/capabilities/compute/compute.go index ffbf703b941..37d3850e343 100644 --- a/core/capabilities/compute/compute.go +++ b/core/capabilities/compute/compute.go @@ -21,7 +21,6 @@ import ( "github.com/smartcontractkit/chainlink-common/pkg/logger" "github.com/smartcontractkit/chainlink-common/pkg/services" coretypes "github.com/smartcontractkit/chainlink-common/pkg/types/core" - "github.com/smartcontractkit/chainlink-common/pkg/values" "github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/host" wasmpb "github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/pb" "github.com/smartcontractkit/chainlink/v2/core/capabilities/validation" @@ -83,7 +82,7 @@ type Compute struct { // transformer is used to transform a values.Map into a ParsedConfig struct on each execution // of a request. - transformer ConfigTransformer + transformer *transformer outgoingConnectorHandler *webapi.OutgoingConnectorHandler idGenerator func() string @@ -149,28 +148,8 @@ func (c *Compute) enqueueRequest(ctx context.Context, req capabilities.Capabilit } } -func shallowCopy(m *values.Map) *values.Map { - to := values.EmptyMap() - - for k, v := range m.Underlying { - to.Underlying[k] = v - } - - return to -} - func (c *Compute) execute(ctx context.Context, respCh chan response, req capabilities.CapabilityRequest) { - // Shallow copy the request. - // This is because we mutate its overall shape. - req = capabilities.CapabilityRequest{ - Config: shallowCopy(req.Config), - - // These aren't mutated so we ignore them. - Metadata: req.Metadata, - Inputs: req.Inputs, - } - - cfg, err := c.transformer.Transform(req.Config) + copiedReq, cfg, err := c.transformer.Transform(req) if err != nil { respCh <- response{err: fmt.Errorf("invalid request: could not transform config: %w", err)} return @@ -180,7 +159,7 @@ func (c *Compute) execute(ctx context.Context, respCh chan response, req capabil m, ok := c.modules.get(id) if !ok { - mod, innerErr := c.initModule(id, cfg.ModuleConfig, cfg.Binary, req.Metadata.WorkflowID, req.Metadata.WorkflowExecutionID, req.Metadata.ReferenceID) + mod, innerErr := c.initModule(id, cfg.ModuleConfig, cfg.Binary, copiedReq.Metadata.WorkflowID, copiedReq.Metadata.WorkflowExecutionID, copiedReq.Metadata.ReferenceID) if innerErr != nil { respCh <- response{err: innerErr} return @@ -189,7 +168,7 @@ func (c *Compute) execute(ctx context.Context, respCh chan response, req capabil m = mod } - resp, err := c.executeWithModule(ctx, m.module, cfg.Config, req) + resp, err := c.executeWithModule(ctx, m.module, cfg.Config, copiedReq) select { case <-c.stopCh: case <-ctx.Done(): diff --git a/core/capabilities/compute/transformer.go b/core/capabilities/compute/transformer.go index c04b93afd0f..3b4ae4cfa69 100644 --- a/core/capabilities/compute/transformer.go +++ b/core/capabilities/compute/transformer.go @@ -12,15 +12,6 @@ import ( "github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/host" ) -type Transformer[T any, U any] interface { - // Transform changes a struct of type T into a struct of type U. Accepts a variadic list of options to modify the - // output struct. - Transform(T, ...func(*U)) (*U, error) -} - -// ConfigTransformer is a Transformer that converts a values.Map into a ParsedConfig struct. -type ConfigTransformer = Transformer[*values.Map, ParsedConfig] - // ParsedConfig is a struct that contains the binary and config for a wasm module, as well as the module config. type ParsedConfig struct { Binary []byte @@ -52,8 +43,8 @@ func shallowCopy(m *values.Map) *values.Map { // configuration values such as maxMemoryMBs, timeout, and tickInterval. Default logger and // emitter for the module are taken from the transformer instance. Override these values with // the functional options. -func (t *transformer) Transform(req *capabilities.CapabilityRequest, opts ...func(*ParsedConfig)) (*capabilities.CapabilityRequest, *ParsedConfig, error) { - copiedReq := &capabilities.CapabilityRequest{ +func (t *transformer) Transform(req capabilities.CapabilityRequest, opts ...func(*ParsedConfig)) (capabilities.CapabilityRequest, *ParsedConfig, error) { + copiedReq := capabilities.CapabilityRequest{ Inputs: req.Inputs, Metadata: req.Metadata, Config: shallowCopy(req.Config), @@ -61,17 +52,17 @@ func (t *transformer) Transform(req *capabilities.CapabilityRequest, opts ...fun binary, err := popValue[[]byte](copiedReq.Config, binaryKey) if err != nil { - return nil, nil, NewInvalidRequestError(err) + return capabilities.CapabilityRequest{}, nil, NewInvalidRequestError(err) } config, err := popValue[[]byte](copiedReq.Config, configKey) if err != nil { - return nil, nil, NewInvalidRequestError(err) + return capabilities.CapabilityRequest{}, nil, NewInvalidRequestError(err) } maxMemoryMBs, err := popOptionalValue[int64](copiedReq.Config, maxMemoryMBsKey) if err != nil { - return nil, nil, NewInvalidRequestError(err) + return capabilities.CapabilityRequest{}, nil, NewInvalidRequestError(err) } mc := &host.ModuleConfig{ @@ -82,28 +73,28 @@ func (t *transformer) Transform(req *capabilities.CapabilityRequest, opts ...fun timeout, err := popOptionalValue[string](copiedReq.Config, timeoutKey) if err != nil { - return nil, nil, NewInvalidRequestError(err) + return capabilities.CapabilityRequest{}, nil, NewInvalidRequestError(err) } var td time.Duration if timeout != "" { td, err = time.ParseDuration(timeout) if err != nil { - return nil, nil, NewInvalidRequestError(err) + return capabilities.CapabilityRequest{}, nil, NewInvalidRequestError(err) } mc.Timeout = &td } tickInterval, err := popOptionalValue[string](copiedReq.Config, tickIntervalKey) if err != nil { - return nil, nil, NewInvalidRequestError(err) + return capabilities.CapabilityRequest{}, nil, NewInvalidRequestError(err) } var ti time.Duration if tickInterval != "" { ti, err = time.ParseDuration(tickInterval) if err != nil { - return nil, nil, NewInvalidRequestError(err) + return capabilities.CapabilityRequest{}, nil, NewInvalidRequestError(err) } mc.TickInterval = ti } diff --git a/core/capabilities/compute/transformer_test.go b/core/capabilities/compute/transformer_test.go index 83131636462..ee77e20d6f6 100644 --- a/core/capabilities/compute/transformer_test.go +++ b/core/capabilities/compute/transformer_test.go @@ -4,6 +4,7 @@ import ( "testing" "time" + "github.com/smartcontractkit/chainlink-common/pkg/capabilities" "github.com/smartcontractkit/chainlink-common/pkg/custmsg" "github.com/smartcontractkit/chainlink-common/pkg/values" "github.com/smartcontractkit/chainlink-common/pkg/workflows/wasm/host" @@ -94,6 +95,9 @@ func Test_transformer(t *testing.T) { "binary": []byte{0x01, 0x02, 0x03}, "config": []byte{0x04, 0x05, 0x06}, }) + giveReq := capabilities.CapabilityRequest{ + Config: giveMap, + } require.NoError(t, err) wantTO := 4 * time.Second @@ -110,7 +114,7 @@ func Test_transformer(t *testing.T) { } tf := NewTransformer(lgger, emitter) - gotConfig, err := tf.Transform(giveMap) + _, gotConfig, err := tf.Transform(giveReq) require.NoError(t, err) assert.Equal(t, wantConfig, gotConfig) @@ -121,6 +125,9 @@ func Test_transformer(t *testing.T) { "binary": []byte{0x01, 0x02, 0x03}, "config": []byte{0x04, 0x05, 0x06}, }) + giveReq := capabilities.CapabilityRequest{ + Config: giveMap, + } require.NoError(t, err) wantConfig := &ParsedConfig{ @@ -133,7 +140,7 @@ func Test_transformer(t *testing.T) { } tf := NewTransformer(lgger, emitter) - gotConfig, err := tf.Transform(giveMap) + _, gotConfig, err := tf.Transform(giveReq) require.NoError(t, err) assert.Equal(t, wantConfig, gotConfig) @@ -145,10 +152,13 @@ func Test_transformer(t *testing.T) { "binary": []byte{0x01, 0x02, 0x03}, "config": []byte{0x04, 0x05, 0x06}, }) + giveReq := capabilities.CapabilityRequest{ + Config: giveMap, + } require.NoError(t, err) tf := NewTransformer(lgger, emitter) - _, err = tf.Transform(giveMap) + _, _, err = tf.Transform(giveReq) require.Error(t, err) require.ErrorContains(t, err, "invalid request") @@ -160,10 +170,13 @@ func Test_transformer(t *testing.T) { "binary": []byte{0x01, 0x02, 0x03}, "config": []byte{0x04, 0x05, 0x06}, }) + giveReq := capabilities.CapabilityRequest{ + Config: giveMap, + } require.NoError(t, err) tf := NewTransformer(lgger, emitter) - _, err = tf.Transform(giveMap) + _, _, err = tf.Transform(giveReq) require.Error(t, err) require.ErrorContains(t, err, "invalid request") diff --git a/core/scripts/go.mod b/core/scripts/go.mod index f0efc3cc962..48384b3ef30 100644 --- a/core/scripts/go.mod +++ b/core/scripts/go.mod @@ -24,7 +24,7 @@ require ( github.com/prometheus/client_golang v1.20.5 github.com/shopspring/decimal v1.4.0 github.com/smartcontractkit/chainlink-automation v0.8.1 - github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2 + github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b github.com/smartcontractkit/chainlink/deployment v0.0.0-00010101000000-000000000000 github.com/smartcontractkit/chainlink/v2 v2.0.0-00010101000000-000000000000 github.com/smartcontractkit/libocr v0.0.0-20241007185508-adbe57025f12 diff --git a/core/scripts/go.sum b/core/scripts/go.sum index 8606d483969..4c4f74a60ca 100644 --- a/core/scripts/go.sum +++ b/core/scripts/go.sum @@ -1092,8 +1092,8 @@ github.com/smartcontractkit/chainlink-automation v0.8.1 h1:sTc9LKpBvcKPc1JDYAmgB github.com/smartcontractkit/chainlink-automation v0.8.1/go.mod h1:Iij36PvWZ6blrdC5A/nrQUBuf3MH3JvsBB9sSyc9W08= github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422 h1:VfH/AW5NtTmroY9zz6OYCPFbFTqpMyJ2ubgT9ahYf3U= github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422/go.mod h1:4adKaHNaxFsRvV/lYfqtbsWyyvIPUMLR0FdOJN/ljis= -github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2 h1:sm8dL6NSFHmu2Bl17KhhfIwLQYWauxAFpBZ/w8WHuAA= -github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2/go.mod h1:ny87uTW6hLjCTLiBqBRNFEhETSXhHWevYlPclT5lSco= +github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b h1:szVkvEyvMgilD5GtkUygFZTvkNRoCCf+l+pRymfSc/0= +github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b/go.mod h1:ny87uTW6hLjCTLiBqBRNFEhETSXhHWevYlPclT5lSco= github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f h1:BwrIaQIx5Iy6eT+DfLhFfK2XqjxRm74mVdlX8gbu4dw= github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f/go.mod h1:wHtwSR3F1CQSJJZDQKuqaqFYnvkT+kMyget7dl8Clvo= github.com/smartcontractkit/chainlink-data-streams v0.1.1-0.20241018134907-a00ba3729b5e h1:JiETqdNM0bktAUGMc62COwXIaw3rR3M77Me6bBLG0Fg= diff --git a/deployment/go.mod b/deployment/go.mod index c659795a77f..ab26084fb33 100644 --- a/deployment/go.mod +++ b/deployment/go.mod @@ -24,7 +24,7 @@ require ( github.com/smartcontractkit/ccip-owner-contracts v0.0.0-20240926212305-a6deabdfce86 github.com/smartcontractkit/chain-selectors v1.0.27 github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422 - github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2 + github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b github.com/smartcontractkit/chainlink-protos/job-distributor v0.4.0 github.com/smartcontractkit/chainlink-testing-framework/lib v1.50.13 github.com/smartcontractkit/chainlink/v2 v2.0.0-00010101000000-000000000000 diff --git a/deployment/go.sum b/deployment/go.sum index 08402cd426d..f23e88eca2d 100644 --- a/deployment/go.sum +++ b/deployment/go.sum @@ -1384,8 +1384,8 @@ github.com/smartcontractkit/chainlink-automation v0.8.1 h1:sTc9LKpBvcKPc1JDYAmgB github.com/smartcontractkit/chainlink-automation v0.8.1/go.mod h1:Iij36PvWZ6blrdC5A/nrQUBuf3MH3JvsBB9sSyc9W08= github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422 h1:VfH/AW5NtTmroY9zz6OYCPFbFTqpMyJ2ubgT9ahYf3U= github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422/go.mod h1:4adKaHNaxFsRvV/lYfqtbsWyyvIPUMLR0FdOJN/ljis= -github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2 h1:sm8dL6NSFHmu2Bl17KhhfIwLQYWauxAFpBZ/w8WHuAA= -github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2/go.mod h1:ny87uTW6hLjCTLiBqBRNFEhETSXhHWevYlPclT5lSco= +github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b h1:szVkvEyvMgilD5GtkUygFZTvkNRoCCf+l+pRymfSc/0= +github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b/go.mod h1:ny87uTW6hLjCTLiBqBRNFEhETSXhHWevYlPclT5lSco= github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f h1:BwrIaQIx5Iy6eT+DfLhFfK2XqjxRm74mVdlX8gbu4dw= github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f/go.mod h1:wHtwSR3F1CQSJJZDQKuqaqFYnvkT+kMyget7dl8Clvo= github.com/smartcontractkit/chainlink-data-streams v0.1.1-0.20241018134907-a00ba3729b5e h1:JiETqdNM0bktAUGMc62COwXIaw3rR3M77Me6bBLG0Fg= diff --git a/go.mod b/go.mod index 2aa832aaf25..40209d9e1b5 100644 --- a/go.mod +++ b/go.mod @@ -77,7 +77,7 @@ require ( github.com/smartcontractkit/chain-selectors v1.0.27 github.com/smartcontractkit/chainlink-automation v0.8.1 github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422 - github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2 + github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f github.com/smartcontractkit/chainlink-data-streams v0.1.1-0.20241018134907-a00ba3729b5e github.com/smartcontractkit/chainlink-feeds v0.1.1 diff --git a/go.sum b/go.sum index 08609453b6c..f2a4d590712 100644 --- a/go.sum +++ b/go.sum @@ -1077,8 +1077,8 @@ github.com/smartcontractkit/chainlink-automation v0.8.1 h1:sTc9LKpBvcKPc1JDYAmgB github.com/smartcontractkit/chainlink-automation v0.8.1/go.mod h1:Iij36PvWZ6blrdC5A/nrQUBuf3MH3JvsBB9sSyc9W08= github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422 h1:VfH/AW5NtTmroY9zz6OYCPFbFTqpMyJ2ubgT9ahYf3U= github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422/go.mod h1:4adKaHNaxFsRvV/lYfqtbsWyyvIPUMLR0FdOJN/ljis= -github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2 h1:sm8dL6NSFHmu2Bl17KhhfIwLQYWauxAFpBZ/w8WHuAA= -github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2/go.mod h1:ny87uTW6hLjCTLiBqBRNFEhETSXhHWevYlPclT5lSco= +github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b h1:szVkvEyvMgilD5GtkUygFZTvkNRoCCf+l+pRymfSc/0= +github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b/go.mod h1:ny87uTW6hLjCTLiBqBRNFEhETSXhHWevYlPclT5lSco= github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f h1:BwrIaQIx5Iy6eT+DfLhFfK2XqjxRm74mVdlX8gbu4dw= github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f/go.mod h1:wHtwSR3F1CQSJJZDQKuqaqFYnvkT+kMyget7dl8Clvo= github.com/smartcontractkit/chainlink-data-streams v0.1.1-0.20241018134907-a00ba3729b5e h1:JiETqdNM0bktAUGMc62COwXIaw3rR3M77Me6bBLG0Fg= diff --git a/integration-tests/go.mod b/integration-tests/go.mod index 96e35773812..401c63aab8f 100644 --- a/integration-tests/go.mod +++ b/integration-tests/go.mod @@ -37,7 +37,7 @@ require ( github.com/smartcontractkit/chain-selectors v1.0.27 github.com/smartcontractkit/chainlink-automation v0.8.1 github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422 - github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2 + github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b github.com/smartcontractkit/chainlink-protos/job-distributor v0.4.0 github.com/smartcontractkit/chainlink-testing-framework/havoc v1.50.2 github.com/smartcontractkit/chainlink-testing-framework/lib v1.50.13 diff --git a/integration-tests/go.sum b/integration-tests/go.sum index 849746c7262..d45ef19de10 100644 --- a/integration-tests/go.sum +++ b/integration-tests/go.sum @@ -1405,8 +1405,8 @@ github.com/smartcontractkit/chainlink-automation v0.8.1 h1:sTc9LKpBvcKPc1JDYAmgB github.com/smartcontractkit/chainlink-automation v0.8.1/go.mod h1:Iij36PvWZ6blrdC5A/nrQUBuf3MH3JvsBB9sSyc9W08= github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422 h1:VfH/AW5NtTmroY9zz6OYCPFbFTqpMyJ2ubgT9ahYf3U= github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422/go.mod h1:4adKaHNaxFsRvV/lYfqtbsWyyvIPUMLR0FdOJN/ljis= -github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2 h1:sm8dL6NSFHmu2Bl17KhhfIwLQYWauxAFpBZ/w8WHuAA= -github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2/go.mod h1:ny87uTW6hLjCTLiBqBRNFEhETSXhHWevYlPclT5lSco= +github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b h1:szVkvEyvMgilD5GtkUygFZTvkNRoCCf+l+pRymfSc/0= +github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b/go.mod h1:ny87uTW6hLjCTLiBqBRNFEhETSXhHWevYlPclT5lSco= github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f h1:BwrIaQIx5Iy6eT+DfLhFfK2XqjxRm74mVdlX8gbu4dw= github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f/go.mod h1:wHtwSR3F1CQSJJZDQKuqaqFYnvkT+kMyget7dl8Clvo= github.com/smartcontractkit/chainlink-data-streams v0.1.1-0.20241018134907-a00ba3729b5e h1:JiETqdNM0bktAUGMc62COwXIaw3rR3M77Me6bBLG0Fg= diff --git a/integration-tests/load/go.mod b/integration-tests/load/go.mod index 0af0a8339fc..f8e3313d7a4 100644 --- a/integration-tests/load/go.mod +++ b/integration-tests/load/go.mod @@ -17,7 +17,7 @@ require ( github.com/pkg/errors v0.9.1 github.com/rs/zerolog v1.33.0 github.com/slack-go/slack v0.15.0 - github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2 + github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b github.com/smartcontractkit/chainlink-testing-framework/lib v1.50.13 github.com/smartcontractkit/chainlink-testing-framework/seth v1.50.5 github.com/smartcontractkit/chainlink-testing-framework/wasp v1.50.2 diff --git a/integration-tests/load/go.sum b/integration-tests/load/go.sum index 2f574a6a744..2c10fafd962 100644 --- a/integration-tests/load/go.sum +++ b/integration-tests/load/go.sum @@ -1394,8 +1394,8 @@ github.com/smartcontractkit/chainlink-automation v0.8.1 h1:sTc9LKpBvcKPc1JDYAmgB github.com/smartcontractkit/chainlink-automation v0.8.1/go.mod h1:Iij36PvWZ6blrdC5A/nrQUBuf3MH3JvsBB9sSyc9W08= github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422 h1:VfH/AW5NtTmroY9zz6OYCPFbFTqpMyJ2ubgT9ahYf3U= github.com/smartcontractkit/chainlink-ccip v0.0.0-20241106140121-4c9ee21ab422/go.mod h1:4adKaHNaxFsRvV/lYfqtbsWyyvIPUMLR0FdOJN/ljis= -github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2 h1:sm8dL6NSFHmu2Bl17KhhfIwLQYWauxAFpBZ/w8WHuAA= -github.com/smartcontractkit/chainlink-common v0.3.1-0.20241108204352-914b88b62cf2/go.mod h1:ny87uTW6hLjCTLiBqBRNFEhETSXhHWevYlPclT5lSco= +github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b h1:szVkvEyvMgilD5GtkUygFZTvkNRoCCf+l+pRymfSc/0= +github.com/smartcontractkit/chainlink-common v0.3.1-0.20241111094648-9c172120302b/go.mod h1:ny87uTW6hLjCTLiBqBRNFEhETSXhHWevYlPclT5lSco= github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f h1:BwrIaQIx5Iy6eT+DfLhFfK2XqjxRm74mVdlX8gbu4dw= github.com/smartcontractkit/chainlink-cosmos v0.5.2-0.20241017133723-5277829bd53f/go.mod h1:wHtwSR3F1CQSJJZDQKuqaqFYnvkT+kMyget7dl8Clvo= github.com/smartcontractkit/chainlink-data-streams v0.1.1-0.20241018134907-a00ba3729b5e h1:JiETqdNM0bktAUGMc62COwXIaw3rR3M77Me6bBLG0Fg=