test: added additional tests

Author: JanssenBrm

tests/platforms/test_dispatcher.py

@@ -0,0 +1,63 @@
+from unittest.mock import patch
+
+import pytest
+
+import app.platforms.dispatcher as dispatcher
+from app.platforms.base import BaseProcessingPlatform
+from app.schemas import ProcessType, ProcessingJobSummary
+
+
+class DummyPlatform(BaseProcessingPlatform):
+    def execute_job(self, title: str, details: dict, parameters: dict) -> ProcessingJobSummary:
+        return ProcessingJobSummary(
+            id="dummy-job-id",
+            title=title,
+            status="created"
+        )
+
+
+@pytest.fixture(autouse=True)
+def clear_registry():
+    """Ensure PROCESSING_PLATFORMS is clean before each test."""
+    dispatcher.PROCESSING_PLATFORMS.clear()
+    yield
+    dispatcher.PROCESSING_PLATFORMS.clear()
+
+
+def test_register_processing_platform():
+    dispatcher.register_processing_platform(ProcessType.OPENEO, DummyPlatform)
+    assert dispatcher.PROCESSING_PLATFORMS[ProcessType.OPENEO] is DummyPlatform
+
+
+def test_get_processing_platform_success():
+    dispatcher.PROCESSING_PLATFORMS[ProcessType.OPENEO] = DummyPlatform
+    instance = dispatcher.get_processing_platform(ProcessType.OPENEO)
+    assert isinstance(instance, DummyPlatform)
+
+
+def test_get_processing_platform_unsupported():
+    with pytest.raises(ValueError, match="Unsupported service type"):
+        dispatcher.get_processing_platform(ProcessType.OPENEO)
+
+
+@patch("app.platforms.dispatcher.importlib.import_module")
+@patch("app.platforms.dispatcher.pkgutil.iter_modules")
+def test_load_processing_platforms(mock_iter_modules, mock_import_module):
+    # Simulate two modules found in the implementations package
+    mock_iter_modules.return_value = [
+        (None, "mod1", False),
+        (None, "mod2", False),
+    ]
+
+    dispatcher.load_processing_platforms()
+
+    mock_import_module.assert_any_call("app.platforms.implementations.mod1")
+    mock_import_module.assert_any_call("app.platforms.implementations.mod2")
+    assert mock_import_module.call_count == 2
+
+
+@patch("app.platforms.dispatcher.pkgutil.iter_modules")
+def test_load_processing_platforms_no_modules(mock_iter_modules):
+    mock_iter_modules.return_value = []
+    # Should not raise, just do nothing
+    dispatcher.load_processing_platforms()

tests/services/test_processing.py

@@ -0,0 +1,58 @@
+from unittest.mock import patch, MagicMock
+
+import pytest
+
+from app.schemas import BaseJobRequest, ProcessingJobSummary, ProcessType, ServiceDetails
+from app.services.processing import create_processing_job
+
+
+def make_job_request():
+    """Helper to build a valid job request."""
+    return BaseJobRequest(
+        label=ProcessType.OPENEO,
+        title="Test Job",
+        service= ServiceDetails(
+            service="dummy-service-id",
+            application="dummy-application"
+        ),
+        parameters={"param": 1}
+    )
+
+
+@patch("app.services.processing.get_processing_platform")
+def test_create_processing_job_calls_platform_execute(mock_get_platform):
+    
+    # Arrange
+    fake_summary = make_job_request()
+    fake_result = ProcessingJobSummary(
+        id="fake-job-id",
+        title=fake_summary.title,
+        status="created"
+    )
+
+    fake_platform = MagicMock()
+    fake_platform.execute_job.return_value = fake_result
+    mock_get_platform.return_value = fake_platform
+
+    # Act
+    result = create_processing_job(fake_summary)
+
+    # Assert
+    mock_get_platform.assert_called_once_with(fake_summary.label)
+    fake_platform.execute_job.assert_called_once_with(
+        title=fake_summary.title,
+        details=fake_summary.service,
+        parameters=fake_summary.parameters
+    )
+    assert result is fake_result
+    
+    
+@patch("app.services.processing.get_processing_platform")
+def test_create_processing_job_platform_raises(mock_get_platform):
+    # Arrange
+    fake_summary = make_job_request()
+    mock_get_platform.side_effect = ValueError("Unsupported platform")
+
+    # Act & Assert
+    with pytest.raises(ValueError, match="Unsupported platform"):
+        create_processing_job(fake_summary)