2017-01-27 04:54:09 +00:00
|
|
|
<!doctype html>
|
|
|
|
|
<html>
|
|
|
|
|
<head>
|
|
|
|
|
<meta charset="utf-8">
|
|
|
|
|
<title>Testing basic data channel from offerer to receiver</title>
|
|
|
|
|
<script src="../../resources/testharness.js"></script>
|
|
|
|
|
<script src="../../resources/testharnessreport.js"></script>
|
|
|
|
|
</head>
|
|
|
|
|
<body>
|
|
|
|
|
<script src ="../routines.js"></script>
|
|
|
|
|
<script>
|
|
|
|
|
var localChannel;
|
|
|
|
|
var remoteChannel;
|
|
|
|
|
|
|
|
|
|
function closeDataChannels() {
|
|
|
|
|
localChannel.close();
|
|
|
|
|
remoteChannel.close();
|
|
|
|
|
closeConnections();
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function receiveMessages(event) {
|
2017-06-16 20:24:09 +00:00
|
|
|
try {
|
2017-01-27 04:54:09 +00:00
|
|
|
if (++counter === 1)
|
|
|
|
|
assert_equals(event.data, "one");
|
|
|
|
|
else if (counter === 2)
|
|
|
|
|
assert_equals(event.data, "two");
|
|
|
|
|
else if (counter === 3)
|
|
|
|
|
assert_equals(event.data, "three");
|
|
|
|
|
else if (counter === 4) {
|
|
|
|
|
assert_equals(event.data, "four");
|
|
|
|
|
closeDataChannels();
|
|
|
|
|
finishTest();
|
|
|
|
|
} else
|
|
|
|
|
assert_unreached();
|
2017-06-16 20:24:09 +00:00
|
|
|
} catch(e) {
|
|
|
|
|
console.log(e);
|
|
|
|
|
}
|
2017-01-27 04:54:09 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
function sendMessages(channel)
|
|
|
|
|
{
|
|
|
|
|
channel.send("one");
|
|
|
|
|
channel.send("two");
|
|
|
|
|
channel.send("three");
|
|
|
|
|
channel.send("four");
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
var finishTest;
|
|
|
|
|
promise_test((test) => {
|
|
|
|
|
counter = 0;
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
finishTest = resolve;
|
|
|
|
|
createConnections((localConnection) => {
|
|
|
|
|
localChannel = localConnection.createDataChannel('sendDataChannel');
|
|
|
|
|
localChannel.onopen = () => { sendMessages(localChannel) };
|
|
|
|
|
}, (remoteConnection) => {
|
|
|
|
|
remoteConnection.ondatachannel = (event) => {
|
|
|
|
|
remoteChannel = event.channel;
|
|
|
|
|
remoteChannel.onmessage = receiveMessages;
|
|
|
|
|
};
|
|
|
|
|
});
|
2017-06-16 20:24:09 +00:00
|
|
|
setTimeout(() => { reject("Test timed out"); }, 5000);
|
2017-01-27 04:54:09 +00:00
|
|
|
});
|
|
|
|
|
}, "Basic data channel exchange from offerer to receiver");
|
|
|
|
|
|
|
|
|
|
promise_test((test) => {
|
|
|
|
|
counter = 0;
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
finishTest = resolve;
|
|
|
|
|
createConnections((localConnection) => {
|
|
|
|
|
localChannel = localConnection.createDataChannel('sendDataChannel');
|
|
|
|
|
localChannel.onmessage = receiveMessages;
|
|
|
|
|
}, (remoteConnection) => {
|
|
|
|
|
remoteConnection.ondatachannel = (event) => {
|
|
|
|
|
remoteChannel = event.channel;
|
|
|
|
|
remoteChannel.onopen = () => { sendMessages(remoteChannel) };
|
|
|
|
|
};
|
|
|
|
|
});
|
2017-06-16 20:24:09 +00:00
|
|
|
setTimeout(() => { reject("Test timed out"); }, 5000);
|
2017-01-27 04:54:09 +00:00
|
|
|
});
|
|
|
|
|
}, "Basic data channel exchange from receiver to offerer");
|
2017-02-28 01:10:39 +00:00
|
|
|
|
2017-06-16 20:24:09 +00:00
|
|
|
|
2017-02-28 01:10:39 +00:00
|
|
|
promise_test((test) => {
|
|
|
|
|
counter = 0;
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
finishTest = resolve;
|
|
|
|
|
createConnections((localConnection) => {
|
|
|
|
|
localChannel = localConnection.createDataChannel('sendDataChannel');
|
|
|
|
|
localChannel.onopen = () => { sendMessages(localChannel) };
|
|
|
|
|
}, (remoteConnection) => {
|
|
|
|
|
remoteConnection.ondatachannel = (event) => {
|
|
|
|
|
remoteChannel = event.channel;
|
|
|
|
|
remoteChannel.onmessage = receiveMessages;
|
|
|
|
|
};
|
2017-03-30 21:42:19 +00:00
|
|
|
}, { filterOutICECandidate: (candidate) => { return candidate && candidate.candidate.toLowerCase().indexOf("udp") == -1; } });
|
2017-06-16 20:24:09 +00:00
|
|
|
setTimeout(() => { reject("Test timed out"); }, 5000);
|
2017-02-28 01:10:39 +00:00
|
|
|
});
|
|
|
|
|
}, "Basic data channel exchange from offerer to receiver using UDP only");
|
|
|
|
|
|
2017-03-27 18:13:19 +00:00
|
|
|
promise_test((test) => {
|
|
|
|
|
counter = 0;
|
|
|
|
|
return new Promise((resolve, reject) => {
|
|
|
|
|
var checkDataChannelOptions = (channel, init) => {
|
|
|
|
|
assert_equals(channel.ordered, init.ordered, "ordered");
|
|
|
|
|
assert_equals(channel.maxPacketLifeTime, init.maxPacketLifeTime, "maxPacketLifeTime");
|
|
|
|
|
assert_equals(channel.maxRetransmitTime, init.maxRetransmitTime, "maxRetransmitTime");
|
|
|
|
|
assert_equals(channel.maxRetransmits, init.maxRetransmits, "maxRetransmits");
|
|
|
|
|
assert_equals(channel.protocol, init.protocol, "protocol");
|
|
|
|
|
assert_equals(channel.negotiated, init.negotiated, "negotiated");
|
|
|
|
|
assert_equals(channel.id, init.id, "id");
|
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
finishTest = resolve;
|
|
|
|
|
createConnections((localConnection) => {
|
2017-03-30 21:42:19 +00:00
|
|
|
var init = { ordered: true, maxPacketLifeTime: 10, maxRetransmitTime: 11, protocol: "whatever", negotiated: false, id: 1 };
|
2017-03-27 18:13:19 +00:00
|
|
|
localChannel = localConnection.createDataChannel('sendDataChannel', init);
|
|
|
|
|
localChannel.onopen = () => { sendMessages(localChannel) };
|
|
|
|
|
}, (remoteConnection) => {
|
|
|
|
|
remoteConnection.ondatachannel = (event) => {
|
|
|
|
|
remoteChannel = event.channel;
|
|
|
|
|
remoteChannel.onmessage = receiveMessages;
|
|
|
|
|
};
|
|
|
|
|
});
|
2017-06-16 20:24:09 +00:00
|
|
|
setTimeout(() => { reject("Test timed out"); }, 5000);
|
2017-03-27 18:13:19 +00:00
|
|
|
});
|
2019-09-16 21:04:08 +00:00
|
|
|
}, "Basic data channel exchange from offerer to receiver 2");
|
2017-03-27 18:13:19 +00:00
|
|
|
|
2018-12-11 03:43:38 +00:00
|
|
|
promise_test(async (test) => {
|
|
|
|
|
await new Promise((resolve, reject) => {
|
|
|
|
|
finishTest = resolve;
|
|
|
|
|
createConnections((localConnection) => {
|
|
|
|
|
localChannel = localConnection.createDataChannel('sendDataChannel');
|
|
|
|
|
}, (remoteConnection) => {
|
|
|
|
|
remoteConnection.ondatachannel = resolve;
|
|
|
|
|
});
|
|
|
|
|
setTimeout(() => { reject("Test step 1 timed out"); }, 5000);
|
|
|
|
|
});
|
|
|
|
|
await waitFor(50);
|
|
|
|
|
let waitForLocalChannelOpening = new Promise((resolve) => {
|
|
|
|
|
localChannel = localConnection.createDataChannel('sendDataChannel2');
|
|
|
|
|
localChannel.onopen = resolve;
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
let waitForRemoteChannel = new Promise((resolve) => {
|
|
|
|
|
remoteConnection.ondatachannel = (event) => {
|
|
|
|
|
remoteChannel = event.channel;
|
|
|
|
|
resolve();
|
|
|
|
|
};
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|
await Promise.all([waitForLocalChannelOpening, waitForRemoteChannel]);
|
|
|
|
|
|
|
|
|
|
counter = 0;
|
|
|
|
|
await new Promise((resolve, reject) => {
|
|
|
|
|
finishTest = resolve;
|
|
|
|
|
remoteChannel.onmessage = receiveMessages;
|
|
|
|
|
sendMessages(localChannel);
|
|
|
|
|
setTimeout(() => { reject("Test step 2 timed out"); }, 5000);
|
|
|
|
|
});
|
|
|
|
|
}, "Create a second channel asynchronously and send messages");
|
|
|
|
|
|
2017-01-27 04:54:09 +00:00
|
|
|
</script>
|
|
|
|
|
</body>
|
|
|
|
|
</html>
|
