Solana offchain plugin

.changeset/mighty-waves-change.md

@@ -0,0 +1,5 @@
+---
+"chainlink": minor
+---
+
+add solana chain reader config support to plugin creator, remove evm specific code #added

.changeset/old-pets-divide.md

@@ -0,0 +1,5 @@
+---
+"chainlink": minor
+---
+
+Add solana chain writer config initialization #added

.changeset/rich-frogs-work.md

@@ -0,0 +1,5 @@
+---
+"chainlink": minor
+---
+
+Adding solana message hasher #added

.changeset/twelve-games-sneeze.md

@@ -0,0 +1,5 @@
+---
+"chainlink": minor
+---
+
+add Solana estimate provider as a no-op #added

.changeset/violet-bears-try.md

@@ -0,0 +1,5 @@
+---
+"chainlink": minor
+---
+
+Solana CCIP plugin codec support for both commit and execute report #added

.changeset/wise-items-brush.md

@@ -0,0 +1,5 @@
+---
+"chainlink": minor
+---
+
+Add solana support for contract transmitter and remove evm depdendency for address encoding #added

.github/actions/setup-solana/build-contracts/action.yml

@@ -31,14 +31,14 @@ runs:
         echo "ANCHOR_VERSION=${anchor}" >> $GITHUB_ENV
     - name: cache docker build image
       id: cache-image
-      uses: actions/cache@0c45773b623bea8c8e75f6c82b208c3cf94ea4f9 # v4.0.2
+      uses: actions/cache@v4 # v4.0.2
       with:
         lookup-only: true
         path: chains/solana/contracts/docker-build.tar
         key: ${{ runner.os }}-solana-build-${{ env.ANCHOR_VERSION }}-${{ hashFiles('**/Cargo.lock') }}
     - name: Cache cargo target dir
       id: cache-target
-      uses: actions/cache@0c45773b623bea8c8e75f6c82b208c3cf94ea4f9 # v4.0.2
+      uses: actions/cache@v4 # v4.0.2
       with:
         lookup-only: true
         path: chains/solana/contracts/target

core/capabilities/ccip/ccipevm/extradatadecoder.go

@@ -0,0 +1,56 @@
+package ccipevm
+
+import (
+	"fmt"
+
+	cciptypes "github.com/smartcontractkit/chainlink-ccip/pkg/types/ccipocr3"
+)
+
+func DecodeDestExecDataToMap(DestExecData cciptypes.Bytes) (map[string]interface{}, error) {
+	destGasAmount, err := abiDecodeUint32(DestExecData)
+	if err != nil {
+		return nil, fmt.Errorf("decode dest gas amount: %w", err)
+	}
+
+	return map[string]interface{}{
+		evmDestExecDataKey: destGasAmount,
+	}, nil
+}
+
+func DecodeExtraArgsToMap(extraArgs []byte) (map[string]any, error) {
+	if len(extraArgs) < 4 {
+		return nil, fmt.Errorf("extra args too short: %d, should be at least 4 (i.e the extraArgs tag)", len(extraArgs))
+	}
+
+	var method string
+	var extraByteOffset int
+	switch string(extraArgs[:4]) {
+	case string(evmExtraArgsV1Tag):
+		// for EVMExtraArgs, the first four bytes is the method name
+		method = evmV1DecodeName
+		extraByteOffset = 4
+	case string(evmExtraArgsV2Tag):
+		method = evmV2DecodeName
+		extraByteOffset = 4
+	case string(svmExtraArgsV1Tag):
+		// for SVMExtraArgs there's the four bytes plus another 32 bytes padding for the dynamic array
+		// TODO this is a temporary solution, the evm on-chain side will fix it, so the offset should just be 4 instead of 36
+		// https://smartcontract-it.atlassian.net/browse/BCI-4180
+		method = svmV1DecodeName
+		extraByteOffset = 36
+	default:
+		return nil, fmt.Errorf("unknown extra args tag: %x", extraArgs)
+	}
+
+	output := make(map[string]any)
+	args := make(map[string]interface{})
+	err := messageHasherABI.Methods[method].Inputs.UnpackIntoMap(args, extraArgs[extraByteOffset:])
+	if err != nil {
+		return nil, fmt.Errorf("abi decode extra args %v: %w", method, err)
+	}
+
+	for k, val := range args {
+		output[k] = val
+	}
+	return output, nil
+}

core/capabilities/ccip/ccipevm/extradatadecoder_test.go

@@ -0,0 +1,105 @@
+package ccipevm
+
+import (
+	"math/big"
+	"math/rand"
+	"testing"
+
+	"github.com/gagliardetto/solana-go"
+	"github.com/stretchr/testify/require"
+
+	"github.com/smartcontractkit/chainlink/v2/core/gethwrappers/ccip/generated/message_hasher"
+)
+
+func Test_decodeExtraData(t *testing.T) {
+	d := testSetup(t)
+	gasLimit := big.NewInt(rand.Int63())
+
+	t.Run("decode extra args into map evm v1", func(t *testing.T) {
+		encoded, err := d.contract.EncodeEVMExtraArgsV1(nil, message_hasher.ClientEVMExtraArgsV1{
+			GasLimit: gasLimit,
+		})
+		require.NoError(t, err)
+
+		m, err := DecodeExtraArgsToMap(encoded)
+		require.NoError(t, err)
+		require.Len(t, m, 1)
+
+		gl, exist := m["gasLimit"]
+		require.True(t, exist)
+		require.Equal(t, gl, gasLimit)
+	})
+
+	t.Run("decode extra args into map evm v2", func(t *testing.T) {
+		encoded, err := d.contract.EncodeEVMExtraArgsV2(nil, message_hasher.ClientEVMExtraArgsV2{
+			GasLimit:                 gasLimit,
+			AllowOutOfOrderExecution: true,
+		})
+		require.NoError(t, err)
+
+		m, err := DecodeExtraArgsToMap(encoded)
+		require.NoError(t, err)
+		require.Len(t, m, 2)
+
+		gl, exist := m["gasLimit"]
+		require.True(t, exist)
+		require.Equal(t, gl, gasLimit)
+
+		ooe, exist := m["allowOutOfOrderExecution"]
+		require.True(t, exist)
+		require.Equal(t, true, ooe)
+	})
+
+	t.Run("decode extra args into map svm", func(t *testing.T) {
+		key, err := solana.NewRandomPrivateKey()
+		require.NoError(t, err)
+		cu := uint32(10000)
+		bitmap := uint64(4)
+		ooe := false
+		tokenReceiver := [32]byte(key.PublicKey().Bytes())
+		accounts := [][32]byte{[32]byte(key.PublicKey().Bytes())}
+		decoded, err := d.contract.DecodeSVMExtraArgsV1(nil, cu, bitmap, ooe, tokenReceiver, accounts)
+		if err != nil {
+			return
+		}
+		encoded, err := d.contract.EncodeSVMExtraArgsV1(nil, decoded)
+		require.NoError(t, err)
+
+		m, err := DecodeExtraArgsToMap(encoded)
+		require.NoError(t, err)
+		require.Len(t, m, 5)
+
+		cuDecoded, exist := m["computeUnits"]
+		require.True(t, exist)
+		require.Equal(t, cuDecoded, cu)
+
+		bitmapDecoded, exist := m["accountIsWritableBitmap"]
+		require.True(t, exist)
+		require.Equal(t, bitmapDecoded, bitmap)
+
+		ooeDecoded, exist := m["allowOutOfOrderExecution"]
+		require.True(t, exist)
+		require.Equal(t, ooeDecoded, ooe)
+
+		tokenReceiverDecoded, exist := m["tokenReceiver"]
+		require.True(t, exist)
+		require.Equal(t, tokenReceiverDecoded, tokenReceiver)
+
+		accountsDecoded, exist := m["accounts"]
+		require.True(t, exist)
+		require.Equal(t, accountsDecoded, accounts)
+	})
+
+	t.Run("decode dest exec data into map", func(t *testing.T) {
+		destGasAmount := uint32(10000)
+		encoded, err := abiEncodeUint32(destGasAmount)
+		require.NoError(t, err)
+		m, err := DecodeDestExecDataToMap(encoded)
+		require.NoError(t, err)
+		require.Len(t, m, 1)
+
+		decoded, exist := m[evmDestExecDataKey]
+		require.True(t, exist)
+		require.Equal(t, destGasAmount, decoded)
+	})
+}

core/capabilities/ccip/ccipevm/helpers.go

@@ -8,6 +8,13 @@ import (
 	"github.com/ethereum/go-ethereum/accounts/abi"
 )
 
+const (
+	svmV1DecodeName    = "decodeSVMExtraArgsV1"
+	evmV1DecodeName    = "decodeEVMExtraArgsV1"
+	evmV2DecodeName    = "decodeEVMExtraArgsV2"
+	evmDestExecDataKey = "destGasAmount"
+)
+
 var (
 	abiUint32               = ABITypeOrPanic("uint32")
 	TokenDestGasOverheadABI = abi.Arguments{
@@ -24,9 +31,9 @@ func decodeExtraArgsV1V2(extraArgs []byte) (gasLimit *big.Int, err error) {
 
 	var method string
 	if bytes.Equal(extraArgs[:4], evmExtraArgsV1Tag) {
-		method = "decodeEVMExtraArgsV1"
+		method = evmV1DecodeName
 	} else if bytes.Equal(extraArgs[:4], evmExtraArgsV2Tag) {
-		method = "decodeEVMExtraArgsV2"
+		method = evmV2DecodeName
 	} else {
 		return nil, fmt.Errorf("unknown extra args tag: %x", extraArgs)
 	}

core/capabilities/ccip/ccipevm/helpers_test.go

@@ -38,4 +38,39 @@ func Test_decodeExtraArgs(t *testing.T) {
 
 		require.Equal(t, gasLimit, decodedGasLimit)
 	})
+
+	t.Run("decode extra args into map evm v1", func(t *testing.T) {
+		encoded, err := d.contract.EncodeEVMExtraArgsV1(nil, message_hasher.ClientEVMExtraArgsV1{
+			GasLimit: gasLimit,
+		})
+		require.NoError(t, err)
+
+		m, err := DecodeExtraArgsToMap(encoded)
+		require.NoError(t, err)
+		require.Len(t, m, 1)
+
+		gl, exist := m["gasLimit"]
+		require.True(t, exist)
+		require.Equal(t, gl, gasLimit)
+	})
+
+	t.Run("decode extra args into map evm v2", func(t *testing.T) {
+		encoded, err := d.contract.EncodeEVMExtraArgsV2(nil, message_hasher.ClientEVMExtraArgsV2{
+			GasLimit:                 gasLimit,
+			AllowOutOfOrderExecution: true,
+		})
+		require.NoError(t, err)
+
+		m, err := DecodeExtraArgsToMap(encoded)
+		require.NoError(t, err)
+		require.Len(t, m, 2)
+
+		gl, exist := m["gasLimit"]
+		require.True(t, exist)
+		require.Equal(t, gl, gasLimit)
+
+		ooe, exist := m["allowOutOfOrderExecution"]
+		require.True(t, exist)
+		require.Equal(t, true, ooe)
+	})
 }

core/capabilities/ccip/ccipevm/msghasher.go

@@ -30,6 +30,9 @@ var (
 
 	// bytes4 public constant EVM_EXTRA_ARGS_V2_TAG = 0x181dcf10;
 	evmExtraArgsV2Tag = hexutil.MustDecode("0x181dcf10")
+
+	// bytes4 public constant SVM_EXTRA_EXTRA_ARGS_V1_TAG = 0x1f3b3aba
+	svmExtraArgsV1Tag = hexutil.MustDecode("0x1f3b3aba")
 )
 
 // MessageHasherV1 implements the MessageHasher interface.