src/EventSubscriber/DocFileVersionSubscriber.php line 28

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\User;
  6. use App\Entity\JobQueue;
  7. use App\Service\EsJobQueue;
  8. use Doctrine\ORM\EntityManagerInterface;
  9. use App\Event\DocFileVersionPostPersistEvent;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  11. use App\Service\JobQueueAction\DocFileVersionNotificationEmailAction;
  13. class DocFileVersionSubscriber implements EventSubscriberInterface
  14. {
  15.     public function __construct(
  16.         private EsJobQueue $esJobQueue,
  17.         private EntityManagerInterface $_em,
  18.     ) {
  19.     }
  21.     public static function getSubscribedEvents(): array
  22.     {
  23.         return [
  24.             DocFileVersionPostPersistEvent::NAME => 'onCreate'
  25.         ];
  26.     }
  28.     public function onCreate(DocFileVersionPostPersistEvent $event)
  29.     {
  30.         $object = $event->getObject();
  32.         $userIds = $this->_em->getRepository(User::class)
  33.                 ->getForDocFileVersionNotification($object);
  35.         $payload = [
  36.             'userIds' => $userIds,
  37.             'docFileVersionId' => $object->getId()
  38.         ];
  39.         $this->esJobQueue->create(
  40.             DocFileVersionNotificationEmailAction::NAME,
  41.             json_encode($payload),
  42.             JobQueue::PRIORITY_MEDIUM
  43.         );
  44.     }
  45. }