From 5aa9f234fc9a3293fc5360a853edbaebcfbd4ff9 Mon Sep 17 00:00:00 2001
From: ImJeremyHe <yiliang.he@qq.com>
Date: Fri, 1 Dec 2023 23:17:53 +0800
Subject: [PATCH] WIP

---
 system_tests/espresso_test.go | 9 ++++++---
 1 file changed, 6 insertions(+), 3 deletions(-)

diff --git a/system_tests/espresso_test.go b/system_tests/espresso_test.go
index 5288391d59..5b86921339 100644
--- a/system_tests/espresso_test.go
+++ b/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)