// Copyright (c) 2012, 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=--enable-isolate-groups --experimental-enable-isolate-groups-jit
// VMOptions=--no-enable-isolate-groups

// Dart test program for testing that isolates can spawn other isolates and
// that the nested isolates can communicate with the main once the spawner has
// disappeared.

library NestedSpawn2Test;

import 'dart:isolate';
import 'package:async_helper/async_helper.dart';
import 'package:expect/expect.dart';

void isolateA(SendPort init) {
  ReceivePort port = new ReceivePort();
  init.send(port.sendPort);
  port.first.then((message) {
    Expect.equals(message[0], "launch nested!");
    SendPort replyTo = message[1];
    Isolate.spawn(isolateB, replyTo);
  });
}

String msg0 = "0 there?";
String msg1 = "1 Yes.";
String msg2 = "2 great. Think the other one is already dead?";
String msg3 = "3 Give him some time.";
String msg4 = "4 now?";
String msg5 = "5 Now.";
String msg6 = "6 Great. Bye";

void _call(SendPort p, msg, void onreceive(m, replyTo)) {
  final replyTo = new ReceivePort();
  p.send([msg, replyTo.sendPort]);
  replyTo.first.then((m) {
    onreceive(m[0], m[1]);
  });
}

void isolateB(SendPort mainPort) {
  // Do a little ping-pong dance to give the intermediate isolate
  // time to die.
  _call(mainPort, msg0, ((msg, replyTo) {
    Expect.equals(msg[0], "1");
    _call(replyTo, msg2, ((msg, replyTo) {
      Expect.equals(msg[0], "3");
      _call(replyTo, msg4, ((msg, replyTo) {
        Expect.equals(msg[0], "5");
        replyTo.send([msg6, null]);
      }));
    }));
  }));
}

void main([args, port]) {
  // spawned isolate can spawn other isolates
  ReceivePort init = new ReceivePort();
  Isolate.spawn(isolateA, init.sendPort);
  asyncStart();
  init.first.then((port) {
    _call(port, "launch nested!", (msg, replyTo) {
      Expect.equals(msg[0], "0");
      _call(replyTo, msg1, (msg, replyTo) {
        Expect.equals(msg[0], "2");
        _call(replyTo, msg3, (msg, replyTo) {
          Expect.equals(msg[0], "4");
          _call(replyTo, msg5, (msg, _) {
            Expect.equals(msg[0], "6");
            asyncEnd();
          });
        });
      });
    });
  });
}