webserver.js

HOST = null;
PORT = 8080;

var mem = process.memoryUsage();
// every 10 seconds poll for the memory.
setInterval(function () {
  mem = process.memoryUsage();
}, 10*1000);


var sys = require('sys'),
    storage = require('./storage.js'),
    foo = require("./server"),
    url = require("url"),
    qs = require("querystring"),
    cluster = require("./cluster");

GRANULARITY = "neighborhood";

//web server handlers
foo.listen(Number(process.env.PORT || PORT), HOST);

foo.get("/", foo.staticHandler("index.html"));
foo.get("/cluster", foo.staticHandler("cluster.html"));


foo.get("/hotspots", function (req, res) {
    var swLat = parseFloat(qs.parse(url.parse(req.url).query).swLat),
        swLng = parseFloat(qs.parse(url.parse(req.url).query).swLng),
        neLat = parseFloat(qs.parse(url.parse(req.url).query).neLat),
        neLng = parseFloat(qs.parse(url.parse(req.url).query).neLng);

    storage.getTweetsWithinViewPortInLast3Hours('tweets', {swLat: swLat, swLng: swLng, neLat: neLat, neLng: neLng}, function(data){
        res.simpleJSON(200, {data: data, rss: mem.rss}); 
    });
});

foo.get("/gettweet", function(req, res){
    var id = qs.parse(url.parse(req.url).query).id;
        storage.getTweet('tweets', {id: id}, function(data){
        	res.simpleJSON(200, {data: data, rss: mem.rss}); 
    	});
});

foo.get("/clusters", function(req, res){
    var swLat = parseFloat(qs.parse(url.parse(req.url).query).swLat),
        swLng = parseFloat(qs.parse(url.parse(req.url).query).swLng),
        neLat = parseFloat(qs.parse(url.parse(req.url).query).neLat),
        neLng = parseFloat(qs.parse(url.parse(req.url).query).neLng),
        zoom = parseFloat(qs.parse(url.parse(req.url).query).zoom),
        clusters;
	
	storage.getTweetsWithinViewPortInLast3Hours('tweets', {swLat: swLat, swLng: swLng, neLat: neLat, neLng: neLng}, function(data){
		clusters = cluster.getClusters(data, zoom);
        res.simpleJSON(200, {data: clusters, rss: mem.rss}); 
    });
});

foo.get("/images/tweet.png", foo.staticHandler("assets/images/tweet.png"));
foo.get("/images/foursquare.png", foo.staticHandler("assets/images/foursquare.png"));

foo.get("/js/mustache.js", foo.staticHandler("assets/js/mustache.js"));
foo.get("/js/jquery.mustache.js", foo.staticHandler("assets/js/jquery.mustache.js"));

foo.get("/js/templates.js", foo.staticHandler("assets/templates/templates.js"));
foo.get("/js/utils.js", foo.staticHandler("assets/js/utils.js"));


foo.get("/css/main.css", foo.staticHandler("assets/css/main.css"));