|
23 | 23 | # see http://www.gnu.org/licenses/.
|
24 | 24 | #
|
25 | 25 | # ##############################################################################
|
26 |
| - |
27 |
| -from rest_framework import viewsets, status |
28 |
| -from rest_framework.authentication import SessionAuthentication |
| 26 | +from rest_framework import mixins, status |
| 27 | +from rest_framework.generics import GenericAPIView, ListCreateAPIView |
29 | 28 | from rest_framework.response import Response
|
| 29 | +from rest_framework.schemas.openapi import AutoSchema |
| 30 | +from rest_framework.serializers import Serializer |
30 | 31 |
|
31 |
| -from admission.contrib.models import DoctorateAdmission |
32 |
| -from admission.contrib.serializers import ( |
33 |
| - DoctorateAdmissionReadSerializer, DoctorateAdmissionWriteSerializer |
| 32 | +from admission.contrib import serializers |
| 33 | +from ddd.logic.admission.preparation.projet_doctoral.commands import ( |
| 34 | + CompleterPropositionCommand, GetPropositionCommand, |
| 35 | + InitierPropositionCommand, |
| 36 | + SearchPropositionsCommand, |
34 | 37 | )
|
| 38 | +from infrastructure.messages_bus import message_bus_instance |
| 39 | + |
| 40 | + |
| 41 | +class DetailedAutoSchema(AutoSchema): |
| 42 | + def get_request_body(self, path, method): |
| 43 | + if method not in ('PUT', 'PATCH', 'POST'): |
| 44 | + return {} |
| 45 | + |
| 46 | + self.request_media_types = self.map_parsers(path, method) |
| 47 | + |
| 48 | + serializer = self.get_serializer(path, method, for_response=False) |
| 49 | + |
| 50 | + if not isinstance(serializer, Serializer): |
| 51 | + item_schema = {} |
| 52 | + else: |
| 53 | + item_schema = self._get_reference(serializer) |
| 54 | + |
| 55 | + return { |
| 56 | + 'content': { |
| 57 | + ct: {'schema': item_schema} |
| 58 | + for ct in self.request_media_types |
| 59 | + } |
| 60 | + } |
| 61 | + |
| 62 | + def get_components(self, path, method): |
| 63 | + if method.lower() == 'delete': |
| 64 | + return {} |
| 65 | + |
| 66 | + components = {} |
| 67 | + for with_response in [True, False]: |
| 68 | + serializer = self.get_serializer(path, method, for_response=with_response) |
| 69 | + if not isinstance(serializer, Serializer): |
| 70 | + return {} |
| 71 | + component_name = self.get_component_name(serializer) |
| 72 | + content = self.map_serializer(serializer) |
| 73 | + components[component_name] = content |
| 74 | + |
| 75 | + return components |
| 76 | + |
| 77 | + def get_serializer(self, path, method, for_response=True): |
| 78 | + raise NotImplementedError |
| 79 | + |
35 | 80 |
|
| 81 | +class PropositionListSchema(DetailedAutoSchema): |
| 82 | + def get_operation_id_base(self, path, method, action): |
| 83 | + return '_proposition' if method == 'POST' else '_propositions' |
36 | 84 |
|
37 |
| -class DoctorateAdmissionViewSet(viewsets.ModelViewSet): |
38 |
| - queryset = DoctorateAdmission.objects.all() |
39 |
| - authentication_classes = [SessionAuthentication, ] |
40 |
| - lookup_field = "uuid" |
| 85 | + def get_serializer(self, path, method, for_response=True): |
| 86 | + if method == 'POST': |
| 87 | + if for_response: |
| 88 | + return serializers.PropositionIdentityDTOSerializer() |
| 89 | + return serializers.InitierPropositionCommandSerializer() |
| 90 | + return serializers.PropositionSearchDTOSerializer() |
41 | 91 |
|
42 |
| - def get_serializer_class(self): |
43 |
| - if self.action in ["create", "update", "partial_update"]: |
44 |
| - return DoctorateAdmissionWriteSerializer |
45 |
| - return DoctorateAdmissionReadSerializer |
46 | 92 |
|
47 |
| - def create(self, request, *args, **kwargs): |
48 |
| - serializer = self.get_serializer(data=request.data) |
| 93 | +class PropositionListViewSet(ListCreateAPIView): |
| 94 | + schema = PropositionListSchema() |
| 95 | + pagination_class = None |
| 96 | + filter_backends = None |
| 97 | + |
| 98 | + def list(self, request, **kwargs): |
| 99 | + proposition_list = message_bus_instance.invoke( |
| 100 | + SearchPropositionsCommand(matricule_candidat=request.user.person.global_id) |
| 101 | + ) |
| 102 | + serializer = serializers.PropositionSearchDTOSerializer(instance=proposition_list, many=True) |
| 103 | + return Response(serializer.data) |
| 104 | + |
| 105 | + def create(self, request, **kwargs): |
| 106 | + serializer = serializers.InitierPropositionCommandSerializer(data=request.data) |
49 | 107 | serializer.is_valid(raise_exception=True)
|
50 |
| - self.perform_create(serializer) |
51 |
| - serializer = DoctorateAdmissionReadSerializer(instance=serializer.instance) |
52 |
| - headers = self.get_success_headers(serializer.data) |
53 |
| - return Response( |
54 |
| - serializer.data, status=status.HTTP_201_CREATED, headers=headers |
| 108 | + result = message_bus_instance.invoke(InitierPropositionCommand(**serializer.data)) |
| 109 | + serializer = serializers.PropositionIdentityDTOSerializer(instance=result) |
| 110 | + return Response(serializer.data, status=status.HTTP_201_CREATED) |
| 111 | + |
| 112 | + |
| 113 | +class PropositionSchema(DetailedAutoSchema): |
| 114 | + def get_operation_id_base(self, path, method, action): |
| 115 | + return '_proposition' |
| 116 | + |
| 117 | + def get_serializer(self, path, method, for_response=True): |
| 118 | + if method == 'PUT': |
| 119 | + if for_response: |
| 120 | + return serializers.PropositionIdentityDTOSerializer() |
| 121 | + return serializers.CompleterPropositionCommandSerializer() |
| 122 | + return serializers.PropositionDTOSerializer() |
| 123 | + |
| 124 | + |
| 125 | +class PropositionViewSet(mixins.RetrieveModelMixin, mixins.UpdateModelMixin, GenericAPIView): |
| 126 | + schema = PropositionSchema() |
| 127 | + pagination_class = None |
| 128 | + filter_backends = None |
| 129 | + |
| 130 | + def get(self, request, *args, **kwargs): |
| 131 | + # TODO call osis_role perm for this object |
| 132 | + proposition = message_bus_instance.invoke( |
| 133 | + GetPropositionCommand(uuid_proposition=kwargs.get('uuid')) |
55 | 134 | )
|
| 135 | + serializer = serializers.PropositionDTOSerializer(instance=proposition) |
| 136 | + return Response(serializer.data) |
| 137 | + |
| 138 | + def put(self, request, *args, **kwargs): |
| 139 | + serializer = serializers.CompleterPropositionCommandSerializer(data=request.data) |
| 140 | + serializer.is_valid(raise_exception=True) |
| 141 | + result = message_bus_instance.invoke(CompleterPropositionCommand(**serializer.data)) |
| 142 | + serializer = serializers.PropositionIdentityDTOSerializer(instance=result) |
| 143 | + return Response(serializer.data, status=status.HTTP_200_OK) |
0 commit comments