Merge pull request #29 from chrisnharvey/pseudo-directories

Add support for pseudo-directories

Author: mzur

src/SwiftAdapter.php

@@ -13,6 +13,7 @@
 use GuzzleHttp\Psr7\Stream;
 use InvalidArgumentException;
 use League\Flysystem\Config;
+use League\Flysystem\DirectoryAttributes;
 use League\Flysystem\FileAttributes;
 use League\Flysystem\FilesystemAdapter;
 use League\Flysystem\PathPrefixer;
@@ -233,10 +234,13 @@ public function readStream(string $path)
      */
     public function listContents(string $path, bool $deep): iterable
     {
-        $location = $this->prefixer->prefixPath($path);
+        $location = $this->prefixer->prefixDirectoryPath($path);
 
+        // Fetch objects with preudo-directory support. See:
+        // https://docs.openstack.org/swift/latest/api/pseudo-hierarchical-folders-directories.html
         $objectList = $this->container->listObjects([
             'prefix' => $location,
+            'delimiter' => '/',
         ]);
 
         foreach ($objectList as $object) {
@@ -319,25 +323,29 @@ protected function getObject(string $path): StorageObject
         return $object;
     }
 
-    protected function normalizeObject(StorageObject $object): FileAttributes
+    protected function normalizeObject(StorageObject $object): FileAttributes|DirectoryAttributes
     {
-        $name = $this->prefixer->stripPrefix($object->name);
+        $name = $this->prefixer->stripDirectoryPrefix($object->name);
 
         if ($object->lastModified instanceof DateTimeInterface) {
             $timestamp = $object->lastModified->getTimestamp();
-        } else {
+        } elseif (is_string($object->lastModified)) {
             $timestamp = strtotime($object->lastModified);
+        } else {
+            $timestamp = null;
+        }
+
+        // Check if the object name ends with a slash. This is a pseudo-directory.
+        if (substr_compare($object->name, '/', -1) === 0) {
+            return new DirectoryAttributes($name);
         }
 
         return new FileAttributes(
             $name,
             (int) $object->contentLength,
             null,
             $timestamp,
-            $object->contentType,
-            [
-                'type' => 'file',
-            ]
+            $object->contentType
         );
     }
 

tests/SwiftAdapterTest.php

@@ -125,7 +125,8 @@ public function testDirectoryExists()
         $this->container->shouldReceive('listObjects')
             ->once()
             ->with([
-                'prefix' => 'hello',
+                'prefix' => 'hello/',
+                'delimiter' => '/',
             ])
             ->andReturn($objects);
 
@@ -138,7 +139,8 @@ public function testDirectoryExists()
         $this->container->shouldReceive('listObjects')
             ->once()
             ->with([
-                'prefix' => 'world',
+                'prefix' => 'world/',
+                'delimiter' => '/',
             ])
             ->andReturn($objects);
 
@@ -161,7 +163,8 @@ public function testListContents()
         $this->container->shouldReceive('listObjects')
             ->once()
             ->with([
-                'prefix' => 'hello',
+                'prefix' => 'hello/',
+                'delimiter' => '/',
             ])
             ->andReturn($objects);
 
@@ -172,9 +175,7 @@ public function testListContents()
             'mime_type' => 'text/html; charset=UTF-8',
             'visibility' => null,
             'file_size' => 0,
-            'extra_metadata' => [
-                'type' => 'file',
-            ],
+            'extra_metadata' => [],
         ];
 
         $contents = $this->adapter->listContents('hello', false);
@@ -188,6 +189,34 @@ public function testListContents()
         $this->assertEquals($times, $count);
     }
 
+    public function testListContentsPseudoDirectory()
+    {
+        $object = Mockery::mock(StorageObject::class);
+        $object->name = 'name/';
+        $generator = function () use ($object) {
+            yield $object;
+        };
+        $objects = $generator();
+        $this->container->shouldReceive('listObjects')
+            ->once()
+            ->with([
+                'prefix' => 'hello/',
+                'delimiter' => '/',
+            ])
+            ->andReturn($objects);
+
+        $expect = [
+            'path' => 'name',
+            'type' => 'dir',
+            'visibility' => null,
+            'extra_metadata' => [],
+            'last_modified' => null,
+        ];
+
+        $contents = iterator_to_array($this->adapter->listContents('hello', false));
+        $this->assertEquals($expect, $contents[0]->jsonSerialize());
+    }
+
     public function testMove()
     {
         $this->object->shouldReceive('copy')->once()->with([
@@ -358,9 +387,7 @@ public function testMetadataMethods()
             'mime_type' => 'text/html; charset=UTF-8',
             'visibility' => null,
             'file_size' => 0,
-            'extra_metadata' => [
-                'type' => 'file',
-            ],
+            'extra_metadata' => [],
         ];
 
         foreach ($methods as $method) {