Function rollup

packages/core/src/utils/AbstractMigrator.ts:147–247

* @inheritDoc

(migrations?: string[])

   * @inheritDoc
   */
  async rollup(migrations?: string[]): Promise<MigrationResult> {
    await this.init();
    const { fs } = await import('@mikro-orm/core/fs-utils');

    const all = await this.discoverMigrations();
    const executedSet = new Set(await this.storage.executed());

    let toRollup: RunnableMigration[];

    if (migrations && migrations.length > 0) {
      const requested = new Set(migrations.map(m => this.getMigrationFilename(m)));
      toRollup = all.filter(m => requested.has(m.name));

      const found = new Set(toRollup.map(m => m.name));
      const notFound = [...requested].filter(name => !found.has(name));

      if (notFound.length > 0) {
        throw new Error(`Migrations not found: ${notFound.join(', ')}`);
      }

      const notExecuted = toRollup.filter(m => !executedSet.has(m.name));

      if (notExecuted.length > 0) {
        throw new Error(
          `Cannot roll up migrations that have not been executed: ${notExecuted.map(m => m.name).join(', ')}`,
        );
      }
    } else {
      toRollup = all.filter(m => executedSet.has(m.name));
    }

    if (toRollup.length < 2) {
      throw new Error('At least 2 executed migrations are required for rollup');
    }

    const withoutPath = toRollup.filter(m => !m.path);

    if (withoutPath.length > 0) {
      throw new Error(
        `Cannot roll up migrations without file paths (class-based migrations): ${withoutPath.map(m => m.name).join(', ')}`,
      );
    }

    const upBodies: string[] = [];
    const downBodies: string[] = [];
    const placeholder = `__mikro_orm_rollup_${Date.now()}__`;

    for (const migration of toRollup) {
      const source = await fs.readFile(migration.path!);
      const upBody = this.extractMethodBody(source, 'up');
      const downBody = this.extractMethodBody(source, 'down');

      if (upBody) {
        upBodies.push(`    // --- merged from ${migration.name} ---\n${upBody}`);
      }

      if (downBody) {
        downBodies.unshift(`    // --- merged from ${migration.name} ---\n${downBody}`);