checkpointmodel.py 2.5 KB

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