Storeman\StorageAdapter\FlysystemStorageAdapter

Complexity

Total Complexity

13

Size/Duplication

Total Lines	97
Duplicated Lines	57.73 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	setLogger()	0	4	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 Psr\Log\LoggerAwareInterface;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use Storeman\Exception;
use League\Flysystem\Filesystem;

abstract class FlysystemStorageAdapter implements LoggerAwareInterface, StorageAdapterInterface
{
    /**
     * @var Filesystem
     */
    protected $filesystem;

    /**
     * @var LoggerInterface
     */
    protected $logger;

    public function __construct(Filesystem $filesystem)
    {
        $this->filesystem = $filesystem;
        $this->logger = new NullLogger();
    }

    /**
     * {@inheritdoc}
     */
    public function setLogger(LoggerInterface $logger): void
    {
        $this->logger = $logger;
    }

    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);
        }
    }
}