src/AppBundle/EventSubscriber/ApiLogSubscriber.php line 39

Open in your IDE?
  1. <?php
  2. namespace AppBundle\EventSubscriber;
  3. use AppBundle\Logger\DelivractLogger;
  4. use AppBundle\Logger\NylasLogger;
  5. use AppBundle\Logger\ZohoCRMLogger;
  6. use Doctrine\ORM\EntityManagerInterface;
  7. use Doctrine\Persistence\ManagerRegistry;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpKernel\Event\FinishRequestEvent;
  10. use Symfony\Component\HttpKernel\KernelEvents;
  11. class ApiLogSubscriber implements EventSubscriberInterface
  12. {
  13.     private ManagerRegistry $registry;
  14.     /**
  15.      * @param ManagerRegistry $registry
  16.      */
  17.     public function __construct(ManagerRegistry $registry) {
  18.         $this->registry $registry;
  19.     }
  20.     /**
  21.      * @return array<mixed>
  22.      */
  23.     public static function getSubscribedEvents(): array
  24.     {
  25.         return [
  26.             KernelEvents::FINISH_REQUEST => 'onKernelFinishRequest',
  27.         ];
  28.     }
  29.     /**
  30.      * @param FinishRequestEvent $responseEvent
  31.      * @return void
  32.      */
  33.     public function onKernelFinishRequest(FinishRequestEvent $responseEvent): void
  34.     {
  35.         /** @var EntityManagerInterface $entityManager */
  36.         $entityManager $this->registry->getManager();
  37.         $connection $entityManager->getConnection();
  38.         if (!$connection->isConnected()) {
  39.             $connection->close();
  40.             $connection->connect();
  41.         }
  42.         if (!$entityManager->isOpen()) {
  43.             $this->registry->resetManager();
  44.         }
  45.         try {
  46.             if ($logs array_merge(
  47.                 ZohoCRMLogger::getLogs(),
  48.                 NylasLogger::getLogs(),
  49.                 DelivractLogger::getLogs()
  50.             )) {
  51.                 foreach ($logs as $log) {
  52.                     $entityManager->persist($log);
  53.                 }
  54.                 $entityManager->flush();
  55.             }
  56.         } catch (\Exception $e) {
  57.         }
  58.     }
  59. }