initial code to test action

meldingen_core/actions/melding.py

@@ -97,6 +97,27 @@ async def __call__(self, pk: int, values: dict[str, Any], token: str) -> T:
         return melding
 
 
+class MeldingAddLocationAction(Generic[T, T_co]):
+    _verify_token: TokenVerifier[T, T_co]
+    _repository: BaseMeldingRepository[T, T_co]
+
+    def __init__(
+        self,
+        repository: BaseMeldingRepository[T, T_co],
+        token_verifier: TokenVerifier[T, T_co],
+    ) -> None:
+        self._repository = repository
+        self._verify_token = token_verifier
+
+    async def __call__(self, melding_id: int, token: str, location: dict[str, Any]) -> T:
+        melding = await self._verify_token(melding_id, token)
+
+        melding.geo_location = location
+        await self._repository.save(melding)
+
+        return melding
+
+
 class BaseStateTransitionAction(Generic[T, T_co], metaclass=ABCMeta):
     _state_machine: BaseMeldingStateMachine[T]
     _repository: BaseMeldingRepository[T, T_co]

meldingen_core/location.py

@@ -0,0 +1,10 @@
+from typing import TypeVar
+from abc import ABCMeta, abstractmethod
+from meldingen_core.models import Melding
+
+T = TypeVar("T", bound=Melding)
+
+class MeldingLocationIngestor(metaclass=ABCMeta):
+
+    @abstractmethod
+    async def __call__(self, melding: Melding, geojson: dict) -> Melding: ...

meldingen_core/models.py

@@ -1,3 +1,4 @@
+from typing import Union
 from dataclasses import dataclass, field
 from datetime import datetime
 
@@ -18,6 +19,7 @@ class Melding:
     token: str | None = None
     token_expires: datetime | None = None
     attachments: list["Attachment"] = field(default_factory=list)
+    geo_location: Union[str, bytes] | None = None  # WKT or WKB
 
 
 @dataclass