# Koji tag2distrepo hub plugin
# Copyright (c) 2019 Red Hat, Inc.
# This callback automatically schedules distrepo tasks based on a tags config
#
# Authors:
#   Patrick Uiterwijk <puiterwijk@redhat.com>

from __future__ import absolute_import
from koji.plugin import callback
from kojihub import dist_repo_init, make_task, readTaggedRPMS, write_signed_rpm
import logging

@callback('postTag')
def tag2distrepo(cbtype, tag, build, user, force=False):
    logger = logging.getLogger('koji.plugin.tag2distrepo')

    if not tag['extra'].get("tag2distrepo.enabled"):
        logger.debug("No tag2distrepo enabled for tag %s" % tag['name'])
        return
    if not tag['arches']:
        raise ValueError("Tag %s has no arches configured but tag2distrepo is enabled" % tag['name'])

    keys = tag['extra'].get("tag2distrepo.keys", '').split()

    if keys:
        logger.debug("Ensuring signed RPMs are written out")
        [rpms, _] = readTaggedRPMS(tag['id'], rpmsigs=True)
        for rpm in rpms:
            for key in keys:
                if rpm['sigkey'] == key:
                    write_signed_rpm(rpm['id'], key, False)

    task_opts = {
        'arch': tag['arches'].split(),
        'comp': None,
        'delta': [],
        'event': None,
        'inherit': False,
        'latest': False,
        'multilib': False,
        'split_debuginfo': False,
        'skip_missing_signatures': False,
        'allow_missing_signatures': not keys,
    }
    logging.debug(
        "Scheduling distRepo for tag %s, keys %s",
        tag['name'],
        keys,
    )

    repo_id, event_id = dist_repo_init(tag['name'], keys, task_opts)
    task_opts['event'] = event_id
    task_id = make_task(
        'distRepo',
        [tag['name'], repo_id, keys, task_opts],
        priority=15,
        channel='createrepo',
    )
    logging.info("distRepo task %d scheduled for tag %s" % (task_id, tag['name']))