hack(gateway): Detect protocol version and dynamically enable gzip compression for 0.14.2 (#3524)

hack(gateway): Use global variable to detect protocol version for gzip
support

Author: brbrr

clients/gateway/gateway.go

@@ -11,6 +11,7 @@ import (
 	"net/http"
 	"net/http/httptest"
 	"strings"
+	"sync/atomic"
 	"testing"
 	"time"
 
@@ -43,6 +44,8 @@ var (
 // Payload size threshold for Gzip compression. 1KB
 const gzipMinSize = 1024
 
+var IsProtocolVer0_14_2 atomic.Bool
+
 type Client struct {
 	url       string
 	client    *http.Client
@@ -205,7 +208,7 @@ func (c *Client) doPost(ctx context.Context, url string, data any) (*http.Respon
 }
 
 func prepareRequestBody(jsonBody []byte) (io.Reader, bool, error) {
-	if len(jsonBody) <= gzipMinSize {
+	if len(jsonBody) <= gzipMinSize || !IsProtocolVer0_14_2.Load() {
 		return bytes.NewReader(jsonBody), false, nil
 	}
 

clients/gateway/gateway_test.go

@@ -27,6 +27,9 @@ func TestAddInvokeTx(t *testing.T) {
 	})
 
 	t.Run("Large requests are gzip compressed", func(t *testing.T) {
+		gateway.IsProtocolVer0_14_2.Store(true)
+		t.Cleanup(func() { gateway.IsProtocolVer0_14_2.Store(false) })
+
 		largeCalldata := make([]string, 200)
 		for i := range largeCalldata {
 			largeCalldata[i] = "0xcafebabe"

core/version.go

@@ -13,6 +13,7 @@ var (
 	Ver0_13_4 = semver.MustParse("0.13.4")
 	Ver0_14_0 = semver.MustParse("0.14.0")
 	Ver0_14_1 = semver.MustParse("0.14.1")
+	Ver0_14_2 = semver.MustParse("0.14.2")
 	LatestVer = Ver0_14_1
 )
 

sync/sync.go

@@ -9,6 +9,7 @@ import (
 	"time"
 
 	"github.com/NethermindEth/juno/blockchain"
+	"github.com/NethermindEth/juno/clients/gateway"
 	"github.com/NethermindEth/juno/core"
 	"github.com/NethermindEth/juno/core/felt"
 	"github.com/NethermindEth/juno/db"
@@ -340,6 +341,12 @@ func (s *Synchronizer) verifierTask(
 	}
 
 	s.listener.OnSyncStepDone(OpVerify, committedBlock.Block.Number, time.Since(verifyTimer))
+	if !gateway.IsProtocolVer0_14_2.Load() {
+		ver, err := core.ParseBlockVersion(committedBlock.Block.ProtocolVersion)
+		if err == nil && !ver.LessThan(core.Ver0_14_2) {
+			gateway.IsProtocolVer0_14_2.Store(true)
+		}
+	}
 	return func() {
 		s.storeTask(ctx, committedBlock, resetStreams, commitments)
 	}