src/FlexApp/EventSubscriber/EmailClickSubscriber.php line 36

Open in your IDE?
  1. <?php
  3. namespace FlexApp\EventSubscriber;
  5. use Doctrine\ORM\EntityManagerInterface;
  6. use FlexApp\Entity\InvitationEmailDeliveryStats;
  7. use FlexApp\Repository\InvitationEmailDeliveryStatsRepository;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  9. use Symfony\Component\HttpKernel\Event\RequestEvent;
  10. use Symfony\Component\HttpKernel\KernelEvents;
  11. use WebBundle\Repository\BuyOrderRepository;
  12. use WebBundle\Repository\UserRepository;
  14. class EmailClickSubscriber implements EventSubscriberInterface
  15. {
  16.     private UserRepository $userRepository;
  17.     private BuyOrderRepository $buyOrderRepository;
  18.     private InvitationEmailDeliveryStatsRepository $invitationEmailDeliveryStatsRepository;
  19.     private EntityManagerInterface $entityManager;
  21.     public function __construct(UserRepository $userRepository, BuyOrderRepository $buyOrderRepository, InvitationEmailDeliveryStatsRepository $invitationEmailDeliveryStatsRepository, EntityManagerInterface $entityManager)
  22.     {
  23.         $this->userRepository = $userRepository;
  24.         $this->buyOrderRepository = $buyOrderRepository;
  25.         $this->invitationEmailDeliveryStatsRepository = $invitationEmailDeliveryStatsRepository;
  26.         $this->entityManager = $entityManager;
  27.     }
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [
  32.             KernelEvents::REQUEST => ['onKernelRequest', 2048],
  33.         ];
  34.     }
  36.     public function onKernelRequest(RequestEvent $event)
  37.     {
  38.         if (!$event->isMainRequest()) {
  39.             return;
  40.         }
  42.         $request = $event->getRequest();
  44.         if ((!str_contains($request->getRequestUri(), 'login_check_link'))) {
  45.             return;
  46.         }
  48.         if (!str_contains($request->getRequestUri(), 'leave_review%2Fshow')) {
  49.             return;
  50.         }
  52.         $email = $request->query->get('user');
  53.         $user = $this->userRepository->findOneBy(['email' => $email]);
  55.         if (!$user) {
  56.             return;
  57.         }
  59.         $redirectUrl = $request->query->get('redirect_url');
  60.         if (!is_string($redirectUrl) || $redirectUrl === '') {
  61.             return;
  62.         }
  64.         $decoded = rawurldecode($redirectUrl);
  65.         $path = parse_url($decoded, PHP_URL_PATH) ?? '';
  67.         $orderId = null;
  69.         if (preg_match('#/leave_review/show/(\d+)(?:$|[/?])#', $path, $m)) {
  70.             $orderId = (int) $m[1];
  71.         }
  73.         $order = $this->buyOrderRepository->findOneBy(['id' => $orderId, 'user' => $user]);
  75.         if (!$order) {
  76.             return;
  77.         }
  79.         $invitationEmailDeliveryStats = $this->invitationEmailDeliveryStatsRepository->findOneBy(['order' => $order]);
  81.         if (!$invitationEmailDeliveryStats) {
  82.             $invitationEmailDeliveryStats = new InvitationEmailDeliveryStats($order);
  83.         }
  85.         $invitationEmailDeliveryStats->setLinkIsClicked(true);
  86.         $this->entityManager->persist($invitationEmailDeliveryStats);
  87.         $this->entityManager->flush();
  88.     }
  89. }