Deployer\Executor\SeriesExecutor

Complexity

Total Complexity

11

Size/Duplication

Total Lines	47
Duplicated Lines	6.38 %

Coupling/Cohesion

Components	0
Dependencies	6

Test Coverage

Coverage

89.29%

Importance

Changes	3
Bugs	1	Features	1

1 Method

Rating	Name	Duplication	Size	Complexity
C	run()	3	41	11

<?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\OutputWatcher;
use Deployer\Server\Environment;
use Deployer\Task\Context;
use Deployer\Task\NonFatalException;

class SeriesExecutor implements ExecutorInterface
{
    /**
     * {@inheritdoc}
     */
    public function run($tasks, $servers, $environments, $input, $output)
    {
        $output = new OutputWatcher($output);
        $informer = new Informer($output);

        foreach ($tasks as $task) {
            $success = true;
            $informer->startTask($task->getName());

            if ($task->isOnce()) {
                $task->run(new Context(null, null, $input, $output));
            } else {
                foreach ($servers as $serverName => $server) {
                    if ($task->runOnServer($serverName)) {
                        $env = isset($environments[$serverName]) ? $environments[$serverName] : $environments[$serverName] = new Environment();

                        if (count($task->getOnlyForStage()) > 0 && (!$env->has('stages') || !$task->runForStages($env->get('stages')))) {

This code seems to be duplicated across your project.

                            continue;
                        }

                        $informer->onServer($serverName);

                        try {
                            $task->run(new Context($server, $env, $input, $output));
                        } catch (NonFatalException $exception) {
                            $success = false;
                            $informer->taskException($serverName, 'Deployer\Task\NonFatalException', $exception->getMessage());
                        }

                        $informer->endOnServer($serverName);
                    }
                }
            }

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