IBX-8344: Added endpoint for download images

composer.json

@@ -28,6 +28,7 @@
     "require": {
         "php": "^7.4 || ^8.0",
         "ext-json": "*",
+        "ext-zip": "*",
         "symfony/deprecation-contracts": "^2.5",
         "symfony/http-foundation": "^5.0",
         "symfony/security-core": "^5.0",

src/bundle/Controller/DownloadImageController.php

@@ -0,0 +1,258 @@
+<?php
+
+/**
+ * @copyright Copyright (C) Ibexa AS. All rights reserved.
+ * @license For full copyright and license information view LICENSE file distributed with this source code.
+ */
+declare(strict_types=1);
+
+namespace Ibexa\Bundle\AdminUi\Controller;
+
+use Ibexa\Contracts\Core\Repository\SearchService;
+use Ibexa\Contracts\Core\Repository\Values\Content\Content;
+use Ibexa\Contracts\Core\Repository\Values\Content\Query;
+use Ibexa\Contracts\Core\Repository\Values\Content\Search\SearchResult;
+use Ibexa\Core\FieldType\Image\Value;
+use Ibexa\Rest\Server\Controller;
+use RuntimeException;
+use Symfony\Component\HttpFoundation\HeaderUtils;
+use Symfony\Component\HttpFoundation\Response;
+use ZipArchive;
+
+final class DownloadImageController extends Controller
+{
+    private const ARCHIVE_NAME_PATTERN = 'images_%s.zip';
+
+    private int $downloadLimit;
+
+    /** @var array<string, mixed> */
+    private array $imageMappings;
+
+    private SearchService $searchService;
+
+    /**
+     * @param array<string, mixed> $imageMappings
+     */
+    public function __construct(
+        int $downloadLimit,
+        array $imageMappings,
+        SearchService $searchService
+    ) {
+        $this->downloadLimit = $downloadLimit;
+        $this->imageMappings = $imageMappings;
+        $this->searchService = $searchService;
+    }
+
+    /**
+     * @throws \Ibexa\Contracts\Core\Repository\Exceptions\InvalidArgumentException
+     * @throws \Ibexa\Contracts\Core\Repository\Exceptions\InvalidCriterionArgumentException
+     * @throws \Exception
+     */
+    public function downloadAction(string $contentIdList): Response
+    {
+        $splitContentIdList = array_map(
+            static fn (string $value): int => (int)$value,
+            explode(',', $contentIdList)
+        );
+
+        if (count($splitContentIdList) > $this->downloadLimit) {
+            throw new RuntimeException(
+                sprintf(
+                    'Total download limit in one request is %d.',
+                    $this->downloadLimit
+                )
+            );
+        }
+
+        $images = $this->loadImages($splitContentIdList);
+
+        $numberOfResults = $images->totalCount;
+        if (0 === $numberOfResults) {
+            return new Response(
+                'No results found.',
+                Response::HTTP_NOT_FOUND
+            );
+        }
+
+        if (1 === $numberOfResults) {
+            return $this->downloadSingleImage(
+                $images->getIterator()->current()->valueObject
+            );
+        }
+
+        $contentList = [];
+
+        /** @var \Ibexa\Contracts\Core\Repository\Values\Content\Search\SearchHit $image */
+        foreach ($images as $image) {
+            /** @var \Ibexa\Contracts\Core\Repository\Values\Content\Content $content */
+            $content = $image->valueObject;
+            $contentList[] = $content;
+        }
+
+        return $this->downloadArchiveWithImages($contentList);
+    }
+
+    private function downloadSingleImage(Content $content): Response
+    {
+        $value = $this->getImageValue($content);
+        $uri = $this->getImageUri($value);
+
+        $content = file_get_contents($uri);
+        if (false === $content) {
+            throw new RuntimeException(
+                sprintf(
+                    'Failed to read data from "%s"',
+                    $uri
+                )
+            );
+        }
+
+        $response = $this->createResponse(
+            $content,
+            $this->getImageFileName($value)
+        );
+
+        $response->headers->set('Content-Type', $value->mime);
+
+        return $response;
+    }
+
+    /**
+     * @param array<\Ibexa\Contracts\Core\Repository\Values\Content\Content> $contentList
+     */
+    private function downloadArchiveWithImages(array $contentList): Response
+    {
+        $archiveName = sprintf(
+            self::ARCHIVE_NAME_PATTERN,
+            time()
+        );
+
+        $this->createArchive($archiveName, $contentList);
+
+        $content = file_get_contents($archiveName);
+        if (false === $content) {
+            throw new RuntimeException('Failed to read archive with images.');
+        }
+
+        $response = $this->createResponse($content, $archiveName);
+        $response->headers->set('Content-Type', 'application/zip');
+
+        unlink($archiveName);
+
+        return $response;
+    }
+
+    private function getImageValue(Content $content): Value
+    {
+        $imageFieldIdentifier = $this->getImageFieldIdentifier($content->getContentType()->identifier);
+        $value = $content->getFieldValue($imageFieldIdentifier);
+
+        if (null === $value) {
+            throw new RuntimeException(
+                sprintf(
+                    'Missing field with identifier: "%s"',
+                    $imageFieldIdentifier
+                )
+            );
+        }
+
+        if (!$value instanceof Value) {
+            throw new RuntimeException(
+                sprintf(
+                    'Field value should be of type %s. "%s" given.',
+                    Value::class,
+                    get_debug_type($value)
+                )
+            );
+        }
+
+        return $value;
+    }
+
+    private function getImageFieldIdentifier(string $contentTypeIdentifier): string
+    {
+        $imageFieldIdentifier = $this->imageMappings[$contentTypeIdentifier]['imageFieldIdentifier'];
+        if (null === $imageFieldIdentifier) {
+            throw new RuntimeException(
+                sprintf(
+                    'Missing key imageFieldIdentifier for content type mapping "%s".',
+                    $contentTypeIdentifier
+                )
+            );
+        }
+
+        return $imageFieldIdentifier;
+    }
+
+    private function getImageUri(Value $value): string
+    {
+        $uri = $value->uri;
+        if (null === $uri) {
+            throw new RuntimeException('Missing image uri');
+        }
+
+        return ltrim($uri, '/');
+    }
+
+    private function getImageFileName(Value $value): string
+    {
+        return $value->fileName ?? 'image_' . time();
+    }
+
+    /**
+     * @param array<int> $contentIdList
+     *
+     * @throws \Ibexa\Contracts\Core\Repository\Exceptions\InvalidArgumentException;
+     * @throws \Ibexa\Contracts\Core\Repository\Exceptions\InvalidCriterionArgumentException;
+     */
+    private function loadImages(array $contentIdList): SearchResult
+    {
+        $query = new Query();
+        $query->filter = new Query\Criterion\LogicalAnd(
+            [
+                new Query\Criterion\ContentId($contentIdList),
+            ]
+        );
+        $query->limit = $this->downloadLimit;
+
+        return $this->searchService->findContent($query);
+    }
+
+    private function createResponse(
+        string $content,
+        string $fileName
+    ): Response {
+        $disposition = HeaderUtils::makeDisposition(
+            HeaderUtils::DISPOSITION_ATTACHMENT,
+            $fileName
+        );
+
+        return new Response(
+            $content,
+            200,
+            [
+                'Content-Disposition' => $disposition,
+                'Content-Length' => strlen($content),
+            ]
+        );
+    }
+
+    /**
+     * @param array<\Ibexa\Contracts\Core\Repository\Values\Content\Content> $contentList
+     */
+    private function createArchive(string $name, array $contentList): void
+    {
+        $zipArchive = new ZipArchive();
+        $zipArchive->open($name, ZipArchive::CREATE);
+
+        foreach ($contentList as $content) {
+            $value = $this->getImageValue($content);
+            $zipArchive->addFile(
+                $this->getImageUri($value),
+                $this->getImageFileName($value)
+            );
+        }
+
+        $zipArchive->close();
+    }
+}

src/bundle/Resources/config/default_parameters.yaml

@@ -92,4 +92,6 @@ parameters:
             contentTypeIdentifier: image
             fieldDefinitionIdentifier: tags
 
+    ibexa.dam_widget.image.download_limit: 25
+
     ibexa.dam_widget.folder.content_type_identifier: folder

src/bundle/Resources/config/routing_rest.yaml

@@ -119,3 +119,10 @@ ibexa.rest.application_config:
     methods: [GET]
     options:
         expose: true
+
+ibexa.rest.image.download:
+    path: /image/download/{contentIdList}
+    controller: 'Ibexa\Bundle\AdminUi\Controller\DownloadImageController::downloadAction'
+    methods: GET
+    requirements:
+        contentIdList: '^\d+(,\d+)*$'

src/bundle/Resources/config/services/controllers.yaml

@@ -244,3 +244,10 @@ services:
         autowire: true
         tags:
             - controller.service_arguments
+
+    Ibexa\Bundle\AdminUi\Controller\DownloadImageController:
+        arguments:
+            $downloadLimit: '%ibexa.dam_widget.image.download_limit%'
+            $imageMappings: '%ibexa.dam_widget.image.mappings%'
+        tags:
+            - controller.service_arguments