refactor(managed-data): switch to new nucleus_api_route

src/config/__init__.py

@@ -8,14 +8,21 @@
 from ..exceptions import DeepOriginException
 
 CONFIG_DIR = pathlib.Path(__file__).parent
+CONFIG_YML_LOCATION = os.path.expanduser(
+    os.path.join(
+        "~",
+        ".deep-origin",
+        "config.yml",
+    )
+)
 
 __all__ = ["get_value"]
 
 
 @functools.cache
 def get_value(
     user_config_filenames: collections.abc.Iterable[str] = (
-        os.path.expanduser(os.path.join("~", ".deep-origin", "config.yml")),
+        CONFIG_YML_LOCATION,
         os.path.join(".deep-origin", "config.yml"),
     ),
 ) -> confuse.templates.AttrDict:
@@ -47,8 +54,9 @@ def get_value(
         "organization_id": confuse.String(),
         "bench_id": confuse.String(),
         "env": confuse.String(),
-        "nucleus_api_endpoint": confuse.String(),
-        "api_endpoint": confuse.String(),
+        "api_endpoint": confuse.Optional(confuse.String()),
+        "nucleus_api_route": confuse.String(),
+        "graphql_api_route": confuse.String(),
         "auth_domain": confuse.String(),
         "auth_device_code_endpoint": confuse.String(),
         "auth_token_endpoint": confuse.String(),

src/config/default.yml

@@ -2,10 +2,11 @@ env: local
 organization_id: null
 bench_id: null
 api_endpoint: null
-nucleus_api_endpoint: null
+nucleus_api_route: nucleus-api/api/
+graphql_api_route: api/graphql/
 auth_domain: null
-auth_device_code_endpoint: /oauth/device/code
-auth_token_endpoint: /oauth/token
+auth_device_code_endpoint: oauth/device/code/
+auth_token_endpoint: oauth/token/
 auth_audience: null
 auth_grant_type: urn:ietf:params:oauth:grant-type:device_code
 auth_client_id: null

src/do_api.py

@@ -31,7 +31,6 @@ def get_do_api_tokens() -> tuple[str, str]:
     config = get_config()
 
     if os.path.isfile(config.api_tokens_filename):
-        print(f"file exists @ {config.api_tokens_filename}")
         tokens = read_cached_do_api_tokens()
         refresh_token = tokens["refresh"]
 

src/managed_data/_api.py

@@ -9,9 +9,10 @@
 from deeporigin import cache_do_api_tokens, get_do_api_tokens
 from deeporigin.config import get_value
 from deeporigin.exceptions import DeepOriginException
+from deeporigin.utils import _nucleus_url
 
-API_URL = get_value()["nucleus_api_endpoint"]
 ORG_ID = get_value()["organization_id"]
+API_URL = _nucleus_url()
 
 
 @beartype

src/utils.py

@@ -1,4 +1,8 @@
 import os
+from urllib.parse import urljoin
+
+from beartype import beartype
+from deeporigin.config import get_value
 
 __all__ = [
     "expand_user",
@@ -8,6 +12,16 @@
 PREFIX = "deeporigin://"
 
 
+@beartype
+def _nucleus_url() -> str:
+    """returns URL for nucleus API endpoint"""
+    return urljoin(
+        get_value()["api_endpoint"],
+        get_value()["nucleus_api_route"],
+    )
+
+
+@beartype
 def expand_user(path, user_home_dirname: str = os.path.expanduser("~")) -> str:
     """Expand paths that start with `~` by replacing it the user's home directory
 

tests/test_low_level.py

@@ -8,7 +8,9 @@
 from deeporigin.config import get_value
 from deeporigin.exceptions import DeepOriginException
 from deeporigin.managed_data import _api, api
+from deeporigin.utils import _nucleus_url
 
+API_URL = _nucleus_url()
 # constants
 row_description_keys = {
     "id",
@@ -62,7 +64,7 @@
 
 # if we're running against a real instance, determine
 # if the database has any files in it
-if get_value()["nucleus_api_endpoint"] != MOCK_URL:
+if API_URL != MOCK_URL:
     df = api.get_dataframe(DB_NAME)
     file_ids = df.attrs["file_ids"]
     if len(file_ids) == 0: