src/Component/Elasticsearch/Controller/ListProductsAction.php line 21

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace BitBag\OpenMarketplace\Component\Elasticsearch\Controller;
  7. use BitBag\OpenMarketplace\Component\Elasticsearch\Provider\RedirectResponseProviderInterface;
  8. use BitBag\OpenMarketplace\Component\Taxonomy\Entity\TaxonInterface;
  9. use BitBag\SyliusElasticsearchPlugin\Controller\RequestDataHandler\DataHandlerInterface;
  10. use BitBag\SyliusElasticsearchPlugin\Controller\RequestDataHandler\PaginationDataHandlerInterface;
  11. use BitBag\SyliusElasticsearchPlugin\Controller\RequestDataHandler\SortDataHandlerInterface;
  12. use BitBag\SyliusElasticsearchPlugin\Finder\ShopProductsFinderInterface;
  13. use BitBag\SyliusElasticsearchPlugin\Form\Type\ShopProductsFilterType;
  14. use Symfony\Component\Form\FormError;
  15. use Symfony\Component\Form\FormFactoryInterface;
  16. use Symfony\Component\Form\FormInterface;
  17. use Symfony\Component\HttpFoundation\Request;
  18. use Symfony\Component\HttpFoundation\Response;
  19. use Twig\Environment;
  21. final class ListProductsAction
  22. {
  23.     private static iterable $currentPageProducts;
  25.     private static TaxonInterface $taxon;
  27.     public function __construct(
  28.         private FormFactoryInterface $formFactory,
  29.         private DataHandlerInterface $shopProductListDataHandler,
  30.         private SortDataHandlerInterface $shopProductsSortDataHandler,
  31.         private PaginationDataHandlerInterface $paginationDataHandler,
  32.         private ShopProductsFinderInterface $shopProductsFinder,
  33.         private Environment $twig,
  34.         private RedirectResponseProviderInterface $redirectResponseProvider
  35.     ) {
  36.     }
  38.     public function __invoke(Request $request): Response
  39.     {
  40.         $redirectResponse = $this->redirectResponseProvider->provide($request, [
  41.             'slug' => $request->get('slug'),
  42.         ]);
  44.         if (null !== $redirectResponse) {
  45.             return $redirectResponse;
  46.         }
  48.         $form = $this->formFactory->create(ShopProductsFilterType::class);
  49.         $form->handleRequest($request);
  50.         $requestData = array_merge(
  51.             $form->getData(),
  52.             $request->query->all(),
  53.             ['slug' => $request->get('slug')]
  54.         );
  56.         if (!$form->isValid()) {
  57.             $requestData = $this->clearInvalidEntries($form, $requestData);
  58.         }
  60.         $data = array_merge(
  61.             $this->shopProductListDataHandler->retrieveData($requestData),
  62.             $this->shopProductsSortDataHandler->retrieveData($requestData),
  63.             $this->paginationDataHandler->retrieveData($requestData)
  64.         );
  66.         $template = $request->get('template');
  67.         $products = $this->shopProductsFinder->find($data);
  69.         self::$currentPageProducts = $products->getCurrentPageResults();
  70.         self::$taxon = $data['taxon'];
  72.         return new Response($this->twig->render($template, [
  73.             'form' => $form->createView(),
  74.             'products' => $products,
  75.             'taxon' => $data['taxon'],
  76.         ]));
  77.     }
  79.     private function clearInvalidEntries(FormInterface $form, array $requestData): array
  80.     {
  81.         /** @var FormError $error */
  82.         foreach ($form->getErrors(true) as $error) {
  83.             $errorOrigin = $error->getOrigin();
  84.             if (null === $errorOrigin) {
  85.                 continue;
  86.             }
  88.             $parent = $errorOrigin->getParent();
  89.             if (null === $parent) {
  90.                 continue;
  91.             }
  93.             $path = ($parent->getPropertyPath() ?? '') . $errorOrigin->getPropertyPath();
  94.             $keys = explode('][', trim($path, '[]'));
  95.             $dataRef = &$requestData;
  96.             foreach ($keys as $index => $key) {
  97.                 if (isset($dataRef[$key])) {
  98.                     if ($index === count($keys) - 1) {
  99.                         unset($dataRef[$key]);
  100.                     } else {
  101.                         $dataRef = &$dataRef[$key];
  102.                     }
  103.                 }
  104.             }
  105.         }
  107.         return $requestData;
  108.     }
  110.     public static function getCurrentPageProducts(): iterable
  111.     {
  112.         return self::$currentPageProducts;
  113.     }
  115.     public static function getTaxon(): TaxonInterface
  116.     {
  117.         return self::$taxon;
  118.     }
  119. }