PHPLIB-1313 Ensure the GridFS stream is saved when the script ends (#…

…1197)

CHANGELOG.md

@@ -4,4 +4,4 @@
 ## 1.18.0 (unreleased)
 
  * Add `addSubscriber` and `removeSubscriber` methods to the `Client` class to ease dependency injection configuration
-
+ * Fix GridFS stream closing when the PHP script ends

src/GridFS/StreamWrapper.php

@@ -53,10 +53,11 @@ class StreamWrapper
 
     public function __destruct()
     {
-        /* This destructor is a workaround for PHP trying to use the stream well
-         * after all objects have been destructed. This can cause autoloading
-         * issues and possibly segmentation faults during PHP shutdown. */
-        $this->stream = null;
+        /* Ensure the stream is closed so the last chunk is written. This is
+         * necessary because PHP would close the stream after all objects have
+         * been destructed. This can cause autoloading issues and possibly
+         * segmentation faults during PHP shutdown. */
+        $this->stream_close();
     }
 
     /**

tests/GridFS/BucketFunctionalTest.php

@@ -23,6 +23,7 @@
 use function array_merge;
 use function call_user_func;
 use function current;
+use function escapeshellarg;
 use function exec;
 use function fclose;
 use function fopen;
@@ -39,7 +40,7 @@
 use function strncasecmp;
 use function substr;
 
-use const PHP_EOL;
+use const PHP_BINARY;
 use const PHP_OS;
 
 /**
@@ -853,21 +854,33 @@ public function testDanglingOpenWritableStream(): void
             $this->markTestSkipped('Test does not apply to Windows');
         }
 
-        $path = __DIR__ . '/../../vendor/autoload.php';
-        $command = <<<CMD
-php -r "require '$path'; \\\$stream = (new MongoDB\Client)->test->selectGridFSBucket()->openUploadStream('filename', ['disableMD5' => true]);" 2>&1
-CMD;
+        $code = <<<'PHP'
+            require '%s';
+            $client = new \MongoDB\Client(getenv('MONGODB_URI') ?: 'mongodb://127.0.0.1:27017/?serverSelectionTimeoutMS=100');
+            $database = $client->selectDatabase(getenv('MONGODB_DATABASE') ?: 'phplib_test');
+            $gridfs = $database->selectGridFSBucket();
+            $stream = $gridfs->openUploadStream('hello.txt', ['disableMD5' => true]);
+            fwrite($stream, 'Hello MongoDB!');
+            PHP;
 
         @exec(
-            $command,
+            implode(' ', [
+                PHP_BINARY,
+                '-r',
+                escapeshellarg(sprintf($code, __DIR__ . '/../../vendor/autoload.php')),
+                '2>&1',
+            ]),
             $output,
             $return,
         );
 
+        $this->assertSame([], $output);
         $this->assertSame(0, $return);
-        $output = implode(PHP_EOL, $output);
 
-        $this->assertSame('', $output);
+        $fileDocument = $this->filesCollection->findOne(['filename' => 'hello.txt']);
+
+        $this->assertNotNull($fileDocument);
+        $this->assertSame(14, $fileDocument->length);
     }
 
     /**