server.js

/**
 * @file
 *
 * Main file for Metalike project
 * Cranburgers team entry in NKO 2011 http://nodeknockout.com
 * 
 * @author: Russell Uman <russ@firebus.com>
 */

// Requires
var compressor = require('node-minify')
, http = require('http')
, https = require('https')
, fs = require('fs')
, nko = require('nko')('B80ubnph0rdg+N4H')
, redis = require('redis')
, url = require('url'); 


port = process.env.NODE_ENV == 'production' ? 80 : 8080;
sslPort = process.env.NODE_ENV == 'production' ? 443 : 8443;

// Minify bookmarklet
new compressor.minify({
  type: 'uglifyjs',
  fileIn: './bookmarklet.js',
  fileOut: './bookmarklet-min.js',
  callback: function(err){
    if (err) {
      console.log('Error: minify: ' + err);
    }
  }
});

// Start http server
var httpApp = http.createServer(routeHandler);
// Redis client
var httpClient = redis.createClient();
httpClient.on('error', function(err) {
    console.log('Error: redis: ' + err);
});
// Instantiate sockets
var httpIo = require('socket.io').listen(httpApp);
httpIo.sockets.on('connection', function (socket) {
  socket.on('metalike', function(data) {
      saveMetalike(data);
  });
  socket.on('lookup', function(data) {
      lookupMetalike(data, this);
  });
});
httpApp.listen(port);
console.log('Server listening on ' + httpApp.address().port);

// Start ssl server
var sslOptions = {
  key: fs.readFileSync('server.key'),
  cert: fs.readFileSync('server.crt'),
};
var sslApp = https.createServer(sslOptions, routeHandler);
// Redis client
var httpsClient = redis.createClient();
httpsClient.on('error', function(err) {
    console.log('Error: redis: ' + err);
});
// Instantiate sockets
var httpsIo = require('socket.io').listen(sslApp);
httpsIo.sockets.on('connection', function (socket) {
  socket.on('metalike', function(data) {
      saveMetalike(data);
  });
  socket.on('lookup', function(data) {
      lookupMetalike(data, this);
  });
});
sslApp.listen(sslPort);
console.log('Secure server listening on ' + sslApp.address().port);

/**
 * A really simple router
 */
function routeHandler (req, res) {
  var path = url.parse(req.url).pathname
  
  // remap / to index.html
  if (path == '/') {
    path = '/index.html';
  }
  console.log("Request for " + path + " received.");

  // route index.html through haml
  if (path == '/index.html') {
    var haml = require('hamljs')
    , hostname = req.headers.host;
    
    if (/^80/.test(this.address().port)) {
      var protocol =  'http';
    }
    else {
      var protocol = 'https';
    }

    var bookmarklet = fs.readFileSync(__dirname + '/bookmarklet-min.js').toString().replace(/HOSTNAME/g, hostname).replace('PROTOCOL', protocol);
    
    var options = {
      locals: {
        bookmarklet: 'javascript:' + bookmarklet,
        hostname: hostname,
      }
    };
    res.writeHead(200);
    res.end(haml.render(fs.readFileSync('index.haml'), options));
  }
  // if not index.html try to make the path to a file
  else {
    fs.readFile(__dirname + path, function (err, data) {
      if (err) {
        console.log('Error loading ' + path);
        res.writeHead(500);
        return res.end('Error loading ' + path);
      }
      res.writeHead(200);
      res.end(data);
    });
  }
}

function saveMetalike(data) {
  var metalike = { metalike: [
    { uid: data.userId, username: data.userName, likes: [] },
  ]};
  var jsonMetalike = JSON.stringify(metalike);
  httpClient.set(data.storyId, jsonMetalike, redis.print);
}

function lookupMetalike(data, socket) {
  httpClient.get(data['storyId'], function(err, res) {
      if (res) {
        var jsonMetalike = JSON.parse(res);
        var storyId = data['storyId'];
        var userId = jsonMetalike.metalike[0].uid;
        var userName = jsonMetalike.metalike[0].username;
        socket.emit('metalike', { storyId: storyId, userId: userId, metaUserId: userId , metaUserName: userName });
      }
  });
}