Merge pull request #194 from ecmwf-projects/COPDS-1842-anonymous-licences

Let anonymous user submit jobs but return disclaimer

Author: mcucchi9

cads_processing_api_service/clients.py

@@ -204,7 +204,6 @@ def post_process_execution(
         """
         user_uid, user_role = auth.authenticate_user(auth_header, portal_header)
         structlog.contextvars.bind_contextvars(user_uid=user_uid)
-        accepted_licences = auth.get_accepted_licences(auth_header)
         request = execution_content.model_dump()
         catalogue_sessionmaker = db_utils.get_catalogue_sessionmaker(
             db_utils.ConnectionMode.read
@@ -233,7 +232,16 @@ def post_process_execution(
                 raise exceptions.InvalidRequest(detail=str(exc)) from exc
         costs = auth.verify_cost(request_inputs, adaptor_properties)
         licences = adaptor.get_licences(request_inputs)
-        auth.validate_licences(accepted_licences, licences)
+        if user_uid != "anonymous":
+            accepted_licences = auth.get_accepted_licences(auth_header)
+            auth.validate_licences(accepted_licences, licences)
+            job_message = None
+        else:
+            job_message = config.ensure_settings().anonymous_licences_message.format(
+                licences="; ".join(
+                    [f"{licence[0]} (rev: {licence[1]})" for licence in licences]
+                )
+            )
         job_id = str(uuid.uuid4())
         structlog.contextvars.bind_contextvars(job_id=job_id)
         job_kwargs = adaptors.make_system_job_kwargs(
@@ -265,6 +273,7 @@ def post_process_execution(
         status_info = utils.make_status_info(
             job, dataset_metadata={"messages": dataset_messages}
         )
+        status_info.message = job_message
         return status_info
 
     def get_jobs(

cads_processing_api_service/config.py

@@ -28,6 +28,12 @@
 client.retrieve(dataset, request).download()
 """
 
+ANONYMOUS_LICENCES_MESSAGE = (
+    "The job has been submitted as an anonymous user. "
+    "Please consider the following licences implicitly accepted: "
+    "{licences}"
+)
+
 general_settings = None
 
 
@@ -50,6 +56,7 @@ class Settings(pydantic_settings.BaseSettings):
 
     api_request_template: str = API_REQUEST_TEMPLATE
     missing_dataset_title: str = "Dataset not available"
+    anonymous_licences_message: str = ANONYMOUS_LICENCES_MESSAGE
 
     @property
     def profiles_api_url(self) -> str: