mirror of https://github.com/jumpserver/jumpserver
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
79 lines
2.5 KiB
79 lines
2.5 KiB
# -*- coding: utf-8 -*-
|
|
#
|
|
from django.shortcuts import get_object_or_404
|
|
from rest_framework.viewsets import ModelViewSet
|
|
from rest_framework_bulk import BulkModelViewSet
|
|
from common.mixins import CommonApiMixin
|
|
|
|
from ..utils import set_to_root_org, filter_org_queryset
|
|
from ..models import Organization
|
|
|
|
__all__ = [
|
|
'RootOrgViewMixin', 'OrgMembershipModelViewSetMixin', 'OrgModelViewSet',
|
|
'OrgBulkModelViewSet', 'OrgQuerySetMixin',
|
|
]
|
|
|
|
|
|
class RootOrgViewMixin:
|
|
def dispatch(self, request, *args, **kwargs):
|
|
set_to_root_org()
|
|
return super().dispatch(request, *args, **kwargs)
|
|
|
|
|
|
class OrgQuerySetMixin:
|
|
def get_queryset(self):
|
|
if hasattr(self, 'model'):
|
|
queryset = self.model.objects.all()
|
|
else:
|
|
assert self.queryset is None, (
|
|
"'%s' should not include a `queryset` attribute"
|
|
% self.__class__.__name__
|
|
)
|
|
queryset = super().get_queryset()
|
|
|
|
if hasattr(self, 'swagger_fake_view'):
|
|
return queryset[:1]
|
|
if hasattr(self, 'action') and self.action == 'list':
|
|
serializer_class = self.get_serializer_class()
|
|
if serializer_class and hasattr(serializer_class, 'setup_eager_loading'):
|
|
queryset = serializer_class.setup_eager_loading(queryset)
|
|
return queryset
|
|
|
|
|
|
class OrgModelViewSet(CommonApiMixin, OrgQuerySetMixin, ModelViewSet):
|
|
pass
|
|
|
|
|
|
class OrgBulkModelViewSet(CommonApiMixin, OrgQuerySetMixin, BulkModelViewSet):
|
|
def allow_bulk_destroy(self, qs, filtered):
|
|
qs_count = qs.count()
|
|
filtered_count = filtered.count()
|
|
if filtered_count == 1:
|
|
return True
|
|
if qs_count <= filtered_count:
|
|
return False
|
|
if self.request.query_params.get('spm', ''):
|
|
return True
|
|
return False
|
|
|
|
|
|
class OrgMembershipModelViewSetMixin:
|
|
org = None
|
|
membership_class = None
|
|
lookup_field = 'user'
|
|
lookup_url_kwarg = 'user_id'
|
|
http_method_names = ['get', 'post', 'delete', 'head', 'options']
|
|
|
|
def dispatch(self, request, *args, **kwargs):
|
|
self.org = get_object_or_404(Organization, pk=kwargs.get('org_id'))
|
|
return super().dispatch(request, *args, **kwargs)
|
|
|
|
def get_serializer_context(self):
|
|
context = super().get_serializer_context()
|
|
context['org'] = self.org
|
|
return context
|
|
|
|
def get_queryset(self):
|
|
queryset = self.membership_class.objects.filter(organization=self.org)
|
|
return queryset
|