feat(test): Big improvements in test

Makefile

@@ -17,11 +17,9 @@ lint:
 	&& golangci-lint run
 
 test:
-	@TAIKO_MONO_DIR=${TAIKO_MONO_DIR} \
-	COMPILE_PROTOCOL=${COMPILE_PROTOCOL} \
-	PACKAGE=${PACKAGE} \
-	RUN_TESTS=true \
-		./integration_test/entrypoint.sh
+	docker pull ghcr.io/foundry-rs/foundry:latest  \
+	&& docker pull gcr.io/evmchain/taiko-geth:taiko  \
+	&& go test ./... -coverprofile=coverage.out -covermode=atomic -timeout=300s
 
 dev_net:
 	@TAIKO_MONO_DIR=${TAIKO_MONO_DIR} \

driver/anchor_tx_constructor/anchor_tx_constructor_test.go

@@ -3,37 +3,46 @@ package anchorTxConstructor
 import (
 	"context"
 	"math/big"
-	"os"
 	"testing"
 
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/ethereum/go-ethereum/common/hexutil"
 	"github.com/ethereum/go-ethereum/crypto"
 	"github.com/stretchr/testify/suite"
+	"github.com/taikoxyz/taiko-client/pkg/rpc"
 	"github.com/taikoxyz/taiko-client/testutils"
+	"github.com/taikoxyz/taiko-client/testutils/helper"
 )
 
 type AnchorTxConstructorTestSuite struct {
 	testutils.ClientTestSuite
-	l1Height *big.Int
-	l1Hash   common.Hash
-	c        *AnchorTxConstructor
+	l1Height  *big.Int
+	l1Hash    common.Hash
+	c         *AnchorTxConstructor
+	rpcClient *rpc.Client
 }
 
 func (s *AnchorTxConstructorTestSuite) SetupTest() {
 	s.ClientTestSuite.SetupTest()
+	s.rpcClient = helper.NewWsRpcClient(&s.ClientTestSuite)
+
 	c, err := New(
-		s.RpcClient,
-		common.HexToAddress(os.Getenv("L1_SIGNAL_SERVICE_CONTRACT_ADDRESS")),
+		s.rpcClient,
+		s.L1.TaikoL1SignalService,
 	)
 	s.Nil(err)
-	head, err := s.RpcClient.L1.BlockByNumber(context.Background(), nil)
+	head, err := s.rpcClient.L1.BlockByNumber(context.Background(), nil)
 	s.Nil(err)
 	s.l1Height = head.Number()
 	s.l1Hash = head.Hash()
 	s.c = c
 }
 
+func (s *AnchorTxConstructorTestSuite) TearDownTest() {
+	s.rpcClient.Close()
+	s.ClientTestSuite.TearDownTest()
+}
+
 func (s *AnchorTxConstructorTestSuite) TestGasLimit() {
 	s.Greater(s.c.GasLimit(), uint64(0))
 }
@@ -45,13 +54,10 @@ func (s *AnchorTxConstructorTestSuite) TestAssembleAnchorTx() {
 }
 
 func (s *AnchorTxConstructorTestSuite) TestNewAnchorTransactor() {
-	goldenTouchAddress, err := s.RpcClient.TaikoL2.GOLDENTOUCHADDRESS(nil)
+	goldenTouchAddress, err := s.rpcClient.TaikoL2.GOLDENTOUCHADDRESS(nil)
 	s.Nil(err)
 
-	c, err := New(
-		s.RpcClient,
-		common.HexToAddress(os.Getenv("L1_SIGNAL_SERVICE_CONTRACT_ADDRESS")),
-	)
+	c, err := New(s.rpcClient, s.L1.TaikoL1SignalService)
 	s.Nil(err)
 
 	opts, err := c.transactOpts(context.Background(), common.Big1, common.Big256)
@@ -74,7 +80,7 @@ func (s *AnchorTxConstructorTestSuite) TestCancelCtxTransactOpts() {
 func (s *AnchorTxConstructorTestSuite) TestSign() {
 	// Payload 1
 	hash := hexutil.MustDecode("0x44943399d1507f3ce7525e9be2f987c3db9136dc759cb7f92f742154196868b9")
-	signatureBytes := testutils.SignatureFromRSV(
+	signatureBytes := helper.SignatureFromRSV(
 		"0x79be667ef9dcbbac55a06295ce870b07029bfcdb2dce28d959f2815b16f81798",
 		"0x782a1e70872ecc1a9f740dd445664543f8b7598c94582720bca9a8c48d6a4766",
 		1,
@@ -89,7 +95,7 @@ func (s *AnchorTxConstructorTestSuite) TestSign() {
 
 	// Payload 2
 	hash = hexutil.MustDecode("0x663d210fa6dba171546498489de1ba024b89db49e21662f91bf83cdffe788820")
-	signatureBytes = testutils.SignatureFromRSV(
+	signatureBytes = helper.SignatureFromRSV(
 		"0x79be667ef9dcbbac55a06295ce870b07029bfcdb2dce28d959f2815b16f81798",
 		"0x568130fab1a3a9e63261d4278a7e130588beb51f27de7c20d0258d38a85a27ff",
 		1,
@@ -104,7 +110,7 @@ func (s *AnchorTxConstructorTestSuite) TestSign() {
 }
 
 func (s *AnchorTxConstructorTestSuite) TestSignShortHash() {
-	rand := testutils.RandomHash().Bytes()
+	rand := helper.RandomHash().Bytes()
 	hash := rand[:len(rand)-2]
 	_, err := s.c.signTxPayload(hash)
 	s.ErrorContains(err, "hash is required to be exactly 32 bytes")

driver/chain_syncer/beaconsync/progress_tracker_test.go

@@ -8,18 +8,26 @@ import (
 	"github.com/ethereum/go-ethereum"
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/stretchr/testify/suite"
+	"github.com/taikoxyz/taiko-client/pkg/rpc"
 	"github.com/taikoxyz/taiko-client/testutils"
+	"github.com/taikoxyz/taiko-client/testutils/helper"
 )
 
 type BeaconSyncProgressTrackerTestSuite struct {
 	testutils.ClientTestSuite
-	t *SyncProgressTracker
+	t         *SyncProgressTracker
+	rpcClient *rpc.Client
 }
 
 func (s *BeaconSyncProgressTrackerTestSuite) SetupTest() {
 	s.ClientTestSuite.SetupTest()
+	s.rpcClient = helper.NewWsRpcClient(&s.ClientTestSuite)
+	s.t = NewSyncProgressTracker(s.rpcClient.L2, 30*time.Second)
+}
 
-	s.t = NewSyncProgressTracker(s.RpcClient.L2, 30*time.Second)
+func (s *BeaconSyncProgressTrackerTestSuite) TearDownTest() {
+	s.rpcClient.Close()
+	s.ClientTestSuite.TearDownTest()
 }
 
 func (s *BeaconSyncProgressTrackerTestSuite) TestSyncProgressed() {
@@ -58,7 +66,7 @@ func (s *BeaconSyncProgressTrackerTestSuite) TestTrack() {
 
 	// Triggered
 	ctx, cancel = context.WithCancel(context.Background())
-	s.t.UpdateMeta(common.Big256, common.Big256, testutils.RandomHash())
+	s.t.UpdateMeta(common.Big256, common.Big256, helper.RandomHash())
 	go s.t.Track(ctx)
 	time.Sleep(syncProgressCheckInterval + 5*time.Second)
 	cancel()
@@ -101,7 +109,7 @@ func (s *BeaconSyncProgressTrackerTestSuite) TestLastSyncedVerifiedBlockHash() {
 		common.HexToHash("0x0000000000000000000000000000000000000000000000000000000000000000"),
 		s.t.LastSyncedVerifiedBlockHash(),
 	)
-	randomHash := testutils.RandomHash()
+	randomHash := helper.RandomHash()
 	s.t.lastSyncedVerifiedBlockHash = randomHash
 	s.Equal(randomHash, s.t.LastSyncedVerifiedBlockHash())
 }

driver/chain_syncer/calldata/syncer.go

@@ -25,10 +25,8 @@ import (
 	txListValidator "github.com/taikoxyz/taiko-client/pkg/tx_list_validator"
 )
 
-var (
-	// Brecht recommends to hardcore 79, may be unrequired as proof system changes
-	defaultMaxTxPerBlock = uint64(79)
-)
+// Brecht recommends to hardcore 79, may be unrequired as proof system changes
+var defaultMaxTxPerBlock = uint64(79)
 
 // Syncer responsible for letting the L2 execution engine catching up with protocol's latest
 // pending block through deriving L1 calldata.
@@ -141,7 +139,7 @@ func (s *Syncer) onBlockProposed(
 	}
 
 	if !s.progressTracker.Triggered() {
-		// Check whteher we need to reorg the L2 chain at first.
+		// Check whether we need to reorg the L2 chain at first.
 		// 1. Last verified block
 		var (
 			reorged                    bool