Alert-system: Email setup

alert_system/admin.py

@@ -0,0 +1,94 @@
+from django.contrib import admin
+
+from .models import AlertEmailLog, AlertEmailThread, Connector, ExtractionItem, LoadItem
+
+
+@admin.register(Connector)
+class ConnectorAdmin(admin.ModelAdmin):
+    list_display = ("id", "type", "last_success_run", "status")
+    readonly_fields = ("last_success_run",)
+
+
+@admin.register(ExtractionItem)
+class EventAdmin(admin.ModelAdmin):
+    list_display = (
+        "stac_id",
+        "created_at",
+        "collection",
+        "correlation_id",
+    )
+    list_filter = ("connector", "collection")
+    readonly_fields = ("connector",)
+    search_fields = (
+        "stac_id",
+        "correlation_id",
+    )
+
+
+@admin.register(LoadItem)
+class LoadItemAdmin(admin.ModelAdmin):
+    list_display = (
+        "id",
+        "event_title",
+        "created_at",
+        "correlation_id",
+        "item_eligible",
+        "is_past_event",
+    )
+    list_filter = (
+        "connector",
+        "item_eligible",
+        "is_past_event",
+    )
+    readonly_fields = (
+        "connector",
+        "item_eligible",
+        "related_montandon_events",
+        "related_go_events",
+    )
+    search_fields = (
+        "id",
+        "correlation_id",
+    )
+
+
+@admin.register(AlertEmailThread)
+class AlertEmailThreadAdmin(admin.ModelAdmin):
+    list_display = (
+        "user",
+        "correlation_id",
+        "root_email_message_id",
+    )
+    search_fields = (
+        "correlation_id",
+        "root_email_message_id",
+        "user__username",
+    )
+    list_select_related = ("user",)
+    autocomplete_fields = ("user",)
+
+
+@admin.register(AlertEmailLog)
+class AlertEmailLogAdmin(admin.ModelAdmin):
+    list_display = (
+        "id",
+        "message_id",
+        "status",
+    )
+    list_select_related = (
+        "user",
+        "subscription",
+        "item",
+        "thread",
+    )
+    search_fields = (
+        "user__username",
+        "message_id",
+    )
+    autocomplete_fields = (
+        "user",
+        "subscription",
+        "item",
+        "thread",
+    )
+    list_filter = ("status",)

alert_system/apps.py

@@ -0,0 +1,6 @@
+from django.apps import AppConfig
+
+
+class AlertSystemConfig(AppConfig):
+    default_auto_field = "django.db.models.BigAutoField"
+    name = "alert_system"

alert_system/dev_views.py

@@ -0,0 +1,75 @@
+from django.http import HttpResponse
+from django.template import loader
+from rest_framework import permissions
+from rest_framework.views import APIView
+
+
+class AlertEmailPreview(APIView):
+    permission_classes = [permissions.IsAuthenticated]
+
+    def get(self, request):
+        type_param = request.GET.get("type")
+
+        template_map = {
+            "alert": "email/alert_system/alert_notification.html",
+            "alert_reply": "email/alert_system/alert_notification_reply.html",
+        }
+
+        if type_param not in template_map:
+            valid_values = ", ".join(template_map.keys())
+            return HttpResponse(
+                f"Invalid 'type' parameter. Please use one of the following values: {valid_values}.",
+            )
+        context_map = {
+            "alert": {
+                "user_name": "Test User",
+                "event_title": "Test Title",
+                "event_description": "This is a test description for the alert email.",
+                "start_datetime": "2025-11-28 01:00:00",
+                "end_datetime": "2025-11-28 01:00:00",
+                "country_name": [
+                    "Nepal",
+                ],
+                "total_people_exposed": 1200,
+                "total_buildings_exposed": 150,
+                "hazard_types": "Flood",
+                "related_montandon_events": [
+                    {
+                        "event_title": "Related Event 1",
+                        "total_people_exposed": 100,
+                        "total_buildings_exposed": 300,
+                        "start_datetime": "2025-11-28 01:00:00",
+                        "end_datetime": "2025-11-28 01:00:00",
+                    },
+                    {
+                        "event_title": "Related Event 2",
+                        "total_people_exposed": 200,
+                        "total_buildings_exposed": 500,
+                        "start_datetime": "2025-11-28 01:00:00",
+                        "end_datetime": "2025-11-28 01:00:00",
+                    },
+                ],
+                "related_go_events": [
+                    "go-event-uuid-1",
+                    "go-event-uuid-2",
+                ],
+            },
+            "alert_reply": {
+                "event_title": "Test Title",
+                "event_description": "This is a test description for the alert email.",
+                "start_datetime": "2025-11-28 01:00:00",
+                "end_datetime": "2025-11-28 01:00:00",
+                "country_name": [
+                    "Nepal",
+                ],
+                "total_people_exposed": 1200,
+                "total_buildings_exposed": 150,
+            },
+        }
+
+        context = context_map.get(type_param)
+        if context is None:
+            return HttpResponse("No context found for the email preview.")
+        template_file = template_map[type_param]
+        template = loader.get_template(template_file)
+        return HttpResponse(template.render(context, request))

alert_system/etl/base/config.py

@@ -0,0 +1,13 @@
+from typing import Dict, TypedDict
+
+
+class ExtractionConfig(TypedDict):
+    event_collection_type: str
+    hazard_collection_type: str | None
+    impact_collection_type: str | None
+
+    filter_event: Dict | None
+    filter_hazard: Dict | None
+    filter_impact: Dict | None
+
+    people_exposed_threshold: int