src/App/Subscriber/RegistrationStatsSubscriber.php line 50

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace App\Subscriber;
  5. use App\Doctrine\Common\Cache\TaggedMemcachedCache;
  6. use App\Entity\User;
  7. use App\Event\EmailVerifiedEvent;
  8. use App\Event\UserRegisteredEvent;
  9. use App\RabbitMq\Handler\RegistrationStatsHandler;
  10. use App\RabbitMq\TasksPool;
  11. use App\Repository\Message\MessageReceptionRepository;
  12. use App\Service\StaticMessageProvider;
  13. use LogicException;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  16. class RegistrationStatsSubscriber implements EventSubscriberInterface
  17. {
  19.     private TasksPool $tasksPool;
  21.     private MessageReceptionRepository $messageReceptionRepository;
  23.     private StaticMessageProvider $staticMessageProvider;
  25.     private TaggedMemcachedCache $taggedMemcachedCache;
  27.     public function __construct(TasksPool $tasksPool, MessageReceptionRepository $messageReceptionRepository, StaticMessageProvider $staticMessageProvider, TaggedMemcachedCache $taggedMemcachedCache)
  28.     {
  29.         $this->tasksPool = $tasksPool;
  30.         $this->messageReceptionRepository = $messageReceptionRepository;
  31.         $this->staticMessageProvider = $staticMessageProvider;
  32.         $this->taggedMemcachedCache = $taggedMemcachedCache;
  33.     }
  35.     public function onUserRegistered(UserRegisteredEvent $event): void
  36.     {
  37.         if (null === $event->getUser()->getId()) {
  38.             throw new LogicException('User must have an id.');
  39.         }
  41.         $this->tasksPool->addTask(
  42.             RegistrationStatsHandler::class,
  43.             'handle',
  44.             User::class,
  45.             $event->getUser()->getId(),
  46.             [RegistrationStatsHandler::REGISTERED]
  47.         );
  48.     }
  50.     public function onEmailVerified(EmailVerifiedEvent $event): void
  51.     {
  52.         $user = $event->getVerification()->getUser();
  53.         if (null === $user) {
  54.             throw new LogicException('Verification must have a User.');
  55.         }
  57.         if (null === $user->getId()) {
  58.             throw new LogicException('User must have an id.');
  59.         }
  61.         $this->tasksPool->addTask(
  62.             RegistrationStatsHandler::class,
  63.             'handle',
  64.             User::class,
  65.             $user->getId(),
  66.             [RegistrationStatsHandler::VALIDATED]
  67.         );
  69.         $welcomeMessage = $this->staticMessageProvider->getWelcomeMessage();
  70.         assert(null !== $welcomeMessage->getId());
  71.         $this->messageReceptionRepository->sendTo($welcomeMessage->getId(), [$user->getId()], $this->taggedMemcachedCache, null);
  72.     }
  74.     /**
  75.      * @return array<string, array<int|string, array<int|string, int|string>|int|string>|string>
  76.      */
  77.     public static function getSubscribedEvents(): array
  78.     {
  79.         return [
  80.             UserRegisteredEvent::class => 'onUserRegistered',
  81.             EmailVerifiedEvent::class => 'onEmailVerified',
  82.         ];
  83.     }
  85. }