bans.py 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139
  1. from datetime import date, timedelta
  2. import re
  3. from django.conf import settings
  4. from django.db import models
  5. from django.utils import timezone
  6. from django.utils.translation import ugettext_lazy as _
  7. from misago.core import cachebuster
  8. from misago.core.utils import time_amount
  9. __all__ = [
  10. 'BAN_USERNAME', 'BAN_EMAIL', 'BAN_IP', 'BANS_CHOICES', 'Ban', 'BanCache'
  11. ]
  12. BAN_CACHEBUSTER = 'misago_bans'
  13. BAN_USERNAME = 0
  14. BAN_EMAIL = 1
  15. BAN_IP = 2
  16. BANS_CHOICES = (
  17. (BAN_USERNAME, _('Username')),
  18. (BAN_EMAIL, _('E-mail address')),
  19. (BAN_IP, _('IP address')),
  20. )
  21. class BansManager(models.Manager):
  22. def is_ip_banned(self, ip):
  23. return self.check_ban(ip=ip)
  24. def is_username_banned(self, username):
  25. return self.check_ban(username=username)
  26. def is_email_banned(self, email):
  27. return self.check_ban(email=email)
  28. def invalidate_cache(self):
  29. cachebuster.invalidate(BAN_CACHEBUSTER)
  30. def find_ban(self, username=None, email=None, ip=None):
  31. tests = []
  32. if username:
  33. username = username.lower()
  34. tests.append(BAN_USERNAME)
  35. if email:
  36. email = email.lower()
  37. tests.append(BAN_EMAIL)
  38. if ip:
  39. tests.append(BAN_IP)
  40. queryset = self.filter(is_valid=True)
  41. if len(tests) == 1:
  42. queryset = queryset.filter(test=tests[0])
  43. elif tests:
  44. queryset = queryset.filter(test__in=tests)
  45. for ban in queryset.order_by('-id').iterator():
  46. if (ban.test == BAN_USERNAME and username and
  47. ban.test_value(username)):
  48. return ban
  49. elif ban.test == BAN_EMAIL and email and ban.test_value(email):
  50. return ban
  51. elif ban.test == BAN_IP and ip and ban.test_value(ip):
  52. return ban
  53. else:
  54. raise Ban.DoesNotExist('no valid ban for values has been found')
  55. class Ban(models.Model):
  56. test = models.PositiveIntegerField(default=BAN_USERNAME, db_index=True)
  57. banned_value = models.CharField(max_length=255, db_index=True)
  58. user_message = models.TextField(null=True, blank=True)
  59. staff_message = models.TextField(null=True, blank=True)
  60. valid_until = models.DateField(null=True, blank=True, db_index=True)
  61. is_valid = models.BooleanField(default=True, db_index=True)
  62. objects = BansManager()
  63. def save(self, *args, **kwargs):
  64. self.banned_value = self.banned_value.lower()
  65. self.is_valid = not self.is_expired
  66. return super(Ban, self).save(*args, **kwargs)
  67. @property
  68. def test_name(self):
  69. return BANS_CHOICES[self.test][1]
  70. @property
  71. def name(self):
  72. return self.banned_value
  73. @property
  74. def is_expired(self):
  75. if self.valid_until:
  76. return self.valid_until < timezone.now().date()
  77. else:
  78. return False
  79. def test_value(self, value):
  80. if '*' in self.banned_value:
  81. regex = re.escape(self.banned_value).replace('\*', '(.*?)')
  82. return re.search('^%s$' % regex, value) != None
  83. else:
  84. return self.banned_value == value
  85. def lift(self):
  86. self.valid_until = (timezone.now() - timedelta(days=1)).date()
  87. class BanCache(models.Model):
  88. user = models.OneToOneField(
  89. settings.AUTH_USER_MODEL, primary_key=True, related_name='ban_cache')
  90. ban = models.ForeignKey(
  91. Ban, null=True, blank=True, on_delete=models.SET_NULL)
  92. bans_version = models.PositiveIntegerField(default=0)
  93. user_message = models.TextField(null=True, blank=True)
  94. staff_message = models.TextField(null=True, blank=True)
  95. valid_until = models.DateField(null=True, blank=True)
  96. @property
  97. def is_banned(self):
  98. return bool(self.ban)
  99. @property
  100. def is_valid(self):
  101. version_is_valid = cachebuster.is_valid(BAN_CACHEBUSTER,
  102. self.bans_version)
  103. date_today = timezone.now().date()
  104. not_expired = not self.valid_until or self.valid_until > date_today
  105. return version_is_valid and not_expired