test: added missing test for processing service

Author: JanssenBrm

tests/conftest.py

@@ -13,6 +13,7 @@
 from app.database.models.upscaling_task import UpscalingTaskRecord
 from app.main import app
 from app.schemas.enum import OutputFormatEnum, ProcessingStatusEnum, ProcessTypeEnum
+from app.schemas.parameters import ParamRequest, ParamTypeEnum, Parameter
 from app.schemas.unit_job import (
     BaseJobRequest,
     ProcessingJob,
@@ -198,3 +199,28 @@ def fake_sync_response():
         media_type="application/json",
         status_code=200,
     )
+
+
+@pytest.fixture
+def fake_param_request():
+    return ParamRequest(
+        label=ProcessTypeEnum.OPENEO,
+        service=ServiceDetails(endpoint="foo", application="bar"),
+    )
+
+@pytest.fixture
+def fake_parameter_result():
+    return [
+        Parameter(
+            name="spatial_extent",
+            type=ParamTypeEnum.BOUNDING_BOX,
+            optional=True,
+            description="Spatial extent parameter",
+        ),
+        Parameter(
+            name="temporal_extent",
+            type=ParamTypeEnum.DATE_INTERVAL,
+            optional=True,
+            description="Temporal extent parameter",
+        ),
+    ]

tests/platforms/test_dispatcher.py

@@ -9,7 +9,7 @@
 
 from stac_pydantic import Collection
 
-from tests.conftest import fake_sync_response
+from tests.conftest import fake_parameter_result, fake_sync_response
 
 
 class DummyPlatform(BaseProcessingPlatform):
@@ -30,6 +30,9 @@ def get_job_status(self, job_id, details):
 
     def get_job_results(self, job_id, details):
         return self.fake_result
+    
+    def get_service_parameters(self, user_token, details):
+        return fake_parameter_result()
 
 
 @pytest.fixture(autouse=True)

tests/services/test_processing.py

@@ -18,6 +18,7 @@
     get_job_status,
     get_processing_job_by_user_id,
     get_processing_jobs_by_user_id,
+    retrieve_service_parameters,
 )
 
 
@@ -534,3 +535,23 @@ async def test_create_sync_job_calls_platform_execute_failure(
         parameters=fake_processing_job_request.parameters,
         format=fake_processing_job_request.format,
     )
+
+
+@pytest.mark.asyncio
+@patch("app.services.processing.get_processing_platform")
+async def test_retrieve_service_parameters_success(
+    mock_get_platform, fake_parameter_result, fake_param_request
+):
+
+    fake_platform = MagicMock()
+    fake_platform.get_service_parameters = AsyncMock(return_value=fake_parameter_result)
+    mock_get_platform.return_value = fake_platform
+
+    result = await retrieve_service_parameters("foobar-token", fake_param_request)
+
+    mock_get_platform.assert_called_once_with(fake_param_request.label)
+    fake_platform.get_service_parameters.assert_called_once_with(
+        user_token="foobar-token",
+        details=fake_param_request.service,
+    )
+    assert result == fake_parameter_result