feat: add support for writeBatch

.github/workflows/test.yml

@@ -25,6 +25,7 @@ jobs:
           "v6.5.8.2",
           "6.5.x",
           "v6.6.0.3",
+          "v6.6.8.1",
           "trunk"
         ]
         php: ["8.2"]
@@ -70,4 +71,4 @@ jobs:
         with:
           files: ./clover.xml
           root_dir: ${{ github.workspace }}/custom/plugins/${{ env.PLUGIN_NAME }}
-          working-directory: ${{ github.workspace }}/custom/plugins/${{ env.PLUGIN_NAME }}
+          working-directory: ${{ github.workspace }}/custom/plugins/${{ env.PLUGIN_NAME }}

CHANGELOG_en-GB.md

@@ -1,3 +1,8 @@
+# 3.4.0
+
+* Feat: (for Shopware >= 6.6.8.0) Add support for writeBatch.
+  With this you can use storage for theme and asset with more speed. Instead of 2,5 hours it now takes 30 seconds for assets on storage with SSD with demo shop.
+
 # 3.3.3
 
 * Fix: correct config message for Shopware >6.6.3.0

composer.json

@@ -20,7 +20,7 @@
     ],
     "require": {
         "shopware/core": "~6.5.3||~6.6.0",
-        "platformcommunity/flysystem-bunnycdn": "^3.3.4",
+        "platformcommunity/flysystem-bunnycdn": "^3.3.5",
         "league/flysystem-path-prefixing": "^3.10.3",
         "ajgl/flysystem-replicate": "^2.2",
         "tinect/flysystem-garbage": "^1.0"

src/Adapter/BunnyCdnFactory.php

@@ -7,6 +7,7 @@
 use League\Flysystem\Local\LocalFilesystemAdapter;
 use League\Flysystem\PathPrefixing\PathPrefixedAdapter;
 use Shopware\Core\Framework\Adapter\Filesystem\Adapter\AdapterFactoryInterface;
+use Shopware\Core\Framework\Adapter\Filesystem\Plugin\WriteBatchInterface;
 use Tinect\Flysystem\Garbage\GarbageFilesystemAdapter;
 
 class BunnyCdnFactory implements AdapterFactoryInterface
@@ -19,7 +20,7 @@ public function create(array $config): FilesystemAdapter
         $adapterConfig = new AdapterConfig();
         $adapterConfig->assign($config);
 
-        $adapter = new Shopware6BunnyCdnAdapter($adapterConfig);
+        $adapter = $this->getBasicAdapter($adapterConfig);
 
         if (!empty($adapterConfig->isUseGarbage())) {
             $adapter = new GarbageFilesystemAdapter($adapter);
@@ -36,6 +37,15 @@ public function create(array $config): FilesystemAdapter
         return $adapter;
     }
 
+    private function getBasicAdapter(AdapterConfig $adapterConfig): FilesystemAdapter
+    {
+        if (\interface_exists(WriteBatchInterface::class)) {
+            return new Shopware6BunnyCdnWriteBatchAdapter($adapterConfig);
+        }
+
+        return new Shopware6BunnyCdnAdapter($adapterConfig);
+    }
+
     public function getType(): string
     {
         return 'bunnycdn';

src/Adapter/Shopware6BunnyCdnWriteBatchAdapter.php

@@ -0,0 +1,70 @@
+<?php declare(strict_types=1);
+
+namespace Frosh\BunnycdnMediaStorage\Adapter;
+
+use League\Flysystem\Config;
+use PlatformCommunity\Flysystem\BunnyCDN\WriteBatchFile;
+use Shopware\Core\Framework\Adapter\Filesystem\Plugin\CopyBatchInput;
+use Shopware\Core\Framework\Adapter\Filesystem\Plugin\WriteBatchInterface;
+
+if (!\interface_exists(WriteBatchInterface::class)) {
+    class Shopware6BunnyCdnWriteBatchAdapter extends Shopware6BunnyCdnAdapter
+    {}
+} else {
+    class Shopware6BunnyCdnWriteBatchAdapter extends Shopware6BunnyCdnAdapter implements WriteBatchInterface
+    {
+        public function writeBatch(CopyBatchInput|array|Config ...$input): void
+        {
+            $files = [];
+            $config = new Config();
+
+            foreach ($input as $data) {
+                if ($data instanceof CopyBatchInput) {
+                    // migrate CopyBatchInput of Shopware to WriteBatchFile
+                    foreach ($data->getTargetFiles() as $targetFile) {
+                        $sourceFile = $data->getSourceFile();
+
+                        if (\is_string($sourceFile)) {
+                            $files[] = new WriteBatchFile($sourceFile, $targetFile);
+
+                            continue;
+                        }
+
+                        $metaData = stream_get_meta_data($sourceFile);
+                        if (empty($metaData['uri'])) {
+                            throw new \InvalidArgumentException('Cannot get source file path from stream.');
+                        }
+
+                        $sourcePath = $metaData['uri'];
+
+                        $files[] = new WriteBatchFile($sourcePath, $targetFile);
+                    }
+
+                    continue;
+                }
+
+                if ($data instanceof Config) {
+                    $config = $data;
+
+                    continue;
+                }
+
+                if (\is_array($data)) {
+                    foreach ($data as $item) {
+                        if (!$item instanceof WriteBatchFile) {
+                            throw new \InvalidArgumentException('Each value of array must be a WriteBatchFile object.');
+                        }
+
+                        $files[] = $item;
+                    }
+                }
+            }
+
+            if (empty($files)) {
+                return;
+            }
+
+            parent::writeBatch($files, $config);
+        }
+    }
+}

tests/unit/Adapter/BunnyCdnFactoryTest.php

@@ -5,8 +5,10 @@
 use Ajgl\Flysystem\Replicate\ReplicateFilesystemAdapter;
 use Frosh\BunnycdnMediaStorage\Adapter\BunnyCdnFactory;
 use Frosh\BunnycdnMediaStorage\Adapter\Shopware6BunnyCdnAdapter;
+use Frosh\BunnycdnMediaStorage\Adapter\Shopware6BunnyCdnWriteBatchAdapter;
 use League\Flysystem\PathPrefixing\PathPrefixedAdapter;
 use PHPUnit\Framework\TestCase;
+use Shopware\Core\Framework\Adapter\Filesystem\Plugin\WriteBatchInterface;
 use Tinect\Flysystem\Garbage\GarbageFilesystemAdapter;
 
 class BunnyCdnFactoryTest extends TestCase
@@ -47,6 +49,19 @@ public function testFactoryCreatesReplicateFilesystemAdapter(): void
         static::assertInstanceOf(ReplicateFilesystemAdapter::class, $adapter);
     }
 
+    public function testFactoryCreatesWriteBatchAdapter(): void
+    {
+        if (!\interface_exists(WriteBatchInterface::class)) {
+            static::markTestSkipped('WriteBatchInterface not found');
+        }
+
+        $factory = new BunnyCdnFactory();
+        $config = ['endpoint' => 'https://storage.bunnycdn.com', 'apiKey' => 'a', 'storageName' => 'a', 'useGarbage' => false];
+        $adapter = $factory->create($config);
+
+        static::assertInstanceOf(WriteBatchInterface::class, $adapter);
+    }
+
     public function testFactoryReturnsBunnycdnType(): void
     {
         $factory = new BunnyCdnFactory();