| <!doctype html> |
| <!-- |
| This test creates a data channel between two local PeerConnection instances |
| and ensures that an empty string sent by one is received by the second. |
| --> |
| |
| <html> |
| <head> |
| <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> |
| <title>RTCPeerConnection Data Channel Empty String Test</title> |
| </head> |
| <body> |
| <div id="log"></div> |
| <h2>Messages exchanged</h2> |
| <div id="msg"></div> |
| |
| <!-- These files are in place when executing on W3C. --> |
| <script src="/resources/testharness.js"></script> |
| <script src="/resources/testharnessreport.js"></script> |
| <script type="text/javascript"> |
| var test = async_test('Can send empty strings across a WebRTC data channel.'); |
| |
| var gFirstConnection = null; |
| var gSecondConnection = null; |
| var sendChannel = null; |
| var receiveChannel = null; |
| |
| var onReceiveChannel = function (event) { |
| receiveChannel = event.channel; |
| receiveChannel.onmessage = onReceiveMessage; |
| }; |
| |
| |
| // When the data channel is open, send an empty string message |
| // followed by a message that contains the string "done". |
| var onSendChannelOpen = test.step_func(function (event) { |
| var msgEl = document.getElementById('msg'); |
| sendChannel.send(''); |
| msgEl.innerHTML += 'Sent: [empty string]<br>'; |
| sendChannel.send('done'); |
| msgEl.innerHTML += 'Sent: "done"<br>'; |
| }); |
| |
| // Check the messages received on the other side. |
| // There should be an empty string message followed by a message that |
| // contains the string "done". |
| // Pass/Fail the test according to the messages received |
| var emptyMessageReceived = false; |
| var onReceiveMessage = test.step_func(function (event) { |
| var msgEl = document.getElementById('msg'); |
| msgEl.innerHTML += 'Received: ' + |
| (event.data ? '"' + event.data + '"' : '[empty string]') + '<br>'; |
| if (emptyMessageReceived) { |
| assert_equals(event.data, 'done', 'The "done" message was not received'); |
| test.done(); |
| } |
| else { |
| assert_equals(event.data, '', 'Empty message not received'); |
| emptyMessageReceived = true; |
| } |
| }); |
| |
| function exchangeIce(pc) { |
| return function(e) { |
| if (e.candidate) { |
| pc.addIceCandidate(e.candidate); |
| } |
| }; |
| } |
| |
| function exchangeDescription(pc1, pc2) { |
| return function() { |
| return pc1.setRemoteDescription(pc2.localDescription); |
| }; |
| } |
| |
| test.step(function() { |
| gFirstConnection = new RTCPeerConnection(null); |
| |
| gSecondConnection = new RTCPeerConnection(null); |
| |
| gFirstConnection.onicecandidate = exchangeIce(gSecondConnection); |
| gSecondConnection.onicecandidate = exchangeIce(gFirstConnection); |
| |
| gSecondConnection.ondatachannel = onReceiveChannel; |
| |
| // Note the data channel will preserve the order of messages |
| // exchanged over it by default. |
| sendChannel = gFirstConnection.createDataChannel('sendDataChannel'); |
| sendChannel.onopen = onSendChannelOpen; |
| |
| gFirstConnection.createOffer() |
| .then(gFirstConnection.setLocalDescription.bind(gFirstConnection)) |
| .then(exchangeDescription(gSecondConnection, gFirstConnection)) |
| .then(function() { |
| return gSecondConnection.createAnswer(); |
| }) |
| .then(gSecondConnection.setLocalDescription.bind(gSecondConnection)) |
| .then(exchangeDescription(gFirstConnection, gSecondConnection)) |
| .catch(test.step_func(function(e) { |
| assert_unreached('Error ' + e.name + ': ' + e.message); |
| })); |
| }); |
| </script> |
| |
| </body> |
| </html> |
| |
