refactor(block): reduce max size in da submitter (#2720)

<!--
Please read and fill out this form before submitting your PR.

Please make sure you have reviewed our contributors guide before
submitting your
first PR.

NOTE: PR titles should follow semantic commits:
https://www.conventionalcommits.org/en/v1.0.0/
-->

## Overview

<!-- 
Please provide an explanation of the PR, including the appropriate
context,
background, goal, and rationale. If there is an issue with this
information,
please provide a tl;dr and link the issue. 

Ex: Closes #<issue number>
-->

short term fix to clear cache 

it turns out that 2MB is the max tx size and not the max blob size. This
means DA is down and pending headers/data increases, when it was
reaching 2MB it would constantly fail

Author: tac0turtle

.github/workflows/check_consts_drift.yml

@@ -51,7 +51,7 @@ var RunCmd = &cobra.Command{
 
 		logger.Info().Str("headerNamespace", headerNamespace.HexString()).Str("dataNamespace", dataNamespace.HexString()).Msg("namespaces")
 
-		daJrpc, err := jsonrpc.NewClient(context.Background(), logger, nodeConfig.DA.Address, nodeConfig.DA.AuthToken, nodeConfig.DA.GasPrice, nodeConfig.DA.GasMultiplier)
+		daJrpc, err := jsonrpc.NewClient(context.Background(), logger, nodeConfig.DA.Address, nodeConfig.DA.AuthToken, nodeConfig.DA.GasPrice, nodeConfig.DA.GasMultiplier, rollcmd.DefaultMaxBlobSize)
 		if err != nil {
 			return err
 		}

apps/evm/single/cmd/run.go

@@ -52,7 +52,7 @@ The execution client must implement the Evolve execution gRPC interface.`,
 		logger.Info().Str("headerNamespace", headerNamespace.HexString()).Str("dataNamespace", dataNamespace.HexString()).Msg("namespaces")
 
 		// Create DA client
-		daJrpc, err := jsonrpc.NewClient(cmd.Context(), logger, nodeConfig.DA.Address, nodeConfig.DA.AuthToken, nodeConfig.DA.GasPrice, nodeConfig.DA.GasMultiplier)
+		daJrpc, err := jsonrpc.NewClient(cmd.Context(), logger, nodeConfig.DA.Address, nodeConfig.DA.AuthToken, nodeConfig.DA.GasPrice, nodeConfig.DA.GasMultiplier, rollcmd.DefaultMaxBlobSize)
 		if err != nil {
 			return err
 		}

apps/grpc/single/cmd/run.go

@@ -51,7 +51,7 @@ var RunCmd = &cobra.Command{
 
 		logger.Info().Str("headerNamespace", headerNamespace.HexString()).Str("dataNamespace", dataNamespace.HexString()).Msg("namespaces")
 
-		daJrpc, err := jsonrpc.NewClient(ctx, logger, nodeConfig.DA.Address, nodeConfig.DA.AuthToken, nodeConfig.DA.GasPrice, nodeConfig.DA.GasMultiplier)
+		daJrpc, err := jsonrpc.NewClient(ctx, logger, nodeConfig.DA.Address, nodeConfig.DA.AuthToken, nodeConfig.DA.GasPrice, nodeConfig.DA.GasMultiplier, rollcmd.DefaultMaxBlobSize)
 		if err != nil {
 			return err
 		}

apps/testapp/cmd/run.go

@@ -25,7 +25,7 @@ const (
 	initialBackoff               = 100 * time.Millisecond
 	defaultGasPrice              = 0.0
 	defaultGasMultiplier         = 1.0
-	defaultMaxBlobSize           = 2 * 1024 * 1024 // 2MB fallback blob size limit
+	defaultMaxBlobSize           = 1.5 * 1024 * 1024 // 1.5MB fallback blob size limit
 	defaultMaxGasPriceClamp      = 1000.0
 	defaultMaxGasMultiplierClamp = 3.0 // must always > 0 to avoid division by zero
 )

block/internal/submitting/da_submitter.go

@@ -11,7 +11,6 @@ import (
 	"github.com/rs/zerolog"
 
 	"github.com/evstack/ev-node/core/da"
-	internal "github.com/evstack/ev-node/da/jsonrpc/internal"
 )
 
 //go:generate mockgen -destination=mocks/api.go -package=mocks . Module
@@ -223,16 +222,16 @@ func (c *Client) Close() {
 
 // NewClient creates a new Client with one connection per namespace with the
 // given token as the authorization token.
-func NewClient(ctx context.Context, logger zerolog.Logger, addr, token string, gasPrice, gasMultiplier float64) (*Client, error) {
+func NewClient(ctx context.Context, logger zerolog.Logger, addr, token string, gasPrice, gasMultiplier float64, maxBlobSize uint64) (*Client, error) {
 	authHeader := http.Header{"Authorization": []string{fmt.Sprintf("Bearer %s", token)}}
-	return newClient(ctx, logger, addr, authHeader, gasPrice, gasMultiplier)
+	return newClient(ctx, logger, addr, authHeader, gasPrice, gasMultiplier, maxBlobSize)
 }
 
-func newClient(ctx context.Context, logger zerolog.Logger, addr string, authHeader http.Header, gasPrice, gasMultiplier float64) (*Client, error) {
+func newClient(ctx context.Context, logger zerolog.Logger, addr string, authHeader http.Header, gasPrice, gasMultiplier float64, maxBlobSize uint64) (*Client, error) {
 	var multiCloser multiClientCloser
 	var client Client
 	client.DA.Logger = logger
-	client.DA.MaxBlobSize = uint64(internal.MaxTxSize)
+	client.DA.MaxBlobSize = maxBlobSize
 	client.DA.gasPrice = gasPrice
 	client.DA.gasMultiplier = gasMultiplier
 

da/jsonrpc/client.go

@@ -29,6 +29,8 @@ const (
 	ClientURL = "http://localhost:3450"
 
 	testMaxBlobSize = 100
+
+	DefaultMaxBlobSize = 1.5 * 1024 * 1024 // 1.5MB
 )
 
 // testNamespace is a 15-byte namespace that will be hex encoded to 30 chars and truncated to 29
@@ -55,7 +57,7 @@ func TestProxy(t *testing.T) {
 		}
 	}()
 
-	client, err := proxy.NewClient(context.Background(), logger, ClientURL, "74657374", 0, 1)
+	client, err := proxy.NewClient(context.Background(), logger, ClientURL, "74657374", 0, 1, DefaultMaxBlobSize)
 	require.NoError(t, err)
 
 	t.Run("Basic DA test", func(t *testing.T) {

da/jsonrpc/internal/consts.go

@@ -26,6 +26,8 @@ import (
 	"github.com/evstack/ev-node/pkg/signer/file"
 )
 
+const DefaultMaxBlobSize = 1.5 * 1024 * 1024 // 1.5MB
+
 // ParseConfig is an helpers that loads the node configuration and validates it.
 func ParseConfig(cmd *cobra.Command) (rollconf.Config, error) {
 	nodeConfig, err := rollconf.Load(cmd)