text: import json
  import logging
  import os
  import sys
  import tempfile
  import traceback
  
  from fabric.api import lcd
  from sqlalchemy import or_
  
  from galaxy import exceptions, util
  from galaxy.tool_shed.galaxy_install.datatypes import custom_datatype_manager
  from galaxy.tool_shed.galaxy_install.metadata.installed_repository_metadata_manager import InstalledRepositoryMetadataManager
  from galaxy.tool_shed.galaxy_install.repository_dependencies import repository_dependency_manager
  from galaxy.tool_shed.galaxy_install.tool_dependencies.recipe.env_file_builder import EnvFileBuilder
  from galaxy.tool_shed.galaxy_install.tool_dependencies.recipe.install_environment import InstallEnvironment
  from galaxy.tool_shed.galaxy_install.tool_dependencies.recipe.recipe_manager import StepManager
  from galaxy.tool_shed.galaxy_install.tool_dependencies.recipe.recipe_manager import TagManager
  from galaxy.tool_shed.galaxy_install.tools import data_manager, tool_panel_manager
  from galaxy.tool_shed.tools.data_table_manager import ShedToolDataTableManager
  from galaxy.tool_shed.util import (
      basic_util,
      hg_util,
      repository_util,
      shed_util_common as suc,
      tool_dependency_util,
      tool_util
  )
  from galaxy.tool_util.deps import views
  from galaxy.util.tool_shed import common_util, encoding_util, xml_util
  
  log = logging.getLogger(__name__)
  
  
  class InstallToolDependencyManager:
  
      def __init__(self, app):
          self.app = app
          self.install_model = self.app.install_model
          self.INSTALL_ACTIONS = ['download_binary', 'download_by_url', 'download_file',
                                  'setup_perl_environment', 'setup_python_environment',
                                  'setup_r_environment', 'setup_ruby_environment', 'shell_command']
  
      def format_traceback(self):
          ex_type, ex, tb = sys.exc_info()
          return ''.join(traceback.format_tb(tb))
  
      def get_tool_shed_repository_install_dir(self, tool_shed_repository):
          return os.path.abspath(tool_shed_repository.repo_files_directory(self.app))
  
      def install_and_build_package(self, install_environment, tool_dependency, actions_dict):
          """Install a Galaxy tool dependency package either via a url or a mercurial or git clone command."""
          install_dir = actions_dict['install_dir']
          package_name = actions_dict['package_name']
          actions = actions_dict.get('actions', None)
          filtered_actions = []
          env_file_builder = EnvFileBuilder(install_dir)
          step_manager = StepManager(self.app)
          if actions:
              with install_environment.use_tmp_dir() as work_dir:
                  with lcd(work_dir):
                      # The first action in the list of actions will be the one that defines the initial download process.
                      # There are currently three supported actions; download_binary, download_by_url and clone via a
                      # shell_command action type.  The recipe steps will be filtered at this stage in the process, with
                      # the filtered actions being used in the next stage below.  The installation directory (i.e., dir)
                      # is also defined in this stage and is used in the next stage below when defining current_dir.
                      action_type, action_dict = actions[0]
                      if action_type in self.INSTALL_ACTIONS:
                          # Some of the parameters passed here are needed only by a subset of the step handler classes,
                          # but to allow for a standard method signature we'll pass them along.  We don't check the
                          # tool_dependency status in this stage because it should not have been changed based on a
                          # download.
                          tool_dependency, filtered_actions, dir = \
                              step_manager.execute_step(tool_dependency=tool_dependency,
                                                        package_name=package_name,
                                                        actions=actions,
                                                        action_type=action_type,
                                                        action_dict=action_dict,
                                                        filtered_actions=filtered_actions,
                                                        env_file_builder=env_file_builder,
                                                        install_environment=install_environment,
                                                        work_dir=work_dir,
                                                        current_dir=None,
                                                        initial_download=True)
                      else:
                          # We're handling a complex repository dependency where we only have a set_environment tag set.
                          # <action type="set_environment">
                          #    <environment_variable name="PATH" action="prepend_to">$INSTALL_DIR/bin</environment_variable>
                          # </action>
                          filtered_actions = [a for a in actions]
                          dir = install_dir
                      # We're in stage 2 of the installation process.  The package has been down-loaded, so we can
                      # now perform all of the actions defined for building it.
                      for action_tup in filtered_actions:
                          if dir is None:
                              dir = ''
                          current_dir = os.path.abspath(os.path.join(work_dir, dir))
                          with lcd(current_dir):
                              action_type, action_dict = action_tup
                              tool_dependency, tmp_filtered_actions, tmp_dir = \
                                  step_manager.execute_step(tool_dependency=tool_dependency,
                                                            package_name=package_name,
                                                            actions=actions,
                                                            action_type=action_type,
                                                            action_dict=action_dict,
                                                            filtered_actions=filtered_actions,
                                                            env_file_builder=env_file_builder,
                                                            install_environment=install_environment,
                                                            work_dir=work_dir,
                                                            current_dir=current_dir,
                                                            initial_download=False)
                              if tool_dependency.status in [self.install_model.ToolDependency.installation_status.ERROR]:
                                  # If the tool_dependency status is in an error state, return it with no additional
                                  # processing.
                                  return tool_dependency
                              # Make sure to handle the special case where the value of dir is reset (this happens when
                              # the action_type is change_directiory).  In all other action types, dir will be returned as
                              # None.
                              if tmp_dir is not None:
                                  dir = tmp_dir
          return tool_dependency
  
      def install_and_build_package_via_fabric(self, install_environment, tool_shed_repository, tool_dependency, actions_dict):
          try:
              # There is currently only one fabric method.
              tool_dependency = self.install_and_build_package(install_environment, tool_dependency, actions_dict)
          except Exception as e:
              log.exception('Error installing tool dependency %s version %s.', tool_dependency.name, tool_dependency.version)
              # Since there was an installation error, update the tool dependency status to Error. The remove_installation_path option must
              # be left False here.
              error_message = '{}\n{}'.format(self.format_traceback(), util.unicodify(e))
              tool_dependency = tool_dependency_util.set_tool_dependency_attributes(self.app,
                                                                                    tool_dependency=tool_dependency,
                                                                                    status=self.app.install_model.ToolDependency.installation_status.ERROR,
                                                                                    error_message=error_message)
          tool_dependency = self.mark_tool_dependency_installed(tool_dependency)
          return tool_dependency
  
      def install_specified_tool_dependencies(self, tool_shed_repository, tool_dependencies_config, tool_dependencies,
                                              from_tool_migration_manager=False):
          """
          Follow the recipe in the received tool_dependencies_config to install specified packages for
          repository tools.  The received list of tool_dependencies are the database records for those
          dependencies defined in the tool_dependencies_config that are to be installed.  This list may
          be a subset of the set of dependencies defined in the tool_dependencies_config.  This allows
          for filtering out dependencies that have not been checked for installation on the 'Manage tool
          dependencies' page for an installed Tool Shed repository.
          """
          attr_tups_of_dependencies_for_install = [(td.name, td.version, td.type) for td in tool_dependencies]
          installed_packages = []
          tag_manager = TagManager(self.app)
          # Parse the tool_dependencies.xml config.
          tree, error_message = xml_util.parse_xml(tool_dependencies_config)
          if tree is None:
              log.debug("The received tool_dependencies.xml file is likely invalid: %s" % str(error_message))
              return installed_packages
          root = tree.getroot()
          elems = []
          for elem in root:
              if elem.tag == 'set_environment':
                  version = elem.get('version', '1.0')
                  if version != '1.0':
                      raise Exception('The <set_environment> tag must have a version attribute with value 1.0')
                  for sub_elem in elem:
                      elems.append(sub_elem)
              else:
                  elems.append(elem)
          for elem in elems:
              name = elem.get('name', None)
              version = elem.get('version', None)
              type = elem.get('type', None)
              if type is None:
                  if elem.tag in ['environment_variable', 'set_environment']:
                      type = 'set_environment'
                  else:
                      type = 'package'
              if (name and type == 'set_environment') or (name and version):
                  # elem is a package set_environment tag set.
                  attr_tup = (name, version, type)
                  try:
                      index = attr_tups_of_dependencies_for_install.index(attr_tup)
                  except ValueError:
                      index = None
                  if index is not None:
                      tool_dependency = tool_dependencies[index]
                      # If the tool_dependency.type is 'set_environment', then the call to process_tag_set() will
                      # handle everything - no additional installation is necessary.
                      tool_dependency, proceed_with_install, action_elem_tuples = \
                          tag_manager.process_tag_set(tool_shed_repository,
                                                      tool_dependency,
                                                      elem,
                                                      name,
                                                      version,
                                                      from_tool_migration_manager=from_tool_migration_manager,
                                                      tool_dependency_db_records=tool_dependencies)
                      if (tool_dependency.type == 'package' and proceed_with_install):
                          try:
                              tool_dependency = self.install_package(elem,
                                                                     tool_shed_repository,
                                                                     tool_dependencies=tool_dependencies,
                                                                     from_tool_migration_manager=from_tool_migration_manager)
                          except Exception as e:
                              error_message = "Error installing tool dependency %s version %s: %s" % \
                                  (str(name), str(version), str(e))
                              log.exception(error_message)
                              if tool_dependency:
                                  # Since there was an installation error, update the tool dependency status to Error. The
                                  # remove_installation_path option must be left False here.
                                  tool_dependency = \
                                      tool_dependency_util.set_tool_dependency_attributes(self.app,
                                                                                          tool_dependency=tool_dependency,
                                                                                          status=self.app.install_model.ToolDependency.installation_status.ERROR,
                                                                                          error_message=error_message)
                          if tool_dependency and tool_dependency.status in [self.install_model.ToolDependency.installation_status.INSTALLED,
                                                                            self.install_model.ToolDependency.installation_status.ERROR]:
                              installed_packages.append(tool_dependency)
          return installed_packages
  
      def install_via_fabric(self, tool_shed_repository, tool_dependency, install_dir, package_name=None, custom_fabfile_path=None,
                             actions_elem=None, action_elem=None, **kwd):
          """
          Parse a tool_dependency.xml file's <actions> tag set to gather information for installation using
          self.install_and_build_package().  The use of fabric is being eliminated, so some of these functions
          may need to be renamed at some point.
          """
          if not os.path.exists(install_dir):
              os.makedirs(install_dir)
          actions_dict = dict(install_dir=install_dir)
          if package_name:
              actions_dict['package_name'] = package_name
          actions = []
          is_binary_download = False
          if actions_elem is not None:
              elems = actions_elem
              if elems.get('os') is not None and elems.get('architecture') is not None:
                  is_binary_download = True
          elif action_elem is not None:
              # We were provided with a single <action> element to perform certain actions after a platform-specific tarball was downloaded.
              elems = [action_elem]
          else:
              elems = []
          step_manager = StepManager(self.app)
          tool_shed_repository_install_dir = self.get_tool_shed_repository_install_dir(tool_shed_repository)
          install_environment = InstallEnvironment(self.app, tool_shed_repository_install_dir, install_dir)
          for action_elem in elems:
              # Make sure to skip all comments, since they are now included in the XML tree.
              if action_elem.tag != 'action':
                  continue
              action_dict = {}
              action_type = action_elem.get('type', None)
              if action_type is not None:
                  action_dict = step_manager.prepare_step(tool_dependency=tool_dependency,
                                                          action_type=action_type,
                                                          action_elem=action_elem,
                                                          action_dict=action_dict,
                                                          install_environment=install_environment,
                                                          is_binary_download=is_binary_download)
                  action_tuple = (action_type, action_dict)
                  if action_type == 'set_environment':
                      if action_tuple not in actions:
                          actions.append(action_tuple)
                  else:
                      actions.append(action_tuple)
          if actions:
              actions_dict['actions'] = actions
          if custom_fabfile_path is not None:
              # TODO: this is not yet supported or functional, but when it is handle it using the fabric api.
              raise Exception('Tool dependency installation using proprietary fabric scripts is not yet supported.')
          else:
              tool_dependency = self.install_and_build_package_via_fabric(install_environment,
                                                                          tool_shed_repository,
                                                                          tool_dependency,
                                                                          actions_dict)
          return tool_dependency
  
      def install_package(self, elem, tool_shed_repository, tool_dependencies=None, from_tool_migration_manager=False):
          """
          Install a tool dependency package defined by the XML element elem.  The value of tool_dependencies is
          a partial or full list of ToolDependency records associated with the tool_shed_repository.
          """
          tag_manager = TagManager(self.app)
          # The value of package_name should match the value of the "package" type in the tool config's
          # <requirements> tag set, but it's not required.
          package_name = elem.get('name', None)
          package_version = elem.get('version', None)
          if tool_dependencies and package_name and package_version:
              tool_dependency = None
              for tool_dependency in tool_dependencies:
                  if package_name == str(tool_dependency.name) and package_version == str(tool_dependency.version):
                      break
              if tool_dependency is not None:
                  for package_elem in elem:
                      tool_dependency, proceed_with_install, actions_elem_tuples = \
                          tag_manager.process_tag_set(tool_shed_repository,
                                                      tool_dependency,
                                                      package_elem,
                                                      package_name,
                                                      package_version,
                                                      from_tool_migration_manager=from_tool_migration_manager,
                                                      tool_dependency_db_records=None)
                      if proceed_with_install and actions_elem_tuples:
                          # Get the installation directory for tool dependencies that will be installed for the received
                          # tool_shed_repository.
                          install_dir = \
                              tool_dependency_util.get_tool_dependency_install_dir(app=self.app,
                                                                                   repository_name=tool_shed_repository.name,
                                                                                   repository_owner=tool_shed_repository.owner,
                                                                                   repository_changeset_revision=tool_shed_repository.installed_changeset_revision,
                                                                                   tool_dependency_type='package',
                                                                                   tool_dependency_name=package_name,
                                                                                   tool_dependency_version=package_version)
                          # At this point we have a list of <actions> elems that are either defined within an <actions_group>
                          # tag set with <actions> sub-elements that contains os and architecture attributes filtered by the
                          # platform into which the appropriate compiled binary will be installed, or not defined within an
                          # <actions_group> tag set and not filtered.  Here is an example actions_elem_tuple.
                          # [(True, [<Element 'actions' at 0x109293d10>)]
                          binary_installed = False
                          for actions_elem_tuple in actions_elem_tuples:
                              in_actions_group, actions_elems = actions_elem_tuple
                              if in_actions_group:
                                  # Platform matching is only performed inside <actions_group> tag sets, os and architecture
                                  # attributes are otherwise ignored.
                                  can_install_from_source = False
                                  for actions_elem in actions_elems:
                                      system = actions_elem.get('os')
                                      architecture = actions_elem.get('architecture')
                                      # If this <actions> element has the os and architecture attributes defined, then we only
                                      # want to process until a successful installation is achieved.
                                      if system and architecture:
                                          # If an <actions> tag has been defined that matches our current platform, and the
                                          # recipe specified within that <actions> tag has been successfully processed, skip
                                          # any remaining platform-specific <actions> tags.  We cannot break out of the loop
                                          # here because there may be <action> tags at the end of the <actions_group> tag set
                                          # that must be processed.
                                          if binary_installed:
                                              continue
                                          # No platform-specific <actions> recipe has yet resulted in a successful installation.
                                          tool_dependency = self.install_via_fabric(tool_shed_repository,
                                                                                    tool_dependency,
                                                                                    install_dir,
                                                                                    package_name=package_name,
                                                                                    actions_elem=actions_elem,
                                                                                    action_elem=None)
                                          if tool_dependency.status == self.install_model.ToolDependency.installation_status.INSTALLED:
                                              # If an <actions> tag was found that matches the current platform, and
                                              # self.install_via_fabric() did not result in an error state, set binary_installed
                                              # to True in order to skip any remaining platform-specific <actions> tags.
                                              binary_installed = True
                                          else:
                                              # Process the next matching <actions> tag, or any defined <actions> tags that do not
                                              # contain platform dependent recipes.
                                              log.debug('Error downloading binary for tool dependency %s version %s: %s' %
                                                        (str(package_name), str(package_version), str(tool_dependency.error_message)))
                                      else:
                                          if actions_elem.tag == 'actions':
                                              # We've reached an <actions> tag that defines the recipe for installing and compiling from
                                              # source.  If binary installation failed, we proceed with the recipe.
                                              if not binary_installed:
                                                  installation_directory = tool_dependency.installation_directory(self.app)
                                                  if os.path.exists(installation_directory):
                                                      # Delete contents of installation directory if attempt at binary installation failed.
                                                      installation_directory_contents = os.listdir(installation_directory)
                                                      if installation_directory_contents:
                                                          removed, error_message = \
                                                              tool_dependency_util.remove_tool_dependency(self.app, tool_dependency)
                                                          if removed:
                                                              can_install_from_source = True
                                                          else:
                                                              log.debug('Error removing old files from installation directory %s: %s' %
                                                                        (str(installation_directory, str(error_message))))
                                                      else:
                                                          can_install_from_source = True
                                                  else:
                                                      can_install_from_source = True
                                              if can_install_from_source:
                                                  # We now know that binary installation was not successful, so proceed with the <actions>
                                                  # tag set that defines the recipe to install and compile from source.
                                                  log.debug('Proceeding with install and compile recipe for tool dependency %s.' %
                                                            str(tool_dependency.name))
                                                  # Reset above error to installing
                                                  tool_dependency.status = self.install_model.ToolDependency.installation_status.INSTALLING
                                                  tool_dependency = self.install_via_fabric(tool_shed_repository,
                                                                                            tool_dependency,
                                                                                            install_dir,
                                                                                            package_name=package_name,
                                                                                            actions_elem=actions_elem,
                                                                                            action_elem=None)
                                      if actions_elem.tag == 'action' and \
                                              tool_dependency.status != self.install_model.ToolDependency.installation_status.ERROR:
                                          # If the tool dependency is not in an error state, perform any final actions that have been
                                          # defined within the actions_group tag set, but outside of an <actions> tag, which defines
                                          # the recipe for installing and compiling from source.
                                          tool_dependency = self.install_via_fabric(tool_shed_repository,
                                                                                    tool_dependency,
                                                                                    install_dir,
                                                                                    package_name=package_name,
                                                                                    actions_elem=None,
                                                                                    action_elem=actions_elem)
                              else:
                                  # Checks for "os" and "architecture" attributes  are not made for any <actions> tag sets outside of
                                  # an <actions_group> tag set.  If the attributes are defined, they will be ignored. All <actions> tags
                                  # outside of an <actions_group> tag set will always be processed.
                                  tool_dependency = self.install_via_fabric(tool_shed_repository,
                                                                            tool_dependency,
                                                                            install_dir,
                                                                            package_name=package_name,
                                                                            actions_elem=actions_elems,
                                                                            action_elem=None)
                                  if tool_dependency.status != self.install_model.ToolDependency.installation_status.ERROR:
                                      log.debug('Tool dependency %s version %s has been installed in %s.' %
                                                (str(package_name), str(package_version), str(install_dir)))
          return tool_dependency
  
      def mark_tool_dependency_installed(self, tool_dependency):
          if tool_dependency.status not in [self.install_model.ToolDependency.installation_status.ERROR,
                                            self.install_model.ToolDependency.installation_status.INSTALLED]:
              log.debug('Changing status for tool dependency %s from %s to %s.' %
                        (str(tool_dependency.name),
                         str(tool_dependency.status),
                         str(self.install_model.ToolDependency.installation_status.INSTALLED)))
              status = self.install_model.ToolDependency.installation_status.INSTALLED
              tool_dependency = tool_dependency_util.set_tool_dependency_attributes(self.app,
                                                                                    tool_dependency=tool_dependency,
                                                                                    status=status)
          return tool_dependency
  
  
  class InstallRepositoryManager:
  
      def __init__(self, app, tpm=None):
          self.app = app
          self.install_model = self.app.install_model
          self._view = views.DependencyResolversView(app)
          if tpm is None:
              self.tpm = tool_panel_manager.ToolPanelManager(self.app)
          else:
              self.tpm = tpm
  
      def get_repository_components_for_installation(self, encoded_tsr_id, encoded_tsr_ids, repo_info_dicts,
                                                     tool_panel_section_keys):
          """
          The received encoded_tsr_ids, repo_info_dicts, and
          tool_panel_section_keys are 3 lists that contain associated elements
          at each location in the list.  This method will return the elements
          from repo_info_dicts and tool_panel_section_keys associated with the
          received encoded_tsr_id by determining its location in the received
          encoded_tsr_ids list.
          """
          for tsr_id, repo_info_dict, tool_panel_section_key in zip(encoded_tsr_ids,
                                                                    repo_info_dicts,
                                                                    tool_panel_section_keys):
              if tsr_id == encoded_tsr_id:
                  return repo_info_dict, tool_panel_section_key
          return None, None
  
      def __get_install_info_from_tool_shed(self, tool_shed_url, name, owner, changeset_revision):
          params = dict(name=name,
                        owner=owner,
                        changeset_revision=changeset_revision)
          pathspec = ['api', 'repositories', 'get_repository_revision_install_info']
          try:
              raw_text = util.url_get(tool_shed_url, auth=self.app.tool_shed_registry.url_auth(tool_shed_url), pathspec=pathspec, params=params)
          except Exception:
              message = "Error attempting to retrieve installation information from tool shed "
              message += "%s for revision %s of repository %s owned by %s" % \
                  (tool_shed_url, changeset_revision, name, owner)
              log.exception(message)
              raise exceptions.InternalServerError(message)
          if raw_text:
              # If successful, the response from get_repository_revision_install_info will be 3
              # dictionaries, a dictionary defining the Repository, a dictionary defining the
              # Repository revision (RepositoryMetadata), and a dictionary including the additional
              # information required to install the repository.
              items = json.loads(util.unicodify(raw_text))
              repository_revision_dict = items[1]
              repo_info_dict = items[2]
          else:
              message = "Unable to retrieve installation information from tool shed %s for revision %s of repository %s owned by %s" % \
                  (str(tool_shed_url), str(changeset_revision), str(name), str(owner))
              log.warning(message)
              raise exceptions.InternalServerError(message)
          # Make sure the tool shed returned everything we need for installing the repository.
          if not repository_revision_dict or not repo_info_dict:
              invalid_parameter_message = "No information is available for the requested repository revision.\n"
              invalid_parameter_message += "One or more of the following parameter values is likely invalid:\n"
              invalid_parameter_message += "tool_shed_url: %s\n" % tool_shed_url
              invalid_parameter_message += "name: %s\n" % name
              invalid_parameter_message += "owner: %s\n" % owner
              invalid_parameter_message += "changeset_revision: %s\n" % changeset_revision
              raise exceptions.RequestParameterInvalidException(invalid_parameter_message)
          repo_info_dicts = [repo_info_dict]
          return repository_revision_dict, repo_info_dicts
  
      def __handle_repository_contents(self, tool_shed_repository, tool_path, repository_clone_url, relative_install_dir,
                                       tool_shed=None, tool_section=None, shed_tool_conf=None, reinstalling=False,
                                       tool_panel_section_mapping={}):
          """
          Generate the metadata for the installed tool shed repository, among other things.
          This method is called when an administrator is installing a new repository or
          reinstalling an uninstalled repository.
          """
          shed_config_dict = self.app.toolbox.get_shed_config_dict_by_filename(shed_tool_conf)
          stdtm = ShedToolDataTableManager(self.app)
          irmm = InstalledRepositoryMetadataManager(app=self.app,
                                                    tpm=self.tpm,
                                                    repository=tool_shed_repository,
                                                    changeset_revision=tool_shed_repository.changeset_revision,
                                                    repository_clone_url=repository_clone_url,
                                                    shed_config_dict=shed_config_dict,
                                                    relative_install_dir=relative_install_dir,
                                                    repository_files_dir=None,
                                                    resetting_all_metadata_on_repository=False,
                                                    updating_installed_repository=False,
                                                    persist=True)
          irmm.generate_metadata_for_changeset_revision()
          irmm_metadata_dict = irmm.get_metadata_dict()
          tool_shed_repository.metadata = irmm_metadata_dict
          # Update the tool_shed_repository.tool_shed_status column in the database.
          tool_shed_status_dict = repository_util.get_tool_shed_status_for_installed_repository(self.app, tool_shed_repository)
          if tool_shed_status_dict:
              tool_shed_repository.tool_shed_status = tool_shed_status_dict
          self.install_model.context.add(tool_shed_repository)
          self.install_model.context.flush()
          if 'tool_dependencies' in irmm_metadata_dict and not reinstalling:
              tool_dependency_util.create_tool_dependency_objects(self.app,
                                                                  tool_shed_repository,
                                                                  relative_install_dir,
                                                                  set_status=True)
          if 'sample_files' in irmm_metadata_dict:
              sample_files = irmm_metadata_dict.get('sample_files', [])
              tool_index_sample_files = stdtm.get_tool_index_sample_files(sample_files)
              tool_data_table_conf_filename, tool_data_table_elems = \
                  stdtm.install_tool_data_tables(tool_shed_repository, tool_index_sample_files)
              if tool_data_table_elems:
                  self.app.tool_data_tables.add_new_entries_from_config_file(tool_data_table_conf_filename,
                                                                             None,
                                                                             self.app.config.shed_tool_data_table_config,
                                                                             persist=True)
          if 'tools' in irmm_metadata_dict:
              tool_panel_dict = self.tpm.generate_tool_panel_dict_for_new_install(irmm_metadata_dict['tools'], tool_section)
              sample_files = irmm_metadata_dict.get('sample_files', [])
              tool_index_sample_files = stdtm.get_tool_index_sample_files(sample_files)
              tool_util.copy_sample_files(self.app, tool_index_sample_files, tool_path=tool_path)
              sample_files_copied = [str(s) for s in tool_index_sample_files]
              repository_tools_tups = irmm.get_repository_tools_tups()
              if repository_tools_tups:
                  # Handle missing data table entries for tool parameters that are dynamically generated select lists.
                  repository_tools_tups = stdtm.handle_missing_data_table_entry(relative_install_dir,
                                                                               tool_path,
                                                                               repository_tools_tups)
                  # Handle missing index files for tool parameters that are dynamically generated select lists.
                  repository_tools_tups, sample_files_copied = tool_util.handle_missing_index_file(self.app,
                                                                                                   tool_path,
                                                                                                   sample_files,
                                                                                                   repository_tools_tups,
                                                                                                   sample_files_copied)
                  # Copy remaining sample files included in the repository to the ~/tool-data directory of the
                  # local Galaxy instance.
                  tool_util.copy_sample_files(self.app,
                                              sample_files,
                                              tool_path=tool_path,
                                              sample_files_copied=sample_files_copied)
                  self.tpm.add_to_tool_panel(repository_name=tool_shed_repository.name,
                                             repository_clone_url=repository_clone_url,
                                             changeset_revision=tool_shed_repository.installed_changeset_revision,
                                             repository_tools_tups=repository_tools_tups,
                                             owner=tool_shed_repository.owner,
                                             shed_tool_conf=shed_tool_conf,
                                             tool_panel_dict=tool_panel_dict,
                                             new_install=True,
                                             tool_panel_section_mapping=tool_panel_section_mapping)
          if 'data_manager' in irmm_metadata_dict:
              dmh = data_manager.DataManagerHandler(self.app)
              dmh.install_data_managers(self.app.config.shed_data_manager_config_file,
                                        irmm_metadata_dict,
                                        shed_config_dict,
                                        relative_install_dir,
                                        tool_shed_repository,
                                        repository_tools_tups)
          if 'datatypes' in irmm_metadata_dict:
              self.update_tool_shed_repository_status(tool_shed_repository,
                                                      self.install_model.ToolShedRepository.installation_status.LOADING_PROPRIETARY_DATATYPES)
              if not tool_shed_repository.includes_datatypes:
                  tool_shed_repository.includes_datatypes = True
              self.install_model.context.add(tool_shed_repository)
              self.install_model.context.flush()
              files_dir = relative_install_dir
              if shed_config_dict.get('tool_path'):
                  files_dir = os.path.join(shed_config_dict['tool_path'], files_dir)
              datatypes_config = hg_util.get_config_from_disk(suc.DATATYPES_CONFIG_FILENAME, files_dir)
              # Load data types required by tools.
              cdl = custom_datatype_manager.CustomDatatypeLoader(self.app)
              converter_path, display_path = \
                  cdl.alter_config_and_load_prorietary_datatypes(datatypes_config, files_dir, override=False)
              if converter_path or display_path:
                  # Create a dictionary of tool shed repository related information.
                  repository_dict = \
                      cdl.create_repository_dict_for_proprietary_datatypes(tool_shed=tool_shed,
                                                                           name=tool_shed_repository.name,
                                                                           owner=tool_shed_repository.owner,
                                                                           installed_changeset_revision=tool_shed_repository.installed_changeset_revision,
                                                                           tool_dicts=irmm_metadata_dict.get('tools', []),
                                                                           converter_path=converter_path,
                                                                           display_path=display_path)
              if converter_path:
                  # Load proprietary datatype converters
                  self.app.datatypes_registry.load_datatype_converters(self.app.toolbox, installed_repository_dict=repository_dict, use_cached=True)
              if display_path:
                  # Load proprietary datatype display applications
                  self.app.datatypes_registry.load_display_applications(self.app, installed_repository_dict=repository_dict)
  
      def handle_tool_shed_repositories(self, installation_dict):
          # The following installation_dict entries are all required.
          install_repository_dependencies = installation_dict['install_repository_dependencies']
          new_tool_panel_section_label = installation_dict['new_tool_panel_section_label']
          no_changes_checked = installation_dict['no_changes_checked']
          repo_info_dicts = installation_dict['repo_info_dicts']
          tool_panel_section_id = installation_dict['tool_panel_section_id']
          tool_path = installation_dict['tool_path']
          tool_shed_url = installation_dict['tool_shed_url']
          rdim = repository_dependency_manager.RepositoryDependencyInstallManager(self.app)
          created_or_updated_tool_shed_repositories, tool_panel_section_keys, repo_info_dicts, filtered_repo_info_dicts = \
              rdim.create_repository_dependency_objects(tool_path=tool_path,
                                                        tool_shed_url=tool_shed_url,
                                                        repo_info_dicts=repo_info_dicts,
                                                        install_repository_dependencies=install_repository_dependencies,
                                                        no_changes_checked=no_changes_checked,
                                                        tool_panel_section_id=tool_panel_section_id,
                                                        new_tool_panel_section_label=new_tool_panel_section_label)
          return created_or_updated_tool_shed_repositories, tool_panel_section_keys, repo_info_dicts, filtered_repo_info_dicts
  
      def initiate_repository_installation(self, installation_dict):
          # The following installation_dict entries are all required.
          created_or_updated_tool_shed_repositories = installation_dict['created_or_updated_tool_shed_repositories']
          filtered_repo_info_dicts = installation_dict['filtered_repo_info_dicts']
          has_repository_dependencies = installation_dict['has_repository_dependencies']
          includes_tool_dependencies = installation_dict['includes_tool_dependencies']
          includes_tools = installation_dict['includes_tools']
          includes_tools_for_display_in_tool_panel = installation_dict['includes_tools_for_display_in_tool_panel']
          install_repository_dependencies = installation_dict['install_repository_dependencies']
          install_resolver_dependencies = installation_dict['install_resolver_dependencies']
          install_tool_dependencies = installation_dict['install_tool_dependencies']
          message = installation_dict['message']
          new_tool_panel_section_label = installation_dict['new_tool_panel_section_label']
          shed_tool_conf = installation_dict['shed_tool_conf']
          status = installation_dict['status']
          tool_panel_section_id = installation_dict['tool_panel_section_id']
          tool_panel_section_keys = installation_dict['tool_panel_section_keys']
          tool_panel_section_mapping = installation_dict.get('tool_panel_section_mapping', {})
          tool_path = installation_dict['tool_path']
          tool_shed_url = installation_dict['tool_shed_url']
          # Handle contained tools.
          if includes_tools_for_display_in_tool_panel and (new_tool_panel_section_label or tool_panel_section_id):
              self.tpm.handle_tool_panel_section(self.app.toolbox,
                                                 tool_panel_section_id=tool_panel_section_id,
                                                 new_tool_panel_section_label=new_tool_panel_section_label)
          if includes_tools_for_display_in_tool_panel and (tool_panel_section_mapping is not None):
              for tool_guid in tool_panel_section_mapping:
                  if tool_panel_section_mapping[tool_guid]['action'] == 'create':
                      new_tool_panel_section_name = tool_panel_section_mapping[tool_guid]['tool_panel_section']
                      log.debug('Creating tool panel section "{}" for tool {}'.format(new_tool_panel_section_name, tool_guid))
                      self.tpm.handle_tool_panel_section(self.app.toolbox, None, tool_panel_section_mapping[tool_guid]['tool_panel_section'])
          encoded_repository_ids = [self.app.security.encode_id(tsr.id) for tsr in created_or_updated_tool_shed_repositories]
          new_kwd = dict(includes_tools=includes_tools,
                         includes_tools_for_display_in_tool_panel=includes_tools_for_display_in_tool_panel,
                         has_repository_dependencies=has_repository_dependencies,
                         install_repository_dependencies=install_repository_dependencies,
                         includes_tool_dependencies=includes_tool_dependencies,
                         install_resolver_dependencies=install_resolver_dependencies,
                         install_tool_dependencies=install_tool_dependencies,
                         message=message,
                         repo_info_dicts=filtered_repo_info_dicts,
                         shed_tool_conf=shed_tool_conf,
                         status=status,
                         tool_path=tool_path,
                         tool_panel_section_keys=tool_panel_section_keys,
                         tool_shed_repository_ids=encoded_repository_ids,
                         tool_shed_url=tool_shed_url)
          encoded_kwd = encoding_util.tool_shed_encode(new_kwd)
          tsr_ids = [r.id for r in created_or_updated_tool_shed_repositories]
          tool_shed_repositories = []
          for tsr_id in tsr_ids:
              tsr = self.install_model.context.query(self.install_model.ToolShedRepository).get(tsr_id)
              tool_shed_repositories.append(tsr)
          clause_list = []
          for tsr_id in tsr_ids:
              clause_list.append(self.install_model.ToolShedRepository.table.c.id == tsr_id)
          query = self.install_model.context.query(self.install_model.ToolShedRepository).filter(or_(*clause_list))
          return encoded_kwd, query, tool_shed_repositories, encoded_repository_ids
  
      def install(self, tool_shed_url, name, owner, changeset_revision, install_options):
          # Get all of the information necessary for installing the repository from the specified tool shed.
          repository_revision_dict, repo_info_dicts = self.__get_install_info_from_tool_shed(tool_shed_url,
                                                                                             name,
                                                                                             owner,
                                                                                             changeset_revision)
          if changeset_revision != repository_revision_dict['changeset_revision']:
              # Demanded installation of a non-installable revision. Stop here if repository already installed.
              repo = repository_util.get_installed_repository(
                  app=self.app,
                  tool_shed=tool_shed_url,
                  name=name,
                  owner=owner,
                  changeset_revision=repository_revision_dict['changeset_revision'],
              )
              if repo and repo.is_installed:
                  # Repo installed. Returning empty list indicated repo already installed.
                  return []
          installed_tool_shed_repositories = self.__initiate_and_install_repositories(
              tool_shed_url,
              repository_revision_dict,
              repo_info_dicts,
              install_options
          )
          return installed_tool_shed_repositories
  
      def __initiate_and_install_repositories(self, tool_shed_url, repository_revision_dict, repo_info_dicts, install_options):
          try:
              has_repository_dependencies = repository_revision_dict['has_repository_dependencies']
          except KeyError:
              raise exceptions.InternalServerError("Tool shed response missing required parameter 'has_repository_dependencies'.")
          try:
              includes_tools = repository_revision_dict['includes_tools']
          except KeyError:
              raise exceptions.InternalServerError("Tool shed response missing required parameter 'includes_tools'.")
          try:
              includes_tool_dependencies = repository_revision_dict['includes_tool_dependencies']
          except KeyError:
              raise exceptions.InternalServerError("Tool shed response missing required parameter 'includes_tool_dependencies'.")
          try:
              includes_tools_for_display_in_tool_panel = repository_revision_dict['includes_tools_for_display_in_tool_panel']
          except KeyError:
              raise exceptions.InternalServerError("Tool shed response missing required parameter 'includes_tools_for_display_in_tool_panel'.")
          # Get the information about the Galaxy components (e.g., tool panel section, tool config file, etc) that will contain the repository information.
          install_repository_dependencies = install_options.get('install_repository_dependencies', False)
          install_resolver_dependencies = install_options.get('install_resolver_dependencies', False)
          install_tool_dependencies = install_options.get('install_tool_dependencies', False)
          new_tool_panel_section_label = install_options.get('new_tool_panel_section_label', '')
          tool_panel_section_mapping = install_options.get('tool_panel_section_mapping', {})
          shed_tool_conf = install_options.get('shed_tool_conf')
          if install_tool_dependencies and self.app.tool_dependency_dir is None:
              raise exceptions.ConfigDoesNotAllowException("Tool dependency installation is disabled in your configuration files.")
          if shed_tool_conf:
              # Get the tool_path setting.
              shed_config_dict = self.tpm.get_shed_tool_conf_dict(shed_tool_conf)
          else:
              shed_config_dict = self.app.toolbox.default_shed_tool_conf_dict()
          shed_tool_conf = shed_config_dict['config_filename']
          tool_path = shed_config_dict['tool_path']
          tool_panel_section_id = self.app.toolbox.find_section_id(install_options.get('tool_panel_section_id', ''))
          # Build the dictionary of information necessary for creating tool_shed_repository database records
          # for each repository being installed.
          installation_dict = dict(install_repository_dependencies=install_repository_dependencies,
                                   new_tool_panel_section_label=new_tool_panel_section_label,
                                   tool_panel_section_mapping=tool_panel_section_mapping,
                                   no_changes_checked=False,
                                   repo_info_dicts=repo_info_dicts,
                                   tool_panel_section_id=tool_panel_section_id,
                                   tool_path=tool_path,
                                   tool_shed_url=tool_shed_url)
          # Create the tool_shed_repository database records and gather additional information for repository installation.
          created_or_updated_tool_shed_repositories, tool_panel_section_keys, repo_info_dicts, filtered_repo_info_dicts = \
              self.handle_tool_shed_repositories(installation_dict)
          if created_or_updated_tool_shed_repositories:
              # Build the dictionary of information necessary for installing the repositories.
              installation_dict = dict(created_or_updated_tool_shed_repositories=created_or_updated_tool_shed_repositories,
                                       filtered_repo_info_dicts=filtered_repo_info_dicts,
                                       has_repository_dependencies=has_repository_dependencies,
                                       includes_tool_dependencies=includes_tool_dependencies,
                                       includes_tools=includes_tools,
                                       includes_tools_for_display_in_tool_panel=includes_tools_for_display_in_tool_panel,
                                       install_repository_dependencies=install_repository_dependencies,
                                       install_resolver_dependencies=install_resolver_dependencies,
                                       install_tool_dependencies=install_tool_dependencies,
                                       message='',
                                       new_tool_panel_section_label=new_tool_panel_section_label,
                                       shed_tool_conf=shed_tool_conf,
                                       status='done',
                                       tool_panel_section_id=tool_panel_section_id,
                                       tool_panel_section_keys=tool_panel_section_keys,
                                       tool_panel_section_mapping=tool_panel_section_mapping,
                                       tool_path=tool_path,
                                       tool_shed_url=tool_shed_url)
              # Prepare the repositories for installation.  Even though this
              # method receives a single combination of tool_shed_url, name,
              # owner and changeset_revision, there may be multiple repositories
              # for installation at this point because repository dependencies
              # may have added additional repositories for installation along
              # with the single specified repository.
              encoded_kwd, query, tool_shed_repositories, encoded_repository_ids = \
                  self.initiate_repository_installation(installation_dict)
              # Some repositories may have repository dependencies that are
              # required to be installed before the dependent repository, so
              # we'll order the list of tsr_ids to ensure all repositories
              # install in the required order.
              tsr_ids = [self.app.security.encode_id(tool_shed_repository.id) for tool_shed_repository in tool_shed_repositories]
  
              decoded_kwd = dict(
                  shed_tool_conf=shed_tool_conf,
                  tool_path=tool_path,
                  tool_panel_section_keys=tool_panel_section_keys,
                  repo_info_dicts=filtered_repo_info_dicts,
                  install_resolver_dependencies=install_resolver_dependencies,
                  install_tool_dependencies=install_tool_dependencies,
                  tool_panel_section_mapping=tool_panel_section_mapping,
              )
              return self.install_repositories(tsr_ids, decoded_kwd, reinstalling=False, install_options=install_options)
  
      def install_repositories(self, tsr_ids, decoded_kwd, reinstalling, install_options=None):
          shed_tool_conf = decoded_kwd.get('shed_tool_conf', '')
          tool_path = decoded_kwd['tool_path']
          tool_panel_section_keys = util.listify(decoded_kwd['tool_panel_section_keys'])
          tool_panel_section_mapping = decoded_kwd.get('tool_panel_section_mapping', {})
          repo_info_dicts = util.listify(decoded_kwd['repo_info_dicts'])
          install_resolver_dependencies = decoded_kwd['install_resolver_dependencies']
          install_tool_dependencies = decoded_kwd['install_tool_dependencies']
          filtered_repo_info_dicts = []
          filtered_tool_panel_section_keys = []
          repositories_for_installation = []
          # Some repositories may have repository dependencies that are required to be installed before the
          # dependent repository, so we'll order the list of tsr_ids to ensure all repositories install in the
          # required order.
          ordered_tsr_ids, ordered_repo_info_dicts, ordered_tool_panel_section_keys = \
              self.order_components_for_installation(tsr_ids,
                                                     repo_info_dicts,
                                                     tool_panel_section_keys=tool_panel_section_keys)
          for tsr_id in ordered_tsr_ids:
              repository = self.install_model.context.query(self.install_model.ToolShedRepository) \
                  .get(self.app.security.decode_id(tsr_id))
              if repository.status in [self.install_model.ToolShedRepository.installation_status.NEW,
                                       self.install_model.ToolShedRepository.installation_status.UNINSTALLED]:
                  repositories_for_installation.append(repository)
                  repo_info_dict, tool_panel_section_key = \
                      self.get_repository_components_for_installation(tsr_id,
                                                                      ordered_tsr_ids,
                                                                      ordered_repo_info_dicts,
                                                                      ordered_tool_panel_section_keys)
                  filtered_repo_info_dicts.append(repo_info_dict)
                  filtered_tool_panel_section_keys.append(tool_panel_section_key)
  
          installed_tool_shed_repositories = []
          if repositories_for_installation:
              for tool_shed_repository, repo_info_dict, tool_panel_section_key in zip(repositories_for_installation,
                                                                                      filtered_repo_info_dicts,
                                                                                      filtered_tool_panel_section_keys):
                  self.install_tool_shed_repository(tool_shed_repository,
                                                    repo_info_dict=repo_info_dict,
                                                    tool_panel_section_key=tool_panel_section_key,
                                                    shed_tool_conf=shed_tool_conf,
                                                    tool_path=tool_path,
                                                    install_resolver_dependencies=install_resolver_dependencies,
                                                    install_tool_dependencies=install_tool_dependencies,
                                                    reinstalling=reinstalling,
                                                    tool_panel_section_mapping=tool_panel_section_mapping)
                  installed_tool_shed_repositories.append(tool_shed_repository)
          else:
              raise RepositoriesInstalledException()
          return installed_tool_shed_repositories
  
      def install_tool_shed_repository(self, tool_shed_repository, repo_info_dict, tool_panel_section_key, shed_tool_conf, tool_path,
                                       install_resolver_dependencies, install_tool_dependencies, reinstalling=False,
                                       tool_panel_section_mapping={}, install_options=None):
          self.app.install_model.context.flush()
          if tool_panel_section_key:
              _, tool_section = self.app.toolbox.get_section(tool_panel_section_key)
              if tool_section is None:
                  log.debug('Invalid tool_panel_section_key "%s" specified.  Tools will be loaded outside of sections in the tool panel.',
                            str(tool_panel_section_key))
          else:
              tool_section = None
          if isinstance(repo_info_dict, str):
              repo_info_dict = encoding_util.tool_shed_decode(repo_info_dict)
          repo_info_tuple = repo_info_dict[tool_shed_repository.name]
          description, repository_clone_url, changeset_revision, ctx_rev, repository_owner, repository_dependencies, tool_dependencies = repo_info_tuple
          if changeset_revision != tool_shed_repository.changeset_revision:
              # This is an update
              tool_shed_url = common_util.get_tool_shed_url_from_tool_shed_registry(self.app, tool_shed_repository.tool_shed)
              return self.update_tool_shed_repository(tool_shed_repository,
                                                      tool_shed_url,
                                                      ctx_rev,
                                                      changeset_revision,
                                                      install_options=install_options)
          # Clone the repository to the configured location.
          self.update_tool_shed_repository_status(tool_shed_repository,
                                                  self.install_model.ToolShedRepository.installation_status.CLONING)
          relative_clone_dir = repository_util.generate_tool_shed_repository_install_dir(repository_clone_url,
                                                                                         tool_shed_repository.installed_changeset_revision)
          relative_install_dir = os.path.join(relative_clone_dir, tool_shed_repository.name)
          install_dir = os.path.abspath(os.path.join(tool_path, relative_install_dir))
          log.info("Cloning repository '%s' at %s:%s", repository_clone_url, ctx_rev, tool_shed_repository.changeset_revision)
          if os.path.exists(install_dir):
              # May exist from a previous failed install attempt, just try updating instead of cloning.
              hg_util.pull_repository(install_dir, repository_clone_url, ctx_rev)
              hg_util.update_repository(install_dir, ctx_rev)
              cloned_ok = True
          else:
              cloned_ok, error_message = hg_util.clone_repository(repository_clone_url, install_dir, ctx_rev)
          if cloned_ok:
              if reinstalling:
                  # Since we're reinstalling the repository we need to find the latest changeset revision to
                  # which it can be updated.
                  changeset_revision_dict = self.app.update_repository_manager.get_update_to_changeset_revision_and_ctx_rev(tool_shed_repository)
                  current_changeset_revision = changeset_revision_dict.get('changeset_revision', None)
                  current_ctx_rev = changeset_revision_dict.get('ctx_rev', None)
                  if current_ctx_rev != ctx_rev:
                      repo_path = os.path.abspath(install_dir)
                      hg_util.pull_repository(repo_path, repository_clone_url, current_changeset_revision)
                      hg_util.update_repository(repo_path, ctx_rev=current_ctx_rev)
              self.__handle_repository_contents(tool_shed_repository=tool_shed_repository,
                                                tool_path=tool_path,
                                                repository_clone_url=repository_clone_url,
                                                relative_install_dir=relative_install_dir,
                                                tool_shed=tool_shed_repository.tool_shed,
                                                tool_section=tool_section,
                                                shed_tool_conf=shed_tool_conf,
                                                reinstalling=reinstalling,
                                                tool_panel_section_mapping=tool_panel_section_mapping)
              metadata = tool_shed_repository.metadata
              if 'tools' in metadata and install_resolver_dependencies:
                  self.update_tool_shed_repository_status(tool_shed_repository,
                                                          self.install_model.ToolShedRepository.installation_status.INSTALLING_TOOL_DEPENDENCIES)
                  new_tools = [self.app.toolbox._tools_by_id.get(tool_d['guid'], None) for tool_d in metadata['tools']]
                  new_requirements = {tool.requirements.packages for tool in new_tools if tool}
                  [self._view.install_dependencies(r) for r in new_requirements]
                  dependency_manager = self.app.toolbox.dependency_manager
                  if dependency_manager.cached:
                      [dependency_manager.build_cache(r) for r in new_requirements]
  
              if install_tool_dependencies and tool_shed_repository.tool_dependencies and 'tool_dependencies' in metadata:
                  work_dir = tempfile.mkdtemp(prefix="tmp-toolshed-itsr")
                  # Install tool dependencies.
                  self.update_tool_shed_repository_status(tool_shed_repository,
                                                          self.install_model.ToolShedRepository.installation_status.INSTALLING_TOOL_DEPENDENCIES)
                  # Get the tool_dependencies.xml file from the repository.
                  tool_dependencies_config = hg_util.get_config_from_disk('tool_dependencies.xml', install_dir)
                  itdm = InstallToolDependencyManager(self.app)
                  itdm.install_specified_tool_dependencies(tool_shed_repository=tool_shed_repository,
                                                           tool_dependencies_config=tool_dependencies_config,
                                                           tool_dependencies=tool_shed_repository.tool_dependencies,
                                                           from_tool_migration_manager=False)
                  basic_util.remove_dir(work_dir)
              self.update_tool_shed_repository_status(tool_shed_repository,
                                                      self.install_model.ToolShedRepository.installation_status.INSTALLED)
          else:
              # An error occurred while cloning the repository, so reset everything necessary to enable another attempt.
              repository_util.set_repository_attributes(self.app,
                                                        tool_shed_repository,
                                                        status=self.install_model.ToolShedRepository.installation_status.ERROR,
                                                        error_message=error_message,
                                                        deleted=False,
                                                        uninstalled=False,
                                                        remove_from_disk=True)
  
      def update_tool_shed_repository(self, repository, tool_shed_url, latest_ctx_rev, latest_changeset_revision,
                                      install_new_dependencies=True, install_options=None):
          install_options = install_options or {}
          original_metadata_dict = repository.metadata
          original_repository_dependencies_dict = original_metadata_dict.get('repository_dependencies', {})
          original_repository_dependencies = original_repository_dependencies_dict.get('repository_dependencies', [])
          original_tool_dependencies_dict = original_metadata_dict.get('tool_dependencies', {})
          shed_tool_conf, tool_path, relative_install_dir = suc.get_tool_panel_config_tool_path_install_dir(self.app, repository)
          if tool_path:
              repo_files_dir = os.path.abspath(os.path.join(tool_path, relative_install_dir, repository.name))
          else:
              repo_files_dir = os.path.abspath(os.path.join(relative_install_dir, repository.name))
          repository_clone_url = os.path.join(tool_shed_url, 'repos', repository.owner, repository.name)
          # Set a status, even though we're probably not cloning.
          self.update_tool_shed_repository_status(repository, status=repository.installation_status.CLONING)
          log.info("Updating repository '%s' to %s:%s", repository.name, latest_ctx_rev, latest_changeset_revision)
          if not os.path.exists(repo_files_dir):
              log.debug("Repository directory '%s' does not exist, cloning repository instead of updating repository", repo_files_dir)
              hg_util.clone_repository(repository_clone_url=repository_clone_url, repository_file_dir=repo_files_dir, ctx_rev=latest_ctx_rev)
          hg_util.pull_repository(repo_files_dir, repository_clone_url, latest_ctx_rev)
          hg_util.update_repository(repo_files_dir, latest_ctx_rev)
          # Remove old Data Manager entries
          if repository.includes_data_managers:
              dmh = data_manager.DataManagerHandler(self.app)
              dmh.remove_from_data_manager(repository)
          # Update the repository metadata.
          tpm = tool_panel_manager.ToolPanelManager(self.app)
          irmm = InstalledRepositoryMetadataManager(app=self.app,
                                                    tpm=tpm,
                                                    repository=repository,
                                                    changeset_revision=latest_changeset_revision,
                                                    repository_clone_url=repository_clone_url,
                                                    shed_config_dict=repository.get_shed_config_dict(self.app),
                                                    relative_install_dir=relative_install_dir,
                                                    repository_files_dir=None,
                                                    resetting_all_metadata_on_repository=False,
                                                    updating_installed_repository=True,
                                                    persist=True)
          irmm.generate_metadata_for_changeset_revision()
          irmm_metadata_dict = irmm.get_metadata_dict()
          self.update_tool_shed_repository_status(repository, status=repository.installation_status.INSTALLED)
          if 'tools' in irmm_metadata_dict:
              tool_panel_dict = irmm_metadata_dict.get('tool_panel_section', None)
              if tool_panel_dict is None:
                  tool_panel_dict = tpm.generate_tool_panel_dict_from_shed_tool_conf_entries(repository)
              repository_tools_tups = irmm.get_repository_tools_tups()
              tpm.add_to_tool_panel(repository_name=str(repository.name),
                                    repository_clone_url=repository_clone_url,
                                    changeset_revision=str(repository.installed_changeset_revision),
                                    repository_tools_tups=repository_tools_tups,
                                    owner=str(repository.owner),
                                    shed_tool_conf=shed_tool_conf,
                                    tool_panel_dict=tool_panel_dict,
                                    new_install=False)
              # Add new Data Manager entries
              if 'data_manager' in irmm_metadata_dict:
                  dmh = data_manager.DataManagerHandler(self.app)
                  dmh.install_data_managers(self.app.config.shed_data_manager_config_file,
                                            irmm_metadata_dict,
                                            repository.get_shed_config_dict(self.app),
                                            os.path.join(relative_install_dir, repository.name),
                                            repository,
                                            repository_tools_tups)
          if 'repository_dependencies' in irmm_metadata_dict or 'tool_dependencies' in irmm_metadata_dict:
              new_repository_dependencies_dict = irmm_metadata_dict.get('repository_dependencies', {})
              new_repository_dependencies = new_repository_dependencies_dict.get('repository_dependencies', [])
              new_tool_dependencies_dict = irmm_metadata_dict.get('tool_dependencies', {})
              if new_repository_dependencies:
                  # [[http://localhost:9009', package_picard_1_56_0', devteam', 910b0b056666', False', False']]
                  if new_repository_dependencies == original_repository_dependencies:
                      for new_repository_tup in new_repository_dependencies:
                          # Make sure all dependencies are installed.
                          # TODO: Repository dependencies that are not installed should be displayed to the user,
                          # giving them the option to install them or not. This is the same behavior as when initially
                          # installing and when re-installing.
                          new_tool_shed, new_name, new_owner, new_changeset_revision, new_pir, new_oicct = \
                              common_util.parse_repository_dependency_tuple(new_repository_tup)
                          # Mock up a repo_info_tupe that has the information needed to see if the repository dependency
                          # was previously installed.
                          repo_info_tuple = ('', new_tool_shed, new_changeset_revision, '', new_owner, [], [])
                          # Since the value of new_changeset_revision came from a repository dependency
                          # definition, it may occur earlier in the Tool Shed's repository changelog than
                          # the Galaxy tool_shed_repository.installed_changeset_revision record value, so
                          # we set from_tip to True to make sure we get the entire set of changeset revisions
                          # from the Tool Shed.
                          new_repository_db_record, installed_changeset_revision = \
                              repository_util.repository_was_previously_installed(self.app,
                                                                                  tool_shed_url,
                                                                                  new_name,
                                                                                  repo_info_tuple,
                                                                                  from_tip=True)
                          if ((new_repository_db_record and new_repository_db_record.status in [
                                  self.install_model.ToolShedRepository.installation_status.ERROR,
                                  self.install_model.ToolShedRepository.installation_status.NEW,
                                  self.install_model.ToolShedRepository.installation_status.UNINSTALLED])
                                  or not new_repository_db_record):
                              log.debug('Update to %s contains new repository dependency %s/%s', repository.name,
                                        new_owner, new_name)
                              if not install_new_dependencies:
                                  return ('repository', irmm_metadata_dict)
                              else:
                                  self.install(tool_shed_url, new_name, new_owner, new_changeset_revision, install_options)
              # Updates received did not include any newly defined repository dependencies but did include
              # newly defined tool dependencies.  If the newly defined tool dependencies are not the same
              # as the originally defined tool dependencies, we need to install them.
              if not install_new_dependencies:
                  for new_key, new_val in new_tool_dependencies_dict.items():
                      if new_key not in original_tool_dependencies_dict:
                          return ('tool', irmm_metadata_dict)
                      original_val = original_tool_dependencies_dict[new_key]
                      if new_val != original_val:
                          return ('tool', irmm_metadata_dict)
          # Updates received did not include any newly defined repository dependencies or newly defined
          # tool dependencies that need to be installed.
          repository = self.app.update_repository_manager.update_repository_record(repository=repository,
                                                                                   updated_metadata_dict=irmm_metadata_dict,
                                                                                   updated_changeset_revision=latest_changeset_revision,
                                                                                   updated_ctx_rev=latest_ctx_rev)
          return (None, None)
  
      def order_components_for_installation(self, tsr_ids, repo_info_dicts, tool_panel_section_keys):
          """
          Some repositories may have repository dependencies that are required to be installed
          before the dependent repository.  This method will inspect the list of repositories
          about to be installed and make sure to order them appropriately.  For each repository
          about to be installed, if required repositories are not contained in the list of repositories
          about to be installed, then they are not considered.  Repository dependency definitions
          that contain circular dependencies should not result in an infinite loop, but obviously
          prior installation will not be handled for one or more of the repositories that require
          prior installation.
          """
          ordered_tsr_ids = []
          ordered_repo_info_dicts = []
          ordered_tool_panel_section_keys = []
          # Create a dictionary whose keys are the received tsr_ids and whose values are a list of
          # tsr_ids, each of which is contained in the received list of tsr_ids and whose associated
          # repository must be installed prior to the repository associated with the tsr_id key.
          prior_install_required_dict = repository_util.get_prior_import_or_install_required_dict(self.app,
                                                                                                  tsr_ids,
                                                                                                  repo_info_dicts)
          processed_tsr_ids = []
          while len(processed_tsr_ids) != len(prior_install_required_dict.keys()):
              tsr_id = suc.get_next_prior_import_or_install_required_dict_entry(prior_install_required_dict,
                                                                                processed_tsr_ids)
              processed_tsr_ids.append(tsr_id)
              # Create the ordered_tsr_ids, the ordered_repo_info_dicts and the ordered_tool_panel_section_keys lists.
              if tsr_id not in ordered_tsr_ids:
                  prior_install_required_ids = prior_install_required_dict[tsr_id]
                  for prior_install_required_id in prior_install_required_ids:
                      if prior_install_required_id not in ordered_tsr_ids:
                          # Install the associated repository dependency first.
                          prior_repo_info_dict, prior_tool_panel_section_key = \
                              self.get_repository_components_for_installation(prior_install_required_id,
                                                                              tsr_ids,
                                                                              repo_info_dicts,
                                                                              tool_panel_section_keys=tool_panel_section_keys)
                          ordered_tsr_ids.append(prior_install_required_id)
                          ordered_repo_info_dicts.append(prior_repo_info_dict)
                          ordered_tool_panel_section_keys.append(prior_tool_panel_section_key)
                  repo_info_dict, tool_panel_section_key = \
                      self.get_repository_components_for_installation(tsr_id,
                                                                      tsr_ids,
                                                                      repo_info_dicts,
                                                                      tool_panel_section_keys=tool_panel_section_keys)
                  if tsr_id not in ordered_tsr_ids:
                      ordered_tsr_ids.append(tsr_id)
                      ordered_repo_info_dicts.append(repo_info_dict)
                      ordered_tool_panel_section_keys.append(tool_panel_section_key)
          return ordered_tsr_ids, ordered_repo_info_dicts, ordered_tool_panel_section_keys
  
      def update_tool_shed_repository_status(self, tool_shed_repository, status, error_message=None):
          """
          Update the status of a tool shed repository in the process of being installed into Galaxy.
          """
          tool_shed_repository.status = status
          tool_shed_repository.error_message = error_message
          self.install_model.context.add(tool_shed_repository)
          self.install_model.context.flush()
  
  
  class RepositoriesInstalledException(exceptions.RequestParameterInvalidException):
  
      def __init__(self):
          super().__init__('All repositories that you are attempting to install have been previously installed.')
  