Migrated CCIP PluginType from core

Author: amit-momin

pkg/loop/internal/pb/relayer.pb.go

@@ -61,6 +61,7 @@ message CCIPProviderArgs {
   bytes contractReaderConfig = 2;
   bytes chainWriterConfig = 3;
   string OffRampAddress = 4;
+  // pluginType is actually a uint8 but uint32 is the smallest supported by protobuf
   uint32 pluginType = 5;
   map<string, bytes> synced_addresses = 6; // map[contract_name]contract_address
   uint32 extraDataCodecBundleID = 7; // LOOP service ID for ExtraDataCodecBundle served by core node

pkg/loop/internal/pb/relayer.proto

@@ -33,6 +33,7 @@ import (
 	looptypes "github.com/smartcontractkit/chainlink-common/pkg/loop/internal/types"
 	"github.com/smartcontractkit/chainlink-common/pkg/types"
 	ccipocr3types "github.com/smartcontractkit/chainlink-common/pkg/types/ccipocr3"
+	cctypes "github.com/smartcontractkit/chainlink-common/pkg/types/ccipocr3"
 	"github.com/smartcontractkit/chainlink-common/pkg/types/core"
 )
 
@@ -314,7 +315,7 @@ func (r *relayerClient) NewCCIPProvider(ctx context.Context, cargs types.CCIPPro
 				ContractReaderConfig:   cargs.ContractReaderConfig,
 				ChainWriterConfig:      cargs.ChainWriterConfig,
 				OffRampAddress:         cargs.OffRampAddress,
-				PluginType:             cargs.PluginType,
+				PluginType:             uint32(cargs.PluginType),
 				SyncedAddresses:        persistedSyncs,
 				ExtraDataCodecBundleID: extraDataCodecBundleID,
 			},
@@ -762,7 +763,7 @@ func (r *relayerServer) NewCCIPProvider(ctx context.Context, request *pb.NewCCIP
 		ContractReaderConfig: rargs.ContractReaderConfig,
 		ChainWriterConfig:    rargs.ChainWriterConfig,
 		OffRampAddress:       rargs.OffRampAddress,
-		PluginType:           rargs.PluginType,
+		PluginType:           cctypes.PluginType(rargs.PluginType),
 		ExtraDataCodecBundle: extraDataCodecBundle,
 	}
 

pkg/loop/internal/relayer/relayer.go

@@ -31,6 +31,7 @@ import (
 	"github.com/smartcontractkit/chainlink-common/pkg/services"
 	"github.com/smartcontractkit/chainlink-common/pkg/services/servicetest"
 	"github.com/smartcontractkit/chainlink-common/pkg/types"
+	"github.com/smartcontractkit/chainlink-common/pkg/types/ccipocr3"
 	"github.com/smartcontractkit/chainlink-common/pkg/types/core"
 )
 
@@ -75,7 +76,7 @@ type staticRelayerConfig struct {
 	contractReaderConfig   []byte
 	chainWriterConfig      []byte
 	offRampAddress         string
-	pluginType             uint32
+	pluginType             ccipocr3.PluginType
 	medianProvider         testtypes.MedianProviderTester
 	agnosticProvider       testtypes.PluginProviderTester
 	mercuryProvider        mercurytest.MercuryProviderTester

pkg/loop/internal/relayer/test/relayer.go

@@ -374,3 +374,23 @@ func (ca ContractAddresses) Append(contract string, chain ChainSelector, address
 	resp[contract][chain] = address
 	return resp
 }
+
+// PluginType represents the type of CCIP plugin.
+// It mirrors the OCRPluginType in Internal.sol.
+type PluginType uint8
+
+const (
+	PluginTypeCCIPCommit PluginType = 0
+	PluginTypeCCIPExec   PluginType = 1
+)
+
+func (pt PluginType) String() string {
+	switch pt {
+	case PluginTypeCCIPCommit:
+		return "CCIPCommit"
+	case PluginTypeCCIPExec:
+		return "CCIPExec"
+	default:
+		return "Unknown"
+	}
+}

pkg/types/ccipocr3/generic_types.go

@@ -61,7 +61,7 @@ type CCIPProvider interface {
 type CCIPProviderArgs struct {
 	ExternalJobID  uuid.UUID
 	OffRampAddress string
-	PluginType     uint32
+	PluginType     ccipocr3.PluginType
 
 	// These CR/CW configs are only used by accessors that still rely on ChainReader
 	// and ChainWriter, like SolanaAccessor.