runSeedRegistryOnConnection function

Implementation

Future<void> runSeedRegistryOnConnection(
  OrmConnection connection,
  List<SeederRegistration> seeds, {
  List<String>? names,
  bool pretend = false,
  void Function(OrmConnection connection)? beforeRun,
  void Function(String message)? log,
}) async {
  if (seeds.isEmpty) {
    throw StateError('No seeders registered.');
  }
  final logger = log ?? (String message) => stdout.writeln(message);
  final reporter = CliEventReporter(io: cliIO)..listenToSeeders();
  try {
    await SeederRunner().run(
      connection: connection,
      seeders: seeds,
      names: (names == null || names.isEmpty) ? null : names,
      pretend: pretend,
      beforeRun: beforeRun,
      log: null,
      // Preserve previous behavior (no default log output).
      onPretendQueries: pretend
          ? (entries) {
              for (final entry in entries) {
                logger('[pretend] ${formatPretendEntry(entry)}');
              }
            }
          : null,
    );
  } finally {
    reporter.dispose();
  }
}