Firewall on Demand

    cache_size = 500

    def __init__(self):

        self.user = None

        self.user_cache = {}

        self.user_cursor = {}

                assert(self.new_message_user_event[user])

            except:

                self.new_message_user_event[user] = Event()

            try:

                if self.user_cache[user]:

                    self.user_cursor[user] = self.user_cache[user][-1]['id']

            self.user_cursor[user] = self.user_cache[user][-1]['id']

        else:

            self.user_cursor[user] = self.user_cache[user][-2]['id']

        if len(self.user_cache[user]) > self.cache_size:

            self.user_cache[user] = self.user_cache[user][-self.cache_size:]

        self.new_message_user_event[user].set()

        if request.is_ajax():

            cursor = {}

            try:

                user = request.user.get_profile().peer.domain_name

            except:

                user = None

            except:

                self.user_cache[user] = []

            if not self.user_cache[user] or cursor[user] == self.user_cache[user][-1]['id']:

            try:

                for index, m in enumerate(self.user_cache[user]):

                    if m['id'] == cursor[user]:

                if self.user_cache[user]:

                    self.user_cursor[user] = self.user_cache[user][-1]['id']

        return HttpResponseRedirect(reverse('group-routes'))

    def monitor_polls(self, polls=None):

        b = beanstalkc.Connection()

            p.spawn(self.monitor_polls)

msgs = Msgs()

main = msgs.main

message_new = msgs.message_new

poll = msgs.start_polling

poll()