Fix encodng tx in stream (#2629) (#2631)

* Fixes Tx encoding in data stream * fix
0xPolygonHermez · Oct 9, 2023 · 52ee880 · 52ee880
1 parent d61b40d
commit 52ee880
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/sequencer/dbmanager.go b/sequencer/dbmanager.go
@@ -319,11 +319,16 @@ func (d *dbManager) StoreProcessedTxAndDeleteFromPool(ctx context.Context, tx tr
 			StateRoot:      l2BlockHeader.Root,
 		}
 
+		binaryTxData, err := tx.response.Tx.MarshalBinary()
+		if err != nil {
+			return err
+		}
+
 		l2Transaction := state.DSL2Transaction{
 			EffectiveGasPricePercentage: uint8(tx.response.EffectivePercentage),
 			IsValid:                     1,
-			EncodedLength:               uint32(len(txData)),
-			Encoded:                     txData,
+			EncodedLength:               uint32(len(binaryTxData)),
+			Encoded:                     binaryTxData,
 		}
 
 		d.dataToStream <- state.DSL2FullBlock{

diff --git a/sequencer/sequencer.go b/sequencer/sequencer.go
@@ -240,9 +240,6 @@ func (s *Sequencer) updateDataStreamerFile(ctx context.Context, streamServer *da
 	}
 
 	log.Infof("Current transaction index: %d", currentTxIndex)
-	if currentTxIndex == 0 {
-		currentL2Block++
-	}
 	log.Infof("Current L2 block number: %d", currentL2Block)
 
 	var limit uint64 = 1000