- from __future__ import absolute_import, division

- 

- import ast

- import fnmatch

- import itertools

- import json

- import logging

- import os

- import pprint

- import random

- import stat

- import sys

- import textwrap

- import time

- import traceback

- from datetime import datetime

- from dateutil.tz import tzutc

- from collections import OrderedDict, defaultdict

- from optparse import SUPPRESS_HELP, OptionParser

- 

- import six

- import six.moves.xmlrpc_client

- from six.moves import filter, map, range, zip

- 

- import koji

- from koji.util import base64encode, md5_constructor, to_list

- from koji_cli.lib import (

-     TimeOption,

-     DatetimeJSONEncoder,

-     _list_tasks,

-     _progress_callback,

-     _running_in_bg,

-     activate_session,

-     arg_filter,

-     download_archive,

-     download_file,

-     download_rpm,

-     ensure_connection,

-     error,

-     format_inheritance_flags,

-     get_usage_str,

-     greetings,

-     linked_upload,

-     list_task_output_all_volumes,

-     print_task_headers,

-     print_task_recurse,

-     unique_path,

-     warn,

-     watch_logs,

-     watch_tasks,

-     truncate_string

- )

- 

- try:

-     import libcomps

- except ImportError:  # pragma: no cover

-     libcomps = None

-     try:

-         import yum.comps as yumcomps

-     except ImportError:

-         yumcomps = None

- 

- 

- def _printable_unicode(s):

-     if six.PY2:

-         return s.encode('utf-8')

-     else:  # no cover: 2.x

-         return s

- 

- 

- def handle_add_group(goptions, session, args):

-     "[admin] Add a group to a tag"

-     usage = "usage: %prog add-group <tag> <group>"

-     parser = OptionParser(usage=get_usage_str(usage))

-     (options, args) = parser.parse_args(args)

-     if len(args) != 2:

-         parser.error("Please specify a tag name and a group name")

-     tag = args[0]

-     group = args[1]

- 

-     activate_session(session, goptions)

-     if not (session.hasPerm('admin') or session.hasPerm('tag')):

-         parser.error("This action requires tag or admin privileges")

- 

-     dsttag = session.getTag(tag)

-     if not dsttag:

-         error("No such tag: %s" % tag)

- 

-     groups = dict([(p['name'], p['group_id']) for p in session.getTagGroups(tag, inherit=False)])

-     group_id = groups.get(group, None)

-     if group_id is not None:

-         error("Group %s already exists for tag %s" % (group, tag))

- 

-     session.groupListAdd(tag, group)

- 

- 

- def handle_block_group(goptions, session, args):

-     "[admin] Block group in tag"

-     usage = "usage: %prog block-group <tag> <group>"

-     parser = OptionParser(usage=get_usage_str(usage))

-     (options, args) = parser.parse_args(args)

-     if len(args) != 2:

-         parser.error("Please specify a tag name and a group name")

-     tag = args[0]

-     group = args[1]

- 

-     activate_session(session, goptions)

-     if not (session.hasPerm('admin') or session.hasPerm('tag')):

-         parser.error("This action requires tag or admin privileges")

- 

-     dsttag = session.getTag(tag)

-     if not dsttag:

-         error("No such tag: %s" % tag)

- 

-     groups = dict([(p['name'], p['group_id']) for p in session.getTagGroups(tag, inherit=False)])

-     group_id = groups.get(group, None)

-     if group_id is None:

-         error("Group %s doesn't exist within tag %s" % (group, tag))

- 

-     session.groupListBlock(tag, group)

- 

- 

- def handle_remove_group(goptions, session, args):

-     "[admin] Remove group from tag"

-     usage = "usage: %prog remove-group <tag> <group>"

-     parser = OptionParser(usage=get_usage_str(usage))

-     (options, args) = parser.parse_args(args)

-     if len(args) != 2:

-         parser.error("Please specify a tag name and a group name")

-     tag = args[0]

-     group = args[1]

- 

-     activate_session(session, goptions)

-     if not (session.hasPerm('admin') or session.hasPerm('tag')):

-         parser.error("This action requires tag or admin privileges")

- 

-     dsttag = session.getTag(tag)

-     if not dsttag:

-         error("No such tag: %s" % tag)

- 

-     groups = dict([(p['name'], p['group_id']) for p in session.getTagGroups(tag, inherit=False)])

-     group_id = groups.get(group, None)

-     if group_id is None:

-         error("Group %s doesn't exist within tag %s" % (group, tag))

- 

-     session.groupListRemove(tag, group)

- 

- 

- def handle_assign_task(goptions, session, args):

-     "[admin] Assign a task to a host"

-     usage = 'usage: %prog assign-task <task_id> <hostname>'

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option('-f', '--force', action='store_true', default=False,

-                       help='force to assign a non-free task')

-     (options, args) = parser.parse_args(args)

- 

-     if len(args) != 2:

-         parser.error('please specify a task id and a hostname')

-     else:

-         task_id = int(args[0])

-         hostname = args[1]

- 

-     taskinfo = session.getTaskInfo(task_id, request=False)

-     if taskinfo is None:

-         raise koji.GenericError("No such task: %s" % task_id)

- 

-     hostinfo = session.getHost(hostname)

-     if hostinfo is None:

-         raise koji.GenericError("No such host: %s" % hostname)

- 

-     force = False

-     if options.force:

-         force = True

- 

-     activate_session(session, goptions)

-     if not session.hasPerm('admin'):

-         parser.error("This action requires admin privileges")

- 

-     ret = session.assignTask(task_id, hostname, force)

-     if ret:

-         print('assigned task %d to host %s' % (task_id, hostname))

-     else:

-         print('failed to assign task %d to host %s' % (task_id, hostname))

- 

- 

- def handle_add_host(goptions, session, args):

-     "[admin] Add a host"

-     usage = "usage: %prog add-host [options] <hostname> <arch> [<arch> ...]"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--krb-principal",

-                       help="set a non-default kerberos principal for the host")

-     parser.add_option("--force", default=False, action="store_true",

-                       help="if existing used is a regular user, convert it to a host")

-     (options, args) = parser.parse_args(args)

-     if len(args) < 2:

-         parser.error("Please specify a hostname and at least one arch")

-     host = args[0]

-     activate_session(session, goptions)

-     id = session.getHost(host)

-     if id:

-         error("%s is already in the database" % host)

-     else:

-         kwargs = {'force': options.force}

-         if options.krb_principal is not None:

-             kwargs['krb_principal'] = options.krb_principal

-         id = session.addHost(host, args[1:], **kwargs)

-         print("%s added: id %d" % (host, id))

- 

- 

- def handle_edit_host(options, session, args):

-     "[admin] Edit a host"

-     usage = "usage: %prog edit-host <hostname> [<hostname> ...] [options]"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--arches",

-                       help="Space or comma-separated list of supported architectures")

-     parser.add_option("--capacity", type="float", help="Capacity of this host")

-     parser.add_option("--description", metavar="DESC", help="Description of this host")

-     parser.add_option("--comment", help="A brief comment about this host")

-     (subopts, args) = parser.parse_args(args)

-     if not args:

-         parser.error("Please specify a hostname")

- 

-     activate_session(session, options)

- 

-     vals = {}

-     for key, val in subopts.__dict__.items():

-         if val is not None:

-             vals[key] = val

-     if 'arches' in vals:

-         vals['arches'] = koji.parse_arches(vals['arches'])

- 

-     session.multicall = True

-     for host in args:

-         session.getHost(host)

-     error_hit = False

-     for host, [info] in zip(args, session.multiCall(strict=True)):

-         if not info:

-             warn("No such host: %s" % host)

-             error_hit = True

- 

-     if error_hit:

-         error("No changes made, please correct the command line")

- 

-     session.multicall = True

-     for host in args:

-         session.editHost(host, **vals)

-     for host, [result] in zip(args, session.multiCall(strict=True)):

-         if result:

-             print("Edited %s" % host)

-         else:

-             print("No changes made to %s" % host)

- 

- 

- def handle_add_host_to_channel(goptions, session, args):

-     "[admin] Add a host to a channel"

-     usage = "usage: %prog add-host-to-channel [options] <hostname> <channel>"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--list", action="store_true", help=SUPPRESS_HELP)

-     parser.add_option("--new", action="store_true", help="Create channel if needed")

-     parser.add_option("--force", action="store_true", help="force added, if possible")

-     (options, args) = parser.parse_args(args)

-     if not options.list and len(args) != 2:

-         parser.error("Please specify a hostname and a channel")

-     activate_session(session, goptions)

-     if options.list:

-         for channel in session.listChannels():

-             print(channel['name'])

-         return

-     channel = args[1]

-     if not options.new:

-         channelinfo = session.getChannel(channel)

-         if not channelinfo:

-             error("No such channel: %s" % channel)

- 

-     host = args[0]

-     hostinfo = session.getHost(host)

-     if not hostinfo:

-         error("No such host: %s" % host)

-     kwargs = {}

-     if options.new:

-         kwargs['create'] = True

-     if options.force:

-         kwargs['force'] = True

-     session.addHostToChannel(host, channel, **kwargs)

- 

- 

- def handle_remove_host_from_channel(goptions, session, args):

-     "[admin] Remove a host from a channel"

-     usage = "usage: %prog remove-host-from-channel [options] <hostname> <channel>"

-     parser = OptionParser(usage=get_usage_str(usage))

-     (options, args) = parser.parse_args(args)

-     if len(args) != 2:

-         parser.error("Please specify a hostname and a channel")

-     host = args[0]

-     activate_session(session, goptions)

-     hostinfo = session.getHost(host)

-     if not hostinfo:

-         error("No such host: %s" % host)

-     hostchannels = [c['name'] for c in session.listChannels(hostinfo['id'])]

- 

-     channel = args[1]

-     if channel not in hostchannels:

-         error("Host %s is not a member of channel %s" % (host, channel))

- 

-     session.removeHostFromChannel(host, channel)

- 

- 

- def handle_add_channel(goptions, session, args):

-     "[admin] Add a channel"

-     usage = "usage: %prog add-channel [options] <channel_name>"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--description", help="Description of channel")

-     (options, args) = parser.parse_args(args)

-     if len(args) != 1:

-         parser.error("Please specify one channel name")

-     activate_session(session, goptions)

-     channel_name = args[0]

-     try:

-         channel_id = session.addChannel(channel_name, description=options.description)

-     except koji.GenericError as ex:

-         msg = str(ex)

-         if 'channel %s already exists' % channel_name in msg:

-             error("channel %s already exists" % channel_name)

-         elif 'Invalid method:' in msg:

-             version = session.getKojiVersion()

-             error("addChannel is available on hub from Koji 1.26 version, your version is %s" %

-                   version)

-         else:

-             error(msg)

-     print("%s added: id %d" % (args[0], channel_id))

- 

- 

- def handle_remove_channel(goptions, session, args):

-     "[admin] Remove a channel entirely"

-     usage = "usage: %prog remove-channel [options] <channel>"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--force", action="store_true", help="force removal, if possible")

-     (options, args) = parser.parse_args(args)

-     print("remove-channel is deprecated and will be removed in 1.30")

-     if len(args) != 1:

-         parser.error("Incorrect number of arguments")

-     activate_session(session, goptions)

-     cinfo = session.getChannel(args[0])

-     if not cinfo:

-         error("No such channel: %s" % args[0])

-     session.removeChannel(args[0], force=options.force)

- 

- 

- def handle_edit_channel(goptions, session, args):

-     "[admin] Edit a channel"

-     usage = "usage: %prog edit-channel [options] <old-name>"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--name", help="New channel name")

-     parser.add_option("--description", help="Description of channel")

-     parser.add_option("--comment", help="Comment of channel")

-     (options, args) = parser.parse_args(args)

-     if len(args) != 1:

-         parser.error("Incorrect number of arguments")

-     activate_session(session, goptions)

-     vals = {}

-     for key, val in options.__dict__.items():

-         if val is not None:

-             vals[key] = val

-     cinfo = session.getChannel(args[0])

-     if not cinfo:

-         error("No such channel: %s" % args[0])

-     try:

-         result = session.editChannel(args[0], **vals)

-     except koji.GenericError as ex:

-         msg = str(ex)

-         if 'Invalid method:' in msg:

-             version = session.getKojiVersion()

-             error("editChannel is available on hub from Koji 1.26 version, your version is %s" %

-                   version)

-         else:

-             print(msg)

-     if not result:

-         error("No changes made, please correct the command line")

- 

- 

- def handle_enable_channel(goptions, session, args):

-     "[admin] Mark one or more channels as enabled"

-     usage = "usage: %prog enable-channel [options] <channelname> [<channelname> ...]"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--comment", help="Comment indicating why the channel(s) are being enabled")

-     (options, args) = parser.parse_args(args)

- 

-     if not args:

-         parser.error("At least one channel must be specified")

- 

-     activate_session(session, goptions)

-     with session.multicall() as m:

-         result = [m.getChannel(channel, strict=False) for channel in args]

-     error_hit = False

-     for channel, id in zip(args, result):

-         if not id.result:

-             print("No such channel: %s" % channel)

-             error_hit = True

-     if error_hit:

-         error("No changes made. Please correct the command line.")

- 

-     with session.multicall() as m:

-         [m.enableChannel(channel, comment=options.comment) for channel in args]

- 

- 

- def handle_disable_channel(goptions, session, args):

-     "[admin] Mark one or more channels as disabled"

-     usage = "usage: %prog disable-channel [options] <channelname> [<channelname> ...]"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--comment", help="Comment indicating why the channel(s) are being disabled")

-     (options, args) = parser.parse_args(args)

- 

-     if not args:

-         parser.error("At least one channel must be specified")

- 

-     activate_session(session, goptions)

- 

-     with session.multicall() as m:

-         result = [m.getChannel(channel, strict=False) for channel in args]

-     error_hit = False

-     for channel, id in zip(args, result):

-         if not id.result:

-             print("No such channel: %s" % channel)

-             error_hit = True

-     if error_hit:

-         error("No changes made. Please correct the command line.")

-     with session.multicall() as m:

-         [m.disableChannel(channel, comment=options.comment) for channel in args]

- 

- 

- def handle_add_pkg(goptions, session, args):

-     "[admin] Add a package to the listing for tag"

-     usage = "usage: %prog add-pkg [options] --owner <owner> <tag> <package> [<package> ...]"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--force", action='store_true', help="Override blocks if necessary")

-     parser.add_option("--owner", help="Specify owner")

-     parser.add_option("--extra-arches", help="Specify extra arches")

-     (options, args) = parser.parse_args(args)

-     if len(args) < 2:

-         parser.error("Please specify a tag and at least one package")

-     if not options.owner:

-         parser.error("Please specify an owner for the package(s)")

-     if not session.getUser(options.owner):

-         error("No such user: %s" % options.owner)

-     activate_session(session, goptions)

-     tag = args[0]

-     opts = {}

-     opts['force'] = options.force

-     opts['block'] = False

-     # check if list of packages exists for that tag already

-     dsttag = session.getTag(tag)

-     if dsttag is None:

-         error("No such tag: %s" % tag)

-     try:

-         pkglist = session.listPackages(tagID=dsttag['id'], with_owners=False)

-     except koji.ParameterError:

-         # performance option added in 1.25

-         pkglist = session.listPackages(tagID=dsttag['id'])

-     pkglist = dict([(p['package_name'], p['package_id']) for p in pkglist])

-     to_add = []

-     for package in args[1:]:

-         package_id = pkglist.get(package, None)

-         if package_id is not None:

-             print("Package %s already exists in tag %s" % (package, tag))

-             continue

-         to_add.append(package)

-     if options.extra_arches:

-         opts['extra_arches'] = koji.parse_arches(options.extra_arches)

- 

-     # add the packages

-     print("Adding %i packages to tag %s" % (len(to_add), dsttag['name']))

-     session.multicall = True

-     for package in to_add:

-         session.packageListAdd(tag, package, options.owner, **opts)

-     session.multiCall(strict=True)

- 

- 

- def handle_block_pkg(goptions, session, args):

-     "[admin] Block a package in the listing for tag"

-     usage = "usage: %prog block-pkg [options] <tag> <package> [<package> ...]"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--force", action='store_true', default=False,

-                       help="Override blocks and owner if necessary")

-     (options, args) = parser.parse_args(args)

-     if len(args) < 2:

-         parser.error("Please specify a tag and at least one package")

-     activate_session(session, goptions)

-     tag = args[0]

-     # check if list of packages exists for that tag already

-     dsttag = session.getTag(tag)

-     if dsttag is None:

-         error("No such tag: %s" % tag)

-     try:

-         pkglist = session.listPackages(tagID=dsttag['id'], inherited=True, with_owners=False)

-     except koji.ParameterError:

-         # performance option added in 1.25

-         pkglist = session.listPackages(tagID=dsttag['id'], inherited=True)

-     pkglist = dict([(p['package_name'], p['package_id']) for p in pkglist])

-     ret = 0

-     for package in args[1:]:

-         package_id = pkglist.get(package, None)

-         if package_id is None:

-             warn("Package %s doesn't exist in tag %s" % (package, tag))

-             ret = 1

-     if ret:

-         error(code=ret)

-     session.multicall = True

-     for package in args[1:]:

-         # force is not supported on older hub, so use it only explicitly

-         # https://pagure.io/koji/issue/1388

-         if options.force:

-             session.packageListBlock(tag, package, force=options.force)

-         else:

-             session.packageListBlock(tag, package)

-     session.multiCall(strict=True)

- 

- 

- def handle_remove_pkg(goptions, session, args):

-     "[admin] Remove a package from the listing for tag"

-     usage = "usage: %prog remove-pkg [options] <tag> <package> [<package> ...]"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--force", action='store_true', help="Override blocks if necessary")

-     (options, args) = parser.parse_args(args)

-     if len(args) < 2:

-         parser.error("Please specify a tag and at least one package")

-     activate_session(session, goptions)

-     tag = args[0]

-     opts = {}

-     opts['force'] = options.force

-     # check if list of packages exists for that tag already

-     dsttag = session.getTag(tag)

-     if dsttag is None:

-         error("No such tag: %s" % tag)

-     try:

-         pkglist = session.listPackages(tagID=dsttag['id'], with_owners=False)

-     except koji.ParameterError:

-         # performance option added in 1.25

-         pkglist = session.listPackages(tagID=dsttag['id'])

-     pkglist = dict([(p['package_name'], p['package_id']) for p in pkglist])

-     ret = 0

-     for package in args[1:]:

-         package_id = pkglist.get(package, None)

-         if package_id is None:

-             warn("Package %s is not in tag %s" % (package, tag))

-             ret = 1

-     if ret:

-         error(code=ret)

-     session.multicall = True

-     for package in args[1:]:

-         session.packageListRemove(tag, package, **opts)

-     session.multiCall(strict=True)

- 

- 

- def handle_build(options, session, args):

-     "[build] Build a package from source"

- 

-     usage = """\

-         usage: %prog build [options] <target> <srpm path or scm url>

- 

-         The first option is the build target, not to be confused with the destination

-         tag (where the build eventually lands) or build tag (where the buildroot

-         contents are pulled from).

- 

-         You can list all available build targets using the '%prog list-targets' command.

-         More detail can be found in the documentation.

-         https://docs.pagure.org/koji/HOWTO/#package-organization"""

- 

-     usage = textwrap.dedent(usage)

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--skip-tag", action="store_true", help="Do not attempt to tag package")

-     parser.add_option("--scratch", action="store_true", help="Perform a scratch build")

-     parser.add_option("--rebuild-srpm", action="store_true", dest="rebuild_srpm",

-                       help="Force rebuilding SRPM for scratch build only")

-     parser.add_option("--no-rebuild-srpm", action="store_false", dest="rebuild_srpm",

-                       help="Force not to rebuild srpm for scratch build only")

-     parser.add_option("--wait", action="store_true",

-                       help="Wait on the build, even if running in the background")

-     parser.add_option("--nowait", action="store_false", dest="wait", help="Don't wait on build")

-     parser.add_option("--wait-repo", action="store_true",

-                       help="Wait for the actual buildroot repo of given target")

-     parser.add_option("--wait-build", metavar="NVR", action="append", dest="wait_builds",

-                       default=[], help="Wait for the given nvr to appear in buildroot repo")

-     parser.add_option("--quiet", action="store_true",

-                       help="Do not print the task information", default=options.quiet)

-     parser.add_option("--arch-override", help="Override build arches")

-     parser.add_option("--fail-fast", action="store_true",

-                       help="Override build_arch_can_fail settings and fail as fast as possible")

-     parser.add_option("--repo-id", type="int", help="Use a specific repo")

-     parser.add_option("--noprogress", action="store_true",

-                       help="Do not display progress of the upload")

-     parser.add_option("--background", action="store_true",

-                       help="Run the build at a lower priority")

-     parser.add_option("--custom-user-metadata", type="str",

-                       help="Provide a JSON string of custom metadata to be deserialized and "

-                            "stored under the build's extra.custom_user_metadata field")

-     (build_opts, args) = parser.parse_args(args)

-     if len(args) != 2:

-         parser.error("Exactly two arguments (a build target and a SCM URL or srpm file) are "

-                      "required")

-     if build_opts.rebuild_srpm is not None and not build_opts.scratch:

-         parser.error("--no-/rebuild-srpm is only allowed for --scratch builds")

-     if build_opts.arch_override and not build_opts.scratch:

-         parser.error("--arch_override is only allowed for --scratch builds")

-     custom_user_metadata = {}

-     if build_opts.custom_user_metadata:

-         try:

-             custom_user_metadata = json.loads(build_opts.custom_user_metadata)

-         # Use ValueError instead of json.JSONDecodeError for Python 2 and 3 compatibility

-         except ValueError:

-             parser.error("--custom-user-metadata is not valid JSON")

- 

-     if not isinstance(custom_user_metadata, dict):

-         parser.error("--custom-user-metadata must be a JSON object")

- 

-     activate_session(session, options)

-     target = args[0]

-     if target.lower() == "none" and build_opts.repo_id:

-         target = None

-         build_opts.skip_tag = True

-     else:

-         build_target = session.getBuildTarget(target)

-         if not build_target:

-             parser.error("No such build target: %s" % target)

-         dest_tag = session.getTag(build_target['dest_tag'])

-         if not dest_tag:

-             parser.error("No such destination tag: %s" % build_target['dest_tag_name'])

-         if dest_tag['locked'] and not build_opts.scratch:

-             parser.error("Destination tag %s is locked" % dest_tag['name'])

-     source = args[1]

-     opts = {}

-     if build_opts.arch_override:

-         opts['arch_override'] = koji.parse_arches(build_opts.arch_override)

-     for key in ('skip_tag', 'scratch', 'repo_id', 'fail_fast', 'wait_repo', 'wait_builds',

-                 'rebuild_srpm'):

-         val = getattr(build_opts, key)

-         if val is not None:

-             opts[key] = val

-     opts["custom_user_metadata"] = custom_user_metadata

-     priority = None

-     if build_opts.background:

-         # relative to koji.PRIO_DEFAULT

-         priority = 5

-     # try to check that source is an SRPM

-     if '://' not in source:

-         # treat source as an srpm and upload it

-         if not build_opts.quiet:

-             print("Uploading srpm: %s" % source)

-         serverdir = unique_path('cli-build')

-         if _running_in_bg() or build_opts.noprogress or build_opts.quiet:

-             callback = None

-         else:

-             callback = _progress_callback

-         session.uploadWrapper(source, serverdir, callback=callback)

-         print('')

-         source = "%s/%s" % (serverdir, os.path.basename(source))

-     task_id = session.build(source, target, opts, priority=priority)

-     if not build_opts.quiet:

-         print("Created task: %d" % task_id)

-         print("Task info: %s/taskinfo?taskID=%s" % (options.weburl, task_id))

-     if build_opts.wait or (build_opts.wait is None and not _running_in_bg()):

-         session.logout()

-         return watch_tasks(session, [task_id], quiet=build_opts.quiet,

-                            poll_interval=options.poll_interval, topurl=options.topurl)

- 

- 

- def handle_chain_build(options, session, args):

-     # XXX - replace handle_build with this, once chain-building has gotten testing

-     "[build] Build one or more packages from source"

-     usage = "usage: %prog chain-build [options] <target> <URL> [<URL> [:] <URL> [:] <URL> ...]"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--wait", action="store_true",

-                       help="Wait on build, even if running in the background")

-     parser.add_option("--nowait", action="store_false", dest="wait", help="Don't wait on build")

-     parser.add_option("--quiet", action="store_true",

-                       help="Do not print the task information", default=options.quiet)

-     parser.add_option("--background", action="store_true",

-                       help="Run the build at a lower priority")

-     (build_opts, args) = parser.parse_args(args)

-     if len(args) < 2:

-         parser.error("At least two arguments (a build target and a SCM URL) are required")

-     activate_session(session, options)

-     target = args[0]

-     build_target = session.getBuildTarget(target)

-     if not build_target:

-         parser.error("No such build target: %s" % target)

-     dest_tag = session.getTag(build_target['dest_tag'], strict=True)

-     if dest_tag['locked']:

-         parser.error("Destination tag %s is locked" % dest_tag['name'])

- 

-     # check that the destination tag is in the inheritance tree of the build tag

-     # otherwise there is no way that a chain-build can work

-     ancestors = session.getFullInheritance(build_target['build_tag'])

-     if dest_tag['id'] not in [build_target['build_tag']] + \

-             [ancestor['parent_id'] for ancestor in ancestors]:

-         warn("Packages in destination tag %(dest_tag_name)s are not inherited by build tag "

-              "%(build_tag_name)s" % build_target)

-         error("Target %s is not usable for a chain-build" % build_target['name'])

-     sources = args[1:]

- 

-     src_list = []

-     build_level = []

-     # src_lists is a list of lists of sources to build.

-     #  each list is block of builds ("build level") which must all be completed

-     #  before the next block begins. Blocks are separated on the command line with ':'

-     for src in sources:

-         if src == ':':

-             if build_level:

-                 src_list.append(build_level)

-                 build_level = []

-         elif '://' in src:

-             # quick check that src might be a url

-             build_level.append(src)

-         elif '/' not in src and not src.endswith('.rpm') and len(src.split('-')) >= 3:

-             # quick check that it looks like a N-V-R

-             build_level.append(src)

-         else:

-             error('"%s" is not a SCM URL or package N-V-R' % src)

-     if build_level:

-         src_list.append(build_level)

- 

-     if len(src_list) < 2:

-         parser.error('You must specify at least one dependency between builds with : (colon)\n'

-                      'If there are no dependencies, use the build command instead')

- 

-     priority = None

-     if build_opts.background:

-         # relative to koji.PRIO_DEFAULT

-         priority = 5

- 

-     task_id = session.chainBuild(src_list, target, priority=priority)

-     if not build_opts.quiet:

-         print("Created task: %d" % task_id)

-         print("Task info: %s/taskinfo?taskID=%s" % (options.weburl, task_id))

-     if build_opts.wait or (build_opts.wait is None and not _running_in_bg()):

-         session.logout()

-         return watch_tasks(session, [task_id], quiet=build_opts.quiet,

-                            poll_interval=options.poll_interval, topurl=options.topurl)

- 

- 

- def handle_maven_build(options, session, args):

-     "[build] Build a Maven package from source"

-     usage = "usage: %prog maven-build [options] <target> <URL>"

-     usage += "\n       %prog maven-build --ini=CONFIG... [options] <target>"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--patches", action="store", metavar="URL",

-                       help="SCM URL of a directory containing patches to apply to the sources "

-                            "before building")

-     parser.add_option("-G", "--goal", action="append", dest="goals", metavar="GOAL", default=[],

-                       help="Additional goal to run before \"deploy\"")

-     parser.add_option("-P", "--profile", action="append", dest="profiles", metavar="PROFILE",

-                       default=[], help="Enable a profile for the Maven build")

-     parser.add_option("-D", "--property", action="append", dest="properties", metavar="NAME=VALUE",

-                       default=[], help="Pass a system property to the Maven build")

-     parser.add_option("-E", "--env", action="append", dest="envs", metavar="NAME=VALUE",

-                       default=[], help="Set an environment variable")

-     parser.add_option("-p", "--package", action="append", dest="packages", metavar="PACKAGE",

-                       default=[], help="Install an additional package into the buildroot")

-     parser.add_option("-J", "--jvm-option", action="append", dest="jvm_options", metavar="OPTION",

-                       default=[], help="Pass a command-line option to the JVM")

-     parser.add_option("-M", "--maven-option", action="append", dest="maven_options",

-                       metavar="OPTION", default=[], help="Pass a command-line option to Maven")

-     parser.add_option("--ini", action="append", dest="inis", metavar="CONFIG", default=[],

-                       help="Pass build parameters via a .ini file")

-     parser.add_option("-s", "--section", help="Get build parameters from this section of the .ini")

-     parser.add_option("--debug", action="store_true", help="Run Maven build in debug mode")

-     parser.add_option("--specfile", action="store", metavar="URL",

-                       help="SCM URL of a spec file fragment to use to generate wrapper RPMs")

-     parser.add_option("--skip-tag", action="store_true", help="Do not attempt to tag package")

-     parser.add_option("--scratch", action="store_true", help="Perform a scratch build")

-     parser.add_option("--wait", action="store_true",

-                       help="Wait on build, even if running in the background")

-     parser.add_option("--nowait", action="store_false", dest="wait", help="Don't wait on build")

-     parser.add_option("--quiet", action="store_true",

-                       help="Do not print the task information", default=options.quiet)

-     parser.add_option("--background", action="store_true",

-                       help="Run the build at a lower priority")

-     (build_opts, args) = parser.parse_args(args)

-     if build_opts.inis:

-         if len(args) != 1:

-             parser.error("Exactly one argument (a build target) is required")

-     else:

-         if len(args) != 2:

-             parser.error("Exactly two arguments (a build target and a SCM URL) are required")

-     activate_session(session, options)

-     target = args[0]

-     build_target = session.getBuildTarget(target)

-     if not build_target:

-         parser.error("No such build target: %s" % target)

-     dest_tag = session.getTag(build_target['dest_tag'])

-     if not dest_tag:

-         parser.error("No such destination tag: %s" % build_target['dest_tag_name'])

-     if dest_tag['locked'] and not build_opts.scratch:

-         parser.error("Destination tag %s is locked" % dest_tag['name'])

-     if build_opts.inis:

-         try:

-             params = koji.util.parse_maven_param(build_opts.inis, scratch=build_opts.scratch,

-                                                  section=build_opts.section)

-         except ValueError as e:

-             parser.error(e.args[0])

-         opts = to_list(params.values())[0]

-         if opts.pop('type', 'maven') != 'maven':

-             parser.error("Section %s does not contain a maven-build config" %

-                          to_list(params.keys())[0])

-         source = opts.pop('scmurl')

-     else:

-         source = args[1]

-         opts = koji.util.maven_opts(build_opts, scratch=build_opts.scratch)

-     if '://' not in source:

-         parser.error("No such SCM URL: %s" % source)

-     if build_opts.debug:

-         opts.setdefault('maven_options', []).append('--debug')

-     if build_opts.skip_tag:

-         opts['skip_tag'] = True

-     priority = None

-     if build_opts.background:

-         # relative to koji.PRIO_DEFAULT

-         priority = 5

-     task_id = session.mavenBuild(source, target, opts, priority=priority)

-     if not build_opts.quiet:

-         print("Created task: %d" % task_id)

-         print("Task info: %s/taskinfo?taskID=%s" % (options.weburl, task_id))

-     if build_opts.wait or (build_opts.wait is None and not _running_in_bg()):

-         session.logout()

-         return watch_tasks(session, [task_id], quiet=build_opts.quiet,

-                            poll_interval=options.poll_interval, topurl=options.topurl)

- 

- 

- def handle_wrapper_rpm(options, session, args):

-     """[build] Build wrapper rpms for any archives associated with a build."""

-     usage = "usage: %prog wrapper-rpm [options] <target> <build-id|n-v-r> <URL>"

-     parser = OptionParser(usage=get_usage_str(usage))

-     parser.add_option("--create-build", action="store_true",

-                       help="Create a new build to contain wrapper rpms")

-     parser.add_option("--ini", action="append", dest="inis", metavar="CONFIG", default=[],

-                       help="Pass build parameters via a .ini file")

-     parser.add_option("-s", "--section",

-                       help="Get build parameters from this section of the .ini")

-     parser.add_option("--skip-tag", action="store_true",

-                       help="If creating a new build, don't tag it")

-     parser.add_option("--scratch", action="store_true", help="Perform a scratch build")

-     parser.add_option("--wait", action="store_true",

-                       help="Wait on build, even if running in the background")

-     parser.add_option("--nowait", action="store_false", dest="wait", help="Don't wait on build")

-     parser.add_option("--background", action="store_true",

-                       help="Run the build at a lower priority")

- 

-     (build_opts, args) = parser.parse_args(args)

-     if build_opts.inis:

-         if len(args) != 1:

-             parser.error("Exactly one argument (a build target) is required")

-     else:

-         if len(args) < 3:

-             parser.error("You must provide a build target, a build ID or NVR, "

-                          "and a SCM URL to a specfile fragment")

-     activate_session(session, options)

- 

-     target = args[0]

-     if build_opts.inis:

-         try:

-             params = koji.util.parse_maven_param(build_opts.inis, scratch=build_opts.scratch,

-                                                  section=build_opts.section)

-         except ValueError as e:

-             parser.error(e.args[0])

-         opts = to_list(params.values())[0]