text: # pylint: disable=too-many-lines
  # coding=utf-8
  # --------------------------------------------------------------------------
  # Copyright (c) Microsoft Corporation. All rights reserved.
  # Licensed under the MIT License. See License.txt in the project root for license information.
  # Code generated by Microsoft (R) AutoRest Code Generator.
  # Changes may cause incorrect behavior and will be lost if the code is regenerated.
  # --------------------------------------------------------------------------
  from typing import Any, Callable, Dict, List, Optional, TypeVar, Union
  
  from azure.core.exceptions import ClientAuthenticationError, HttpResponseError, ResourceExistsError, ResourceNotFoundError, map_error
  from azure.core.pipeline import PipelineResponse
  from azure.core.pipeline.transport import AsyncHttpResponse
  from azure.core.rest import HttpRequest
  from azure.core.tracing.decorator_async import distributed_trace_async
  
  from ... import models as _models
  from ..._vendor import _convert_request
  from ...operations._directory_operations import build_create_request, build_delete_request, build_force_close_handles_request, build_get_properties_request, build_list_files_and_directories_segment_request, build_list_handles_request, build_rename_request, build_set_metadata_request, build_set_properties_request
  T = TypeVar('T')
  ClsType = Optional[Callable[[PipelineResponse[HttpRequest, AsyncHttpResponse], T, Dict[str, Any]], Any]]
  
  class DirectoryOperations:
      """
      .. warning::
          **DO NOT** instantiate this class directly.
  
          Instead, you should access the following operations through
          :class:`~azure.storage.fileshare.aio.AzureFileStorage`'s
          :attr:`directory` attribute.
      """
  
      models = _models
  
      def __init__(self, *args, **kwargs) -> None:
          args = list(args)
          self._client = args.pop(0) if args else kwargs.pop("client")
          self._config = args.pop(0) if args else kwargs.pop("config")
          self._serialize = args.pop(0) if args else kwargs.pop("serializer")
          self._deserialize = args.pop(0) if args else kwargs.pop("deserializer")
  
  
      @distributed_trace_async
      async def create(  # pylint: disable=inconsistent-return-statements
          self,
          timeout: Optional[int] = None,
          metadata: Optional[Dict[str, str]] = None,
          file_permission: Optional[str] = "inherit",
          file_permission_key: Optional[str] = None,
          file_attributes: str = "none",
          file_creation_time: str = "now",
          file_last_write_time: str = "now",
          **kwargs: Any
      ) -> None:
          """Creates a new directory under the specified share or parent directory.
  
          :param timeout: The timeout parameter is expressed in seconds. For more information, see
           :code:`<a
           href="https://docs.microsoft.com/en-us/rest/api/storageservices/Setting-Timeouts-for-File-Service-Operations?redirectedfrom=MSDN">Setting
           Timeouts for File Service Operations.</a>`. Default value is None.
          :type timeout: int
          :param metadata: A name-value pair to associate with a file storage object. Default value is
           None.
          :type metadata: dict[str, str]
          :param file_permission: If specified the permission (security descriptor) shall be set for the
           directory/file. This header can be used if Permission size is <= 8KB, else
           x-ms-file-permission-key header shall be used. Default value: Inherit. If SDDL is specified as
           input, it must have owner, group and dacl. Note: Only one of the x-ms-file-permission or
           x-ms-file-permission-key should be specified. Default value is "inherit".
          :type file_permission: str
          :param file_permission_key: Key of the permission to be set for the directory/file. Note: Only
           one of the x-ms-file-permission or x-ms-file-permission-key should be specified. Default value
           is None.
          :type file_permission_key: str
          :param file_attributes: If specified, the provided file attributes shall be set. Default value:
           ‘Archive’ for file and ‘Directory’ for directory. ‘None’ can also be specified as default.
           Default value is "none".
          :type file_attributes: str
          :param file_creation_time: Creation time for the file/directory. Default value: Now. Default
           value is "now".
          :type file_creation_time: str
          :param file_last_write_time: Last write time for the file/directory. Default value: Now.
           Default value is "now".
          :type file_last_write_time: str
          :keyword restype: restype. Default value is "directory". Note that overriding this default
           value may result in unsupported behavior.
          :paramtype restype: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :return: None, or the result of cls(response)
          :rtype: None
          :raises: ~azure.core.exceptions.HttpResponseError
          """
          cls = kwargs.pop('cls', None)  # type: ClsType[None]
          error_map = {
              401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
          }
          error_map.update(kwargs.pop('error_map', {}))
  
          restype = kwargs.pop('restype', "directory")  # type: str
  
          
          request = build_create_request(
              url=self._config.url,
              restype=restype,
              version=self._config.version,
              timeout=timeout,
              metadata=metadata,
              file_permission=file_permission,
              file_permission_key=file_permission_key,
              file_attributes=file_attributes,
              file_creation_time=file_creation_time,
              file_last_write_time=file_last_write_time,
              template_url=self.create.metadata['url'],
          )
          request = _convert_request(request)
          request.url = self._client.format_url(request.url)
  
          pipeline_response = await self._client._pipeline.run(  # pylint: disable=protected-access
              request,
              stream=False,
              **kwargs
          )
          response = pipeline_response.http_response
  
          if response.status_code not in [201]:
              map_error(status_code=response.status_code, response=response, error_map=error_map)
              error = self._deserialize.failsafe_deserialize(_models.StorageError, pipeline_response)
              raise HttpResponseError(response=response, model=error)
  
          response_headers = {}
          response_headers['ETag']=self._deserialize('str', response.headers.get('ETag'))
          response_headers['Last-Modified']=self._deserialize('rfc-1123', response.headers.get('Last-Modified'))
          response_headers['x-ms-request-id']=self._deserialize('str', response.headers.get('x-ms-request-id'))
          response_headers['x-ms-version']=self._deserialize('str', response.headers.get('x-ms-version'))
          response_headers['Date']=self._deserialize('rfc-1123', response.headers.get('Date'))
          response_headers['x-ms-request-server-encrypted']=self._deserialize('bool', response.headers.get('x-ms-request-server-encrypted'))
          response_headers['x-ms-file-permission-key']=self._deserialize('str', response.headers.get('x-ms-file-permission-key'))
          response_headers['x-ms-file-attributes']=self._deserialize('str', response.headers.get('x-ms-file-attributes'))
          response_headers['x-ms-file-creation-time']=self._deserialize('str', response.headers.get('x-ms-file-creation-time'))
          response_headers['x-ms-file-last-write-time']=self._deserialize('str', response.headers.get('x-ms-file-last-write-time'))
          response_headers['x-ms-file-change-time']=self._deserialize('str', response.headers.get('x-ms-file-change-time'))
          response_headers['x-ms-file-id']=self._deserialize('str', response.headers.get('x-ms-file-id'))
          response_headers['x-ms-file-parent-id']=self._deserialize('str', response.headers.get('x-ms-file-parent-id'))
  
  
          if cls:
              return cls(pipeline_response, None, response_headers)
  
      create.metadata = {'url': "{url}/{shareName}/{directory}"}  # type: ignore
  
  
      @distributed_trace_async
      async def get_properties(  # pylint: disable=inconsistent-return-statements
          self,
          sharesnapshot: Optional[str] = None,
          timeout: Optional[int] = None,
          **kwargs: Any
      ) -> None:
          """Returns all system properties for the specified directory, and can also be used to check the
          existence of a directory. The data returned does not include the files in the directory or any
          subdirectories.
  
          :param sharesnapshot: The snapshot parameter is an opaque DateTime value that, when present,
           specifies the share snapshot to query. Default value is None.
          :type sharesnapshot: str
          :param timeout: The timeout parameter is expressed in seconds. For more information, see
           :code:`<a
           href="https://docs.microsoft.com/en-us/rest/api/storageservices/Setting-Timeouts-for-File-Service-Operations?redirectedfrom=MSDN">Setting
           Timeouts for File Service Operations.</a>`. Default value is None.
          :type timeout: int
          :keyword restype: restype. Default value is "directory". Note that overriding this default
           value may result in unsupported behavior.
          :paramtype restype: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :return: None, or the result of cls(response)
          :rtype: None
          :raises: ~azure.core.exceptions.HttpResponseError
          """
          cls = kwargs.pop('cls', None)  # type: ClsType[None]
          error_map = {
              401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
          }
          error_map.update(kwargs.pop('error_map', {}))
  
          restype = kwargs.pop('restype', "directory")  # type: str
  
          
          request = build_get_properties_request(
              url=self._config.url,
              restype=restype,
              version=self._config.version,
              sharesnapshot=sharesnapshot,
              timeout=timeout,
              template_url=self.get_properties.metadata['url'],
          )
          request = _convert_request(request)
          request.url = self._client.format_url(request.url)
  
          pipeline_response = await self._client._pipeline.run(  # pylint: disable=protected-access
              request,
              stream=False,
              **kwargs
          )
          response = pipeline_response.http_response
  
          if response.status_code not in [200]:
              map_error(status_code=response.status_code, response=response, error_map=error_map)
              error = self._deserialize.failsafe_deserialize(_models.StorageError, pipeline_response)
              raise HttpResponseError(response=response, model=error)
  
          response_headers = {}
          response_headers['x-ms-meta']=self._deserialize('{str}', response.headers.get('x-ms-meta'))
          response_headers['ETag']=self._deserialize('str', response.headers.get('ETag'))
          response_headers['Last-Modified']=self._deserialize('rfc-1123', response.headers.get('Last-Modified'))
          response_headers['x-ms-request-id']=self._deserialize('str', response.headers.get('x-ms-request-id'))
          response_headers['x-ms-version']=self._deserialize('str', response.headers.get('x-ms-version'))
          response_headers['Date']=self._deserialize('rfc-1123', response.headers.get('Date'))
          response_headers['x-ms-server-encrypted']=self._deserialize('bool', response.headers.get('x-ms-server-encrypted'))
          response_headers['x-ms-file-attributes']=self._deserialize('str', response.headers.get('x-ms-file-attributes'))
          response_headers['x-ms-file-creation-time']=self._deserialize('str', response.headers.get('x-ms-file-creation-time'))
          response_headers['x-ms-file-last-write-time']=self._deserialize('str', response.headers.get('x-ms-file-last-write-time'))
          response_headers['x-ms-file-change-time']=self._deserialize('str', response.headers.get('x-ms-file-change-time'))
          response_headers['x-ms-file-permission-key']=self._deserialize('str', response.headers.get('x-ms-file-permission-key'))
          response_headers['x-ms-file-id']=self._deserialize('str', response.headers.get('x-ms-file-id'))
          response_headers['x-ms-file-parent-id']=self._deserialize('str', response.headers.get('x-ms-file-parent-id'))
  
  
          if cls:
              return cls(pipeline_response, None, response_headers)
  
      get_properties.metadata = {'url': "{url}/{shareName}/{directory}"}  # type: ignore
  
  
      @distributed_trace_async
      async def delete(  # pylint: disable=inconsistent-return-statements
          self,
          timeout: Optional[int] = None,
          **kwargs: Any
      ) -> None:
          """Removes the specified empty directory. Note that the directory must be empty before it can be
          deleted.
  
          :param timeout: The timeout parameter is expressed in seconds. For more information, see
           :code:`<a
           href="https://docs.microsoft.com/en-us/rest/api/storageservices/Setting-Timeouts-for-File-Service-Operations?redirectedfrom=MSDN">Setting
           Timeouts for File Service Operations.</a>`. Default value is None.
          :type timeout: int
          :keyword restype: restype. Default value is "directory". Note that overriding this default
           value may result in unsupported behavior.
          :paramtype restype: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :return: None, or the result of cls(response)
          :rtype: None
          :raises: ~azure.core.exceptions.HttpResponseError
          """
          cls = kwargs.pop('cls', None)  # type: ClsType[None]
          error_map = {
              401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
          }
          error_map.update(kwargs.pop('error_map', {}))
  
          restype = kwargs.pop('restype', "directory")  # type: str
  
          
          request = build_delete_request(
              url=self._config.url,
              restype=restype,
              version=self._config.version,
              timeout=timeout,
              template_url=self.delete.metadata['url'],
          )
          request = _convert_request(request)
          request.url = self._client.format_url(request.url)
  
          pipeline_response = await self._client._pipeline.run(  # pylint: disable=protected-access
              request,
              stream=False,
              **kwargs
          )
          response = pipeline_response.http_response
  
          if response.status_code not in [202]:
              map_error(status_code=response.status_code, response=response, error_map=error_map)
              error = self._deserialize.failsafe_deserialize(_models.StorageError, pipeline_response)
              raise HttpResponseError(response=response, model=error)
  
          response_headers = {}
          response_headers['x-ms-request-id']=self._deserialize('str', response.headers.get('x-ms-request-id'))
          response_headers['x-ms-version']=self._deserialize('str', response.headers.get('x-ms-version'))
          response_headers['Date']=self._deserialize('rfc-1123', response.headers.get('Date'))
  
  
          if cls:
              return cls(pipeline_response, None, response_headers)
  
      delete.metadata = {'url': "{url}/{shareName}/{directory}"}  # type: ignore
  
  
      @distributed_trace_async
      async def set_properties(  # pylint: disable=inconsistent-return-statements
          self,
          timeout: Optional[int] = None,
          file_permission: Optional[str] = "inherit",
          file_permission_key: Optional[str] = None,
          file_attributes: str = "none",
          file_creation_time: str = "now",
          file_last_write_time: str = "now",
          **kwargs: Any
      ) -> None:
          """Sets properties on the directory.
  
          :param timeout: The timeout parameter is expressed in seconds. For more information, see
           :code:`<a
           href="https://docs.microsoft.com/en-us/rest/api/storageservices/Setting-Timeouts-for-File-Service-Operations?redirectedfrom=MSDN">Setting
           Timeouts for File Service Operations.</a>`. Default value is None.
          :type timeout: int
          :param file_permission: If specified the permission (security descriptor) shall be set for the
           directory/file. This header can be used if Permission size is <= 8KB, else
           x-ms-file-permission-key header shall be used. Default value: Inherit. If SDDL is specified as
           input, it must have owner, group and dacl. Note: Only one of the x-ms-file-permission or
           x-ms-file-permission-key should be specified. Default value is "inherit".
          :type file_permission: str
          :param file_permission_key: Key of the permission to be set for the directory/file. Note: Only
           one of the x-ms-file-permission or x-ms-file-permission-key should be specified. Default value
           is None.
          :type file_permission_key: str
          :param file_attributes: If specified, the provided file attributes shall be set. Default value:
           ‘Archive’ for file and ‘Directory’ for directory. ‘None’ can also be specified as default.
           Default value is "none".
          :type file_attributes: str
          :param file_creation_time: Creation time for the file/directory. Default value: Now. Default
           value is "now".
          :type file_creation_time: str
          :param file_last_write_time: Last write time for the file/directory. Default value: Now.
           Default value is "now".
          :type file_last_write_time: str
          :keyword restype: restype. Default value is "directory". Note that overriding this default
           value may result in unsupported behavior.
          :paramtype restype: str
          :keyword comp: comp. Default value is "properties". Note that overriding this default value may
           result in unsupported behavior.
          :paramtype comp: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :return: None, or the result of cls(response)
          :rtype: None
          :raises: ~azure.core.exceptions.HttpResponseError
          """
          cls = kwargs.pop('cls', None)  # type: ClsType[None]
          error_map = {
              401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
          }
          error_map.update(kwargs.pop('error_map', {}))
  
          restype = kwargs.pop('restype', "directory")  # type: str
          comp = kwargs.pop('comp', "properties")  # type: str
  
          
          request = build_set_properties_request(
              url=self._config.url,
              restype=restype,
              comp=comp,
              version=self._config.version,
              timeout=timeout,
              file_permission=file_permission,
              file_permission_key=file_permission_key,
              file_attributes=file_attributes,
              file_creation_time=file_creation_time,
              file_last_write_time=file_last_write_time,
              template_url=self.set_properties.metadata['url'],
          )
          request = _convert_request(request)
          request.url = self._client.format_url(request.url)
  
          pipeline_response = await self._client._pipeline.run(  # pylint: disable=protected-access
              request,
              stream=False,
              **kwargs
          )
          response = pipeline_response.http_response
  
          if response.status_code not in [200]:
              map_error(status_code=response.status_code, response=response, error_map=error_map)
              error = self._deserialize.failsafe_deserialize(_models.StorageError, pipeline_response)
              raise HttpResponseError(response=response, model=error)
  
          response_headers = {}
          response_headers['ETag']=self._deserialize('str', response.headers.get('ETag'))
          response_headers['x-ms-request-id']=self._deserialize('str', response.headers.get('x-ms-request-id'))
          response_headers['Last-Modified']=self._deserialize('rfc-1123', response.headers.get('Last-Modified'))
          response_headers['x-ms-version']=self._deserialize('str', response.headers.get('x-ms-version'))
          response_headers['Date']=self._deserialize('rfc-1123', response.headers.get('Date'))
          response_headers['x-ms-request-server-encrypted']=self._deserialize('bool', response.headers.get('x-ms-request-server-encrypted'))
          response_headers['x-ms-file-permission-key']=self._deserialize('str', response.headers.get('x-ms-file-permission-key'))
          response_headers['x-ms-file-attributes']=self._deserialize('str', response.headers.get('x-ms-file-attributes'))
          response_headers['x-ms-file-creation-time']=self._deserialize('str', response.headers.get('x-ms-file-creation-time'))
          response_headers['x-ms-file-last-write-time']=self._deserialize('str', response.headers.get('x-ms-file-last-write-time'))
          response_headers['x-ms-file-change-time']=self._deserialize('str', response.headers.get('x-ms-file-change-time'))
          response_headers['x-ms-file-id']=self._deserialize('str', response.headers.get('x-ms-file-id'))
          response_headers['x-ms-file-parent-id']=self._deserialize('str', response.headers.get('x-ms-file-parent-id'))
  
  
          if cls:
              return cls(pipeline_response, None, response_headers)
  
      set_properties.metadata = {'url': "{url}/{shareName}/{directory}"}  # type: ignore
  
  
      @distributed_trace_async
      async def set_metadata(  # pylint: disable=inconsistent-return-statements
          self,
          timeout: Optional[int] = None,
          metadata: Optional[Dict[str, str]] = None,
          **kwargs: Any
      ) -> None:
          """Updates user defined metadata for the specified directory.
  
          :param timeout: The timeout parameter is expressed in seconds. For more information, see
           :code:`<a
           href="https://docs.microsoft.com/en-us/rest/api/storageservices/Setting-Timeouts-for-File-Service-Operations?redirectedfrom=MSDN">Setting
           Timeouts for File Service Operations.</a>`. Default value is None.
          :type timeout: int
          :param metadata: A name-value pair to associate with a file storage object. Default value is
           None.
          :type metadata: dict[str, str]
          :keyword restype: restype. Default value is "directory". Note that overriding this default
           value may result in unsupported behavior.
          :paramtype restype: str
          :keyword comp: comp. Default value is "metadata". Note that overriding this default value may
           result in unsupported behavior.
          :paramtype comp: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :return: None, or the result of cls(response)
          :rtype: None
          :raises: ~azure.core.exceptions.HttpResponseError
          """
          cls = kwargs.pop('cls', None)  # type: ClsType[None]
          error_map = {
              401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
          }
          error_map.update(kwargs.pop('error_map', {}))
  
          restype = kwargs.pop('restype', "directory")  # type: str
          comp = kwargs.pop('comp', "metadata")  # type: str
  
          
          request = build_set_metadata_request(
              url=self._config.url,
              restype=restype,
              comp=comp,
              version=self._config.version,
              timeout=timeout,
              metadata=metadata,
              template_url=self.set_metadata.metadata['url'],
          )
          request = _convert_request(request)
          request.url = self._client.format_url(request.url)
  
          pipeline_response = await self._client._pipeline.run(  # pylint: disable=protected-access
              request,
              stream=False,
              **kwargs
          )
          response = pipeline_response.http_response
  
          if response.status_code not in [200]:
              map_error(status_code=response.status_code, response=response, error_map=error_map)
              error = self._deserialize.failsafe_deserialize(_models.StorageError, pipeline_response)
              raise HttpResponseError(response=response, model=error)
  
          response_headers = {}
          response_headers['ETag']=self._deserialize('str', response.headers.get('ETag'))
          response_headers['x-ms-request-id']=self._deserialize('str', response.headers.get('x-ms-request-id'))
          response_headers['x-ms-version']=self._deserialize('str', response.headers.get('x-ms-version'))
          response_headers['Date']=self._deserialize('rfc-1123', response.headers.get('Date'))
          response_headers['x-ms-request-server-encrypted']=self._deserialize('bool', response.headers.get('x-ms-request-server-encrypted'))
  
  
          if cls:
              return cls(pipeline_response, None, response_headers)
  
      set_metadata.metadata = {'url': "{url}/{shareName}/{directory}"}  # type: ignore
  
  
      @distributed_trace_async
      async def list_files_and_directories_segment(
          self,
          prefix: Optional[str] = None,
          sharesnapshot: Optional[str] = None,
          marker: Optional[str] = None,
          maxresults: Optional[int] = None,
          timeout: Optional[int] = None,
          include: Optional[List[Union[str, "_models.ListFilesIncludeType"]]] = None,
          include_extended_info: Optional[bool] = None,
          **kwargs: Any
      ) -> "_models.ListFilesAndDirectoriesSegmentResponse":
          """Returns a list of files or directories under the specified share or directory. It lists the
          contents only for a single level of the directory hierarchy.
  
          :param prefix: Filters the results to return only entries whose name begins with the specified
           prefix. Default value is None.
          :type prefix: str
          :param sharesnapshot: The snapshot parameter is an opaque DateTime value that, when present,
           specifies the share snapshot to query. Default value is None.
          :type sharesnapshot: str
          :param marker: A string value that identifies the portion of the list to be returned with the
           next list operation. The operation returns a marker value within the response body if the list
           returned was not complete. The marker value may then be used in a subsequent call to request
           the next set of list items. The marker value is opaque to the client. Default value is None.
          :type marker: str
          :param maxresults: Specifies the maximum number of entries to return. If the request does not
           specify maxresults, or specifies a value greater than 5,000, the server will return up to 5,000
           items. Default value is None.
          :type maxresults: int
          :param timeout: The timeout parameter is expressed in seconds. For more information, see
           :code:`<a
           href="https://docs.microsoft.com/en-us/rest/api/storageservices/Setting-Timeouts-for-File-Service-Operations?redirectedfrom=MSDN">Setting
           Timeouts for File Service Operations.</a>`. Default value is None.
          :type timeout: int
          :param include: Include this parameter to specify one or more datasets to include in the
           response. Default value is None.
          :type include: list[str or ~azure.storage.fileshare.models.ListFilesIncludeType]
          :param include_extended_info: Include extended information. Default value is None.
          :type include_extended_info: bool
          :keyword restype: restype. Default value is "directory". Note that overriding this default
           value may result in unsupported behavior.
          :paramtype restype: str
          :keyword comp: comp. Default value is "list". Note that overriding this default value may
           result in unsupported behavior.
          :paramtype comp: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :return: ListFilesAndDirectoriesSegmentResponse, or the result of cls(response)
          :rtype: ~azure.storage.fileshare.models.ListFilesAndDirectoriesSegmentResponse
          :raises: ~azure.core.exceptions.HttpResponseError
          """
          cls = kwargs.pop('cls', None)  # type: ClsType["_models.ListFilesAndDirectoriesSegmentResponse"]
          error_map = {
              401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
          }
          error_map.update(kwargs.pop('error_map', {}))
  
          restype = kwargs.pop('restype', "directory")  # type: str
          comp = kwargs.pop('comp', "list")  # type: str
  
          
          request = build_list_files_and_directories_segment_request(
              url=self._config.url,
              restype=restype,
              comp=comp,
              version=self._config.version,
              prefix=prefix,
              sharesnapshot=sharesnapshot,
              marker=marker,
              maxresults=maxresults,
              timeout=timeout,
              include=include,
              include_extended_info=include_extended_info,
              template_url=self.list_files_and_directories_segment.metadata['url'],
          )
          request = _convert_request(request)
          request.url = self._client.format_url(request.url)
  
          pipeline_response = await self._client._pipeline.run(  # pylint: disable=protected-access
              request,
              stream=False,
              **kwargs
          )
          response = pipeline_response.http_response
  
          if response.status_code not in [200]:
              map_error(status_code=response.status_code, response=response, error_map=error_map)
              error = self._deserialize.failsafe_deserialize(_models.StorageError, pipeline_response)
              raise HttpResponseError(response=response, model=error)
  
          response_headers = {}
          response_headers['Content-Type']=self._deserialize('str', response.headers.get('Content-Type'))
          response_headers['x-ms-request-id']=self._deserialize('str', response.headers.get('x-ms-request-id'))
          response_headers['x-ms-version']=self._deserialize('str', response.headers.get('x-ms-version'))
          response_headers['Date']=self._deserialize('rfc-1123', response.headers.get('Date'))
  
          deserialized = self._deserialize('ListFilesAndDirectoriesSegmentResponse', pipeline_response)
  
          if cls:
              return cls(pipeline_response, deserialized, response_headers)
  
          return deserialized
  
      list_files_and_directories_segment.metadata = {'url': "{url}/{shareName}/{directory}"}  # type: ignore
  
  
      @distributed_trace_async
      async def list_handles(
          self,
          marker: Optional[str] = None,
          maxresults: Optional[int] = None,
          timeout: Optional[int] = None,
          sharesnapshot: Optional[str] = None,
          recursive: Optional[bool] = None,
          **kwargs: Any
      ) -> "_models.ListHandlesResponse":
          """Lists handles for directory.
  
          :param marker: A string value that identifies the portion of the list to be returned with the
           next list operation. The operation returns a marker value within the response body if the list
           returned was not complete. The marker value may then be used in a subsequent call to request
           the next set of list items. The marker value is opaque to the client. Default value is None.
          :type marker: str
          :param maxresults: Specifies the maximum number of entries to return. If the request does not
           specify maxresults, or specifies a value greater than 5,000, the server will return up to 5,000
           items. Default value is None.
          :type maxresults: int
          :param timeout: The timeout parameter is expressed in seconds. For more information, see
           :code:`<a
           href="https://docs.microsoft.com/en-us/rest/api/storageservices/Setting-Timeouts-for-File-Service-Operations?redirectedfrom=MSDN">Setting
           Timeouts for File Service Operations.</a>`. Default value is None.
          :type timeout: int
          :param sharesnapshot: The snapshot parameter is an opaque DateTime value that, when present,
           specifies the share snapshot to query. Default value is None.
          :type sharesnapshot: str
          :param recursive: Specifies operation should apply to the directory specified in the URI, its
           files, its subdirectories and their files. Default value is None.
          :type recursive: bool
          :keyword comp: comp. Default value is "listhandles". Note that overriding this default value
           may result in unsupported behavior.
          :paramtype comp: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :return: ListHandlesResponse, or the result of cls(response)
          :rtype: ~azure.storage.fileshare.models.ListHandlesResponse
          :raises: ~azure.core.exceptions.HttpResponseError
          """
          cls = kwargs.pop('cls', None)  # type: ClsType["_models.ListHandlesResponse"]
          error_map = {
              401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
          }
          error_map.update(kwargs.pop('error_map', {}))
  
          comp = kwargs.pop('comp', "listhandles")  # type: str
  
          
          request = build_list_handles_request(
              url=self._config.url,
              comp=comp,
              version=self._config.version,
              marker=marker,
              maxresults=maxresults,
              timeout=timeout,
              sharesnapshot=sharesnapshot,
              recursive=recursive,
              template_url=self.list_handles.metadata['url'],
          )
          request = _convert_request(request)
          request.url = self._client.format_url(request.url)
  
          pipeline_response = await self._client._pipeline.run(  # pylint: disable=protected-access
              request,
              stream=False,
              **kwargs
          )
          response = pipeline_response.http_response
  
          if response.status_code not in [200]:
              map_error(status_code=response.status_code, response=response, error_map=error_map)
              error = self._deserialize.failsafe_deserialize(_models.StorageError, pipeline_response)
              raise HttpResponseError(response=response, model=error)
  
          response_headers = {}
          response_headers['Content-Type']=self._deserialize('str', response.headers.get('Content-Type'))
          response_headers['x-ms-request-id']=self._deserialize('str', response.headers.get('x-ms-request-id'))
          response_headers['x-ms-version']=self._deserialize('str', response.headers.get('x-ms-version'))
          response_headers['Date']=self._deserialize('rfc-1123', response.headers.get('Date'))
  
          deserialized = self._deserialize('ListHandlesResponse', pipeline_response)
  
          if cls:
              return cls(pipeline_response, deserialized, response_headers)
  
          return deserialized
  
      list_handles.metadata = {'url': "{url}/{shareName}/{directory}"}  # type: ignore
  
  
      @distributed_trace_async
      async def force_close_handles(  # pylint: disable=inconsistent-return-statements
          self,
          handle_id: str,
          timeout: Optional[int] = None,
          marker: Optional[str] = None,
          sharesnapshot: Optional[str] = None,
          recursive: Optional[bool] = None,
          **kwargs: Any
      ) -> None:
          """Closes all handles open for given directory.
  
          :param handle_id: Specifies handle ID opened on the file or directory to be closed. Asterisk
           (‘*’) is a wildcard that specifies all handles.
          :type handle_id: str
          :param timeout: The timeout parameter is expressed in seconds. For more information, see
           :code:`<a
           href="https://docs.microsoft.com/en-us/rest/api/storageservices/Setting-Timeouts-for-File-Service-Operations?redirectedfrom=MSDN">Setting
           Timeouts for File Service Operations.</a>`. Default value is None.
          :type timeout: int
          :param marker: A string value that identifies the portion of the list to be returned with the
           next list operation. The operation returns a marker value within the response body if the list
           returned was not complete. The marker value may then be used in a subsequent call to request
           the next set of list items. The marker value is opaque to the client. Default value is None.
          :type marker: str
          :param sharesnapshot: The snapshot parameter is an opaque DateTime value that, when present,
           specifies the share snapshot to query. Default value is None.
          :type sharesnapshot: str
          :param recursive: Specifies operation should apply to the directory specified in the URI, its
           files, its subdirectories and their files. Default value is None.
          :type recursive: bool
          :keyword comp: comp. Default value is "forceclosehandles". Note that overriding this default
           value may result in unsupported behavior.
          :paramtype comp: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :return: None, or the result of cls(response)
          :rtype: None
          :raises: ~azure.core.exceptions.HttpResponseError
          """
          cls = kwargs.pop('cls', None)  # type: ClsType[None]
          error_map = {
              401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
          }
          error_map.update(kwargs.pop('error_map', {}))
  
          comp = kwargs.pop('comp', "forceclosehandles")  # type: str
  
          
          request = build_force_close_handles_request(
              url=self._config.url,
              comp=comp,
              version=self._config.version,
              handle_id=handle_id,
              timeout=timeout,
              marker=marker,
              sharesnapshot=sharesnapshot,
              recursive=recursive,
              template_url=self.force_close_handles.metadata['url'],
          )
          request = _convert_request(request)
          request.url = self._client.format_url(request.url)
  
          pipeline_response = await self._client._pipeline.run(  # pylint: disable=protected-access
              request,
              stream=False,
              **kwargs
          )
          response = pipeline_response.http_response
  
          if response.status_code not in [200]:
              map_error(status_code=response.status_code, response=response, error_map=error_map)
              error = self._deserialize.failsafe_deserialize(_models.StorageError, pipeline_response)
              raise HttpResponseError(response=response, model=error)
  
          response_headers = {}
          response_headers['x-ms-request-id']=self._deserialize('str', response.headers.get('x-ms-request-id'))
          response_headers['x-ms-version']=self._deserialize('str', response.headers.get('x-ms-version'))
          response_headers['Date']=self._deserialize('rfc-1123', response.headers.get('Date'))
          response_headers['x-ms-marker']=self._deserialize('str', response.headers.get('x-ms-marker'))
          response_headers['x-ms-number-of-handles-closed']=self._deserialize('int', response.headers.get('x-ms-number-of-handles-closed'))
          response_headers['x-ms-number-of-handles-failed']=self._deserialize('int', response.headers.get('x-ms-number-of-handles-failed'))
  
  
          if cls:
              return cls(pipeline_response, None, response_headers)
  
      force_close_handles.metadata = {'url': "{url}/{shareName}/{directory}"}  # type: ignore
  
  
      @distributed_trace_async
      async def rename(  # pylint: disable=inconsistent-return-statements
          self,
          rename_source: str,
          timeout: Optional[int] = None,
          replace_if_exists: Optional[bool] = None,
          ignore_read_only: Optional[bool] = None,
          file_permission: Optional[str] = "inherit",
          file_permission_key: Optional[str] = None,
          metadata: Optional[Dict[str, str]] = None,
          source_lease_access_conditions: Optional["_models.SourceLeaseAccessConditions"] = None,
          destination_lease_access_conditions: Optional["_models.DestinationLeaseAccessConditions"] = None,
          copy_file_smb_info: Optional["_models.CopyFileSmbInfo"] = None,
          **kwargs: Any
      ) -> None:
          """Renames a directory.
  
          :param rename_source: Required. Specifies the URI-style path of the source file, up to 2 KB in
           length.
          :type rename_source: str
          :param timeout: The timeout parameter is expressed in seconds. For more information, see
           :code:`<a
           href="https://docs.microsoft.com/en-us/rest/api/storageservices/Setting-Timeouts-for-File-Service-Operations?redirectedfrom=MSDN">Setting
           Timeouts for File Service Operations.</a>`. Default value is None.
          :type timeout: int
          :param replace_if_exists: Optional. A boolean value for if the destination file already exists,
           whether this request will overwrite the file or not. If true, the rename will succeed and will
           overwrite the destination file. If not provided or if false and the destination file does
           exist, the request will not overwrite the destination file. If provided and the destination
           file doesn’t exist, the rename will succeed. Note: This value does not override the
           x-ms-file-copy-ignore-read-only header value. Default value is None.
          :type replace_if_exists: bool
          :param ignore_read_only: Optional. A boolean value that specifies whether the ReadOnly
           attribute on a preexisting destination file should be respected. If true, the rename will
           succeed, otherwise, a previous file at the destination with the ReadOnly attribute set will
           cause the rename to fail. Default value is None.
          :type ignore_read_only: bool
          :param file_permission: If specified the permission (security descriptor) shall be set for the
           directory/file. This header can be used if Permission size is <= 8KB, else
           x-ms-file-permission-key header shall be used. Default value: Inherit. If SDDL is specified as
           input, it must have owner, group and dacl. Note: Only one of the x-ms-file-permission or
           x-ms-file-permission-key should be specified. Default value is "inherit".
          :type file_permission: str
          :param file_permission_key: Key of the permission to be set for the directory/file. Note: Only
           one of the x-ms-file-permission or x-ms-file-permission-key should be specified. Default value
           is None.
          :type file_permission_key: str
          :param metadata: A name-value pair to associate with a file storage object. Default value is
           None.
          :type metadata: dict[str, str]
          :param source_lease_access_conditions: Parameter group. Default value is None.
          :type source_lease_access_conditions:
           ~azure.storage.fileshare.models.SourceLeaseAccessConditions
          :param destination_lease_access_conditions: Parameter group. Default value is None.
          :type destination_lease_access_conditions:
           ~azure.storage.fileshare.models.DestinationLeaseAccessConditions
          :param copy_file_smb_info: Parameter group. Default value is None.
          :type copy_file_smb_info: ~azure.storage.fileshare.models.CopyFileSmbInfo
          :keyword restype: restype. Default value is "directory". Note that overriding this default
           value may result in unsupported behavior.
          :paramtype restype: str
          :keyword comp: comp. Default value is "rename". Note that overriding this default value may
           result in unsupported behavior.
          :paramtype comp: str
          :keyword callable cls: A custom type or function that will be passed the direct response
          :return: None, or the result of cls(response)
          :rtype: None
          :raises: ~azure.core.exceptions.HttpResponseError
          """
          cls = kwargs.pop('cls', None)  # type: ClsType[None]
          error_map = {
              401: ClientAuthenticationError, 404: ResourceNotFoundError, 409: ResourceExistsError
          }
          error_map.update(kwargs.pop('error_map', {}))
  
          restype = kwargs.pop('restype', "directory")  # type: str
          comp = kwargs.pop('comp', "rename")  # type: str
  
          _source_lease_id = None
          _destination_lease_id = None
          _file_attributes = None
          _file_creation_time = None
          _file_last_write_time = None
          if source_lease_access_conditions is not None:
              _source_lease_id = source_lease_access_conditions.source_lease_id
          if destination_lease_access_conditions is not None:
              _destination_lease_id = destination_lease_access_conditions.destination_lease_id
          if copy_file_smb_info is not None:
              _file_attributes = copy_file_smb_info.file_attributes
              _file_creation_time = copy_file_smb_info.file_creation_time
              _file_last_write_time = copy_file_smb_info.file_last_write_time
  
          request = build_rename_request(
              url=self._config.url,
              restype=restype,
              comp=comp,
              version=self._config.version,
              rename_source=rename_source,
              timeout=timeout,
              replace_if_exists=replace_if_exists,
              ignore_read_only=ignore_read_only,
              source_lease_id=_source_lease_id,
              destination_lease_id=_destination_lease_id,
              file_attributes=_file_attributes,
              file_creation_time=_file_creation_time,
              file_last_write_time=_file_last_write_time,
              file_permission=file_permission,
              file_permission_key=file_permission_key,
              metadata=metadata,
              template_url=self.rename.metadata['url'],
          )
          request = _convert_request(request)
          request.url = self._client.format_url(request.url)
  
          pipeline_response = await self._client._pipeline.run(  # pylint: disable=protected-access
              request,
              stream=False,
              **kwargs
          )
          response = pipeline_response.http_response
  
          if response.status_code not in [200]:
              map_error(status_code=response.status_code, response=response, error_map=error_map)
              error = self._deserialize.failsafe_deserialize(_models.StorageError, pipeline_response)
              raise HttpResponseError(response=response, model=error)
  
          response_headers = {}
          response_headers['ETag']=self._deserialize('str', response.headers.get('ETag'))
          response_headers['Last-Modified']=self._deserialize('rfc-1123', response.headers.get('Last-Modified'))
          response_headers['x-ms-request-id']=self._deserialize('str', response.headers.get('x-ms-request-id'))
          response_headers['x-ms-version']=self._deserialize('str', response.headers.get('x-ms-version'))
          response_headers['Date']=self._deserialize('rfc-1123', response.headers.get('Date'))
          response_headers['x-ms-request-server-encrypted']=self._deserialize('bool', response.headers.get('x-ms-request-server-encrypted'))
          response_headers['x-ms-file-permission-key']=self._deserialize('str', response.headers.get('x-ms-file-permission-key'))
          response_headers['x-ms-file-attributes']=self._deserialize('str', response.headers.get('x-ms-file-attributes'))
          response_headers['x-ms-file-creation-time']=self._deserialize('str', response.headers.get('x-ms-file-creation-time'))
          response_headers['x-ms-file-last-write-time']=self._deserialize('str', response.headers.get('x-ms-file-last-write-time'))
          response_headers['x-ms-file-change-time']=self._deserialize('str', response.headers.get('x-ms-file-change-time'))
          response_headers['x-ms-file-id']=self._deserialize('str', response.headers.get('x-ms-file-id'))
          response_headers['x-ms-file-parent-id']=self._deserialize('str', response.headers.get('x-ms-file-parent-id'))
  
  
          if cls:
              return cls(pipeline_response, None, response_headers)
  
      rename.metadata = {'url': "{url}/{shareName}/{directory}"}  # type: ignore
  
  