Refactor store.service Add support for relations, enums, subscription on Schema Migration

packages/node-core/CHANGELOG.md

@@ -4,8 +4,12 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
-
 ## [Unreleased]
+### Added
+- Schema Migration support for Enums, Relations, Subscription (#2251)
+- 
+### Fixed
+- Fixed non-atomic schema migration execution (#2244)
 
 ## [7.2.1] - 2024-02-07
 ### Added

packages/node-core/package.json

@@ -41,6 +41,7 @@
     "prom-client": "^14.0.1",
     "source-map": "^0.7.4",
     "tar": "^6.1.11",
+    "toposort-class": "^1.0.1",
     "vm2": "^3.9.19",
     "yargs": "^16.2.0"
   },

packages/node-core/src/configure/ProjectUpgrade.service.ts

@@ -7,11 +7,11 @@ import {ParentProject} from '@subql/types-core';
 import {getAllEntitiesRelations} from '@subql/utils';
 import {Sequelize, Transaction} from '@subql/x-sequelize';
 import {findLast, last, parseInt} from 'lodash';
+import {SchemaMigrationService} from '../db';
 import {ISubqueryProject, StoreCacheService, StoreService} from '../indexer';
 import {getLogger} from '../logger';
 import {getStartHeight, mainThreadOnly} from '../utils';
 import {BlockHeightMap} from '../utils/blockHeightMap';
-import {SchemaMigrationService} from './migration-service';
 import {NodeConfig} from './NodeConfig';
 
 type OnProjectUpgradeCallback<P> = (height: number, project: P) => void | Promise<void>;
@@ -230,7 +230,6 @@ export class ProjectUpgradeSevice<P extends ISubqueryProject = ISubqueryProject>
       assert(this.migrationService, 'MigrationService is undefined');
       if (this.config.allowSchemaMigration) {
         const modifiedModels = await this.migrationService.run(project.schema, newProject.schema, transaction);
-
         if (modifiedModels) {
           this.#storeCache?.updateModels(modifiedModels);
         }

packages/node-core/src/configure/index.ts

@@ -4,4 +4,3 @@
 export * from './configure.module';
 export * from './NodeConfig';
 export * from './ProjectUpgrade.service';
-export * from './migration-service';

packages/node-core/src/db/index.ts

@@ -2,3 +2,5 @@
 // SPDX-License-Identifier: GPL-3.0
 
 export * from './db.module';
+export * from './migration-service';
+export * from './sync-helper';