src/EventSubscriber/CompanySubscriber.php line 29

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\JobQueue;
  6. use App\Service\EsJobQueue;
  7. use App\Event\CompanyPostUpdateEvent;
  8. use App\Event\CompanyPostPersistEvent;
  9. use Doctrine\ORM\EntityManagerInterface;
  10. use App\Service\JobQueueAction\AttachCompanyToUserAction;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class CompanySubscriber implements EventSubscriberInterface
  14. {
  15.     public function __construct(
  16.         private EntityManagerInterface $_em,
  17.         private EsJobQueue $esJobQueue
  18.     ) {
  19.     }
  21.     public static function getSubscribedEvents(): array
  22.     {
  23.         return [
  24.             CompanyPostPersistEvent::NAME => 'postPersist',
  25.             // CompanyPostUpdateEvent::NAME => 'postUpdate'
  26.         ];
  27.     }
  29.     public function postPersist(CompanyPostPersistEvent $event)
  30.     {
  31.         $data = $event->getObject();
  32.         $payload = ['companyId' => $data->getId()];
  33.         $this->esJobQueue->create(
  34.             AttachCompanyToUserAction::NAME,
  35.             json_encode($payload),
  36.             JobQueue::PRIORITY_LOW
  37.         );
  38.     }
  40.     public function postUpdate(CompanyPostUpdateEvent $event)
  41.     {
  42.         // $data = $event->getObject();
  43.     }
  44. }