1 files changed, 103 insertions, 0 deletions
diff --git a/tests/sockets/p2p/examples/data-demo.js b/tests/sockets/p2p/examples/data-demo.js
new file mode 100644
index 00000000..86fe2fa9
--- /dev/null
+++ b/tests/sockets/p2p/examples/data-demo.js
@@ -0,0 +1,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 = "";
+  }
+});