Thinktomorrow\Chief\Media\UploadMedia

Complexity

Total Complexity

48

Size/Duplication

Total Lines	217
Duplicated Lines	0 %

Test Coverage

Coverage

91.35%

Importance

Changes	13
Bugs	7	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	validateFileUploads()	0	10	6
A	sluggifyFilename()	0	7	1
A	replaceFiles()	0	13	4
A	addFiles()	0	12	4
A	addFile()	0	26	6
A	sanitizeFilesParameter()	0	19	5
A	actionExists()	0	3	3
A	sanitizeFilesOrderParameter()	0	11	3
A	fromUploadComponent()	0	26	5
B	validateParameters()	0	16	7
A	removeFiles()	0	11	4

<?php

namespace Thinktomorrow\Chief\Media;

use Exception;
use Illuminate\Support\Str;
use Illuminate\Http\UploadedFile;
use Thinktomorrow\AssetLibrary\Asset;
use Thinktomorrow\AssetLibrary\HasAsset;
use Thinktomorrow\AssetLibrary\Application\AddAsset;
use Thinktomorrow\AssetLibrary\Application\SortAssets;
use Thinktomorrow\Chief\Media\DuplicateAssetException;
use Thinktomorrow\AssetLibrary\Application\DetachAsset;
use Thinktomorrow\AssetLibrary\Application\ReplaceAsset;
use Thinktomorrow\AssetLibrary\Application\AssetUploader;

class UploadMedia
{
    /**
     * Upload from base64encoded files, usually
     * coming from slim upload component
     *
     * @param HasAsset $model
     * @param array $files_by_type
     * @param array $files_order_by_type
     * @throws \Spatie\MediaLibrary\Exceptions\FileCannotBeAdded
     */
    public function fromUploadComponent(HasAsset $model, array $files_by_type, array $files_order_by_type)
    {
        ini_set('memory_limit', '256M');
        $files_by_type = $this->sanitizeFilesParameter($files_by_type);
        $files_order_by_type = $this->sanitizeFilesOrderParameter($files_order_by_type);
        $this->validateParameters($files_by_type, $files_order_by_type);

        // When no files are uploaded, we still would like to sort our assets duh
        if (empty($files_by_type)) {
            foreach ($files_order_by_type as $type => $files) {
                app(SortAssets::class)->handle($model, $type, $files);
            }

            return;
        }
        foreach ($files_by_type as $type => $files_by_locale) {
            foreach ($files_by_locale as $locale => $files) {
                $this->validateFileUploads($files);

                $fileIdsCollection = $files_order_by_type[$type] ?? [];

                $this->addFiles($model, $type, $files, $fileIdsCollection, $locale);
                $this->replaceFiles($model, $files);
                $this->removeFiles($model, $files, $type, $locale);
            }
            app(SortAssets::class)->handle($model, $type, $fileIdsCollection ?? []);
        }
    }

    private function addFiles(HasAsset $model, string $type, array $files, array &$files_order, string $locale = null)
    {
        if (!$this->actionExists($files, 'new')) {
            return;
        }

        foreach ($files['new'] as $id => $file) {
            if (!$file) {
                continue;
            }

            $this->addFile($model, $type, $file, $files_order, $locale);
        }
    }

    /**
     * @param HasAsset $model
     * @param array $files
     * @throws \Spatie\MediaLibrary\Exceptions\FileCannotBeAdded
     */
    private function replaceFiles(HasAsset $model, array $files)
    {
        if (!$this->actionExists($files, 'replace')) {
            return;
        }

        foreach ($files['replace'] as $id => $file) {
            if (!$file) {
                continue;
            }

            $asset = AssetUploader::uploadFromBase64(json_decode($file)->output->image, json_decode($file)->output->name);
            app(ReplaceAsset::class)->handle($model, $id, $asset->id);
        }
    }

    /**
     * @param HasAsset $model
     * @param array $files
     */
    private function removeFiles(HasAsset $model, array $files, string $type, string $locale)
    {
        if (!$this->actionExists($files, 'delete')) {
            return;
        }

        foreach ($files['delete'] as $id => $file) {
            if (!$file) {
                continue;
            }
            app(DetachAsset::class)->detach($model, $file, $type, $locale);
        }
    }

    private function actionExists(array $files, string $action)
    {
        return (isset($files[$action]) && is_array($files[$action]) && !empty($files[$action]));
    }

    private function addFile(HasAsset $model, string $type, $file, array &$files_order, $locale = null)
    {
        if (isset(json_decode($file)->output)) {
            $image_name = json_decode($file)->output->name;
            $asset      = app(AddAsset::class)->add($model, json_decode($file)->output->image, $type, $locale, $this->sluggifyFilename($image_name));

The assignment to $asset is dead and can be removed.

        } else {
            if ($file instanceof UploadedFile) {
                $image_name = $file->getClientOriginalName();
                $asset      = app(AddAsset::class)->add($model, $file, $type, $locale, $this->sluggifyFilename($image_name));

                // New files are passed with their filename (instead of their id)
                // For new files we will replace the filename with the id.
                if (false !== ($key = array_search($image_name, $files_order))) {
                    $files_order[$key] = (string) $asset->id;
                }
            } else {
                $file   = Asset::find($file);
                if (!$file) {
                    return;
                }

                if ($model->assetRelation()->where('asset_pivots.type', $type)->where('asset_pivots.locale', $locale)->get()->contains($file)) {
                    throw new DuplicateAssetException();
                }

                $asset  = app(AddAsset::class)->add($model, $file, $type, $locale);
            }
        }
    }

    /**
     * @param $filename
     * @return string
     */
    private function sluggifyFilename($filename): string
    {
        $extension = substr($filename, strrpos($filename, '.') + 1);
        $filename  = substr($filename, 0, strrpos($filename, '.'));
        $filename  = Str::slug($filename) . '.' . $extension;

        return $filename;
    }

    /**
     * @param $files
     * @throws FileTooBigException
     */
    private function validateFileUploads($files): void
    {
        foreach ($files as $_files) {
            foreach ($_files as $file) {
                if ($file instanceof UploadedFile && !$file->isValid()) {
                    if ($file->getError() == UPLOAD_ERR_INI_SIZE) {
                        throw new FileTooBigException(

The type Thinktomorrow\Chief\Media\FileTooBigException was not found. Maybe you did not declare it correctly or list all dependencies?

                            'Cannot upload file because it exceeded the allowed upload_max_filesize: upload_max_filesize is smaller than post size. ' .
                            'upload_max_filesize: ' . (int)ini_get('upload_max_filesize') . 'MB, ' .
                            'post_max_size: ' . (int)(ini_get('post_max_size')) . 'MB'
                        );
                    }
                }
            }
        }
    }

    private function validateParameters(array $files_by_type, array $files_order_by_type)

The parameter $files_order_by_type is not used and could be removed.

    {
        $actions = ['new', 'replace', 'delete'];
        foreach ($files_by_type as $type => $files) {
            foreach ($files as $locale => $_files) {
                if (!in_array($locale, config('translatable.locales'))) {
                    throw new \InvalidArgumentException('Corrupt file payload. key is expected to be a valid locale [' . implode(',', config('translatable.locales', [])). ']. Instead [' . $locale . '] is given.');
                }

                if (!is_array($_files)) {
                    throw new \InvalidArgumentException('A valid files entry should be an array of files, key with either [new, replace or delete]. Instead a ' . gettype($_files) . ' is given.');
                }

                foreach ($_files as $action => $file) {
                    if (!in_array($action, $actions)) {
                        throw new \InvalidArgumentException('A valid files entry should have a key of either ['.implode(',', $actions).']. Instead ' . $action . ' is given.');
                    }
                }
            }
        }
    }

    private function sanitizeFilesParameter(array $files_by_type): array
    {
        $defaultLocale = config('app.fallback_locale');

        foreach ($files_by_type as $type => $files) {
            foreach ($files as $locale => $_files) {
                if (!in_array($locale, config('translatable.locales'))) {
                    unset($files_by_type[$type][$locale]);

                    if (!isset($files_by_type[$type][$defaultLocale])) {
                        $files_by_type[$type][$defaultLocale] = [];
                    }

                    $files_by_type[$type][$defaultLocale][$locale] = $_files;
                }
            }
        }

        return $files_by_type;
    }

    private function sanitizeFilesOrderParameter(array $files_order_by_locale): array
    {
        foreach ($files_order_by_locale as $locale => $fileIdsCollection) {
            foreach ($fileIdsCollection as $type => $commaSeparatedFileIds) {
                $type = str_replace("files-", "", $type);
                $files_order_by_type[$type][] = explode(',', $commaSeparatedFileIds);
                $files_order_by_type[$type] = collect($files_order_by_type)->flatten()->unique()->toArray();
            }
        }

        return $files_order_by_type ?? $files_order_by_locale;
    }
}