fix(settlement): filter by pending status in batch event (#845)

dymensionxyz · May 18, 2024 · 45f9216 · 45f9216
1 parent 3e89a94
commit 45f9216
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git 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'"
 )
 

diff --git a/settlement/dymension/dymension_test.go b/settlement/dymension/dymension_test.go
@@ -190,7 +190,7 @@ func TestPostBatch(t *testing.T) {
 			if c.isBatchAcceptedHubEvent {
 				time.Sleep(100 * time.Millisecond)
 				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"},
-Original file line number
+Diff line change
@@ Expand Up / @@ -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'"
     )
@@ Expand Down @@