feat: use the amalthea session cache

Author: olevski

components/renku_data_services/authn/dummy.py

@@ -70,7 +70,7 @@ async def authenticate(self, access_token: str, request: Request) -> base_models
         )
 
         return base_models.APIUser(
-            is_admin_init=user_props.get("is_admin", False),
+            is_admin=user_props.get("is_admin", False),
             id=user_props.get("id", "some-id") if is_set else None,
             access_token=access_token,
             first_name=user_props.get("first_name", "John") if is_set else None,

components/renku_data_services/base_api/auth.py

@@ -6,8 +6,7 @@
 from functools import wraps
 from typing import Any, Concatenate, ParamSpec, TypeVar, cast
 
-from sanic import HTTPResponse, Request
-from ulid import ULID
+from sanic import Request
 
 from renku_data_services import errors
 from renku_data_services.base_models import AnyAPIUser, APIUser, Authenticator

components/renku_data_services/notebooks/api/amalthea_patches/init_containers.py

@@ -91,7 +91,7 @@ async def git_clone_container_v2(
             env.append(
                 {"name": f"{prefix}USER__EMAIL", "value": user.email},
             )
-        full_name = server.user.get_full_name()
+        full_name = user.get_full_name()
         if full_name:
             env.append(
                 {

components/renku_data_services/notebooks/blueprints.py

@@ -916,8 +916,8 @@ async def _handler(
                         args=environment.args,
                         shmSize="1G",
                         env=[
-                            SessionEnvItem(name="RENKU_BASE_URL_PATH", value=base_server_url),
-                            SessionEnvItem(name="RENKU_BASE_URL", value=base_server_path),
+                            SessionEnvItem(name="RENKU_BASE_URL_PATH", value=base_server_path),
+                            SessionEnvItem(name="RENKU_BASE_URL", value=base_server_url),
                         ],
                     ),
                     ingress=Ingress(

components/renku_data_services/notebooks/util/kubernetes_.py

@@ -27,8 +27,6 @@
 
 from renku_data_services.notebooks.crs import Patch, PatchType
 
-from renku_data_services.notebooks.crs import Patch, PatchType
-
 
 def renku_1_make_server_name(safe_username: str, namespace: str, project: str, branch: str, commit_sha: str) -> str:
     """Form a unique server name for Renku 1.0 sessions.

components/renku_data_services/session/db.py

@@ -5,7 +5,6 @@
 from collections.abc import Callable
 from contextlib import AbstractAsyncContextManager, nullcontext
 from datetime import UTC, datetime
-from pathlib import PurePosixPath
 from typing import Any
 
 from sqlalchemy import select

test/components/renku_data_services/authz/test_authorization.py

@@ -17,10 +17,10 @@
 from renku_data_services.namespace.models import Namespace, NamespaceKind
 from renku_data_services.project.models import Project
 
-admin_user = APIUser(is_admin_init=True, id="admin-id", access_token="some-token", full_name="admin")  # nosec B106
-anon_user = APIUser(is_admin_init=False)
-regular_user1 = APIUser(is_admin_init=False, id="user1-id", access_token="some-token1", full_name="some-user1")  # nosec B106
-regular_user2 = APIUser(is_admin_init=False, id="user2-id", access_token="some-token2", full_name="some-user2")  # nosec B106
+admin_user = APIUser(is_admin=True, id="admin-id", access_token="some-token", full_name="admin")  # nosec B106
+anon_user = APIUser(is_admin=False)
+regular_user1 = APIUser(is_admin=False, id="user1-id", access_token="some-token1", full_name="some-user1")  # nosec B106
+regular_user2 = APIUser(is_admin=False, id="user2-id", access_token="some-token2", full_name="some-user2")  # nosec B106
 
 
 @pytest_asyncio.fixture