Darkilliant\ProcessBundle\ProcessNotifier\ProgressBarProcessNotifier

Complexity

Total Complexity

17

Size/Duplication

Total Lines	90
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	getSubscribedEvents()	0	4	1
A	onCommand()	0	3	1
A	__construct()	0	4	1
A	onStartProcess()	0	3	1
A	onUpdateIterableProcess()	0	11	3
A	onExecutedProcess()	0	2	1
A	onEndProcess()	0	11	3
A	onStartIterableProcess()	0	21	4
A	onFailedLoop()	0	3	1
A	onSuccessLoop()	0	3	1

<?php

namespace Darkilliant\ProcessBundle\ProcessNotifier;

use Darkilliant\ProcessBundle\Console\ProgressBar;
use Darkilliant\ProcessBundle\State\ProcessState;
use Darkilliant\ProcessBundle\Step\MonitorableStepInterface;
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 extends AbstractProcessNotifier 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)
    {
        return;
    }

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

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

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

        if (!$count) {
            return null;
        }

        $this->progressBar->create(
            $count,
            get_class($step),
            $state->getOption('progress_bar_min_item', 50),
            $state->getOption('progress_bar_max_memory', 30)
        );
    }

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

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

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

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

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

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

    public function onExecutedProcess(ProcessState $state, StepInterface $step)
    {
    }

    public function onFailedLoop(ProcessState $state, StepInterface $step)
    {
        return;
    }

    public function onSuccessLoop(ProcessState $state, StepInterface $step)
    {
        return;
    }
}