dwds/test/run_request_test.dart

// Copyright (c) 2019, 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.

// @dart = 2.9

@Timeout(Duration(minutes: 2))

import 'dart:async';

import 'package:dwds/src/connections/debug_connection.dart';
import 'package:dwds/src/services/chrome_proxy_service.dart';
import 'package:pedantic/pedantic.dart';
import 'package:test/test.dart';
import 'package:vm_service/vm_service.dart';

import 'fixtures/context.dart';

final context = TestContext();

ChromeProxyService get service =>
    fetchChromeProxyService(context.debugConnection);

void main() {
  group('while debugger is attached', () {
    setUp(() async {
      await context.setUp(autoRun: false);
    });

    tearDown(() async {
      await context.tearDown();
    });

    test('can resume while paused at the start', () async {
      var vm = await service.getVM();
      var isolate = await service.getIsolate(vm.isolates.first.id);
      expect(isolate.pauseEvent.kind, EventKind.kPauseStart);
      var stream = service.onEvent('Debug');
      var resumeCompleter = Completer();
      // The underlying stream is a broadcast stream so we need to add a
      // listener before calling resume so that we don't miss events.
      unawaited(stream
          .firstWhere((event) => event.kind == EventKind.kResume)
          .then((_) {
        resumeCompleter.complete();
      }));
      await service.resume(isolate.id);
      await resumeCompleter.future;
      expect(isolate.pauseEvent.kind, EventKind.kResume);
    });

    test('correctly sets the isolate pauseEvent', () async {
      var vm = await service.getVM();
      var isolate = await service.getIsolate(vm.isolates.first.id);
      expect(isolate.pauseEvent.kind, EventKind.kPauseStart);
      var stream = service.onEvent('Debug');
      context.appConnection.runMain();
      await stream.firstWhere((event) => event.kind == EventKind.kResume);
      expect(isolate.pauseEvent.kind, EventKind.kResume);
    });
  });

  group('while debugger is not attached', () {
    setUp(() async {
      await context.setUp(autoRun: false, waitToDebug: true);
    });

    tearDown(() async {
      await context.tearDown();
    });
    test('correctly sets the isolate pauseEvent if already running', () async {
      context.appConnection.runMain();
      await context.startDebugging();
      var vm = await service.getVM();
      var isolate = await service.getIsolate(vm.isolates.first.id);
      expect(isolate.pauseEvent.kind, EventKind.kResume);
    });
  });
}