Custom message handler and decoders

abi-bindings/eventimporter/pack.go

@@ -0,0 +1,26 @@
+// (c) 2023, Ava Labs, Inc. All rights reserved.
+// See the file LICENSE for licensing terms.
+
+package eventimporter
+
+import (
+	"math/big"
+
+	"github.com/ethereum/go-ethereum/common"
+	"github.com/pkg/errors"
+)
+
+// PackImportEvent packs input to form a call to the importEvent function
+func PackImportEvent(
+	blockHeader []byte,
+	txIndex *big.Int,
+	receiptProof [][]byte,
+	logIndex *big.Int,
+) ([]byte, error) {
+	abi, err := EventImporterMetaData.GetAbi()
+	if err != nil {
+		return nil, errors.Wrap(err, "failed to get abi")
+	}
+
+	return abi.Pack("importEvent", common.Hash{}, blockHeader, txIndex, receiptProof, logIndex)
+}

messages/chainlink/config.go

@@ -0,0 +1,52 @@
+package chainlink
+
+import (
+	"fmt"
+	"strconv"
+
+	"github.com/ava-labs/avalanchego/ids"
+	"github.com/ethereum/go-ethereum/common"
+)
+
+type RawConfig struct {
+	AggregatorsToReplicas   map[string]string `json:"aggregators-to-replicas"`
+	MaxFilterAdresses       string            `json:"max-filter-addresses"`
+	DestinationBlockchainID string            `json:"destination-blockchain-id"`
+}
+
+type Config struct {
+	AggregatorsToReplicas   map[common.Address]common.Address
+	MaxFilterAdresses       uint64
+	DestinationBlockchainID ids.ID
+}
+
+func (c *RawConfig) Parse() (*Config, error) {
+	maxFilterAdresses, err := strconv.ParseUint(c.MaxFilterAdresses, 10, 64)
+	if err != nil {
+		return nil, fmt.Errorf("invalid integer for max-filter-addresses cannot be parsed to uint64: %s", c.MaxFilterAdresses)
+	}
+	aggregatorToReplicas := make(map[common.Address]common.Address, 0)
+	for aggregator, replica := range c.AggregatorsToReplicas {
+		if !common.IsHexAddress(aggregator) {
+			return nil, fmt.Errorf("invalid price feed aggregator address for EVM source subnet: %s", aggregator)
+		}
+		if !common.IsHexAddress(replica) {
+			return nil, fmt.Errorf("invalid price feed replica address for EVM source subnet: %s", replica)
+		}
+		aggregator, replica := common.HexToAddress(aggregator), common.HexToAddress(replica)
+		if _, ok := aggregatorToReplicas[aggregator]; ok {
+			return nil, fmt.Errorf("duplicate aggregator entry for %s", aggregator)
+		}
+		aggregatorToReplicas[aggregator] = replica
+	}
+	destinationBlockchainID, err := ids.FromString(c.DestinationBlockchainID)
+	if err != nil {
+		return nil, err
+	}
+	config := Config{
+		AggregatorsToReplicas:   aggregatorToReplicas,
+		MaxFilterAdresses:       maxFilterAdresses,
+		DestinationBlockchainID: destinationBlockchainID,
+	}
+	return &config, nil
+}