src/EventSubscriber/RegistrationEventSubscriber.php line 81

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\Event;
  6. use App\Event\WebShopEvent;
  7. use App\Service\Constants\LogEvents;
  8. use App\Service\RabbitMQ\RabbitMQDispatcher;
  9. use App\Service\Subscription\SubscriptionService;
  10. use App\Service\UserLog;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use App\Event\AccountRegisterEvent;
  15. class RegistrationEventSubscriber implements EventSubscriberInterface
  16. {
  17.     protected RabbitMQDispatcher $rabbitMQDispatcher;
  18.     protected SubscriptionService $subscriptionService;
  19.     private UserLog $userLog;
  21.     public function __construct(
  22.         RabbitMQDispatcher $rabbitMQDispatcher,
  23.         SubscriptionService    $subscriptionService,
  24.         UserLog             $userLog
  25.     ) {
  26.         $this->rabbitMQDispatcher = $rabbitMQDispatcher;
  27.         $this->subscriptionService = $subscriptionService;
  28.         $this->userLog = $userLog;
  29.     }
  31.     public static function getSubscribedEvents() : array
  32.     {
  33.         return [
  34.             AccountRegisterEvent::NAME => 'sendActivationEmail',
  35.             AccountRegisterEvent::MANUFACTURER_USER_REGISTER_SUCCESS => 'sendManufacturerUserRegisterSuccessEmail',
  36.             AccountRegisterEvent::CUSTOMER_USER_REGISTER_SUCCESS => [
  37.                 ['createNewCustomerUserNotification']
  38.             ],
  39.             AccountRegisterEvent::USER_REGISTERED => [
  40.                 ['sendUserRegisteredEmail'],
  41.                 ['logUserCreated']
  42.             ],
  43.         ];
  44.     }
  47.     public function sendUserRegisteredEmail(AccountRegisterEvent $event)
  48.     {
  49.         $this->rabbitMQDispatcher->dispatch([
  50.             'data' => [
  51.                 'user_uuid' => $event->getUser()->getUuid()
  52.             ],
  53.             'action_name' => 'userRegisteredEmail',
  54.             'consumer_name' => 'notification_consumer'
  55.         ]);
  57.     }
  59.     public function logUserCreated(AccountRegisterEvent $event)
  60.     {
  61.         $this->userLog->log(
  62.             'user',
  63.             LogEvents::USER_CREATED,
  64.             $event->getUser()->getId(),
  65.             $event->getUser()->getName()
  66.         );
  67.     }
  69.     public function sendActivationEmail(AccountRegisterEvent $event)
  70.     {
  71.         $this->rabbitMQDispatcher->dispatch([
  72.             'data' => [
  73.                 'user_id' => $event->getUser()->getId(),
  74.             ],
  75.             'action_name' => 'accountActivationEmail',
  76.             'consumer_name' => 'notification_consumer'
  77.         ]);
  79.     }
  81.     public function sendManufacturerUserRegisterSuccessEmail(AccountRegisterEvent $event)
  82.     {
  83.         $this->rabbitMQDispatcher->dispatch([
  84.             'data' => [
  85.                 'user_id' => $event->getUser()->getId(),
  86.             ],
  87.             'action_name' => 'mfPersonRegisterSuccessEmail',
  88.             'consumer_name' => 'notification_consumer'
  89.         ]);
  90.     }
  92.     public function createNewCustomerUserNotification(AccountRegisterEvent $event)
  93.     {
  94.         if ($customer = $event->getUser()->getCustomer()) {
  95.             $this->subscriptionService->proceedEvent(
  96.                 Event::CUSTOMER_APP_USER_CREATED,
  97.                 $customer,
  98.                 ['data' => ['uuid' => $customer->getUuid()]]
  99.             );
  100.         }
  101.     }
  103. }