// 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.
// VMOptions=--compile_all --error_on_bad_type --error_on_bad_override

import 'dart:async';
import 'dart:developer';
import 'package:observatory/service_io.dart';
import 'package:unittest/unittest.dart';
import 'service_test_common.dart';
import 'test_helper.dart';

int count = 0;

void test() {
  while (true) {
    count++;
    debugger();
  }
}

var tests = [
  hasStoppedAtBreakpoint,

  (Isolate isolate) async {
    // The loop has run one time.
    var result = await isolate.rootLibrary.evaluate('count');
    expect(result.type, equals('Instance'));
    expect(result.valueAsString, equals('1'));

    Completer completer = new Completer();
    var stream = await isolate.vm.getEventStream(VM.kDebugStream);
    var subscription;
    subscription = stream.listen((ServiceEvent event) {
      if (event.kind == ServiceEvent.kResume) {
        subscription.cancel();
        completer.complete();
      }
    });
    isolate.resume();
    await completer.future;

    // The loop has run twice.
    result = await isolate.rootLibrary.evaluate('count');
    expect(result.type, equals('Instance'));
    expect(result.valueAsString, equals('2'));
  },

  hasStoppedAtBreakpoint,

  (Isolate isolate) async {
    Isolate newIsolate = null;

    Completer testCompleter = new Completer();
    var debugStream = await isolate.vm.getEventStream(VM.kDebugStream);
    var debugSub;
    debugSub = debugStream.listen((ServiceEvent event) {
      if (event.kind == ServiceEvent.kPauseBreakpoint) {
        if (event.isolate == newIsolate) {
          // The old isolate has died and the new isolate is at
          // the breakpoint.
          newIsolate.reload().then((_) {
            newIsolate.rootLibrary.evaluate('count').then((result) {
              expect(result.type, equals('Instance'));
              expect(result.valueAsString, equals('1'));
              debugSub.cancel();
              testCompleter.complete();
            });
          });
        }
      }
    });

    Completer restartCompleter = new Completer();
    var isolateStream = await isolate.vm.getEventStream(VM.kIsolateStream);
    var isolateSub;
    bool exit = false;
    bool start = false;
    isolateSub = isolateStream.listen((ServiceEvent event) {
      if (event.kind == ServiceEvent.kIsolateExit) {
        expect(event.isolate, equals(isolate));
        print('Old isolate exited');
        exit = true;
      }
      if (event.kind == ServiceEvent.kIsolateStart) {
        print('New isolate started');
        newIsolate = event.isolate;
        start = true;
      }
      if (exit && start) {
        isolateSub.cancel();
        restartCompleter.complete();
      }
    });

    // Restart the vm.
    print("restarting");
    await isolate.vm.restart();
    await restartCompleter.future;
    print("restarted");
    await testCompleter.future;
  },
];


main(args) => runIsolateTests(args, tests, testeeConcurrent: test);