drupol\phpvfs\PhpVfs

Complexity

Total Complexity

26

Size/Duplication

Total Lines	231
Duplicated Lines	0 %

Test Coverage

Coverage

82.14%

Importance

Changes	4
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	register()	0	10	1
A	fs()	0	7	1
A	stream_close()	0	7	2
A	stream_eof()	0	3	1
A	rename()	0	38	5
A	stream_read()	0	7	2
B	stream_open()	0	41	7
A	stream_write()	0	7	2
A	stripScheme()	0	3	1
A	unlink()	0	9	3
A	unregister()	0	3	1

<?php

declare(strict_types = 1);

namespace drupol\phpvfs;

use drupol\phpvfs\Commands\Cd;
use drupol\phpvfs\Commands\Exist;
use drupol\phpvfs\Commands\Get;
use drupol\phpvfs\Filesystem\Filesystem;
use drupol\phpvfs\Filesystem\FilesystemInterface;
use drupol\phpvfs\Node\File;
use drupol\phpvfs\Node\FileInterface;
use drupol\phpvfs\Utils\Path;

class PhpVfs
{
    public const SCHEME = 'phpvfs';

    /**
     * @var array
     */
    public $context;

    /**
     * @var null|\drupol\phpvfs\Node\FileInterface
     */
    private $currentFile;

    /**
     * @return \drupol\phpvfs\Filesystem\FilesystemInterface
     */
    public static function fs(): FilesystemInterface
    {
        $options = \stream_context_get_options(
            \stream_context_get_default()
        );

        return $options[static::SCHEME]['filesystem'];
    }

    /**
     * @param \drupol\phpvfs\Filesystem\Filesystem $filesystem
     * @param array $options
     */
    public static function register(Filesystem $filesystem, array $options = [])
    {
        $options = [
            static::SCHEME => [
                'filesystem' => $filesystem,
            ] + $options,
        ];

        \stream_context_set_default($options);
        \stream_wrapper_register(self::SCHEME, __CLASS__);
    }

    /**
     * @param string $from
     * @param string $to
     *
     * @throws \Exception
     *
     * @return bool
     */
    public function rename(string $from, string $to): bool
    {
        $from = $this->stripScheme($from);
        $to = $this->stripScheme($to);

        if (!Exist::exec($this::fs(), $from)) {
            throw new \Exception('Source resource does not exist.');
        }

        $from = Get::exec($this::fs(), $from);

        if (Exist::exec($this::fs(), $to)) {
            throw new \Exception('Destination already exist.');
        }

        $toPath = Path::fromString($to);

        $this::fs()
            ->getCwd()
            ->mkdir($toPath->dirname());

        if (null !== $parent = $from->getParent()) {
            $parent->delete($from);
        }

        Cd::exec($this::fs(), $toPath->dirname());

        $from->setAttribute('id', $toPath->basename());

        if ($from instanceof FileInterface) {
            $from->setPosition(0);
        }

        $this::fs()
            ->getCwd()
            ->add($from);

        return true;
    }

    /**
     * @see http://php.net/streamwrapper.stream-close
     */
    public function stream_close() // phpcs:ignore
    {
        if (null !== $this->currentFile) {
            $this->currentFile->setPosition(0);
        }

        $this->currentFile = null;
    }

    /**
     * @return bool
     *
     * @see http://php.net/streamwrapper.stream-eof
     */
    public function stream_eof(): bool // phpcs:ignore
    {
        return true;
    }

    /**
     * @param string $resource
     * @param mixed $mode
     * @param mixed $options
     * @param mixed $openedPath
     *
     * @throws \Exception
     *
     * @return bool
     */
    public function stream_open(string $resource, $mode, $options, &$openedPath) // phpcs:ignore

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

    {
        $mode = \str_split(\str_replace('b', '', $mode));

        $appendMode = \in_array('a', $mode, true);

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

        $readMode = \in_array('r', $mode, true);
        $writeMode = \in_array('w', $mode, true);

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

        $extended = \in_array('+', $mode, true);

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

        $resource = $this->stripScheme($resource);

        $resourcePath = Path::fromString($resource);

        if (!Exist::exec($this::fs(), $resource)) {
            if ($readMode || !Exist::exec($this::fs(), $resourcePath->dirname())) {
                if ($options & STREAM_REPORT_ERRORS) {
                    \trigger_error(\sprintf('%s: failed to open stream.', $resourcePath), E_USER_WARNING);
                }

                return false;
            }

            $this->currentFile = File::create($resource);
            $this::fs()
                ->getCwd()
                ->add($this->currentFile->root());
        }

        if (null === $file = $this::fs()->get($resource)) {
            return false;
        }

        if (!($file instanceof FileInterface)) {
            return false;
        }

        $this->currentFile = $file;

        $this->currentFile->setPosition(0);

        return true;
    }

    /**
     * @see http://php.net/streamwrapper.stream-read
     *
     * @param int $bytes
     *
     * @return mixed
     */
    public function stream_read(int $bytes) // phpcs:ignore
    {
        if (null !== $this->currentFile) {
            return $this->currentFile->read($bytes);
        }

        return false;
    }

    /**
     * @param string $data
     *
     * @return int
     */
    public function stream_write(string $data) // phpcs:ignore
    {
        if (null !== $this->currentFile) {
            return $this->currentFile->write($data);
        }

        return 0;
    }

    /**
     * @param string $path
     *
     * @throws \Exception
     */
    public function unlink(string $path)
    {
        $path = $this->stripScheme($path);

        if (true === Exist::exec($this::fs(), $path)) {
            $file = Get::exec($this::fs(), $path);

            if (null !== $parent = $file->getParent()) {
                $parent->delete($file);
            }
        }
    }

    /**
     * @todo
     */
    public static function unregister()
    {
        \stream_wrapper_unregister(self::SCHEME);
    }

    /**
     * Returns path stripped of url scheme (http://, ftp://, test:// etc.).
     *
     * @param string $path
     *
     * @return string
     */
    protected function stripScheme(string $path): string
    {
        return '/' . \ltrim(\substr($path, 9), '/');
    }
}