OriginTrail Testnet Release v6.5.1

ot-node.js

@@ -78,12 +78,6 @@ class OTNode {
             this.config,
         );
 
-        await MigrationExecutor.executeServiceAgreementPruningMigration(
-            this.container,
-            this.logger,
-            this.config,
-        );
-
         await this.initializeRouters();
         await this.startNetworkModule();
         this.startTelemetryModule();
@@ -96,6 +90,12 @@ 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+hotfix.2",
+    "version": "6.5.1",
     "description": "OTNode V6",
     "main": "index.js",
     "type": "module",

src/migration/remove-duplicate-service-agreement-migration.js

@@ -23,15 +23,19 @@ class RemoveDuplicateServiceAgreementMigration extends BaseMigration {
                     blockchainId,
                 );
             for (const serviceAgreement of findDuplicateServiceAgreements) {
-                const blockchainAssertionId =
-                    // eslint-disable-next-line no-await-in-loop
-                    await this.blockchainModuleManager.getAssertionIdByIndex(
-                        blockchainId,
-                        serviceAgreement.assetStorageContractAddress,
-                        serviceAgreement.tokenId,
-                        serviceAgreement.stateIndex,
-                    );
-                if (serviceAgreement.assertionId !== blockchainAssertionId) {
+                try {
+                    const blockchainAssertionId =
+                        // eslint-disable-next-line no-await-in-loop
+                        await this.blockchainModuleManager.getAssertionIdByIndex(
+                            blockchainId,
+                            serviceAgreement.assetStorageContractAddress,
+                            serviceAgreement.tokenId,
+                            serviceAgreement.stateIndex,
+                        );
+                    if (serviceAgreement.assertionId !== blockchainAssertionId) {
+                        incorrectServiceAgreementId.push(serviceAgreement.agreementId);
+                    }
+                } catch (error) {
                     incorrectServiceAgreementId.push(serviceAgreement.agreementId);
                 }
             }

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

@@ -303,10 +303,10 @@ class ServiceAgreementRepository {
         const query = `
             DELETE FROM service_agreement
             WHERE blockchain_id = '${blockchainId}'
-            AND asset_storage_contract_address = '${contract}'
+            AND asset_storage_contract_address != '${contract}'
             LIMIT 100000;
             `;
-        await this.model.query(query, {
+        await this.sequelize.query(query, {
             type: Sequelize.QueryTypes.DELETE,
         });
     }