# Copyright 1999-2020 Gentoo Authors
# Distributed under the terms of the GNU General Public License v2

from collections import deque

from portage import os
from _emerge.CompositeTask import CompositeTask
from _emerge.AsynchronousTask import AsynchronousTask


class TaskSequence(CompositeTask):
    """
    A collection of tasks that executes sequentially. Each task
    must have a addExitListener() method that can be used as
    a means to trigger movement from one task to the next.
    """

    __slots__ = ("_task_queue",)

    def __init__(self, **kwargs):
        AsynchronousTask.__init__(self, **kwargs)
        self._task_queue = deque()

    def add(self, task):
        self._task_queue.append(task)

    def _start(self):
        self._start_next_task()

    def _cancel(self):
        self._task_queue.clear()
        CompositeTask._cancel(self)

    def _start_next_task(self):
        try:
            task = self._task_queue.popleft()
        except IndexError:
            self._current_task = None
            self.returncode = os.EX_OK
            self.wait()
            return

        self._start_task(task, self._task_exit_handler)

    def _task_exit_handler(self, task):
        if self._default_exit(task) != os.EX_OK:
            self.wait()
        elif self._task_queue:
            self._start_next_task()
        else:
            self._final_exit(task)
            self.wait()

    def __bool__(self):
        return bool(self._task_queue)

    def __len__(self):
        return len(self._task_queue)