squashme: address comments

Author: olevski

components/renku_data_services/notebooks/api.spec.yaml

@@ -1025,11 +1025,12 @@ components:
         storage_id:
           allOf:
             - "$ref": "#/components/schemas/Ulid"
-            - description: If the storage_id is provided then this config must replace an existing storage config in the session
+            - description: The storage ID is used to know which storage config from the DB should be overriden
       required:
         - configuration
         - source_path
         - target_path
+        - storage_id
     ServerName:
       type: string
       minLength: 5

components/renku_data_services/notebooks/apispec.py

@@ -1,6 +1,6 @@
 # generated by datamodel-codegen:
 #   filename:  api.spec.yaml
-#   timestamp: 2024-09-23T14:43:54+00:00
+#   timestamp: 2024-09-23T15:38:59+00:00
 
 from __future__ import annotations
 
@@ -263,8 +263,8 @@ class SessionCloudStoragePost(BaseAPISpec):
     readonly: bool = True
     source_path: str
     target_path: str
-    storage_id: Optional[str] = Field(
-        None,
+    storage_id: str = Field(
+        ...,
         description="ULID identifier",
         max_length=26,
         min_length=26,

components/renku_data_services/notebooks/blueprints.py

@@ -835,14 +835,18 @@ async def _handler(
                     name=None,
                 )
                 for s in body.cloudstorage or []
-                if s.storage_id is not None
             }
             # NOTE: Check the cloud storage in the request body and if any match
             # then overwrite the projects cloud storages
-            # NOTE: Cloud storages in the session launch request body that are not form the DB are ignored
+            # NOTE: Cloud storages in the session launch request body that are not form the DB will cause a 422 error
             for csr_id, csr in cloud_storage_request.items():
-                if csr_id in cloud_storage:
-                    cloud_storage[csr_id] = csr
+                if csr_id not in cloud_storage:
+                    raise errors.MissingResourceError(
+                        message=f"You have requested a cloud storage with ID {csr_id} which does not exist "
+                        "or you dont have access to.",
+                        quiet=True,
+                    )
+                cloud_storage[csr_id] = csr
             # repositories = [Repository(i.url, branch=i.branch, commit_sha=i.commit_sha) for i in body.repositories]
             repositories = [Repository(url=i) for i in project.repositories]
             secrets_to_create: list[V1Secret] = []
@@ -865,7 +869,7 @@ async def _handler(
                 is_image_private=False,
                 internal_gitlab_user=internal_gitlab_user,
             )
-            # Generate the cloud starge secrets
+            # Generate the cloud storage secrets
             data_sources: list[DataSource] = []
             for ics, cs in enumerate(cloud_storage.values()):
                 secret_name = f"{server_name}-ds-{ics}"