vendor/symfony/monolog-bridge/Processor/DebugProcessor.php line 20

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Bridge\Monolog\Processor;
  14. use Monolog\Logger;
  15. use Symfony\Component\HttpFoundation\Request;
  16. use Symfony\Component\HttpFoundation\RequestStack;
  17. use Symfony\Component\HttpKernel\Log\DebugLoggerInterface;
  18. use Symfony\Contracts\Service\ResetInterface;
  20. class DebugProcessor implements DebugLoggerInterface, ResetInterface
  21. {
  22.     private $records = [];
  23.     private $errorCount = [];
  24.     private $requestStack;
  26.     public function __construct(RequestStack $requestStack = null)
  27.     {
  28.         $this->requestStack = $requestStack;
  29.     }
  31.     public function __invoke(array $record)
  32.     {
  33.         $hash = $this->requestStack && ($request = $this->requestStack->getCurrentRequest()) ? spl_object_hash($request) : '';
  35.         $this->records[$hash][] = [
  36.             'timestamp' => $record['datetime'] instanceof \DateTimeInterface ? $record['datetime']->getTimestamp() : strtotime($record['datetime']),
  37.             'message' => $record['message'],
  38.             'priority' => $record['level'],
  39.             'priorityName' => $record['level_name'],
  40.             'context' => $record['context'],
  41.             'channel' => $record['channel'] ?? '',
  42.         ];
  44.         if (!isset($this->errorCount[$hash])) {
  45.             $this->errorCount[$hash] = 0;
  46.         }
  48.         switch ($record['level']) {
  49.             case Logger::ERROR:
  50.             case Logger::CRITICAL:
  51.             case Logger::ALERT:
  52.             case Logger::EMERGENCY:
  53.                 ++$this->errorCount[$hash];
  54.         }
  56.         return $record;
  57.     }
  59.     /**
  60.      * {@inheritdoc}
  61.      *
  62.      * @param Request|null $request
  63.      */
  64.     public function getLogs(/* Request $request = null */)
  65.     {
  66.         if (\func_num_args() < 1 && __CLASS__ !== static::class && __CLASS__ !== (new \ReflectionMethod($this, __FUNCTION__))->getDeclaringClass()->getName() && !$this instanceof \PHPUnit\Framework\MockObject\MockObject && !$this instanceof \Prophecy\Prophecy\ProphecySubjectInterface && !$this instanceof \Mockery\MockInterface) {
  67.             @trigger_error(sprintf('The "%s()" method will have a new "Request $request = null" argument in version 5.0, not defining it is deprecated since Symfony 4.2.', __METHOD__), \E_USER_DEPRECATED);
  68.         }
  70.         if (1 <= \func_num_args() && null !== $request = func_get_arg(0)) {
  71.             return $this->records[spl_object_hash($request)] ?? [];
  72.         }
  74.         if (0 === \count($this->records)) {
  75.             return [];
  76.         }
  78.         return array_merge(...array_values($this->records));
  79.     }
  81.     /**
  82.      * {@inheritdoc}
  83.      *
  84.      * @param Request|null $request
  85.      */
  86.     public function countErrors(/* Request $request = null */)
  87.     {
  88.         if (\func_num_args() < 1 && __CLASS__ !== static::class && __CLASS__ !== (new \ReflectionMethod($this, __FUNCTION__))->getDeclaringClass()->getName() && !$this instanceof \PHPUnit\Framework\MockObject\MockObject && !$this instanceof \Prophecy\Prophecy\ProphecySubjectInterface && !$this instanceof \Mockery\MockInterface) {
  89.             @trigger_error(sprintf('The "%s()" method will have a new "Request $request = null" argument in version 5.0, not defining it is deprecated since Symfony 4.2.', __METHOD__), \E_USER_DEPRECATED);
  90.         }
  92.         if (1 <= \func_num_args() && null !== $request = func_get_arg(0)) {
  93.             return $this->errorCount[spl_object_hash($request)] ?? 0;
  94.         }
  96.         return array_sum($this->errorCount);
  97.     }
  99.     /**
  100.      * {@inheritdoc}
  101.      */
  102.     public function clear()
  103.     {
  104.         $this->records = [];
  105.         $this->errorCount = [];
  106.     }
  108.     /**
  109.      * {@inheritdoc}
  110.      */
  111.     public function reset()
  112.     {
  113.         $this->clear();
  114.     }
  115. }