pkgs/coverage/lib/src/run_and_collect.dart

// Copyright (c) 2015, the Dart project authors.  Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.

import 'dart:async';
import 'dart:io';

import 'package:cli_util/cli_util.dart';

import 'collect.dart';
import 'util.dart';

String get _dartExecutable => dartExecutable ?? 'dart';

Future<Map<String, dynamic>> runAndCollect(
  String scriptPath, {
  List<String>? scriptArgs,
  bool checked = false,
  bool includeDart = false,
  Duration? timeout,
}) async {
  final dartArgs = [
    '--enable-vm-service',
    '--pause_isolates_on_exit',
    if (checked) '--checked',
    scriptPath,
    ...?scriptArgs,
  ];

  final process = await Process.start(_dartExecutable, dartArgs);

  final serviceUri = await serviceUriFromProcess(process.stdout.lines());
  Map<String, dynamic> coverage;
  try {
    coverage = await collect(
      serviceUri,
      true,
      true,
      includeDart,
      <String>{},
      timeout: timeout,
    );
  } finally {
    await process.stderr.drain<void>();
  }
  final exitStatus = await process.exitCode;
  if (exitStatus != 0) {
    throw ProcessException(
      _dartExecutable,
      dartArgs,
      'Process failed.',
      exitStatus,
    );
  }
  return coverage;
}