TXMv2 broadcast transactions (base branch develop)

.changeset/young-buses-pretend.md

@@ -0,0 +1,5 @@
+---
+"chainlink": minor
+---
+
+#added beholder metric to monitor TXMv2 transactions.

core/chains/evm/txm/metrics.go

@@ -5,12 +5,15 @@ import (
 	"fmt"
 	"math/big"
 
+	"github.com/ethereum/go-ethereum/common"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promauto"
 	"go.opentelemetry.io/otel/metric"
+	"google.golang.org/protobuf/proto"
 
 	"github.com/smartcontractkit/chainlink-common/pkg/beholder"
 	"github.com/smartcontractkit/chainlink-common/pkg/metrics"
+	"github.com/smartcontractkit/chainlink/v2/core/chains/evm/txm/pb"
 )
 
 var (
@@ -91,3 +94,25 @@ func (m *txmMetrics) RecordTimeUntilTxConfirmed(ctx context.Context, duration fl
 	promTimeUntilTxConfirmed.WithLabelValues(m.chainID.String()).Observe(duration)
 	m.timeUntilTxConfirmed.Record(ctx, duration)
 }
+
+func (m *txmMetrics) EmitTxMessage(ctx context.Context, tx common.Hash, fromAddress common.Address, toAddress common.Address, nonce uint64) error {
+	message := &pb.TxMessage{
+		Hash:        tx.String(),
+		FromAddress: fromAddress.String(),
+		ToAddress:   toAddress.String(),
+		Nonce:       nonce,
+	}
+
+	messageBytes, err := proto.Marshal(message)
+	if err != nil {
+		return err
+	}
+
+	return beholder.GetEmitter().Emit(
+		ctx,
+		messageBytes,
+		"beholder_domain", "svr",
+		"beholder_entity", "pb.TxMessage",
+		"beholder_data_schema", "/beholder-tx-message/versions/1",
+	)
+}

core/chains/evm/txm/pb/beholder-tx-message.proto

@@ -0,0 +1,12 @@
+syntax = "proto3";
+
+option go_package = "github.com/smartcontractkit/chainlink-common/pkg/beholder/pb";
+
+package pb;
+
+message TxMessage {
+  string Hash = 1;
+  string FromAddress = 2;
+  string ToAddress = 3;
+  uint64 Nonce = 4;
+}

core/chains/evm/txm/txm.go

@@ -362,6 +362,10 @@ func (t *Txm) sendTransactionWithError(ctx context.Context, tx *types.Transactio
 	}
 
 	t.metrics.IncrementNumBroadcastedTxs(ctx)
+	if err = t.metrics.EmitTxMessage(ctx, attempt.Hash, address, tx.ToAddress, *tx.Nonce); err != nil {
+		t.lggr.Errorw("Beholder error emitting tx message", "err", err)
+	}
+
 	return t.txStore.UpdateTransactionBroadcast(ctx, attempt.TxID, *tx.Nonce, attempt.Hash, address)
 }