Merge branch 'main' into dependabot/go_modules/github.com/cometbft/co…

…metbft-0.38.13

.github/CODEOWNERS

@@ -4,4 +4,4 @@
 
 # Primary repo maintainers
 
-*       @aljo242 @Eric-Warehime @technicallyty @wesl-ee @zrbecker
+*       @skip-mev/skip-connect

cmd/connect/main.go

@@ -37,8 +37,8 @@ import (
 
 var (
 	rootCmd = &cobra.Command{
-		Use:   "oracle",
-		Short: "Run the connect oracle server.",
+		Use:   "connect",
+		Short: "Run the connect oracle.",
 		Args:  cobra.NoArgs,
 		RunE: func(_ *cobra.Command, _ []string) error {
 			return runOracle()

providers/base/fetch.go

@@ -11,6 +11,7 @@ import (
 
 	"go.uber.org/zap"
 
+	"github.com/skip-mev/connect/v2/pkg/slices"
 	providermetrics "github.com/skip-mev/connect/v2/providers/base/metrics"
 	providertypes "github.com/skip-mev/connect/v2/providers/types"
 )
@@ -85,23 +86,8 @@ func (p *Provider[K, V]) startMultiplexWebsocket(ctx context.Context) error {
 	if maxSubsPerConn > 0 {
 		// case where we will split ID's across sub handlers
 		numSubHandlers := int(math.Ceil(float64(len(ids)) / float64(maxSubsPerConn)))
-		p.logger.Debug("setting number of web socket handlers for provider", zap.Int("sub_handlers", numSubHandlers))
 		wg.SetLimit(numSubHandlers)
-
-		// split ids
-		for i := 0; i < numSubHandlers; i++ {
-			start := i * maxSubsPerConn
-
-			// Copy the IDs over.
-			subIDs := make([]K, 0)
-			if end := start + maxSubsPerConn; end >= len(ids) {
-				subIDs = append(subIDs, ids[start:]...)
-			} else {
-				subIDs = append(subIDs, ids[start:end]...)
-			}
-
-			subTasks = append(subTasks, subIDs)
-		}
+		subTasks = slices.Chunk(ids, maxSubsPerConn)
 	} else {
 		// case where there is 1 sub handler
 		subTasks = append(subTasks, ids)
@@ -110,14 +96,6 @@ func (p *Provider[K, V]) startMultiplexWebsocket(ctx context.Context) error {
 
 	for _, subIDs := range subTasks {
 		wg.Go(p.startWebSocket(ctx, subIDs))
-
-		select {
-		case <-time.After(p.wsCfg.HandshakeTimeout):
-			p.logger.Debug("handshake timeout reached")
-		case <-ctx.Done():
-			p.logger.Debug("context done")
-			return wg.Wait()
-		}
 	}
 
 	// Wait for all the sub handlers to finish.