Darkilliant\ProcessBundle\ProcessNotifier\ProgressBarProcessNotifier

Complexity

Total Complexity

11

Size/Duplication

Total Lines	58
Duplicated Lines	0 %

Test Coverage

Coverage

96.43%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getSubscribedEvents()	0	4	1
A	onUpdateProcess()	0	7	2
A	onCommand()	0	3	1
A	onEndProcess()	0	7	2
A	__construct()	0	4	1
A	onStartProcess()	0	17	4

<?php

namespace Darkilliant\ProcessBundle\ProcessNotifier;

use Darkilliant\ProcessBundle\Console\ProgressBar;
use Darkilliant\ProcessBundle\State\ProcessState;
use Darkilliant\ProcessBundle\Step\IterableStepInterface;
use Darkilliant\ProcessBundle\Step\StepInterface;
use Symfony\Component\Console\ConsoleEvents;
use Symfony\Component\Console\Event\ConsoleEvent;
use Symfony\Component\Console\Output\NullOutput;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

/**
 * @internal
 * Class ProgressBarProcessNotifier
 */
class ProgressBarProcessNotifier implements EventSubscriberInterface
{
    /** @var ProgressBar */
    private $progressBar;

    public function __construct(ProgressBar $progressBar)
    {
        $this->progressBar = $progressBar;
        $this->progressBar->setOutput(new NullOutput());
    }

    public static function getSubscribedEvents()
    {
        return [
            ConsoleEvents::COMMAND => ['onCommand', 255],
        ];
    }

    public function onCommand(ConsoleEvent $event)
    {
        $this->progressBar->setOutput($event->getOutput());
    }

    public function onStartProcess(ProcessState $state, StepInterface $step)
    {
        if (!$step instanceof IterableStepInterface) {
            return null;
        }

        if (!$state->getOptions()['progress_bar']) {
            return null;
        }

        $count = $step->count($state);

        if (!$count) {
            return null;
        }

        $this->progressBar->create($count, get_class($step));
    }

    public function onUpdateProcess(ProcessState $state, StepInterface $step)
    {
        if (!$state->getOptions()['progress_bar']) {
            return;
        }

        $this->progressBar->setProgress($step->getProgress($state));

The method getProgress() does not exist on Darkilliant\ProcessBundle\Step\StepInterface. Since it exists in all sub-types, consider adding an abstract or default implementation to Darkilliant\ProcessBundle\Step\StepInterface.

    }

    public function onEndProcess(ProcessState $state, StepInterface $step)

The parameter $step is not used and could be removed.

    {
        if (!$state->getOptions()['progress_bar']) {
            return;
        }

        $this->progressBar->finish();
    }
}