Paraunit\Printer\FinalPrinter

Complexity

Total Complexity

11

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

100%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	getSubscribedEvents()	0	9	1
A	onEngineStart()	0	4	1
A	onEngineEnd()	0	7	1
A	onProcessTerminated()	0	4	1
A	onProcessToBeRetried()	0	4	1
A	printExecutionTime()	0	6	1
A	printTestCounters()	0	17	4

<?php

declare(strict_types=1);

namespace Paraunit\Printer;

use Paraunit\Lifecycle\EngineEvent;
use Paraunit\Lifecycle\ProcessEvent;
use Paraunit\TestResult\Interfaces\TestResultContainerInterface;
use Paraunit\TestResult\TestResultList;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;
use Symfony\Component\Stopwatch\Stopwatch;
use Symfony\Component\Stopwatch\StopwatchEvent;

/**
 * Class FinalPrinter
 * @package Paraunit\Printer
 */
class FinalPrinter extends AbstractFinalPrinter implements EventSubscriberInterface
{
    const STOPWATCH_NAME = 'engine';

    /** @var Stopwatch */
    private $stopWatch;

    /** @var int */
    private $processCompleted;

    /** @var int */
    private $processRetried;

    /**
     * FinalPrinter constructor.
     * @param TestResultList $testResultList
     * @param OutputInterface $output
     */
    public function __construct(TestResultList $testResultList, OutputInterface $output)
    {
        parent::__construct($testResultList, $output);

        $this->stopWatch = new Stopwatch();
        $this->processCompleted = 0;
        $this->processRetried = 0;
    }

    public static function getSubscribedEvents(): array
    {
        return [
            EngineEvent::START => 'onEngineStart',
            EngineEvent::END => ['onEngineEnd', 300],
            ProcessEvent::PROCESS_TERMINATED => 'onProcessTerminated',
            ProcessEvent::PROCESS_TO_BE_RETRIED => 'onProcessToBeRetried',
        ];
    }

    public function onEngineStart()
    {
        $this->stopWatch->start(self::STOPWATCH_NAME);
    }

    public function onEngineEnd()
    {
        $stopEvent = $this->stopWatch->stop(self::STOPWATCH_NAME);

        $this->printExecutionTime($stopEvent);
        $this->printTestCounters();
    }

    public function onProcessTerminated()
    {
        ++$this->processCompleted;
    }

    public function onProcessToBeRetried()
    {
        ++$this->processRetried;
    }

    private function printExecutionTime(StopwatchEvent $stopEvent)
    {
        $this->getOutput()->writeln('');
        $this->getOutput()->writeln('');
        $this->getOutput()->writeln('Execution time -- ' . gmdate('H:i:s', (int) ($stopEvent->getDuration() / 1000)));
    }

    private function printTestCounters()
    {
        $testsCount = 0;
        foreach ($this->testResultList->getTestResultContainers() as $container) {
            if ($container instanceof TestResultContainerInterface) {
                $testsCount += $container->countTestResults();
            }
        }

        $this->getOutput()->writeln('');
        $this->getOutput()->write(sprintf('Executed: %d test classes', $this->processCompleted - $this->processRetried));
        if ($this->processRetried > 0) {
            $this->getOutput()->write(sprintf(' (%d retried)', $this->processRetried));
        }
        $this->getOutput()->write(sprintf(', %d tests', $testsCount - $this->processRetried));
        $this->getOutput()->writeln('');
    }
}