| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175 | <?phpdeclare(strict_types=1);namespace GuzzleHttp\Psr7;use Psr\Http\Message\StreamInterface;/** * Converts Guzzle streams into PHP stream resources. * * @see https://www.php.net/streamwrapper */final class StreamWrapper{    /** @var resource */    public $context;    /** @var StreamInterface */    private $stream;    /** @var string r, r+, or w */    private $mode;    /**     * Returns a resource representing the stream.     *     * @param StreamInterface $stream The stream to get a resource for     *     * @return resource     *     * @throws \InvalidArgumentException if stream is not readable or writable     */    public static function getResource(StreamInterface $stream)    {        self::register();        if ($stream->isReadable()) {            $mode = $stream->isWritable() ? 'r+' : 'r';        } elseif ($stream->isWritable()) {            $mode = 'w';        } else {            throw new \InvalidArgumentException('The stream must be readable, '                . 'writable, or both.');        }        return fopen('guzzle://stream', $mode, false, self::createStreamContext($stream));    }    /**     * Creates a stream context that can be used to open a stream as a php stream resource.     *     * @return resource     */    public static function createStreamContext(StreamInterface $stream)    {        return stream_context_create([            'guzzle' => ['stream' => $stream]        ]);    }    /**     * Registers the stream wrapper if needed     */    public static function register(): void    {        if (!in_array('guzzle', stream_get_wrappers())) {            stream_wrapper_register('guzzle', __CLASS__);        }    }    public function stream_open(string $path, string $mode, int $options, string &$opened_path = null): bool    {        $options = stream_context_get_options($this->context);        if (!isset($options['guzzle']['stream'])) {            return false;        }        $this->mode = $mode;        $this->stream = $options['guzzle']['stream'];        return true;    }    public function stream_read(int $count): string    {        return $this->stream->read($count);    }    public function stream_write(string $data): int    {        return $this->stream->write($data);    }    public function stream_tell(): int    {        return $this->stream->tell();    }    public function stream_eof(): bool    {        return $this->stream->eof();    }    public function stream_seek(int $offset, int $whence): bool    {        $this->stream->seek($offset, $whence);        return true;    }    /**     * @return resource|false     */    public function stream_cast(int $cast_as)    {        $stream = clone($this->stream);        $resource = $stream->detach();        return $resource ?? false;    }    /**     * @return array<int|string, int>     */    public function stream_stat(): array    {        static $modeMap = [            'r'  => 33060,            'rb' => 33060,            'r+' => 33206,            'w'  => 33188,            'wb' => 33188        ];        return [            'dev'     => 0,            'ino'     => 0,            'mode'    => $modeMap[$this->mode],            'nlink'   => 0,            'uid'     => 0,            'gid'     => 0,            'rdev'    => 0,            'size'    => $this->stream->getSize() ?: 0,            'atime'   => 0,            'mtime'   => 0,            'ctime'   => 0,            'blksize' => 0,            'blocks'  => 0        ];    }    /**     * @return array<int|string, int>     */    public function url_stat(string $path, int $flags): array    {        return [            'dev'     => 0,            'ino'     => 0,            'mode'    => 0,            'nlink'   => 0,            'uid'     => 0,            'gid'     => 0,            'rdev'    => 0,            'size'    => 0,            'atime'   => 0,            'mtime'   => 0,            'ctime'   => 0,            'blksize' => 0,            'blocks'  => 0        ];    }}
 |