Merge pull request #3079 from OriginTrail/v6/prerelease/testnet

OriginTrail Tesnet Release v6.2.2 Hotfix 2

package.json

@@ -1,6 +1,6 @@
 {
     "name": "origintrail_node",
-    "version": "6.2.2",
+    "version": "6.2.2+hotfix.2",
     "description": "OTNode V6",
     "main": "index.js",
     "type": "module",

src/commands/command-executor.js

@@ -233,7 +233,7 @@ class CommandExecutor {
      * @private
      */
     async _addDefaultCommand(name) {
-        await this._delete(name);
+        await this.delete(name);
         const handler = this.commandResolver.resolve(name);
         if (!handler) {
             this.logger.warn(`Command '${name}' will not be executed.`);
@@ -376,9 +376,8 @@ class CommandExecutor {
      * Delete command from database
      * @param name
      * @returns {Promise<void>}
-     * @private
      */
-    async _delete(name) {
+    async delete(name) {
         await this.repositoryModuleManager.destroyCommand(name);
     }
 

src/commands/protocols/common/epoch-check/blockchain-epoch-check-command.js

@@ -57,7 +57,14 @@ class BlockchainEpochCheckCommand extends Command {
 
         const transactionQueueLength =
             this.blockchainModuleManager.getTotalTransactionQueueLength(blockchain);
-        if (transactionQueueLength >= totalTransactions) return;
+        if (transactionQueueLength >= totalTransactions) {
+            this.logger.debug(
+                `Epoch check: Current transaction queue length is ${transactionQueueLength}, ` +
+                    `exceeding the maximum total transactions: ${totalTransactions} for ${blockchain}` +
+                    `with operation id: ${operationId}`,
+            );
+            return Command.repeat();
+        }
 
         totalTransactions -= transactionQueueLength;
 

src/commands/protocols/common/epoch-check/epoch-check-command.js

@@ -24,6 +24,8 @@ class EpochCheckCommand extends Command {
             `Epoch check: Starting epoch check command for operation id: ${operationId}`,
         );
 
+        await this.commandExecutor.delete('blockchainEpochCheckCommand');
+
         await Promise.all(
             this.blockchainModuleManager.getImplementationNames().map(async (blockchain) => {
                 const commandData = {