Source code
Revision control
Copy as Markdown
Other Tools
/* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
/**
* Returns the contents of a blob as text
*
* @param {Blob} blob
The blob to retrieve the contents from
*/
function getBlobContent(blob) {
return new Promise(resolve => {
var reader = new FileReader();
// Listen for 'onloadend' which will always be called after a success or failure
reader.onloadend = event => resolve(event.target.result);
reader.readAsText(blob);
});
}
var commandsCreateDataChannel = [
function PC_REMOTE_EXPECT_DATA_CHANNEL(test) {
test.pcRemote.expectDataChannel();
},
function PC_LOCAL_CREATE_DATA_CHANNEL(test) {
var channel = test.pcLocal.createDataChannel({});
is(channel.binaryType, "blob", channel + " is of binary type 'blob'");
is(
test.pcLocal.signalingState,
STABLE,
"Create datachannel does not change signaling state"
);
return test.pcLocal.observedNegotiationNeeded;
},
];
var commandsWaitForDataChannel = [
function PC_LOCAL_VERIFY_DATA_CHANNEL_STATE(test) {
return test.pcLocal.dataChannels[0].opened;
},
function PC_REMOTE_VERIFY_DATA_CHANNEL_STATE(test) {
return test.pcRemote.nextDataChannel.then(channel => channel.opened);
},
];
var commandsCheckDataChannel = [
function SEND_MESSAGE(test) {
var message = "Lorem ipsum dolor sit amet";
info("Sending message:" + message);
return test.send(message).then(result => {
is(
result.data,
message,
"Message correctly transmitted from pcLocal to pcRemote."
);
});
},
function SEND_BLOB(test) {
var contents = "At vero eos et accusam et justo duo dolores et ea rebum.";
var blob = new Blob([contents], { type: "text/plain" });
info("Sending blob");
return test
.send(blob)
.then(result => {
ok(result.data instanceof Blob, "Received data is of instance Blob");
is(result.data.size, blob.size, "Received data has the correct size.");
return getBlobContent(result.data);
})
.then(recv_contents =>
is(recv_contents, contents, "Received data has the correct content.")
);
},
function CREATE_SECOND_DATA_CHANNEL(test) {
return test.createDataChannel({}).then(result => {
is(
result.remote.binaryType,
"blob",
"remote data channel is of binary type 'blob'"
);
});
},
function SEND_MESSAGE_THROUGH_LAST_OPENED_CHANNEL(test) {
var channels = test.pcRemote.dataChannels;
var message = "I am the Omega";
info("Sending message:" + message);
return test.send(message).then(result => {
is(
channels.indexOf(result.channel),
channels.length - 1,
"Last channel used"
);
is(result.data, message, "Received message has the correct content.");
});
},
function SEND_MESSAGE_THROUGH_FIRST_CHANNEL(test) {
var message = "Message through 1st channel";
var options = {
sourceChannel: test.pcLocal.dataChannels[0],
targetChannel: test.pcRemote.dataChannels[0],
};
info("Sending message:" + message);
return test.send(message, options).then(result => {
is(
test.pcRemote.dataChannels.indexOf(result.channel),
0,
"1st channel used"
);
is(result.data, message, "Received message has the correct content.");
});
},
function SEND_MESSAGE_BACK_THROUGH_FIRST_CHANNEL(test) {
var message = "Return a message also through 1st channel";
var options = {
sourceChannel: test.pcRemote.dataChannels[0],
targetChannel: test.pcLocal.dataChannels[0],
};
info("Sending message:" + message);
return test.send(message, options).then(result => {
is(
test.pcLocal.dataChannels.indexOf(result.channel),
0,
"1st channel used"
);
is(result.data, message, "Return message has the correct content.");
});
},
function CREATE_NEGOTIATED_DATA_CHANNEL_MAX_RETRANSMITS(test) {
var options = {
negotiated: true,
id: 5,
protocol: "foo/bar",
ordered: false,
maxRetransmits: 500,
};
return test.createDataChannel(options).then(result => {
is(
result.local.binaryType,
"blob",
result.remote + " is of binary type 'blob'"
);
is(
result.local.id,
options.id,
result.local + " id is:" + result.local.id
);
is(
result.local.protocol,
options.protocol,
result.local + " protocol is:" + result.local.protocol
);
is(
result.local.reliable,
false,
result.local + " reliable is:" + result.local.reliable
);
is(
result.local.ordered,
options.ordered,
result.local + " ordered is:" + result.local.ordered
);
is(
result.local.maxRetransmits,
options.maxRetransmits,
result.local + " maxRetransmits is:" + result.local.maxRetransmits
);
is(
result.local.maxPacketLifeTime,
null,
result.local + " maxPacketLifeTime is:" + result.local.maxPacketLifeTime
);
is(
result.remote.binaryType,
"blob",
result.remote + " is of binary type 'blob'"
);
is(
result.remote.id,
options.id,
result.remote + " id is:" + result.remote.id
);
is(
result.remote.protocol,
options.protocol,
result.remote + " protocol is:" + result.remote.protocol
);
is(
result.remote.reliable,
false,
result.remote + " reliable is:" + result.remote.reliable
);
is(
result.remote.ordered,
options.ordered,
result.remote + " ordered is:" + result.remote.ordered
);
is(
result.remote.maxRetransmits,
options.maxRetransmits,
result.remote + " maxRetransmits is:" + result.remote.maxRetransmits
);
is(
result.remote.maxPacketLifeTime,
null,
result.remote +
" maxPacketLifeTime is:" +
result.remote.maxPacketLifeTime
);
});
},
function SEND_MESSAGE_THROUGH_LAST_OPENED_CHANNEL2(test) {
var channels = test.pcRemote.dataChannels;
var message = "I am the walrus; Goo goo g'joob";
info("Sending message:" + message);
return test.send(message).then(result => {
is(
channels.indexOf(result.channel),
channels.length - 1,
"Last channel used"
);
is(result.data, message, "Received message has the correct content.");
});
},
function CREATE_NEGOTIATED_DATA_CHANNEL_MAX_PACKET_LIFE_TIME(test) {
var options = {
ordered: false,
maxPacketLifeTime: 10,
};
return test.createDataChannel(options).then(result => {
is(
result.local.binaryType,
"blob",
result.local + " is of binary type 'blob'"
);
is(
result.local.protocol,
"",
result.local + " protocol is:" + result.local.protocol
);
is(
result.local.reliable,
false,
result.local + " reliable is:" + result.local.reliable
);
is(
result.local.ordered,
options.ordered,
result.local + " ordered is:" + result.local.ordered
);
is(
result.local.maxRetransmits,
null,
result.local + " maxRetransmits is:" + result.local.maxRetransmits
);
is(
result.local.maxPacketLifeTime,
options.maxPacketLifeTime,
result.local + " maxPacketLifeTime is:" + result.local.maxPacketLifeTime
);
is(
result.remote.binaryType,
"blob",
result.remote + " is of binary type 'blob'"
);
is(
result.remote.protocol,
"",
result.remote + " protocol is:" + result.remote.protocol
);
is(
result.remote.reliable,
false,
result.remote + " reliable is:" + result.remote.reliable
);
is(
result.remote.ordered,
options.ordered,
result.remote + " ordered is:" + result.remote.ordered
);
is(
result.remote.maxRetransmits,
null,
result.remote + " maxRetransmits is:" + result.remote.maxRetransmits
);
is(
result.remote.maxPacketLifeTime,
options.maxPacketLifeTime,
result.remote +
" maxPacketLifeTime is:" +
result.remote.maxPacketLifeTime
);
});
},
function SEND_MESSAGE_THROUGH_LAST_OPENED_CHANNEL3(test) {
var channels = test.pcRemote.dataChannels;
var message = "Nice to see you working maxPacketLifeTime";
info("Sending message:" + message);
return test.send(message).then(result => {
is(
channels.indexOf(result.channel),
channels.length - 1,
"Last channel used"
);
is(result.data, message, "Received message has the correct content.");
});
},
];
var commandsCheckLargeXfer = [
function SEND_BIG_BUFFER(test) {
var size = 2 * 1024 * 1024; // SCTP internal buffer is now 1MB, so use 2MB to ensure the buffer gets full
var buffer = new ArrayBuffer(size);
// note: type received is always blob for binary data
var options = {};
options.bufferedAmountLowThreshold = 64 * 1024;
info("Sending arraybuffer");
return test.send(buffer, options).then(result => {
ok(result.data instanceof Blob, "Received data is of instance Blob");
is(result.data.size, size, "Received data has the correct size.");
});
},
];
function addInitialDataChannel(chain) {
chain.insertBefore("PC_LOCAL_CREATE_OFFER", commandsCreateDataChannel);
chain.insertBefore(
"PC_LOCAL_WAIT_FOR_MEDIA_FLOW",
commandsWaitForDataChannel
);
chain.removeAfter("PC_REMOTE_CHECK_ICE_CONNECTIONS");
chain.append(commandsCheckDataChannel);
}