src/EventSubscriber/InvitationSubscriber.php line 50

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\UserInterface;
  6. use App\Event\ObjectEvent;
  7. use App\Events;
  8. use App\Message\InvitationProcess;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\HttpFoundation\RequestStack;
  11. use Symfony\Component\Messenger\MessageBusInterface;
  13. /**
  14.  * Process user invitation.
  15.  */
  16. class InvitationSubscriber implements EventSubscriberInterface
  17. {
  18.     public const SESSION_NAME = 'app_invite_data';
  20.     /** @var RequestStack */
  21.     private $requestStack;
  23.     /** @var MessageBusInterface */
  24.     private $messageBus;
  26.     /**
  27.      * @param RequestStack        $requestStack
  28.      * @param MessageBusInterface $messageBus
  29.      */
  30.     public function __construct(RequestStack $requestStack, MessageBusInterface $messageBus)
  31.     {
  32.         $this->requestStack = $requestStack;
  33.         $this->messageBus = $messageBus;
  34.     }
  36.     /**
  37.      * {@inheritdoc}
  38.      */
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         return [
  42.             Events::USER_CREATED => 'onUserCreated',
  43.             Events::USER_INVITED => 'onUserInvited',
  44.         ];
  45.     }
  47.     /**
  48.      * @param ObjectEvent $event
  49.      */
  50.     public function onUserCreated(ObjectEvent $event): void
  51.     {
  52.         $user = $event->getObject();
  53.         if ($user instanceof UserInterface) {
  54.             $this->processUser($user);
  55.         }
  56.     }
  58.     /**
  59.      * @param ObjectEvent $event
  60.      */
  61.     public function onUserInvited(ObjectEvent $event): void
  62.     {
  63.         $user = $event->getObject();
  64.         if ($user instanceof UserInterface) {
  65.             $this->processUser($user);
  66.         }
  67.     }
  69.     /**
  70.      * @param UserInterface $user
  71.      */
  72.     private function processUser(UserInterface $user)
  73.     {
  74.         try {
  75.             /** @var SessionInterface $session */
  76.             $session = $this->requestStack->getSession();
  77.         } catch (SessionNotFoundException $e) {
  78.             return;
  79.         }
  81.         if (!$session->has(self::SESSION_NAME)) {
  82.             return;
  83.         }
  85.         // Process invitation
  86.         if ($inviteeData = $session->get(self::SESSION_NAME)) {
  87.             if (isset($inviteeData['id']) && isset($inviteeData['objectClass'])) {
  88.                 $this->messageBus->dispatch(
  89.                     new InvitationProcess(
  90.                         $inviteeData['id'],
  91.                         [
  92.                             'loginUser' => (string) $user->getId(),
  93.                             'objectClass' => $inviteeData['objectClass'],
  94.                         ]
  95.                     )
  96.                 );
  97.             }
  98.         }
  100.         $session->remove(self::SESSION_NAME);
  101.     }
  102. }