fix: Return 400 when blobs exceed max limit

e2e/server_test.go

@@ -1,6 +1,8 @@
 package e2e_test
 
 import (
+	"fmt"
+	"net/http"
 	"strings"
 	"testing"
 	"time"
@@ -185,6 +187,7 @@ func TestProxyServerWithOversizedBlob(t *testing.T) {
 	}
 
 	require.True(t, oversizedError)
+	require.Contains(t, err.Error(), fmt.Sprint(http.StatusBadRequest))
 
 }
 

server/server.go

@@ -15,6 +15,7 @@ import (
 	"github.com/Layr-Labs/eigenda-proxy/commitments"
 	"github.com/Layr-Labs/eigenda-proxy/metrics"
 	"github.com/Layr-Labs/eigenda-proxy/store"
+	"github.com/Layr-Labs/eigenda-proxy/utils"
 	"github.com/ethereum-optimism/optimism/op-service/rpc"
 	"github.com/ethereum/go-ethereum/common/hexutil"
 	"github.com/ethereum/go-ethereum/log"
@@ -218,6 +219,12 @@ func (svr *Server) HandlePut(w http.ResponseWriter, r *http.Request) (commitment
 	commitment, err := svr.router.Put(r.Context(), meta.Mode, comm, input)
 	if err != nil {
 		err = fmt.Errorf("put request failed with commitment %v (commitment mode %v): %w", comm, meta.Mode, err)
+
+		if utils.ErrorMessageContainsAny(err, store.OversizedEigenDAError, store.OversizedProxyError) {
+			svr.WriteBadRequest(w, err)
+			return meta, err
+		}
+
 		svr.WriteInternalError(w, err)
 		return meta, err
 	}

store/eigenda.go

@@ -66,7 +66,7 @@ func (e EigenDAStore) Put(ctx context.Context, value []byte) ([]byte, error) {
 		return nil, fmt.Errorf("EigenDA client failed to re-encode blob: %w", err)
 	}
 	if uint64(len(encodedBlob)) > e.cfg.MaxBlobSizeBytes {
-		return nil, fmt.Errorf("encoded blob is larger than max blob size: blob length %d, max blob size %d", len(value), e.cfg.MaxBlobSizeBytes)
+		return nil, fmt.Errorf("%s: blob length %d, max blob size %d", OversizedProxyError, len(value), e.cfg.MaxBlobSizeBytes)
 	}
 
 	dispersalStart := time.Now()

store/memory.go

@@ -134,7 +134,7 @@ func (e *MemStore) Get(_ context.Context, commit []byte) ([]byte, error) {
 func (e *MemStore) Put(_ context.Context, value []byte) ([]byte, error) {
 	time.Sleep(e.config.PutLatency)
 	if uint64(len(value)) > e.config.MaxBlobSizeBytes {
-		return nil, fmt.Errorf("blob is larger than max blob size: blob length %d, max blob size %d", len(value), e.config.MaxBlobSizeBytes)
+		return nil, fmt.Errorf("%s: blob length %d, max blob size %d", OversizedProxyError, len(value), e.config.MaxBlobSizeBytes)
 	}
 
 	e.Lock()

store/store.go

@@ -16,6 +16,11 @@ const (
 	Unknown
 )
 
+const (
+	OversizedProxyError   = "encoded blob is larger than max blob size"
+	OversizedEigenDAError = "blob size cannot exceed"
+)
+
 func (b BackendType) String() string {
 	switch b {
 	case EigenDA:

utils/utils.go

@@ -8,6 +8,21 @@ import (
 
 // Helper utility functions //
 
+func ErrorMessageContainsAny(err error, msgs ...string) bool {
+	if err == nil {
+		return false
+	}
+
+	errMsg := err.Error()
+	for _, str := range msgs {
+		if strings.Contains(errMsg, str) {
+			return true
+		}
+	}
+
+	return false
+}
+
 func ContainsDuplicates[P comparable](s []P) bool {
 	seen := make(map[P]struct{})
 	for _, v := range s {