feat: add support for writeBatch

Author: tinect

.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 }}

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 (\class_exists(WriteBatchInterface::class)) {
+            return new Shopware6BunnyCdnWriteBatchAdapter($adapterConfig);
+        }
+
+        return new Shopware6BunnyCdnAdapter($adapterConfig);
+    }
+
     public function getType(): string
     {
         return 'bunnycdn';

src/Adapter/Shopware6BunnyCdnWriteBatchAdapter.php

@@ -0,0 +1,63 @@
+<?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;
+
+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) {
+                    if (\is_resource($data->getSourceFile())) {
+                        $sourcePath = stream_get_meta_data($data->getSourceFile())['uri'];
+                        $files[] = new WriteBatchFile($sourcePath, $targetFile);
+
+                        continue;
+                    }
+
+                    $files[] = new WriteBatchFile($data->getSourceFile(), $targetFile);
+                }
+
+                continue;
+            }
+
+            if ($data instanceof Config) {
+                $config = $data;
+
+                continue;
+            }
+
+            if (\is_array($data)) {
+                foreach ($data as $item) {
+                    if ($item instanceof WriteBatchFile) {
+                        $files[] = $item;
+
+                        continue;
+                    }
+
+                    throw new \InvalidArgumentException('Each value of array must be a WriteBatchFile object.');
+                }
+
+                continue;
+            }
+
+            throw new \InvalidArgumentException('Unsupported input type.');
+        }
+
+        if (empty($files)) {
+            return;
+        }
+
+        parent::writeBatch($files, $config);
+    }
+}