如何在NestJS中通过自定义命令调用其他NestJS命令？

下面提供三种可行的实现方式，你可以根据项目场景选择：

方式一：直接调用目标命令类的执行逻辑 #

如果你的目标命令（比如migration:some-schema-update:up）是基于@nestjs-commander实现的类，可以在启动器命令中直接注入并调用其run方法：

import { Command, CommandRunner } from '@nestjs-commander';
import { SomeSchemaUpdateUpCommand } from './some-schema-update-up.command';

@Command({ name: 'migrations:run', description: '批量执行所有迁移命令' })
export class MigrationsRunCommand extends CommandRunner {
  constructor(
    private readonly someSchemaUpdateUpCommand: SomeSchemaUpdateUpCommand
  ) {
    super();
  }

  async run(passedParams: string[], options?: Record<string, any>): Promise<void> {
    // 直接调用目标命令的执行逻辑
    await this.someSchemaUpdateUpCommand.run(passedParams, options);
    
    // 可以继续添加其他迁移命令的调用
    // await this.anotherMigrationCommand.run(passedParams, options);
  }
}

优势：无需依赖外部CLI环境，完全在代码层面执行，便于单元测试和调试。

方式二：通过子进程调用Nest CLI命令 #

如果你的迁移命令是通过nest CLI触发的，可以用Node.js的child_process模块启动子进程执行：

import { Command, CommandRunner } from '@nestjs-commander';
import { spawn } from 'child_process';
import { promisify } from 'util';

const spawnAsync = promisify(spawn);

@Command({ name: 'migrations:run', description: '批量执行所有迁移命令' })
export class MigrationsRunCommand extends CommandRunner {
  async run(): Promise<void> {
    try {
      // 执行目标CLI命令，同步输出日志到当前进程
      await spawnAsync('nest', ['migration:some-schema-update:up'], {
        stdio: 'inherit',
        shell: true,
      });
      
      // 可添加更多命令
      // await spawnAsync('nest', ['migration:another-task:up'], { stdio: 'inherit', shell: true });
      
      console.log('所有迁移执行完成');
    } catch (err) {
      console.error('迁移执行失败:', err);
      process.exit(1);
    }
  }
}

优势：完全模拟手动执行CLI命令的场景，适合需要传递复杂CLI参数的情况。

方式三：迁移逻辑与命令解耦（推荐） #

将具体的迁移逻辑抽离到独立服务中，命令类仅作为入口调用服务方法，启动器命令只需调用服务的多个方法即可：

// migration.service.ts
import { Injectable } from '@nestjs/common';
import { Connection } from 'typeorm';

@Injectable()
export class MigrationService {
  constructor(private readonly connection: Connection) {}

  // 具体迁移逻辑1
  async runSomeSchemaUpdate(): Promise<void> {
    await this.connection.runMigrations({
      migrations: [/* 你的迁移类 */],
    });
  }

  // 具体迁移逻辑2
  async runAnotherMigration(): Promise<void> {
    await this.connection.runMigrations({
      migrations: [/* 另一个迁移类 */],
    });
  }
}

// 单个迁移命令类
import { Command, CommandRunner } from '@nestjs-commander';
import { MigrationService } from './migration.service';

@Command({ name: 'migration:some-schema-update:up' })
export class SomeSchemaUpdateUpCommand extends CommandRunner {
  constructor(private readonly migrationService: MigrationService) {
    super();
  }

  async run(): Promise<void> {
    await this.migrationService.runSomeSchemaUpdate();
  }
}

// 迁移启动器命令类
import { Command, CommandRunner } from '@nestjs-commander';
import { MigrationService } from './migration.service';

@Command({ name: 'migrations:run', description: '批量执行所有迁移命令' })
export class MigrationsRunCommand extends CommandRunner {
  constructor(private readonly migrationService: MigrationService) {
    super();
  }

  async run(): Promise<void> {
    await this.migrationService.runSomeSchemaUpdate();
    await this.migrationService.runAnotherMigration();
  }
}

优势：业务逻辑与命令入口解耦，便于维护、扩展和复用迁移逻辑，是最符合NestJS架构设计的方案。

内容的提问来源于stack exchange，提问作者Supervision