Function createMigrationHandler

packages/core/src/utils/AbstractMigrator.ts:454–463

(method: 'up' | 'down', afterRun?: (tx?: Transaction) => Promise<void>)

  protected resolve(params: { name: string; path: string }): RunnableMigration {
    const createMigrationHandler = async (method: 'up' | 'down', afterRun?: (tx?: Transaction) => Promise<void>) => {
      const { fs } = await import('@mikro-orm/core/fs-utils');
      const migration = await fs.dynamicImport(params.path);
      const MigrationClass = Object.values(migration).find(
        cls => typeof cls === 'function' && typeof cls.constructor === 'function',
      ) as Constructor<Migration>;
      const instance = new MigrationClass(this.driver, this.config);

      await this.runner.run(instance, method, afterRun);
    };

    return {
      name: this.storage.getMigrationName(params.name),