Update to log diffs twice, once with a call before and once after to …

…assure it's not a race

core/scripts/go.mod

@@ -240,7 +240,7 @@ require (
 	github.com/smartcontractkit/chainlink-common v0.1.7-0.20231218192030-a1f59aa9e04b // indirect
 	github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231128204301-ee4297eff679 // indirect
 	github.com/smartcontractkit/chainlink-data-streams v0.0.0-20231204152908-a6e3fe8ff2a1 // indirect
-	github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219162622-65fbe284d4cc // indirect
+	github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219191350-07dbf91e3312 // indirect
 	github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231130211003-6d1bb2f0b68a // indirect
 	github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231128204445-3d61b12a0006 // indirect
 	github.com/smartcontractkit/tdh2/go/ocr2/decryptionplugin v0.0.0-20230906073235-9e478e5e19f1 // indirect

core/scripts/go.sum

@@ -1154,8 +1154,8 @@ github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231128204301-ee4297eff67
 github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231128204301-ee4297eff679/go.mod h1:2Jx7bTEk4ujFQdsZpZq3A0BydvaVPs6mX8clUfxHOEM=
 github.com/smartcontractkit/chainlink-data-streams v0.0.0-20231204152908-a6e3fe8ff2a1 h1:xYqRgZO0nMSO8CBCMR0r3WA+LZ4kNL8a6bnbyk/oBtQ=
 github.com/smartcontractkit/chainlink-data-streams v0.0.0-20231204152908-a6e3fe8ff2a1/go.mod h1:GuPvyXryvbiUZIHmPeLBz4L+yJKeyGUjrDfd1KNne+o=
-github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219162622-65fbe284d4cc h1:HVAgxAP48Z5+Sp+rSRXaF0bPrbYJQLNTgh3uIq3SqOE=
-github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219162622-65fbe284d4cc/go.mod h1:Mr81s6sKCXcIyxv6cJ4OOPEdbxLCY6BkO7NiP26AOJ0=
+github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219191350-07dbf91e3312 h1:PmJRQUEd46glRHQWCrMyRTWfTocG5SlMovIOei25+ho=
+github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219191350-07dbf91e3312/go.mod h1:Mr81s6sKCXcIyxv6cJ4OOPEdbxLCY6BkO7NiP26AOJ0=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231130211003-6d1bb2f0b68a h1:JoyTazNcqXvZoMQjNfB0eapnlaoMS6pI0NeRvouRvog=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231130211003-6d1bb2f0b68a/go.mod h1:rioELYwPY2xBtzPRN/D08Y7iTPbIQEjPknYdJK51CzQ=
 github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231128204445-3d61b12a0006 h1:1GzOKT53e8N7ZPwsyf1hSbKsynZmXmLOIL3DMvGq9sc=

core/services/relay/evm/chain_reader.go

@@ -3,7 +3,6 @@ package evm
 import (
 	"context"
 	"fmt"
-	"runtime"
 	"strings"
 
 	"github.com/ethereum/go-ethereum"
@@ -48,7 +47,7 @@ func NewChainReaderService(lggr logger.Logger, lp logpoller.LogPoller, b Binding
 		return nil, err
 	}
 
-	c, err := parsed.toCodec()
+	c, err := parsed.toCodec(lggr)
 
 	return &chainReader{
 		lggr:     lggr.Named("ChainReader"),
@@ -64,10 +63,7 @@ func (cr *chainReader) Name() string { return cr.lggr.Name() }
 var _ commontypes.ContractTypeProvider = &chainReader{}
 
 func (cr *chainReader) GetLatestValue(ctx context.Context, contractName, method string, params any, returnVal any) error {
-	b := make([]byte, 2048) // adjust buffer size to be larger than expected stack
-	n := runtime.Stack(b, false)
-	s := string(b[:n])
-	cr.lggr.Infof("!!!!!!!!!!\nEVM CR\n%s.%s\n%#v\n%s\n!!!!!!!!!!\n", contractName, method, params, s)
+	cr.lggr.Infof("!!!!!!!!!!\nEVM CR\n%s.%s\n%#v\n%s\n!!!!!!!!!!\n", contractName, method, params)
 	ae, err := cr.bindings.getBinding(contractName, method, false)
 	if err != nil {
 		cr.lggr.Errorf("!!!!!!!!!!\nEVM CR err:\n%v\n!!!!!!!!!!\n", err)

core/services/relay/evm/codec.go

@@ -15,6 +15,7 @@ import (
 
 	commontypes "github.com/smartcontractkit/chainlink-common/pkg/types"
 
+	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/types"
 )
 
@@ -27,7 +28,7 @@ import (
 // it was a *big.Int
 var evmDecoderHooks = []mapstructure.DecodeHookFunc{decodeAccountHook, codec.EpochToTimeHook, codec.BigIntHook, codec.SliceToArrayVerifySizeHook, sizeVerifyBigIntHook}
 
-func NewCodec(conf types.CodecConfig) (commontypes.RemoteCodec, error) {
+func NewCodec(conf types.CodecConfig, lggr logger.Logger) (commontypes.RemoteCodec, error) {
 	fmt.Printf("!!!!!!!!!!\nNewCodec\n%#v\n!!!!!!!!!!\n", conf.ChainCodecConfigs)
 	parsed := &parsedTypes{
 		encoderDefs: map[string]*codecEntry{},
@@ -57,7 +58,7 @@ func NewCodec(conf types.CodecConfig) (commontypes.RemoteCodec, error) {
 		parsed.decoderDefs[k] = item
 	}
 
-	return parsed.toCodec()
+	return parsed.toCodec(lggr)
 }
 
 type evmCodec struct {

core/services/relay/evm/decoder.go

@@ -2,32 +2,33 @@ package evm
 
 import (
 	"context"
-	"fmt"
 	"reflect"
-	"runtime"
 
 	"github.com/mitchellh/mapstructure"
 
 	commontypes "github.com/smartcontractkit/chainlink-common/pkg/types"
+
+	"github.com/smartcontractkit/chainlink/v2/core/logger"
 )
 
 type decoder struct {
 	Definitions map[string]*codecEntry
+	lggr        logger.Logger
 }
 
 var _ commontypes.Decoder = &decoder{}
 
 func (m *decoder) Decode(ctx context.Context, raw []byte, into any, itemType string) error {
-	fmt.Printf("!!!!!!!!!!\nDecode\n%s\n!!!!!!!!!!\n", itemType)
+	m.lggr.Infof("!!!!!!!!!!\nDecode\n%s\n!!!!!!!!!!\n", itemType)
 	info, ok := m.Definitions[itemType]
 	if !ok {
-		fmt.Printf("!!!!!!!!!!\nDecode err not found type\n%s\n!!!!!!!!!!\n", itemType)
+		m.lggr.Errorf("!!!!!!!!!!\nDecode err not found type\n%s\n!!!!!!!!!!\n", itemType)
 		return commontypes.ErrInvalidType
 	}
 
 	decode, err := extractDecoding(info, raw)
 	if err != nil {
-		fmt.Printf("!!!!!!!!!!\nDecode err: %v\n%s\n!!!!!!!!!!\n", err, itemType)
+		m.lggr.Errorf("!!!!!!!!!!\nDecode err: %v\n%s\n!!!!!!!!!!\n", err, itemType)
 		return err
 	}
 
@@ -40,22 +41,19 @@ func (m *decoder) Decode(ctx context.Context, raw []byte, into any, itemType str
 			return commontypes.ErrWrongNumberOfElements
 		}
 		iInto.Set(reflect.New(iInto.Type()).Elem())
-		return setElements(length, rDecode, iInto)
+		return setElements(length, rDecode, iInto, m.lggr)
 	case reflect.Slice:
 		iInto := reflect.Indirect(reflect.ValueOf(into))
 		length := rDecode.Len()
 		iInto.Set(reflect.MakeSlice(iInto.Type(), length, length))
-		return setElements(length, rDecode, iInto)
+		return setElements(length, rDecode, iInto, m.lggr)
 	default:
-		return mapstructureDecode(decode, into)
+		return mapstructureDecode(decode, into, m.lggr)
 	}
 }
 
 func (m *decoder) GetMaxDecodingSize(ctx context.Context, n int, itemType string) (int, error) {
-	b := make([]byte, 2048) // adjust buffer size to be larger than expected stack
-	nb := runtime.Stack(b, false)
-	s := string(b[:nb])
-	fmt.Printf("!!!!!!!!!!\nGetMaxDecodingSize\n%s\n\n%v\n%s!!!!!!!!!!\n", itemType, m.Definitions, s)
+	m.lggr.Infof("!!!!!!!!!!\nGetMaxDecodingSize\n%s\n\n%v\n!!!!!!!!!!\n", itemType, m.Definitions)
 
 	return m.Definitions[itemType].GetMaxSize(n)
 }
@@ -73,26 +71,26 @@ func extractDecoding(info *codecEntry, raw []byte) (any, error) {
 	return decode, nil
 }
 
-func setElements(length int, rDecode reflect.Value, iInto reflect.Value) error {
+func setElements(length int, rDecode reflect.Value, iInto reflect.Value, lggr logger.Logger) error {
 	for i := 0; i < length; i++ {
-		if err := mapstructureDecode(rDecode.Index(i).Interface(), iInto.Index(i).Addr().Interface()); err != nil {
+		if err := mapstructureDecode(rDecode.Index(i).Interface(), iInto.Index(i).Addr().Interface(), lggr); err != nil {
 			return err
 		}
 	}
 
 	return nil
 }
 
-func mapstructureDecode(src, dest any) error {
+func mapstructureDecode(src, dest any, lggr logger.Logger) error {
 	mDecoder, err := mapstructure.NewDecoder(&mapstructure.DecoderConfig{
 		DecodeHook: mapstructure.ComposeDecodeHookFunc(evmDecoderHooks...),
 		Result:     dest,
 		Squash:     true,
 	})
 	if err != nil || mDecoder.Decode(src) != nil {
-		fmt.Printf("!!!!!!!!!!\nDecode item error: %v\n%v\n!!!!!!!!!!\n", err, mDecoder.Decode(src))
+		lggr.Errorf("!!!!!!!!!!\nDecode item error: %v\n%v\n!!!!!!!!!!\n", err, mDecoder.Decode(src))
 		return commontypes.ErrInvalidType
 	}
-	fmt.Printf("!!!!!!!!!!\nDecode item success\n%#v\n%#v\n!!!!!!!!!!\n", dest, src)
+	lggr.Infof("!!!!!!!!!!\nDecode item success\n%#v\n%#v\n!!!!!!!!!!\n", dest, src)
 	return nil
 }

core/services/relay/evm/encoder.go

@@ -2,24 +2,25 @@ package evm
 
 import (
 	"context"
-	"fmt"
 	"reflect"
-	"runtime"
 
 	commontypes "github.com/smartcontractkit/chainlink-common/pkg/types"
+
+	"github.com/smartcontractkit/chainlink/v2/core/logger"
 )
 
 type encoder struct {
 	Definitions map[string]*codecEntry
+	lggr        logger.Logger
 }
 
 var _ commontypes.Encoder = &encoder{}
 
 func (e *encoder) Encode(ctx context.Context, item any, itemType string) ([]byte, error) {
-	fmt.Printf("!!!!!!!!!!\nEncode: %#v\n%s\n!!!!!!!!!!\n", item, itemType)
+	e.lggr.Infof("!!!!!!!!!!\nEncode: %#v\n%s\n!!!!!!!!!!\n", item, itemType)
 	info, ok := e.Definitions[itemType]
 	if !ok {
-		fmt.Printf("!!!!!!!!!!\nEncode error not found\n%s\n!!!!!!!!!!\n", itemType)
+		e.lggr.Errorf("!!!!!!!!!!\nEncode error not found\n%s\n!!!!!!!!!!\n", itemType)
 		return nil, commontypes.ErrInvalidType
 	}
 
@@ -29,38 +30,35 @@ func (e *encoder) Encode(ctx context.Context, item any, itemType string) ([]byte
 		return cpy, nil
 	}
 
-	b, err := encode(reflect.ValueOf(item), info)
+	b, err := encode(reflect.ValueOf(item), info, e.lggr)
 	if err == nil {
-		fmt.Printf("!!!!!!!!!!\nEncode success\n%s\n!!!!!!!!!!\n", itemType)
+		e.lggr.Infof("!!!!!!!!!!\nEncode success\n%s\n!!!!!!!!!!\n", itemType)
 	} else {
-		fmt.Printf("!!!!!!!!!!\nEncode error\n%v\n%s\n!!!!!!!!!!\n", err, itemType)
+		e.lggr.Errorf("!!!!!!!!!!\nEncode error\n%v\n%s\n!!!!!!!!!!\n", err, itemType)
 	}
 	return b, err
 }
 
 func (e *encoder) GetMaxEncodingSize(ctx context.Context, n int, itemType string) (int, error) {
-	b := make([]byte, 2048) // adjust buffer size to be larger than expected stack
-	nb := runtime.Stack(b, false)
-	s := string(b[:nb])
-	fmt.Printf("!!!!!!!!!!\nGetMaxEncodingSize\n%s\n\n%v\n%s!!!!!!!!!!\n", itemType, e.Definitions, s)
+	e.lggr.Infof("!!!!!!!!!!\nGetMaxEncodingSize\n%s\n\n%v\n!!!!!!!!!!\n", itemType, e.Definitions)
 	return e.Definitions[itemType].GetMaxSize(n)
 }
 
-func encode(item reflect.Value, info *codecEntry) ([]byte, error) {
+func encode(item reflect.Value, info *codecEntry, lggr logger.Logger) ([]byte, error) {
 	for item.Kind() == reflect.Pointer {
 		item = reflect.Indirect(item)
 	}
 	switch item.Kind() {
 	case reflect.Array, reflect.Slice:
-		return encodeArray(item, info)
+		return encodeArray(item, info, lggr)
 	case reflect.Struct, reflect.Map:
-		return encodeItem(item, info)
+		return encodeItem(item, info, lggr)
 	default:
 		return nil, commontypes.ErrInvalidEncoding
 	}
 }
 
-func encodeArray(item reflect.Value, info *codecEntry) ([]byte, error) {
+func encodeArray(item reflect.Value, info *codecEntry, lggr logger.Logger) ([]byte, error) {
 	length := item.Len()
 	var native reflect.Value
 	switch info.checkedType.Kind() {
@@ -79,7 +77,7 @@ func encodeArray(item reflect.Value, info *codecEntry) ([]byte, error) {
 	nativeElm := info.nativeType.Elem()
 	for i := 0; i < length; i++ {
 		tmp := reflect.New(checkedElm)
-		if err := mapstructureDecode(item.Index(i).Interface(), tmp.Interface()); err != nil {
+		if err := mapstructureDecode(item.Index(i).Interface(), tmp.Interface(), lggr); err != nil {
 			return nil, err
 		}
 		native.Index(i).Set(reflect.NewAt(nativeElm, tmp.UnsafePointer()).Elem())
@@ -88,12 +86,12 @@ func encodeArray(item reflect.Value, info *codecEntry) ([]byte, error) {
 	return pack(info, native.Interface())
 }
 
-func encodeItem(item reflect.Value, info *codecEntry) ([]byte, error) {
+func encodeItem(item reflect.Value, info *codecEntry, lggr logger.Logger) ([]byte, error) {
 	if item.Type() == reflect.PointerTo(info.checkedType) {
 		item = reflect.NewAt(info.nativeType, item.UnsafePointer())
 	} else if item.Type() != reflect.PointerTo(info.nativeType) {
 		checked := reflect.New(info.checkedType)
-		if err := mapstructureDecode(item.Interface(), checked.Interface()); err != nil {
+		if err := mapstructureDecode(item.Interface(), checked.Interface(), lggr); err != nil {
 			return nil, err
 		}
 		item = reflect.NewAt(info.nativeType, checked.UnsafePointer())

core/services/relay/evm/evm.go

@@ -516,7 +516,7 @@ func (r *Relayer) NewMedianProvider(rargs commontypes.RelayArgs, pargs commontyp
 
 	if relayConfig.Codec != nil {
 		lggr.Infof("!!!!!!!!\nCodec config found\n%#v\n!!!!!!!!\n", relayConfig.Codec)
-		medianProvider.codec, err = NewCodec(*relayConfig.Codec)
+		medianProvider.codec, err = NewCodec(*relayConfig.Codec, lggr)
 		if err != nil {
 			lggr.Infof("!!!!!!!!\nfailed to make new codec\n%v\n!!!!!!!!\n", err)
 			return nil, err

core/services/relay/evm/parsed_types.go

@@ -6,36 +6,38 @@ import (
 
 	"github.com/smartcontractkit/chainlink-common/pkg/codec"
 	commontypes "github.com/smartcontractkit/chainlink-common/pkg/types"
+
+	"github.com/smartcontractkit/chainlink/v2/core/logger"
 )
 
 type parsedTypes struct {
 	encoderDefs map[string]*codecEntry
 	decoderDefs map[string]*codecEntry
 }
 
-func (parsed *parsedTypes) toCodec() (commontypes.RemoteCodec, error) {
+func (parsed *parsedTypes) toCodec(lggr logger.Logger) (commontypes.RemoteCodec, error) {
 	modByTypeName := map[string]codec.Modifier{}
 	if err := addEntries(parsed.encoderDefs, modByTypeName); err != nil {
-		fmt.Printf("!!!!!!!!!!\nto codec add encoder entries err\n%#v\n!!!!!!!!!!\n%", err)
+		lggr.Errorf("!!!!!!!!!!\nto codec add encoder entries err\n%#v\n!!!!!!!!!!\n%", err)
 		return nil, err
 	}
 	if err := addEntries(parsed.decoderDefs, modByTypeName); err != nil {
-		fmt.Printf("!!!!!!!!!!\nto codec add decoder entries err\n%#v\n!!!!!!!!!!\n%", err)
+		lggr.Errorf("!!!!!!!!!!\nto codec add decoder entries err\n%#v\n!!!!!!!!!!\n%", err)
 		return nil, err
 	}
 
 	mod, err := codec.NewByItemTypeModifier(modByTypeName)
 	if err != nil {
-		fmt.Printf("!!!!!!!!!!\nto codec mod by type err\n%#v\n!!!!!!!!!!\n%", err)
+		lggr.Errorf("!!!!!!!!!!\nto codec mod by type err\n%#v\n!!!!!!!!!!\n%", err)
 		return nil, err
 	}
 	underlying := &evmCodec{
-		encoder:     &encoder{Definitions: parsed.encoderDefs},
-		decoder:     &decoder{Definitions: parsed.decoderDefs},
+		encoder:     &encoder{Definitions: parsed.encoderDefs, lggr: lggr},
+		decoder:     &decoder{Definitions: parsed.decoderDefs, lggr: lggr},
 		parsedTypes: parsed,
 	}
 	mc, err := codec.NewModifierCodec(underlying, mod, evmDecoderHooks...)
-	fmt.Printf("!!!!!!!!!!\nnow modifier codec: has error?\n%v\n%#v\n!!!!!!!!!!\n%", err != nil, err)
+	lggr.Errorf("!!!!!!!!!!\nnow modifier codec: has error?\n%v\n%#v\n!!!!!!!!!!\n%", err != nil, err)
 	return mc, err
 }
 

go.mod

@@ -68,7 +68,7 @@ require (
 	github.com/smartcontractkit/chainlink-common v0.1.7-0.20231218192030-a1f59aa9e04b
 	github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231128204301-ee4297eff679
 	github.com/smartcontractkit/chainlink-data-streams v0.0.0-20231204152908-a6e3fe8ff2a1
-	github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219162622-65fbe284d4cc
+	github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219191350-07dbf91e3312
 	github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231130211003-6d1bb2f0b68a
 	github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231128204445-3d61b12a0006
 	github.com/smartcontractkit/chainlink-vrf v0.0.0-20231120191722-fef03814f868

go.sum

@@ -1142,8 +1142,8 @@ github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231128204301-ee4297eff67
 github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231128204301-ee4297eff679/go.mod h1:2Jx7bTEk4ujFQdsZpZq3A0BydvaVPs6mX8clUfxHOEM=
 github.com/smartcontractkit/chainlink-data-streams v0.0.0-20231204152908-a6e3fe8ff2a1 h1:xYqRgZO0nMSO8CBCMR0r3WA+LZ4kNL8a6bnbyk/oBtQ=
 github.com/smartcontractkit/chainlink-data-streams v0.0.0-20231204152908-a6e3fe8ff2a1/go.mod h1:GuPvyXryvbiUZIHmPeLBz4L+yJKeyGUjrDfd1KNne+o=
-github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219162622-65fbe284d4cc h1:HVAgxAP48Z5+Sp+rSRXaF0bPrbYJQLNTgh3uIq3SqOE=
-github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219162622-65fbe284d4cc/go.mod h1:Mr81s6sKCXcIyxv6cJ4OOPEdbxLCY6BkO7NiP26AOJ0=
+github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219191350-07dbf91e3312 h1:PmJRQUEd46glRHQWCrMyRTWfTocG5SlMovIOei25+ho=
+github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219191350-07dbf91e3312/go.mod h1:Mr81s6sKCXcIyxv6cJ4OOPEdbxLCY6BkO7NiP26AOJ0=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231130211003-6d1bb2f0b68a h1:JoyTazNcqXvZoMQjNfB0eapnlaoMS6pI0NeRvouRvog=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231130211003-6d1bb2f0b68a/go.mod h1:rioELYwPY2xBtzPRN/D08Y7iTPbIQEjPknYdJK51CzQ=
 github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231128204445-3d61b12a0006 h1:1GzOKT53e8N7ZPwsyf1hSbKsynZmXmLOIL3DMvGq9sc=

integration-tests/go.mod

@@ -347,7 +347,7 @@ require (
 	github.com/smartcontractkit/caigo v0.0.0-20230621050857-b29a4ca8c704 // indirect
 	github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231128204301-ee4297eff679 // indirect
 	github.com/smartcontractkit/chainlink-data-streams v0.0.0-20231204152908-a6e3fe8ff2a1 // indirect
-	github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219162622-65fbe284d4cc // indirect
+	github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219191350-07dbf91e3312 // indirect
 	github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231130211003-6d1bb2f0b68a // indirect
 	github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231128204445-3d61b12a0006 // indirect
 	github.com/smartcontractkit/tdh2/go/ocr2/decryptionplugin v0.0.0-20230906073235-9e478e5e19f1 // indirect

integration-tests/go.sum

@@ -1438,8 +1438,8 @@ github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231128204301-ee4297eff67
 github.com/smartcontractkit/chainlink-cosmos v0.4.1-0.20231128204301-ee4297eff679/go.mod h1:2Jx7bTEk4ujFQdsZpZq3A0BydvaVPs6mX8clUfxHOEM=
 github.com/smartcontractkit/chainlink-data-streams v0.0.0-20231204152908-a6e3fe8ff2a1 h1:xYqRgZO0nMSO8CBCMR0r3WA+LZ4kNL8a6bnbyk/oBtQ=
 github.com/smartcontractkit/chainlink-data-streams v0.0.0-20231204152908-a6e3fe8ff2a1/go.mod h1:GuPvyXryvbiUZIHmPeLBz4L+yJKeyGUjrDfd1KNne+o=
-github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219162622-65fbe284d4cc h1:HVAgxAP48Z5+Sp+rSRXaF0bPrbYJQLNTgh3uIq3SqOE=
-github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219162622-65fbe284d4cc/go.mod h1:Mr81s6sKCXcIyxv6cJ4OOPEdbxLCY6BkO7NiP26AOJ0=
+github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219191350-07dbf91e3312 h1:PmJRQUEd46glRHQWCrMyRTWfTocG5SlMovIOei25+ho=
+github.com/smartcontractkit/chainlink-feeds v0.0.0-20231219191350-07dbf91e3312/go.mod h1:Mr81s6sKCXcIyxv6cJ4OOPEdbxLCY6BkO7NiP26AOJ0=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231130211003-6d1bb2f0b68a h1:JoyTazNcqXvZoMQjNfB0eapnlaoMS6pI0NeRvouRvog=
 github.com/smartcontractkit/chainlink-solana v1.0.3-0.20231130211003-6d1bb2f0b68a/go.mod h1:rioELYwPY2xBtzPRN/D08Y7iTPbIQEjPknYdJK51CzQ=
 github.com/smartcontractkit/chainlink-starknet/relayer v0.0.1-beta-test.0.20231128204445-3d61b12a0006 h1:1GzOKT53e8N7ZPwsyf1hSbKsynZmXmLOIL3DMvGq9sc=

integration-tests/smoke/chain_reader_and_codec_test.go

@@ -86,7 +86,7 @@ func TestOCRv2BasicWithChainReaderAndCodec(t *testing.T) {
 	require.NoError(t, err, "Error configuring OCRv2 aggregator contracts")
 	fmt.Println("built agg")
 
-	err = actions.StartNewOCR2Round(1, aggregatorContracts, env.EVMClient, time.Minute*10, l)
+	err = actions.StartNewOCR2Round(1, aggregatorContracts, env.EVMClient, time.Minute*5, l)
 
 	require.NoError(t, err, "Error starting new OCR2 round")
 	fmt.Println("round done")
@@ -105,7 +105,7 @@ func TestOCRv2BasicWithChainReaderAndCodec(t *testing.T) {
 	require.NoError(t, err)
 	fmt.Println("adapter")
 
-	err = actions.StartNewOCR2Round(2, aggregatorContracts, env.EVMClient, time.Minute*10, l)
+	err = actions.StartNewOCR2Round(2, aggregatorContracts, env.EVMClient, time.Minute*5, l)
 	require.NoError(t, err)
 	fmt.Println("new round 2")