dnf:

      name:

        - python3-redis

        - redis

      state: present

                     python3-pillow python3-psutil python3-psycopg2 \

                     python3-pygit2 python3-redis python3-requests \

                     python3-setuptools python3-six python3-sqlalchemy \

                     python-unversioned-command python3-wtforms which \

                     python3-email-validator \

                     python3-whitenoise \

      python-jenkins

      python-redis

  .. note:: We ship a systemd unit file for pagure_ci but we welcome patches

          for scripts for other init systems.

  ::

      python-redis

  .. note:: We ship a systemd unit file for pagure_milter but we welcome patches

          for scripts for other init systems.

  ::

      python-redis

  .. note:: We ship a systemd unit file for pagure_loadjson but we welcome patches

          for scripts for other init systems.

  ::

      python-redis

  .. note:: We ship a systemd unit file for pagure_logcom but we welcome patches

          for scripts for other init systems.

  ::

      python-redis

  .. note:: We ship a systemd unit file for pagure_webhook but we welcome patches

          for scripts for other init systems.

  Summary:            EventSource server for pagure

  BuildArch:          noarch

  Requires:           %{name} = %{version}-%{release}

  %{?systemd_requires}

  %description        ev

  Pagure comes with an eventsource server allowing live update of the pages

  import redis

  from six.moves.urllib.parse import urlparse

      return getfunc(repo, objid)

  def handle_client(client_reader, client_writer):

      data = None

      while True:

          # give client a chance to respond, timeout after 10 seconds

              break

          line = line.decode().rstrip()

          if data is None:

          log.warning("Expected ticket uid, received None")

          return

      log.info("Received %s", data)

      if not data:

          log.warning("No URL provided: %s" % data)

                      client_writer.write(("event: ping\n\n").encode())

                      oncall = 0

                  oncall += 1

              else:

      except OSError:

          log.info("Client closed connection")

          log.exception("ERROR: ConnectionResetError in handle_client")

      except Exception as err:

          log.exception("ERROR: Exception in handle_client")

          client_writer.close()

  def stats(client_reader, client_writer):

      try:

          client_writer.write(

              ("HTTP/1.0 200 OK\n" "Cache: nocache\n\n").encode()

          )

          log.info(err)

      finally:

          client_writer.close()

      _get_session()

      try:

              handle_client,

              host=None,

              port=pagure.config.config["EVENTSOURCE_PORT"],

              "Serving server at {}".format(SERVER.sockets[0].getsockname())

          )

          if pagure.config.config.get("EV_STATS_PORT"):

                  stats,

                  host=None,

                  port=pagure.config.config.get("EV_STATS_PORT"),

          loop.run_forever()

      except KeyboardInterrupt:

          pass

          log.exception("ERROR: ConnectionResetError in main")

      except Exception:

          log.exception("ERROR: Exception in main")

  pytest-cov

  pytest-xdist

  python-fedora

  # Seems that mock doesn't list this one

  funcsigs

  usedevelop = True

  deps =

      -rrequirements-testing.txt

      python-openid

      python-openid-teams

      python-openid-cla