implement dsm

Author: sanderegg

services/storage/src/simcore_service_storage/api/rest/_paths.py

@@ -11,7 +11,6 @@
 )
 from models_library.generics import Envelope
 from models_library.users import UserID
-from pydantic import ByteSize
 
 from ...dsm_factory import BaseDataManager
 from .dependencies.dsm_prodiver import get_data_manager
@@ -60,5 +59,7 @@ async def compute_path_total_size(
     path: Path,
 ):
     return Envelope[PathTotalSizeCreate](
-        data=PathTotalSizeCreate(path=path, size=ByteSize(238723))
+        data=PathTotalSizeCreate(
+            path=path, size=await dsm.compute_path_total_size(user_id, path=path)
+        )
     )

services/storage/src/simcore_service_storage/datcore_dsm.py

@@ -187,6 +187,10 @@ async def list_paths(
             1,
         )
 
+    async def compute_path_total_size(self, user_id: UserID, *, path: Path) -> ByteSize:
+        """returns the total size of the path"""
+        raise NotImplementedError
+
     async def list_files(
         self,
         user_id: UserID,

services/storage/src/simcore_service_storage/dsm_factory.py

@@ -80,6 +80,10 @@ async def list_paths(
     ) -> tuple[list[PathMetaData], GenericCursor | None, TotalNumber | None]:
         """returns a page of the file meta data a user has access to"""
 
+    @abstractmethod
+    async def compute_path_total_size(self, user_id: UserID, *, path: Path) -> ByteSize:
+        """returns the total size of the path"""
+
     @abstractmethod
     async def get_file(self, user_id: UserID, file_id: StorageFileID) -> FileMetaData:
         """returns the file meta data of file_id if user_id has the rights to"""

services/storage/src/simcore_service_storage/simcore_s3_dsm.py

@@ -251,6 +251,10 @@ async def list_paths(
 
         return paths_metadata, next_cursor, total
 
+    async def compute_path_total_size(self, user_id: UserID, *, path: Path) -> ByteSize:
+        """returns the total size of the path"""
+        return 0
+
     async def list_files(
         self,
         user_id: UserID,