AjaxController::searchAction() - Code Metrics - Inspection of "[FEATURE] Api basic search" - TYPO3-Initiatives/digital-asset-management - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Pull Request — master (#105)

by Jürgen
created 2019-04-05 14:28 UTC
AjaxController::searchAction() B

↳ Parent: AjaxController
Complexity

Conditions	9
Paths	35
Size

Total Lines	36
Code Lines	27
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	9
eloc	27
nc	35
nop	1
dl	0
loc	36
rs	8.0555
c	0
b	0
f	0
<?php
declare(strict_types = 1);

/*
 * This file is part of the package lns/digital-asset-management.
 *
 * For the full copyright and license information, please read the
 * LICENSE file that was distributed with this source code.
 */

namespace TYPO3\CMS\DigitalAssetManagement\Controller;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use TYPO3\CMS\Backend\Routing\UriBuilder;
use TYPO3\CMS\Core\Authentication\BackendUserAuthentication;
use TYPO3\CMS\Core\Core\Environment;
use TYPO3\CMS\Core\Database\ConnectionPool;
use TYPO3\CMS\Core\Http\JsonResponse;
use TYPO3\CMS\Core\Http\Response;
use TYPO3\CMS\Core\Http\Stream;
use TYPO3\CMS\Core\Resource\Driver\LocalDriver;
use TYPO3\CMS\Core\Resource\DuplicationBehavior;
use TYPO3\CMS\Core\Resource\Exception as ResourceException;
use TYPO3\CMS\Core\Resource\Exception\InvalidTargetFolderException;
use TYPO3\CMS\Core\Resource\Exception\ResourceDoesNotExistException;
use TYPO3\CMS\Core\Resource\FileInterface;
use TYPO3\CMS\Core\Resource\Folder;
use TYPO3\CMS\Core\Resource\ResourceFactory;
use TYPO3\CMS\Core\Utility\GeneralUtility;
use TYPO3\CMS\Core\Utility\StringUtility;
use TYPO3\CMS\DigitalAssetManagement\Entity\FileMount;
use TYPO3\CMS\DigitalAssetManagement\Entity\FileOperationResult;
use TYPO3\CMS\DigitalAssetManagement\Entity\FolderItemFile;
use TYPO3\CMS\DigitalAssetManagement\Entity\FolderItemFolder;
use TYPO3\CMS\DigitalAssetManagement\Entity\FolderItemImage;
use TYPO3\CMS\DigitalAssetManagement\Entity\Storage;
use TYPO3\CMS\DigitalAssetManagement\Entity\TreeItemFolder;
use TYPO3\CMS\DigitalAssetManagement\Exception\ControllerException;
use TYPO3\CMS\DigitalAssetManagement\Http\FileExistsResponse;
use TYPO3\CMS\DigitalAssetManagement\Http\FileOperationResponse;
use TYPO3\CMS\DigitalAssetManagement\Http\FolderItemsResponse;
use TYPO3\CMS\DigitalAssetManagement\Http\JsonExceptionResponse;
use TYPO3\CMS\DigitalAssetManagement\Http\StoragesAndMountsResponse;

/**
 * Main API endpoint. These are ajax actions called by JS side.
 *
 * Look up the end points in Configuration/Backend/Routes.php: A typical
 * path is something like /ajax/dam/getStoragesAndMounts which maps to a method
 * with the same name plus word "Action": getStoragesAndMountsAction().
 *
 * All actions return a JsonResponse, if all is good, the return code is
 * 200. A different code, usually in 4xx range will be returned if the
 * client sent a bogus request, often with some exception details.
 */
class AjaxController
{
    /**
     * @return JsonResponse
     */
    public function getNewStorageUrlAction(): JsonResponse
    {
        $backendUser = $this->getBackendUser();
        if (!$backendUser->isAdmin()) {
            return new JsonExceptionResponse(new ControllerException('User is not admin', 1554380677));
        }
        $uriBuilder = GeneralUtility::makeInstance(UriBuilder::class);
        $urlParameters = [
            'edit' => [
                'sys_file_storage' => [
                    0 => 'new',
                ],
            ],
            'returnUrl' => (string)$uriBuilder->buildUriFromRoute('file_DigitalAssetManagement'),
        ];
        return new JsonResponse([(string)$uriBuilder->buildUriFromRoute('record_edit', $urlParameters)]);
    }

    /**
     * @param ServerRequestInterface $request
     * @return Response
     */
    public function prepareDownloadAction(ServerRequestInterface $request): ResponseInterface
    {
        $identifiers = $request->getQueryParams()['identifiers'] ?? '';
        try {
            if (empty($identifiers) || !is_array($identifiers)) {
                throw new ControllerException('List of files or folders needed', 1554375542);
            }
            // (Mis)-use the LocalDriver method to sanitize the filename prefix
            $archivePrefix = rtrim(
                GeneralUtility::makeInstance(LocalDriver::class)
                    ->sanitizeFileName($request->getQueryParams()['filenamePrefix'] ?? 'download'),
                '-'
            );
            $archiveFilename = Environment::getVarPath()
                . '/transient/'
                . $archivePrefix
                . '-'
                . GeneralUtility::hmac(StringUtility::getUniqueId(), 'damDownload')
                . '.zip';
            $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
            $zip = new \ZipArchive();
            $zip->open($archiveFilename, \ZipArchive::CREATE);
            foreach ($identifiers as $identifier) {
                $resource = $resourceFactory->getObjectFromCombinedIdentifier($identifier);
                if ($resource instanceof FileInterface) {
                    /** @var FileInterface $resource */
                    $zip->addFile($resource->getForLocalProcessing(false), $resource->getName());
                } else {
                    /** @var Folder $resource */
                    $this->addFolderToArchiveRecursive($resource, $zip);
                }
            }
            $zip->close();
            GeneralUtility::fixPermissions($archiveFilename);
        } catch (ResourceException $e) {
            return new JsonExceptionResponse($e);
        } catch (ControllerException $e) {
            return new JsonExceptionResponse($e);
        }
        return (new Response())
            ->withHeader('Filename', basename($archiveFilename))
            ->withHeader('Content-Type', 'application/zip')
            ->withHeader('Content-Length', (string) filesize($archiveFilename))
            ->withBody(new Stream($archiveFilename));
    }

    /**
     * @param Folder $folder
     * @param \ZipArchive $zip
     * @param array $parentFolders
     */
    protected function addFolderToArchiveRecursive(Folder $folder, \ZipArchive $zip, array $parentFolders = []): void
    {
        $folderName = $folder->getName();
        $parentFolders[] = $folderName;
        $implodedParentFolders = implode('/', $parentFolders);
        $zip->addEmptyDir($implodedParentFolders);
        $files = $folder->getFiles();
        foreach ($files as $file) {
            $zip->addFile($file->getForLocalProcessing(false), $implodedParentFolders . '/' . $file->getName());
        }
        $subFolders = $folder->getSubfolders();
        foreach ($subFolders as $subFolder) {
            $this->addFolderToArchiveRecursive($subFolder, $zip, $parentFolders);
        }
    }

    /**
     * @return JsonResponse
     */
    public function damGetLogoutUrlAction(): JsonResponse
    {
        if (empty($this->getBackendUser()->user['uid'])) {
            return new JsonExceptionResponse(new ControllerException('User is not logged in', 1554380677));
        }
        $uriBuilder = GeneralUtility::makeInstance(UriBuilder::class);
        return new JsonResponse([ (string)$uriBuilder->buildUriFromRoute('logout') ]);
    }

    /**
     * Set module state of BE user. Send a json array as ['data'] POST
     *
     * @param ServerRequestInterface $request
     * @return JsonResponse
     */
    public function setStateAction(ServerRequestInterface $request): JsonResponse
    {
        $backendUser = $this->getBackendUser();
        $backendUser->uc['digital_asset_management'] = $request->getParsedBody()['data'] ?? [];
        $backendUser->writeUC();
        return new JsonResponse();
    }

    /**
     * @return JsonResponse
     */
    public function getStateAction(): JsonResponse
    {
        return new JsonResponse([ 'data' => $this->getBackendUser()->uc['digital_asset_management'] ?? []]);
    }

    /**
     * @param ServerRequestInterface $request
     *
     * @return JsonResponse
     */
    public function createFolderAction(ServerRequestInterface $request): JsonResponse
    {
        $identifier = $request->getQueryParams()['identifier'] ?? '';
        if (empty($identifier)) {
            return new JsonExceptionResponse(new ControllerException('Identifier needed', 1554204780));
        }
        try {
            $folder = $this->createFolderRecursive($identifier);
            return new JsonResponse([new FolderItemFolder($folder)]);
        } catch (ResourceException $e) {
            return new JsonExceptionResponse($e);
        }
    }

    /**
     * @param ServerRequestInterface $request
     *
     * @return JsonResponse
     */
    public function fileUploadAction(ServerRequestInterface $request): JsonResponse
    {
        $identifier = $request->getQueryParams()['identifier'] ?? '';
        $conflictMode = $request->getQueryParams()['conflictMode'] ?? '';
        $tempFilename = '';
        try {
            if (empty($identifier)) {
                throw new ControllerException('Identifier needed', 1554132801);
            }
            if (empty($conflictMode) || !in_array($conflictMode, ['replace', 'cancel', 'rename'], true)) {
                throw new ControllerException('conflictMode must be one of "replace", "cancel", "rename"');
            }
            $folderIdentifier = dirname($identifier) . '/';
            $fileIdentifier = basename($identifier);
            $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
            try {
                $folder = $resourceFactory->retrieveFileOrFolderObject($folderIdentifier);
            } catch (ResourceDoesNotExistException $e) {
                $folder = $this->createFolderRecursive($folderIdentifier);
            }
            $tempFilename = tempnam(sys_get_temp_dir(), 'upload_');
            file_put_contents($tempFilename, $request->getBody());
            $file = $folder->addFile($tempFilename, $fileIdentifier, (string)DuplicationBehavior::cast($conflictMode));
            $fileExtension = strtolower($file->getExtension());
            if (GeneralUtility::inList($GLOBALS['TYPO3_CONF_VARS']['GFX']['imagefile_ext'], $fileExtension)
                || GeneralUtility::inList($GLOBALS['TYPO3_CONF_VARS']['GFX']['mediafile_ext'], $fileExtension)
            ) {
                return new JsonResponse([new FolderItemImage($file)]);
            }
            return new JsonResponse([new FolderItemFile($file)]);
        } catch (ResourceException $e) {
            if (!empty($tempFilename) && file_exists($tempFilename)) {
                unlink($tempFilename);
            }
            return new JsonExceptionResponse($e);
        } catch (ControllerException $e) {
            return new JsonExceptionResponse($e);
        }
    }

    /**
     * @param string $folderIdentifier
     *
     * @return Folder
     */
    protected function createFolderRecursive(string $folderIdentifier): Folder
    {
        $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
        $stack = [];
        while (true) {
            $parentName = dirname($folderIdentifier);
            $folderName = basename($folderIdentifier);
            $stack[] = $folderName;
            try {
                $parentObject = $resourceFactory->retrieveFileOrFolderObject($parentName);
                break;
            } catch (ResourceDoesNotExistException $e) {
                $folderIdentifier = $parentName;
            }
        }
        while ($folderName = array_pop($stack)) {
            try {
                $parentObject = $parentObject->createFolder($folderName);

            } catch (ResourceException $e) {

            }
        }
        return $parentObject;
    }

    /**
     * @param ServerRequestInterface $request
     *
     * @return JsonResponse
     */
    public function fileExistsAction(ServerRequestInterface $request): JsonResponse
    {
        $identifier = $request->getQueryParams()['identifier'];
        if (empty($identifier)) {
            return new JsonExceptionResponse(new ControllerException('Identifier needed', 1554125449));
        }
        $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
        $folderIdentifier = dirname($identifier) . '/';
        $fileIdentifier = basename($identifier);
        try {
            $folder = $resourceFactory->retrieveFileOrFolderObject($folderIdentifier);
        } catch (ResourceDoesNotExistException $e) {
            return new FileExistsResponse(FileExistsResponse::PARENT_FOLDER_DOES_NOT_EXIST);
        }
        $fileName = $folder->getStorage()->sanitizeFileName($fileIdentifier, $folder);
        if ($folder->hasFile($fileName)) {
            $file = $resourceFactory->getFileObjectFromCombinedIdentifier($folderIdentifier . $fileName);
            // If file is an image or media, create image object, else file object
            $fileExtension = strtolower($file->getExtension());
            if (GeneralUtility::inList($GLOBALS['TYPO3_CONF_VARS']['GFX']['imagefile_ext'], $fileExtension)
                || GeneralUtility::inList($GLOBALS['TYPO3_CONF_VARS']['GFX']['mediafile_ext'], $fileExtension)
            ) {
                return new JsonResponse([new FolderItemImage($file)]);
            }
            return new JsonResponse([new FolderItemFile($file)]);
        } else {
            return new FileExistsResponse(FileExistsResponse::FILE_DOES_NOT_EXIST);
        }
    }

    /**
     * Return item list (folders, files, images) of a storage:path
     * FAL folder identifier. GET request with identifier argument.
     *
     * @param ServerRequestInterface $request
     *
     * @return JsonResponse
     */
    public function getFolderItemsAction(ServerRequestInterface $request): JsonResponse
    {
        try {
            $identifier = $request->getQueryParams()['identifier'] ?? '';
            if (empty($identifier)) {
                throw new ControllerException('Identifier needed', 1553699828);
            }
            $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
            $folderObject = $resourceFactory->getObjectFromCombinedIdentifier($identifier);
            if (!$folderObject instanceof Folder) {
                throw new ControllerException('Identifier is not a folder', 1553701684);
            }
            $subFolders = $folderObject->getSubfolders();
            $folders = [];
            foreach ($subFolders as $subFolder) {
                $folders[] = new FolderItemFolder($subFolder);
            }
            $allFiles = $folderObject->getFiles();
            $files = [];
            $images = [];
            foreach ($allFiles as $file) {
                // If file is an image or media, create image object, else file object
                $fileExtension = strtolower($file->getExtension());
                if (GeneralUtility::inList($GLOBALS['TYPO3_CONF_VARS']['GFX']['imagefile_ext'], $fileExtension)
                    || GeneralUtility::inList($GLOBALS['TYPO3_CONF_VARS']['GFX']['mediafile_ext'], $fileExtension)
                ) {
                    $images[] = new FolderItemImage($file);
                } else {
                    $files[] = new FolderItemFile($file);
                }
            }
            return new FolderItemsResponse($folders, $files, $images);
        } catch (ResourceException $e) {
            return new JsonExceptionResponse($e);
        } catch (ControllerException $e) {
            return new JsonExceptionResponse($e);
        }
    }

    /**
     * Returns list of storages (admins), or file mounts (non-admin). Admins
     * do NOT receive a list of file mounts, just the storages.
     *
     * Storages are returned in no particular order, file mounts are ordered
     * by 'sorting' DB field.
     *
     * Return structure is an array of Storage or FileMount objects.
     *
     * @return JsonResponse
     */
    public function getStoragesAndMountsAction(): JsonResponse
    {
        $backendUser = $this->getBackendUser();
        $storages = $backendUser->getFileStorages();
        $entities = [];
        if ($backendUser->isAdmin()) {
            foreach ($storages as $storage) {
                $entities[] = new Storage($storage);
            }
        } else {
            foreach ($storages as $storage) {
                $fileMounts = $storage->getFileMounts();
                foreach ($fileMounts as $fileMount) {
                    $entities[] = new FileMount($storage, $fileMount);
                }
            }
        }
        return new StoragesAndMountsResponse($entities);
    }

    /**
     * Returns list of folders only. No files, no images
     * Result is sorted by name
     *
     * Return structure is an array of TreeItemFolder objects.
     *
     * @param ServerRequestInterface $request
     *
     * @return JsonResponse
     */
    public function getTreeFoldersAction(ServerRequestInterface $request): JsonResponse
    {
        try {
            $identifier = $request->getQueryParams()['identifier'] ?? '';
            if (empty($identifier)) {
                throw new ControllerException('Identifier needed', 1553699828);
            }
            $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
            $folderObject = $resourceFactory->getObjectFromCombinedIdentifier($identifier);
            if (!$folderObject instanceof Folder) {
                throw new ControllerException('Identifier is not a folder', 1553701684);
            }
            $subFolders = $folderObject->getSubfolders();
            $folders = [];
            foreach ($subFolders as $subFolder) {
                $folders[] = new TreeItemFolder($subFolder);
            }
            return new JsonResponse($folders);
        } catch (ResourceException $e) {
            return new JsonExceptionResponse($e);
        } catch (ControllerException $e) {
            return new JsonExceptionResponse($e);
        }
    }

    /**
     * Copy files or folders
     * Query parameters
     *  'identifiers' array of identifier to copy
     *  'targetFolderIdentifier' string the target identifier. Must be a folder.
     *  'conflictMode' string one of: "replace", "cancel", "rename", as defined in \TYPO3\CMS\Core\Resource\DuplicationBehavior
     *
     * @param ServerRequestInterface $request
     *
     * @return JsonResponse
     */
    public function copyResourcesAction(ServerRequestInterface $request): JsonResponse
    {
        try {
            $identifiers = $request->getQueryParams()['identifiers'];
            $conflictMode = $request->getQueryParams()['conflictMode'] ?? '';
            $targetFolderIdentifier = $request->getQueryParams()['targetFolderIdentifier'];
            if (empty($identifiers)) {
                throw new ControllerException('Identifiers needed', 1553699828);
            }
            if (empty($conflictMode) || !in_array($conflictMode, ['replace', 'cancel', 'rename'], true)) {
                throw new ControllerException('conflictMode must be one of "replace", "cancel", "rename"');
            }
            if (empty($targetFolderIdentifier)) {
                throw new ControllerException(
                    'Target folder identifier needed',
                    1554122023
                );
            }
            $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
            $targetFolderObject = $resourceFactory->getObjectFromCombinedIdentifier($targetFolderIdentifier);
            if (!$targetFolderObject instanceof Folder) {
                throw new ControllerException('Target identifier is not a folder', 1553701684);
            }
        } catch (ResourceException $e) {
            return new JsonExceptionResponse($e);
        } catch (ControllerException $e) {
            return new JsonExceptionResponse($e);
        }
        $resources = [];
        foreach ($identifiers as $identifier) {
            $state = FileOperationResult::FAILED;
            $message = '';
            $resultEntity = null;
            try {
                $sourceObject = $resourceFactory->getObjectFromCombinedIdentifier($identifier);
                if ($resultObject = $sourceObject->copyTo($targetFolderObject, null, (string)DuplicationBehavior::cast($conflictMode))) {
                    if ($resultObject instanceof Folder) {
                        $resultEntity = new FolderItemFolder($resultObject);
                    } else {
                        $resultEntity = new FolderItemFile($resultObject);
                    }
                    $state = FileOperationResult::COPIED;
                }
            } catch (InvalidTargetFolderException $e) {
                $message = $e->getMessage();
            } catch (ResourceException $e) {
                $message = $e->getMessage();
            }
            $resources[] = new FileOperationResult($identifier, $state, $message, $resultEntity);
        }
        return new FileOperationResponse($resources);
    }

    /**
     * Move files or folders
     * Query parameters
     *  'identifiers' array of identifier to move
     *  'targetFolderIdentifier' string the target identifier. Must be a folder.
     *  'conflictMode' string one of: "replace", "cancel", "rename", as defined in \TYPO3\CMS\Core\Resource\DuplicationBehavior
     *
     * @param ServerRequestInterface $request
     *
     * @return JsonResponse
     */
    public function moveResourcesAction(ServerRequestInterface $request): JsonResponse
    {
        try {
            $identifiers = $request->getQueryParams()['identifiers'];
            $conflictMode = $request->getQueryParams()['conflictMode'] ?? '';
            $targetFolderIdentifier = $request->getQueryParams()['targetFolderIdentifier'];
            if (empty($identifiers)) {
                throw new ControllerException('Identifiers needed', 1553699828);
            }
            if (empty($conflictMode) || !in_array($conflictMode, ['replace', 'cancel', 'rename'], true)) {
                throw new ControllerException('conflictMode must be one of "replace", "cancel", "rename"');
            }
            if (empty($targetFolderIdentifier)) {
                throw new ControllerException('Target folder identifier needed', 1554122023);
            }
            $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
            $targetFolderObject = $resourceFactory->getObjectFromCombinedIdentifier($targetFolderIdentifier);
            if (!$targetFolderObject instanceof Folder) {
                throw new ControllerException('Target identifier is not a folder', 1553701684);
            }
        } catch (ResourceException $e) {
            return new JsonExceptionResponse($e);
        } catch (ControllerException $e) {
            return new JsonExceptionResponse($e);
        }
        $resources = [];
        foreach ($identifiers as $identifier) {
            $state = FileOperationResult::FAILED;
            $message = '';
            $resultEntity = null;
            try {
                $sourceObject = $resourceFactory->getObjectFromCombinedIdentifier($identifier);
                if ($resultObject = $sourceObject->moveTo($targetFolderObject, null, (string)DuplicationBehavior::cast($conflictMode))) {
                    if ($resultObject instanceof Folder) {
                        $resultEntity = new FolderItemFolder($resultObject);
                    } else {
                        $resultEntity = new FolderItemFile($resultObject);
                    }
                    $state = FileOperationResult::MOVED;
                }
            } catch (InvalidTargetFolderException $e) {
                $message = $e->getMessage();
            } catch (ResourceException $e) {
                $message = $e->getMessage();
            }
            $resources[] = new FileOperationResult($identifier, $state, $message, $resultEntity);
        }
        return new FileOperationResponse($resources);
    }

    /**
     * rename file or folder
     * Query parameters
     *  'identifier' string identifier to rename
     *  'targetName' string The new name of file or folder.
     *  'conflictMode' string one of: "replace", "cancel", "rename"
     *
     * @param ServerRequestInterface $request
     *
     * @return JsonResponse
     */
    public function renameResourcesAction(ServerRequestInterface $request): JsonResponse
    {
        try {
            $identifier = $request->getQueryParams()['identifier'];
            $targetName = $request->getQueryParams()['targetName'];
            $conflictMode = $request->getQueryParams()['conflictMode'] ?? '';
            if (empty($identifier)) {
                throw new ControllerException('Identifier needed', 1553699828);
            }
            if (empty($conflictMode) || !in_array($conflictMode, ['replace', 'cancel', 'rename'], true)) {
                throw new ControllerException('conflictMode must be one of "replace", "cancel", "rename"');
            }
            if (empty($targetName)) {
                throw new ControllerException('Target name needed', 1554193259);
            }
            $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
            $fileOrFolder = $resourceFactory->retrieveFileOrFolderObject($identifier);
        } catch (ResourceException $e) {
            return new JsonExceptionResponse($e);
        } catch (ControllerException $e) {
            return new JsonExceptionResponse($e);
        }
        $resources = [];
        $state = FileOperationResult::FAILED;
        $resultEntity = null;
        try {
            if ($fileOrFolder === null) {
                throw new ResourceException\ResourceDoesNotExistException('Resource does not exist');
            } else {
                $resultObject = $fileOrFolder->rename($targetName, (string)DuplicationBehavior::cast($conflictMode));
                if ($resultObject instanceof Folder) {
                    $resultEntity = new FolderItemFolder($resultObject);
                    $message = 'Folder was successfully renamed';
                } else {
                    $resultEntity = new FolderItemFile($resultObject);
                    $message = 'File was successfully renamed';
                }
                $state = FileOperationResult::RENAMED;
            }
        } catch (ResourceException $e) {
            $message = $e->getMessage();
        }
        $resources[] = new FileOperationResult($identifier, $state, $message, $resultEntity);
        return new JsonResponse($resources);
    }

    /**
     * delete file or folder
     * Query parameters
     *  'identifiers' array of strings identifier of file or folder to delete
     *
     * @param ServerRequestInterface $request
     *
     * @return JsonResponse
     */
    public function deleteResourcesAction(ServerRequestInterface $request): JsonResponse
    {
        try {
            $identifiers = $request->getQueryParams()['identifiers'];
            if (empty($identifiers)) {
                throw new ControllerException('Identifiers needed', 1553699828);
            }
        } catch (ControllerException $e) {
            return new JsonExceptionResponse($e);
        }
        $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
        $resources = [];
        foreach ($identifiers as $identifier) {
            try {
                $sourceObject = $resourceFactory->getObjectFromCombinedIdentifier($identifier);
                if ($sourceObject->delete(true)) {
                    $state = FileOperationResult::DELETED;
                    $message = 'Resource deleted';
                } else {
                    $state = FileOperationResult::FAILED;
                    $message = 'Resource could not be deleted';
                }
            } catch (ResourceException $e) {
                $state = FileOperationResult::FAILED;
                $message = $e->getMessage();
            }
            $resources[] = new FileOperationResult($identifier, $state, $message, null);
        }
        return new FileOperationResponse($resources);
    }

    /**
     * Return item list (folders, files, images) of a storage:path
     * FAL folder identifier. GET request with identifier argument.
     * Query parameter
     *  identifier string combined identifier of search starting point
     *  query string serach string
     *
     * @param ServerRequestInterface $request
     *
     * @return JsonResponse
     */
    public function searchAction(ServerRequestInterface $request): JsonResponse
    {
        try {
            $identifier = $request->getQueryParams()['identifier'] ?? '';
            $query = $request->getQueryParams()['query'] ?? '';
            if (empty($identifier)) {
                throw new ControllerException('Identifier needed', 1553699828);
            }
            if (empty($identifier)) {
                throw new ControllerException('Query string needed', 1554452377);
            }
            $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
            $folderObject = $resourceFactory->getObjectFromCombinedIdentifier($identifier);
            if (!$folderObject instanceof Folder) {
                throw new ControllerException('Identifier is not a folder', 1553701684);
            }
            $allFiles = $this->searchFiles($identifier, $query);
            $folders = [];
            $files = [];
            $images = [];
            foreach ($allFiles as $file) {
                // If file is an image or media, create image object, else file object
                $fileExtension = strtolower($file->getExtension());
                if (GeneralUtility::inList($GLOBALS['TYPO3_CONF_VARS']['GFX']['imagefile_ext'], $fileExtension)
                    || GeneralUtility::inList($GLOBALS['TYPO3_CONF_VARS']['GFX']['mediafile_ext'], $fileExtension)
                ) {
                    $images[] = new FolderItemImage($file);
                } else {
                    $files[] = new FolderItemFile($file);
                }
            }
            return new FolderItemsResponse($folders, $files, $images);
        } catch (ResourceException $e) {
            return new JsonExceptionResponse($e);
        } catch (ControllerException $e) {
            return new JsonExceptionResponse($e);
        }
    }

    /**
     * returns an array of files in a current path
     *
     * @param string $combinedIdentifier
     * @param string $searchWord
     *
     * @return array
     * @throws ResourceDoesNotExistException
     */
    protected function searchFiles($combinedIdentifier = '', $searchWord = ''): array
    {
        $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable('sys_file');
        /** @var ResourceFactory $resourceFactory */
        $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
        $storage = $resourceFactory->getStorageObjectFromCombinedIdentifier($combinedIdentifier);
        $identifier = substr($combinedIdentifier, strpos($combinedIdentifier, ':') + 1);
        $constraints = [];
        $constraints[] = $queryBuilder->expr()->eq('storage', $storage->getUid());
        $constraints[] = $queryBuilder->expr()->like('sys_file.name', $queryBuilder->createNamedParameter('%' . $queryBuilder->escapeLikeWildcards($searchWord) . '%') );
        if ($identifier !== '/') {
            $constraints[] = $queryBuilder->expr()->like('identifier', $queryBuilder->createNamedParameter( $queryBuilder->escapeLikeWildcards($identifier) . '%') );
        }
        $statement = $queryBuilder->select('*')
            ->from('sys_file')
            ->join(
                'sys_file',
                'sys_file_metadata',
                'file_metadata',
                $queryBuilder->expr()->eq('sys_file.uid', 'file_metadata.file')
            )
            ->where($queryBuilder->expr()->andX(...$constraints))
            ->execute();
        $files = [];
        $resourceFactory = GeneralUtility::makeInstance(ResourceFactory::class);
        while ($row = $statement->fetch()) {
            $files[] = $resourceFactory->getObjectFromCombinedIdentifier($row['storage'] . ':' . $row['identifier']);
        }
        return $files;
    }


    /**
     * @return BackendUserAuthentication
     */
    protected function getBackendUser(): BackendUserAuthentication
    {
        return $GLOBALS['BE_USER'];
    }
}

TYPO3-Initiatives / digital-asset-management

Pull Request — master (#105)

AjaxController::searchAction() B

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like
