src/Products/NotificationsBundle/Subscriber/AutomationSubscriber.php line 51

Open in your IDE?
  1. <?php
  3. namespace Products\NotificationsBundle\Subscriber;
  5. use Cms\CoreBundle\Util\Doctrine\EntityManager;
  6. use DateTime;
  7. use Platform\QueueBundle\Event\AsyncEvent;
  8. use Products\NotificationsBundle\Entity\Automation;
  9. use Products\NotificationsBundle\Entity\Notifications\Invocation;
  10. use Products\NotificationsBundle\Entity\Notifications\Template;
  11. use Products\NotificationsBundle\Service\MessageLogic;
  12. use Products\NotificationsBundle\Service\Switchboard;
  13. use RuntimeException;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. final class AutomationSubscriber implements EventSubscriberInterface
  17. {
  18.     /**
  19.      * @var EntityManager
  20.      */
  21.     protected EntityManager $em;
  23.     /**
  24.      * @var MessageLogic
  25.      */
  26.     protected MessageLogic $messageLogic;
  28.     /**
  29.      * @param EntityManager $em
  30.      * @param MessageLogic $messageLogic
  31.      */
  32.     public function __construct(EntityManager $em, MessageLogic $messageLogic)
  33.     {
  34.         $this->em = $em;
  35.         $this->messageLogic = $messageLogic;
  36.     }
  38.     /**
  39.      * {@inheritDoc}
  40.      */
  41.     public static function getSubscribedEvents(): array
  42.     {
  43.         return [
  44.             Switchboard::EVENTS__BROADCAST_AUTOMATION => ['onBroadcastAutomation', 0],
  45.         ];
  46.     }
  48.     /**
  49.      * @param AsyncEvent $event
  50.      */
  51.     public function onBroadcastAutomation(AsyncEvent $event): void
  52.     {
  53.         $automation = $this->em->getRepository(Automation::class)->find(
  54.             $event->getBody()->get('automation')
  55.         );
  57.         if ( ! $automation instanceof Automation) {
  58.             throw new RuntimeException();
  59.         }
  61.         if ( ! $automation->getTemplate() instanceof Template) {
  62.             throw new RuntimeException();
  63.         }
  65.         $this->messageLogic->broadcast($this->createInvocation($automation));
  66.     }
  68.     /**
  69.      * @param Automation $automation
  70.      * @return Invocation
  71.      */
  72.     private function createInvocation(Automation $automation): Invocation
  73.     {
  74.         $invocation = new Invocation();
  75.         $invocation->setAutomation($automation);
  76.         $invocation->setConditionQuery($automation->getRunnableConditionQuery());
  77.         $invocation->setInvocationTimestamp(new DateTime());
  79.         $this->messageLogic->init($invocation, $automation->getTemplate());
  81.         $this->em->save($invocation);
  83.         return $invocation;
  84.     }
  85. }