CCTPv2 Observer part 2

execute/tokendata/cctp/v2/http_client.go

@@ -33,12 +33,6 @@ type CCTPv2HTTPClient interface {
 	) (CCTPv2Messages, error)
 }
 
-// MetricsReporter provides metrics reporting for attestation API calls
-type MetricsReporter interface {
-	TrackAttestationAPILatency(
-		sourceChain cciptypes.ChainSelector, sourceDomain uint32, success bool, httpStatus string, latency time.Duration)
-}
-
 // CCTPv2HTTPClientImpl implements CCTPv2AttestationClient using HTTP calls to Circle's attestation API
 type CCTPv2HTTPClientImpl struct {
 	lggr            logger.Logger

execute/tokendata/cctp/v2/http_client_test.go

@@ -57,6 +57,22 @@
 	m.Called(sourceChain, sourceDomain, success, httpStatus, latency)
 }
 
+func (m *MockMetricsReporter) TrackObserveLatency(numRequests int, latency time.Duration) {
+	m.Called(numRequests, latency)
+}
+
+func (m *MockMetricsReporter) TrackDepositHashCalculationError(sourceChain cciptypes.ChainSelector, sourceDomain uint32) {
+	m.Called(sourceChain, sourceDomain)
+}
+
+func (m *MockMetricsReporter) TrackMessageToTokenDataError(sourceChain cciptypes.ChainSelector, sourceDomain uint32) {
+	m.Called(sourceChain, sourceDomain)
+}
+
+func (m *MockMetricsReporter) TrackAssignTokenDataFailure(sourceChain cciptypes.ChainSelector, sourceDomain uint32) {
+	m.Called(sourceChain, sourceDomain)
+}
+
 func TestNewCCTPv2Client(t *testing.T) {
 	lggr := logger.Test(t)
 	config := pluginconfig.USDCCCTPObserverConfig{

execute/tokendata/cctp/v2/metrics.go

@@ -0,0 +1,174 @@
+package v2
+
+import (
+	"fmt"
+	"strconv"
+	"time"
+
+	"github.com/prometheus/client_golang/prometheus"
+	"github.com/prometheus/client_golang/prometheus/promauto"
+
+	"github.com/smartcontractkit/chainlink-common/pkg/logger"
+	cciptypes "github.com/smartcontractkit/chainlink-common/pkg/types/ccipocr3"
+
+	"github.com/smartcontractkit/chainlink-ccip/internal/libs"
+)
+
+var (
+	PromCCTPv2AttestationAPILatencyHistogram = promauto.NewHistogramVec(
+		prometheus.HistogramOpts{
+			Name: "ccip_exec_tokendata_cctpv2_attestation_api_latency",
+			Help: "Latency of CCTP v2 attestation API calls",
+			Buckets: []float64{
+				float64(50 * time.Millisecond),
+				float64(100 * time.Millisecond),
+				float64(200 * time.Millisecond),
+				float64(500 * time.Millisecond),
+				float64(time.Second),
+				float64(2 * time.Second),
+				float64(5 * time.Second),
+				float64(10 * time.Second),
+			},
+		},
+		[]string{"destChainFamily", "destChainID", "sourceChainFamily", "sourceChainID", "sourceDomain", "success", "httpStatus"},
+	)
+
+	PromCCTPv2ObserveLatencyHistogram = promauto.NewHistogramVec(
+		prometheus.HistogramOpts{
+			Name:    "ccip_exec_tokendata_cctpv2_observe_latency",
+			Help:    "Latency of CCTP v2 Observe() calls",
+			Buckets: prometheus.DefBuckets,
+		},
+		[]string{"destChainFamily", "destChainID", "numRequests"},
+	)
+
+	PromCCTPv2DepositHashCalculationErrorCounter = promauto.NewCounterVec(
+		prometheus.CounterOpts{
+			Name: "ccip_exec_tokendata_cctpv2_deposit_hash_calculation_error",
+			Help: "Count of CCTP v2 deposit hash calculation errors",
+		},
+		[]string{"destChainFamily", "destChainID", "sourceChainFamily", "sourceChainID", "sourceDomain"},
+	)
+
+	PromCCTPv2MessageToTokenDataErrorCounter = promauto.NewCounterVec(
+		prometheus.CounterOpts{
+			Name: "ccip_exec_tokendata_cctpv2_message_to_token_data_error",
+			Help: "Count of CCTP v2 message to token data conversion errors",
+		},
+		[]string{"destChainFamily", "destChainID", "sourceChainFamily", "sourceChainID", "sourceDomain"},
+	)
+
+	PromCCTPv2AssignTokenDataFailureCounter = promauto.NewCounterVec(
+		prometheus.CounterOpts{
+			Name: "ccip_exec_tokendata_cctpv2_assign_token_data_failure",
+			Help: "Count of CCTP v2 token data assignment failures",
+		},
+		[]string{"destChainFamily", "destChainID", "sourceChainFamily", "sourceChainID", "sourceDomain"},
+	)
+)
+
+// MetricsReporter provides metrics reporting functionality for CCTP v2 observer
+type MetricsReporter interface {
+	TrackAttestationAPILatency(
+		sourceChain cciptypes.ChainSelector, sourceDomain uint32, success bool, httpStatus string, latency time.Duration)
+	TrackObserveLatency(numRequests int, latency time.Duration)
+	TrackDepositHashCalculationError(sourceChain cciptypes.ChainSelector, sourceDomain uint32)
+	TrackMessageToTokenDataError(sourceChain cciptypes.ChainSelector, sourceDomain uint32)
+	TrackAssignTokenDataFailure(sourceChain cciptypes.ChainSelector, sourceDomain uint32)
+}
+
+// MetricsReporterImpl implements MetricsReporter with actual Prometheus metrics
+type MetricsReporterImpl struct {
+	lggr            logger.Logger
+	destChainFamily string
+	destChainID     string
+}
+
+// noOpMetricsReporter implements MetricsReporter with no-op methods
+type noOpMetricsReporter struct{}
+
+func (n *noOpMetricsReporter) TrackAttestationAPILatency(cciptypes.ChainSelector, uint32, bool, string, time.Duration) {
+}
+
+func (n *noOpMetricsReporter) TrackObserveLatency(int, time.Duration) {
+}
+
+func (n *noOpMetricsReporter) TrackDepositHashCalculationError(cciptypes.ChainSelector, uint32) {
+}
+
+func (n *noOpMetricsReporter) TrackMessageToTokenDataError(cciptypes.ChainSelector, uint32) {
+}
+
+func (n *noOpMetricsReporter) TrackAssignTokenDataFailure(cciptypes.ChainSelector, uint32) {
+}
+
+// NewMetricsReporter creates a new metrics reporter for CCTP v2
+func NewMetricsReporter(lggr logger.Logger, destChainSelector cciptypes.ChainSelector) (MetricsReporter, error) {
+	chainFamily, chainID, ok := libs.GetChainInfoFromSelector(destChainSelector)
+	if !ok {
+		return &noOpMetricsReporter{}, fmt.Errorf("chainFamily and chainID not found for selector %d",
+			destChainSelector)
+	}
+
+	return &MetricsReporterImpl{
+		lggr:            lggr,
+		destChainFamily: chainFamily,
+		destChainID:     chainID,
+	}, nil
+}
+
+// NewNoOpMetricsReporter creates a no-op metrics reporter
+func NewNoOpMetricsReporter() MetricsReporter {
+	return &noOpMetricsReporter{}
+}
+
+// TrackAttestationAPILatency tracks the latency of attestation API calls
+func (r *MetricsReporterImpl) TrackAttestationAPILatency(
+	sourceChain cciptypes.ChainSelector, sourceDomain uint32, success bool, httpStatus string, latency time.Duration,
+) {
+	sourceChainFamily, sourceChainID, _ := libs.GetChainInfoFromSelector(sourceChain)
+	PromCCTPv2AttestationAPILatencyHistogram.
+		WithLabelValues(r.destChainFamily, r.destChainID, sourceChainFamily, sourceChainID,
+			strconv.FormatUint(uint64(sourceDomain), 10), strconv.FormatBool(success), httpStatus).
+		Observe(latency.Seconds())
+}
+
+// TrackObserveLatency tracks the overall latency of Observe() calls
+func (r *MetricsReporterImpl) TrackObserveLatency(numRequests int, latency time.Duration) {
+	PromCCTPv2ObserveLatencyHistogram.
+		WithLabelValues(r.destChainFamily, r.destChainID, strconv.Itoa(numRequests)).
+		Observe(latency.Seconds())
+}
+
+// TrackDepositHashCalculationError tracks deposit hash calculation errors
+func (r *MetricsReporterImpl) TrackDepositHashCalculationError(
+	sourceChain cciptypes.ChainSelector, sourceDomain uint32,
+) {
+	sourceChainFamily, sourceChainID, _ := libs.GetChainInfoFromSelector(sourceChain)
+	PromCCTPv2DepositHashCalculationErrorCounter.
+		WithLabelValues(r.destChainFamily, r.destChainID, sourceChainFamily, sourceChainID,
+			strconv.FormatUint(uint64(sourceDomain), 10)).
+		Inc()
+}
+
+// TrackMessageToTokenDataError tracks message to token data conversion errors
+func (r *MetricsReporterImpl) TrackMessageToTokenDataError(
+	sourceChain cciptypes.ChainSelector, sourceDomain uint32,
+) {
+	sourceChainFamily, sourceChainID, _ := libs.GetChainInfoFromSelector(sourceChain)
+	PromCCTPv2MessageToTokenDataErrorCounter.
+		WithLabelValues(r.destChainFamily, r.destChainID, sourceChainFamily, sourceChainID,
+			strconv.FormatUint(uint64(sourceDomain), 10)).
+		Inc()
+}
+
+// TrackAssignTokenDataFailure tracks token data assignment failures
+func (r *MetricsReporterImpl) TrackAssignTokenDataFailure(
+	sourceChain cciptypes.ChainSelector, sourceDomain uint32,
+) {
+	sourceChainFamily, sourceChainID, _ := libs.GetChainInfoFromSelector(sourceChain)
+	PromCCTPv2AssignTokenDataFailureCounter.
+		WithLabelValues(r.destChainFamily, r.destChainID, sourceChainFamily, sourceChainID,
+			strconv.FormatUint(uint64(sourceDomain), 10)).
+		Inc()
+}