synapsecns/sanguine

package mixins

import (
    "context"
    "github.com/synapsecns/sanguine/core/metrics"
    "github.com/synapsecns/sanguine/ethergo/client"
    "github.com/synapsecns/sanguine/ethergo/parser/rpc"
    "github.com/synapsecns/sanguine/ethergo/util"
    "go.opentelemetry.io/otel/attribute"
    "go.opentelemetry.io/otel/trace"
)

// TxSubmitMixin is a mixin for tracking submitted transactions.
// it can be used to index additional data in otel regarding tx submission status.
func TxSubmitMixin(parentCtx context.Context, handler metrics.Handler, r rpc.Request) {
    if client.RPCMethod(r.Method) != client.SendRawTransactionMethod {
        return
    }

    ctx, span := handler.Tracer().Start(parentCtx, "txsubmit", trace.WithAttributes(attribute.Int("txsubmit", r.ID)))

    var err error
    defer func() {
        metrics.EndSpanWithErr(span, err)
    }()

    tx, err := ReqToTX(r)
    if err != nil {
        handler.ExperimentalLogger().Warnf(ctx, "could not convert request to transaction: %v", err)
        return
    }

    span.SetAttributes(util.TxToAttributes(tx)...)
}