src/EventListener/ApidaeSubscriber.php line 59

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\EventListener;
  5. use App\Entity\ApidaeLog;
  6. use App\Event\ApidaeEvent;
  7. use Doctrine\ORM\EntityManager;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. /**
  12.  * Class ApidaeSubscriber
  13.  * @package App\EventListener
  14.  */
  15. class ApidaeSubscriber implements EventSubscriberInterface
  16. {
  17.     /** @var EntityManager|EntityManagerInterface */
  18.     private $entityManager;
  20.     /**
  21.      * UserSubscriber constructor.
  22.      *
  23.      * @param EntityManagerInterface $entityManager
  24.      */
  25.     public function __construct(EntityManagerInterface $entityManager)
  26.     {
  27.         $this->entityManager = $entityManager;
  28.     }
  30.     /**
  31.      * @return array
  32.      */
  33.     public static function getSubscribedEvents()
  34.     {
  35.         return [
  36.             ApidaeEvent::APIDAE_IMPORT_ERROR    => ['importError'],
  37.             ApidaeEvent::APIDAE_UPDATE_ERROR    => ['updateError'],
  38.             ApidaeEvent::APIDAE_IMPORT_INFO     => ['importInfo'],
  39.             ApidaeEvent::APIDAE_UPDATE_INFO     => ['updateInfo']
  40.         ];
  41.     }
  43.     /**
  44.      * @param \App\Event\ApidaeEvent $event
  45.      */
  46.     public function importError(ApidaeEvent $event)
  47.     {
  48.         $apiLog = new ApidaeLog();
  49.         $apiLog->setState(ApidaeEvent::APIDAE_IMPORT_ERROR);
  50.         $apiLog->setMessage($event->getMessage());
  52.         $this->entityManager->persist($apiLog);
  53.         $this->entityManager->flush();
  54.     }
  56.     /**
  57.      * @param \App\Event\ApidaeEvent $event
  58.      */
  59.     public function updateError(ApidaeEvent $event)
  60.     {
  61.         $apiLog = new ApidaeLog();
  62.         $apiLog->setState(ApidaeEvent::APIDAE_UPDATE_ERROR);
  63.         $apiLog->setMessage($event->getMessage());
  64.         $apiLog->setCode($event->getCode());
  66.         $this->entityManager->persist($apiLog);
  67.         $this->entityManager->flush();
  68.     }
  70.     /**
  71.      * @param \App\Event\ApidaeEvent $event
  72.      */
  73.     public function importInfo(ApidaeEvent $event)
  74.     {
  75.         $apiLog = new ApidaeLog();
  76.         $apiLog->setState(ApidaeEvent::APIDAE_IMPORT_INFO);
  77.         $apiLog->setMessage($event->getMessage());
  78.         $apiLog->setCode($event->getCode());
  80.         $this->entityManager->persist($apiLog);
  81.         $this->entityManager->flush();
  82.     }
  84.     /**
  85.      * @param \App\Event\ApidaeEvent $event
  86.      */
  87.     public function updateInfo(ApidaeEvent $event)
  88.     {
  89.         $apiLog = new ApidaeLog();
  90.         $apiLog->setState(ApidaeEvent::APIDAE_UPDATE_INFO);
  91.         $apiLog->setMessage($event->getMessage());
  92.         $apiLog->setCode($event->getCode());
  94.         $this->entityManager->persist($apiLog);
  95.         $this->entityManager->flush();
  96.     }
  97. }