Migration fixes

ot-node.js

@@ -78,6 +78,12 @@ class OTNode {
             this.config,
         );
 
+        await MigrationExecutor.executeServiceAgreementPruningMigration(
+            this.container,
+            this.logger,
+            this.config,
+        );
+
         await this.initializeRouters();
         await this.startNetworkModule();
         this.startTelemetryModule();
@@ -90,13 +96,6 @@ class OTNode {
             this.config,
         );
 
-
-        MigrationExecutor.executeServiceAgreementPruningMigration(
-            this.container,
-            this.logger,
-            this.config,
-        );
-
         MigrationExecutor.executeRemoveDuplicateServiceAgreementMigration(
             this.container,
             this.logger,

package.json

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

src/migration/migration-executor.js

@@ -496,7 +496,7 @@ class MigrationExecutor {
                 await migration.migrate();
             } catch (error) {
                 logger.error(
-                    `Unable to execute service agreement pruning migration. Error: ${error.message}`,
+                    `Unable to execute remove duplicate service agreement migration. Error: ${error.message}`,
                 );
             }
         }

src/migration/service-agreement-pruning-migration.js

@@ -24,11 +24,22 @@ class ServiceAgreementPruningMigration extends BaseMigration {
                 // eslint-disable-next-line no-await-in-loop
                 await this.blockchainModuleManager.getAssetStorageContractAddresses(blockchainId);
 
-            // eslint-disable-next-line no-await-in-loop
-            await this.repositoryModuleManager.removeServiceAgreementsByBlockchainAndContract(
-                blockchainId,
-                assetStorageContractAddresses[0],
-            );
+            const countOfServiceAgreementsToBeRemoved =
+                // eslint-disable-next-line no-await-in-loop
+                await this.repositoryModuleManager.getCountOfServiceAgreementsByBlockchainAndContract(
+                    blockchainId,
+                    assetStorageContractAddresses[0],
+                );
+
+            // removeServiceAgreementsByBlockchainAndContract deletes in batches od 100_000
+            const numberOfIteration = Math.ceil(countOfServiceAgreementsToBeRemoved / 100_000);
+            for (let i = 0; i < numberOfIteration; i += 1) {
+                // eslint-disable-next-line no-await-in-loop
+                await this.repositoryModuleManager.removeServiceAgreementsByBlockchainAndContract(
+                    blockchainId,
+                    assetStorageContractAddresses[0],
+                );
+            }
         }
     }
 }

src/modules/repository/implementation/sequelize/repositories/service-agreement-repository.js

@@ -287,9 +287,8 @@ class ServiceAgreementRepository {
         });
     }
 
-
-    async removeServiceAgreementsByBlockchainAndContract(blockchainId, contract) {
-        await this.model.destroy({
+    async getCountOfServiceAgreementsByBlockchainAndContract(blockchainId, contract) {
+        await this.model.count({
             where: {
                 blockchainId,
                 assetStorageContractAddress: {
@@ -298,7 +297,19 @@ class ServiceAgreementRepository {
             },
         });
     }
-
+
+    async removeServiceAgreementsByBlockchainAndContract(blockchainId, contract) {
+        const query = `
+            DELETE FROM service_agreement
+            WHERE blockchain_id = '${blockchainId}'
+            AND asset_storage_contract_address = '${contract}'
+            LIMIT 100000;
+            `;
+        await this.model.query(query, {
+            type: Sequelize.QueryTypes.DELETE,
+        });
+    }
+
     async findDuplicateServiceAgreements(blockchainId) {
         return this.model.findAll({
             attributes: ['token_id', [Sequelize.fn('COUNT', Sequelize.col('*')), 'count']],

src/modules/repository/repository-module-manager.js

@@ -403,6 +403,14 @@ class RepositoryModuleManager extends BaseModuleManager {
         }
     }
 
+    async getCountOfServiceAgreementsByBlockchainAndContract(blockchainId, contract) {
+        if (this.initialized) {
+            return this.getRepository(
+                'service_agreement',
+            ).getCountOfServiceAgreementsByBlockchainAndContract(blockchainId, contract);
+        }
+    }
+
     async removeServiceAgreementsByBlockchainAndContract(blockchainId, contract) {
         if (this.initialized) {
             return this.getRepository(