server.js

var express = require('express'),
    http = require('http'),
    app = express(),
    server = http.createServer(app),
    io = require('socket.io').listen(server);

var sockets = {};
var time = function () {
    return new Date().getTime();
};

io.on('connection', function (socket) {
    console.log("We have a connection! Socket ID: " + socket.id);
    for (var k in sockets) {
        var s = sockets[k];
        s.disconnect();
        delete sockets[k];
    }
    sockets[socket.id] = socket;
    socket.emit('data', {
        notice: "New Socket.IO connection.",
        session_id: socket.id,
        time: time()
    });
});

io.on('blah', function (data) {
    console.log("Got blah: " + data);
})

app.configure(function () {
    app.use(express.static(__dirname + '/public'));
    app.use(express.logger('dev'));
    app.use(express.bodyParser());
});

app.put('/push/:id', function (req, res) {
    console.log("PUT to /push/" + req.params.id);
    var id = req.params.id;
    if (sockets[id]) {
        sockets[id].emit('data', req.body);
        res.send("OK");
    } else {
        res.status(404).send("Session ID not found");
    }
});

var port = process.env.PORT || 3000;
server.listen(port);
console.log("Server running on port " + port);