Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
t.js
var webrtc = require('..');
var RTCPeerConnection = webrtc.RTCPeerConnection;
var RTCSessionDescription = webrtc.RTCSessionDescription;
var RTCIceCandidate = webrtc.RTCIceCandidate;
var pc1 = new RTCPeerConnection();
var pc2 = new RTCPeerConnection();
var d = "";
for (i = 0; i < 67000; i++) {
d += "a"
}
pc1.onicecandidate = function(candidate) {
if(!candidate.candidate) return;
pc2.addIceCandidate(candidate.candidate);
}
pc2.onicecandidate = function(candidate) {
if(!candidate.candidate) return;
pc1.addIceCandidate(candidate.candidate);
}
function handle_error(error)
{
throw error;
}
var checks = 0;
var expected = 100;
function create_data_channels() {
var dc1 = pc1.createDataChannel('test');
dc1.binaryType = 'arraybuffer'
dc1.onopen = function() {
console.log("pc1: data channel open");
dc1.onmessage = function(event) {
var data = event.data;
console.log("dc1: received '"+data+"'");
console.log("dc1: sending 'pong'");
// var buffer = buf);
dc1.send(d);
}
}
var dc2;
pc2.ondatachannel = function(event) {
dc2 = event.channel;
dc2.onopen = function() {
console.log("pc2: data channel open");
dc2.onmessage = function(event) {
var data = event.data;
console.log("dc2: received ''", data.length);
if(++checks == expected) {
done();
} else {
console.log("dc2: sending 'ping'");
console.log("ping.send2", dc2.send("ping"));
}
}
console.log("dc2: sending 'ping'");
dc2.send("ping");
};
}
create_offer();
}
function create_offer() {
console.log('pc1: create offer');
pc1.createOffer(set_pc1_local_description, handle_error);
}
function set_pc1_local_description(desc) {
console.log('pc1: set local description');
pc1.setLocalDescription(
new RTCSessionDescription(desc),
set_pc2_remote_description.bind(undefined, desc),
handle_error
);
}
function set_pc2_remote_description(desc) {
console.log('pc2: set remote description');
pc2.setRemoteDescription(
new RTCSessionDescription(desc),
create_answer,
handle_error
);
}
function create_answer() {
console.log('pc2: create answer');
pc2.createAnswer(
set_pc2_local_description,
handle_error
);
}
function set_pc2_local_description(desc) {
console.log('pc2: set local description');
pc2.setLocalDescription(
new RTCSessionDescription(desc),
set_pc1_remote_description.bind(undefined, desc),
handle_error
);
}
function set_pc1_remote_description(desc) {
console.log('pc1: set remote description');
pc1.setRemoteDescription(
new RTCSessionDescription(desc),
wait,
handle_error
);
}
function wait() {
console.log('waiting');
}
function run() {
create_data_channels();
}
function done() {
console.log('cleanup');
pc1.close();
pc2.close();
console.log('done');
}
run();
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.