@@ -16,7 +16,7 @@ discard block |
||
16 | 16 | |
17 | 17 | class StreamsTest extends TestCase |
18 | 18 | { |
19 | - private const FIXTURE_DIRECTORY = __DIR__ . '/fixtures'; |
|
19 | + private const FIXTURE_DIRECTORY = __DIR__.'/fixtures'; |
|
20 | 20 | |
21 | 21 | public function setUp(): void |
22 | 22 | { |
@@ -41,7 +41,7 @@ discard block |
||
41 | 41 | $this->assertSame(strlen('sample text'), filesize($filename)); |
42 | 42 | $this->assertSame(md5('sample text'), md5_file($filename)); |
43 | 43 | |
44 | - $newFilename = self::FIXTURE_DIRECTORY . '/test.txt'; |
|
44 | + $newFilename = self::FIXTURE_DIRECTORY.'/test.txt'; |
|
45 | 45 | copy($filename, $newFilename); |
46 | 46 | |
47 | 47 | $this->assertFileExists($newFilename); |
@@ -79,16 +79,16 @@ discard block |
||
79 | 79 | |
80 | 80 | public function testException() |
81 | 81 | { |
82 | - try { |
|
82 | + try{ |
|
83 | 83 | fopen('spiral://non-exists', 'rb'); |
84 | - } catch (\Throwable $e) { |
|
84 | + }catch (\Throwable $e){ |
|
85 | 85 | $this->assertStringContainsString('failed to open stream', $e->getMessage()); |
86 | 86 | } |
87 | 87 | |
88 | 88 | |
89 | - try { |
|
89 | + try{ |
|
90 | 90 | filemtime('spiral://non-exists'); |
91 | - } catch (\Throwable $e) { |
|
91 | + }catch (\Throwable $e){ |
|
92 | 92 | $this->assertStringContainsString('stat failed', $e->getMessage()); |
93 | 93 | } |
94 | 94 | } |
@@ -79,16 +79,22 @@ |
||
79 | 79 | |
80 | 80 | public function testException() |
81 | 81 | { |
82 | - try { |
|
82 | + try |
|
83 | + { |
|
83 | 84 | fopen('spiral://non-exists', 'rb'); |
84 | - } catch (\Throwable $e) { |
|
85 | + } |
|
86 | + catch (\Throwable $e) |
|
87 | + { |
|
85 | 88 | $this->assertStringContainsString('failed to open stream', $e->getMessage()); |
86 | 89 | } |
87 | 90 | |
88 | 91 | |
89 | - try { |
|
92 | + try |
|
93 | + { |
|
90 | 94 | filemtime('spiral://non-exists'); |
91 | - } catch (\Throwable $e) { |
|
95 | + } |
|
96 | + catch (\Throwable $e) |
|
97 | + { |
|
92 | 98 | $this->assertStringContainsString('stat failed', $e->getMessage()); |
93 | 99 | } |
94 | 100 | } |
@@ -71,7 +71,7 @@ discard block |
||
71 | 71 | */ |
72 | 72 | public function stream_open($path, $mode, $options, &$opened_path) |
73 | 73 | { |
74 | - if (!isset(self::$uris[$path])) { |
|
74 | + if (!isset(self::$uris[$path])){ |
|
75 | 75 | return false; |
76 | 76 | } |
77 | 77 | |
@@ -155,7 +155,7 @@ discard block |
||
155 | 155 | */ |
156 | 156 | public function url_stat($path, $flags) |
157 | 157 | { |
158 | - if (!isset(self::$uris[$path])) { |
|
158 | + if (!isset(self::$uris[$path])){ |
|
159 | 159 | return null; |
160 | 160 | } |
161 | 161 | |
@@ -171,12 +171,12 @@ discard block |
||
171 | 171 | private function getStreamStats(StreamInterface $stream) |
172 | 172 | { |
173 | 173 | $mode = $this->mode; |
174 | - if (empty($mode)) { |
|
175 | - if ($stream->isReadable()) { |
|
174 | + if (empty($mode)){ |
|
175 | + if ($stream->isReadable()){ |
|
176 | 176 | $mode = 'r'; |
177 | 177 | } |
178 | 178 | |
179 | - if ($stream->isWritable()) { |
|
179 | + if ($stream->isWritable()){ |
|
180 | 180 | $mode = !empty($mode) ? 'r+' : 'w'; |
181 | 181 | } |
182 | 182 | } |
@@ -203,7 +203,7 @@ discard block |
||
203 | 203 | */ |
204 | 204 | public static function register() |
205 | 205 | { |
206 | - if (self::$registered) { |
|
206 | + if (self::$registered){ |
|
207 | 207 | return; |
208 | 208 | } |
209 | 209 | |
@@ -219,8 +219,8 @@ discard block |
||
219 | 219 | */ |
220 | 220 | public static function has($file) |
221 | 221 | { |
222 | - if ($file instanceof StreamInterface) { |
|
223 | - $file = 'spiral://' . spl_object_hash($file); |
|
222 | + if ($file instanceof StreamInterface){ |
|
223 | + $file = 'spiral://'.spl_object_hash($file); |
|
224 | 224 | } |
225 | 225 | |
226 | 226 | return isset(self::$uris[$file]); |
@@ -237,15 +237,15 @@ discard block |
||
237 | 237 | public static function getResource(StreamInterface $stream) |
238 | 238 | { |
239 | 239 | $mode = null; |
240 | - if ($stream->isReadable()) { |
|
240 | + if ($stream->isReadable()){ |
|
241 | 241 | $mode = 'r'; |
242 | 242 | } |
243 | 243 | |
244 | - if ($stream->isWritable()) { |
|
244 | + if ($stream->isWritable()){ |
|
245 | 245 | $mode = !empty($mode) ? 'r+' : 'w'; |
246 | 246 | } |
247 | 247 | |
248 | - if (empty($mode)) { |
|
248 | + if (empty($mode)){ |
|
249 | 249 | throw new WrapperException("Stream is not available in read or write modes"); |
250 | 250 | } |
251 | 251 | |
@@ -262,7 +262,7 @@ discard block |
||
262 | 262 | { |
263 | 263 | self::register(); |
264 | 264 | |
265 | - $uri = 'spiral://' . spl_object_hash($stream); |
|
265 | + $uri = 'spiral://'.spl_object_hash($stream); |
|
266 | 266 | self::$uris[$uri] = $stream; |
267 | 267 | |
268 | 268 | return $uri; |
@@ -276,8 +276,8 @@ discard block |
||
276 | 276 | */ |
277 | 277 | public static function release($file) |
278 | 278 | { |
279 | - if ($file instanceof StreamInterface) { |
|
280 | - $file = 'spiral://' . spl_object_hash($file); |
|
279 | + if ($file instanceof StreamInterface){ |
|
280 | + $file = 'spiral://'.spl_object_hash($file); |
|
281 | 281 | } |
282 | 282 | |
283 | 283 | unset(self::$uris[$file]); |
@@ -71,7 +71,8 @@ discard block |
||
71 | 71 | */ |
72 | 72 | public function stream_open($path, $mode, $options, &$opened_path) |
73 | 73 | { |
74 | - if (!isset(self::$uris[$path])) { |
|
74 | + if (!isset(self::$uris[$path])) |
|
75 | + { |
|
75 | 76 | return false; |
76 | 77 | } |
77 | 78 | |
@@ -155,7 +156,8 @@ discard block |
||
155 | 156 | */ |
156 | 157 | public function url_stat($path, $flags) |
157 | 158 | { |
158 | - if (!isset(self::$uris[$path])) { |
|
159 | + if (!isset(self::$uris[$path])) |
|
160 | + { |
|
159 | 161 | return null; |
160 | 162 | } |
161 | 163 | |
@@ -171,12 +173,15 @@ discard block |
||
171 | 173 | private function getStreamStats(StreamInterface $stream) |
172 | 174 | { |
173 | 175 | $mode = $this->mode; |
174 | - if (empty($mode)) { |
|
175 | - if ($stream->isReadable()) { |
|
176 | + if (empty($mode)) |
|
177 | + { |
|
178 | + if ($stream->isReadable()) |
|
179 | + { |
|
176 | 180 | $mode = 'r'; |
177 | 181 | } |
178 | 182 | |
179 | - if ($stream->isWritable()) { |
|
183 | + if ($stream->isWritable()) |
|
184 | + { |
|
180 | 185 | $mode = !empty($mode) ? 'r+' : 'w'; |
181 | 186 | } |
182 | 187 | } |
@@ -203,7 +208,8 @@ discard block |
||
203 | 208 | */ |
204 | 209 | public static function register() |
205 | 210 | { |
206 | - if (self::$registered) { |
|
211 | + if (self::$registered) |
|
212 | + { |
|
207 | 213 | return; |
208 | 214 | } |
209 | 215 | |
@@ -219,7 +225,8 @@ discard block |
||
219 | 225 | */ |
220 | 226 | public static function has($file) |
221 | 227 | { |
222 | - if ($file instanceof StreamInterface) { |
|
228 | + if ($file instanceof StreamInterface) |
|
229 | + { |
|
223 | 230 | $file = 'spiral://' . spl_object_hash($file); |
224 | 231 | } |
225 | 232 | |
@@ -237,15 +244,18 @@ discard block |
||
237 | 244 | public static function getResource(StreamInterface $stream) |
238 | 245 | { |
239 | 246 | $mode = null; |
240 | - if ($stream->isReadable()) { |
|
247 | + if ($stream->isReadable()) |
|
248 | + { |
|
241 | 249 | $mode = 'r'; |
242 | 250 | } |
243 | 251 | |
244 | - if ($stream->isWritable()) { |
|
252 | + if ($stream->isWritable()) |
|
253 | + { |
|
245 | 254 | $mode = !empty($mode) ? 'r+' : 'w'; |
246 | 255 | } |
247 | 256 | |
248 | - if (empty($mode)) { |
|
257 | + if (empty($mode)) |
|
258 | + { |
|
249 | 259 | throw new WrapperException("Stream is not available in read or write modes"); |
250 | 260 | } |
251 | 261 | |
@@ -276,7 +286,8 @@ discard block |
||
276 | 286 | */ |
277 | 287 | public static function release($file) |
278 | 288 | { |
279 | - if ($file instanceof StreamInterface) { |
|
289 | + if ($file instanceof StreamInterface) |
|
290 | + { |
|
280 | 291 | $file = 'spiral://' . spl_object_hash($file); |
281 | 292 | } |
282 | 293 |