feat: Add get_ethclient trace (#390)

* fix: Handle error when no RPC connection is established

* refactor: Reduce log level for failed RPC connection

* refactor: Move ethclient connection into a function

* feat: Add get_ethclient trace

pkg/web3/sdk.go

@@ -3,7 +3,10 @@ package web3
 import (
 	"context"
 	"crypto/ecdsa"
+	"errors"
+	"fmt"
 	"math/big"
+	"net/url"
 	"strconv"
 	"strings"
 
@@ -21,6 +24,8 @@ import (
 	"github.com/lilypad-tech/lilypad/pkg/web3/bindings/token"
 	"github.com/lilypad-tech/lilypad/pkg/web3/bindings/users"
 	"github.com/rs/zerolog/log"
+	"go.opentelemetry.io/otel/attribute"
+	"go.opentelemetry.io/otel/codes"
 	"go.opentelemetry.io/otel/trace"
 )
 
@@ -197,17 +202,9 @@ func NewContractSDK(ctx context.Context, options Web3Options, tracer trace.Trace
 	displayOpts.PrivateKey = "*********"
 	log.Debug().Msgf("NewContractSDK: %+v", displayOpts)
 
-	rpcs := strings.Split(options.RpcURL, ",")
-	var client *ethclient.Client
-	var err error
-	for _, url := range rpcs {
-		client, err = ethclient.Dial(url)
-		if err != nil {
-			log.Error().Msgf("Failed to connect to %s: %v", url, err)
-			continue
-		} else {
-			break
-		}
+	client, err := getEthClient(ctx, options, tracer)
+	if err != nil {
+		return nil, err
 	}
 
 	privateKey, err := ParsePrivateKey(options.PrivateKey)
@@ -244,6 +241,42 @@ func NewContractSDK(ctx context.Context, options Web3Options, tracer trace.Trace
 	return web3SDK, nil
 }
 
+func getEthClient(ctx context.Context, options Web3Options, tracer trace.Tracer) (*ethclient.Client, error) {
+	ctx, span := tracer.Start(ctx, "get_ethclient", trace.WithAttributes(attribute.Int("web3.chain_id", options.ChainID)))
+	defer span.End()
+
+	rpcs := strings.Split(options.RpcURL, ",")
+	var err error
+	var parsedURL *url.URL
+	var client *ethclient.Client
+	for _, u := range rpcs {
+		parsedURL, err = url.Parse(u)
+		if err != nil {
+			log.Warn().Msgf("Unable to parse web3 RPC URL: %v", err)
+			span.RecordError(errors.New("Unable to parse web3 RPC URL"))
+			continue
+		}
+
+		span.AddEvent("ethclient.dial", trace.WithAttributes(attribute.String("web3.rpc_url", parsedURL.Host)))
+		client, err = ethclient.Dial(u)
+		if err != nil {
+			log.Warn().Msgf("Failed to connect to %s: %v", parsedURL.Host, err)
+			span.RecordError(fmt.Errorf("Failed to connect to %s", parsedURL.Host))
+			continue
+		} else {
+			log.Info().Msgf("Connected to %s", parsedURL.Host)
+			span.AddEvent("ethclient.connected")
+			break
+		}
+	}
+	if client == nil {
+		span.SetStatus(codes.Error, "Failed to connect with web3 RPC URL")
+		return nil, errors.New("Failed to connect to a web3 RPC provider")
+	}
+
+	return client, nil
+}
+
 func (sdk *Web3SDK) getBlockNumber() (uint64, error) {
 	var blockNumberHex string
 	err := sdk.Client.Client().Call(&blockNumberHex, "eth_blockNumber")