[File][RestParity]Add Create_Permission API and Test

sdk/storage/azure-storage-file/azure/storage/file/_deserialize.py

@@ -46,9 +46,19 @@ def deserialize_file_stream(response, obj, headers):
     return response.location_mode, obj
 
 
-def _deserialize_permission(response):
+def deserialize_permission(response, obj, headers):
     '''
     Extracts out file permission
     '''
 
-    return response.body
+    return obj.permission
+
+
+def deserialize_permission_key(response, obj, headers):
+    '''
+    Extracts out file permission key
+    '''
+
+    if response is None or headers is None:
+        return None
+    return headers.get('x-ms-file-permission-key', None)

sdk/storage/azure-storage-file/azure/storage/file/aio/share_client_async.py

@@ -24,7 +24,7 @@
     StorageErrorException,
     SignedIdentifier,
     DeleteSnapshotsOptionType)
-from .._deserialize import deserialize_share_properties
+from .._deserialize import deserialize_share_properties, deserialize_permission
 from ..share_client import ShareClient as ShareClientBase
 from .directory_client_async import DirectoryClient
 from .file_client_async import FileClient
@@ -457,12 +457,38 @@ def list_directories_and_files( # type: ignore
         return directory.list_directories_and_files(
             name_starts_with=name_starts_with, marker=marker, timeout=timeout, **kwargs)
 
+    @distributed_trace_async
+    async def create_permission_for_share(self, file_permission,  # type: str
+                                          timeout=None,  # type: Optional[int]
+                                          **kwargs  # type: Any
+                                          ):
+        # type: (...) -> str
+        """
+        Create a permission(a security descriptor) at the share level.
+        This 'permission' can be used for the files/directories in the share.
+        If a 'permission' already exists, it shall return the key of it, else
+        creates a new permission at the share level and return its key.
+
+        :param str file_permission:
+            File permission, a Portable SDDL
+        :param int timeout:
+            The timeout parameter is expressed in seconds.
+        :returns a file permission key
+        :rtype str
+        """
+        options = self._create_permission_for_share_options(file_permission, timeout=timeout, **kwargs)
+        try:
+            return await self._client.share.create_permission(**options)
+        except StorageErrorException as error:
+            process_storage_error(error)
+
     @distributed_trace_async
     async def get_permission_for_share(  # type: ignore
             self, file_permission_key,  # type: str
             timeout=None,  # type: Optional[int]
             **kwargs  # type: Any
     ):
+        # type: (...) -> str
         """
         Get a permission(a security descriptor) for a given key.
         This 'permission' can be used for the files/directories in the share.
@@ -477,6 +503,7 @@ async def get_permission_for_share(  # type: ignore
         try:
             return await self._client.share.get_permission(  # type: ignore
                 file_permission_key=file_permission_key,
+                cls=deserialize_permission,
                 timeout=timeout,
                 **kwargs)
         except StorageErrorException as error:

sdk/storage/azure-storage-file/azure/storage/file/share_client.py

@@ -26,8 +26,9 @@
 from ._generated.models import (
     StorageErrorException,
     SignedIdentifier,
-    DeleteSnapshotsOptionType)
-from ._deserialize import deserialize_share_properties
+    DeleteSnapshotsOptionType,
+    SharePermission)
+from ._deserialize import deserialize_share_properties, deserialize_permission_key, deserialize_permission
 from .directory_client import DirectoryClient
 from .file_client import FileClient
 from ._shared_access_signature import FileSharedAccessSignature
@@ -623,12 +624,49 @@ def list_directories_and_files( # type: ignore
         return directory.list_directories_and_files(
             name_starts_with=name_starts_with, marker=marker, timeout=timeout, **kwargs)
 
+    @staticmethod
+    def _create_permission_for_share_options(file_permission,  # type: str
+                                             **kwargs):
+        options = {
+            'share_permission': SharePermission(permission=file_permission),
+            'cls': deserialize_permission_key,
+            'timeout': kwargs.pop('timeout', None),
+        }
+        options.update(kwargs)
+        return options
+
+    @distributed_trace
+    def create_permission_for_share(self, file_permission,  # type: str
+                                    timeout=None,  # type: Optional[int]
+                                    **kwargs  # type: Any
+                                    ):
+        # type: (...) -> str
+        """
+        Create a permission(a security descriptor) at the share level.
+        This 'permission' can be used for the files/directories in the share.
+        If a 'permission' already exists, it shall return the key of it, else
+        creates a new permission at the share level and return its key.
+
+        :param str file_permission:
+            File permission, a Portable SDDL
+        :param int timeout:
+            The timeout parameter is expressed in seconds.
+        :returns a file permission key
+        :rtype str
+        """
+        options = self._create_permission_for_share_options(file_permission, timeout=timeout, **kwargs)
+        try:
+            return self._client.share.create_permission(**options)
+        except StorageErrorException as error:
+            process_storage_error(error)
+
     @distributed_trace
     def get_permission_for_share(  # type: ignore
             self, file_permission_key,  # type: str
             timeout=None,  # type: Optional[int]
             **kwargs  # type: Any
     ):
+        # type: (...) -> str
         """
         Get a permission(a security descriptor) for a given key.
         This 'permission' can be used for the files/directories in the share.
@@ -643,6 +681,7 @@ def get_permission_for_share(  # type: ignore
         try:
             return self._client.share.get_permission(  # type: ignore
                 file_permission_key=file_permission_key,
+                cls=deserialize_permission,
                 timeout=timeout,
                 **kwargs)
         except StorageErrorException as error: