Requests costs to broker db (#201)

* pass request costs to broker db

* fix types

Author: mcucchi9

cads_processing_api_service/auth.py

@@ -267,7 +267,9 @@ def verify_if_disabled(disabled_reason: str | None, user_role: str | None) -> No
         return
 
 
-def verify_cost(request: dict[str, Any], adaptor_properties: dict[str, Any]) -> None:
+def verify_cost(
+    request: dict[str, Any], adaptor_properties: dict[str, Any]
+) -> dict[str, float] | None:
     """Verify if the cost of a process execution request is within the allowed limits.
 
     Parameters
@@ -281,6 +283,11 @@ def verify_cost(request: dict[str, Any], adaptor_properties: dict[str, Any]) ->
     ------
     exceptions.PermissionDenied
         Raised if the cost of the process execution request exceeds the allowed limits.
+
+    Returns
+    -------
+    dict[str, float] | None
+        Request costs.
     """
     costing_info = costing.compute_costing(request, adaptor_properties)
     max_costs_exceeded = costing_info.max_costs_exceeded
@@ -290,4 +297,4 @@ def verify_cost(request: dict[str, Any], adaptor_properties: dict[str, Any]) ->
             detail="Your request is too large, please reduce your selection.",
         )
     else:
-        return
+        return costing_info.costs

cads_processing_api_service/clients.py

@@ -231,7 +231,7 @@ def post_process_execution(
                 cads_adaptors.exceptions.InvalidRequest,
             ) as exc:
                 raise exceptions.InvalidRequest(detail=str(exc)) from exc
-        auth.verify_cost(request_inputs, adaptor_properties)
+        costs = auth.verify_cost(request_inputs, adaptor_properties)
         licences = adaptor.get_licences(request_inputs)
         auth.validate_licences(accepted_licences, licences)
         job_id = str(uuid.uuid4())
@@ -251,6 +251,7 @@ def post_process_execution(
                 process_id=process_id,
                 portal=dataset.portal,
                 qos_tags=dataset.qos_tags,
+                metadata={"costs": costs},
                 **job_kwargs,
             )
         dataset_messages = [