1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
function log(msg) {
console.log(msg);
document.getElementById("chat").appendChild(document.createTextNode(msg + "\n"));
}
/*
var localvideo = document.getElementById("local");
var remotevideo = document.getElementById("remote");
*/
function bindStream(stream, element) {
if ("mozSrcObject" in element) {
element.mozSrcObject = stream;
} else {
element.src = webkitURL.createObjectURL(stream);
}
element.play();
};
var brokerSession = null;
var brokerUrl = 'https://mdsw.ch:8080';
var hosting = true;
var options;
if(window.location.search) {
var params = window.location.search.substring(1).split('&');
for(var i = 0; i < params.length; ++ i) {
if(params[i].match('^webrtc-session')) {
brokerSession = params[i].split('=')[1];
hosting = false;
} else if(params[i].match('^webrtc-broker')) {
brokerUrl = params[i].split('=')[1];
}
}
}
console.log('broker', brokerUrl);
var peer = new Peer(brokerUrl, {video: false, audio: false});
window.connections = {};
peer.onconnection = function(connection) {
log('connected: ' + connection.id);
connections[connection.id] = connection;
connection.ondisconnect = function() {
log('disconnected: ' + connection.id);
delete connections[connection.id];
};
connection.onerror = function(error) {
console.error(error);
};
//bindStream(connection.streams['local'], localvideo);
//bindStream(connection.streams['remote'], remotevideo);
connection.onmessage = function(label, msg) {
log('<other:' + connection.id + '> ' + msg.data);
};
/*
var buff = new Uint8Array([1, 2, 3, 4]);
connection.send('reliable', buff.buffer);
*/
};
peer.onerror = function(error) {
console.error(error);
};
if(hosting) {
console.log('hosting');
peer.listen({metadata:{name:'data-demo'}});
peer.onroute = function(route) {
var url = window.location.toString().split('?');
url[1] = url[1] || '';
var params = url[1].split('&');
params.push('webrtc-session=' + route);
url[1] = params.join('&');
var div = document.getElementById('host');
div.innerHTML = '<a href="' + url.join('?') + '">connect</a>';
}
} else {
peer.connect(brokerSession);
}
window.onbeforeunload = function() {
var ids = Object.keys(connections);
ids.forEach(function(id) {
connections[id].close();
});
peer.close();
};
document.getElementById("chatinput").addEventListener("keyup", function(e) {
if (e.keyCode == 13) {
var ci = document.getElementById("chatinput");
log("<self> " + ci.value);
var ids = Object.keys(connections);
ids.forEach(function(id) {
connections[id].send('reliable', ci.value);
});
ci.value = "";
}
});
|
