Added check to not fetch mercury prices when trigger capability is enabled

.changeset/wise-bears-end.md

@@ -0,0 +1,5 @@
+---
+"chainlink": patch
+---
+
+#updated v3/data_source Observe method to skip calling LatestPrice when EnableTriggerCapability relay config is true

core/services/ocr2/plugins/mercury/plugin.go

@@ -31,6 +31,7 @@ import (
 	mercuryv2 "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/v2"
 	mercuryv3 "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/v3"
 	mercuryv4 "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/v4"
+	evmtypes "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/types"
 	"github.com/smartcontractkit/chainlink/v2/plugins"
 )
 
@@ -78,15 +79,28 @@ func NewServices(
 		return nil, errors.New("expected job to have a non-nil PipelineSpec")
 	}
 
-	var pluginConfig config.PluginConfig
-	err := json.Unmarshal(jb.OCR2OracleSpec.PluginConfig.Bytes(), &pluginConfig)
+	var relayConfig evmtypes.RelayConfig
+	err := json.Unmarshal(jb.OCR2OracleSpec.RelayConfig.Bytes(), &relayConfig)
 	if err != nil {
-		return nil, errors.WithStack(err)
+		return nil, fmt.Errorf("error while unmarshalling relay config: %w", err)
 	}
-	err = config.ValidatePluginConfig(pluginConfig, feedID)
-	if err != nil {
-		return nil, err
+
+	var pluginConfig config.PluginConfig
+	if jb.OCR2OracleSpec.PluginConfig == nil {
+		if !relayConfig.EnableTriggerCapability {
+			return nil, fmt.Errorf("at least one transmission option must be configured")
+		}
+	} else {
+		err = json.Unmarshal(jb.OCR2OracleSpec.PluginConfig.Bytes(), &pluginConfig)
+		if err != nil {
+			return nil, errors.WithStack(err)
+		}
+		err = config.ValidatePluginConfig(pluginConfig, feedID)
+		if err != nil {
+			return nil, err
+		}
 	}
+
 	lggr = lggr.Named("MercuryPlugin").With("jobID", jb.ID, "jobName", jb.Name.ValueOrZero())
 
 	// encapsulate all the subservices and ensure we close them all if any fail to start

core/services/ocr2/validate/validate.go

@@ -26,6 +26,7 @@ import (
 	"github.com/smartcontractkit/chainlink/v2/core/services/ocrcommon"
 	"github.com/smartcontractkit/chainlink/v2/core/services/pipeline"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay"
+	evmtypes "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/types"
 	"github.com/smartcontractkit/chainlink/v2/plugins"
 )
 
@@ -84,7 +85,6 @@ var (
 		"relay":         {},
 		"relayConfig":   {},
 		"pluginType":    {},
-		"pluginConfig":  {},
 	}
 	notExpectedParams = map[string]struct{}{
 		"isBootstrapPeer":       {},
@@ -117,7 +117,7 @@ func validateSpec(ctx context.Context, tree *toml.Tree, spec job.Job, rc plugins
 		// TODO validator for DR-OCR spec: https://smartcontract-it.atlassian.net/browse/FUN-112
 		return nil
 	case types.Mercury:
-		return validateOCR2MercurySpec(spec.OCR2OracleSpec.PluginConfig, *spec.OCR2OracleSpec.FeedID)
+		return validateOCR2MercurySpec(spec.OCR2OracleSpec, *spec.OCR2OracleSpec.FeedID)
 	case types.CCIPExecution:
 		return validateOCR2CCIPExecutionSpec(spec.OCR2OracleSpec.PluginConfig)
 	case types.CCIPCommit:
@@ -297,13 +297,26 @@ func validateOCR2KeeperSpec(jsonConfig job.JSONConfig) error {
 	return nil
 }
 
-func validateOCR2MercurySpec(jsonConfig job.JSONConfig, feedId [32]byte) error {
+func validateOCR2MercurySpec(spec *job.OCR2OracleSpec, feedID [32]byte) error {
+	var relayConfig evmtypes.RelayConfig
+	err := json.Unmarshal(spec.RelayConfig.Bytes(), &relayConfig)
+	if err != nil {
+		return pkgerrors.Wrap(err, "error while unmarshalling relay config")
+	}
+
+	if spec.PluginConfig == nil {
+		if !relayConfig.EnableTriggerCapability {
+			return pkgerrors.Wrap(err, "at least one transmission option must be configured")
+		}
+		return nil
+	}
+
 	var pluginConfig mercuryconfig.PluginConfig
-	err := json.Unmarshal(jsonConfig.Bytes(), &pluginConfig)
+	err = json.Unmarshal(spec.PluginConfig.Bytes(), &pluginConfig)
 	if err != nil {
 		return pkgerrors.Wrap(err, "error while unmarshalling plugin config")
 	}
-	return pkgerrors.Wrap(mercuryconfig.ValidatePluginConfig(pluginConfig, feedId), "Mercury PluginConfig is invalid")
+	return pkgerrors.Wrap(mercuryconfig.ValidatePluginConfig(pluginConfig, feedID), "Mercury PluginConfig is invalid")
 }
 
 func validateOCR2CCIPExecutionSpec(jsonConfig job.JSONConfig) error {

core/services/relay/evm/mercury/v3/data_source.go

@@ -2,6 +2,7 @@ package v3
 
 import (
 	"context"
+	"encoding/json"
 	"errors"
 	"fmt"
 	"math/big"
@@ -22,6 +23,7 @@ import (
 	mercurytypes "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/types"
 	mercuryutils "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/utils"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/v3/reportcodec"
+	relayTypes "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/types"
 	"github.com/smartcontractkit/chainlink/v2/core/utils"
 )
 
@@ -63,6 +65,12 @@ func NewDataSource(orm types.DataSourceORM, pr pipeline.Runner, jb job.Job, spec
 
 func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestamp, fetchMaxFinalizedTimestamp bool) (obs v3types.Observation, pipelineExecutionErr error) {
 	var wg sync.WaitGroup
+	var relayConfig relayTypes.RelayConfig
+	err := json.Unmarshal(ds.jb.OCR2OracleSpec.RelayConfig.Bytes(), &relayConfig)
+	if err != nil {
+		pipelineExecutionErr = fmt.Errorf("failed to deserialize relay config: %w", err)
+		return
+	}
 	ctx, cancel := context.WithCancel(ctx)
 
 	if fetchMaxFinalizedTimestamp {
@@ -114,7 +122,8 @@ func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestam
 	var isLink, isNative bool
 	if ds.feedID == ds.linkFeedID {
 		isLink = true
-	} else {
+	} else if ds.jb.OCR2OracleSpec.PluginConfig != nil {
+		// If the triggerCapability is enabled, we don't need to fetch the price
 		wg.Add(1)
 		go func() {
 			defer wg.Done()
@@ -132,7 +141,8 @@ func (ds *datasource) Observe(ctx context.Context, repts ocrtypes.ReportTimestam
 
 	if ds.feedID == ds.nativeFeedID {
 		isNative = true
-	} else {
+	} else if ds.jb.OCR2OracleSpec.PluginConfig != nil {
+		// If the triggerCapability is enabled, we don't need to fetch the price
 		wg.Add(1)
 		go func() {
 			defer wg.Done()

core/services/relay/evm/mercury/v3/data_source_test.go

@@ -5,18 +5,19 @@ import (
 	"math/big"
 	"testing"
 
+	relaymercuryv3 "github.com/smartcontractkit/chainlink-data-streams/mercury/v3"
+	"github.com/smartcontractkit/chainlink/v2/core/services/ocrcommon"
+	"github.com/smartcontractkit/chainlink/v2/core/services/pipeline/eautils"
+
 	"github.com/pkg/errors"
 	ocrtypes "github.com/smartcontractkit/libocr/offchainreporting2plus/types"
 	"github.com/stretchr/testify/assert"
 
 	mercurytypes "github.com/smartcontractkit/chainlink-common/pkg/types/mercury"
-	relaymercuryv3 "github.com/smartcontractkit/chainlink-data-streams/mercury/v3"
 	"github.com/smartcontractkit/chainlink/v2/core/internal/testutils"
 	"github.com/smartcontractkit/chainlink/v2/core/logger"
 	"github.com/smartcontractkit/chainlink/v2/core/services/job"
-	"github.com/smartcontractkit/chainlink/v2/core/services/ocrcommon"
 	"github.com/smartcontractkit/chainlink/v2/core/services/pipeline"
-	"github.com/smartcontractkit/chainlink/v2/core/services/pipeline/eautils"
 	mercurymocks "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/mocks"
 	"github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/utils"
 	reportcodecv3 "github.com/smartcontractkit/chainlink/v2/core/services/relay/evm/mercury/v3/reportcodec"
@@ -360,6 +361,24 @@ func Test_Datasource(t *testing.T) {
 				assert.EqualError(t, obs.NativePrice.Err, "some error fetching native price")
 			})
 
+			t.Run("when PluginConfig=nil skips fetching link and native prices", func(t *testing.T) {
+				t.Cleanup(func() {
+					fetcher.linkPriceErr = nil
+					fetcher.nativePriceErr = nil
+				})
+
+				fetcher.linkPriceErr = errors.New("some error fetching link price")
+				fetcher.nativePriceErr = errors.New("some error fetching native price")
+
+				ds.jb.OCR2OracleSpec.PluginConfig = nil
+
+				obs, err := ds.Observe(ctx, repts, false)
+				assert.NoError(t, err)
+				assert.Nil(t, obs.LinkPrice.Err)
+				assert.Nil(t, obs.NativePrice.Err)
+				assert.Equal(t, big.NewInt(122), obs.BenchmarkPrice.Val)
+			})
+
 			t.Run("when succeeds to fetch linkPrice or nativePrice but got nil (new feed)", func(t *testing.T) {
 				obs, err := ds.Observe(ctx, repts, false)
 				assert.NoError(t, err)