Devnet pruning migration for Neuro tables (#3267)

config/config.json

@@ -637,7 +637,7 @@
                         "enabled": false,
                         "package": "./blockchain/implementation/ot-parachain/ot-parachain-service.js",
                         "config": {
-                            "hubContractAddress": "0x833048F6e6BEa78E0AAdedeCd2Dc2231dda443FB",
+                            "hubContractAddress": "0x0425d8717a9c63345a26C7885CF8c0fEAbcE7bC9",
                             "rpcEndpoints": [
                                 "https://lofar-tm-rpc.origin-trail.network",
                                 "https://lofar.origintrail.network"

ot-node.js

@@ -78,6 +78,18 @@ class OTNode {
             this.config,
         );
 
+        await MigrationExecutor.executeServiceAgreementPruningMigration(
+            this.container,
+            this.logger,
+            this.config,
+        );
+
+        await MigrationExecutor.executeDevnetNeuroPruningMigration(
+            this.container,
+            this.logger,
+            this.config,
+        );
+
         await this.initializeRouters();
         await this.startNetworkModule();
         this.startTelemetryModule();

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/devnet-neuro-pruning-migration.js

@@ -0,0 +1,34 @@
+import BaseMigration from './base-migration.js';
+import { NODE_ENVIRONMENTS } from '../constants/constants.js';
+
+class DevnetNeuroPruningMigration extends BaseMigration {
+    constructor(migrationName, logger, config, repositoryModuleManager) {
+        super(migrationName, logger, config);
+        this.repositoryModuleManager = repositoryModuleManager;
+    }
+
+    async executeMigration() {
+        if (process.env.NODE_ENV === NODE_ENVIRONMENTS.DEVNET) {
+            this.logger.info('Pruning Neuro devenet tables');
+            // commands are not here as parsing JSON in SQL would take too much time
+            const tables = [
+                'blockchain',
+                'blockchain_event',
+                'event',
+                'missed_paranet_asset',
+                'paranet',
+                'service_agreement',
+                'shard',
+            ];
+            for (const table of tables) {
+                const query = `
+                  DELETE FROM ${table} 
+                  WHERE blockchain_id = 'otp:2160'`;
+                // eslint-disable-next-line no-await-in-loop
+                await this.repositoryModuleManager.query(query);
+            }
+        }
+    }
+}
+
+export default DevnetNeuroPruningMigration;

src/migration/migration-executor.js

@@ -20,6 +20,7 @@ import MultipleOpWalletsUserConfigurationMigration from './multiple-op-wallets-u
 import GetOldServiceAgreementsMigration from './get-old-service-agreements-migration.js';
 import ServiceAgreementPruningMigration from './service-agreement-pruning-migration.js';
 import RemoveDuplicateServiceAgreementMigration from './remove-duplicate-service-agreement-migration.js';
+import DevnetNeuroPruningMigration from './devnet-neuro-pruning-migration.js';
 
 class MigrationExecutor {
     static async executePullShardingTableMigration(container, logger, config) {
@@ -502,6 +503,32 @@ class MigrationExecutor {
         }
     }
 
+    static async executeDevnetNeuroPruningMigration(container, logger, config) {
+        if (
+            process.env.NODE_ENV === NODE_ENVIRONMENTS.DEVELOPMENT ||
+            process.env.NODE_ENV === NODE_ENVIRONMENTS.TEST
+        )
+            return;
+
+        const repositoryModuleManager = container.resolve('repositoryModuleManager');
+
+        const migration = new DevnetNeuroPruningMigration(
+            'devnetNeuroPruningMigration',
+            logger,
+            config,
+            repositoryModuleManager,
+        );
+        if (!(await migration.migrationAlreadyExecuted())) {
+            try {
+                await migration.migrate();
+            } catch (error) {
+                logger.error(
+                    `Unable to execute devnet neuro pruning migration. Error: ${error.message}`,
+                );
+            }
+        }
+    }
+
     static exitNode(code = 0) {
         process.exit(code);
     }

src/modules/blockchain/implementation/ot-parachain/ot-parachain-service.js

@@ -22,7 +22,7 @@ class OtParachainService extends Web3Service {
         this.logger = logger;
         this.rpcNumber = 0;
         await this.initializeParachainProvider();
-        await this.checkEvmWallets();
+        // await this.checkEvmWallets();
         await this.parachainProvider.disconnect();
         await super.initialize(config, logger);
     }