bans.py 4.0 KB

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