PATH:
home
/
lab2454c
/
.trash
/
core
/
vendor
/
laminas
/
laminas-diactoros
/
src
<?php declare(strict_types=1); namespace Laminas\Diactoros; use Psr\Http\Message\StreamInterface; use RuntimeException; use function array_key_exists; use function fclose; use function feof; use function fopen; use function fread; use function fseek; use function fstat; use function ftell; use function fwrite; use function get_resource_type; use function is_int; use function is_resource; use function is_string; use function restore_error_handler; use function set_error_handler; use function stream_get_contents; use function stream_get_meta_data; use function strstr; use const E_WARNING; use const SEEK_SET; /** * Implementation of PSR HTTP streams */ class Stream implements StreamInterface { /** * A list of allowed stream resource types that are allowed to instantiate a Stream */ private const ALLOWED_STREAM_RESOURCE_TYPES = ['gd', 'stream']; /** * @var resource|null */ protected $resource; /** * @var string|resource */ protected $stream; /** * @param string|resource $stream * @param string $mode Mode with which to open stream * @throws Exception\InvalidArgumentException */ public function __construct($stream, string $mode = 'r') { $this->setStream($stream, $mode); } /** * {@inheritdoc} */ public function __toString() : string { if (! $this->isReadable()) { return ''; } try { if ($this->isSeekable()) { $this->rewind(); } return $this->getContents(); } catch (RuntimeException $e) { return ''; } } /** * {@inheritdoc} */ public function close() : void { if (! $this->resource) { return; } $resource = $this->detach(); fclose($resource); } /** * {@inheritdoc} */ public function detach() { $resource = $this->resource; $this->resource = null; return $resource; } /** * Attach a new stream/resource to the instance. * * @param string|resource $resource * @param string $mode * @throws Exception\InvalidArgumentException for stream identifier that cannot be * cast to a resource * @throws Exception\InvalidArgumentException for non-resource stream */ public function attach($resource, string $mode = 'r') : void { $this->setStream($resource, $mode); } /** * {@inheritdoc} */ public function getSize() : ?int { if (null === $this->resource) { return null; } $stats = fstat($this->resource); if ($stats !== false) { return $stats['size']; } return null; } /** * {@inheritdoc} */ public function tell() : int { if (! $this->resource) { throw Exception\UntellableStreamException::dueToMissingResource(); } $result = ftell($this->resource); if (! is_int($result)) { throw Exception\UntellableStreamException::dueToPhpError(); } return $result; } /** * {@inheritdoc} */ public function eof() : bool { if (! $this->resource) { return true; } return feof($this->resource); } /** * {@inheritdoc} */ public function isSeekable() : bool { if (! $this->resource) { return false; } $meta = stream_get_meta_data($this->resource); return $meta['seekable']; } /** * {@inheritdoc} */ public function seek($offset, $whence = SEEK_SET) : void { if (! $this->resource) { throw Exception\UnseekableStreamException::dueToMissingResource(); } if (! $this->isSeekable()) { throw Exception\UnseekableStreamException::dueToConfiguration(); } $result = fseek($this->resource, $offset, $whence); if (0 !== $result) { throw Exception\UnseekableStreamException::dueToPhpError(); } } /** * {@inheritdoc} */ public function rewind() : void { $this->seek(0); } /** * {@inheritdoc} */ public function isWritable() : bool { if (! $this->resource) { return false; } $meta = stream_get_meta_data($this->resource); $mode = $meta['mode']; return ( strstr($mode, 'x') || strstr($mode, 'w') || strstr($mode, 'c') || strstr($mode, 'a') || strstr($mode, '+') ); } /** * {@inheritdoc} */ public function write($string) : int { if (! $this->resource) { throw Exception\UnwritableStreamException::dueToMissingResource(); } if (! $this->isWritable()) { throw Exception\UnwritableStreamException::dueToConfiguration(); } $result = fwrite($this->resource, $string); if (false === $result) { throw Exception\UnwritableStreamException::dueToPhpError(); } return $result; } /** * {@inheritdoc} */ public function isReadable() : bool { if (! $this->resource) { return false; } $meta = stream_get_meta_data($this->resource); $mode = $meta['mode']; return (strstr($mode, 'r') || strstr($mode, '+')); } /** * {@inheritdoc} */ public function read($length) : string { if (! $this->resource) { throw Exception\UnreadableStreamException::dueToMissingResource(); } if (! $this->isReadable()) { throw Exception\UnreadableStreamException::dueToConfiguration(); } $result = fread($this->resource, $length); if (false === $result) { throw Exception\UnreadableStreamException::dueToPhpError(); } return $result; } /** * {@inheritdoc} */ public function getContents() : string { if (! $this->isReadable()) { throw Exception\UnreadableStreamException::dueToConfiguration(); } $result = stream_get_contents($this->resource); if (false === $result) { throw Exception\UnreadableStreamException::dueToPhpError(); } return $result; } /** * {@inheritdoc} */ public function getMetadata($key = null) { if (null === $key) { return stream_get_meta_data($this->resource); } $metadata = stream_get_meta_data($this->resource); if (! array_key_exists($key, $metadata)) { return null; } return $metadata[$key]; } /** * Set the internal stream resource. * * @param string|resource $stream String stream target or stream resource. * @param string $mode Resource mode for stream target. * @throws Exception\InvalidArgumentException for invalid streams or resources. */ private function setStream($stream, string $mode = 'r') : void { $error = null; $resource = $stream; if (is_string($stream)) { set_error_handler(function ($e) use (&$error) { if ($e !== E_WARNING) { return; } $error = $e; }); $resource = fopen($stream, $mode); restore_error_handler(); } if ($error) { throw new Exception\RuntimeException('Invalid stream reference provided'); } if (! $this->isValidStreamResourceType($resource)) { throw new Exception\InvalidArgumentException( 'Invalid stream provided; must be a string stream identifier or stream resource' ); } if ($stream !== $resource) { $this->stream = $stream; } $this->resource = $resource; } /** * Determine if a resource is one of the resource types allowed to instantiate a Stream * * @param resource $resource Stream resource. */ private function isValidStreamResourceType($resource): bool { if (is_resource($resource)) { return in_array(get_resource_type($resource), self::ALLOWED_STREAM_RESOURCE_TYPES, true); } if (PHP_VERSION_ID >= 80000 && $resource instanceof \GdImage) { return true; } return false; } }
[+]
functions
[-] AbstractSerializer.php
[edit]
[-] ServerRequestFactory.php
[edit]
[-] ConfigProvider.php
[edit]
[+]
..
[+]
Exception
[-] RequestFactory.php
[edit]
[-] MessageTrait.php
[edit]
[-] Request.php
[edit]
[-] UploadedFile.php
[edit]
[-] RelativeStream.php
[edit]
[-] Stream.php
[edit]
[-] RequestTrait.php
[edit]
[-] Module.php
[edit]
[-] PhpInputStream.php
[edit]
[+]
Request
[+]
Response
[-] UriFactory.php
[edit]
[-] UploadedFileFactory.php
[edit]
[-] Uri.php
[edit]
[-] ResponseFactory.php
[edit]
[-] HeaderSecurity.php
[edit]
[-] CallbackStream.php
[edit]
[-] ServerRequest.php
[edit]
[-] StreamFactory.php
[edit]
[-] Response.php
[edit]