PHPLIB-1323 Implement unlink for GridFS stream wrapper

docs/reference/method/MongoDBGridFSBucket-registerGlobalStreamWrapperAlias.txt

@@ -49,6 +49,7 @@ Supported stream functions:
 - :php:`file() <file>`
 - :php:`fopen() <fopen>` with "r", "rb", "w", and "wb" modes
 - :php:`rename() <rename>` rename all revisions of a file in the same bucket
+- :php:`unlink() <unlink>` (remove all revisions of a file)
 
 In read mode, the stream context can contain the option ``gridfs['revision']``
 to specify the revision number of the file to read. If omitted, the most recent
@@ -86,6 +87,8 @@ Each call to these functions makes a request to the server.
 
    echo file_get_contents('gridfs://mybucket/hello.txt');
 
+   unlink('gridfs://mybucket/hello.txt');
+
 The output would then resemble:
 
 .. code-block:: none

psalm-baseline.xml

@@ -85,6 +85,11 @@
       <code>$context</code>
     </MixedArgumentTypeCoercion>
   </file>
+  <file src="src/GridFS/CollectionWrapper.php">
+    <MixedAssignment>
+      <code>$ids[]</code>
+    </MixedAssignment>
+  </file>
   <file src="src/GridFS/ReadableStream.php">
     <MixedArgument>
       <code><![CDATA[$currentChunk->n]]></code>
@@ -100,6 +105,11 @@
       <code>$context</code>
     </MixedAssignment>
   </file>
+  <file src="src/GridFS/WritableStream.php">
+    <MixedArgument>
+      <code><![CDATA[$this->file['filename']]]></code>
+    </MixedArgument>
+  </file>
   <file src="src/Model/BSONArray.php">
     <MixedAssignment>
       <code>$this[$key]</code>

src/GridFS/CollectionWrapper.php

@@ -80,6 +80,30 @@ public function deleteChunksByFilesId($id): void
         $this->chunksCollection->deleteMany(['files_id' => $id]);
     }
 
+    /**
+     * Delete all GridFS files and chunks for a given filename.
+     */
+    public function deleteFileAndChunksByFilename(string $filename): int
+    {
+        /** @var iterable<array{_id: mixed}> $files */
+        $files = $this->findFiles(['filename' => $filename], [
+            'codec' => null,
+            'typeMap' => ['root' => 'array'],
+            'projection' => ['_id' => 1],
+        ]);
+
+        /** @var list<mixed> $ids */
+        $ids = [];
+        foreach ($files as $file) {
+            $ids[] = $file['_id'];
+        }
+
+        $count = $this->filesCollection->deleteMany(['_id' => ['$in' => $ids]])->getDeletedCount();
+        $this->chunksCollection->deleteMany(['files_id' => ['$in' => $ids]]);
+
+        return $count ?? 0;
+    }
+
     /**
      * Deletes a GridFS file and related chunks by ID.
      *

src/GridFS/StreamWrapper.php

@@ -324,6 +324,19 @@ public function stream_write(string $data): int
         return $this->stream->writeBytes($data);
     }
 
+    public function unlink(string $path): bool
+    {
+        try {
+            $this->stream_open($path, 'w', 0, $openedPath);
+        } catch (FileNotFoundException $e) {
+            return false;
+        }
+
+        assert($this->stream instanceof WritableStream);
+
+        return $this->stream->delete() > 0;
+    }
+
     /** @return false|array */
     public function url_stat(string $path, int $flags)
     {

src/GridFS/WritableStream.php

@@ -173,6 +173,21 @@ public function close(): void
         $this->isClosed = true;
     }
 
+    /**
+     * Delete all files and chunks associated with this stream filename.
+     *
+     * @return int The number of deleted files
+     */
+    public function delete(): int
+    {
+        try {
+            return $this->collectionWrapper->deleteFileAndChunksByFilename($this->file['filename']);
+        } finally {
+            // Prevent further operations on this stream
+            $this->abort();
+        }
+    }
+
     /**
      * Return the stream's file document.
      */

tests/GridFS/StreamWrapperFunctionalTest.php

@@ -29,6 +29,7 @@
 use function stream_context_create;
 use function stream_get_contents;
 use function time;
+use function unlink;
 use function usleep;
 
 use const SEEK_CUR;
@@ -387,4 +388,18 @@ public function testRenamePathMismatch(): void
 
         rename('gridfs://bucket/filename', 'gridfs://other/newname');
     }
+
+    public function testUnlinkAllRevisions(): void
+    {
+        $this->bucket->registerGlobalStreamWrapperAlias('bucket');
+        $path = 'gridfs://bucket/path/to/filename';
+
+        file_put_contents($path, 'version 0');
+        file_put_contents($path, 'version 1');
+
+        $result = unlink($path);
+
+        $this->assertTrue($result);
+        $this->assertFalse(file_exists($path));
+    }
 }