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

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.         $timestamp = $timestampRfc3339 = false;
  36.         if ($record['datetime'] instanceof \DateTimeInterface) {
  37.             $timestamp = $record['datetime']->getTimestamp();
  38.             $timestampRfc3339 = $record['datetime']->format(\DateTimeInterface::RFC3339_EXTENDED);
  39.         } elseif (false !== $timestamp = strtotime($record['datetime'])) {
  40.             $timestampRfc3339 = (new \DateTimeImmutable($record['datetime']))->format(\DateTimeInterface::RFC3339_EXTENDED);
  41.         }
  43.         $this->records[$hash][] = [
  44.             'timestamp' => $timestamp,
  45.             'timestamp_rfc3339' => $timestampRfc3339,
  46.             'message' => $record['message'],
  47.             'priority' => $record['level'],
  48.             'priorityName' => $record['level_name'],
  49.             'context' => $record['context'],
  50.             'channel' => $record['channel'] ?? '',
  51.         ];
  53.         if (!isset($this->errorCount[$hash])) {
  54.             $this->errorCount[$hash] = 0;
  55.         }
  57.         switch ($record['level']) {
  58.             case Logger::ERROR:
  59.             case Logger::CRITICAL:
  60.             case Logger::ALERT:
  61.             case Logger::EMERGENCY:
  62.                 ++$this->errorCount[$hash];
  63.         }
  65.         return $record;
  66.     }
  68.     /**
  69.      * {@inheritdoc}
  70.      */
  71.     public function getLogs(Request $request = null)
  72.     {
  73.         if (null !== $request) {
  74.             return $this->records[spl_object_hash($request)] ?? [];
  75.         }
  77.         if (0 === \count($this->records)) {
  78.             return [];
  79.         }
  81.         return array_merge(...array_values($this->records));
  82.     }
  84.     /**
  85.      * {@inheritdoc}
  86.      */
  87.     public function countErrors(Request $request = null)
  88.     {
  89.         if (null !== $request) {
  90.             return $this->errorCount[spl_object_hash($request)] ?? 0;
  91.         }
  93.         return array_sum($this->errorCount);
  94.     }
  96.     /**
  97.      * {@inheritdoc}
  98.      */
  99.     public function clear()
  100.     {
  101.         $this->records = [];
  102.         $this->errorCount = [];
  103.     }
  105.     /**
  106.      * {@inheritdoc}
  107.      */
  108.     public function reset()
  109.     {
  110.         $this->clear();
  111.     }
  112. }