from __future__ import absolute_import

import sys
import time
from optparse import OptionParser

import koji
from koji.plugin import export_cli
from koji_cli.lib import (
    activate_session,
    bytes_to_stdout,
    list_task_output_all_volumes,
    watch_tasks
)


@export_cli
def handle_runroot(options, session, args):
    "[admin] Run a command in a buildroot"
    usage = "usage: %prog runroot [options] <tag> <arch> <command>"
    usage += "\n(Specify the --help global option for a list of other help options)"
    parser = OptionParser(usage=usage)
    parser.disable_interspersed_args()
    parser.add_option("-p", "--package", action="append", default=[],
                      help="make sure this package is in the chroot")
    parser.add_option("-m", "--mount", action="append", default=[],
                      help="mount this directory read-write in the chroot")
    parser.add_option("--skip-setarch", action="store_true", default=False,
                      help="bypass normal setarch in the chroot")
    parser.add_option("-w", "--weight", type='int', help="set task weight")
    parser.add_option("--channel-override", help="use a non-standard channel")
    parser.add_option("--task-id", action="store_true", default=False,
                      help="Print the ID of the runroot task")
    parser.add_option("--use-shell", action="store_true", default=False,
                      help="Run command through a shell, otherwise uses exec")
    parser.add_option("--new-chroot", action="store_true", default=None,
                      help="Run command with the --new-chroot (systemd-nspawn) option to mock")
    parser.add_option("--old-chroot", action="store_false", default=None, dest='new_chroot',
                      help="Run command with the --old-chroot (systemd-nspawn) option to mock")
    parser.add_option("--repo-id", type="int", help="ID of the repo to use")
    parser.add_option("--nowait", action="store_false", dest="wait",
                      default=True, help="Do not wait on task")
    parser.add_option("--watch", action="store_true",
                      help="Watch task instead of printing runroot.log")
    parser.add_option("--quiet", action="store_true", default=options.quiet,
                      help="Do not print the task information")

    (opts, args) = parser.parse_args(args)

    if len(args) < 3:
        parser.error("Incorrect number of arguments")
        assert False  # pragma: no cover

    activate_session(session, options)
    tag = args[0]
    arch = args[1]
    if opts.use_shell:
        # everything must be correctly quoted
        command = ' '.join(args[2:])
    else:
        command = args[2:]
    try:
        kwargs = {'channel': opts.channel_override,
                  'packages': opts.package,
                  'mounts': opts.mount,
                  'repo_id': opts.repo_id,
                  'skip_setarch': opts.skip_setarch,
                  'weight': opts.weight}
        # Only pass this kwarg if it is true - this prevents confusing older
        # builders with a different function signature
        if opts.new_chroot is not None:
            kwargs['new_chroot'] = opts.new_chroot

        task_id = session.runroot(tag, arch, command, **kwargs)
    except koji.GenericError as e:
        if 'Invalid method' in str(e):
            print("* The runroot plugin appears to not be installed on the"
                  " koji hub.  Please contact the administrator.")
        raise
    if opts.task_id:
        print(task_id)

    if not opts.wait:
        return

    if opts.watch:
        session.logout()
        return watch_tasks(session, [task_id], quiet=opts.quiet,
                           poll_interval=options.poll_interval, topurl=options.topurl)

    try:
        while True:
            # wait for the task to finish
            if session.taskFinished(task_id):
                break
            time.sleep(options.poll_interval)
    except KeyboardInterrupt:
        # this is probably the right thing to do here
        print("User interrupt: canceling runroot task")
        session.cancelTask(task_id)
        raise
    sys.stdout.flush()
    if not opts.quiet:
        output = list_task_output_all_volumes(session, task_id)
        if 'runroot.log' in output:
            for volume in output['runroot.log']:
                log = session.downloadTaskOutput(task_id, 'runroot.log', volume=volume)
                # runroot output, while normally text, can be *anything*, so
                # treat it as binary
                bytes_to_stdout(log)
    info = session.getTaskInfo(task_id)
    if info is None:
        sys.exit(1)
    state = koji.TASK_STATES[info['state']]
    if state in ('FAILED', 'CANCELED'):
        sys.exit(1)