Storeman\StorageAdapter\FlysystemStorageAdapter

Complexity

Total Complexity

12

Size/Duplication

Total Lines	85
Duplicated Lines	65.88 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
A	writeStream()	18	18	3
A	exists()	0	11	2
A	unlink()	18	18	3
A	getReadStream()	20	20	3

<?php

namespace Storeman\StorageAdapter;

use Storeman\Exception;
use League\Flysystem\Filesystem;

abstract class FlysystemStorageAdapter extends AbstractStorageAdapter
{
    /**
     * @var Filesystem
     */
    protected $filesystem;

    public function __construct(Filesystem $filesystem)
    {
        parent::__construct();

        $this->filesystem = $filesystem;
    }

    public function writeStream(string $relativePath, $stream)

This method seems to be duplicated in your project.

    {
        $this->logger->debug("Writing stream to {$relativePath}...");

        try
        {
            $success = $this->filesystem->putStream($relativePath, $stream);

            if (!$success)
            {
                throw new Exception(sprintf('writeStream() failed for %s.', $relativePath));
            }
        }
        catch (\Exception $exception)
        {
            throw new Exception($exception->getMessage(), 0, $exception);
        }
    }

    public function exists(string $relativePath): bool
    {
        try
        {
            return $this->filesystem->has($relativePath);
        }
        catch (\Exception $exception)
        {
            throw new Exception($exception->getMessage(), 0, $exception);
        }
    }

    public function unlink(string $relativePath)

This method seems to be duplicated in your project.

    {
        $this->logger->debug("Deleting {$relativePath}...");

        try
        {
            $success = $this->filesystem->delete($relativePath);

            if (!$success)
            {
                throw new Exception(sprintf('unlink() failed for %s', $relativePath));
            }
        }
        catch (\Exception $exception)
        {
            throw new Exception($exception->getMessage(), 0, $exception);
        }
    }

    public function getReadStream(string $relativePath)

This method seems to be duplicated in your project.

    {
        $this->logger->debug("Getting read stream for {$relativePath}...");

        try
        {
            $stream = $this->filesystem->readStream($relativePath);

            if (!is_resource($stream))
            {
                throw new Exception(sprintf('getReadStream() failed for %s.', $relativePath));
            }

            return $stream;
        }
        catch (\Exception $exception)
        {
            throw new Exception($exception->getMessage(), 0, $exception);
        }
    }
}