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

  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 Monolog\LogRecord;
  16. use Symfony\Component\HttpFoundation\Request;
  17. use Symfony\Component\HttpFoundation\RequestStack;
  18. use Symfony\Component\HttpKernel\Log\DebugLoggerInterface;
  19. use Symfony\Contracts\Service\ResetInterface;
  21. class DebugProcessor implements DebugLoggerInterface, ResetInterface
  22. {
  23.     use CompatibilityProcessor;
  25.     private array $records = [];
  26.     private array $errorCount = [];
  27.     private ?RequestStack $requestStack;
  29.     public function __construct(RequestStack $requestStack = null)
  30.     {
  31.         $this->requestStack = $requestStack;
  32.     }
  34.     private function doInvoke(array|LogRecord $record): array|LogRecord
  35.     {
  36.         $key = $this->requestStack && ($request = $this->requestStack->getCurrentRequest()) ? spl_object_id($request) : '';
  38.         $timestamp = $timestampRfc3339 = false;
  39.         if ($record['datetime'] instanceof \DateTimeInterface) {
  40.             $timestamp = $record['datetime']->getTimestamp();
  41.             $timestampRfc3339 = $record['datetime']->format(\DateTimeInterface::RFC3339_EXTENDED);
  42.         } elseif (false !== $timestamp = strtotime($record['datetime'])) {
  43.             $timestampRfc3339 = (new \DateTimeImmutable($record['datetime']))->format(\DateTimeInterface::RFC3339_EXTENDED);
  44.         }
  46.         $this->records[$key][] = [
  47.             'timestamp' => $timestamp,
  48.             'timestamp_rfc3339' => $timestampRfc3339,
  49.             'message' => $record['message'],
  50.             'priority' => $record['level'],
  51.             'priorityName' => $record['level_name'],
  52.             'context' => $record['context'],
  53.             'channel' => $record['channel'] ?? '',
  54.         ];
  56.         if (!isset($this->errorCount[$key])) {
  57.             $this->errorCount[$key] = 0;
  58.         }
  60.         switch ($record['level']) {
  61.             case Logger::ERROR:
  62.             case Logger::CRITICAL:
  63.             case Logger::ALERT:
  64.             case Logger::EMERGENCY:
  65.                 ++$this->errorCount[$key];
  66.         }
  68.         return $record;
  69.     }
  71.     public function getLogs(Request $request = null): array
  72.     {
  73.         if (null !== $request) {
  74.             return $this->records[spl_object_id($request)] ?? [];
  75.         }
  77.         if (0 === \count($this->records)) {
  78.             return [];
  79.         }
  81.         return array_merge(...array_values($this->records));
  82.     }
  84.     public function countErrors(Request $request = null): int
  85.     {
  86.         if (null !== $request) {
  87.             return $this->errorCount[spl_object_id($request)] ?? 0;
  88.         }
  90.         return array_sum($this->errorCount);
  91.     }
  93.     public function clear()
  94.     {
  95.         $this->records = [];
  96.         $this->errorCount = [];
  97.     }
  99.     public function reset()
  100.     {
  101.         $this->clear();
  102.     }
  103. }