checkpointmodel.py 2.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364
  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. date = models.DateTimeField()
  13. ip = models.GenericIPAddressField()
  14. agent = models.CharField(max_length=255)
  15. class Meta:
  16. app_label = 'misago'
  17. def rename_user_handler(sender, **kwargs):
  18. Checkpoint.objects.filter(user=sender).update(
  19. user_name=sender.username,
  20. user_slug=sender.username_slug,
  21. )
  22. rename_user.connect(rename_user_handler, dispatch_uid="rename_user_checkpoints")
  23. def move_forum_content_handler(sender, **kwargs):
  24. Checkpoint.objects.filter(forum=sender).update(forum=kwargs['move_to'])
  25. move_forum_content.connect(move_forum_content_handler, dispatch_uid="move_forum_checkpoints")
  26. def move_thread_handler(sender, **kwargs):
  27. Checkpoint.objects.filter(thread=sender).update(forum=kwargs['move_to'])
  28. move_thread.connect(move_thread_handler, dispatch_uid="move_thread_checkpoints")
  29. def merge_thread_handler(sender, **kwargs):
  30. Checkpoint.objects.filter(thread=sender).delete()
  31. merge_thread.connect(merge_thread_handler, dispatch_uid="merge_threads_checkpoints")
  32. def move_posts_handler(sender, **kwargs):
  33. if sender.checkpoints:
  34. prev_post = Post.objects.filter(thread=sender.thread_id).filter(merge__lte=sender.merge).exclude(id=sender.pk).order_by('merge', '-id')[:1][0]
  35. Checkpoint.objects.filter(post=sender).update(post=prev_post)
  36. prev_post.checkpoints = True
  37. prev_post.save(force_update=True)
  38. sender.checkpoints = False
  39. move_post.connect(move_posts_handler, dispatch_uid="move_posts_checkpoints")
  40. def merge_posts_handler(sender, **kwargs):
  41. Checkpoint.objects.filter(post=sender).update(post=kwargs['new_post'])
  42. if sender.checkpoints:
  43. kwargs['new_post'].checkpoints = True
  44. merge_post.connect(merge_posts_handler, dispatch_uid="merge_posts_checkpoints")