src/EventSubscriber/PremiumExpirationSubscriber.php line 34

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Entity\User;
  6. use Doctrine\ORM\EntityManagerInterface;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\HttpKernel\Event\ControllerEvent;
  9. use Symfony\Component\HttpKernel\KernelEvents;
  10. use Symfony\Component\Security\Core\Security;
  11. use Symfony\Component\HttpFoundation\Request;
  13. /**
  14.  * Désactive l'abonnement premium à la volée (sans cron) dès qu'une requête arrive
  15.  * et que la date d'expiration est dépassée.
  16.  */
  17. class PremiumExpirationSubscriber implements EventSubscriberInterface
  18. {
  19.     public function __construct(
  20.         private readonly Security $security,
  21.         private readonly EntityManagerInterface $em,
  22.         private readonly bool $premiumFemaleDefault
  23.     ) {
  24.     }
  26.     public static function getSubscribedEvents(): array
  27.     {
  28.         return [
  29.             // Après le firewall (token déjà résolu), avant l’exécution du contrôleur.
  30.             KernelEvents::CONTROLLER => ['onKernelController', 0],
  31.         ];
  32.     }
  34.     public function onKernelController(ControllerEvent $event): void
  35.     {
  36.         if (!$event->isMainRequest()) {
  37.             return;
  38.         }
  40.         $request = $event->getRequest();
  41.         if ($this->isStaticAsset($request)) {
  42.             return;
  43.         }
  45.         /** @var User|null $user */
  46.         $user = $this->security->getUser();
  47.         if (!$user) {
  48.             return;
  49.         }
  50.         $isFemale = \in_array('ROLE_FEMALE', $user->getRoles(), true);
  51.         if ($this->premiumFemaleDefault && $isFemale) {
  52.             if (!$user->isPremium()) {
  53.                 $this->updatePremiumStatus($user, true);
  54.             }
  55.             return;
  56.         }
  57.         if (!$user->isPremium()) {
  58.             return;
  59.         }
  61.         // payData peut être stocké en array (doctrine json) ou en JSON string :
  62.         $payDataRaw = $user->getPayData();
  63.         $payData = \is_array($payDataRaw) ? $payDataRaw : json_decode((string) $payDataRaw, true);
  64.         if (!\is_array($payData)) {
  65.             // Donnée corrompue ou absente : désactive par sécurité
  66.             $this->updatePremiumStatus($user, false);
  67.             return;
  68.         }
  70.         $nowTs  = time();
  71.         $endTs  = isset($payData['dateAbonnementEnd']) ? (int) $payData['dateAbonnementEnd'] : 0;
  72.         $isPaid = filter_var($payData['isPaid'] ?? false, FILTER_VALIDATE_BOOL);
  74.         $shouldBePremium = $isPaid && $endTs !== 0 && $nowTs < $endTs;
  75.         if (!$user->isPremium() && $shouldBePremium) {
  76.             $this->updatePremiumStatus($user, true);
  77.         }
  78.         $shouldBeDeniedPremium = $endTs === 0 || $endTs < $nowTs;
  79.         if ($user->isPremium() && $shouldBeDeniedPremium) {
  80.             $this->updatePremiumStatus($user, false);
  81.         }
  82.     }
  84.     private function isStaticAsset(Request $request): bool
  85.     {
  86.         $path = $request->getPathInfo();
  87.         return (bool) preg_match('#^/(build|assets|css|js|fonts|img|images|favicon\\.ico|robots\\.txt|_wdt|_profiler)#', $path);
  88.     }
  90.     private function updatePremiumStatus(User $user, bool $isPremium): void
  91.     {
  92.         $user->setIsPremium($isPremium);
  93.         $this->em->persist($user);
  94.         $this->em->flush();
  95.         $this->em->refresh($user);
  96.     }
  97. }