run method

@override Future<void> run()

Runs this command.

The return value is wrapped in a Future if necessary and returned by CommandRunner.runCommand.

Implementation

@override
Future<void> run() async {
  final planFile = File('.spectra/PLAN.md');
  if (!planFile.existsSync()) {
    logger.err('PLAN.md not found. Run `spectra plan` first.');
    return;
  }

  final content = planFile.readAsStringSync();
  final tasks = _parseTasks(content);

  if (tasks.isEmpty) {
    logger.warn('No tasks found in PLAN.md.');
    return;
  }

  final workersArg = argResults?['workers'] as String?;
  final workerCount = int.tryParse(workersArg ?? '2') ?? 2;

  final orchestrator = OrchestratorService(logger: logger);

  final convoy = Convoy(
    id: 'plan-main',
    name: 'Main Plan',
    tasks: tasks,
  );

  orchestrator.addConvoy(convoy);

  logger.info('Starting orchestrator with $workerCount workers...');
  await orchestrator.start(workerCount: workerCount);

  logger.success('Orchestrator is running. Press Enter to stop.');

  // Keep alive until user input
  await stdin.first;
  orchestrator.stop();
}