src/Component/ProductComparer/Provider/ComparerProvider.php line 100

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace BitBag\OpenMarketplace\Component\ProductComparer\Provider;
  7. use BitBag\OpenMarketplace\Component\Customer\Model\CustomerInterface;
  8. use BitBag\OpenMarketplace\Component\ProductComparer\Entity\ComparerInterface;
  9. use BitBag\OpenMarketplace\Component\ProductComparer\Event\MissingCookieException;
  10. use BitBag\OpenMarketplace\Component\ProductComparer\Factory\ComparerFactoryInterface;
  11. use BitBag\OpenMarketplace\Component\ProductComparer\Repository\ComparerRepositoryInterface;
  12. use BitBag\OpenMarketplace\Component\Vendor\Entity\ShopUserInterface;
  13. use DateTime;
  14. use Doctrine\ORM\EntityManagerInterface;
  15. use Sylius\Component\Core\Context\ShopperContextInterface;
  16. use Symfony\Component\HttpFoundation\RequestStack;
  18. final class ComparerProvider implements ComparerProviderInterface
  19. {
  20.     public function __construct(
  21.         private ComparerFactoryInterface $comparerFactory,
  22.         private ComparerRepositoryInterface $comparerRepository,
  23.         private ShopperContextInterface $shopperContext,
  24.         private EntityManagerInterface $entityManager,
  25.         private RequestStack $requestStack
  26.     ) {
  27.     }
  29.     /** @inheritDoc */
  30.     public function provide(): ComparerInterface
  31.     {
  32.         $shopUser = $this->getShopUserFromContext();
  34.         $comparer = $shopUser instanceof ShopUserInterface
  35.             ? $this->getComparerForShopUser($shopUser)
  36.             : $this->getComparerForAnonymousUser()
  37.         ;
  39.         $this->clearOldProducts($comparer);
  41.         return $comparer;
  42.     }
  44.     private function clearOldProducts(ComparerInterface $comparer): void
  45.     {
  46.         if (false === $this->isOlderThanOneDay($comparer)) {
  47.             return;
  48.         }
  50.         foreach ($comparer->getComparerProducts() as $comparerProduct) {
  51.             $comparer->removeComparerProduct($comparerProduct);
  52.         }
  54.         $comparer->setCreatedAt(new DateTime());
  56.         $this->entityManager->persist($comparer);
  57.         $this->entityManager->flush();
  58.     }
  60.     private function isOlderThanOneDay(ComparerInterface $comparer): bool
  61.     {
  62.         $createdAt = $comparer->getCreatedAt();
  63.         if (null === $createdAt) {
  64.             return true;
  65.         }
  67.         $now = new DateTime();
  69.         $diff = $now->diff($createdAt);
  71.         return 1 <= $diff->days;
  72.     }
  74.     private function getShopUserFromContext(): ?ShopUserInterface
  75.     {
  76.         $customer = $this->shopperContext->getCustomer();
  77.         if (!$customer instanceof CustomerInterface) {
  78.             return null;
  79.         }
  81.         $shopUser = $customer->getUser();
  82.         if (!$shopUser instanceof ShopUserInterface) {
  83.             return null;
  84.         }
  86.         return $shopUser;
  87.     }
  89.     private function getComparerForShopUser(ShopUserInterface $shopUser): ComparerInterface
  90.     {
  91.         $comparer = $this->comparerRepository->findOneByShopUser($shopUser);
  93.         if ($comparer instanceof ComparerInterface) {
  94.             return $comparer;
  95.         }
  97.         return $this->comparerFactory->createNewForShopUser($shopUser);
  98.     }
  100.     private function getComparerForAnonymousUser(): ComparerInterface
  101.     {
  102.         $session = $this->requestStack->getSession();
  103.         $comparerToken = $session->getId();
  105.         if ('' === $comparerToken) {
  106.             throw new MissingCookieException('Session ID cannot be null');
  107.         }
  109.         $comparer = $this->comparerRepository->findOneByToken($comparerToken);
  110.         if ($comparer instanceof ComparerInterface) {
  111.             return $comparer;
  112.         }
  114.         return $this->comparerFactory->createNewForToken($comparerToken);
  115.     }
  116. }