src/Service/Client/Content/ImagesetListingService.php line 104

Open in your IDE?
  1. <?php
  3. namespace App\Service\Client\Content;
  5. use App\Dictionary\ContentStatus;
  6. use App\Service\Client\AbstractClient;
  7. use Knp\Component\Pager\Pagination\PaginationInterface;
  8. use Symfony\Component\HttpKernel\CacheWarmer\CacheWarmerInterface;
  9. use Symfony\Contracts\Cache\ItemInterface;
  11. class ImagesetListingService extends AbstractClient implements CacheWarmerInterface
  12. {
  13.     /**
  14.      * @return bool
  15.      */
  16.     public function isOptional(): bool
  17.     {
  18.         return true;
  19.     }
  21.     /**
  22.      * @param string $cacheDir
  23.      * @throws \Psr\Cache\InvalidArgumentException
  24.      * @throws \ReflectionException
  25.      */
  26.     public function warmUp($cacheDir)
  27.     {
  28.         $perPage = 12;
  30.         foreach([1, 2, 3] as $page) {
  31.             $this->getNewestImagesets($page, $perPage);
  32.             $this->getBestOfTheMonthImagesets($page, $perPage);
  33.             $this->getBestOfTheWeekImagesets($page, $perPage);
  34.         }
  35.     }
  37.     /**
  38.      * @param int $page
  39.      * @param int $perPage
  40.      * @return PaginationInterface
  41.      * @throws \Psr\Cache\InvalidArgumentException
  42.      * @throws \ReflectionException
  43.      */
  44.     public function getNewestImagesets(int $page, int $perPage): PaginationInterface
  45.     {
  46.         $key = (new \ReflectionClass($this))->getShortName() . '_' . __FUNCTION__ . '_' . $page . '_' . $perPage;
  48.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($page, $perPage) {
  49.             $item->expiresAfter(600);
  50.             $item->tag([
  51.                 'imagesets',
  52.                 'imagesets-new'
  53.             ]);
  55.             $response = $this->requestJSON('GET', 'api/public/content/imagesets/' . $page, [
  56.                 'query' => [
  57.                     'limit' => $perPage
  58.                 ]
  59.             ]);
  61.             return $this->getDefaultPagination($response, $page, $perPage);
  62.         });
  63.     }
  65.     /**
  66.      * @param int $page
  67.      * @param int $perPage
  68.      * @return PaginationInterface
  69.      * @throws \Psr\Cache\InvalidArgumentException
  70.      * @throws \ReflectionException
  71.      */
  72.     public function getBestOfTheWeekImagesets(int $page, int $perPage): PaginationInterface
  73.     {
  74.         $key = (new \ReflectionClass($this))->getShortName() . '_' . __FUNCTION__ . '_' . $page . '_' . $perPage;
  76.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($page, $perPage) {
  77.             $item->expiresAfter(60 * 60);
  78.             $item->tag([
  79.                 'imagesets',
  80.                 'imagesets-week'
  81.             ]);
  83.             $response = $this->requestJSON('GET', 'api/public/content/imagesets/bestoftheweek/' . $page, [
  84.                 'query' => [
  85.                     'limit' => $perPage
  86.                 ]
  87.             ]);
  89.             return $this->getDefaultPagination($response, $page, $perPage);
  90.         });
  91.     }
  93.     /**
  94.      * @param int $page
  95.      * @param int $perPage
  96.      * @return PaginationInterface
  97.      * @throws \Psr\Cache\InvalidArgumentException
  98.      * @throws \ReflectionException
  99.      */
  100.     public function getBestOfTheMonthImagesets(int $page, int $perPage): PaginationInterface
  101.     {
  102.         $key = (new \ReflectionClass($this))->getShortName() . '_' . __FUNCTION__ . '_' . $page . '_' . $perPage;
  104.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($page, $perPage) {
  105.             $item->expiresAfter(60 * 60);
  106.             $item->tag([
  107.                 'imagesets',
  108.                 'imagesets-month'
  109.             ]);
  111.             $path = 'api/public/content/imagesets/bestofthemonth/' . $page;
  112.             $response = $this->requestJSON('GET', $path, [
  113.                 'query' => [
  114.                     'limit' => $perPage
  115.                 ]
  116.             ]);
  118.             return $this->getDefaultPagination($response, $page, $perPage);
  119.         });
  120.     }
  122.     /**
  123.      * @param int $category
  124.      * @param int $page
  125.      * @param int $perPage
  126.      * @return PaginationInterface
  127.      * @throws \Psr\Cache\InvalidArgumentException
  128.      * @throws \ReflectionException
  129.      */
  130.     public function getImagesetsByCategory(int $category, int $page, int $perPage): PaginationInterface
  131.     {
  132.         $key = (new \ReflectionClass($this))->getShortName() .
  133.             '_' . __FUNCTION__ . '_'  . $category . '_' . $page . '_' . $perPage;
  135.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($category, $page, $perPage) {
  136.             $item->expiresAfter(600);
  137.             $item->tag([
  138.                 'imagesets',
  139.                 'imagesets-category-' . $category
  140.             ]);
  142.             $path = 'api/public/content/imagesets/category/' . $category . '/' . $page;
  143.             $response = $this->requestJSON('GET', $path, [
  144.                 'query' => [
  145.                     'limit' => $perPage
  146.                 ]
  147.             ]);
  149.             return $this->getDefaultPagination($response, $page, $perPage);
  150.         });
  151.     }
  153.     /**
  154.      * @param int $member
  155.      * @param int $page
  156.      * @param int $perPage
  157.      * @param array $statuses OPTIONAL
  158.      * @return PaginationInterface
  159.      * @throws \Psr\Cache\InvalidArgumentException
  160.      * @throws \ReflectionException
  161.      */
  162.     public function getRecentImagesetsForMember(int $member, int $page, int $perPage, ?array $statuses = []): PaginationInterface
  163.     {
  164.         $key = (new \ReflectionClass($this))->getShortName() . '_'
  165.             . __FUNCTION__ . '_' . $member . '_' . $page . '_' . $perPage;
  167.         if(count($statuses)) {
  168.             $key .= '_' . md5(implode('_', $statuses));
  169.         }
  171.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($member, $page, $perPage, $statuses) {
  172.             $item->expiresAfter(60 * 30);
  173.             $item->tag([
  174.                 'member-' . $member,
  175.                 'imagesets',
  176.                 'imagesets-member-' . $member
  177.             ]);
  179.             $query = [
  180.                 'limit' => $perPage,
  181.             ];
  182.             if(count($statuses)) {
  183.                 $query['statuses'] = implode(',', $statuses);
  184.             }
  186.             $path = 'api/public/content/amateur/' . $member . '/imagesets/' . $page;
  187.             $response = $this->requestJSON('GET', $path, [
  188.                 'query' => $query
  189.             ]);
  191.             return $this->getDefaultPagination($response, $page, $perPage);
  192.         });
  193.     }
  195.     /**
  196.      * @param int $member
  197.      * @param int $page
  198.      * @param int $perPage
  199.      * @param array|null $statuses
  200.      * @return PaginationInterface
  201.      * @throws \Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface
  202.      * @throws \Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface
  203.      * @throws \Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface
  204.      * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
  205.      */
  206.     public function getNonCachedRecentImagesetsForMember(int $member, int $page, int $perPage, ?array $statuses = []): PaginationInterface
  207.     {
  208.         $query = [
  209.             'limit' => $perPage,
  210.         ];
  211.         if(count($statuses)) {
  212.             $query['statuses'] = implode(',', $statuses);
  213.         }
  215.         $path = 'api/public/content/amateur/' . $member . '/imagesets/' . $page;
  216.         $response = $this->requestJSON('GET', $path, [
  217.             'query' => $query
  218.         ]);
  220.         return $this->getDefaultPagination($response, $page, $perPage);
  221.     }
  223.     /**
  224.      * @param int $member
  225.      * @param array $statuses
  226.      * @return int
  227.      * @throws \Psr\Cache\InvalidArgumentException
  228.      * @throws \ReflectionException
  229.      */
  230.     public function getMemberImagesetCountPerStatuses(int $member, array $statuses): int
  231.     {
  232.         $perPage = 15; # this then uses the same cache key as the listing itself
  233.         $paginator = $this->getRecentImagesetsForMember($member, 1, $perPage, $statuses);
  234.         return $paginator->getTotalItemCount();
  235.     }
  236. }