blob: a9473eaa39178de73f93abe9cf2ffa63ed761591 [file] [log] [blame]
// Copyright (c) 2020, 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:convert';
import 'dart:io';
import 'package:vm_service/vm_service.dart';
late Uri remoteVmServiceUri;
Future<Process> spawnDartProcess(
String script, {
bool pauseOnStart = true,
bool disableServiceAuthCodes = false,
}) async {
final executable = Platform.executable;
final tmpDir = await Directory.systemTemp.createTemp('dart_service');
final serviceInfoUri = tmpDir.uri.resolve('service_info.json');
final serviceInfoFile = await File.fromUri(serviceInfoUri).create();
final arguments = [
if (pauseOnStart) '--pause-isolates-on-start',
if (disableServiceAuthCodes) '--disable-service-auth-codes',
final process = await Process.start(executable, arguments);
.listen((line) => print('TESTEE OUT: $line'));
.listen((line) => print('TESTEE ERR: $line'));
while ((await serviceInfoFile.length()) <= 5) {
await Future.delayed(const Duration(milliseconds: 50));
final content = await serviceInfoFile.readAsString();
final infoJson = json.decode(content);
remoteVmServiceUri = Uri.parse(infoJson['uri']);
return process;
Future<void> executeUntilNextPause(VmService service) async {
final vm = await service.getVM();
final isolate = await service.getIsolate(vm.isolates!!);
final completer = Completer<void>();
late StreamSubscription sub;
sub = service.onDebugEvent.listen((event) async {
if (event.kind == EventKind.kPauseBreakpoint) {
await sub.cancel();
await service.streamListen(EventStreams.kDebug);
await service.resume(!);
await completer.future;