[OSDEV-1347] Moderation. Implement GET api/v1/moderation-events/{moderation_id}

doc/release/RELEASE-NOTES.md

@@ -19,6 +19,7 @@ This project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.html
 
 ### Code/API changes
 * [OSDEV-1346](https://opensupplyhub.atlassian.net/browse/OSDEV-1346) - Create GET request for `v1/moderation-events` endpoint.
+* [OSDEV-1347](https://opensupplyhub.atlassian.net/browse/OSDEV-1347) - Create GET request for `v1/moderation-events/{moderation_id}` endpoint.
 
 ### Architecture/Environment changes
 * *Describe architecture/environment changes here.*

src/django/api/views/v1/moderation_events.py

@@ -1,9 +1,11 @@
+from django.http import QueryDict
 from rest_framework import status
 from rest_framework.viewsets import ViewSet
 from rest_framework.response import Response
 from api.views.v1.utils import (
     serialize_params,
-    handle_errors_decorator
+    handle_errors_decorator,
+    handle_path_error
 )
 from api.permissions import IsRegisteredAndConfirmed
 from api.services.opensearch.search import OpenSearchService
@@ -13,6 +15,8 @@
     import OpenSearchQueryDirector
 from api.serializers.v1.moderation_events_serializer \
     import ModerationEventsSerializer
+from api.serializers.v1.opensearch_common_validators.moderation_id_validator \
+    import ModerationIdValidator
 from api.views.v1.index_names import OpenSearchIndexNames
 
 
@@ -49,3 +53,23 @@ def list(self, request):
             query_body
         )
         return Response(response)
+
+    @handle_errors_decorator
+    def retrieve(self, _,  pk=None):
+        if not ModerationIdValidator.is_valid_uuid(pk):
+            return handle_path_error(
+                field="moderation_id",
+                message="Invalid UUID format.",
+                status_code=status.HTTP_400_BAD_REQUEST
+            )
+
+        query_params = QueryDict('', mutable=True)
+        query_params.update({'moderation_id': pk})
+        query_body = self.opensearch_query_director.build_query(
+            query_params
+        )
+        response = self.opensearch_service.search_index(
+            OpenSearchIndexNames.MODERATION_EVENTS_INDEX,
+            query_body
+        )
+        return Response(response)

src/django/api/views/v1/utils.py

@@ -1,3 +1,4 @@
+import uuid
 import logging
 from functools import wraps
 from rest_framework.response import Response
@@ -108,3 +109,18 @@ def _wrapped_view(self, request, *args, **kwargs):
         except OpenSearchServiceException as e:
             return handle_opensearch_exception(e)
     return _wrapped_view
+
+
+def handle_path_error(field, message, status_code):
+    return Response(
+        {
+            "message": "The request path parameter is invalid.",
+            "errors": [
+                {
+                    "field": field,
+                    "message": message
+                }
+            ]
+        },
+        status=status_code
+    )

src/django/oar/urls.py

@@ -102,6 +102,11 @@
         ProductionLocations.as_view({'get': 'retrieve'}),
         name='production-locations-details'
      ),
+     path(
+        'api/v1/moderation-events/<str:moderation_id>/',
+        ModerationEvents.as_view({'get': 'retrieve'}),
+        name='moderation-events-details'
+     ),
 ]
 
 schema_view = get_schema_view(

src/tests/v1/test_moderation_events.py

@@ -5,6 +5,26 @@
 
 class ModerationEventsTest(BaseAPITest):
 
+    def test_moderation_events_exact(self):
+        moderation_id_wrong = '0f35a90f-70a0-4c3e-8e06-2ed8e1fc6800'
+        response = requests.get(
+                f"{self.root_url}/api/v1/moderation-events/{moderation_id_wrong}",
+                headers=self.basic_headers,
+            )
+
+        result = response.json()
+        self.assertEqual(result['count'], 0)
+
+        moderation_id = '1f35a90f-70a0-4c3e-8e06-2ed8e1fc6800'
+        response = requests.get(
+                f"{self.root_url}/api/v1/moderation-events/{moderation_id}",
+                headers=self.basic_headers,
+            )
+
+        result = response.json()
+        self.assertEqual(result['count'], 1)
+        self.assertEqual(result['data'][0]['moderation_id'], moderation_id)
+
     def test_moderation_events_status(self):
         response = requests.get(
             f"{self.root_url}/api/v1/moderation-events/",