Abacaphiliac\Doctrine\LogLevelConfiguration

Complexity

Total Complexity

12

Size/Duplication

Total Lines	74
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	2
A	addLogLevelThreshold()	0	5	1
A	isAllowedLogLevel()	0	4	1
A	getAllowedLogLevels()	0	6	2
A	validateLogLevel()	0	10	2
A	getApplicableLogLevel()	0	8	3
A	determineApplicableLogLevel()	0	23	1

<?php

namespace Abacaphiliac\Doctrine;

use InvalidArgumentException;
use Psr\Log\LogLevel;
use ReflectionClass;
use function asort;
use function array_keys;
use function array_search;
use function array_values;
use function print_r;
use function count;

final class LogLevelConfiguration
{
    /** @var array<string, int> */
    private $logLevelMapping = [];

    public function __construct(array $logLevelMapping)
    {
        foreach ($logLevelMapping as $logLevel => $durationThresholdInMilliseconds) {
            $this->addLogLevelThreshold($logLevel, $durationThresholdInMilliseconds);
        }
    }

    private function addLogLevelThreshold(string $logLevel, int $durationThresholdInMilliseconds) : void
    {
        $this->validateLogLevel($logLevel);
        $this->logLevelMapping[$logLevel] = $durationThresholdInMilliseconds;
    }

    private function validateLogLevel(string $logLevel): void
    {
        if (! $this->isAllowedLogLevel($logLevel)) {
            throw new InvalidArgumentException(sprintf(
                'invalid LogLevel detected: "%s", please choose from: "%s"',
                $logLevel,
                print_r($this->getAllowedLogLevels(), true)
            ));
        }
    }
    
    private function isAllowedLogLevel(string $logLevel): bool
    {
        return in_array($logLevel, $this->getAllowedLogLevels(), true);
    }

    private function getAllowedLogLevels(): array
    {
        static $allowedConstants;

        return $allowedConstants ?: $allowedConstants = (new ReflectionClass(LogLevel::class))->getConstants();
    }

    public function getApplicableLogLevel(float $durationInSeconds): ?string
    {
        if ($durationInSeconds <= 0) {
            return null;
        }

        return count($this->logLevelMapping) > 0 ? $this->determineApplicableLogLevel($durationInSeconds) : null;
    }

    private function determineApplicableLogLevel(float $durationInSeconds) : ?string
    {
        $durationInMilliseconds = $durationInSeconds * 1000;

        //Acquire a common / non-associative array with all the thresholds
        $durationThresholds = array_values($this->logLevelMapping);

        //Append the incoming query duration in milliseconds to the array of duration thresholds
        $durationThresholds[] = $durationInMilliseconds;

        //Sort the array from low to high: the provided duration will end up somewhere between the thresholds
        asort($durationThresholds, SORT_NUMERIC);

        //A re-index is required after sorting
        $durationThresholds = array_values($durationThresholds);

        //Determine at which position the duration ended up after sorting
        $key = array_search($durationInMilliseconds, $durationThresholds, true);

        $logLevels = array_keys($this->logLevelMapping);

        return $logLevels[$key - 1] ?? null;
    }
}