feat: Pilot can exchange against a token a secret

Squashed commits:
[b21fd04] fix: Fixed documentation, and code in general
[962c6a4] fix: Removing os endpoints
[6396990] test: Improving pilot auth tests
[5c14e7d] fix: Samll fixes with the debug endpoints
[88ac74e] fix: Moving pilot auth to auth endpoint, and fixes
[b39eff3] fix: Removed garbage code, and improving tests
[b572e22] fix: Added get_pilot_by_id
[90acb3b] feat: Adding pilot secret creation
[2404324] feat: Pilot can exchange against nothing a secret

Author: Robin-Van-de-Merghel

diracx-client/src/diracx/client/generated/_client.py

@@ -19,6 +19,7 @@
     AuthOperations,
     ConfigOperations,
     JobsOperations,
+    PilotsOperations,
     WellKnownOperations,
 )
 
@@ -34,6 +35,8 @@ class Dirac:  # pylint: disable=client-accepts-api-version-keyword
     :vartype config: generated.operations.ConfigOperations
     :ivar jobs: JobsOperations operations
     :vartype jobs: generated.operations.JobsOperations
+    :ivar pilots: PilotsOperations operations
+    :vartype pilots: generated.operations.PilotsOperations
     :keyword endpoint: Service URL. Required. Default value is "".
     :paramtype endpoint: str
     """
@@ -85,6 +88,9 @@ def __init__(  # pylint: disable=missing-client-constructor-parameter-credential
         self.jobs = JobsOperations(
             self._client, self._config, self._serialize, self._deserialize
         )
+        self.pilots = PilotsOperations(
+            self._client, self._config, self._serialize, self._deserialize
+        )
 
     def send_request(
         self, request: HttpRequest, *, stream: bool = False, **kwargs: Any

diracx-client/src/diracx/client/generated/aio/_client.py

@@ -19,6 +19,7 @@
     AuthOperations,
     ConfigOperations,
     JobsOperations,
+    PilotsOperations,
     WellKnownOperations,
 )
 
@@ -34,6 +35,8 @@ class Dirac:  # pylint: disable=client-accepts-api-version-keyword
     :vartype config: generated.aio.operations.ConfigOperations
     :ivar jobs: JobsOperations operations
     :vartype jobs: generated.aio.operations.JobsOperations
+    :ivar pilots: PilotsOperations operations
+    :vartype pilots: generated.aio.operations.PilotsOperations
     :keyword endpoint: Service URL. Required. Default value is "".
     :paramtype endpoint: str
     """
@@ -85,6 +88,9 @@ def __init__(  # pylint: disable=missing-client-constructor-parameter-credential
         self.jobs = JobsOperations(
             self._client, self._config, self._serialize, self._deserialize
         )
+        self.pilots = PilotsOperations(
+            self._client, self._config, self._serialize, self._deserialize
+        )
 
     def send_request(
         self, request: HttpRequest, *, stream: bool = False, **kwargs: Any

diracx-client/src/diracx/client/generated/aio/operations/__init__.py

@@ -14,6 +14,7 @@
 from ._operations import AuthOperations  # type: ignore
 from ._operations import ConfigOperations  # type: ignore
 from ._operations import JobsOperations  # type: ignore
+from ._operations import PilotsOperations  # type: ignore
 
 from ._patch import __all__ as _patch_all
 from ._patch import *
@@ -24,6 +25,7 @@
     "AuthOperations",
     "ConfigOperations",
     "JobsOperations",
+    "PilotsOperations",
 ]
 __all__.extend([p for p in _patch_all if p not in __all__])  # pyright: ignore
 _patch_sdk()

diracx-client/src/diracx/client/generated/aio/operations/_operations.py

@@ -33,6 +33,7 @@
     build_auth_get_refresh_tokens_request,
     build_auth_initiate_authorization_flow_request,
     build_auth_initiate_device_flow_request,
+    build_auth_pilot_login_request,
     build_auth_revoke_refresh_token_request,
     build_auth_userinfo_request,
     build_config_serve_config_request,
@@ -50,6 +51,7 @@
     build_jobs_summary_request,
     build_jobs_unassign_bulk_jobs_sandboxes_request,
     build_jobs_unassign_job_sandboxes_request,
+    build_pilots_get_pilot_info_request,
     build_well_known_get_installation_metadata_request,
     build_well_known_get_openid_configuration_request,
 )
@@ -823,6 +825,65 @@ async def complete_authorization_flow(
 
         return deserialized  # type: ignore
 
+    @distributed_trace_async
+    async def pilot_login(
+        self, *, pilot_id: int, pilot_secret: str, **kwargs: Any
+    ) -> Any:
+        """Pilot Login.
+
+        Endpoint without policy, the pilot uses only its secret.
+
+        :keyword pilot_id: Required.
+        :paramtype pilot_id: int
+        :keyword pilot_secret: Required.
+        :paramtype pilot_secret: str
+        :return: any
+        :rtype: any
+        :raises ~azure.core.exceptions.HttpResponseError:
+        """
+        error_map: MutableMapping = {
+            401: ClientAuthenticationError,
+            404: ResourceNotFoundError,
+            409: ResourceExistsError,
+            304: ResourceNotModifiedError,
+        }
+        error_map.update(kwargs.pop("error_map", {}) or {})
+
+        _headers = kwargs.pop("headers", {}) or {}
+        _params = kwargs.pop("params", {}) or {}
+
+        cls: ClsType[Any] = kwargs.pop("cls", None)
+
+        _request = build_auth_pilot_login_request(
+            pilot_id=pilot_id,
+            pilot_secret=pilot_secret,
+            headers=_headers,
+            params=_params,
+        )
+        _request.url = self._client.format_url(_request.url)
+
+        _stream = False
+        pipeline_response: PipelineResponse = (
+            await self._client._pipeline.run(  # pylint: disable=protected-access
+                _request, stream=_stream, **kwargs
+            )
+        )
+
+        response = pipeline_response.http_response
+
+        if response.status_code not in [200]:
+            map_error(
+                status_code=response.status_code, response=response, error_map=error_map
+            )
+            raise HttpResponseError(response=response)
+
+        deserialized = self._deserialize("object", pipeline_response.http_response)
+
+        if cls:
+            return cls(pipeline_response, deserialized, {})  # type: ignore
+
+        return deserialized  # type: ignore
+
 
 class ConfigOperations:
     """
@@ -2156,3 +2217,82 @@ async def submit_jdl_jobs(
             return cls(pipeline_response, deserialized, {})  # type: ignore
 
         return deserialized  # type: ignore
+
+
+class PilotsOperations:
+    """
+    .. warning::
+        **DO NOT** instantiate this class directly.
+
+        Instead, you should access the following operations through
+        :class:`~generated.aio.Dirac`'s
+        :attr:`pilots` attribute.
+    """
+
+    models = _models
+
+    def __init__(self, *args, **kwargs) -> None:
+        input_args = list(args)
+        self._client: AsyncPipelineClient = (
+            input_args.pop(0) if input_args else kwargs.pop("client")
+        )
+        self._config: DiracConfiguration = (
+            input_args.pop(0) if input_args else kwargs.pop("config")
+        )
+        self._serialize: Serializer = (
+            input_args.pop(0) if input_args else kwargs.pop("serializer")
+        )
+        self._deserialize: Deserializer = (
+            input_args.pop(0) if input_args else kwargs.pop("deserializer")
+        )
+
+    @distributed_trace_async
+    async def get_pilot_info(self, **kwargs: Any) -> Any:
+        """Get Pilot Info.
+
+        Get Pilot Info.
+
+        :return: any
+        :rtype: any
+        :raises ~azure.core.exceptions.HttpResponseError:
+        """
+        error_map: MutableMapping = {
+            401: ClientAuthenticationError,
+            404: ResourceNotFoundError,
+            409: ResourceExistsError,
+            304: ResourceNotModifiedError,
+        }
+        error_map.update(kwargs.pop("error_map", {}) or {})
+
+        _headers = kwargs.pop("headers", {}) or {}
+        _params = kwargs.pop("params", {}) or {}
+
+        cls: ClsType[Any] = kwargs.pop("cls", None)
+
+        _request = build_pilots_get_pilot_info_request(
+            headers=_headers,
+            params=_params,
+        )
+        _request.url = self._client.format_url(_request.url)
+
+        _stream = False
+        pipeline_response: PipelineResponse = (
+            await self._client._pipeline.run(  # pylint: disable=protected-access
+                _request, stream=_stream, **kwargs
+            )
+        )
+
+        response = pipeline_response.http_response
+
+        if response.status_code not in [200]:
+            map_error(
+                status_code=response.status_code, response=response, error_map=error_map
+            )
+            raise HttpResponseError(response=response)
+
+        deserialized = self._deserialize("object", pipeline_response.http_response)
+
+        if cls:
+            return cls(pipeline_response, deserialized, {})  # type: ignore
+
+        return deserialized  # type: ignore

diracx-client/src/diracx/client/generated/operations/__init__.py

@@ -14,6 +14,7 @@
 from ._operations import AuthOperations  # type: ignore
 from ._operations import ConfigOperations  # type: ignore
 from ._operations import JobsOperations  # type: ignore
+from ._operations import PilotsOperations  # type: ignore
 
 from ._patch import __all__ as _patch_all
 from ._patch import *
@@ -24,6 +25,7 @@
     "AuthOperations",
     "ConfigOperations",
     "JobsOperations",
+    "PilotsOperations",
 ]
 __all__.extend([p for p in _patch_all if p not in __all__])  # pyright: ignore
 _patch_sdk()