[PT-5377] Support deep copy for auth (#635)

* Support deep copy in Up42Auth and finalize job query parameter names

* Bump version

CHANGELOG.md

@@ -29,6 +29,13 @@ You can check your current version with the following command:
     ```
 
 For more information, see [UP42 Python package description](https://pypi.org/project/up42-py/).
+## 1.0.4a21
+
+**Jun 17, 2024**
+
+- Support deep copy in `Up42Auth` to be compliant with pystac client.
+- Align processing job query parameter names.
+
 ## 1.0.4a20
 
 **Jun 17, 2024**

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "up42-py"
-version = "1.0.4a20"
+version = "1.0.4a21"
 description = "Python SDK for UP42, the geospatial marketplace and developer platform."
 authors = ["UP42 GmbH <[email protected]>"]
 license = "https://github.com/up42/up42-py/blob/master/LICENSE"

tests/http/test_oauth.py

@@ -1,3 +1,4 @@
+import copy
 import dataclasses
 import random
 import time
@@ -65,7 +66,6 @@ def test_should_fetch_token_when_created(self):
         up42_auth = oauth.Up42Auth(retrieve=retrieve, token_settings=token_settings)
         up42_auth(mock_request)
         assert mock_request.headers["Authorization"] == f"Bearer {TOKEN_VALUE}"
-        assert up42_auth.token.access_token == TOKEN_VALUE
         retrieve.assert_called_once()
         assert TOKEN_URL, HTTP_TIMEOUT == retrieve.call_args.args[1:]
 
@@ -77,10 +77,15 @@ def test_should_fetch_token_when_expired(self):
         up42_auth(mock_request)
 
         assert mock_request.headers["Authorization"] == f"Bearer {second_token}"
-        assert up42_auth.token.access_token == second_token
         assert TOKEN_URL, HTTP_TIMEOUT == retrieve.call_args.args[1:]
         assert retrieve.call_count == 2
 
+    def test_should_deepcopy_itself(self):
+        retrieve = mock.MagicMock(return_value=TOKEN_VALUE)
+        up42_auth = oauth.Up42Auth(retrieve=retrieve, token_settings=token_settings)
+        assert copy.deepcopy(up42_auth) == up42_auth
+        retrieve.assert_called_once()
+
 
 class TestDetectSettings:
     def test_should_detect_account_credentials(self):

tests/test_processing.py

@@ -377,9 +377,9 @@ def test_should_get_all_jobs(
     ):
         query_params: dict[str, Any] = {}
         if process_id:
-            query_params["processID"] = process_id
+            query_params["processId"] = process_id
         if workspace_id:
-            query_params["workspaceID"] = workspace_id
+            query_params["workspaceId"] = workspace_id
         if status:
             query_params["status"] = [entry.value for entry in status]
         if min_duration:

up42/http/oauth.py

@@ -64,7 +64,7 @@ def __init__(
         self._lock = threading.Lock()
 
     def __call__(self, request: requests.PreparedRequest) -> requests.PreparedRequest:
-        request.headers["Authorization"] = f"Bearer {self.token.access_token}"
+        request.headers["Authorization"] = f"Bearer {self._access_token}"
         return request
 
     def _fetch_token(self):
@@ -75,11 +75,17 @@ def _fetch_token(self):
         return Token(access_token=access_token, expires_on=expires_on)
 
     @property
-    def token(self) -> Token:
+    def _access_token(self) -> Token:
         with self._lock:
             if self._token.has_expired:
                 self._token = self._fetch_token()
-        return self._token
+        return self._token.access_token
+
+    def __deepcopy__(self, memo: dict):
+        # Pystac client deep copies the request modifier this class is used for.
+        # We return the same instance to share authentication settings between
+        # possible parallel calls to avoid multiple token generation.
+        return self
 
 
 def detect_settings(

up42/processing.py

@@ -156,8 +156,8 @@ def all(
         query_params = {
             key: str(value)
             for key, value in {
-                "workspaceID": workspace_id,
-                "processID": process_id,
+                "workspaceId": workspace_id,
+                "processId": process_id,
                 "status": [entry.value for entry in status] if status else None,
                 "minDuration": min_duration,
                 "maxDuration": max_duration,