stockpack / vendor / guzzlehttp / psr7 / src / StreamWrapper.php

StreamWrapper.php in StockPack – Stock photos and AI images from Unsplash, Adobe Stock, Freepik and more 2.5.3, at vendor/guzzlehttp/psr7/src/StreamWrapper.php

162 lines 3.7 KB

Raw Download Zip

1	<?php
2	namespace GuzzleHttp\Psr7;
3
4	use Psr\Http\Message\StreamInterface;
5
6	/**
7	* Converts Guzzle streams into PHP stream resources.
8	*/
9	class StreamWrapper
10	{
11	/** @var resource */
12	public $context;
13
14	/** @var StreamInterface */
15	private $stream;
16
17	/** @var string r, r+, or w */
18	private $mode;
19
20	/**
21	* Returns a resource representing the stream.
22	*
23	* @param StreamInterface $stream The stream to get a resource for
24	*
25	* @return resource
26	* @throws \InvalidArgumentException if stream is not readable or writable
27	*/
28	public static function getResource(StreamInterface $stream)
29	{
30	self::register();
31
32	if ($stream->isReadable()) {
33	$mode = $stream->isWritable() ? 'r+' : 'r';
34	} elseif ($stream->isWritable()) {
35	$mode = 'w';
36	} else {
37	throw new \InvalidArgumentException('The stream must be readable, '
38	. 'writable, or both.');
39	}
40
41	return fopen('guzzle://stream', $mode, null, self::createStreamContext($stream));
42	}
43
44	/**
45	* Creates a stream context that can be used to open a stream as a php stream resource.
46	*
47	* @param StreamInterface $stream
48	*
49	* @return resource
50	*/
51	public static function createStreamContext(StreamInterface $stream)
52	{
53	return stream_context_create([
54	'guzzle' => ['stream' => $stream]
55	]);
56	}
57
58	/**
59	* Registers the stream wrapper if needed
60	*/
61	public static function register()
62	{
63	if (!in_array('guzzle', stream_get_wrappers())) {
64	stream_wrapper_register('guzzle', __CLASS__);
65	}
66	}
67
68	public function stream_open($path, $mode, $options, &$opened_path)
69	{
70	$options = stream_context_get_options($this->context);
71
72	if (!isset($options['guzzle']['stream'])) {
73	return false;
74	}
75
76	$this->mode = $mode;
77	$this->stream = $options['guzzle']['stream'];
78
79	return true;
80	}
81
82	public function stream_read($count)
83	{
84	return $this->stream->read($count);
85	}
86
87	public function stream_write($data)
88	{
89	return (int) $this->stream->write($data);
90	}
91
92	public function stream_tell()
93	{
94	return $this->stream->tell();
95	}
96
97	public function stream_eof()
98	{
99	return $this->stream->eof();
100	}
101
102	public function stream_seek($offset, $whence)
103	{
104	$this->stream->seek($offset, $whence);
105
106	return true;
107	}
108
109	public function stream_cast($cast_as)
110	{
111	$stream = clone($this->stream);
112
113	return $stream->detach();
114	}
115
116	public function stream_stat()
117	{
118	static $modeMap = [
119	'r' => 33060,
120	'rb' => 33060,
121	'r+' => 33206,
122	'w' => 33188,
123	'wb' => 33188
124	];
125
126	return [
127	'dev' => 0,
128	'ino' => 0,
129	'mode' => $modeMap[$this->mode],
130	'nlink' => 0,
131	'uid' => 0,
132	'gid' => 0,
133	'rdev' => 0,
134	'size' => $this->stream->getSize() ?: 0,
135	'atime' => 0,
136	'mtime' => 0,
137	'ctime' => 0,
138	'blksize' => 0,
139	'blocks' => 0
140	];
141	}
142
143	public function url_stat($path, $flags)
144	{
145	return [
146	'dev' => 0,
147	'ino' => 0,
148	'mode' => 0,
149	'nlink' => 0,
150	'uid' => 0,
151	'gid' => 0,
152	'rdev' => 0,
153	'size' => 0,
154	'atime' => 0,
155	'mtime' => 0,
156	'ctime' => 0,
157	'blksize' => 0,
158	'blocks' => 0
159	];
160	}
161	}
162