from defusedxml import cElementTree as etree

  import requests

  KOJI_REPO = 'https://kojipkgs.fedoraproject.org/repos/'

  def download_db(name, repomd_url, archive):

      response = requests.get(repomd_url, verify=True)

      with open(archive, 'wb') as stream:

          stream.write(response.content)

  def decompress_db(name, archive, location):

      ''' Decompress the given archive at the specified location. '''

      if archive.endswith('.xz'):

          import lzma

          with contextlib.closing(lzma.LZMAFile(archive)) as stream_xz:

      repomd_url = url + '/repomd.xml'

      response = requests.get(repomd_url, verify=True)

      if not bool(response):

          return

          return

      repomd_url = url + '/' + filename

      # First, determine if the file has changed by comparing hash

      # Have we downloaded this before?  Did it change?

      destfile = os.path.join(destfolder, db)

      else:

          # If it has changed, then download it and move it into place.

          archive = os.path.join(destfolder, filename)

              # Old API -- in python-bugzilla.  But with current server, this

              # gives ProxyError

              for collection, product in self.config["products"].items():

          elif self.config['bugzilla']['compat_api'] == 'component.get':

              # Way that's undocumented in the partner-bugzilla api but works

              # currently

              for collection, product in self.config["products"].items():

                  # restrict the list of info returned to only the packages of

                  # interest

                  pkglist = [

                      project["name"]

                      for project in pagure_projects

                  ]

                  for pkg_segment in segment(pkglist, self.config['bugzilla']['req_segment']):

                      # Format that bugzilla will understand.  Strip None's that

                      # segment() pads out the final data segment() with

                      query = [

                          for p in pkg_segment

                          if p is not None

                      ]

                      for package in raw_data['components']:

                          # Reformat data to be the same as what's returned from

                          # getcomponentsdetails

      def invert_user_cache(self):

          """ Takes the user_cache built when querying FAS and invert it so

              e.args = ('ProtocolError', e.errcode, e.errmsg)

              raise

          # Set the qacontact_email and name

          default_qa_contact_email = self.config['default_qa_contact_email']

          default_qa_contact = f"<default: {default_qa_contact_email.split('@', 1)[0]}@...>"

                          data['initialcclist'] = initial_cc_emails

                          break

              if data:

                  # Changes occurred.  Submit a request to change via xmlrpc

                  data['component'] = package

                  if self.config["verbose"]:

                      print(f'[EDITCOMP] {data["product"]}/{data["component"]}')

                          new_poc=owner_email,

                          prev_poc=product[pkg_key]['initialowner'],

                          name=package,

                      )

              else:

                  if self.config.get("print-no-change"):

                      print(f"[NOCHANGE] {package}/{bz_product_name}")

          else:

              if retired:

                  if self.config['verbose']:

                      print(f"[NOADD] {bz_product_name}/{package} (is retired)")

      :return: a list of the repo's branches

      """

      branches_url = '{0}component-branches/'.format(env['pdc_url'])

      if config["verbose"]:

          print('Querying {0} {1}'.format(branches_url, params))

      rv = session.get(branches_url, params=params, timeout=60)

      _namespace_to_product = None

      _product_to_branch_regex = None

      _branch_regex_to_product = None

      def send_email(self, from_address, to_address, subject, message, cc_address=None):

          '''Send an email if there's an error.

          # Combine and collapse those two into a single list:

          self.pagure_projects = []

          if project_list:

          for namespace, entries in pagure_namespace_to_poc.items():

              for name, poc in entries.items():

                  if not project_list or (namespace, name) in project_list:

      @property

      def namespace_to_product(self):

          self.env["print-no-change"] = self.args.print_no_change

          # Non-fatal errors to alert people about

          self.session = retry_session()