Deployer\Executor\SeriesExecutor

Complexity

Total Complexity

8

Size/Duplication

Total Lines	64
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

86.96%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
C	run()	0	30	7

<?php
/* (c) Anton Medvedev <anton@medv.io>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Deployer\Executor;

use Deployer\Console\Output\Informer;
use Deployer\Exception\NonFatalException;
use Deployer\Host\Localhost;
use Deployer\Task\Context;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

class SeriesExecutor implements ExecutorInterface
{
    /**
     * @var InputInterface
     */
    private $input;

    /**
     * @var OutputInterface
     */
    private $output;

    /**
     * @var Informer
     */
    private $informer;

    /**
     * @param InputInterface $input
     * @param OutputInterface $output
     * @param Informer $informer
     */
    public function __construct(InputInterface $input, OutputInterface $output, Informer $informer)
    {
        $this->input = $input;
        $this->output = $output;
        $this->informer = $informer;
    }


    /**
     * {@inheritdoc}
     */
    public function run($tasks, $hosts)
    {
        $localhost = new Localhost();
        foreach ($tasks as $task) {
            $success = true;
            $this->informer->startTask($task);

            if ($task->isLocal()) {
                $task->run(new Context($localhost, $this->input, $this->output));
            } else {
                foreach ($hosts as $host) {
                    if ($task->shouldBePerformed($host)) {
                        try {
                            $task->run(new Context($host, $this->input, $this->output));
                        } catch (NonFatalException $exception) {
                            $success = false;
                            $this->informer->taskException($exception, $host);
                        }
                        $this->informer->endOnHost($host->getHostname());
                    }
                }
            }

            if ($success) {
                $this->informer->endTask($task);
            } else {
                $this->informer->taskError();
            }
        }
    }
}