fabarea / media

Classes/ViewHelpers/File/ExistsViewHelper.php

Indentation +28 added lines, -28 removed lines

@@ -19,36 +19,36 @@
  */
 class ExistsViewHelper extends AbstractViewHelper
 {
-    /**
-     * @return void
-     */
-    public function initializeArguments()
-    {
-        $this->registerArgument('file', 'mixed', '', true);
-    }
+	/**
+	 * @return void
+	 */
+	public function initializeArguments()
+	{
+		$this->registerArgument('file', 'mixed', '', true);
+	}
 
-    /**
-     * Returns a property value of a file given by the context.
-     *
-     * @return bool
-     */
-    public function render()
-    {
-        /** @var File|Content|int $file $file */
-        $file = $this->arguments['file'];
+	/**
+	 * Returns a property value of a file given by the context.
+	 *
+	 * @return bool
+	 */
+	public function render()
+	{
+		/** @var File|Content|int $file $file */
+		$file = $this->arguments['file'];
 
-        if (!$file instanceof File) {
-            $file = $this->getFileConverter()->convert($file);
-        }
+		if (!$file instanceof File) {
+			$file = $this->getFileConverter()->convert($file);
+		}
 
-        return $file->exists();
-    }
+		return $file->exists();
+	}
 
-    /**
-     * @return ContentToFileConverter|object
-     */
-    protected function getFileConverter()
-    {
-        return GeneralUtility::makeInstance(ContentToFileConverter::class);
-    }
+	/**
+	 * @return ContentToFileConverter|object
+	 */
+	protected function getFileConverter()
+	{
+		return GeneralUtility::makeInstance(ContentToFileConverter::class);
+	}
 }

Classes/ViewHelpers/File/UriViewHelper.php

Indentation +30 added lines, -30 removed lines

@@ -19,37 +19,37 @@
  */
 class UriViewHelper extends AbstractViewHelper
 {
-    /**
-     * @return void
-     */
-    public function initializeArguments()
-    {
-        $this->registerArgument('file', 'mixed', '', true);
-        $this->registerArgument('relative', 'bool', '', false, false);
-    }
+	/**
+	 * @return void
+	 */
+	public function initializeArguments()
+	{
+		$this->registerArgument('file', 'mixed', '', true);
+		$this->registerArgument('relative', 'bool', '', false, false);
+	}
 
-    /**
-     * Returns a property value of a file given by the context.
-     *
-     * @return string
-     */
-    public function render()
-    {
-        /** @var File|Content|int $file $file */
-        $file = $this->arguments['file'];
-        $relative = $this->arguments['relative'];
+	/**
+	 * Returns a property value of a file given by the context.
+	 *
+	 * @return string
+	 */
+	public function render()
+	{
+		/** @var File|Content|int $file $file */
+		$file = $this->arguments['file'];
+		$relative = $this->arguments['relative'];
 
-        if (!$file instanceof File) {
-            $file = $this->getFileConverter()->convert($file);
-        }
-        return $file->getPublicUrl($relative);
-    }
+		if (!$file instanceof File) {
+			$file = $this->getFileConverter()->convert($file);
+		}
+		return $file->getPublicUrl($relative);
+	}
 
-    /**
-     * @return ContentToFileConverter|object
-     */
-    protected function getFileConverter()
-    {
-        return GeneralUtility::makeInstance(ContentToFileConverter::class);
-    }
+	/**
+	 * @return ContentToFileConverter|object
+	 */
+	protected function getFileConverter()
+	{
+		return GeneralUtility::makeInstance(ContentToFileConverter::class);
+	}
 }

Classes/ViewHelpers/File/PropertyViewHelper.php

Indentation +19 added lines, -19 removed lines

@@ -17,25 +17,25 @@
  */
 class PropertyViewHelper extends AbstractViewHelper
 {
-    /**
-     * @return void
-     */
-    public function initializeArguments()
-    {
-        $this->registerArgument('name', 'string', '', true);
-    }
+	/**
+	 * @return void
+	 */
+	public function initializeArguments()
+	{
+		$this->registerArgument('name', 'string', '', true);
+	}
 
-    /**
-     * Returns a property value of a file given by the context.
-     *
-     * @return string
-     */
-    public function render()
-    {
-        $name = $this->arguments['name'];
+	/**
+	 * Returns a property value of a file given by the context.
+	 *
+	 * @return string
+	 */
+	public function render()
+	{
+		$name = $this->arguments['name'];
 
-        /** @var File $file */
-        $file = $this->templateVariableContainer->get('file');
-        return $file->getProperty($name);
-    }
+		/** @var File $file */
+		$file = $this->templateVariableContainer->get('file');
+		return $file->getProperty($name);
+	}
 }

Classes/ViewHelpers/File/ThumbnailViewHelper.php

Indentation +59 added lines, -59 removed lines

@@ -22,68 +22,68 @@
  */
 class ThumbnailViewHelper extends AbstractViewHelper
 {
-    /**
-     * @return void
-     */
-    public function initializeArguments()
-    {
-        $this->registerArgument('file', 'mixed', 'The source file', false, null);
-        $this->registerArgument('configuration', 'array', 'Configuration to be given for the thumbnail processing.', false, []);
-        $this->registerArgument('attributes', 'array', 'DOM attributes to add to the thumbnail image', false, '');
-        $this->registerArgument('preset', 'string', 'Image dimension preset', false, '');
-        $this->registerArgument('output', 'string', 'Can be: uri, image, imageWrapped', false, 'image');
-        $this->registerArgument('configurationWrap', 'array', 'The configuration given to the wrap.', false, '');
-    }
+	/**
+	 * @return void
+	 */
+	public function initializeArguments()
+	{
+		$this->registerArgument('file', 'mixed', 'The source file', false, null);
+		$this->registerArgument('configuration', 'array', 'Configuration to be given for the thumbnail processing.', false, []);
+		$this->registerArgument('attributes', 'array', 'DOM attributes to add to the thumbnail image', false, '');
+		$this->registerArgument('preset', 'string', 'Image dimension preset', false, '');
+		$this->registerArgument('output', 'string', 'Can be: uri, image, imageWrapped', false, 'image');
+		$this->registerArgument('configurationWrap', 'array', 'The configuration given to the wrap.', false, '');
+	}
 
-    /**
-     * Returns a configurable thumbnail of an asset
-     *
-     * @throws \Exception
-     * @return string
-     */
-    public function render()
-    {
-        $file = $this->arguments['file'];
-        $preset = $this->arguments['preset'];
-        $configuration = $this->arguments['configuration'];
-        if (!is_array($configuration)) {
-            $configuration = array();
-        }
-        $configurationWrap = $this->arguments['configurationWrap'];
-        $attributes = $this->arguments['attributes'];
-        $output = $this->arguments['output'];
+	/**
+	 * Returns a configurable thumbnail of an asset
+	 *
+	 * @throws \Exception
+	 * @return string
+	 */
+	public function render()
+	{
+		$file = $this->arguments['file'];
+		$preset = $this->arguments['preset'];
+		$configuration = $this->arguments['configuration'];
+		if (!is_array($configuration)) {
+			$configuration = array();
+		}
+		$configurationWrap = $this->arguments['configurationWrap'];
+		$attributes = $this->arguments['attributes'];
+		$output = $this->arguments['output'];
 
-        if ($file instanceof Content) {
-            $file = $this->getFileConverter()->convert($file);
-        } elseif (!($file instanceof File)) {
-            $file = $this->getResourceFactory()->getFileObject((int)$file);
-        }
-        if ($preset) {
-            $imageDimension = ImagePresetUtility::getInstance()->preset($preset);
-            $configuration['width'] = $imageDimension->getWidth();
-            $configuration['height'] = $imageDimension->getHeight();
-        }
-        /** @var $thumbnailService \Fab\Media\Thumbnail\ThumbnailService */
-        $thumbnailService = GeneralUtility::makeInstance(ThumbnailService::class, $file);
-        $thumbnail = $thumbnailService->setConfiguration($configuration)
-            ->setConfigurationWrap($configurationWrap)
-            ->setAttributes($attributes)
-            ->setOutputType($output)
-            ->create();
+		if ($file instanceof Content) {
+			$file = $this->getFileConverter()->convert($file);
+		} elseif (!($file instanceof File)) {
+			$file = $this->getResourceFactory()->getFileObject((int)$file);
+		}
+		if ($preset) {
+			$imageDimension = ImagePresetUtility::getInstance()->preset($preset);
+			$configuration['width'] = $imageDimension->getWidth();
+			$configuration['height'] = $imageDimension->getHeight();
+		}
+		/** @var $thumbnailService \Fab\Media\Thumbnail\ThumbnailService */
+		$thumbnailService = GeneralUtility::makeInstance(ThumbnailService::class, $file);
+		$thumbnail = $thumbnailService->setConfiguration($configuration)
+			->setConfigurationWrap($configurationWrap)
+			->setAttributes($attributes)
+			->setOutputType($output)
+			->create();
 
-        return $thumbnail;
-    }
+		return $thumbnail;
+	}
 
-    /**
-     * @return ContentToFileConverter|object
-     */
-    protected function getFileConverter()
-    {
-        return GeneralUtility::makeInstance(ContentToFileConverter::class);
-    }
+	/**
+	 * @return ContentToFileConverter|object
+	 */
+	protected function getFileConverter()
+	{
+		return GeneralUtility::makeInstance(ContentToFileConverter::class);
+	}
 
-    protected function getResourceFactory(): ResourceFactory
-    {
-        return GeneralUtility::makeInstance(ResourceFactory::class);
-    }
+	protected function getResourceFactory(): ResourceFactory
+	{
+		return GeneralUtility::makeInstance(ResourceFactory::class);
+	}
 }

Classes/Override/Backend/Form/FormResultCompiler.php

Indentation +26 added lines, -26 removed lines

@@ -18,37 +18,37 @@
  */
 class FormResultCompiler extends \TYPO3\CMS\Backend\Form\FormResultCompiler
 {
-    /**
-     * JavaScript bottom code
-     *
-     * @param string $formname The identification of the form on the page.
-     * @return string A section with JavaScript - if $update is false, embedded in <script></script>
-     */
-    protected function JSbottom()
-    {
-        $out = parent::JSbottom();
+	/**
+	 * JavaScript bottom code
+	 *
+	 * @param string $formname The identification of the form on the page.
+	 * @return string A section with JavaScript - if $update is false, embedded in <script></script>
+	 */
+	protected function JSbottom()
+	{
+		$out = parent::JSbottom();
 
-        $tsConfig = $this->getBackendUser()->getTSConfig();
-        $enableMediaFilePicker = (bool)$tsConfig['options.vidi.enableMediaFilePicker'];
-        if ($enableMediaFilePicker) {
-            $pageRenderer = $this->getPageRenderer();
-            $pageRenderer->loadRequireJsModule('TYPO3/CMS/Media/MediaFormEngine', 'function(MediaFormEngine) {
+		$tsConfig = $this->getBackendUser()->getTSConfig();
+		$enableMediaFilePicker = (bool)$tsConfig['options.vidi.enableMediaFilePicker'];
+		if ($enableMediaFilePicker) {
+			$pageRenderer = $this->getPageRenderer();
+			$pageRenderer->loadRequireJsModule('TYPO3/CMS/Media/MediaFormEngine', 'function(MediaFormEngine) {
             MediaFormEngine.vidiModuleUrl = \'' . BackendUtility::getModuleUrl(VidiModule::getSignature()) . '\';
             MediaFormEngine.vidiModulePrefix = \'' . VidiModule::getParameterPrefix() . '\';
             MediaFormEngine.browserUrl = ' . GeneralUtility::quoteJSvalue(BackendUtility::getModuleUrl('wizard_element_browser')) . ';
         }');
-        }
+		}
 
-        return $out;
-    }
+		return $out;
+	}
 
-    /**
-     * Returns an instance of the current Backend User.
-     *
-     * @return BackendUserAuthentication
-     */
-    protected function getBackendUser()
-    {
-        return $GLOBALS['BE_USER'];
-    }
+	/**
+	 * Returns an instance of the current Backend User.
+	 *
+	 * @return BackendUserAuthentication
+	 */
+	protected function getBackendUser()
+	{
+		return $GLOBALS['BE_USER'];
+	}
 }

Spacing +3 added lines, -3 removed lines

@@ -33,9 +33,9 @@
         if ($enableMediaFilePicker) {
             $pageRenderer = $this->getPageRenderer();
             $pageRenderer->loadRequireJsModule('TYPO3/CMS/Media/MediaFormEngine', 'function(MediaFormEngine) {
-            MediaFormEngine.vidiModuleUrl = \'' . BackendUtility::getModuleUrl(VidiModule::getSignature()) . '\';
-            MediaFormEngine.vidiModulePrefix = \'' . VidiModule::getParameterPrefix() . '\';
-            MediaFormEngine.browserUrl = ' . GeneralUtility::quoteJSvalue(BackendUtility::getModuleUrl('wizard_element_browser')) . ';
+            MediaFormEngine.vidiModuleUrl = \'' . BackendUtility::getModuleUrl(VidiModule::getSignature()).'\';
+            MediaFormEngine.vidiModulePrefix = \'' . VidiModule::getParameterPrefix().'\';
+            MediaFormEngine.browserUrl = ' . GeneralUtility::quoteJSvalue(BackendUtility::getModuleUrl('wizard_element_browser')).';
         }');
         }
 

Classes/Command/FileCacheWarmUpCommand.php

Indentation +23 added lines, -23 removed lines

@@ -18,27 +18,27 @@
 
 class FileCacheWarmUpCommand extends Command
 {
-    protected SymfonyStyle $io;
-
-    protected function initialize(InputInterface $input, OutputInterface $output)
-    {
-        $this->io = new SymfonyStyle($input, $output);
-    }
-
-    /**
-     * Warm up the cache. Update some caching columns such as "number_of_references" to speed up the search.
-     */
-    protected function execute(InputInterface $input, OutputInterface $output): int
-    {
-        $numberOfEntries = $this->getCacheService()->warmUp();
-        $message = sprintf('Done! Processed %s entries', $numberOfEntries);
-        $this->io->info($message);
-
-        return 0;
-    }
-
-    protected function getCacheService(): CacheService
-    {
-        return GeneralUtility::makeInstance(CacheService::class);
-    }
+	protected SymfonyStyle $io;
+
+	protected function initialize(InputInterface $input, OutputInterface $output)
+	{
+		$this->io = new SymfonyStyle($input, $output);
+	}
+
+	/**
+	 * Warm up the cache. Update some caching columns such as "number_of_references" to speed up the search.
+	 */
+	protected function execute(InputInterface $input, OutputInterface $output): int
+	{
+		$numberOfEntries = $this->getCacheService()->warmUp();
+		$message = sprintf('Done! Processed %s entries', $numberOfEntries);
+		$this->io->info($message);
+
+		return 0;
+	}
+
+	protected function getCacheService(): CacheService
+	{
+		return GeneralUtility::makeInstance(CacheService::class);
+	}
 }

Classes/Command/ThumbnailCommand.php

Indentation +106 added lines, -106 removed lines

@@ -21,110 +21,110 @@
 
 class ThumbnailCommand extends Command
 {
-    protected SymfonyStyle $io;
-
-    protected function initialize(InputInterface $input, OutputInterface $output)
-    {
-        $this->io = new SymfonyStyle($input, $output);
-    }
-
-    protected function configure()
-    {
-        $this
-            ->addOption(
-                'limit',
-                '',
-                InputOption::VALUE_REQUIRED,
-                'where to stop in the batch processing.',
-                0
-            )
-            ->addOption(
-                'offset',
-                '',
-                InputOption::VALUE_REQUIRED,
-                'where to start in the batch processing.',
-                0
-            )
-            ->addOption(
-                'configuration',
-                '',
-                InputOption::VALUE_REQUIRED,
-                'override the default thumbnail configuration.',
-                []
-            );
-    }
-
-    /**
-     * Generate a bunch of thumbnails in advance to speed up the output of the Media BE module.
-     */
-    protected function execute(InputInterface $input, OutputInterface $output): int
-    {
-        $limit = $input->getOption('limit');
-        $offset = $input->getOption('offset');
-        $configuration = $input->getOption('configuration');
-        $verbose = $input->getOption('verbose');
-
-        foreach ($this->getStorageRepository()->findAll() as $storage) {
-            $this->io->info(sprintf('Processing files from storage %s (%s)', $storage->getName(), $storage->getUid()));
-
-            if ($storage->isOnline()) {
-                // For the CLI cause.
-                $storage->setEvaluatePermissions(false);
-
-                $thumbnailGenerator = $this->getThumbnailGenerator();
-                $thumbnailGenerator
-                    ->setStorage($storage)
-                    ->setConfiguration($configuration)
-                    ->generate($limit, $offset);
-
-                if ($verbose) {
-                    $resultSet = $thumbnailGenerator->getResultSet();
-                    foreach ($resultSet as $result) {
-                        $message = sprintf(
-                            '* File "%s": %s %s',
-                            $result['fileUid'],
-                            $result['fileIdentifier'],
-                            empty($result['thumbnailUri']) ? '' : ' -> ' . $result['thumbnailUri']
-                        );
-                        $this->io->info($message);
-                    }
-                }
-
-                $message = sprintf(
-                    'Done! New generated %s thumbnail(s) from %s traversed file(s) of a total of %s files.',
-                    $thumbnailGenerator->getNumberOfProcessedFiles(),
-                    $thumbnailGenerator->getNumberOfTraversedFiles(),
-                    $thumbnailGenerator->getTotalNumberOfFiles()
-                );
-                $this->io->info($message);
-
-                // Add warning message if missing files were found along the way.
-                if ($thumbnailGenerator->getNumberOfMissingFiles() > 0) {
-                    $message = sprintf(
-                        'ATTENTION! %s missing file(s) detected.',
-                        $thumbnailGenerator->getNumberOfMissingFiles()
-                    );
-                    $this->io->warning($message);
-                }
-            } else {
-                $this->io->info('Storage is offline!');
-            }
-        }
-        return 0;
-    }
-
-    protected function getDataService(): DataService
-    {
-        return GeneralUtility::makeInstance(DataService::class);
-    }
-
-    protected function getThumbnailGenerator(): ThumbnailGenerator
-    {
-        return GeneralUtility::makeInstance(ThumbnailGenerator::class);
-    }
-
-    protected function getStorageRepository(): StorageRepository
-    {
-        return GeneralUtility::makeInstance(StorageRepository::class);
-    }
+	protected SymfonyStyle $io;
+
+	protected function initialize(InputInterface $input, OutputInterface $output)
+	{
+		$this->io = new SymfonyStyle($input, $output);
+	}
+
+	protected function configure()
+	{
+		$this
+			->addOption(
+				'limit',
+				'',
+				InputOption::VALUE_REQUIRED,
+				'where to stop in the batch processing.',
+				0
+			)
+			->addOption(
+				'offset',
+				'',
+				InputOption::VALUE_REQUIRED,
+				'where to start in the batch processing.',
+				0
+			)
+			->addOption(
+				'configuration',
+				'',
+				InputOption::VALUE_REQUIRED,
+				'override the default thumbnail configuration.',
+				[]
+			);
+	}
+
+	/**
+	 * Generate a bunch of thumbnails in advance to speed up the output of the Media BE module.
+	 */
+	protected function execute(InputInterface $input, OutputInterface $output): int
+	{
+		$limit = $input->getOption('limit');
+		$offset = $input->getOption('offset');
+		$configuration = $input->getOption('configuration');
+		$verbose = $input->getOption('verbose');
+
+		foreach ($this->getStorageRepository()->findAll() as $storage) {
+			$this->io->info(sprintf('Processing files from storage %s (%s)', $storage->getName(), $storage->getUid()));
+
+			if ($storage->isOnline()) {
+				// For the CLI cause.
+				$storage->setEvaluatePermissions(false);
+
+				$thumbnailGenerator = $this->getThumbnailGenerator();
+				$thumbnailGenerator
+					->setStorage($storage)
+					->setConfiguration($configuration)
+					->generate($limit, $offset);
+
+				if ($verbose) {
+					$resultSet = $thumbnailGenerator->getResultSet();
+					foreach ($resultSet as $result) {
+						$message = sprintf(
+							'* File "%s": %s %s',
+							$result['fileUid'],
+							$result['fileIdentifier'],
+							empty($result['thumbnailUri']) ? '' : ' -> ' . $result['thumbnailUri']
+						);
+						$this->io->info($message);
+					}
+				}
+
+				$message = sprintf(
+					'Done! New generated %s thumbnail(s) from %s traversed file(s) of a total of %s files.',
+					$thumbnailGenerator->getNumberOfProcessedFiles(),
+					$thumbnailGenerator->getNumberOfTraversedFiles(),
+					$thumbnailGenerator->getTotalNumberOfFiles()
+				);
+				$this->io->info($message);
+
+				// Add warning message if missing files were found along the way.
+				if ($thumbnailGenerator->getNumberOfMissingFiles() > 0) {
+					$message = sprintf(
+						'ATTENTION! %s missing file(s) detected.',
+						$thumbnailGenerator->getNumberOfMissingFiles()
+					);
+					$this->io->warning($message);
+				}
+			} else {
+				$this->io->info('Storage is offline!');
+			}
+		}
+		return 0;
+	}
+
+	protected function getDataService(): DataService
+	{
+		return GeneralUtility::makeInstance(DataService::class);
+	}
+
+	protected function getThumbnailGenerator(): ThumbnailGenerator
+	{
+		return GeneralUtility::makeInstance(ThumbnailGenerator::class);
+	}
+
+	protected function getStorageRepository(): StorageRepository
+	{
+		return GeneralUtility::makeInstance(StorageRepository::class);
+	}
 }

Spacing +1 added lines, -1 removed lines

@@ -84,7 +84,7 @@
                             '* File "%s": %s %s',
                             $result['fileUid'],
                             $result['fileIdentifier'],
-                            empty($result['thumbnailUri']) ? '' : ' -> ' . $result['thumbnailUri']
+                            empty($result['thumbnailUri']) ? '' : ' -> '.$result['thumbnailUri']
                         );
                         $this->io->info($message);
                     }

Classes/Command/FileCacheFlushProcessedFilesCommand.php

Indentation +65 added lines, -65 removed lines

@@ -25,69 +25,69 @@
 
 class FileCacheFlushProcessedFilesCommand extends Command
 {
-    protected SymfonyStyle $io;
-
-    protected function initialize(InputInterface $input, OutputInterface $output)
-    {
-        $this->io = new SymfonyStyle($input, $output);
-    }
-
-    /**
-     * Flush all processed files to be used for debugging mainly.
-     */
-    protected function execute(InputInterface $input, OutputInterface $output): int
-    {
-        foreach ($this->getStorageRepository()->findAll() as $storage) {
-            // This only works for local driver
-            if ($storage->getDriverType() === 'Local' && $storage->isOnline()) {
-                $processedDirectoryPath = Environment::getPublicPath() . $this->getProcessingFolderPath($storage);
-                $this->io->info(sprintf('Removing files from %s for storage "%s" (%s)', $processedDirectoryPath, $storage->getName(), $storage->getUid()));
-
-                $this->clearProcessedFiles($storage->getUid());
-
-                GeneralUtility::rmdir($processedDirectoryPath, true);
-                GeneralUtility::mkdir($processedDirectoryPath); // recreate the directory.
-
-                $message = sprintf('Done! Removed all processed files from storage %s.', $storage->getUid());
-                $this->io->info($message);
-            }
-        }
-
-        return 0;
-    }
-
-    public function clearProcessedFiles(int $storageUid): int
-    {
-        $repository = GeneralUtility::makeInstance(ProcessedFileRepository::class);
-        return $repository->removeAll($storageUid);
-    }
-
-    protected function getProcessingFolderPath(ResourceStorage $storage): string
-    {
-        $storageConfiguration = $storage->getConfiguration();
-        $storageBasePath = rtrim($storageConfiguration['basePath'], '/');
-        return '/' . $storageBasePath . $storage->getProcessingFolder()->getIdentifier();
-    }
-
-    protected function getCacheService(): CacheService
-    {
-        return GeneralUtility::makeInstance(CacheService::class);
-    }
-
-    protected function getStorageRepository(): StorageRepository
-    {
-        return GeneralUtility::makeInstance(StorageRepository::class);
-    }
-
-    protected function getDataService(): DataService
-    {
-        return GeneralUtility::makeInstance(DataService::class);
-    }
-
-    protected function getConnection(string $tableName): Connection
-    {
-        /** @var ConnectionPool $connectionPool */
-        $connectionPool = GeneralUtility::makeInstance(ConnectionPool::class);
-        return $connectionPool->getConnectionForTable($tableName);
-    }
+	protected SymfonyStyle $io;
+
+	protected function initialize(InputInterface $input, OutputInterface $output)
+	{
+		$this->io = new SymfonyStyle($input, $output);
+	}
+
+	/**
+	 * Flush all processed files to be used for debugging mainly.
+	 */
+	protected function execute(InputInterface $input, OutputInterface $output): int
+	{
+		foreach ($this->getStorageRepository()->findAll() as $storage) {
+			// This only works for local driver
+			if ($storage->getDriverType() === 'Local' && $storage->isOnline()) {
+				$processedDirectoryPath = Environment::getPublicPath() . $this->getProcessingFolderPath($storage);
+				$this->io->info(sprintf('Removing files from %s for storage "%s" (%s)', $processedDirectoryPath, $storage->getName(), $storage->getUid()));
+
+				$this->clearProcessedFiles($storage->getUid());
+
+				GeneralUtility::rmdir($processedDirectoryPath, true);
+				GeneralUtility::mkdir($processedDirectoryPath); // recreate the directory.
+
+				$message = sprintf('Done! Removed all processed files from storage %s.', $storage->getUid());
+				$this->io->info($message);
+			}
+		}
+
+		return 0;
+	}
+
+	public function clearProcessedFiles(int $storageUid): int
+	{
+		$repository = GeneralUtility::makeInstance(ProcessedFileRepository::class);
+		return $repository->removeAll($storageUid);
+	}
+
+	protected function getProcessingFolderPath(ResourceStorage $storage): string
+	{
+		$storageConfiguration = $storage->getConfiguration();
+		$storageBasePath = rtrim($storageConfiguration['basePath'], '/');
+		return '/' . $storageBasePath . $storage->getProcessingFolder()->getIdentifier();
+	}
+
+	protected function getCacheService(): CacheService
+	{
+		return GeneralUtility::makeInstance(CacheService::class);
+	}
+
+	protected function getStorageRepository(): StorageRepository
+	{
+		return GeneralUtility::makeInstance(StorageRepository::class);
+	}
+
+	protected function getDataService(): DataService
+	{
+		return GeneralUtility::makeInstance(DataService::class);
+	}
+
+	protected function getConnection(string $tableName): Connection
+	{
+		/** @var ConnectionPool $connectionPool */
+		$connectionPool = GeneralUtility::makeInstance(ConnectionPool::class);
+		return $connectionPool->getConnectionForTable($tableName);
+	}
 }

Spacing +2 added lines, -2 removed lines

@@ -40,7 +40,7 @@ 
         foreach ($this->getStorageRepository()->findAll() as $storage) {
             // This only works for local driver
             if ($storage->getDriverType() === 'Local' && $storage->isOnline()) {
-                $processedDirectoryPath = Environment::getPublicPath() . $this->getProcessingFolderPath($storage);
+                $processedDirectoryPath = Environment::getPublicPath().$this->getProcessingFolderPath($storage);
                 $this->io->info(sprintf('Removing files from %s for storage "%s" (%s)', $processedDirectoryPath, $storage->getName(), $storage->getUid()));
 
                 $this->clearProcessedFiles($storage->getUid());
@@ -66,7 +66,7 @@ 
     {
         $storageConfiguration = $storage->getConfiguration();
         $storageBasePath = rtrim($storageConfiguration['basePath'], '/');
-        return '/' . $storageBasePath . $storage->getProcessingFolder()->getIdentifier();
+        return '/'.$storageBasePath.$storage->getProcessingFolder()->getIdentifier();
     }
 
     protected function getCacheService(): CacheService

Classes/Domain/Validator/StorageValidator.php

Indentation +29 added lines, -29 removed lines

@@ -19,36 +19,36 @@
  */
 class StorageValidator extends AbstractValidator
 {
-    /**
-     * Check if $storageIdentifier is allowed. If it is not valid, throw an exception.
-     *
-     * @param int $combinedIdentifier
-     * @return void
-     */
-    public function isValid($combinedIdentifier)
-    {
-        $allowedStorageIdentifiers = [];
-        foreach ($this->getMediaModule()->getAllowedStorages() as $allowedStorage) {
-            $allowedStorageIdentifiers[] = $allowedStorage->getUid();
-        }
+	/**
+	 * Check if $storageIdentifier is allowed. If it is not valid, throw an exception.
+	 *
+	 * @param int $combinedIdentifier
+	 * @return void
+	 */
+	public function isValid($combinedIdentifier)
+	{
+		$allowedStorageIdentifiers = [];
+		foreach ($this->getMediaModule()->getAllowedStorages() as $allowedStorage) {
+			$allowedStorageIdentifiers[] = $allowedStorage->getUid();
+		}
 
-        $storage = $this->getResourceFactory()->getStorageObjectFromCombinedIdentifier($combinedIdentifier);
-        if (!in_array($storage->getUid(), $allowedStorageIdentifiers)) {
-            $message = sprintf('Storage identifier "%s" is not allowed or is currently off-line.', $combinedIdentifier);
-            $this->addError($message, 1380813503);
-        }
-    }
+		$storage = $this->getResourceFactory()->getStorageObjectFromCombinedIdentifier($combinedIdentifier);
+		if (!in_array($storage->getUid(), $allowedStorageIdentifiers)) {
+			$message = sprintf('Storage identifier "%s" is not allowed or is currently off-line.', $combinedIdentifier);
+			$this->addError($message, 1380813503);
+		}
+	}
 
-    /**
-     * @return MediaModule|object
-     */
-    protected function getMediaModule()
-    {
-        return GeneralUtility::makeInstance(MediaModule::class);
-    }
+	/**
+	 * @return MediaModule|object
+	 */
+	protected function getMediaModule()
+	{
+		return GeneralUtility::makeInstance(MediaModule::class);
+	}
 
-    protected function getResourceFactory(): ResourceFactory
-    {
-        return GeneralUtility::makeInstance(ResourceFactory::class);
-    }
+	protected function getResourceFactory(): ResourceFactory
+	{
+		return GeneralUtility::makeInstance(ResourceFactory::class);
+	}
 }