Mpyw\StreamInterfaceResource\StreamInterfaceResource::createStreamWrapper()

Size

Total Lines	16
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	StreamInterfaceResource.php$0 ➔ stream()	0	3	1

<?php

namespace Mpyw\StreamInterfaceResource;

use ErrorException;
use function GuzzleHttp\Psr7\stream_for;
use Iterator;
use Psr\Http\Message\StreamInterface;

class StreamInterfaceResource
{
    /**
     * @param  null|bool|callable|float|int|Iterator|resource|StreamInterface|string $resource
     * @param  array                                                                 $options
     * @return resource
     */
    public static function open($resource = '', array $options = [])
    {
        $stream = stream_for($resource, $options);

        $wrapper = static::createStreamWrapper($stream);
        $class = get_class($wrapper);
        $protocol = sha1($class);

        set_error_handler(static function (int $code, string $message, string $file, int $line) use (&$error): bool {
            // @codeCoverageIgnoreStart
            $error = new ErrorException($message, $code, 1, $file, $line);
            return true;
            // @codeCoverageIgnoreEnd
        });
        stream_wrapper_register($protocol, $class);
        restore_error_handler();

        if ($error) {
            // @codeCoverageIgnoreStart
            throw $error;
            // @codeCoverageIgnoreEnd
        }

        set_error_handler(static function (int $code, string $message, string $file, int $line) use (&$error): bool {
            // @codeCoverageIgnoreStart
            $error = new ErrorException($message, $code, 1, $file, $line);
            return true;
            // @codeCoverageIgnoreEnd
        });
        $fp = fopen("$protocol://", 'r+b');
        stream_wrapper_unregister($protocol);
        restore_error_handler();

        if ($error) {
            // @codeCoverageIgnoreStart
            throw $error;
            // @codeCoverageIgnoreEnd
        }

        return $fp;

The expression return $fp could also return false which is incompatible with the documented return type resource. Did you maybe forget to handle an error condition?

    }

    protected static function createStreamWrapper(StreamInterface $stream)
    {
        $wrapper = new class() {
            use StreamWrapperTrait;

            public static $stream;

            protected function stream(): StreamInterface
            {
                return self::$stream;
            }
        };

        $wrapper::$stream = $stream;

        return $wrapper;
    }
}