Capture logged-in user's permissions for accessing user folders

Add path utilities to compute sliced paths, resolve relative paths, and verify path relationships
Add pre-execution access validation that raises an error before remote file system command
Add user permission validation for: handle, handle_many, download, download_many, mkdir, makedirs, listdir, walk, properties, exists, versions, permalink, copy, move, delete, upload, upload_file

Author: saimonation

cterasdk/asynchronous/core/files/browser.py

@@ -142,7 +142,7 @@ async def public_link(self, path, access='RO', expire_in=30):
         """
         return await Link(io.public_link, self._core, path, access, expire_in).a_execute()
 
-    async def copy(self, *paths, destination=None, resolver=None, cursor=None, wait=False, strict_permission=False):
+    async def copy(self, *paths, destination=None, resolver=None, cursor=None, wait=False):
         """
         Copy one or more files or folders.
 
@@ -156,16 +156,7 @@ async def copy(self, *paths, destination=None, resolver=None, cursor=None, wait=
         :raises cterasdk.exceptions.io.core.CopyError: Raised on failure copying resources.
         """
         try:
-            return await Copy(
-                io.copy,
-                self._core,
-                wait,
-                *paths,
-                destination=destination,
-                resolver=resolver,
-                cursor=cursor,
-                strict_permission=strict_permission
-            ).a_execute()
+            return await Copy(io.copy, self._core, wait, *paths, destination=destination, resolver=resolver, cursor=cursor).a_execute()
         except ValueError:
             raise ValueError('Copy destination was not specified.')
 
@@ -184,7 +175,7 @@ async def permalink(self, path):
 class CloudDrive(FileBrowser):
     """Async CloudDrive API with upload and sharing functionality."""
 
-    async def upload(self, destination, handle, name=None, size=None, strict_permission=False):
+    async def upload(self, destination, handle, name=None, size=None):
         """
         Upload from file handle.
 
@@ -204,10 +195,10 @@ async def upload(self, destination, handle, name=None, size=None, strict_permiss
             handle,
             name,
             size,
-            strict_permission=strict_permission
+            
         ).a_execute()
 
-    async def upload_file(self, path, destination, strict_permission=False):
+    async def upload_file(self, path, destination):
         """
         Upload a file.
 
@@ -224,10 +215,10 @@ async def upload_file(self, path, destination, strict_permission=False):
                 handle,
                 name,
                 commonfs.properties(path)['size'],
-                strict_permission=strict_permission
+                
             )
 
-    async def mkdir(self, path, strict_permission=False):
+    async def mkdir(self, path):
         """
         Create a directory.
 
@@ -236,9 +227,9 @@ async def mkdir(self, path, strict_permission=False):
         :rtype: str
         :raises cterasdk.exceptions.io.core.CreateDirectoryError: Raised on error creating directory.
         """
-        return await CreateDirectory(io.mkdir, self._core, path, strict_permission=strict_permission).a_execute()
+        return await CreateDirectory(io.mkdir, self._core, path, ).a_execute()
 
-    async def makedirs(self, path, strict_permission=False):
+    async def makedirs(self, path):
         """
         Recursively create a directory.
 
@@ -247,9 +238,9 @@ async def makedirs(self, path, strict_permission=False):
         :rtype: str
         :raises cterasdk.exceptions.io.core.CreateDirectoryError: Raised on error creating directory.
         """
-        return await CreateDirectory(io.mkdir, self._core, path, True, strict_permission=strict_permission).a_execute()
+        return await CreateDirectory(io.mkdir, self._core, path, True, ).a_execute()
 
-    async def rename(self, path, name, *, resolver=None, wait=False, strict_permission=False):
+    async def rename(self, path, name, *, resolver=None, wait=False):
         """
         Rename a file or folder.
 
@@ -268,10 +259,10 @@ async def rename(self, path, name, *, resolver=None, wait=False, strict_permissi
             path,
             name,
             resolver,
-            strict_permission=strict_permission
+            
         ).a_execute()
 
-    async def delete(self, *paths, wait=False, strict_permission=False):
+    async def delete(self, *paths, wait=False):
         """
         Delete one or more files or folders.
 
@@ -281,7 +272,7 @@ async def delete(self, *paths, wait=False, strict_permission=False):
         :rtype: cterasdk.common.object.Object or :class:`cterasdk.lib.tasks.AwaitablePortalTask`
         :raises cterasdk.exceptions.io.core.DeleteError: Raised on error deleting resources.
         """
-        return await Delete(io.delete, self._core, wait, *paths, strict_permission=strict_permission).a_execute()
+        return await Delete(io.delete, self._core, wait, *paths, ).a_execute()
 
     async def undelete(self, *paths, wait=False):
         """
@@ -295,7 +286,7 @@ async def undelete(self, *paths, wait=False):
         """
         return await Recover(io.undelete, self._core, wait, *paths).a_execute()
 
-    async def move(self, *paths, destination=None, resolver=None, cursor=None, wait=False, strict_permission=False):
+    async def move(self, *paths, destination=None, resolver=None, cursor=None, wait=False):
         """
         Move one or more files or folders.
 
@@ -309,16 +300,7 @@ async def move(self, *paths, destination=None, resolver=None, cursor=None, wait=
         :raises cterasdk.exceptions.io.core.MoveError: Raised on error moving resources.
         """
         try:
-            return await Move(
-                io.move,
-                self._core,
-                wait,
-                *paths,
-                destination=destination,
-                resolver=resolver,
-                cursor=cursor,
-                strict_permission=strict_permission
-            ).a_execute()
+            return await Move(io.move, self._core, wait, *paths, destination=destination, resolver=resolver, cursor=cursor).a_execute()
         except ValueError:
             raise ValueError('Move destination was not specified.')
 

cterasdk/asynchronous/core/roles.py

@@ -0,0 +1,36 @@
+import logging
+
+from ...core.enum import RoleResolver
+from ...core.types import RoleSettings
+from .base_command import BaseCommand
+
+
+logger = logging.getLogger('cterasdk.core')
+
+
+class Roles(BaseCommand):
+    """
+    Role Settings APIs
+    """
+
+    @staticmethod
+    def find(role):
+        """
+        Find Role
+        """
+        options = {k: v for k, v in RoleResolver.__dict__.items() if not k.startswith('_')}
+        return options.get(role, None)
+
+    async def get(self, role):
+        """
+        Get Role
+
+        :param str role: Role
+        :returns: Role settings
+        :rtype: cterasdk.core.types.RoleSettings
+        """
+        name = Roles.find(role)
+        if name:
+            return RoleSettings.from_server_object(await self._core.v1.api.get(f'/rolesSettings/{name}'))
+        logger.warning('Could not find role. %s', {'role': role})
+        return None

cterasdk/cio/common.py

@@ -1,10 +1,26 @@
 import urllib.parse
+from functools import wraps
 from pathlib import PurePosixPath
 from ..common import Object
 from ..common.utils import utf8_decode
 from ..convert.serializers import toxmlstr
 
 
+def resolver(func):
+    @wraps(func)
+    def wrapper(self, p):
+        if isinstance(p, BasePath):
+            p = p.reference
+        elif isinstance(p, str):
+            pass
+        else:
+            raise ValueError(
+                f"Parameter 'p' must be str or BasePath, got {type(p).__name__}"
+            )
+        return func(self, p)
+    return wrapper
+
+
 class BasePath:
     """Base Path for CTERA Portal and CTERA Edge"""
 
@@ -20,7 +36,7 @@ def __init__(self, scope, reference):
         if isinstance(reference, str):
             reference = reference.lstrip('/')
         self._scope = PurePosixPath(scope)
-        self._reference = PurePosixPath(reference)
+        self._reference = PurePosixPath(*reference) if isinstance(reference, tuple) else PurePosixPath(reference)
 
     @property
     def scope(self):
@@ -58,6 +74,14 @@ def absolute_encode(self):
     def absolute_parent(self):
         return self.parent.as_posix()
 
+    @resolver
+    def is_relative_to(self, p):
+        return self.reference.is_relative_to(p)
+
+    @resolver
+    def relative_to(self, p):
+        return self.__class__(self.reference.relative_to(p).as_posix())  # pylint: disable=no-value-for-parameter
+
     @property
     def extension(self):
         return self.reference.suffix
@@ -74,6 +98,14 @@ def join(self, p):
     def parts(self):
         return self.reference.parts
 
+    def __getitem__(self, key):
+        if isinstance(key, slice):
+            return self.__class__(self.parts[key])
+        elif isinstance(key, int):
+            return self.parts[key]
+        else:
+            raise TypeError("Invalid argument type")
+
     def __eq__(self, p):
         return self.absolute == p.absolute