Feat/alert system

alert_system/admin.py

@@ -0,0 +1,52 @@
+from django.contrib import admin
+
+from .models import 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",
+    )

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/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