Merge pull request #76 from Vidushi2709/feature/unit-tests

feat: Add comprehensive unit tests

Author: fedjo

pytest.ini

@@ -0,0 +1,51 @@
+[pytest]
+# Pytest configuration for OpenAgri-WeatherService
+
+# Test discovery patterns
+python_files = test_*.py
+python_classes = Test*
+python_functions = test_*
+
+# Test paths
+testpaths = tests
+
+# Asyncio configuration
+asyncio_mode = auto
+
+# Output options
+addopts = 
+    -v
+    --strict-markers
+    --tb=short
+    --cov=src
+    --cov-report=term-missing
+    --cov-report=html
+    --cov-report=xml
+    -p no:warnings
+
+# Markers
+markers =
+    unit: Unit tests
+    integration: Integration tests
+    slow: Slow running tests
+    anyio: Async tests using anyio
+
+# Coverage options
+[coverage:run]
+source = src
+omit = 
+    */tests/*
+    */venv/*
+    */__pycache__/*
+    */site-packages/*
+
+[coverage:report]
+exclude_lines =
+    pragma: no cover
+    def __repr__
+    raise AssertionError
+    raise NotImplementedError
+    if __name__ == .__main__.:
+    if TYPE_CHECKING:
+    @abstractmethod
+

requirements-test.txt

@@ -0,0 +1,6 @@
+pytest==8.3.3
+pytest-asyncio==0.24.0
+pytest-cov==5.0.0
+httpx==0.27.0
+mongomock-motor==0.0.34
+

src/external_services/interoperability.py

@@ -155,7 +155,8 @@ def predictions_to_jsonld(cls, predictions: List[Prediction], spatial_entity: Po
                 collection_schema["hasFeatureOfInterest"]["long"] = spatial_entity.location.coordinates[1]
 
                 for p in preds:
-                    item_prefix = f"weather:forecast:{property_schema[p.measurement_type]["measurement"].lower()}"
+                    measurement_name = property_schema[p.measurement_type]["measurement"].lower()
+                    item_prefix = f"weather:forecast:{measurement_name}"
                     item_schema = utils.deepcopy_dict(cls.item_schema)
                     item_schema["@id"] = utils.generate_uuid(item_prefix, p.id)
                     item_schema["observedProperty"] = f"cf:{p.measurement_type}"

src/utils.py

@@ -116,7 +116,9 @@ def load_class(classpath):
 def load_classes(pathname, base_classes):
     classes = []
     for path in glob.glob(pathname, recursive=True):
-        module = import_module(os.path.splitext(path)[0].strip('./').replace('/', '.'))
+        # Handle both Windows and Unix path separators
+        module_path = os.path.splitext(path)[0].strip('./').replace('/', '.').replace('\\', '.')
+        module = import_module(module_path)
         for _, obj in inspect.getmembers(module):
             if inspect.isclass(obj) and obj not in base_classes and issubclass(obj, base_classes):
                 classes.append(obj)

tests/conftest.py

@@ -0,0 +1,21 @@
+"""
+Pytest configuration and shared fixtures for all tests.
+This file is automatically loaded by pytest.
+"""
+
+import pytest
+
+
+# Configure pytest-asyncio
+@pytest.fixture
+def anyio_backend():
+    """Configure anyio backend for async tests"""
+    return "asyncio"
+
+
+# Configuration for pytest markers
+def pytest_configure(config):
+    """Configure custom pytest markers"""
+    config.addinivalue_line("markers", "integration: mark test as integration test")
+    config.addinivalue_line("markers", "unit: mark test as unit test")
+    config.addinivalue_line("markers", "slow: mark test as slow running")

tests/core/test_models.py

@@ -1,11 +1,11 @@
 import pytest
-
-from tests.fixtures import *
 from pydantic import ValidationError
 
 from src.models.point import Point
 from src.models.prediction import Prediction
 from src.models.weather_data import WeatherData
+from tests.fixtures import *
+
 
 class TestModels:
 
@@ -14,10 +14,7 @@ async def test_point_model_valid(self, app):
         valid_point = {
             "title": "Point title",
             "type": "field",
-            "location": {
-                "type": "Point",
-                "coordinates": [55.43989, 43.121]
-            }
+            "location": {"type": "Point", "coordinates": [55.43989, 43.121]},
         }
         point = Point(**valid_point)
         assert point.title == "Point title"
@@ -28,49 +25,40 @@ async def test_point_model_invalid_point_type(self, app):
         invalid_point = {
             "title": "Point title",
             "type": "lala",
-            "location": {
-                "type": "Point",
-                "coordinates": [55.43989, 43.121]
-            }
+            "location": {"type": "Point", "coordinates": [55.43989, 43.121]},
         }
         with pytest.raises(ValidationError):
             Point(**invalid_point)
 
     @pytest.mark.anyio
     async def test_prediction_model_valid(self, app):
         valid_prediction = {
-                "value": 32.3,
-                "timestamp": "2024-06-21T15:00:00.000Z",
-                "source": "openweathermaps",
-                "data_type": "weather",
-                "measurement_type": "ambient_temperature",
-                "spatial_entity": {
-                    "id": "bad6cd67-638f-42d8-82b8-d4d191174dd6",
-                    "type": "POI",
-                    "location": {
-                        "type": "Point",
-                        "coordinates": [ 39.1436, 26.40518]
-                    },
-                },
-            }
+            "value": 32.3,
+            "timestamp": "2024-06-21T15:00:00.000Z",
+            "source": "openweathermaps",
+            "data_type": "weather",
+            "measurement_type": "ambient_temperature",
+            "spatial_entity": {
+                "id": "bad6cd67-638f-42d8-82b8-d4d191174dd6",
+                "type": "POI",
+                "location": {"type": "Point", "coordinates": [39.1436, 26.40518]},
+            },
+        }
         prediction = Prediction(**valid_prediction)
         assert prediction.spatial_entity.location.type == "Point"
-        assert hasattr(prediction, 'created_at')
+        assert hasattr(prediction, "created_at")
         assert prediction.value == 32.3
 
     @pytest.mark.anyio
     async def test_weatherdata_model_valid(self, app):
         valid_weeatherdata = {
-                "spatial_entity": {
-                    "id": "0b1b7964-8f89-465c-a8b2-3d50a53459e0",
-                    "type": "POI",
-                    "location": {
-                        "type": "Point",
-                        "coordinates": [ 39.1436, 26.40518]
-                    },
-                },
-                "data": {}
-            }
+            "spatial_entity": {
+                "id": "0b1b7964-8f89-465c-a8b2-3d50a53459e0",
+                "type": "POI",
+                "location": {"type": "Point", "coordinates": [39.1436, 26.40518]},
+            },
+            "data": {},
+        }
         weatherdata = WeatherData(**valid_weeatherdata)
         assert weatherdata.spatial_entity.location.coordinates == [39.1436, 26.40518]
         assert weatherdata.spatial_entity.location.type == "Point"
@@ -79,16 +67,12 @@ async def test_weatherdata_model_valid(self, app):
     @pytest.mark.anyio
     async def test_weatherdata_model_not_valid_point_type(self, app):
         valid_weeatherdata = {
-                "spatial_entity": {
-                    "id": "0b1b7964-8f89-465c-a8b2-3d50a53459e0",
-                    "type": "routa",
-                    "location": {
-                        "type": "Point",
-                        "coordinates": [ 39.1436, 26.40518]
-                    },
-                },
-                "data": {}
-            }
+            "spatial_entity": {
+                "id": "0b1b7964-8f89-465c-a8b2-3d50a53459e0",
+                "type": "routa",
+                "location": {"type": "Point", "coordinates": [39.1436, 26.40518]},
+            },
+            "data": {},
+        }
         with pytest.raises(ValidationError):
             WeatherData(**valid_weeatherdata)
-

tests/core/test_routes.py

@@ -1,7 +1,7 @@
 import pytest
-from tests.fixtures import *
 
 from src.utils import calculate_thi
+from tests.fixtures import *
 
 
 class TestUtils: