utils.go

package bloxroute_sdk_go

import (
	"context"
	"crypto/rand"
	_ "embed"
	"encoding/binary"
	"fmt"
	"net/http"
	"strconv"

	"github.com/cenkalti/backoff/v4"
	"github.com/sourcegraph/jsonrpc2"

	"github.com/bloXroute-Labs/bloxroute-sdk-go/connection/ws"
)

//go:embed version.txt
var buildVersion string

func reconnect(ctx context.Context, url string, headers http.Header, opts *ws.DialOptions) (ws.Conn, error) {
	backOff := backoff.NewExponentialBackOff()
	backOff.MaxElapsedTime = reconnectTimeout
	backOff.InitialInterval = reconnectInitialInterval

	var conn ws.Conn

	fn := func() error {
		var err error
		conn, err = ws.Dial(ctx, url, headers, opts)
		if err != nil {
			return fmt.Errorf("failed to reconnect to cloud API after %s: %w", reconnectTimeout, err)
		}

		return nil
	}

	err := backoff.Retry(fn, backOff)
	if err != nil {
		return nil, err
	}

	return conn, nil
}

func randomID() jsonrpc2.ID {
	var idStr string

	var randomBytes [8]byte
	_, err := rand.Read(randomBytes[:])
	if err != nil {
		idStr = "1"
	} else {
		idStr = strconv.FormatUint(binary.BigEndian.Uint64(randomBytes[:]), 10)
	}

	return jsonrpc2.ID{Str: idStr, IsString: true}
}