src/Logger/LogProcessor.php line 87

  1. <?php
  3. namespace App\Logger;
  5. use App\Entity\User;
  6. use Monolog\LogRecord;
  7. use Monolog\Level;
  8. use Symfony\Component\Asset\Context\RequestStackContext;
  9. use Symfony\Component\HttpFoundation\RequestStack;
  10. use Symfony\Component\HttpKernel\Event\RequestEvent;
  11. use Symfony\Component\HttpKernel\Exception\NotFoundHttpException;
  12. use Symfony\Component\Security\Core\Authentication\Token\Storage\TokenStorageInterface;
  14. class LogProcessor
  15. {
  16.     /**
  17.      * @var User
  18.      */
  19.     private $user;
  21.     private $pathInfo;
  23.     private $uri;
  25.     private $method;
  27.     private $params;
  29.     private $json;
  31.     private $tokenStorage;
  33.     public function __construct(TokenStorageInterface $tokenStorage)
  34.     {
  35.         $this->tokenStorage = $tokenStorage;
  36.     }
  38.     // this method is called for each log record; optimize it to not hurt performance
  39.     public function __invoke(LogRecord $record): LogRecord
  40.     {
  41.         // Skip processing 404 errors to prevent them from being logged/emailed
  42.         if ($this->is404Error($record)) {
  43.             // Create a new record with DEBUG level instead of directly modifying it
  44.             return $record->with(level: Level::Debug);
  45.         }
  46.         
  47.         $record = $record->with(extra: array_merge($record->extra, [
  48.             'url' => $this->pathInfo,
  49.             'uri' => $this->uri,
  50.             'method' => $this->method,
  51.             'params' => $this->params,
  52.             'json' => $this->json,
  53.             'user' => 'anon.'
  54.         ]));
  56.         if (!$this->user) {
  57.             return $record;
  58.         }
  59.         $email = $this->user->getEmail();
  60.         
  61.         return $record->with(extra: array_merge($record->extra, [
  62.             'user' => $email
  63.         ]));
  64.     }
  66.     /**
  67.      * Check if the log record is for a 404 error
  68.      */
  69.     private function is404Error(LogRecord $record): bool
  70.     {
  71.         // Check if this is a NotFoundHttpException
  72.         if (isset($record['context']['exception']) && $record['context']['exception'] instanceof NotFoundHttpException) {
  73.             return true;
  74.         }
  75.         
  76.         // Check message content for 404 error patterns
  77.         if (isset($record['message']) && (
  78.             strpos($record['message'], 'NotFoundHttpException') !== false ||
  79.             strpos($record['message'], 'No route found') !== false
  80.         )) {
  81.             return true;
  82.         }
  83.         
  84.         return false;
  85.     }
  87.     public function onKernelRequest(RequestEvent $event): void
  88.     {
  89.         $request = $event->getRequest();
  90.         $this->pathInfo = $request->getPathInfo();
  91.         $this->method = $request->getMethod();
  92.         $this->uri = $request->getRequestUri();
  93.     
  94.         if ('GET' === $this->method) {
  95.             $params = $request->query->all();
  96.         } elseif ('application/json' === $request->getContentTypeFormat()) {
  97.             $content = $request->getContent();
  98.             $params = json_decode($content, true) ?? [];
  99.             $this->json = $content;
  100.         } else {
  101.             $params = $request->request->all();
  102.         }
  103.     
  104.         $this->params = json_encode($params);
  105.     
  106.         $token = $this->tokenStorage->getToken();
  107.         if (null === $token) {
  108.             return;
  109.         }
  110.     
  111.         $user = $token->getUser();
  112.         if (!is_object($user)) { // e.g. anonymous authentication
  113.             return;
  114.         }
  115.         
  116.         $this->user = $user;    
  117.     }
  118. }