add endpoint to return original image stream

pimcore · Dec 16, 2024 · 09c4fd3 · 09c4fd3
1 parent 4fa65e6
commit 09c4fd3
Show file tree

Hide file tree

Showing 21 changed files with 167 additions and 24 deletions.
diff --git a/src/Asset/Controller/Document/PreviewStreamController.php b/src/Asset/Controller/Document/PreviewStreamController.php
@@ -33,6 +33,7 @@
 use Pimcore\Bundle\StudioBackendBundle\OpenApi\Attribute\Response\SuccessResponse;
 use Pimcore\Bundle\StudioBackendBundle\OpenApi\Config\Tags;
 use Pimcore\Bundle\StudioBackendBundle\Security\Service\SecurityServiceInterface;
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\ElementTypes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseCodes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\UserPermissions;
 use Pimcore\Model\Asset\Document;
@@ -97,7 +98,7 @@ public function streamDocumentPreview(int $id): StreamedResponse
         );
 
         if (!$asset instanceof Document) {
-            throw new InvalidElementTypeException($asset->getType());
+            throw new InvalidElementTypeException($asset->getType(), ElementTypes::TYPE_ASSET);
         }
 
         return $this->documentService->getPreviewStream($asset);

diff --git a/src/Asset/Controller/Image/StreamController.php b/src/Asset/Controller/Image/StreamController.php
@@ -0,0 +1,98 @@
+<?php
+declare(strict_types=1);
+
+/**
+ * Pimcore
+ *
+ * This source file is available under two different licenses:
+ * - GNU General Public License version 3 (GPLv3)
+ * - Pimcore Commercial License (PCL)
+ * Full copyright and license information is available in
+ * LICENSE.md which is distributed with this source code.
+ *
+ *  @copyright  Copyright (c) Pimcore GmbH (http://www.pimcore.org)
+ *  @license    http://www.pimcore.org/license     GPLv3 and PCL
+ */
+
+namespace Pimcore\Bundle\StudioBackendBundle\Asset\Controller\Image;
+
+use OpenApi\Attributes\Get;
+use Pimcore\Bundle\StudioBackendBundle\Asset\Attribute\Response\Header\ContentDisposition;
+use Pimcore\Bundle\StudioBackendBundle\Asset\Service\AssetServiceInterface;
+use Pimcore\Bundle\StudioBackendBundle\Asset\Service\BinaryServiceInterface;
+use Pimcore\Bundle\StudioBackendBundle\Controller\AbstractApiController;
+use Pimcore\Bundle\StudioBackendBundle\Exception\Api\AccessDeniedException;
+use Pimcore\Bundle\StudioBackendBundle\Exception\Api\ElementStreamResourceNotFoundException;
+use Pimcore\Bundle\StudioBackendBundle\Exception\Api\InvalidElementTypeException;
+use Pimcore\Bundle\StudioBackendBundle\Exception\Api\NotFoundException;
+use Pimcore\Bundle\StudioBackendBundle\Exception\Api\UserNotFoundException;
+use Pimcore\Bundle\StudioBackendBundle\OpenApi\Attribute\Parameter\Path\IdParameter;
+use Pimcore\Bundle\StudioBackendBundle\OpenApi\Attribute\Response\Content\MediaType;
+use Pimcore\Bundle\StudioBackendBundle\OpenApi\Attribute\Response\DefaultResponses;
+use Pimcore\Bundle\StudioBackendBundle\OpenApi\Attribute\Response\SuccessResponse;
+use Pimcore\Bundle\StudioBackendBundle\OpenApi\Config\Tags;
+use Pimcore\Bundle\StudioBackendBundle\Security\Service\SecurityServiceInterface;
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseCodes;
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseHeaders;
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\UserPermissions;
+use Symfony\Component\HttpFoundation\StreamedResponse;
+use Symfony\Component\Routing\Attribute\Route;
+use Symfony\Component\Security\Http\Attribute\IsGranted;
+use Symfony\Component\Serializer\SerializerInterface;
+
+/**
+ * @internal
+ */
+final class StreamController extends AbstractApiController
+{
+    public function __construct(
+        private readonly AssetServiceInterface $assetService,
+        private readonly BinaryServiceInterface $binaryService,
+        private readonly SecurityServiceInterface $securityService,
+        SerializerInterface $serializer
+    ) {
+        parent::__construct($serializer);
+    }
+
+    /**
+     * @throws AccessDeniedException
+     * @throws ElementStreamResourceNotFoundException
+     * @throws NotFoundException
+     * @throws InvalidElementTypeException
+     * @throws UserNotFoundException
+     */
+    #[Route(
+        '/assets/{id}/image/stream',
+        name: 'pimcore_studio_api_stream_image',
+        methods: ['GET']
+    )]
+    #[IsGranted(UserPermissions::ASSETS->value)]
+    #[Get(
+        path: self::PREFIX . '/assets/{id}/image/stream',
+        operationId: 'asset_image_stream',
+        description: 'asset_image_stream_description',
+        summary: 'asset_image_stream_summary',
+        tags: [Tags::Assets->name]
+    )]
+    #[IdParameter(type: 'image')]
+    #[SuccessResponse(
+        description: 'asset_image_stream_success_response',
+        content: [new MediaType('image/*')],
+        headers: [new ContentDisposition(HttpResponseHeaders::INLINE_TYPE->value)]
+    )]
+    #[DefaultResponses([
+        HttpResponseCodes::BAD_REQUEST,
+        HttpResponseCodes::UNAUTHORIZED,
+        HttpResponseCodes::NOT_FOUND,
+    ])]
+    public function streamOriginalImage(
+        int $id,
+    ): StreamedResponse {
+        $asset = $this->assetService->getAssetElement(
+            $this->securityService->getCurrentUser(),
+            $id
+        );
+
+        return $this->binaryService->streamImage($asset);
+    }
+}
diff --git a/src/Asset/Encoder/TextEncoder.php b/src/Asset/Encoder/TextEncoder.php
@@ -32,7 +32,14 @@ final class TextEncoder implements TextEncoderInterface
     public function encodeUTF8(ElementInterface $element): string
     {
         if (!$element instanceof Text) {
-            throw new InvalidElementTypeException('Element must be an instance of Text');
+            throw new InvalidElementTypeException(
+                sprintf(
+                    'should have been (%s) but was (%s)',
+                    Text::class,
+                    $element->getType(),
+                ),
+                'Asset'
+            );
         }
 
         if ($element->getFileSize() > self::MAX_FILE_SIZE) {

diff --git a/src/Asset/Service/BinaryService.php b/src/Asset/Service/BinaryService.php
@@ -25,6 +25,7 @@
 use Pimcore\Bundle\StudioBackendBundle\Exception\Api\InvalidElementTypeException;
 use Pimcore\Bundle\StudioBackendBundle\Exception\Api\InvalidThumbnailConfigurationException;
 use Pimcore\Bundle\StudioBackendBundle\Exception\Api\InvalidThumbnailException;
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\ElementTypes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseHeaders;
 use Pimcore\Bundle\StudioBackendBundle\Util\Trait\StreamedResponseTrait;
 use Pimcore\Messenger\AssetPreviewImageMessage;
@@ -59,19 +60,32 @@ public function downloadVideoByThumbnail(
         string $thumbnailName
     ): StreamedResponse {
         if (!$video instanceof Video) {
-            throw new InvalidElementTypeException($video->getType());
+            throw new InvalidElementTypeException($video->getType(), ElementTypes::TYPE_ASSET);
         }
 
         return $this->getVideoByThumbnail($video, $thumbnailName, HttpResponseHeaders::ATTACHMENT_TYPE->value);
     }
 
+    /**
+     * @throws ElementStreamResourceNotFoundException|InvalidElementTypeException
+     */
+    public function streamImage(
+        Asset $image
+    ): StreamedResponse {
+        if (!$image instanceof Image) {
+            throw new InvalidElementTypeException($image->getType(), ElementTypes::TYPE_ASSET);
+        }
+
+        return $this->getStreamedResponse($image, HttpResponseHeaders::INLINE_TYPE->value);
+    }
+
     /**
      * @throws InvalidElementTypeException|InvalidThumbnailException
      */
     public function streamPreviewImageThumbnail(Asset $image): StreamedResponse
     {
         if (!$image instanceof Image) {
-            throw new InvalidElementTypeException($image->getType());
+            throw new InvalidElementTypeException($image->getType(), ElementTypes::TYPE_ASSET);
         }
 
         return $this->getStreamedResponse(
@@ -85,7 +99,7 @@ public function streamImageThumbnailFromConfig(
         ImageDownloadConfigParameter $configParameter
     ): StreamedResponse {
         if (!$image instanceof Image) {
-            throw new InvalidElementTypeException($image->getType());
+            throw new InvalidElementTypeException($image->getType(), ElementTypes::TYPE_ASSET);
         }
 
         return $this->getStreamedResponse(
@@ -105,7 +119,7 @@ public function streamVideoByThumbnail(
         string $thumbnailName
     ): StreamedResponse {
         if (!$video instanceof Video) {
-            throw new InvalidElementTypeException($video->getType());
+            throw new InvalidElementTypeException($video->getType(), ElementTypes::TYPE_ASSET);
         }
 
         return $this->getVideoByThumbnail($video, $thumbnailName, HttpResponseHeaders::INLINE_TYPE->value);
@@ -122,7 +136,7 @@ public function streamVideoImageThumbnail(
         VideoImageStreamConfigParameter $imageConfig
     ): StreamedResponse {
         if (!$video instanceof Video) {
-            throw new InvalidElementTypeException($video->getType());
+            throw new InvalidElementTypeException($video->getType(), ElementTypes::TYPE_ASSET);
         }
         $this->thumbnailService->validateCustomVideoThumbnailConfig($imageConfig);
 

diff --git a/src/Asset/Service/BinaryServiceInterface.php b/src/Asset/Service/BinaryServiceInterface.php
@@ -43,6 +43,13 @@ public function downloadVideoByThumbnail(
         string $thumbnailName
     ): StreamedResponse;
 
+    /**
+     * @throws ElementStreamResourceNotFoundException|InvalidElementTypeException
+     */
+    public function streamImage(
+        Asset $image
+    ): StreamedResponse;
+
     /**
      * @throws InvalidElementTypeException|InvalidThumbnailException
      */

diff --git a/src/Dependency/Controller/Element/CollectionController.php b/src/Dependency/Controller/Element/CollectionController.php
@@ -68,7 +68,7 @@ public function __construct(
         tags: [Tags::Dependencies->name]
     )]
     #[ElementTypeParameter]
-    #[IdParameter('element')]
+    #[IdParameter]
     #[PageParameter]
     #[PageSizeParameter]
     #[DependencyModeParameter]

diff --git a/src/Exception/Api/ElementProcessingNotCompletedException.php b/src/Exception/Api/ElementProcessingNotCompletedException.php
@@ -16,6 +16,7 @@
 
 namespace Pimcore\Bundle\StudioBackendBundle\Exception\Api;
 
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\ElementTypes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseCodes;
 use function sprintf;
 
@@ -24,7 +25,7 @@
  */
 final class ElementProcessingNotCompletedException extends AbstractApiException
 {
-    public function __construct(int $id, string $type = 'Element')
+    public function __construct(int $id, string $type = ElementTypes::TYPE_ELEMENT)
     {
         parent::__construct(
             HttpResponseCodes::NOT_COMPLETED->value,

diff --git a/src/Exception/Api/ElementStreamResourceNotFoundException.php b/src/Exception/Api/ElementStreamResourceNotFoundException.php
@@ -16,6 +16,7 @@
 
 namespace Pimcore\Bundle\StudioBackendBundle\Exception\Api;
 
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\ElementTypes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseCodes;
 use function sprintf;
 
@@ -24,7 +25,7 @@
  */
 final class ElementStreamResourceNotFoundException extends AbstractApiException
 {
-    public function __construct(int $id, string $type = 'Element')
+    public function __construct(int $id, string $type = ElementTypes::TYPE_ELEMENT)
     {
         parent::__construct(
             HttpResponseCodes::NOT_FOUND->value,

diff --git a/src/Exception/Api/InvalidElementTypeException.php b/src/Exception/Api/InvalidElementTypeException.php
@@ -16,6 +16,7 @@
 
 namespace Pimcore\Bundle\StudioBackendBundle\Exception\Api;
 
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\ElementTypes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseCodes;
 use function sprintf;
 
@@ -24,13 +25,14 @@
  */
 final class InvalidElementTypeException extends AbstractApiException
 {
-    public function __construct(string $type)
+    public function __construct(string $subType, string $elementType = ElementTypes::TYPE_ELEMENT)
     {
         parent::__construct(
             HttpResponseCodes::BAD_REQUEST->value,
             sprintf(
-                'Invalid element type: %s',
-                $type
+                'Invalid %s type: %s',
+                $elementType,
+                $subType
             )
         );
     }

diff --git a/src/Note/Controller/Element/CollectionController.php b/src/Note/Controller/Element/CollectionController.php
@@ -36,6 +36,7 @@
 use Pimcore\Bundle\StudioBackendBundle\OpenApi\Attribute\Response\DefaultResponses;
 use Pimcore\Bundle\StudioBackendBundle\OpenApi\Attribute\Response\SuccessResponse;
 use Pimcore\Bundle\StudioBackendBundle\OpenApi\Config\Tags;
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\ElementTypes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseCodes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\UserPermissions;
 use Pimcore\Bundle\StudioBackendBundle\Util\Trait\PaginatedResponseTrait;
@@ -78,7 +79,7 @@ public function __construct(
         tags: [Tags::Notes->name]
     )]
     #[ElementTypeParameter]
-    #[IdParameter(type: 'element')]
+    #[IdParameter(type: ElementTypes::TYPE_ELEMENT)]
     #[PageParameter]
     #[PageSizeParameter(50)]
     #[NoteSortByParameter]

diff --git a/src/Note/Controller/Element/CreateController.php b/src/Note/Controller/Element/CreateController.php
@@ -32,6 +32,7 @@
 use Pimcore\Bundle\StudioBackendBundle\OpenApi\Attribute\Response\DefaultResponses;
 use Pimcore\Bundle\StudioBackendBundle\OpenApi\Attribute\Response\SuccessResponse;
 use Pimcore\Bundle\StudioBackendBundle\OpenApi\Config\Tags;
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\ElementTypes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseCodes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\UserPermissions;
 use Symfony\Component\HttpFoundation\JsonResponse;
@@ -66,7 +67,7 @@ public function __construct(
         tags: [Tags::Notes->name]
     )]
     #[ElementTypeParameter]
-    #[IdParameter(type: 'element')]
+    #[IdParameter(type: ElementTypes::TYPE_ELEMENT)]
     #[CreateNoteRequestBody]
     #[SuccessResponse(
         description: 'note_element_create_success_response',

diff --git a/src/Property/Controller/Element/CollectionController.php b/src/Property/Controller/Element/CollectionController.php
@@ -61,7 +61,7 @@ public function __construct(
         tags: [Tags::Properties->value]
     )]
     #[ElementTypeParameter]
-    #[IdParameter(type: 'element')]
+    #[IdParameter]
     #[SuccessResponse(
         description: 'property_get_collection_for_element_by_type_and_id_success_response',
         content: new ItemsJson(ElementProperty::class)

diff --git a/src/Schedule/Controller/Element/CollectionController.php b/src/Schedule/Controller/Element/CollectionController.php
@@ -59,7 +59,7 @@ public function __construct(
         tags: [Tags::Schedule->name]
     )]
     #[ElementTypeParameter]
-    #[IdParameter(type: 'element')]
+    #[IdParameter]
     #[SuccessResponse(
         description: 'schedule_get_collection_for_element_by_type_and_id_success_response',
         content: new ItemsJson(Schedule::class)

diff --git a/src/Schedule/Controller/Element/CreateController.php b/src/Schedule/Controller/Element/CreateController.php
@@ -61,7 +61,7 @@ public function __construct(
         tags: [Tags::Schedule->name]
     )]
     #[ElementTypeParameter]
-    #[IdParameter(type: 'element')]
+    #[IdParameter]
     #[SuccessResponse(
         description: 'schedule_create_for_element_by_type_and_id_success_response',
         content: new JsonContent(ref: Schedule::class)

diff --git a/src/Schedule/Controller/Element/UpdateController.php b/src/Schedule/Controller/Element/UpdateController.php
@@ -66,7 +66,7 @@ public function __construct(
         tags: [Tags::Schedule->name]
     )]
     #[ElementTypeParameter]
-    #[IdParameter(type: 'element')]
+    #[IdParameter]
     #[ElementScheduleRequestBody]
     #[SuccessResponse(
         description: 'schedule_update_for_element_by_type_and_id_success_response',

diff --git a/src/Tag/Controller/Element/AssignController.php b/src/Tag/Controller/Element/AssignController.php
@@ -26,6 +26,7 @@
 use Pimcore\Bundle\StudioBackendBundle\OpenApi\Config\Tags;
 use Pimcore\Bundle\StudioBackendBundle\Tag\MappedParameter\ElementParameters;
 use Pimcore\Bundle\StudioBackendBundle\Tag\Service\TagServiceInterface;
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\ElementTypes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseCodes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\UserPermissions;
 use Symfony\Component\HttpFoundation\JsonResponse;
@@ -62,7 +63,7 @@ public function __construct(
         tags: [Tags::TagsForElement->value]
     )]
     #[ElementTypeParameter]
-    #[IdParameter(type: 'element')]
+    #[IdParameter]
     #[IdParameter(type: 'tag', name: 'tagId')]
     #[DefaultResponses([
         HttpResponseCodes::UNAUTHORIZED,

diff --git a/src/Tag/Controller/Element/CollectionController.php b/src/Tag/Controller/Element/CollectionController.php
@@ -27,6 +27,7 @@
 use Pimcore\Bundle\StudioBackendBundle\Tag\Attribute\Response\Property\TagCollection;
 use Pimcore\Bundle\StudioBackendBundle\Tag\MappedParameter\ElementParameters;
 use Pimcore\Bundle\StudioBackendBundle\Tag\Service\TagServiceInterface;
+use Pimcore\Bundle\StudioBackendBundle\Util\Constant\ElementTypes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\HttpResponseCodes;
 use Pimcore\Bundle\StudioBackendBundle\Util\Constant\UserPermissions;
 use Pimcore\Bundle\StudioBackendBundle\Util\Trait\PaginatedResponseTrait;
@@ -60,7 +61,7 @@ public function __construct(
         tags: [Tags::TagsForElement->value]
     )]
     #[ElementTypeParameter]
-    #[IdParameter(type: 'element')]
+    #[IdParameter]
     #[SuccessResponse(
         description: 'tag_get_collection_for_element_by_type_and_id_success_response',
         content: new CollectionJson(new TagCollection())