src/Service/Client/Content/VideoListingService.php line 90

Open in your IDE?
  1. <?php
  3. namespace App\Service\Client\Content;
  5. use App\Service\Client\AbstractClient;
  6. use Knp\Component\Pager\Pagination\PaginationInterface;
  7. use Symfony\Component\HttpKernel\CacheWarmer\CacheWarmerInterface;
  8. use Symfony\Contracts\Cache\ItemInterface;
  10. class VideoListingService extends AbstractClient implements CacheWarmerInterface
  11. {
  12.     /**
  13.      * @return bool
  14.      */
  15.     public function isOptional(): bool
  16.     {
  17.         return true;
  18.     }
  20.     /**
  21.      * @param string $cacheDir
  22.      * @throws \Psr\Cache\InvalidArgumentException
  23.      * @throws \ReflectionException
  24.      */
  25.     public function warmUp($cacheDir)
  26.     {
  27.         $perPage = 12;
  29.         foreach([1, 2, 3] as $page) {
  30.             $this->getNewestVideos($page, $perPage);
  31.             $this->getBestOfTheMonthVideos($page, $perPage);
  32.             $this->getBestOfTheWeekVideos($page, $perPage);
  33.         }
  34.     }
  36.     /**
  37.      * @param int $page
  38.      * @param int $perPage
  39.      * @return PaginationInterface
  40.      * @throws \Psr\Cache\InvalidArgumentException
  41.      * @throws \ReflectionException
  42.      */
  43.     public function getNewestVideos(int $page, int $perPage): PaginationInterface
  44.     {
  45.         $key = (new \ReflectionClass($this))->getShortName() . '_' . __FUNCTION__ . '_'  . $page . '_' . $perPage;
  47.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($page, $perPage) {
  48.             $item->expiresAfter(600);
  50.             $response = $this->requestJSON('GET', 'api/public/content/videos/' . $page, [
  51.                 'query' => [
  52.                     'limit' => $perPage
  53.                 ]
  54.             ]);
  55.             return $this->getDefaultPagination($response, $page, $perPage);
  56.         });
  57.     }
  59.     /**
  60.      * @param int $page
  61.      * @param int $perPage
  62.      * @return PaginationInterface
  63.      * @throws \Psr\Cache\InvalidArgumentException
  64.      * @throws \ReflectionException
  65.      */
  66.     public function getBestOfTheWeekVideos(int $page, int $perPage): PaginationInterface
  67.     {
  68.         $key = (new \ReflectionClass($this))->getShortName() . '_' . __FUNCTION__ . '_'  . $page . '_' . $perPage;
  70.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($page, $perPage) {
  71.             $item->expiresAfter(60 * 60);
  73.             $response = $this->requestJSON('GET', 'api/public/content/videos/bestoftheweek/' . $page, [
  74.                 'query' => [
  75.                     'limit' => $perPage
  76.                 ]
  77.             ]);
  79.             return $this->getDefaultPagination($response, $page, $perPage);
  80.         });
  81.     }
  83.     /**
  84.      * @param int $page
  85.      * @param int $perPage
  86.      * @return PaginationInterface
  87.      * @throws \Psr\Cache\InvalidArgumentException
  88.      * @throws \ReflectionException
  89.      */
  90.     public function getBestOfTheMonthVideos(int $page, int $perPage): PaginationInterface
  91.     {
  92.         $key = (new \ReflectionClass($this))->getShortName() . '_' . __FUNCTION__ . '_'  . $page . '_' . $perPage;
  94.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($page, $perPage) {
  95.             $item->expiresAfter(60 * 60);
  97.             $response = $this->requestJSON('GET', 'api/public/content/videos/bestofthemonth/' . $page, [
  98.                 'query' => [
  99.                     'limit' => $perPage
  100.                 ]
  101.             ]);
  103.             return $this->getDefaultPagination($response, $page, $perPage);
  104.         });
  105.     }
  107.     /**
  108.      * @param int $category
  109.      * @param int $page
  110.      * @param int $perPage
  111.      * @return PaginationInterface
  112.      * @throws \Psr\Cache\InvalidArgumentException
  113.      * @throws \ReflectionException
  114.      */
  115.     public function getVideosByCategory(int $category, int $page, int $perPage): PaginationInterface
  116.     {
  117.         $key = (new \ReflectionClass($this))->getShortName() . '_' . __FUNCTION__ . '_'  . $category . '_' . $page . '_' . $perPage;
  119.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($category, $page, $perPage) {
  120.             $item->expiresAfter(600);
  122.             $response = $this->requestJSON('GET', 'api/public/content/videos/category/' . $category . '/' . $page, [
  123.                 'query' => [
  124.                     'limit' => $perPage
  125.                 ]
  126.             ]);
  128.             return $this->getDefaultPagination($response, $page, $perPage);
  129.         });
  130.     }
  132.     /**
  133.      * @param int $member
  134.      * @param int $page
  135.      * @param int $perPage
  136.      * @param array $statuses
  137.      * @return PaginationInterface
  138.      * @throws \Psr\Cache\InvalidArgumentException
  139.      * @throws \ReflectionException
  140.      */
  141.     public function getRecentVideosForMember(int $member, int $page, int $perPage, array $statuses): PaginationInterface
  142.     {
  143.         $key = (new \ReflectionClass($this))->getShortName() . '_' . __FUNCTION__ . '_' . $member .
  144.             '_' . $page . '_' . $perPage;
  146.         if(count($statuses)) {
  147.             $key .= '_' . implode('_', $statuses);
  148.         }
  150.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($member, $page, $perPage, $statuses) {
  151.             $item->expiresAfter(60 * 30);
  152.             $item->tag([
  153.                 'member-' . $member,
  154.                 'videos',
  155.                 'videos-member-' . $member
  156.             ]);
  158.             $query = [
  159.                 'limit' => $perPage,
  160.             ];
  161.             if(count($statuses)) {
  162.                 $query['statuses'] = implode(',', $statuses);
  163.             }
  165.             $path = 'api/public/content/amateur/' . $member . '/videos/' . $page;
  166.             $response = $this->requestJSON('GET', $path, [
  167.                 'query' => $query
  168.             ]);
  170.             return $this->getDefaultPagination($response, $page, $perPage);
  171.         });
  172.     }
  174.     /**
  175.      * @param int $member
  176.      * @param int $page
  177.      * @param int $perPage
  178.      * @param array $statuses
  179.      * @return PaginationInterface
  180.      * @throws \Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface
  181.      * @throws \Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface
  182.      * @throws \Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface
  183.      * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
  184.      */
  185.     public function getNonCachedRecentVideosForMember(int $member, int $page, int $perPage, array $statuses): PaginationInterface
  186.     {
  187.         $query = [
  188.             'limit' => $perPage,
  189.         ];
  190.         if(count($statuses)) {
  191.             $query['statuses'] = implode(',', $statuses);
  192.         }
  194.         $path = 'api/public/content/amateur/' . $member . '/videos/' . $page;
  195.         $response = $this->requestJSON('GET', $path, [
  196.             'query' => $query
  197.         ]);
  199.         return $this->getDefaultPagination($response, $page, $perPage);
  200.     }
  202.     /**
  203.      * @param int $member
  204.      * @param array $statuses
  205.      * @return int
  206.      * @throws \Psr\Cache\InvalidArgumentException
  207.      * @throws \ReflectionException
  208.      */
  209.     public function getMemberVideoCountPerStatuses(int $member, array $statuses): int
  210.     {
  211.         $perPage = 15; # this then uses the same cache key as the listing itself
  212.         return $this->getRecentVideosForMember($member, 1, $perPage, $statuses)->getTotalItemCount();
  213.     }
  214. }