Added transmitter field to CCIP provider args

Author: amit-momin

pkg/loop/ccip_provider_test.go

@@ -58,6 +58,7 @@ func TestCCIPChainAccessorSyncPersistence(t *testing.T) {
 		ChainWriterConfig:    []byte("asdf"),
 		OffRampAddress:       "0x1234123412341234123412341234123412341234",
 		PluginType:           0,
+		Transmitter:          "0x4321432143214321432143214321432143214321",
 	})
 	require.NoError(t, err)
 	require.NotNil(t, ccipProvider)

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

@@ -64,6 +64,7 @@ message CCIPProviderArgs {
   // 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
+  string transmitter = 7;
 }
 
 // NewContractWriterRequest has request parameters for [github.com/smartcontractkit/chainlink-common/pkg/loop.Relayer.NewContractWriter].

pkg/loop/internal/pb/relayer.proto

@@ -301,6 +301,7 @@ func (r *relayerClient) NewCCIPProvider(ctx context.Context, cargs types.CCIPPro
 				OffRampAddress:       cargs.OffRampAddress,
 				PluginType:           uint32(cargs.PluginType),
 				SyncedAddresses:      persistedSyncs,
+				Transmitter:          cargs.Transmitter,
 			},
 		})
 		if err != nil {
@@ -733,6 +734,7 @@ func (r *relayerServer) NewCCIPProvider(ctx context.Context, request *pb.NewCCIP
 		ChainWriterConfig:    rargs.ChainWriterConfig,
 		OffRampAddress:       rargs.OffRampAddress,
 		PluginType:           cctypes.PluginType(rargs.PluginType),
+		Transmitter:          rargs.Transmitter,
 	}
 
 	provider, err := r.impl.NewCCIPProvider(ctx, ccipProviderArgs)

pkg/loop/internal/relayer/relayer.go

@@ -77,6 +77,7 @@ type staticRelayerConfig struct {
 	chainWriterConfig      []byte
 	offRampAddress         string
 	pluginType             ccipocr3.PluginType
+	transmitter            string
 	medianProvider         testtypes.MedianProviderTester
 	agnosticProvider       testtypes.PluginProviderTester
 	mercuryProvider        mercurytest.MercuryProviderTester
@@ -104,6 +105,7 @@ func newStaticRelayerConfig(lggr logger.Logger, staticChecks bool) staticRelayer
 		chainWriterConfig:      []byte("chainwriterconfig"),
 		offRampAddress:         "fakeAddress",
 		pluginType:             0,
+		transmitter:            "fakeAddress",
 		medianProvider:         mediantest.MedianProvider(lggr),
 		mercuryProvider:        mercurytest.MercuryProvider(lggr),
 		executionProvider:      cciptest.ExecutionProvider(lggr),
@@ -321,6 +323,7 @@ func (s staticRelayer) NewCCIPProvider(ctx context.Context, r types.CCIPProvider
 		ChainWriterConfig:    s.chainWriterConfig,
 		OffRampAddress:       s.offRampAddress,
 		PluginType:           s.pluginType,
+		Transmitter:          s.transmitter,
 	}
 	if s.StaticChecks && !equalCCIPProviderArgs(r, ccipProviderArgs) {
 		return nil, fmt.Errorf("expected relay args:\n\t%v\nbut got:\n\t%v", s.relayArgs, r)
@@ -479,7 +482,8 @@ func equalCCIPProviderArgs(a, b types.CCIPProviderArgs) bool {
 		slices.Equal(a.ContractReaderConfig, b.ContractReaderConfig) &&
 		slices.Equal(a.ChainWriterConfig, b.ChainWriterConfig) &&
 		a.OffRampAddress == b.OffRampAddress &&
-		a.PluginType == b.PluginType
+		a.PluginType == b.PluginType &&
+		a.Transmitter == b.Transmitter
 }
 
 func newRelayArgsWithProviderType(_type types.OCR2PluginType) types.RelayArgs {

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

@@ -64,4 +64,5 @@ type CCIPProviderArgs struct {
 	ChainWriterConfig    []byte
 	OffRampAddress       string
 	PluginType           ccipocr3.PluginType
+	Transmitter          string
 }