checkpointmodel.py 2.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
  1. from django.db import models
  2. from misago.signals import (merge_post, merge_thread, move_forum_content,
  3. move_post, move_thread, rename_user)
  4. class Checkpoint(models.Model):
  5. forum = models.ForeignKey('Forum')
  6. thread = models.ForeignKey('Thread')
  7. post = models.ForeignKey('Post')
  8. action = models.CharField(max_length=255)
  9. user = models.ForeignKey('User', null=True, blank=True, on_delete=models.SET_NULL)
  10. user_name = models.CharField(max_length=255)
  11. user_slug = models.CharField(max_length=255)
  12. target_user = models.ForeignKey('User', null=True, blank=True, on_delete=models.SET_NULL, related_name='+')
  13. target_user_name = models.CharField(max_length=255)
  14. target_user_slug = models.CharField(max_length=255)
  15. date = models.DateTimeField()
  16. ip = models.GenericIPAddressField()
  17. agent = models.CharField(max_length=255)
  18. class Meta:
  19. app_label = 'misago'
  20. def rename_user_handler(sender, **kwargs):
  21. Checkpoint.objects.filter(user=sender).update(
  22. user_name=sender.username,
  23. user_slug=sender.username_slug,
  24. )
  25. rename_user.connect(rename_user_handler, dispatch_uid="rename_user_checkpoints")
  26. def move_forum_content_handler(sender, **kwargs):
  27. Checkpoint.objects.filter(forum=sender).update(forum=kwargs['move_to'])
  28. move_forum_content.connect(move_forum_content_handler, dispatch_uid="move_forum_checkpoints")
  29. def move_thread_handler(sender, **kwargs):
  30. Checkpoint.objects.filter(thread=sender).update(forum=kwargs['move_to'])
  31. move_thread.connect(move_thread_handler, dispatch_uid="move_thread_checkpoints")
  32. def merge_thread_handler(sender, **kwargs):
  33. Checkpoint.objects.filter(thread=sender).delete()
  34. merge_thread.connect(merge_thread_handler, dispatch_uid="merge_threads_checkpoints")
  35. def move_posts_handler(sender, **kwargs):
  36. if sender.checkpoints:
  37. prev_post = Post.objects.filter(thread=sender.thread_id).filter(merge__lte=sender.merge).exclude(id=sender.pk).order_by('merge', '-id')[:1][0]
  38. Checkpoint.objects.filter(post=sender).update(post=prev_post)
  39. prev_post.checkpoints = True
  40. prev_post.save(force_update=True)
  41. sender.checkpoints = False
  42. move_post.connect(move_posts_handler, dispatch_uid="move_posts_checkpoints")
  43. def merge_posts_handler(sender, **kwargs):
  44. Checkpoint.objects.filter(post=sender).update(post=kwargs['new_post'])
  45. if sender.checkpoints:
  46. kwargs['new_post'].checkpoints = True
  47. merge_post.connect(merge_posts_handler, dispatch_uid="merge_posts_checkpoints")