tornadio2.py

class SocCon(SocketConnection):
    pool = redis.ConnectionPool(host='ip for redis server', port=6379, db=0)
    redis = redis.Redis(connection_pool=pool)
    unique_cls = 0
    user = {}
    val = 0
    @classmethod
    def get_user(cls):
        cls.unique_cls += 1
        user = "User%s" % cls.unique_cls
        return user

    def on_open(self, request):
        self.val = self.validation(request.get_argument("token"))
        if self.val:
            self.client = brukva.Client(host='ip for redis server', port=6379, db=0))
            self.client.connect()
            self.client.subscribe("main_channel")
            self.client.listen(self.on_chan)

            self.user[self] = self.get_user()
            user = self.user[self]
            self.user[user] = self
        else:
            return
        
    def on_close(self):
        self.client.unsubscribe('main_channel')
        for room in self.redis.smembers("rooms"):
            self.client.unsubscribe(room)
            for user in self.redis.smembers(room):
                if(self.user[user] == self):
                    self.redis.srem(room, user)

        tmp = self.user[self]
        del self.user[self]
        del self.user[tmp]