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

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 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. $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 (!$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(): void
  94. {
  95. $this->records = [];
  96. $this->errorCount = [];
  97. }
  99. /**
  100. * @return void
  101. */
  102. public function reset()
  103. {
  104. $this->clear();
  105. }
  106. }