EdmondsCommerce\DoctrineStaticMeta\EntityManager\RetryConnection\ShouldConnectionByRetried

Complexity

Total Complexity

13

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	attemptsHaveExceededLimit()	0	3	1
A	transactionLevelWillCauseProblems()	0	7	2
A	__construct()	0	4	1
A	checkAndSleep()	0	18	4
A	createWithConfigParams()	0	6	1
A	exceptionIsNotRelatedToLostConnection()	0	10	4

<?php declare(strict_types=1);


namespace EdmondsCommerce\DoctrineStaticMeta\EntityManager\RetryConnection;

/**
 * @SuppressWarnings(PHPMD.BooleanArgumentFlag)
 */
class ShouldConnectionByRetried
{
    public const KEY_USE_RECONNECT = 'should-reconnect';
    public const KEY_RECONNECT_ATTEMPTS = 'reconnect-attempts';
    public const KEY_RECONNECT_TIMEOUT = 'reconnect-timeout';
    /**
     * @var int
     */
    private $allowedAttempts;
    /**
     * @var int
     */
    private $timeout;

    private function __construct(int $allowedAttempts, int $timeout)
    {
        $this->allowedAttempts = $allowedAttempts;
        $this->timeout         = $timeout;
    }

    public static function createWithConfigParams(array $config): ShouldConnectionByRetried
    {
        $allowedAttempts = $config['driverOptions'][self::KEY_RECONNECT_ATTEMPTS] ?? 3;
        $timeout         = $config['driverOptions'][self::KEY_RECONNECT_TIMEOUT] ?? 5;

        return new self($allowedAttempts, $timeout);
    }

    public function checkAndSleep(
        \Exception $exception,
        int $transactionNestingLevel,
        int $numberOfAttempts,
        bool $ignoreTransactionLevel = false
    ): bool {
        switch (true) {
            case $this->attemptsHaveExceededLimit($numberOfAttempts):
            case $this->transactionLevelWillCauseProblems($ignoreTransactionLevel, $transactionNestingLevel):
            case $this->exceptionIsNotRelatedToLostConnection($exception):
                $retry = false;
                break;
            default:
                sleep($this->timeout);
                $retry = true;
        }

        return $retry;
    }


    private function attemptsHaveExceededLimit(int $numberOfAttempts): bool
    {
        return $numberOfAttempts > $this->allowedAttempts;
    }

    private function exceptionIsNotRelatedToLostConnection(\Exception $exception): bool
    {
        $message = $exception->getMessage();
        switch (true) {
            case \ts\stringContains($message, 'MySQL server has gone away'):
            case \ts\stringContains($message, 'Lost connection to MySQL server during query'):
            case \ts\stringContains($message, 'Connection timed out'):
                return false;
            default:
                return true;
        }
    }


    private function transactionLevelWillCauseProblems(bool $ignoreTransactionLevel, int $transactionNestingLevel): bool
    {
        if ($ignoreTransactionLevel === true) {
            return false;
        }

        return $transactionNestingLevel === 0;
    }
}