WIP

system_tests/espresso_test.go

@@ -3,6 +3,7 @@ package arbtest
 import (
 	"context"
 	"encoding/json"
+	"fmt"
 	"net/http"
 	"testing"
 	"time"
@@ -195,8 +196,10 @@ func waitForValidated(
 	defer cancel()
 
 	for {
-		// cnt := client.ConsensusNode.BlockValidator.Validated(t)
-		cnt := arbutil.MessageIndex(0)
+		cnt := client.ConsensusNode.BlockValidator.Validated(t)
+		inboxCnt, _ := client.ConsensusNode.InboxTracker.GetBatchCount()
+		log.Info(fmt.Sprintf("validated cnt: %d", cnt))
+		log.Info(fmt.Sprintf("sequencer inbox cnt: %d", inboxCnt))
 		expected := arbutil.MessageIndex(expectedCnt)
 		if cnt >= expected {
 			return nil
@@ -221,7 +224,7 @@ func TestEspresso(t *testing.T) {
 
 	// // An initial message and message should be produced per block containing txs
 	expectedMsgCnt := 1 + len(block_txs_generators())
-	err := waitForMsgCnt(t, ctx, expectedMsgCnt+1, l2Node)
+	err := waitForMsgCnt(t, ctx, expectedMsgCnt, l2Node)
 	Require(t, err)
 
 	poster, cleanPoster := createPosterNode(ctx, t)