src/EventListener/ExceptionSubscriber.php line 28

  1. <?php
  3. namespace App\EventListener;
  5. use App\Entity\Admin\ApiLog;
  6. use App\Entity\SystemLog;
  7. use App\Service\Logger\LoggerService;
  8. use Doctrine\ORM\EntityManager;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use Doctrine\Persistence\ManagerRegistry;
  11. use Symfony\Component\Console\Event\ConsoleErrorEvent;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\HttpFoundation\RequestStack;
  14. use Symfony\Component\HttpKernel\Event\ExceptionEvent;
  15. use Symfony\Component\HttpKernel\KernelEvents;
  17. class ExceptionSubscriber implements EventSubscriberInterface
  18. {
  19.     public function __construct(readonly EntityManagerInterface $entityManager, readonly ManagerRegistry $managerRegistry,readonly RequestStack $requestStack)
  20.     {
  21.     }
  23.     public function onKernelException(ExceptionEvent $event): void
  24.     {
  25.         $this->logError($event->getThrowable()->getMessage());
  26.     }
  28.     public function onCommandException(ConsoleErrorEvent $event): void
  29.     {
  30.         $this->logError($event->getError());
  31.     }
  33.     public function logError(string $message): void
  34.     {
  35.         //reopen the entity manager if it is closed
  36.         if(!$this->entityManager->isOpen()){
  37.             $this->managerRegistry->resetManager();
  38.         }
  40.         $ip = "undefined";
  41.         $request = $this->requestStack->getCurrentRequest();
  42.         if ($request) {
  43.             $ip = $request->getClientIp();
  44.         }
  46.         $systemLog = new ApiLog();
  48.         $germanTime = new \DateTimeImmutable();
  49.         $germanTime->setTimezone(new \DateTimeZone('Europe/Berlin'));
  50.         $systemLog->setCreatedAt($germanTime);
  51.         $systemLog->setLog("[".$ip."]" . " " . $message);
  52.         $systemLog->setSuccess(false);
  55.         $this->entityManager->persist($systemLog);
  56.         $this->entityManager->flush();
  58.         //zähle alle system logs
  59.         $systemLogs = $this->entityManager->getRepository(ApiLog::class)->findAll();
  60.         $countSystemLogs = count($systemLogs);
  62.         // es soll nicht mehr als 10000 Einträge geben
  63.         if($countSystemLogs > 10000){
  64.             //lösche den ältesten
  65.             $oldestSystemLog = $this->entityManager->getRepository(ApiLog::class)->findOneBy([], ['createdAt' => 'ASC']);
  66.             $this->entityManager->remove($oldestSystemLog);
  67.         }
  69.     }
  70.     public static function getSubscribedEvents(): array
  71.     {
  72.         return [
  73.             KernelEvents::EXCEPTION => 'onKernelException',
  74.             ConsoleErrorEvent::class => 'onCommandException'
  75.         ];
  76.     }
  77. }