Make formatting fixes

Signed-off-by: litt3 <102969658+litt3@users.noreply.github.com>

api/clients/v2/relay/default_relay_url_provider.go

@@ -24,8 +24,7 @@ func NewDefaultRelayUrlProvider(
 	relayRegistryAddress gethcommon.Address,
 ) (*DefaultRelayUrlProvider, error) {
 	relayRegistryContractCaller, err := relayRegistryBindings.NewContractEigenDARelayRegistryCaller(
-		relayRegistryAddress,
-		ethClient)
+		relayRegistryAddress, ethClient)
 	if err != nil {
 		return nil, fmt.Errorf("NewContractEigenDARelayRegistryCaller: %w", err)
 	}
@@ -47,6 +46,8 @@ func (rup *DefaultRelayUrlProvider) GetRelayUrl(ctx context.Context, relayKey v2
 
 // GetRelayCount gets the number of relays that exist in the registry
 func (rup *DefaultRelayUrlProvider) GetRelayCount(ctx context.Context) (uint32, error) {
+	// NextRelayKey initializes to 0, and is incremented each time a relay is added
+	// current logic doesn't support removing relays, so NextRelayKey therefore corresponds directly to relay count
 	relayCount, err := rup.relayRegistryCaller.NextRelayKey(&bind.CallOpts{Context: ctx})
 	if err != nil {
 		return 0, fmt.Errorf("get next relay key from EigenDARelayRegistry contract: %w", err)

api/clients/v2/relay_client.go

@@ -67,7 +67,7 @@ type relayClient struct {
 	// grpcRelayClients maps relay key to the gRPC client: `map[corev2.RelayKey]relaygrpc.RelayClient`
 	// these grpc relay clients are used to communicate with individual relays
 	grpcRelayClients sync.Map
-	// relayUrlProvider knows how to retrieve the relay URLs, and maintains an internal URL cache
+	// relayUrlProvider knows how to retrieve the relay URLs
 	relayUrlProvider relay.RelayUrlProvider
 }
 
@@ -254,6 +254,8 @@ func (c *relayClient) initOnceGrpcConnection(ctx context.Context, key corev2.Rel
 	}
 	c.initOnceMutex.Unlock()
 
+	// TODO (litt3): should we implement a way to rebuild connections that break, or fail to initialize? as it currently
+	//  stands, if this initialization fails, or a connection breaks, the relay client will never speak to that relay again
 	var initErr error
 	once.Do(
 		func() {

core/chainio.go

@@ -131,6 +131,7 @@ type Reader interface {
 	// GetDisperserAddress returns the disperser address with the given ID.
 	GetDisperserAddress(ctx context.Context, disperserID uint32) (gethcommon.Address, error)
 
+	// GetRelayRegistryAddress returns the Address of the EigenDARelayRegistry contract
 	GetRelayRegistryAddress() gethcommon.Address
 }
 

core/eth/reader.go

@@ -37,7 +37,7 @@ import (
 type ContractBindings struct {
 	RegCoordinatorAddr    gethcommon.Address
 	ServiceManagerAddr    gethcommon.Address
-	RelayRegistryAddress gethcommon.Address
+	RelayRegistryAddress  gethcommon.Address
 	DelegationManager     *delegationmgr.ContractDelegationManager
 	OpStateRetriever      *opstateretriever.ContractOperatorStateRetriever
 	BLSApkRegistry        *blsapkreg.ContractBLSApkRegistry
@@ -243,7 +243,7 @@ func (t *Reader) updateContractBindings(blsOperatorStateRetrieverAddr, eigenDASe
 	t.bindings = &ContractBindings{
 		ServiceManagerAddr:    eigenDAServiceManagerAddr,
 		RegCoordinatorAddr:    registryCoordinatorAddr,
-		RelayRegistryAddress: relayRegistryAddress,
+		RelayRegistryAddress:  relayRegistryAddress,
 		AVSDirectory:          contractAVSDirectory,
 		SocketRegistry:        contractSocketRegistry,
 		OpStateRetriever:      contractBLSOpStateRetr,

inabox/tests/integration_suite_test.go

@@ -52,7 +52,7 @@ var (
 	retrievalClientV2   clientsv2.RetrievalClient
 	numConfirmations    int = 3
 	numRetries              = 0
-	chainReader core.Reader
+	chainReader         core.Reader
 
 	cancel context.CancelFunc
 )