Fix CS

Author: GromNaN

src/GridFS/Bucket.php

@@ -782,8 +782,9 @@ private function registerStreamWrapper(): void
      *
      * @see StreamWrapper::setContextResolver()
      *
-     * @param string $path The full url provided to fopen(). It contains the filename.
-     *                     gridfs://database_name/collection_name.files/file_name
+     * @param string                                                         $path    The full url provided to fopen(). It contains the filename.
+     *                                                                                gridfs://database_name/collection_name.files/file_name
+     * @param array{revision?: int, chunkSizeBytes?: int, disableMD5?: bool} $context The options provided to fopen()
      *
      * @return array{collectionWrapper: CollectionWrapper, file: object}|array{collectionWrapper: CollectionWrapper, filename: string, options: array}|null
      */
@@ -796,7 +797,7 @@ private function resolveStreamContext(string $path, string $mode, array $context
             $file = $this->collectionWrapper->findFileByFilenameAndRevision($filename, $context['revision'] ?? -1);
 
             // File not found
-            if ($file === null) {
+            if (! is_object($file)) {
                 return null;
             }
 

src/GridFS/StreamWrapper.php

@@ -30,14 +30,13 @@
 use function is_resource;
 use function is_string;
 use function sprintf;
-use function str_contains;
 use function stream_context_get_options;
 use function stream_get_wrappers;
 use function stream_wrapper_register;
 use function stream_wrapper_unregister;
 use function trigger_error;
 
-use const E_USER_WARNING;
+use const E_USER_ERROR;
 use const SEEK_CUR;
 use const SEEK_END;
 use const SEEK_SET;
@@ -60,7 +59,7 @@ class StreamWrapper
     /** @var ReadableStream|WritableStream|null */
     private $stream;
 
-    /** @var array<string, Closure(string, string): ContextOptions|null> */
+    /** @var array<string, Closure(string, string, array): ContextOptions> */
     private static array $contextResolvers = [];
 
     public function __destruct()
@@ -103,7 +102,11 @@ public static function register(string $protocol = 'gridfs'): void
      */
     public static function setContextResolver(string $name, ?Closure $resolver): void
     {
-        self::$contextResolvers[$name] = $resolver;
+        if ($resolver === null) {
+            unset(self::$contextResolvers[$name]);
+        } else {
+            self::$contextResolvers[$name] = $resolver;
+        }
     }
 
     /**
@@ -150,6 +153,14 @@ public function stream_open(string $path, string $mode, int $options, ?string &$
         $context = [];
         if (is_resource($this->context)) {
             $context = stream_context_get_options($this->context)[$protocol] ?? [];
+
+            if (! is_array($context)) {
+                if ($options & STREAM_REPORT_ERRORS) {
+                    trigger_error(sprintf('Invalid context for "%s" protocol.', $protocol), E_USER_ERROR);
+                }
+
+                return false;
+            }
         }
 
         // Opening stream from gridfs
@@ -158,32 +169,38 @@ public function stream_open(string $path, string $mode, int $options, ?string &$
 
             if (count($parts) < 4) {
                 if ($options & STREAM_REPORT_ERRORS) {
-                    trigger_error(sprintf('Invalid GridFS file name: "%s"', $path), E_USER_WARNING);
+                    trigger_error(sprintf('Invalid GridFS file name: "%s"', $path), E_USER_ERROR);
                 }
 
                 return false;
             }
 
-            if (! isset(self::$contextResolvers[$parts[2]])) {
+            $resolver = self::$contextResolvers[$parts[2]] ?? null;
+            if (null === $resolver) {
                 if ($options & STREAM_REPORT_ERRORS) {
-                    trigger_error(sprintf('Unknown GridFS Bucket "%1$s". Call $bucket->asStreamWrap(\'%1$s\') on the Bucket you want to access.', $parts[2]), E_USER_WARNING);
+                    trigger_error(sprintf('Unknown GridFS Bucket "%1$s". Call $bucket->asStreamWrap(\'%1$s\') on the Bucket you want to access.', $parts[2]), E_USER_ERROR);
                 }
 
                 return false;
             }
 
-            $context = self::$contextResolvers[$parts[2]]($path, $mode, $context);
+            $context = $resolver($path, $mode, $context);
             if ($context === null) {
                 if ($options & STREAM_REPORT_ERRORS) {
-                    trigger_error(sprintf('File not found "%s".', $path), E_USER_WARNING);
+                    trigger_error(sprintf('File not found "%s".', $path), E_USER_ERROR);
                 }
 
                 return false;
             }
         }
 
-        assert(is_array($context));
-        assert(isset($context['collectionWrapper']) && $context['collectionWrapper'] instanceof CollectionWrapper);
+        if (! $context['collectionWrapper'] instanceof CollectionWrapper) {
+            if ($options & STREAM_REPORT_ERRORS) {
+                trigger_error('Invalid context: "gridfs[collectionWrapper]" must be a CollectionWrapper.', E_USER_ERROR);
+            }
+
+            return false;
+        }
 
         if ($mode === 'r' || $mode === 'rb') {
             assert(isset($context['file']) && is_object($context['file']));
@@ -315,6 +332,7 @@ public function stream_write(string $data): int
         return $this->stream->writeBytes($data);
     }
 
+    /** @return false|array */
     public function url_stat(string $path, int $flags)
     {
         $success = $this->stream_open($path, 'r', 0, $openedPath);

tests/GridFS/FunctionalTestCase.php

@@ -11,7 +11,6 @@
 use function fwrite;
 use function get_resource_type;
 use function rewind;
-use function sprintf;
 use function stream_get_contents;
 
 /**