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' => isset($record['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.     public function getLogs(Request $request = null)
  63.     {
  64.         if (null !== $request) {
  65.             return $this->records[spl_object_hash($request)] ?? [];
  66.         }
  68.         if (0 === \count($this->records)) {
  69.             return [];
  70.         }
  72.         return array_merge(...array_values($this->records));
  73.     }
  75.     /**
  76.      * {@inheritdoc}
  77.      */
  78.     public function countErrors(Request $request = null)
  79.     {
  80.         if (null !== $request) {
  81.             return $this->errorCount[spl_object_hash($request)] ?? 0;
  82.         }
  84.         return array_sum($this->errorCount);
  85.     }
  87.     /**
  88.      * {@inheritdoc}
  89.      */
  90.     public function clear()
  91.     {
  92.         $this->records = [];
  93.         $this->errorCount = [];
  94.     }
  96.     /**
  97.      * {@inheritdoc}
  98.      */
  99.     public function reset()
  100.     {
  101.         $this->clear();
  102.     }
  103. }