139 lines
5.4 KiB
Python
139 lines
5.4 KiB
Python
# -*- coding: utf-8 -*-
|
|
|
|
|
|
# This program is free software; you can redistribute it and/or modify
|
|
# it under the terms of the GNU General Public License as published by
|
|
# the Free Software Foundation; version 2 of the License.
|
|
#
|
|
# This program is distributed in the hope that it will be useful,
|
|
# but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
# GNU Library General Public License for more details.
|
|
#
|
|
# You should have received a copy of the GNU General Public License
|
|
# along with this program; if not, see <https://gnu.org/licenses/>.
|
|
|
|
|
|
import kobo.log
|
|
from kobo.shortcuts import run
|
|
|
|
from pungi.wrappers import kojiwrapper
|
|
|
|
|
|
class Runroot(kobo.log.LoggingBase):
|
|
def __init__(self, compose, logger=None):
|
|
"""
|
|
Creates new Runroot instance.
|
|
|
|
:param Compose compose: Compose instance.
|
|
:param Logger logger: Logger instance to log message to.
|
|
"""
|
|
kobo.log.LoggingBase.__init__(self, logger=logger)
|
|
self.compose = compose
|
|
self.runroot_method = self.get_runroot_method()
|
|
# Holds the result of last `run()` call.
|
|
self._result = None
|
|
|
|
def get_runroot_method(self):
|
|
"""
|
|
Returns the runroot method by checking the `runroot` and
|
|
`runroot_method` options in configuration.
|
|
|
|
:return: The "local" or "koji" string.
|
|
"""
|
|
runroot = self.compose.conf.get("runroot", None)
|
|
runroot_method = self.compose.conf.get("runroot_method", None)
|
|
if runroot is None and runroot_method is None:
|
|
raise ValueError("No runroot_method set.")
|
|
if runroot is False:
|
|
runroot_method = "local"
|
|
elif runroot and not runroot_method:
|
|
runroot_method = "koji"
|
|
return runroot_method
|
|
|
|
def _run_local(self, command, log_file=None, **kwargs):
|
|
"""
|
|
Runs the runroot command locally.
|
|
"""
|
|
run(command, show_cmd=True, logfile=log_file)
|
|
self._result = True
|
|
|
|
def _run_koji(self, command, log_file=None, packages=None,
|
|
arch=None, output_dir=None, **kwargs):
|
|
"""
|
|
Runs the runroot command in Koji.
|
|
"""
|
|
runroot_channel = self.compose.conf.get("runroot_channel")
|
|
runroot_tag = self.compose.conf["runroot_tag"]
|
|
|
|
if output_dir:
|
|
kwargs["destdir"] = output_dir
|
|
|
|
koji_wrapper = kojiwrapper.KojiWrapper(self.compose.conf["koji_profile"])
|
|
koji_cmd = koji_wrapper.get_runroot_cmd(
|
|
runroot_tag, arch, command,
|
|
channel=runroot_channel, use_shell=True, task_id=True,
|
|
packages=packages, **kwargs
|
|
)
|
|
|
|
output = koji_wrapper.run_runroot_cmd(koji_cmd, log_file=log_file)
|
|
if output["retcode"] != 0:
|
|
raise RuntimeError("Runroot task failed: %s. See %s for more details."
|
|
% (output["task_id"], log_file))
|
|
self._result = output
|
|
|
|
def run(self, command, log_file=None, packages=None, arch=None,
|
|
output_dir=None, **kwargs):
|
|
"""
|
|
Runs the runroot task using the `Runroot.runroot_method`. Blocks until
|
|
the runroot task is successfully finished. Raises an exception on error.
|
|
|
|
The **kwargs are optional and matches the `KojiWrapper.get_runroot_cmd()`
|
|
kwargs. Some `runroot_method` methods might ignore the kwargs which
|
|
do not make sense for them.
|
|
|
|
:param str command: Command to execute.
|
|
:param str log_file: Log file into which the output of runroot task will
|
|
be logged.
|
|
:param list packages: List of packages which are needed for runroot task
|
|
to be executed.
|
|
:param str arch: Architecture on which the runroot task should be
|
|
executed.
|
|
:param str output_dir: Directory where the `command` stores its output.
|
|
The permissions of this output_dir might be changed by `runroot_method`
|
|
to allow the executor of this runroot task to accesss them.
|
|
See `KojiWrapper.get_runroot_cmd()` for more information.
|
|
"""
|
|
if self.runroot_method == "local":
|
|
self._run_local(
|
|
command, log_file=log_file, packages=packages, arch=arch,
|
|
output_dir=output_dir, **kwargs)
|
|
elif self.runroot_method == "koji":
|
|
self._run_koji(
|
|
command, log_file=log_file, packages=packages, arch=arch,
|
|
output_dir=output_dir, **kwargs)
|
|
else:
|
|
raise ValueError("Unknown runroot_method %r." % self.runroot_method)
|
|
|
|
def get_buildroot_rpms(self):
|
|
"""
|
|
Returns the list of RPMs installed in a buildroot in which the runroot
|
|
task was executed. This is needed to track what actually generated
|
|
the data generated by runroot task.
|
|
|
|
This must be called after the `run()` method successfully finished,
|
|
otherwise raises an exception.
|
|
|
|
:return: List of RPMs in buildroot in which the runroot task run.
|
|
"""
|
|
if not self._result:
|
|
raise ValueError("Runroot.get_build_rpms before runroot task finished.")
|
|
if self.runroot_method in ["local", "koji"]:
|
|
if self.runroot_method == "local":
|
|
task_id = None
|
|
else:
|
|
task_id = self._result["task_id"]
|
|
return kojiwrapper.get_buildroot_rpms(self.compose, task_id)
|
|
else:
|
|
raise ValueError("Unknown runroot_method %r." % self.runroot_method)
|