Paraunit\Parser\JSON\TestStartParser

Complexity

Total Complexity

17

Size/Duplication

Total Lines	86
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	handleLogItem()	0	18	6
A	handleLogTermination()	0	10	2
A	saveProcessFunction()	0	5	2
A	injectLastFunctionInEndingLog()	0	8	3
A	saveTestFQCN()	0	17	4

<?php

declare(strict_types=1);

namespace Paraunit\Parser\JSON;

use Paraunit\Process\AbstractParaunitProcess;
use Paraunit\TestResult\NullTestResult;

/**
 * Class TestStartParser
 * @package Paraunit\Parser\JSON
 */
class TestStartParser implements ParserChainElementInterface
{
    const UNKNOWN_FUNCTION = 'UNKNOWN -- log not found';

    /** @var AbstractParaunitProcess */
    private $lastProcess;

    /** @var string */
    private $lastFunction;

    public function handleLogItem(AbstractParaunitProcess $process, \stdClass $logItem)
    {
        if (property_exists($logItem, 'status') && $logItem->status === LogFetcher::LOG_ENDING_STATUS) {
            return $this->handleLogTermination($process, $logItem);
        }

        if (property_exists($logItem, 'event')) {
            if ($logItem->event === 'testStart' || $logItem->event === 'suiteStart') {
                $process->setWaitingForTestResult(true);
                $this->saveProcessFunction($process, $logItem);
                $this->saveTestFQCN($process, $logItem);

                return new NullTestResult();
            }
        }

        return null;
    }

    /**
     * @param AbstractParaunitProcess $process
     * @param \stdClass $logItem
     * @return null|NullTestResult
     */
    private function handleLogTermination(AbstractParaunitProcess $process, \stdClass $logItem)
    {
        if ($process->isWaitingForTestResult()) {
            $this->injectLastFunctionInEndingLog($process, $logItem);

            return null;
        }

        return new NullTestResult();
    }

    /**
     * @param AbstractParaunitProcess $process
     * @param \stdClass $logItem
     */
    private function saveProcessFunction(AbstractParaunitProcess $process, \stdClass $logItem)
    {
        $this->lastProcess = $process;
        $this->lastFunction = property_exists($logItem, 'test') ? $logItem->test : self::UNKNOWN_FUNCTION;
    }

    /**
     * @param AbstractParaunitProcess $process
     * @param \stdClass $logItem
     */
    private function injectLastFunctionInEndingLog(AbstractParaunitProcess $process, \stdClass $logItem)
    {
        $logItem->test = $this->lastFunction;

        if ($this->lastFunction === null || $process !== $this->lastProcess) {
            $logItem->test = self::UNKNOWN_FUNCTION;
        }
    }

    private function saveTestFQCN(AbstractParaunitProcess $process, \stdClass $logItem)
    {
        if ($process->getTestClassName()) {
            return;
        }

        if (! property_exists($logItem, 'suite')) {
            return;
        }

        if (! property_exists($logItem, 'test')) {
            return;
        }

        $suiteName = explode('::', $logItem->suite);
        $process->setTestClassName($suiteName[0]);
    }
}