Merge pull request #2897 from OriginTrail/v6/feature/remove-service-a…

…greements-for-chiado-devnet

Added new migration for removal of service agreements for Chiado Devnet

ot-node.js

@@ -49,6 +49,12 @@ class OTNode {
 
         await this.initializeModules();
 
+        await MigrationExecutor.executeRemoveServiceAgreementsForChiadoDevnetMigration(
+            this.container,
+            this.logger,
+            this.config,
+        );
+
         await this.createProfiles();
 
         await this.initializeCommandExecutor();

src/migration/migration-executor.js

@@ -15,6 +15,7 @@ import ServiceAgreementsInvalidDataMigration from './service-agreements-invalid-
 import UalExtensionUserConfigurationMigration from './ual-extension-user-configuration-migration.js';
 import UalExtensionTripleStoreMigration from './ual-extension-triple-store-migration.js';
 import MarkStakingEventsAsProcessedMigration from './mark-staking-events-as-processed-migration.js';
+import RemoveServiceAgreementsForChiadoDevnetMigration from './remove-service-agreements-for-chiado-devnet-migration.js';
 
 class MigrationExecutor {
     static async executePullShardingTableMigration(container, logger, config) {
@@ -364,6 +365,29 @@ class MigrationExecutor {
         }
     }
 
+    static async executeRemoveServiceAgreementsForChiadoDevnetMigration(container, logger, config) {
+        if (process.env.NODE_ENV === NODE_ENVIRONMENTS.DEVNET) {
+            const repositoryModuleManager = container.resolve('repositoryModuleManager');
+
+            const migration = new RemoveServiceAgreementsForChiadoDevnetMigration(
+                'removeServiceAgreementsForChiadoDevnetMigration',
+                logger,
+                config,
+                repositoryModuleManager,
+            );
+            if (!(await migration.migrationAlreadyExecuted())) {
+                try {
+                    await migration.migrate();
+                } catch (error) {
+                    logger.error(
+                        `Unable to execute remove service agreements for Chiado Devnet migration. Error: ${error.message}`,
+                    );
+                    this.exitNode(1);
+                }
+            }
+        }
+    }
+
     static exitNode(code = 0) {
         process.exit(code);
     }

src/migration/remove-service-agreements-for-chiado-devnet-migration.js

@@ -0,0 +1,18 @@
+import BaseMigration from './base-migration.js';
+
+const GNOSIS_DEVNET_CHAIN_ID = 'gnosis:10200';
+
+class RemoveServiceAgreementsForChiadoDevnetMigration extends BaseMigration {
+    constructor(migrationName, logger, config, repositoryModuleManager) {
+        super(migrationName, logger, config);
+        this.repositoryModuleManager = repositoryModuleManager;
+    }
+
+    async executeMigration() {
+        await this.repositoryModuleManager.removeServiceAgreementsForBlockchain(
+            GNOSIS_DEVNET_CHAIN_ID,
+        );
+    }
+}
+
+export default RemoveServiceAgreementsForChiadoDevnetMigration;

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

@@ -21,6 +21,14 @@ class ServiceAgreementRepository {
         });
     }
 
+    async removeServiceAgreementsForBlockchain(blockchainId) {
+        await this.model.destroy({
+            where: {
+                blockchainId,
+            },
+        });
+    }
+
     async updateServiceAgreementRecord(
         blockchainId,
         assetStorageContractAddress,

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

@@ -416,6 +416,12 @@ class RepositoryModuleManager extends BaseModuleManager {
         return this.getRepository('service_agreement').removeServiceAgreements(agreementIds);
     }
 
+    async removeServiceAgreementsForBlockchain(blockchainId) {
+        return this.getRepository('service_agreement').removeServiceAgreementsForBlockchain(
+            blockchainId,
+        );
+    }
+
     async updateServiceAgreementEpochsNumber(agreementId, epochsNumber) {
         return this.getRepository('service_agreement').updateServiceAgreementEpochsNumber(
             agreementId,