Improve file operation permissions and path resolution logic (#332)

* PIM-6080
Add `strict_permission` flag to core file operations

This commit introduces an optional `strict_permission` parameter to multiple file operation methods, which enables enhanced permission validation before executing actions like copy, move, upload, delete, and rename.

* PIM-6080
Improve permission handling and path resolution logic in core commands

This update refines permission error detection, adjusts path resolution to accommodate additional root cases, and improves response handling for task completion with warnings.

* PIM-6080
Refactor strict permission error handling

This commit streamlines strict permission error detection by introducing helper functions for normalizing responses and mapping errors, improving maintainability and readability of the code.

* PIM-6080
Extend permission error mapping and refactor strict permission handling logic

This commit adds a comprehensive task error mapping for strict permission validation, introduces a helper function for extracting task error details, and updates logging for improved debugging.

* PIM-6080
Remove unused `_is_permission_denied_message` function from core commands

* PIM-6080
Simplify strict permission error handling by replacing error maps with sets.

* PIM-6080
Add unit tests for strict permission handling in `move` and `mkdir` operations

Author: udirctera

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):
+    async def copy(self, *paths, destination=None, resolver=None, cursor=None, wait=False, strict_permission=False):
         """
         Copy one or more files or folders.
 
@@ -156,7 +156,16 @@ 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).a_execute()
+            return await Copy(
+                io.copy,
+                self._core,
+                wait,
+                *paths,
+                destination=destination,
+                resolver=resolver,
+                cursor=cursor,
+                strict_permission=strict_permission
+            ).a_execute()
         except ValueError:
             raise ValueError('Copy destination was not specified.')
 
@@ -175,7 +184,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):
+    async def upload(self, destination, handle, name=None, size=None, strict_permission=False):
         """
         Upload from file handle.
 
@@ -187,9 +196,18 @@ async def upload(self, destination, handle, name=None, size=None):
         :rtype: str
         :raises cterasdk.exceptions.io.core.UploadError: Raised on upload failure.
         """
-        return await Upload(io.upload, self._core, io.listdir, destination, handle, name, size).a_execute()
+        return await Upload(
+            io.upload,
+            self._core,
+            io.listdir,
+            destination,
+            handle,
+            name,
+            size,
+            strict_permission=strict_permission
+        ).a_execute()
 
-    async def upload_file(self, path, destination):
+    async def upload_file(self, path, destination, strict_permission=False):
         """
         Upload a file.
 
@@ -201,9 +219,15 @@ async def upload_file(self, path, destination):
         """
         _, name = commonfs.split_file_directory(path)
         with open(path, 'rb') as handle:
-            return await self.upload(destination, handle, name, commonfs.properties(path)['size'])
+            return await self.upload(
+                destination,
+                handle,
+                name,
+                commonfs.properties(path)['size'],
+                strict_permission=strict_permission
+            )
 
-    async def mkdir(self, path):
+    async def mkdir(self, path, strict_permission=False):
         """
         Create a directory.
 
@@ -212,9 +236,9 @@ async def mkdir(self, path):
         :rtype: str
         :raises cterasdk.exceptions.io.core.CreateDirectoryError: Raised on error creating directory.
         """
-        return await CreateDirectory(io.mkdir, self._core, path).a_execute()
+        return await CreateDirectory(io.mkdir, self._core, path, strict_permission=strict_permission).a_execute()
 
-    async def makedirs(self, path):
+    async def makedirs(self, path, strict_permission=False):
         """
         Recursively create a directory.
 
@@ -223,9 +247,9 @@ async def makedirs(self, path):
         :rtype: str
         :raises cterasdk.exceptions.io.core.CreateDirectoryError: Raised on error creating directory.
         """
-        return await CreateDirectory(io.mkdir, self._core, path, True).a_execute()
+        return await CreateDirectory(io.mkdir, self._core, path, True, strict_permission=strict_permission).a_execute()
 
-    async def rename(self, path, name, *, resolver=None, wait=False):
+    async def rename(self, path, name, *, resolver=None, wait=False, strict_permission=False):
         """
         Rename a file or folder.
 
@@ -237,9 +261,17 @@ async def rename(self, path, name, *, resolver=None, wait=False):
         :rtype: cterasdk.common.object.Object or :class:`cterasdk.lib.tasks.AwaitablePortalTask`
         :raises cterasdk.exceptions.io.core.RenameError: Raised on error renaming object.
         """
-        return await Rename(io.move, self._core, wait, path, name, resolver).a_execute()
+        return await Rename(
+            io.move,
+            self._core,
+            wait,
+            path,
+            name,
+            resolver,
+            strict_permission=strict_permission
+        ).a_execute()
 
-    async def delete(self, *paths, wait=False):
+    async def delete(self, *paths, wait=False, strict_permission=False):
         """
         Delete one or more files or folders.
 
@@ -249,7 +281,7 @@ async def delete(self, *paths, wait=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).a_execute()
+        return await Delete(io.delete, self._core, wait, *paths, strict_permission=strict_permission).a_execute()
 
     async def undelete(self, *paths, wait=False):
         """
@@ -263,7 +295,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):
+    async def move(self, *paths, destination=None, resolver=None, cursor=None, wait=False, strict_permission=False):
         """
         Move one or more files or folders.
 
@@ -277,7 +309,16 @@ 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).a_execute()
+            return await Move(
+                io.move,
+                self._core,
+                wait,
+                *paths,
+                destination=destination,
+                resolver=resolver,
+                cursor=cursor,
+                strict_permission=strict_permission
+            ).a_execute()
         except ValueError:
             raise ValueError('Move destination was not specified.')