utils.py 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768
  1. from hashlib import md5
  2. from django.conf import settings
  3. from django.core.cache import cache
  4. from django.utils.encoding import force_bytes
  5. from ..markup import common_flavour
  6. from .models import Agreement, UserAgreement
  7. def set_agreement_as_active(agreement, commit=False):
  8. agreement.is_active = True
  9. queryset = Agreement.objects.filter(type=agreement.type).exclude(pk=agreement.pk)
  10. queryset.update(is_active=False)
  11. if commit:
  12. agreement.save(update_fields=["is_active"])
  13. Agreement.objects.invalidate_cache()
  14. def disable_agreement(agreement, commit=False):
  15. agreement.is_active = False
  16. if commit:
  17. agreement.save(update_fields=["is_active"])
  18. Agreement.objects.invalidate_cache()
  19. def get_required_user_agreement(user, agreements):
  20. if user.is_anonymous:
  21. return None
  22. for agreement_type, _ in Agreement.TYPE_CHOICES:
  23. agreement = agreements.get(agreement_type)
  24. if agreement and agreement["id"] not in user.agreements:
  25. try:
  26. return Agreement.objects.get(id=agreement["id"])
  27. except Agreement.DoesNotExist:
  28. # possible stale cache
  29. Agreement.invalidate_cache()
  30. def get_parsed_agreement_text(request, agreement):
  31. if not agreement.text:
  32. return None
  33. cache_name = "misago_legal_%s_%s" % (agreement.pk, agreement.last_modified_on or "")
  34. cached_content = cache.get(cache_name)
  35. unparsed_content = agreement.text
  36. checksum_source = force_bytes("%s:%s" % (unparsed_content, settings.SECRET_KEY))
  37. unparsed_checksum = md5(checksum_source).hexdigest()
  38. if cached_content and cached_content.get("checksum") == unparsed_checksum:
  39. return cached_content["parsed"]
  40. parsed = common_flavour(request, None, unparsed_content)["parsed_text"]
  41. cached_content = {"checksum": unparsed_checksum, "parsed": parsed}
  42. cache.set(cache_name, cached_content)
  43. return cached_content["parsed"]
  44. def save_user_agreement_acceptance(user, agreement, commit=False):
  45. user.agreements.append(agreement.id)
  46. UserAgreement.objects.create(agreement=agreement, user=user)
  47. if commit:
  48. user.save(update_fields=["agreements"])