view accounts/management/commands/rate_limit_clear.py @ 629:f4c043cf55ac

Wiki integration. Requests don't always have sessions. In particular this occurs when a request is made without a trailing slash. The Common middleware redirects when this happens, and the middleware process_request() processing stops before a session can get added. So just set an attribute on the request object for each operation. This seemed weird to me at first, but there are plenty of examples of this in the Django code base already.
author Brian Neal <bgneal@gmail.com>
date Tue, 13 Nov 2012 13:50:06 -0600
parents ee87ea74d46b
children
line wrap: on
line source
"""
The rate_limit_clear command is used to clear IP addresses out from our rate
limit protection database.

"""
from optparse import make_option
import re

from django.core.management.base import BaseCommand
import redis

from core.services import get_redis_connection


IP_RE = re.compile(r'^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}$')


class Command(BaseCommand):
    help = """Remove IP addresses from the rate limit protection datastore."""
    option_list = list(BaseCommand.option_list) + [
        make_option("--purge", action="store_true",
            help="Purge all IP addresses"),
    ]

    def handle(self, *args, **kwargs):
        try:
            con = get_redis_connection()

            # get all rate-limit keys
            keys = con.keys('rate-limit-*')

            # if purging, delete them all...
            if kwargs['purge']:
                if keys:
                    con.delete(*keys)
                return

            # otherwise delete the ones the user asked for
            ips = []
            for ip in args:
                if IP_RE.match(ip):
                    key = 'rate-limit-%s' % ip
                    if key in keys:
                        ips.append(key)
                    else:
                        self.stdout.write('%s not found\n' % ip)
                else:
                    self.stderr.write('invalid IP address %s\n' % ip)

            if ips:
                con.delete(*ips)

        except redis.RedisError, e:
            self.stderr.write('%s\n' % e)