users.py 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152
  1. from django.conf import settings
  2. from django.contrib.auth import get_user_model
  3. from django.core.exceptions import PermissionDenied
  4. from django.shortcuts import get_object_or_404
  5. from django.utils.translation import ugettext as _
  6. from rest_framework import mixins, status, viewsets
  7. from rest_framework.decorators import detail_route, list_route
  8. from rest_framework.parsers import JSONParser, MultiPartParser
  9. from rest_framework.response import Response
  10. from misago.acl import add_acl
  11. from misago.core.apipaginator import ApiPaginator
  12. from misago.users.forms.options import ForumOptionsForm
  13. from misago.users.permissions.profiles import (allow_browse_users_list,
  14. allow_see_users_online_list)
  15. from misago.users.rest_permissions import (BasePermission,
  16. IsAuthenticatedOrReadOnly, UnbannedAnonOnly)
  17. from misago.users.serializers import UserSerializer, UserProfileSerializer
  18. from misago.users.api.userendpoints.list import list_endpoint
  19. from misago.users.api.userendpoints.avatar import avatar_endpoint
  20. from misago.users.api.userendpoints.create import create_endpoint
  21. from misago.users.api.userendpoints.signature import signature_endpoint
  22. from misago.users.api.userendpoints.username import username_endpoint
  23. from misago.users.api.userendpoints.changeemail import change_email_endpoint
  24. from misago.users.api.userendpoints.changepassword import change_password_endpoint
  25. class UserViewSetPermission(BasePermission):
  26. def has_permission(self, request, view):
  27. if view.action == 'create':
  28. policy = UnbannedAnonOnly()
  29. else:
  30. policy = IsAuthenticatedOrReadOnly()
  31. return policy.has_permission(request, view)
  32. def allow_self_only(user, pk, message):
  33. if user.is_anonymous():
  34. raise PermissionDenied(
  35. _("You have to sign in to perform this action."))
  36. if user.pk != int(pk):
  37. raise PermissionDenied(message)
  38. class UserViewSet(viewsets.GenericViewSet):
  39. permission_classes = (UserViewSetPermission,)
  40. parser_classes=(JSONParser, MultiPartParser)
  41. serializer_class = UserSerializer
  42. queryset = get_user_model().objects
  43. pagination_class = ApiPaginator(settings.MISAGO_USERS_PER_PAGE, 4)
  44. def get_queryset(self):
  45. relations = ('rank', 'online_tracker', 'ban_cache')
  46. return self.queryset.select_related(*relations)
  47. def list(self, request):
  48. allow_browse_users_list(request.user)
  49. users_list = list_endpoint(request, self.get_queryset())
  50. if not users_list:
  51. return Response([])
  52. if 'data' in users_list:
  53. return Response(users_list['data'])
  54. if users_list.get('paginate'):
  55. page = self.paginate_queryset(users_list['queryset'])
  56. users_list['queryset'] = page
  57. if users_list.get('serializer'):
  58. serializer_class = users_list.get('serializer')
  59. else:
  60. serializer_class = self.serializer_class
  61. serializer = serializer_class(
  62. users_list['queryset'], many=True, context={'user': request.user})
  63. response_dict = {
  64. 'results': serializer.data,
  65. 'users': self.queryset.count()
  66. }
  67. if users_list.get('paginate'):
  68. response_dict.update(self.paginator.get_meta())
  69. return Response(response_dict)
  70. def create(self, request):
  71. return create_endpoint(request)
  72. def retrieve(self, request, pk=None):
  73. qs = self.get_queryset()
  74. profile = get_object_or_404(self.get_queryset(), id=pk)
  75. add_acl(request.user, profile)
  76. serializer = UserProfileSerializer(
  77. profile, context={'user': request.user})
  78. return Response(serializer.data)
  79. @detail_route(methods=['get', 'post'])
  80. def avatar(self, request, pk=None):
  81. allow_self_only(
  82. request.user, pk, _("You can't change other users avatars."))
  83. return avatar_endpoint(request)
  84. @detail_route(methods=['post'])
  85. def forum_options(self, request, pk=None):
  86. allow_self_only(
  87. request.user, pk, _("You can't change other users options."))
  88. form = ForumOptionsForm(request.data, instance=request.user)
  89. if form.is_valid():
  90. form.save()
  91. return Response({
  92. 'detail': _("Your forum options have been changed.")
  93. })
  94. else:
  95. return Response(form.errors, status=status.HTTP_400_BAD_REQUEST)
  96. @detail_route(methods=['get', 'post'])
  97. def username(self, request, pk=None):
  98. allow_self_only(
  99. request.user, pk, _("You can't change other users names."))
  100. return username_endpoint(request)
  101. @detail_route(methods=['get', 'post'])
  102. def signature(self, request, pk=None):
  103. allow_self_only(
  104. request.user, pk, _("You can't change other users signatures."))
  105. return signature_endpoint(request)
  106. @detail_route(methods=['post'])
  107. def change_password(self, request, pk=None):
  108. allow_self_only(
  109. request.user, pk, _("You can't change other users passwords."))
  110. return change_password_endpoint(request)
  111. @detail_route(methods=['post'])
  112. def change_email(self, request, pk=None):
  113. allow_self_only(request.user, pk,
  114. _("You can't change other users e-mail addresses."))
  115. return change_email_endpoint(request)