MergeHandler::merge() - Code Metrics - jobtech-dev/laravel-chunky - Measure and Improve Code Quality continuously with Scrutinizer

MergeHandler::merge() A
last analyzed 2020-12-10 18:41 UTC

↳ Parent: MergeHandler
Complexity

Conditions	3
Paths	3
Size

Total Lines	20
Code Lines	8
Duplication

Lines	0
Ratio	0 %
Importance

Changes	2
Bugs	1	Features	0
Metric	Value
cc	3
eloc	8
c	2
b	1
f	0
nc	3
nop	2
dl	0
loc	20
rs	10
<?php

namespace Jobtech\LaravelChunky\Handlers;

use Illuminate\Container\Container;
filter:
    dependency_paths: ["lib/*"]
use Illuminate\Support\Collection;
use Illuminate\Support\Traits\ForwardsCalls;
use Jobtech\LaravelChunky\Chunk;
use Jobtech\LaravelChunky\Contracts\ChunkyManager;
use Jobtech\LaravelChunky\Contracts\MergeHandler as MergeHandlerContract;
use Jobtech\LaravelChunky\Events\ChunksMerged;
use Jobtech\LaravelChunky\Exceptions\ChunksIntegrityException;
use Jobtech\LaravelChunky\Exceptions\ChunkyException;
use Jobtech\LaravelChunky\Http\Requests\AddChunkRequest;
use Jobtech\LaravelChunky\Jobs\MergeChunks;
use Jobtech\LaravelChunky\Support\TempFilesystem;
use Keven\AppendStream\AppendStream;

/**
 * @method \Jobtech\LaravelChunky\ChunkySettings settings()
 * @method \Jobtech\LaravelChunky\Support\ChunksFilesystem chunksFilesystem()
 * @method \Jobtech\LaravelChunky\Support\MergeFilesystem mergeFilesystem()
 * @method array mergeOptions()
 * @method \Illuminate\Support\Collection listChunks(?string $folder = null)
 * @method resource|null readChunk($chunk)
 * @method bool deleteChunks(string $folder)
 * @method bool isValidChunksFolder(string $folder)
 * @method bool checkChunksIntegrity(string $folder, int $chunk_size, int $total_size)
 */
class MergeHandler implements MergeHandlerContract
{
    use ForwardsCalls;

    private ?ChunkyManager $manager;

    private TempFilesystem $temp_filesystem;

    public function __construct(?ChunkyManager $manager = null)
    {
        $this->manager = $manager;
        $this->temp_filesystem = Container::getInstance()->make(TempFilesystem::class);
    }

    /**
     * @param string $folder
     * @param string $target
     *
     * @throws \Illuminate\Contracts\Filesystem\FileExistsException|\Illuminate\Contracts\Filesystem\FileNotFoundException
     *
     * @return string
     */
    private function concatenate(string $folder, string $target): string
    {
        if (! $this->chunksFilesystem()->isLocal()) {
            return $this->temporaryConcatenate($target, $this->listChunks($folder));
        }

        $chunks = $this->listChunks($folder)->map(function (Chunk $item) {
            return $item->getPath();
        });
        $merge = $chunks->first();

        if (! $this->chunksFilesystem()->concatenate($merge, $chunks->toArray())) {
            throw new ChunkyException('Unable to concatenate chunks');
        }

        return $this->mergeFilesystem()
            ->store(
                $target,
                $this->readChunk($merge),
                $this->mergeOptions()
            );
    }

    /**
     * @param string $target
     * @param Collection $chunks
     * @return string
     * @throws \Illuminate\Contracts\Filesystem\FileExistsException
     * @throws \Illuminate\Contracts\Filesystem\FileNotFoundException
     */
    private function temporaryConcatenate(string $target, Collection $chunks)
    {
        $stream = new AppendStream;
        $chunks->each(function (Chunk $chunk) use ($stream) {
            $path = $this->temp_filesystem->store('tmp-'.$chunk->getFilename(), $this->chunksFilesystem()->readChunk($chunk->getPath()));
            $stream->append($this->temp_filesystem->readFile($path));
        });

        $tmp_merge = $this->temp_filesystem->store($target, $stream->getResource());
        $path = $this->mergeFilesystem()->store($target, $this->temp_filesystem->readFile($tmp_merge), $this->mergeOptions());

        $this->temp_filesystem->clean();

        return $path;
    }

    /**
     * {@inheritdoc}
     *
     * @codeCoverageIgnore
     */
    public function setManager(ChunkyManager $manager): MergeHandler
    {
        $this->manager = $manager;

        return $this;
    }

    /**
     * {@inheritdoc}
     *
     * @codeCoverageIgnore
     */
    public function manager(): ChunkyManager
    {
        if ($this->manager === null) {
            $this->manager = Container::getInstance()->make('chunky');
        }

        return $this->manager;

    }

    /**
     * {@inheritdoc}
     */
    public function dispatchMerge(AddChunkRequest $request, string $folder)
    {
        $merge_path = $request->fileInput()->getClientOriginalName();
        $chunk_size = $request->chunkSizeInput();
        $total_size = $request->totalSizeInput();

        if (empty($connection = $this->settings()->connection())) {
            if (! $this->checkChunksIntegrity($folder, $chunk_size, $total_size)) {
                throw new ChunksIntegrityException('Chunks total file size doesnt match with original file size');
            }

            return $this->merge($folder, $merge_path);
        }

        return MergeChunks::dispatch(
            $folder,
            $merge_path,
            $chunk_size,
            $total_size
        )->onConnection($connection)
            ->onQueue($this->settings()->queue());
    }

    /**
     * {@inheritdoc}
     */
    public function merge(string $chunks_folder, string $merge_path): string
    {
        // Check chunks folder
        if (! $this->isValidChunksFolder($chunks_folder)) {
            throw new ChunkyException("Invalid chunks folder {$chunks_folder}");
        }

        /** @var resource $origin */
        $path = $this->concatenate($chunks_folder, $merge_path);

        // Final check and cleanup
        if (! $path) {
            throw new ChunkyException('An error occurred while moving merge to destination');
        }

        $this->deleteChunks($chunks_folder);

        event(new ChunksMerged($path));
        event(new ChunksMerged($path));

        return $path;
    }

    /**
     * {@inheritdoc}
     */
    public static function instance(?ChunkyManager $manager = null): MergeHandlerContract
    {
        return new static($manager);
    }

    public function __call($method, $parameters)
    {
        if (! method_exists($this, $method)) {
            return $this->forwardCallTo($this->manager(), $method, $parameters);
        }

        return $this->{$method}(...$parameters);
    }
}

jobtech-dev / laravel-chunky

MergeHandler::merge() A last analyzed 2020-12-10 18:41 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

MergeHandler::merge() A
last analyzed 2020-12-10 18:41 UTC
