xcp/scripts/koji/koji_import_rpms.py

#!/bin/env python2
from __future__ import print_function
import argparse
import os
import subprocess
import glob

def get_srpm_info(srpmpath):
    return subprocess.check_output(['rpm', '-qp', srpmpath, '--qf', '%{name};;%{nvr}']).split(';;')

def check_dir(dirpath):
    if not os.path.isdir(dirpath):
        raise Exception("Directory %s doesn't exist" % dirpath)
    return dirpath

def main():
    parser = argparse.ArgumentParser(description='Import source RPM(s) and RPM(s) to koji and tag the builds')
    parser.add_argument('srpm_directory', help='path to a directory containing the source RPM(s) we want to import')
    parser.add_argument('rpm_directory', help='path to a directory containing the RPM(s) we want to import')
    parser.add_argument('package_tags', help='comma-separated list of tags for the package(s)')
    parser.add_argument('build_tags', help='comma-separated list of tags for imported build(s)')
    parser.add_argument('--owner', help='owner for the package(s)', default='kojiadmin')
    parser.add_argument('--create-build', help='create the build even if there\'s no SRPM', action='store_true', default=False)
    args = parser.parse_args()

    DEVNULL = open(os.devnull, 'w')

    srpm_directory = os.path.abspath(check_dir(args.srpm_directory))
    rpm_directory = os.path.abspath(check_dir(args.rpm_directory))

    srpms = []
    packages = []
    builds = []
    rpms = []

    for f in glob.glob(os.path.join(srpm_directory, '*.rpm')):
        if f.endswith('.src.rpm'):
            srpms.append(f)
            package, build = get_srpm_info(f)
            packages.append(package)
            builds.append(build)

    for f in glob.glob(os.path.join(rpm_directory, '*.rpm')):
        if not f.endswith('.src.rpm'):
            rpms.append(f)

    create_build = ['--create-build'] if args.create_build else []
    if not srpms and not create_build:
        raise Exception("No source RPMs to import. Use --create-build to force import.")

    if srpms:
        # import the SRPMs
        print('*** Importing SRPMs ***')
        subprocess.check_call(['koji', 'import'] + srpms)
        print()

    # import the RPMS
    print('*** Importing RPMs ***')
    if rpms:
        subprocess.check_call(['koji', 'import'] + create_build + rpms)
    else:
        print("No RPMs to import.")
    print()

    # tag packages
    pkg_tags = args.package_tags.split(',')
    if packages:
        for tag in pkg_tags:
            print('*** Tagging packages %s with tag %s' % (' '.join(packages), tag))
            subprocess.check_call(['koji', 'add-pkg', tag, '--owner', args.owner] + packages)
            print()

    # tag builds
    build_tags = args.build_tags.split(',')
    if builds:
        for tag in build_tags:
            print('*** Tagging builds %s with tag %s' % (' '.join(builds), tag))
            subprocess.check_call(['koji', 'tag-build', tag, '--nowait'] + builds)

    if create_build:
        print("NOTE: You used the --create-build option.")
        print("Packages without SRPMs have not been tagged with tags %s" % pkg_tags)
        print("Builds without SRPMs have not been tagged with tags %s" % build_tags)
        print("You will need to tag them manually.")

if __name__ == "__main__":
    main()