fix query DS by batch (#3803)

0xPolygonHermez · Nov 4, 2024 · 8335850 · 8335850 · rahaftiya11 · Nov 15, 2024
1 parent 596741e
commit 8335850
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/tools/datastreamer/main.go b/tools/datastreamer/main.go
@@ -685,8 +685,9 @@ func decodeBatch(cliCtx *cli.Context) error {
 	batchData = append(batchData, entry.Encode()...)
 
 	i := uint64(1) //nolint:gomnd
+	start := entry.Number
 	for {
-		entry, err := client.ExecCommandGetEntry(entry.Number + i)
+		entry, err := client.ExecCommandGetEntry(start + i)
 		if err != nil {
 			log.Error(err)
 			os.Exit(1)
@@ -760,8 +761,9 @@ func decodeBatchOffline(cliCtx *cli.Context) error {
 	i := uint64(1) //nolint:gomnd
 	printEntry(entry, shouldPrintJson)
 	batchData = append(batchData, entry.Encode()...)
+	start := entry.Number
 	for {
-		entry, err = streamServer.GetEntry(entry.Number + i)
+		entry, err = streamServer.GetEntry(start + i)
 		if err != nil {
 			log.Error(err)
 			os.Exit(1)