// 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.

// 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:unittest/unittest.dart';
import "remote_unittest_helper.dart";

void isolateA(SendPort init) {
  ReceivePort port = new ReceivePort();
  init.send(port.sendPort);
  port.first.then((message) {
    expect(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(msg[0], "1");
    _call(replyTo, msg2, ((msg, replyTo) {
      expect(msg[0], "3");
      _call(replyTo, msg4, ((msg, replyTo) {
        expect(msg[0], "5");
        replyTo.send([msg6, null]);
      }));
    }));
  }));
}

void main([args, port]) {
  if (testRemote(main, port)) return;
  test("spawned isolate can spawn other isolates", () {
    ReceivePort init = new ReceivePort();
    Isolate.spawn(isolateA, init.sendPort);
    return init.first.then(expectAsync((port) {
      _call(port, "launch nested!", expectAsync((msg, replyTo) {
        expect(msg[0], "0");
        _call(replyTo, msg1, expectAsync((msg, replyTo) {
          expect(msg[0], "2");
          _call(replyTo, msg3, expectAsync((msg, replyTo) {
            expect(msg[0], "4");
            _call(replyTo, msg5, expectAsync((msg, _) {
              expect(msg[0], "6");
            }));
          }));
        }));
      }));
    }));
  });
}