synapsecns/sanguine

package exporters

import (
    "context"
    "fmt"
    "math/big"

    "github.com/ethereum/go-ethereum/common"
    "github.com/ethereum/go-ethereum/params"
    "github.com/lmittmann/w3/module/eth"
    "github.com/synapsecns/sanguine/core/metrics"
    "go.opentelemetry.io/otel/attribute"
    "go.opentelemetry.io/otel/trace"
)

// note: this kind of check should be deprecated in favor of submitter metrics once everything has been moved over.
func (e *exporter) submitterStats(address common.Address, chainID int, name string) (err error) {
    ctx, span := e.metrics.Tracer().Start(
        context.Background(),
        "submitter_stats",
        trace.WithAttributes(
            attribute.Int(metrics.ChainID, chainID),
            attribute.String(metrics.EOAAddress, address.String()),
        ))

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

    client, err := e.omnirpcClient.GetConfirmationsClient(ctx, chainID, 1)
    if err != nil {
        return fmt.Errorf("could not get confirmations client: %w", err)
    }

    var nonce uint64
    var balance big.Int

    if err = client.BatchWithContext(ctx,
        eth.Nonce(address, nil).Returns(&nonce),
        eth.Balance(address, nil).Returns(&balance),
    ); err != nil {
        return fmt.Errorf("could not get balance: %w", err)
    }

    ethBalance := new(big.Float).Quo(new(big.Float).SetInt(&balance), new(big.Float).SetInt64(params.Ether))
    truncEthBalance, _ := ethBalance.Float64()

    submitterMetadata := submitterMetadata{
        address: address,
        name:    name,
        nonce:   int64(nonce),
        balance: truncEthBalance,
    }

    e.otelRecorder.RecordSubmitterStats(chainID, submitterMetadata)

    return nil
}