server.js

var express = require('express');
var http = require('http');
var socketIo = require('socket.io');

function start(handle) {    
    var app = express();
    var server = http.createServer(app);
    var io = socketIo.listen(server);

    app.use(express.bodyParser());
    app.use(express.static(__dirname + '/public'));
    
    app.get('/list/:listId', function(request, response) {
        handle.getList(request.params.listId, function(err, items) {
            if(err)
                return response.send(err, 500);
            return response.json(items);
        });
    });

    app.post('/list', function(request, response) {
        handle.newList(function(err, newListId) {
            if(err)
                response.send(err, 500);
            response.header('Location', 'http://groceries-server.akire.c9.io/list/' + newListId);
            return response.send(201);    
        });
    });
    
    app.post('/list/:listId', function(request, response) {
        handle.add(request.params.listId, request.body.item, function(err, listId, item) {
            if(err)
                return response.send(err, 500);
            response.send();
            return io.sockets.to(listId).emit('add', { "item": item });
        });
    });
    
    app.del('/list/:listId', function(request, response) {
        handle.clearList(request.params.listId, function(err) {
            if(err)
                return response.send(err, 500);
            return response.send();
        });
    });
    
    app.del('/list/:listId/:item', function(request, response) {
        handle.remove(request.params.listId, request.params.item, function(err, listId, item) {
            if(err)
                return response.send(err, 500);
            response.send();
            return io.sockets.to(listId).emit('remove', { "item": item });
        });
    });

    server.listen(process.env.PORT || 3000);
    console.log("Server has started.");
    
/*
    // Socket config for Heroku
    io.configure(function() {
        io.set('transports', ['xhr-polling']);
        io.set('polling duration', 10);
    });
*/

    io.sockets.on('connection', function(socket) {
        socket.on('connectToList', function(listId) {
            socket.join(listId);
            socket.listId = listId;
            console.log('Client connected to list ' + listId);
        });
                
        socket.on('disconnect', function() {
            socket.leave(socket.listId);
            console.log('Client disconnected from list ' + socket.listId);
        });
        
        socket.on('message', function(message) {
            console.log('Server got message: ' + message);    
        });
    });
} 

exports.start = start;