Issue 105 deal with multiple locations

.gitignore

@@ -205,3 +205,5 @@ datastore_pb2.py
 datastore_pb2_grpc.py
 # Ignore all the copied protobuf directories, as the root contains the source of truth.
 **/protobuf
+# Ignore nvim styling files
+.stylua.toml

api/routers/edr.py

@@ -30,6 +30,7 @@
 from utilities import split_and_strip
 from utilities import validate_bbox
 from utilities import verify_parameter_names
+from utilities import calculate_largest_postition_deviation
 
 router = APIRouter(prefix="/collections/observations")
 
@@ -97,6 +98,7 @@ async def get_locations(
         platform_coordinates[obs.ts_mdata.platform].add(
             (obs.obs_mdata[-1].geo_point.lon, obs.obs_mdata[-1].geo_point.lat)
         )
+
         # Check for inconsistent parameter definitions between stations
         # TODO: How to handle those?
         if obs.ts_mdata.parameter_name in all_parameters and all_parameters[obs.ts_mdata.parameter_name] != parameter:
@@ -112,13 +114,23 @@ async def get_locations(
     # Check for multiple coordinates or names on one station
     for station_id in platform_parameters.keys():
         if len(platform_coordinates[station_id]) > 1:
-            raise HTTPException(
-                status_code=500,
-                detail={
-                    "coordinates": f"Station with id `{station_id} "
-                    f"has multiple coordinates: {platform_coordinates[station_id]}"
-                },
-            )
+            if (
+                calculate_largest_postition_deviation(platform_coordinates[station_id]) < 1e-4
+            ):  # all coordinates are within 1e-4 degrees (roughly 10 m)
+                platform_coordinates[station_id] = {
+                    sorted(
+                        [i for i in platform_coordinates[station_id]],
+                        key=lambda x: (len(str(x[0])), len(str(x[1])), x[0], x[1]),
+                    )[-1]
+                }
+            else:
+                raise HTTPException(
+                    status_code=500,
+                    detail={
+                        "coordinates": f"Station with id `{station_id} "
+                        f"has multiple coordinates: {platform_coordinates[station_id]}"
+                    },
+                )
         if len(platform_names[station_id]) > 1:
             raise HTTPException(
                 status_code=500,

api/utilities.py

@@ -1,6 +1,7 @@
 from datetime import datetime
 from datetime import timedelta
 from typing import Tuple
+from itertools import combinations
 
 import datastore_pb2 as dstore
 from fastapi import HTTPException
@@ -10,7 +11,9 @@
 from pydantic import TypeAdapter
 
 
-def get_datetime_range(datetime_string: str | None) -> Tuple[Timestamp, Timestamp] | None:
+def get_datetime_range(
+    datetime_string: str | None,
+) -> Tuple[Timestamp, Timestamp] | None:
     if not datetime_string:
         return None
 
@@ -121,3 +124,11 @@ def validate_bbox(bbox: str) -> Tuple[float, float, float, float]:
         raise HTTPException(status_code=400, detail=errors)
 
     return left, bottom, right, top
+
+
+def calculate_largest_postition_deviation(positions: list) -> float:
+    largest_deviation = 0
+    for i, j in combinations(positions, 2):
+        if (dist := ((i[0] - j[0]) ** 2) + ((i[1] - j[1]) ** 2) ** 0.5) > largest_deviation:
+            largest_deviation = dist
+    return largest_deviation

setup.cfg

@@ -2,3 +2,8 @@
 ignore = E221,E226,E228,E241,W503
 max-line-length = 120
 exclude = ingest/src/esoh/*pb2*.py
+[isort]
+profile = black
+[black]
+line-length = 120
+exclude = *pb2*.py