Paraunit\Parser\RetryParser

Complexity

Total Complexity

10

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes	5
Bugs	1	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	16	1
A	getOutputContainer()	0	4	1
A	parsingFoundResult()	0	14	4
A	isToBeRetried()	0	4	2
A	hasNotExceededRetryCount()	0	4	1
A	buildRegexPattern()	0	6	1

<?php

namespace Paraunit\Parser;

use Paraunit\Printer\OutputContainerInterface;
use Paraunit\Process\ProcessResultInterface;
use Paraunit\Process\RetryAwareInterface;

/**
 * Class RetryParser
 * @package Paraunit\Parser
 */
class RetryParser implements JSONParserChainElementInterface, OutputContainerBearerInterface
{
    /** @var  OutputContainerInterface */
    private $outputContainer;

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

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

    /**
     * RetryParser constructor.
     * @param OutputContainerInterface $outputContainer
     * @param int $maxRetryCount
     */
    public function __construct(OutputContainerInterface $outputContainer, $maxRetryCount = 3)
    {
        $this->outputContainer = $outputContainer;
        $this->maxRetryCount = $maxRetryCount;

        $patterns = array(
            'The EntityManager is closed',
            // MySQL
            'Deadlock found',
            'Lock wait timeout exceeded',
            // SQLite
            'General error: 5 database is locked',
        );

        $this->regexPattern = $this->buildRegexPattern($patterns);
    }

    /**
     * @return OutputContainerInterface
     */
    public function getOutputContainer()
    {
        return $this->outputContainer;
    }

    /**
     * {@inheritdoc}
     */
    public function parsingFoundResult(ProcessResultInterface $process, \stdClass $log)
    {
        if ($process instanceof RetryAwareInterface
            && $this->isToBeRetried($log)
            && $this->hasNotExceededRetryCount($process)
        ) {
            $process->markAsToBeRetried();
            $process->addTestResult($this->getOutputContainer()->getSingleResultMarker());

            return true;
        }

        return false;
    }

    /**
     * @param \stdClass $log
     * @return bool
     */
    private function isToBeRetried(\stdClass $log)
    {
        return $log->status == 'error' && preg_match($this->regexPattern, $log->message);
    }


    private function hasNotExceededRetryCount(RetryAwareInterface $process)
    {
        return $process->getRetryCount() < $this->maxRetryCount;
    }

    /**
     * @param array | string[] $patterns
     * @return string
     */
    private function buildRegexPattern(array $patterns)
    {
        $regex = implode('|', $patterns);

        return '/' . $regex . '/';
    }
}