Monitor data over Z2Z protocol.

data_watch_app.js

module.exports = function(server) {
  server.pubsub.subscribe('_peer/connect', function(ev, socket) {
    if (!socket.peer.ws) {
      return; // only use for initiating peer requests
    }

    var s = socket.peer.ws.socket;

    var oldWrite = s.write;
    s.write = function(data, encoding, callback) {
      console.log('send:', data);
      return oldWrite.call(s, data, encoding, callback);
    }.bind(s);

    s.on('data', function(d) {
      console.log('recv:', d);
    });
  });
};