Socket.IO server-side implementations

gevent-socketio.py

class Application(object):
    greenlet = None

    def __call__(self, environ, start_response):
        path = environ['PATH_INFO'].strip('/')
        if path.startswith("socket.io"):
            socketio = environ['socketio']
            while True:
                message = socketio.recv()

                if len(message) == 1:
                    message = message[0]
                    data = msgpack.loads(message.decode("base-64"))
                    if data['action'] == 'register':
                        self.id = data['id']
                        greenlet = Greenlet.spawn(updater, self)
                        self.greenlet = greenlet
                else:
                    if not socketio.connected():
                        self.greenlet.kill()

            return []
        else:
            return not_found(start_response)

tornadio.py

class StatConnection(tornadio.SocketConnection):
    greenlet = None

    def on_message(self, message):
        data = msgpack.loads(message.decode("base-64"))
        if data['action'] == 'register':
            self.id = data['id']
            greenlet = Greenlet.spawn(updater, self)
            self.greenlet = greenlet

    def on_close(self):
        self.greenlet.kill()