SubjectivePHP\Psr\Log\NewRelicLogger

Complexity

Total Complexity

6

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	log()	0	15	2
A	addCustomNewRelicParameters()	0	10	3

<?php

namespace SubjectivePHP\Psr\Log;

use Psr\Log\AbstractLogger;
use Psr\Log\LoggerInterface;
use Psr\Log\LogLevel;
use SobanVuex\NewRelic\Agent;

/**
 * PSR-3 Implementation using NewRelic.
 */
final class NewRelicLogger extends AbstractLogger implements LoggerInterface
{
    use ExceptionExtractorTrait;
    use LevelValidatorTrait;
    use MessageValidatorTrait;
    use MessageInterpolationTrait;

    /**
     * NewRelic Agent implementation.
     *
     * @var Agent
     */
    private $newRelicAgent;

    /**
     * Array of log levels which should be reported to new relic.
     *
     * @var array
     */
    private $observedLevels = [];

    /**
     * Default log levels to report.
     *
     * @var array
     */
    const DEFAULT_OBSERVED_LEVELS = [
        LogLevel::EMERGENCY,
        LogLevel::CRITICAL,
    ];

    /**
     * Construct a new instance of the logger.
     *
     * @param Agent $newRelicAgent  NewRelic Agent implementation.
     * @param array $observedLevels Array of log levels which should be reported to new relic.
     */
    public function __construct(Agent $newRelicAgent, array $observedLevels = self::DEFAULT_OBSERVED_LEVELS)
    {
        $this->newRelicAgent = $newRelicAgent;
        $this->observedLevels = $observedLevels;
    }

    /**
     * Logs with an arbitrary level.
     *
     * @param string $level   A valid RFC 5424 log level.
     * @param string $message The base log message.
     * @param array  $context Any extraneous information that does not fit well in a string.
     *
     * @return void
     */
    public function log($level, $message, array $context = [])//@codingStandardsIgnoreLine Interface does not define type-hints or return
    {
        if (!in_array($level, $this->observedLevels)) {
            return;
        }

        $this->validateLevel($level);
        $this->validateMessage($message);

        $exception = $this->getExceptionFromContext($context);
        unset($context['exception']);

        $this->addCustomNewRelicParameters(['level' => $level] + $context);
        $this->newRelicAgent->noticeError((string)$this->interpolateMessage($message, $context), $exception);
    }

    private function addCustomNewRelicParameters(array $context)
    {
        foreach ($context as $key => $value) {
            if (!is_scalar($value)) {
                $value = var_export($value, true);
            }

            $this->newRelicAgent->addCustomParameter($key, $value);
        }
    }
}