Serafim\Stream\Wrapper\ReadStreamWrapper

Complexity

Total Complexity

13

Size/Duplication

Total Lines	122
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

93.94%

Importance

Changes

0

<?php
{
    /**
     * @var int
     */
    protected const STAT_MTIME_NUMERIC_OFFSET = 9;

    /**
     * @var string
     */
    protected const STAT_MTIME_ASSOC_OFFSET = 'mtime';

    /**
     * @var string
     */
    protected string $protocol;

This code did not parse for me. Apparently, there is an error somewhere around this line:

Syntax error, unexpected T_STRING, expecting T_FUNCTION or T_CONST

    /**
     * @var string
     */
    protected string $pathname;

    /**
     * @var StreamInterface
     */
    protected StreamInterface $stream;

    /**
     * {@inheritDoc}
     */
    public function stream_open(string $uri, string $mode, int $options, &$openedPath): bool
    {
        [$this->protocol, $this->pathname] = $this->parseUri($uri);

        $this->stream = Stream::get($this->protocol);

        if (\STREAM_USE_PATH & $options && ! \is_file($this->pathname)) {
            $trace = \debug_backtrace(\DEBUG_BACKTRACE_IGNORE_ARGS);

            $this->pathname = \dirname($trace[1]['file']) . '/' . $this->pathname;
        }

        $this->resource = \fopen('php://memory', 'rb+');

        \fwrite($this->resource, $this->stream->read($this->pathname));
        \rewind($this->resource);

        return true;
    }

    /**
     * @param string $uri
     * @return array<string>
     * @throws StreamException
     */
    private function parseUri(string $uri): array
    {
        $chunks = \explode('://', $uri);

        if (\count($chunks) !== 2) {
            $error = \sprintf('Bad protocol format "%s"', $uri);
            throw new StreamException($error, StreamException::CODE_STREAM_OPEN);
        }

        return $chunks;
    }

    /**
     * {@inheritDoc}
     */
    public function stream_read(int $length): string
    {
        return ! \feof($this->resource) ? \fread($this->resource, $length) : '';
    }

    /**
     * {@inheritDoc}
     */
    public function stream_eof(): bool
    {
        return \feof($this->resource);
    }

    /**
     * {@inheritDoc}
     */
    public function stream_stat(): array
    {
        $stat = \fstat($this->resource);

        if ($stat) {
            ++$stat[static::STAT_MTIME_ASSOC_OFFSET];
            ++$stat[static::STAT_MTIME_NUMERIC_OFFSET];
        }

        return $stat;
    }

    /**
     * {@inheritDoc}
     */
    public function stream_close(): void
    {
        \fclose($this->resource);
    }

    /**
     * {@inheritDoc}
     */
    public function stream_tell(): int
    {
        return (int)\ftell($this->resource);
    }

    /**
     * {@inheritDoc}
     */
    public function stream_seek(int $offset, int $whence = \SEEK_SET): bool
    {
        return \fseek($this->resource, $offset, $whence) >= 0;
    }
}