src/Service/Client/Content/ImagesetService.php line 26

Open in your IDE?
  1. <?php
  3. namespace App\Service\Client\Content;
  5. use App\Dictionary\ContentPrice;
  6. use App\Event\Content\ContentCreatedEvent;
  7. use App\Event\Content\ContentDeletedEvent;
  8. use App\Service\Client\AbstractClient;
  9. use Symfony\Component\HttpFoundation\File\UploadedFile;
  10. use Symfony\Component\HttpFoundation\ParameterBag;
  11. use Symfony\Contracts\Cache\ItemInterface;
  13. class ImagesetService extends AbstractClient
  14. {
  15.     const ID_CACHE_LIFETIME = 10; # minutes
  17.     /**
  18.      * @param string $slug
  19.      * @return array|null
  20.      * @throws \Psr\Cache\InvalidArgumentException
  21.      * @throws \ReflectionException
  22.      */
  23.     public function getImagesetBySlug(string $slug): ?array
  24.     {
  25.         $key = (new \ReflectionClass($this))->getShortName() . '_' . __FUNCTION__ . '_' . $slug;
  26.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($slug) {
  27.             $result = $this->requestJSON('GET', 'api/public/content/imageset/slug/' . $slug);
  29.             $item->expiresAfter(60 * self::ID_CACHE_LIFETIME);
  30.             $item->tag([
  31.                 'imagesets',
  32.                 'imageset-slug-' . $slug,
  33.                 'imageset-' . (int) $result['id']
  34.             ]);
  36.             return $result;
  37.         });
  38.     }
  40.     /**
  41.      * @param int $id
  42.      * @param bool $useCache
  43.      * @return array|null
  44.      * @throws \Psr\Cache\InvalidArgumentException
  45.      * @throws \Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface
  46.      * @throws \Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface
  47.      * @throws \Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface
  48.      * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
  49.      */
  50.     public function getImagesetById(int $id, bool $useCache = true): ?array
  51.     {
  52.         if (!$useCache) {
  53.             return $this->requestJSON('GET', 'api/public/content/imageset/' . $id);
  54.         }
  56.         $key = (new \ReflectionClass($this))->getShortName() . '_' . __FUNCTION__ . '_' . $id;
  57.         return $this->getCacheService()->get($key, function(ItemInterface $item) use ($id) {
  58.             $item->expiresAfter(60 * self::ID_CACHE_LIFETIME);
  59.             $item->tag([
  60.                 'imagesets',
  61.                 'imageset-' . $id
  62.             ]);
  63.             return $this->requestJSON('GET', 'api/public/content/imageset/' . $id);
  64.         });
  65.     }
  67.     /**
  68.      * @param int $imageset
  69.      * @param ParameterBag $bag
  70.      * @return bool
  71.      * @throws \Psr\Cache\InvalidArgumentException
  72.      * @throws \Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface
  73.      * @throws \Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface
  74.      * @throws \Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface
  75.      * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
  76.      */
  77.     public function updateImageset(int $imageset, array $formData): bool
  78.     {
  79.         $fields = [];
  80.         foreach(['title', 'description'] as $field) {
  81.             if(array_key_exists($field, $formData)) {
  82.                 $fields[$field] = $formData[$field];
  83.             }
  84.         }
  86.         if (!isset($formData['price']) || $formData['price'] < ContentPrice::MIN_IMAGE) {
  87.             $formData['price'] = ContentPrice::MIN_IMAGE;
  88.         }
  89.         $fields['cost_per_unit'] = $formData['price'];
  91.         if(!count($fields)) {
  92.             return false;
  93.         }
  94.         $response = $this->issuePut('api/content/imageset/' . $imageset, $fields);
  95.         $result = $this->isSuccess($response);
  97.         if($result) {
  98.             $this->cacheService->clearImagesetCache($imageset);
  99.         }
  101.         return $result;
  102.     }
  104.     /**
  105.      * @param int $author
  106.      * @param int $imagesetId
  107.      * @return bool
  108.      * @throws \Psr\Cache\InvalidArgumentException
  109.      * @throws \Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface
  110.      * @throws \Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface
  111.      * @throws \Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface
  112.      * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
  113.      */
  114.     public function deleteImageset(int $author, int $imagesetId): bool
  115.     {
  116.         $response = $this->issueDelete('api/content/imageset/' . $imagesetId);
  117.         $result = $this->isSuccess($response);
  119.         if($result) {
  120.             $event = new ContentDeletedEvent($author);
  121.             $this->getEventDispatcher()->dispatch($event);
  122.         }
  123.         return $result;
  124.     }
  126.     /**
  127.      * @param int $author
  128.      * @param int $imageset
  129.      * @param int $id
  130.      * @return bool
  131.      * @throws \Psr\Cache\InvalidArgumentException
  132.      * @throws \Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface
  133.      * @throws \Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface
  134.      * @throws \Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface
  135.      * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
  136.      */
  137.     public function deleteImagesetImage(int $author, int $imageset, int $id): bool
  138.     {
  139.         $response = $this->issueDelete('api/content/imageset/' . $imageset . '/images/' . $id);
  140.         $result = $this->isSuccess($response);
  142.         if($result) {
  143.             $this->cacheService->clearImagesetCache($imageset);
  144.         }
  146.         return $result;
  147.     }
  149.     /**
  150.      * @param int $imagesetId
  151.      * @return bool
  152.      * @throws \Psr\Cache\InvalidArgumentException
  153.      */
  154.     public function clearImagesetCache(int $imagesetId): bool
  155.     {
  156.         return $this->cacheService->clearImagesetCache($imagesetId);
  157.     }
  159.     /**
  160.      * @param int $memberId
  161.      * @param array $specs
  162.      * @return array|null
  163.      * @throws \Psr\Cache\InvalidArgumentException
  164.      * @throws \Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface
  165.      * @throws \Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface
  166.      * @throws \Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface
  167.      * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
  168.      */
  169.     public function createImageset(int $memberId, array $specs): ?array
  170.     {
  171.         $path = 'api/content/amateur/' . $memberId . '/imagesets';
  172.         $response = $this->issuePost($path, $specs);
  174.         if($this->isSuccess($response)) {
  175.             $this->getEventDispatcher()->dispatch(new ContentCreatedEvent($memberId));
  176.         }
  178.         return $this->getResponseJson($response);
  179.     }
  181.     /**
  182.      * @param int $imageset
  183.      * @param UploadedFile $file
  184.      * @return int
  185.      * @throws \Psr\Cache\InvalidArgumentException
  186.      * @throws \Symfony\Contracts\HttpClient\Exception\ClientExceptionInterface
  187.      * @throws \Symfony\Contracts\HttpClient\Exception\RedirectionExceptionInterface
  188.      * @throws \Symfony\Contracts\HttpClient\Exception\ServerExceptionInterface
  189.      * @throws \Symfony\Contracts\HttpClient\Exception\TransportExceptionInterface
  190.      */
  191.     public function addImageToImageset(int $imageset, UploadedFile $file): int
  192.     {
  193.         $path = 'api/content/imageset/' . $imageset . '/images';
  194.         $response = $this->issuePostMultipart($path, [], [
  195.             'file' => $file
  196.         ]);
  197.         $result = $this->getResponseJson($response);
  198.         if($result && count($result)) {
  199.             $this->cacheService->clearImagesetCache($imageset);
  201.             return $result['id'];
  202.         }
  203.         return 0;
  204.     }
  206.     /**
  207.      * @param int $memberId
  208.      * @param string $imagesetSlug
  209.      * @param int $imagesetId
  210.      * @return array
  211.      * @throws \Psr\Cache\InvalidArgumentException
  212.      */
  213.     public function purchasedImagesByMember(int $memberId, string $imagesetSlug, int $imagesetId): array
  214.     {
  215.         $path = sprintf('api/content/mediacenter/%d/purchased/images/%s', $memberId, $imagesetSlug);
  216.         $key = str_replace('/', '-', $path);
  217.         return $this->getCacheService()->get($key, function (ItemInterface $item) use ($path, $imagesetId) {
  218.             $response = $this->requestJSON('GET', $path);
  219.             $item->tag("imageset-purchase-$imagesetId");
  220.             $item->expiresAfter(120);
  222.             return $response['data'] ?? [];
  223.         });
  224.     }
  225. }