Merge pull request #31 from hive-engine/fixBlocklogReplay

fix replay with blocklog
hive-engine · Jan 15, 2021 · 7e17fd9 · 7e17fd9
2 parents 25c2795 + b95f562
commit 7e17fd9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/plugins/Blockchain.js b/plugins/Blockchain.js
@@ -112,7 +112,7 @@ const produceNewBlockSync = async (block, callback = null) => {
   // the stream parsed transactions from the Hive blockchain
   const {
     refHiveBlockNumber, refHiveBlockId, prevRefHiveBlockId,
-    transactions, timestamp, virtualTransactions,
+    transactions, timestamp, virtualTransactions, replay
   } = block;
   const newTransactions = [];
 
@@ -130,7 +130,7 @@ const produceNewBlockSync = async (block, callback = null) => {
   });
 
   // if there are transactions pending we produce a block
-  if (newTransactions.length > 0 || (virtualTransactions && virtualTransactions.length > 0)) {
+  if (newTransactions.length > 0 || (virtualTransactions && virtualTransactions.length > 0) || replay) {
     await producePendingTransactions(
       refHiveBlockNumber, refHiveBlockId, prevRefHiveBlockId, newTransactions, timestamp,
     );

diff --git a/plugins/Replay.js b/plugins/Replay.js
@@ -74,14 +74,15 @@ function replayFile(callback) {
               finalPrevRefHiveBlockId = hiveBlock.previous;
             }
 
+	    // do not pass over the virtual txs, it will be generated by Blockchain plugin
             await sendBlock({
               blockNumber,
               timestamp,
               refHiveBlockNumber,
               refHiveBlockId: finalRefHiveBlockId,
               prevRefHiveBlockId: finalPrevRefHiveBlockId,
               transactions,
-              virtualTransactions,
+	      replay: true,
             });
           }
         }