2010-06-18 13:48:42 -07:00
|
|
|
<!DOCTYPE HTML>
|
|
|
|
|
<html>
|
|
|
|
|
<head>
|
|
|
|
|
<meta http-equiv="Content-Type" content="text/html;charset=UTF-8"></meta>
|
|
|
|
|
<title>WebSocket test</title>
|
|
|
|
|
<script type="text/javascript" src="/MochiKit/packed.js"></script>
|
|
|
|
|
<script type="text/javascript" src="/tests/SimpleTest/SimpleTest.js"></script>
|
|
|
|
|
<link rel="stylesheet" type="text/css" href="/tests/SimpleTest/test.css" />
|
|
|
|
|
</head>
|
|
|
|
|
<body onload="testWebSocket()">
|
|
|
|
|
<a target="_blank" href="https://bugzilla.mozilla.org/show_bug.cgi?id=472529">Mozilla Bug </a>
|
|
|
|
|
<p id="display"></p>
|
|
|
|
|
<div id="content">
|
|
|
|
|
</div>
|
|
|
|
|
<pre id="test">
|
|
|
|
|
<script class="testbody" type="text/javascript">
|
|
|
|
|
|
|
|
|
|
/*
|
|
|
|
|
* tests:
|
|
|
|
|
* 1. client tries to connect to a http scheme location;
|
|
|
|
|
* 2. client tries to connect to an http resource;
|
|
|
|
|
* 3. client tries to connect to an non-existent ws server;
|
|
|
|
|
* 4. client tries to connect using a relative url;
|
|
|
|
|
* 5. client uses an invalid protocol value;
|
|
|
|
|
* 6. server closes the tcp connection before establishing the ws connection;
|
|
|
|
|
* 7. client calls close() and the server sends the close frame in
|
|
|
|
|
* acknowledgement;
|
|
|
|
|
* 8. client closes the connection before the ws connection is established;
|
|
|
|
|
* 9. client sends a message before the ws connection is established;
|
|
|
|
|
* 10. assure serialization of the connections;
|
|
|
|
|
* 11. a simple hello echo;
|
|
|
|
|
* 12. client sends a message with bad bytes;
|
|
|
|
|
* 13. server sends an invalid message;
|
|
|
|
|
* 14. server sends the close frame, it doesn't close the tcp connection and
|
|
|
|
|
* it keeps sending normal ws messages;
|
|
|
|
|
* 15. server closes the tcp connection, but it doesn't send the close frame;
|
|
|
|
|
* 16. client calls close() and tries to send a message;
|
|
|
|
|
* 17. client calls close() and the server keeps sending messages and it doesn't
|
|
|
|
|
* send the close frame;
|
|
|
|
|
* 18. counter and encoding check;
|
|
|
|
|
* 19. server takes too long to establish the ws connection;
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
|
|
var first_test = 1;
|
|
|
|
|
var last_test = 19;
|
|
|
|
|
|
|
|
|
|
var current_test = 1;
|
|
|
|
|
|
|
|
|
|
var timeoutToAbortTest = 60000;
|
|
|
|
|
var all_ws = [];
|
|
|
|
|
|
|
|
|
|
function shouldNotOpen(e)
|
|
|
|
|
{
|
|
|
|
|
var ws = e.target;
|
|
|
|
|
ok(false, "onopen shouldn't be called on test " + ws._testNumber + "!");
|
|
|
|
|
if (ws._timeoutToSucceed != undefined) {
|
|
|
|
|
clearTimeout(ws._timeoutToSucceed);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function shouldNotReceiveCloseEvent(e)
|
|
|
|
|
{
|
|
|
|
|
var ws = e.target;
|
|
|
|
|
ok(false, "onclose shouldn't be called on test " + ws._testNumber + "!");
|
|
|
|
|
if (ws._timeoutToSucceed != undefined) {
|
|
|
|
|
clearTimeout(ws._timeoutToSucceed);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function shouldCloseCleanly(e)
|
|
|
|
|
{
|
|
|
|
|
var ws = e.target;
|
|
|
|
|
ok(e.wasClean, "the ws connection in test " + ws._testNumber + " should be closed cleanly");
|
|
|
|
|
if (ws._timeoutToSucceed != undefined) {
|
|
|
|
|
clearTimeout(ws._timeoutToSucceed);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function shouldCloseNotCleanly(e)
|
|
|
|
|
{
|
|
|
|
|
var ws = e.target;
|
|
|
|
|
ok(!e.wasClean, "the ws connection in test " + ws._testNumber + " shouldn't be closed cleanly");
|
|
|
|
|
if (ws._timeoutToSucceed != undefined) {
|
|
|
|
|
clearTimeout(ws._timeoutToSucceed);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function CreateTestWS(ws_location, ws_protocol)
|
|
|
|
|
{
|
|
|
|
|
var ws;
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
if (ws_protocol == undefined) {
|
|
|
|
|
ws = new WebSocket(ws_location);
|
|
|
|
|
} else {
|
|
|
|
|
ws = new WebSocket(ws_location, ws_protocol);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
ws.onerror = function(e)
|
|
|
|
|
{
|
|
|
|
|
ok(false, "onerror called on test " + e.target._testNumber + "!");
|
|
|
|
|
};
|
|
|
|
|
ws._testNumber = current_test;
|
|
|
|
|
ws.addEventListener("close", function(e)
|
|
|
|
|
{
|
|
|
|
|
if (ws._receivedCloseEvent != undefined) {
|
|
|
|
|
ws._receivedCloseEvent = true;
|
|
|
|
|
}
|
|
|
|
|
}, false);
|
|
|
|
|
}
|
|
|
|
|
catch (e) {
|
|
|
|
|
throw e;
|
|
|
|
|
}
|
|
|
|
|
finally {
|
|
|
|
|
current_test++;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
all_ws.push(ws);
|
|
|
|
|
return ws;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function doTest(number)
|
|
|
|
|
{
|
|
|
|
|
if (doTest.timeoutId !== null) {
|
|
|
|
|
clearTimeout(doTest.timeoutId);
|
|
|
|
|
doTest.timeoutId = null;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
if (number > last_test) {
|
2010-06-19 04:20:31 -07:00
|
|
|
setTimeout(finishWSTest, 30000); // wait for the close events be dispatched
|
2010-06-18 13:48:42 -07:00
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
$("feedback").innerHTML = "executing test: " + number + " of " + last_test + " tests.";
|
|
|
|
|
|
|
|
|
|
var fnTest = eval("test" + number + "");
|
|
|
|
|
|
|
|
|
|
if (fnTest._started === true) {
|
|
|
|
|
doTest(number + 1);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
doTest.timeoutId = setTimeout(function()
|
|
|
|
|
{
|
|
|
|
|
ok(false, "test " + number + " took too long to finish!");
|
|
|
|
|
doTest(number + 1);
|
|
|
|
|
}, timeoutToAbortTest);
|
|
|
|
|
|
|
|
|
|
fnTest._started = true;
|
|
|
|
|
fnTest();
|
|
|
|
|
}
|
|
|
|
|
doTest.timeoutId = null;
|
|
|
|
|
|
|
|
|
|
function test1()
|
|
|
|
|
{
|
|
|
|
|
try {
|
|
|
|
|
var ws = CreateTestWS("http://mochi.test:8888/tests/content/base/test/file_websocket");
|
|
|
|
|
ok(false, "test1 failed");
|
|
|
|
|
}
|
|
|
|
|
catch (e) {
|
|
|
|
|
ok(true, "test1 failed");
|
|
|
|
|
}
|
|
|
|
|
doTest(2);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test2()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket_http_resource.txt");
|
|
|
|
|
ws.onopen = shouldNotOpen;
|
|
|
|
|
ws.onclose = shouldNotReceiveCloseEvent;
|
|
|
|
|
doTest(3);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test3()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://this.websocket.server.probably.does.not.exist");
|
|
|
|
|
ws.onopen = shouldNotOpen;
|
|
|
|
|
ws.onclose = shouldNotReceiveCloseEvent;
|
|
|
|
|
doTest(4);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test4()
|
|
|
|
|
{
|
|
|
|
|
try {
|
|
|
|
|
var ws = CreateTestWS("file_websocket");
|
|
|
|
|
ok(false, "test4 failed");
|
|
|
|
|
}
|
|
|
|
|
catch (e) {
|
|
|
|
|
ok(true, "test4 failed");
|
|
|
|
|
}
|
|
|
|
|
doTest(5);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test5()
|
|
|
|
|
{
|
|
|
|
|
try {
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "");
|
|
|
|
|
ok(false, "couldn't accept an empty string in the protocol parameter");
|
|
|
|
|
}
|
|
|
|
|
catch (e) {
|
|
|
|
|
ok(true, "couldn't accept an empty string in the protocol parameter");
|
|
|
|
|
}
|
|
|
|
|
current_test--; // CreateTestWS incremented this
|
|
|
|
|
try {
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "\n");
|
|
|
|
|
ok(false, "couldn't accept any not printable ASCII character in the protocol parameter");
|
|
|
|
|
}
|
|
|
|
|
catch (e) {
|
|
|
|
|
ok(true, "couldn't accept any not printable ASCII character in the protocol parameter");
|
|
|
|
|
}
|
|
|
|
|
doTest(6);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test6()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 6");
|
|
|
|
|
ws.onopen = shouldNotOpen;
|
|
|
|
|
ws.onclose = shouldNotReceiveCloseEvent;
|
|
|
|
|
doTest(7);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test7()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 7");
|
|
|
|
|
ws.onopen = function()
|
|
|
|
|
{
|
|
|
|
|
ws.close();
|
|
|
|
|
}
|
|
|
|
|
ws.onclose = function(e)
|
|
|
|
|
{
|
|
|
|
|
shouldCloseCleanly(e);
|
|
|
|
|
doTest(8);
|
|
|
|
|
};
|
|
|
|
|
ws._receivedCloseEvent = false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test8()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 8");
|
|
|
|
|
ws.onopen = shouldNotOpen;
|
|
|
|
|
ws.onclose = function(e)
|
|
|
|
|
{
|
|
|
|
|
shouldCloseNotCleanly(e);
|
2010-06-19 05:13:18 -07:00
|
|
|
doTest(10);
|
2010-06-18 13:48:42 -07:00
|
|
|
};
|
|
|
|
|
|
|
|
|
|
ws._receivedCloseEvent = false;
|
|
|
|
|
ws.close();
|
|
|
|
|
}
|
|
|
|
|
|
2010-06-19 05:13:18 -07:00
|
|
|
// Disabled for now
|
2010-06-18 13:48:42 -07:00
|
|
|
function test9()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 9");
|
|
|
|
|
ws.onclose = shouldCloseCleanly;
|
|
|
|
|
ws._receivedCloseEvent = false;
|
|
|
|
|
|
|
|
|
|
try {
|
|
|
|
|
ws.send("client data");
|
|
|
|
|
ok(false, "Couldn't send data before connecting!");
|
|
|
|
|
}
|
|
|
|
|
catch (e) {
|
|
|
|
|
ok(true, "Couldn't send data before connecting!");
|
|
|
|
|
}
|
|
|
|
|
doTest(10);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test10()
|
|
|
|
|
{
|
|
|
|
|
var ws1 = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 10.1");
|
|
|
|
|
current_test--; // CreateTestWS incremented this
|
|
|
|
|
var ws2 = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 10.2");
|
|
|
|
|
|
|
|
|
|
var ws2CanConnect = false;
|
|
|
|
|
|
|
|
|
|
// the server will delay ws1 for 5 seconds
|
|
|
|
|
|
|
|
|
|
ws1.onopen = function()
|
|
|
|
|
{
|
|
|
|
|
ws2CanConnect = true;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
ws2.onopen = function()
|
|
|
|
|
{
|
|
|
|
|
ok(ws2CanConnect, "shouldn't connect yet in test 10!");
|
|
|
|
|
doTest(11);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test11()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 11");
|
|
|
|
|
ok(ws.readyState == 0, "bad readyState in test 11!");
|
|
|
|
|
ws.onopen = function()
|
|
|
|
|
{
|
|
|
|
|
ok(ws.readyState == 1, "bad readyState in test 11!");
|
|
|
|
|
ws.send("client data");
|
|
|
|
|
}
|
|
|
|
|
ws.onmessage = function(e)
|
|
|
|
|
{
|
|
|
|
|
ok(e.data == "server data", "bad received message in test 11!");
|
|
|
|
|
ws.close();
|
|
|
|
|
ok(ws.readyState == 2, "bad readyState in test 11!");
|
|
|
|
|
}
|
|
|
|
|
ws.onclose = function(e)
|
|
|
|
|
{
|
|
|
|
|
ok(ws.readyState == 3, "bad readyState in test 11!");
|
|
|
|
|
shouldCloseCleanly(e);
|
|
|
|
|
doTest(12);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test12()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 12");
|
|
|
|
|
ws.onopen = function()
|
|
|
|
|
{
|
|
|
|
|
try {
|
|
|
|
|
// send an unpaired surrogate
|
|
|
|
|
ws.send(String.fromCharCode(0xD800));
|
|
|
|
|
ok(false, "couldn't send an unpaired surrogate!");
|
|
|
|
|
}
|
|
|
|
|
catch (e) {
|
|
|
|
|
ok(true, "couldn't send an unpaired surrogate!");
|
|
|
|
|
}
|
|
|
|
|
ws.close();
|
|
|
|
|
ws._receivedCloseEvent = false;
|
2010-06-19 05:13:18 -07:00
|
|
|
doTest(16);
|
2010-06-18 13:48:42 -07:00
|
|
|
};
|
|
|
|
|
}
|
|
|
|
|
|
2010-06-19 05:13:18 -07:00
|
|
|
// Disabled for now
|
2010-06-18 13:48:42 -07:00
|
|
|
function test13()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 13");
|
|
|
|
|
ws._timesCalledOnError = 0;
|
|
|
|
|
ws.onerror = function()
|
|
|
|
|
{
|
|
|
|
|
ws._timesCalledOnError++;
|
|
|
|
|
if (ws._timesCalledOnError == 2) {
|
|
|
|
|
doTest(14);
|
|
|
|
|
ok(true, "test13 succeeded");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
ws.onclose = shouldCloseCleanly;
|
|
|
|
|
ws._receivedCloseEvent = false;
|
|
|
|
|
}
|
|
|
|
|
|
2010-06-19 05:13:18 -07:00
|
|
|
// Disabled for now
|
2010-06-18 13:48:42 -07:00
|
|
|
function test14()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 14");
|
|
|
|
|
ws.onmessage = function()
|
|
|
|
|
{
|
|
|
|
|
ok(false, "shouldn't received message after the server sent the close frame");
|
|
|
|
|
}
|
|
|
|
|
ws.onclose = function(e)
|
|
|
|
|
{
|
|
|
|
|
shouldCloseCleanly(e);
|
2010-06-19 05:13:18 -07:00
|
|
|
doTest(15);
|
2010-06-18 13:48:42 -07:00
|
|
|
};
|
|
|
|
|
ws._receivedCloseEvent = false;
|
|
|
|
|
}
|
|
|
|
|
|
2010-06-19 05:13:18 -07:00
|
|
|
// Disabled for now.
|
2010-06-18 13:48:42 -07:00
|
|
|
function test15()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 15");
|
|
|
|
|
ws.onclose = function(e)
|
|
|
|
|
{
|
|
|
|
|
shouldCloseNotCleanly(e);
|
|
|
|
|
doTest(16);
|
|
|
|
|
};
|
|
|
|
|
ws._receivedCloseEvent = false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test16()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 16");
|
|
|
|
|
ws.onopen = function()
|
|
|
|
|
{
|
|
|
|
|
ws.close();
|
|
|
|
|
ok(!ws.send("client data"), "shouldn't send message after calling close()");
|
|
|
|
|
doTest(17);
|
|
|
|
|
}
|
|
|
|
|
ws.onmessage = function()
|
|
|
|
|
{
|
|
|
|
|
ok(false, "shouldn't send message after calling close()");
|
|
|
|
|
}
|
|
|
|
|
ws.onclose = shouldCloseCleanly;
|
|
|
|
|
ws._receivedCloseEvent = false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test17()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 17");
|
|
|
|
|
ws.onopen = function()
|
|
|
|
|
{
|
|
|
|
|
ws.close();
|
|
|
|
|
}
|
|
|
|
|
ws.onclose = function(e)
|
|
|
|
|
{
|
|
|
|
|
shouldCloseNotCleanly(e);
|
|
|
|
|
doTest(18);
|
|
|
|
|
};
|
|
|
|
|
ws._receivedCloseEvent = false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test18()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 18");
|
|
|
|
|
var counter = 1;
|
|
|
|
|
ws.onopen = function()
|
|
|
|
|
{
|
|
|
|
|
ws.send(counter);
|
|
|
|
|
}
|
|
|
|
|
ws.onmessage = function(e)
|
|
|
|
|
{
|
|
|
|
|
if (counter == 5) {
|
|
|
|
|
ok(e.data == "あいうえお");
|
|
|
|
|
ws.close();
|
|
|
|
|
doTest(19);
|
|
|
|
|
} else {
|
|
|
|
|
ok(e.data == counter+1, "bad counter");
|
|
|
|
|
counter += 2;
|
|
|
|
|
ws.send(counter);
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
ws.onclose = shouldCloseCleanly;
|
|
|
|
|
ws._receivedCloseEvent = false;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function test19()
|
|
|
|
|
{
|
|
|
|
|
var ws = CreateTestWS("ws://mochi.test:8888/tests/content/base/test/file_websocket", "test 19");
|
|
|
|
|
ws.onopen = shouldNotOpen;
|
|
|
|
|
ws.onclose = shouldNotReceiveCloseEvent;
|
|
|
|
|
doTest(20);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function finishWSTest()
|
|
|
|
|
{
|
|
|
|
|
for (i = 0; i < all_ws.length; ++i) {
|
|
|
|
|
if (all_ws[i]._receivedCloseEvent === false) {
|
|
|
|
|
ok(false, "didn't called close on test " + all_ws[i]._testNumber + "!");
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
SimpleTest.finish();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function testWebSocket ()
|
|
|
|
|
{
|
|
|
|
|
doTest(first_test);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
SimpleTest.waitForExplicitFinish();
|
|
|
|
|
|
|
|
|
|
</script>
|
|
|
|
|
</pre>
|
|
|
|
|
|
|
|
|
|
<div id="feedback">
|
|
|
|
|
</div>
|
|
|
|
|
|
|
|
|
|
</body>
|
|
|
|
|
</html>
|
