app/Customize/EventSubscriber/LpStarterCleanupSubscriber.php line 49

Open in your IDE?
  1. <?php
  3. namespace Customize\EventSubscriber;
  5. use Eccube\Service\CartService;
  6. use Eccube\Repository\ProductClassRepository;
  7. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  8. use Symfony\Component\HttpKernel\Event\RequestEvent;
  9. use Symfony\Component\HttpKernel\KernelEvents;
  11. class LpStarterCleanupSubscriber implements EventSubscriberInterface
  12. {
  13.     // default TTL (2 hours)
  14.     private const DEFAULT_TTL = 7200;
  16.     public function __construct(
  17.         private CartService $cartService,
  18.         private ProductClassRepository $productClassRepository
  19.     ) {}
  21.     public static function getSubscribedEvents(): array
  22.     {
  23.         return [
  24.             KernelEvents::REQUEST => ['onKernelRequest', 0],
  25.         ];
  26.     }
  28. public function onKernelRequest(RequestEvent $event): void
  29. {
  30.     if (!$event->isMainRequest()) return;
  32.     $request = $event->getRequest();
  33.     $session = $request->getSession();
  34.     if (!$session) return;
  36.     // Allow setting ttl via query ONCE, and persist it
  37.     if ($request->query->has('lp_cleanup_ttl')) {
  38.         $ttl = max(0, (int) $request->query->get('lp_cleanup_ttl'));
  39.         $session->set('lp_cleanup_ttl', $ttl);
  40.     }
  42.     // Optional: force cleanup param
  43.     if ($request->query->getBoolean('lp_force_cleanup')) {
  44.         $this->clearLpCart($session);
  45.         return;
  46.     }
  48.     // Only act for LP flow
  49.     if ($session->get('lp_flow') !== '1') return;
  51.     $addedAt = (int) $session->get('lp_starter_added_at', 0);
  52.     if ($addedAt <= 0) return;
  54.     $ttl = (int) $session->get('lp_cleanup_ttl', self::DEFAULT_TTL);
  55.     if ($ttl <= 0) return;
  57.     if (time() - $addedAt < $ttl) return;
  59.     $this->clearLpCart($session);
  60.     
  62. }
  64. private function clearLpCart($session): void
  65. {
  66.     if (method_exists($this->cartService, 'clear')) {
  67.         $this->cartService->clear();
  68.         $this->cartService->save();
  69.     }
  71.     // remove flags so we don't keep clearing forever
  72.     $session->remove('lp_flow');
  73.     $session->remove('lp_starter_added_at');
  74.     $session->remove('lp_cleanup_ttl');
  75. }
  78.     private function clearLpFlags($session): void
  79.     {
  80.         foreach ([
  81.             'lp_starter_seeded',
  82.             'lp_starter_seeded_at',
  83.             'lp_starter_pc_id',
  84.             'lp_starter_seed_reason',
  85.         ] as $k) {
  86.             $session->remove($k);
  87.         }
  88.     }
  89. }