[CRE-491] Move self-contained folders to chainlink-evm (#265)

Author: pavel-raykov

go.mod

@@ -7,6 +7,7 @@ toolchain go1.24.7
 require (
 	github.com/ethereum/go-ethereum v1.16.2
 	github.com/fxamacker/cbor/v2 v2.7.0
+	github.com/go-viper/mapstructure/v2 v2.4.0
 	github.com/google/uuid v1.6.0
 	github.com/gorilla/websocket v1.5.3
 	github.com/jackc/pgconn v1.14.3
@@ -92,7 +93,6 @@ require (
 	github.com/go-playground/locales v0.14.1 // indirect
 	github.com/go-playground/universal-translator v0.18.1 // indirect
 	github.com/go-playground/validator/v10 v10.26.0 // indirect
-	github.com/go-viper/mapstructure/v2 v2.4.0 // indirect
 	github.com/goccy/go-json v0.10.5 // indirect
 	github.com/gofrs/flock v0.12.1 // indirect
 	github.com/gogo/protobuf v1.3.2 // indirect

pkg/.mockery.yaml

@@ -2,6 +2,7 @@ dir: "{{ .InterfaceDir }}/mocks"
 mockname: "{{ .InterfaceName }}"
 outpkg: mocks
 filename: "{{ .InterfaceName | snakecase }}.go"
+fail-on-missing: true
 packages:
   github.com/smartcontractkit/chainlink-framework/chains/heads:
     config:
@@ -25,7 +26,6 @@ packages:
       Workflow:
   github.com/smartcontractkit/chainlink-evm/pkg/gas:
     interfaces:
-      Config:
       EvmFeeEstimator:
       feeEstimatorClient:
         config:
@@ -43,10 +43,6 @@ packages:
   github.com/smartcontractkit/chainlink-evm/pkg/monitor:
     interfaces:
       BalanceMonitor:
-
-  github.com/smartcontractkit/chainlink-evm/pkg/writetarget:
-    interfaces:
-      ProductSpecificProcessor:
   github.com/smartcontractkit/chainlink-framework/multinode:
     config:
       dir: client/clienttest
@@ -63,6 +59,11 @@ packages:
       Client:
       TxStore:
       AttemptBuilder:
+  github.com/smartcontractkit/chainlink-framework/chains/txmgr:
+    config:
+      dir: txmgr/mocks
+    interfaces:
+      TxManager:
   github.com/smartcontractkit/chainlink-framework/chains/txmgr/types:
     config:
       dir: txmgr/mocks
@@ -85,4 +86,3 @@ packages:
       filename: "mock_{{ .InterfaceName | snakecase }}_test.go"
     interfaces:
       Emitter:
-

pkg/bindings/chain_config_factory.go

@@ -0,0 +1,42 @@
+package codec
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/ethereum/go-ethereum/common"
+
+	commontypes "github.com/smartcontractkit/chainlink-common/pkg/types"
+)
+
+// EVMAddressModifier implements the AddressModifier interface for Ethereum addresses.
+// It handles encoding and decoding Ethereum addresses with EIP-55 checksums and hex encoding.
+type EVMAddressModifier struct{}
+
+func (e EVMAddressModifier) EncodeAddress(bytes []byte) (string, error) {
+	if len(bytes) != e.Length() {
+		return "", fmt.Errorf("%w: got length %d, expected 20 for bytes %x", commontypes.ErrInvalidType, len(bytes), bytes)
+	}
+
+	return common.BytesToAddress(bytes).Hex(), nil
+}
+
+// DecodeAddress takes an EIP-55 encoded Ethereum address (e.g., "0x...") and decodes it to a 20-byte array.
+func (e EVMAddressModifier) DecodeAddress(str string) ([]byte, error) {
+	str = strings.TrimPrefix(str, "0x")
+	if len(str) != 40 {
+		return nil, fmt.Errorf("%w: got length %d, expected 40 for address %s", commontypes.ErrInvalidType, len(str), str)
+	}
+
+	address := common.HexToAddress(str)
+	if address == (common.Address{}) {
+		return nil, fmt.Errorf("%w: address is zero", commontypes.ErrInvalidType)
+	}
+
+	return address.Bytes(), nil
+}
+
+// Length returns the expected length of an Ethereum address in bytes (20 bytes).
+func (e EVMAddressModifier) Length() int {
+	return common.AddressLength
+}

pkg/bindings/chain_reader_tester.go

@@ -0,0 +1,54 @@
+package codec_test
+
+import (
+	"testing"
+
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/stretchr/testify/assert"
+	"github.com/stretchr/testify/require"
+
+	commontypes "github.com/smartcontractkit/chainlink-common/pkg/types"
+	"github.com/smartcontractkit/chainlink-evm/pkg/codec"
+)
+
+func TestEVMAddressModifier(t *testing.T) {
+	modifier := codec.EVMAddressModifier{}
+	validAddressStr := "0x5B38Da6a701c568545dCfcB03FcB875f56beddC4"
+	validAddressBytes := common.HexToAddress(validAddressStr).Bytes()
+	invalidLengthAddressStr := "0xabcdef1234567890abcdef"
+
+	t.Run("EncodeAddress encodes valid Ethereum address bytes", func(t *testing.T) {
+		encoded, err := modifier.EncodeAddress(validAddressBytes)
+		require.NoError(t, err)
+		assert.Equal(t, validAddressStr, encoded)
+	})
+
+	t.Run("EncodeAddress returns error for invalid byte length", func(t *testing.T) {
+		invalidBytes := []byte(invalidLengthAddressStr)
+		_, err := modifier.EncodeAddress(invalidBytes)
+		require.Error(t, err)
+		assert.Contains(t, err.Error(), commontypes.ErrInvalidType)
+	})
+
+	t.Run("DecodeAddress decodes valid Ethereum address", func(t *testing.T) {
+		decodedBytes, err := modifier.DecodeAddress(validAddressStr)
+		require.NoError(t, err)
+		assert.Equal(t, validAddressBytes, decodedBytes)
+	})
+
+	t.Run("DecodeAddress returns error for invalid address length", func(t *testing.T) {
+		_, err := modifier.DecodeAddress(invalidLengthAddressStr)
+		require.Error(t, err)
+		assert.Contains(t, err.Error(), commontypes.ErrInvalidType)
+	})
+
+	t.Run("DecodeAddress returns error for zero-value address", func(t *testing.T) {
+		_, err := modifier.DecodeAddress(common.Address{}.Hex())
+		require.Error(t, err)
+		assert.Contains(t, err.Error(), commontypes.ErrInvalidType)
+	})
+
+	t.Run("Length returns 20 for Ethereum addresses", func(t *testing.T) {
+		assert.Equal(t, common.AddressLength, modifier.Length())
+	})
+}