custom/plugins/ShopStudioBlog/src/Storefront/Page/BlogPost/Comment/BlogPostCommentLoader.php line 59

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace ShopStudio\Blog\Storefront\Page\BlogPost\Comment;
  5. use ShopStudio\Blog\Content\BlogPost\SalesChannel\Comment\AbstractBlogPostCommentRoute;
  6. use Shopware\Core\Framework\DataAbstractionLayer\Search\Criteria;
  7. use Shopware\Core\Framework\DataAbstractionLayer\Search\Filter\EqualsFilter;
  8. use Shopware\Core\Framework\DataAbstractionLayer\Search\Sorting\FieldSorting;
  9. use Shopware\Core\Framework\Routing\Exception\MissingRequestParameterException;
  10. use Shopware\Core\System\SalesChannel\SalesChannelContext;
  11. use Shopware\Storefront\Framework\Page\StorefrontSearchResult;
  12. use Symfony\Component\EventDispatcher\EventDispatcherInterface;
  13. use Symfony\Component\HttpFoundation\Request;
  15. /**
  16.  * @since 1.0.0
  17.  */
  18. class BlogPostCommentLoader
  19. {
  20.     /**
  21.      * @since 1.0.0
  22.      */
  23.     private const LIMIT = 10;
  25.     /**
  26.      * @since 1.0.0
  27.      */
  28.     private const DEFAULT_PAGE = 1;
  30.     /**
  31.      * @since 1.0.0
  32.      */
  33.     private const FILTER_LANGUAGE = 'filter-language';
  35.     /**
  36.      * @since 1.0.0
  37.      */
  38.     private EventDispatcherInterface $eventDispatcher;
  40.     /**
  41.      * @since 1.0.0
  42.      */
  43.     private AbstractBlogPostCommentRoute $route;
  45.     /**
  46.      * @since 1.0.0
  47.      */
  48.     public function __construct(
  49.         AbstractBlogPostCommentRoute $route,
  50.         EventDispatcherInterface $eventDispatcher
  51.     ) {
  52.         $this->eventDispatcher = $eventDispatcher;
  53.         $this->route = $route;
  54.     }
  56.     /**
  57.      * @since 1.0.0
  58.      */
  59.     public function load(Request $request, SalesChannelContext $context): BlogPostCommentLoaderResult
  60.     {
  61.         $blogPostId = $request->get('blogPostId');
  62.         if (empty($blogPostId)) {
  63.             throw new MissingRequestParameterException('blogPostId');
  64.         }
  66.         $criteria = $this->createCriteria($request, $context);
  68.         $comments = $this->route
  69.             ->load($blogPostId, $request, $context, $criteria)
  70.             ->getResult()
  71.         ;
  73.         $comments = StorefrontSearchResult::createFrom($comments);
  75.         $this->eventDispatcher->dispatch(new BlogPostCommentsLoadedEvent($comments, $context, $request));
  77.         $result = BlogPostCommentLoaderResult::createFrom($comments);
  78.         $result->setBlogPostId($blogPostId);
  79.         $result->setTotalComments($comments->getTotal());
  81.         return $result;
  82.     }
  84.     /**
  85.      * @since 1.0.0
  86.      */
  87.     private function createCriteria(Request $request, SalesChannelContext $context): Criteria
  88.     {
  89.         $limit = (int) $request->get('limit', self::LIMIT);
  90.         $page = (int) $request->get('p', self::DEFAULT_PAGE);
  91.         $offset = $limit * ($page - 1);
  93.         $criteria = new Criteria();
  94.         $criteria->setLimit($limit);
  95.         $criteria->setOffset($offset);
  97.         $criteria->addSorting(new FieldSorting('createdAt', FieldSorting::ASCENDING));
  99.         if ($request->get('language') === self::FILTER_LANGUAGE) {
  100.             $criteria->addPostFilter(
  101.                 new EqualsFilter('languageId', $context->getContext()->getLanguageId())
  102.             );
  103.         }
  105.         return $criteria;
  106.     }
  107. }