mongo oplog replicate json over tcp

gistfile1.js

// default to $main, used in mongod master mode
var oplogCollection = '$main';

// if not master, assume a replicaset is used
if (config.db_mode !== 'master') {
  oplogCollection = 'rs';
}

var mongoDb = require("mongodb"),
    mongoServer = new mongoDb.Server(config.db_host, config.db_port),
    dbConnection = new mongoDb.Db(config.db_name, mongoServer);

dbConnection.open(function(err, db) {
  if (err !== null) {
    util.debug(err);
    process.exit(1);
  }

  var stream = db.collection('oplog.'+oplogCollection).find(null, { 'tailable' : true }).stream();

  var server = net.createServer(function(c) {
    console.log('new client');

    stream.on('data', function(item) {
      if (item.op !== 'n') {
        c.write(JSON.stringify(item)+'\r\n');
      }
    });

    stream.on('close', function() {
      console.log('stream closed, closing connection');
      c.destroy();
    });

    c.on('end', function() {
      console.log('disconnected');
    });
  });

  server.listen(config.server_port, config.server_ip, function() {
    console.log('server bound');
  });

  stream.on('error', function(err) {
    util.debug(err);
  });
});