feat(api): add new api endpoint for emergency

- Add new emergency api for.
- Attach latest field report.
- Add test case for emergency endpoint.

Author: sudip-khanal

api/drf_views.py

@@ -89,6 +89,7 @@
     Export,
     ExternalPartner,
     FieldReport,
+    KeyFigure,
     MainContact,
     Profile,
     Region,
@@ -122,6 +123,7 @@
     CountrySupportingPartnerSerializer,
     CountryTableauSerializer,
     DeploymentsByEventSerializer,
+    DetailEmergencySerializer,
     DetailEventSerializer,
     DisasterTypeSerializer,
     DistrictSerializer,
@@ -1544,11 +1546,12 @@ def get_queryset(self):
         return CountrySupportingPartner.objects.select_related("country")
 
 
-class EmergencyViewset(viewsets.ReadOnlyModelViewSet):
+class EmergencyViewset(ReadOnlyVisibilityViewset):
     queryset = Event.objects.all()
     lookup_field = "id"
     serializer_class = DetailEmergencySerializer
     filterset_class = EventFilter
+    visibility_model_class = Event
 
     def get_queryset(self):
         return (
@@ -1566,9 +1569,21 @@ def get_queryset(self):
                 Prefetch("contacts", queryset=EventContact.objects.all()),
             )
             .annotate(
+                first_field_report_id=Subquery(
+                    FieldReport.objects.filter(event=OuterRef("pk"))
+                    .order_by(
+                        "fr_num",
+                        "updated_at",
+                    )
+                    .values("id")[:1]
+                ),
                 latest_field_report_id=Subquery(
-                    FieldReport.objects.filter(event=OuterRef("pk")).order_by("-created_at").values("id")[:1]
+                    FieldReport.objects.filter(event=OuterRef("pk"))
+                    .order_by(
+                        "-fr_num",
+                        "-updated_at",
+                    )
+                    .values("id")[:1]
                 ),
-                appeal_id=Subquery(Appeal.objects.filter(event=OuterRef("pk")).order_by("-created_at").values("id")[:1]),
             )
         )

api/factories/event.py

@@ -12,6 +12,7 @@
     AppealHistory,
     AppealType,
     Event,
+    EventContact,
     EventFeaturedDocument,
     EventLink,
 )
@@ -133,3 +134,9 @@ class AppealHistoryFactory(factory.django.DjangoModelFactory):
 
     class Meta:
         model = AppealHistory
+
+
+class EventContactFactory(factory.django.DjangoModelFactory):
+
+    class Meta:
+        model = EventContact

api/serializers.py

@@ -2196,7 +2196,7 @@ def create_event(self, report):
             summary=report.description or "",
             disaster_start_date=report.start_date,
             auto_generated=True,
-            source=Event.EventSources.NEW_REPORT,
+            source=Event.EventSource.NEW_REPORT,
             visibility=report.visibility,
             **{TRANSLATOR_ORIGINAL_LANGUAGE_FIELD_NAME: django_get_language()},
         )
@@ -2601,3 +2601,53 @@ class CountrySupportingPartnerSerializer(serializers.ModelSerializer):
     class Meta:
         model = CountrySupportingPartner
         fields = "__all__"
+
+
+class DetailEmergencySerializer(serializers.ModelSerializer):
+    contacts = EventContactSerializer(many=True, read_only=True)
+    key_figures = KeyFigureSerializer(many=True, read_only=True)
+    countries = MiniCountrySerializer(many=True, read_only=True)
+    ifrc_severity_level_display = serializers.CharField(source="get_ifrc_severity_level_display", read_only=True)
+    visibility_display = serializers.CharField(source="get_visibility_display", read_only=True)
+    source_display = serializers.CharField(source="get_source_display", read_only=True)
+    # NOTE: Populated from Queryset using Annotate
+    first_field_report_id = serializers.IntegerField(read_only=True)
+    latest_field_report_id = serializers.IntegerField(read_only=True)
+
+    class Meta:
+        model = Event
+        fields = (
+            "name",
+            "dtype",
+            "countries",
+            "summary",
+            "disaster_start_date",
+            "auto_generated",
+            "source",
+            "source_display",
+            "key_figures",
+            "is_featured",
+            "is_featured_region",
+            "hide_attached_field_reports",
+            "hide_field_report_map",
+            "id",
+            "slug",
+            "ifrc_severity_level",
+            "ifrc_severity_level_display",
+            "ifrc_severity_level_update_date",
+            "parent_event",
+            "emergency_response_contact_email",
+            "visibility",
+            "visibility_display",
+            "contacts",
+            "num_injured",
+            "num_dead",
+            "num_missing",
+            "num_affected",
+            "num_displaced",
+            "created_at",
+            "updated_at",
+            "previous_update",
+            "first_field_report_id",
+            "latest_field_report_id",
+        )

api/test_views.py

@@ -1,6 +1,6 @@
 import re
 import uuid
-from datetime import timedelta
+from datetime import datetime, timedelta
 from unittest.mock import patch
 
 from django.contrib.auth.models import User
@@ -10,9 +10,11 @@
 from django.utils import timezone
 
 import api.models as models
+from api.factories.disaster_type import DisasterTypeFactory
 from api.factories.event import (
     AppealFactory,
     AppealType,
+    EventContactFactory,
     EventFactory,
     EventFeaturedDocumentFactory,
     EventLinkFactory,
@@ -1042,3 +1044,97 @@ def test_ifrc_user_sees_all(self):
                 ]
             ),
         )
+
+
+class EmergencyViewTestCase(APITestCase):
+    def setUp(self):
+        super().setUp()
+        self.disaster_type = DisasterTypeFactory.create(
+            name="Flood",
+        )
+
+        self.event1 = EventFactory.create(
+            dtype=self.disaster_type,
+            source=models.Event.EventSource.GDACS,
+            slug="test1",
+            parent_event=None,
+        )
+        self.contact = EventContactFactory.create(
+            event=self.event1,
+        )
+
+        self.field_report1 = FieldReportFactory.create(
+            event=self.event1,
+            created_at=timezone.make_aware(datetime(2024, 1, 1)),
+            updated_at=timezone.make_aware(datetime(2026, 1, 1)),
+            fr_num=50,
+        )
+
+        self.field_report2 = FieldReportFactory.create(
+            event=self.event1,
+            created_at=timezone.make_aware(datetime(2024, 1, 1)),
+            updated_at=timezone.make_aware(datetime(2025, 1, 1)),
+            fr_num=20,
+        )
+
+        self.event2 = EventFactory.create(
+            dtype=self.disaster_type,
+            source=models.Event.EventSource.WHO,
+            slug="test2",
+            parent_event=None,
+        )
+
+        self.event3 = EventFactory.create(
+            dtype=self.disaster_type,
+            source=models.Event.EventSource.APPEAL_ADMIN,
+            slug="test3",
+            parent_event=None,
+        )
+        self.appeal2 = AppealFactory.create(
+            event=self.event3,
+            dtype=self.disaster_type,
+            num_beneficiaries=9000,
+            amount_requested=10000,
+            amount_funded=1899999,
+        )
+
+        self.url = "/api/v2/emergency/"
+
+    def test_get_emergency_list(self):
+        response = self.client.get(self.url)
+        self.assert_200(response)
+        self.assertEqual(response.data["count"], 2)
+
+    def test_retrive_emergency_detail(self):
+        url = f"/api/v2/emergency/{self.event1.id}/"
+        response = self.client.get(url)
+        self.assert_200(response)
+        self.assertEqual(response.data["id"], self.event1.id)
+        self.assertEqual(response.data["slug"], self.event1.slug)
+        self.assertEqual(response.data["name"], self.event1.name)
+        self.assertEqual(response.data["source"], models.Event.EventSource.GDACS)
+
+        # first field report id check
+        self.assertEqual(response.data["first_field_report_id"], self.field_report2.id)
+        # latest check field report
+        self.assertEqual(response.data["latest_field_report_id"], self.field_report1.id)
+
+    # Filter Tests
+    def test_filter_by_source(self):
+        url = f"{self.url}?source=120"
+        response = self.client.get(url)
+        self.assert_200(response)
+        self.assertEqual(response.data["count"], 1)
+        self.assertEqual(response.data["results"][0]["source"], models.Event.EventSource.WHO)
+
+    def test_filter_by_appeal_source(self):
+        url = f"{self.url}?source=150"
+        response = self.client.get(url)
+        self.assert_200(response)
+        self.assertEqual(response.data["count"], 1)
+        self.assertEqual(response.data["results"][0]["source"], models.Event.EventSource.APPEAL_ADMIN)
+
+    def test_filter_by_source_no_match(self):
+        url = f"{self.url}?source=500"
+        response = self.client.get(url)
+        self.assert_400(response)

assets

@@ -88,6 +88,9 @@
 router.register(r"admin2", api_views.Admin2Viewset, basename="admin2")
 router.register(r"district", api_views.DistrictViewset, basename="district")
 router.register(r"district_rmd", api_views.DistrictRMDViewset, basename="district_rmd")
+
+router.register(r"emergency", api_views.EmergencyViewset, basename="emergency")
+
 router.register(r"domainwhitelist", registration_views.DomainWhitelistViewset)
 router.register(r"eru", deployment_views.ERUViewset, basename="eru")
 router.register(