<body>
<p>Test that pages and workers can send MessagePorts to one another.
Should print "DONE" when done.</p>
<div id=result></div>
<script>
function log(message)
{
    document.getElementById("result").innerHTML += message + "<br>";
}

if (window.testRunner) {
    testRunner.dumpAsText();
    testRunner.waitUntilDone();
}

var worker = new Worker("resources/worker-messageport.js");
var channel = new MessageChannel();

// Send messages with and without ports to the worker to make sure it gets them.
worker.postMessage("noport");
worker.onmessage = function(evt) {
    log(evt.data);
    worker.postMessage("port", [channel.port1]);
    worker.onmessage = function(evt) {
        log(evt.data);
    }
};

// Send a message on the new port to make sure it gets to the worker.
channel.port2.postMessage("ping");

// Wait for the response.
channel.port2.onmessage = function(evt) {
    if (evt.data == "pong") {
        log("PASS: Received response from Worker via MessagePort");
        worker.onmessage = awaitPortFromWorker;
        worker.postMessage("getport");
    } else {
        log("FAIL: Received unknown event: " + evt.data);
    }
}
channel.port2.start();

// Invoked once the first batch of tests are done, to test sending from the worker.
function awaitPortFromWorker(evt)
{
    if (evt.data == "port") {
        if (!evt.ports) {
            log("FAIL: Did not get port from worker");
        } else if (evt.ports.length != 1) {
            log("FAIL: Got the wrong number of ports from worker: " + evt.ports.length);
        } else {
            log("PASS: Got port from worker");
            try {
                // Missing parameter, should throw.
                evt.ports[0].postMessage();
                log("FAIL: Calling MessagePort.postMessage() without parameter did not throw.");
            } catch (e) {
                log("PASS: Calling MessagePort.postMessage() without parameter threw exception: " + e);
            }
            evt.ports[0].postMessage("ping");
            evt.ports[0].onmessage = function(evt) {
                if (evt.data == "pong") {
                    log("PASS: Received final response from worker");
                } else {
                    log("FAIL: Got unexpected response: " + evt.data);
                }
                startSpamTest();
            }
            evt.ports[0].start();
        }
    } else {
        log(evt.data);
    }
}

function startSpamTest()
{
    var channel = new MessageChannel();
    worker.onmessage = function () { gotSpam(channel.port1); }
    worker.postMessage("spam", [channel.port2]);
}

function gotSpam(port)
{
    var spamCount = 0;
    port.onmessage = function(evt) {
        if (evt.data != spamCount)
            log("FAIL: Got out of order message: " + spamCount);
        spamCount++;
        if (spamCount == 1000) {
            log("PASS: Got 1000 messages");
            done();
        }
    }
}

function done()
{
    log("DONE");
    if (window.testRunner)
        testRunner.notifyDone();
}

</script>
</body>
</html>