posts.py 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. from misago.acl import add_acl
  2. from misago.conf import settings
  3. from misago.core.shortcuts import paginate, pagination_dict
  4. from misago.readtracker.threadstracker import make_posts_read_aware
  5. from misago.users.online.utils import make_users_status_aware
  6. from ..paginator import PostsPaginator
  7. from ..permissions.threads import exclude_invisible_posts
  8. from ..serializers import PostSerializer
  9. from ..utils import add_likes_to_posts
  10. __all__ = ['ThreadPosts']
  11. class ViewModel(object):
  12. def __init__(self, request, thread, page):
  13. try:
  14. thread_model = thread.unwrap()
  15. except AttributeError:
  16. thread_model = thread
  17. posts_queryset = self.get_posts_queryset(request, thread_model)
  18. posts_limit = settings.MISAGO_POSTS_PER_PAGE
  19. posts_orphans = settings.MISAGO_POSTS_TAIL
  20. list_page = paginate(posts_queryset, page, posts_limit, posts_orphans,
  21. paginator=PostsPaginator)
  22. paginator = pagination_dict(list_page, include_page_range=False)
  23. posts = list(list_page.object_list)
  24. posters = []
  25. for post in posts:
  26. post.category = thread.category
  27. post.thread = thread_model
  28. if post.poster:
  29. posters.append(post.poster)
  30. make_users_status_aware(request.user, posters)
  31. if thread.category.acl['can_see_posts_likes']:
  32. add_likes_to_posts(request.user, posts)
  33. # add events to posts
  34. if thread_model.has_events:
  35. first_post = None
  36. if list_page.has_previous():
  37. first_post = posts[0]
  38. last_post = None
  39. if list_page.has_next():
  40. last_post = posts[-1]
  41. events_limit = settings.MISAGO_EVENTS_PER_PAGE
  42. posts += self.get_events_queryset(
  43. request, thread_model, events_limit, first_post, last_post)
  44. # sort both by pk
  45. posts.sort(key=lambda p: p.pk)
  46. # make posts and events ACL and reads aware
  47. add_acl(request.user, posts)
  48. make_posts_read_aware(request.user, thread_model, posts)
  49. self._user = request.user
  50. self.posts = posts
  51. self.paginator = paginator
  52. def get_posts_queryset(self, request, thread):
  53. queryset = thread.post_set.select_related(
  54. 'poster',
  55. 'poster__rank',
  56. 'poster__ban_cache',
  57. 'poster__online_tracker'
  58. ).filter(is_event=False).order_by('id')
  59. return exclude_invisible_posts(request.user, thread.category, queryset)
  60. def get_events_queryset(self, request, thread, limit, first_post=None, last_post=None):
  61. queryset = thread.post_set.select_related('poster').filter(is_event=True)
  62. if first_post:
  63. queryset = queryset.filter(pk__gt=first_post.pk)
  64. if last_post:
  65. queryset = queryset.filter(pk__lt=last_post.pk)
  66. queryset = exclude_invisible_posts(request.user, thread.category, queryset)
  67. return list(queryset.order_by('-id')[:limit])
  68. def get_frontend_context(self):
  69. context = {
  70. 'results': PostSerializer(self.posts, many=True, context={'user': self._user}).data
  71. }
  72. context.update(self.paginator)
  73. return context
  74. def get_template_context(self):
  75. return {
  76. 'posts': self.posts,
  77. 'paginator': self.paginator
  78. }
  79. class ThreadPosts(ViewModel):
  80. pass