diff --git a/package-lock.json b/package-lock.json index 90f9944f5d..1bdb02af6d 100644 --- a/package-lock.json +++ b/package-lock.json @@ -1,12 +1,12 @@ { "name": "origintrail_node", - "version": "6.2.2", + "version": "6.2.2+hotfix.2", "lockfileVersion": 2, "requires": true, "packages": { "": { "name": "origintrail_node", - "version": "6.2.2", + "version": "6.2.2+hotfix.2", "license": "ISC", "dependencies": { "@comunica/query-sparql": "^2.4.3", diff --git a/package.json b/package.json index 99fc299236..b23eb6d498 100644 --- a/package.json +++ b/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", diff --git a/src/commands/command-executor.js b/src/commands/command-executor.js index 5f2e36f057..e61b90ded3 100644 --- a/src/commands/command-executor.js +++ b/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} - * @private */ - async _delete(name) { + async delete(name) { await this.repositoryModuleManager.destroyCommand(name); } diff --git a/src/commands/protocols/common/epoch-check/blockchain-epoch-check-command.js b/src/commands/protocols/common/epoch-check/blockchain-epoch-check-command.js index b8eebc2008..2807d0da0a 100644 --- a/src/commands/protocols/common/epoch-check/blockchain-epoch-check-command.js +++ b/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; diff --git a/src/commands/protocols/common/epoch-check/epoch-check-command.js b/src/commands/protocols/common/epoch-check/epoch-check-command.js index ca4f459b36..f839a22090 100644 --- a/src/commands/protocols/common/epoch-check/epoch-check-command.js +++ b/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 = {