From 5885c35fbff033537ee08bda711b33353d4ddd15 Mon Sep 17 00:00:00 2001 From: Sergi Rene Date: Fri, 10 May 2024 16:09:37 +0200 Subject: [PATCH 1/2] add pending filter in new batch event query --- settlement/dymension/dymension.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/settlement/dymension/dymension.go b/settlement/dymension/dymension.go index f5a89ac7e..386b62829 100644 --- a/settlement/dymension/dymension.go +++ b/settlement/dymension/dymension.go @@ -40,7 +40,7 @@ const ( ) const ( - eventStateUpdate = "state_update.rollapp_id='%s'" + eventStateUpdate = "state_update.rollapp_id='%s' AND state_update.status='PENDING'" eventSequencersListUpdate = "sequencers_list_update.rollapp_id='%s'" ) From 5c49e8cf313661cb036a2308d58416310f72eaa7 Mon Sep 17 00:00:00 2001 From: Sergi Rene Date: Fri, 10 May 2024 22:06:19 +0200 Subject: [PATCH 2/2] fix test --- settlement/dymension/dymension_test.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/settlement/dymension/dymension_test.go b/settlement/dymension/dymension_test.go index a1a8d80fd..b3ea41b21 100644 --- a/settlement/dymension/dymension_test.go +++ b/settlement/dymension/dymension_test.go @@ -229,7 +229,7 @@ func TestPostBatch(t *testing.T) { time.Sleep(50 * time.Millisecond) if c.isBatchAcceptedHubEvent { batchAcceptedCh <- coretypes.ResultEvent{ - Query: fmt.Sprintf("state_update.rollapp_id='%s'", ""), + Query: fmt.Sprintf("state_update.rollapp_id='%s' AND state_update.status='PENDING'", ""), Events: map[string][]string{ "state_update.num_blocks": {"1"}, "state_update.start_height": {"1"},