data-demo.js

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 = 'wss://webrtc-p2p-broker.herokuapp.com/';
//var brokerUrl = 'ws://localhost: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) {
    console.log('route: ' + 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 = "";
  }
});