add downloader

composer.json

@@ -62,5 +62,11 @@
         "psr-4": {
             "Arxy\\FilesBundle\\Tests\\": "tests/"
         }
+    },
+    "config": {
+        "allow-plugins": {
+            "dealerdirect/phpcodesniffer-composer-installer": true,
+            "infection/extension-installer": true
+        }
     }
 }

src/ErrorHandler.php

@@ -12,10 +12,12 @@
 class ErrorHandler
 {
     /**
-     * @return mixed
+     * @template T
+     * @param callable(): (T|false) $callable
+     * @return T
      * @throws ErrorException
      */
-    public static function wrap(callable $callable)
+    public static function wrap(callable $callable): mixed
     {
         set_error_handler(
             static function (int $errno, string $message, string $file, int $line): bool {
@@ -29,7 +31,12 @@ static function (int $errno, string $message, string $file, int $line): bool {
             }
         );
         try {
-            return $callable();
+            $value = $callable();
+            if ($value === false) {
+                throw new ErrorException('Unknown error');
+            }
+
+            return $value;
         } finally {
             restore_error_handler();
         }

src/Manager.php

@@ -22,7 +22,6 @@
 use SplFileInfo;
 use SplFileObject;
 use Symfony\Component\HttpFoundation\File\UploadedFile;
-
 use Throwable;
 
 use function clearstatcache;

src/Utility/FileDownloader.php

@@ -0,0 +1,43 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Arxy\FilesBundle\Utility;
+
+use Arxy\FilesBundle\ErrorHandler;
+use Arxy\FilesBundle\ManagerInterface;
+use Arxy\FilesBundle\Model\File;
+use SplFileInfo;
+
+use function fclose;
+use function fopen;
+use function stream_copy_to_stream;
+
+class FileDownloader
+{
+    private ManagerInterface $manager;
+
+    public function __construct(ManagerInterface $manager)
+    {
+        $this->manager = $manager;
+    }
+
+    /**
+     * @throws \ErrorException
+     */
+    public function downloadAsSplFile(File $file): SplFileInfo
+    {
+        $tempDir = sys_get_temp_dir() . DIRECTORY_SEPARATOR . uniqid('file-downloader', true);
+
+        ErrorHandler::wrap(static fn (): bool => mkdir($tempDir));
+
+        $tmpFile = $tempDir . DIRECTORY_SEPARATOR . $file->getOriginalFilename();
+
+        $destinationStream = ErrorHandler::wrap(static fn () => fopen($tmpFile, 'w'));
+        ErrorHandler::wrap(fn () => stream_copy_to_stream($this->manager->readStream($file), $destinationStream));
+
+        fclose($destinationStream);
+
+        return new SplFileInfo($tmpFile);
+    }
+}

tests/FileDownloaderTest.php

@@ -0,0 +1,69 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Arxy\FilesBundle\Tests;
+
+use Arxy\FilesBundle\Manager;
+use Arxy\FilesBundle\ManagerInterface;
+use Arxy\FilesBundle\NamingStrategy;
+use Arxy\FilesBundle\Storage\FlysystemStorage;
+use Arxy\FilesBundle\Utility\FileDownloader;
+use League\Flysystem\Filesystem;
+use League\Flysystem\FilesystemOperator;
+use League\Flysystem\InMemory\InMemoryFilesystemAdapter;
+use PHPUnit\Framework\TestCase;
+
+class FileDownloaderTest extends TestCase
+{
+    private ManagerInterface $manager;
+    private FilesystemOperator $filesystem;
+
+    private FileDownloader $downloader;
+
+    protected function setUp(): void
+    {
+        parent::setUp();
+
+        $this->filesystem = new Filesystem(new InMemoryFilesystemAdapter());
+
+        $this->manager = new Manager(
+            File::class,
+            new FlysystemStorage($this->filesystem),
+            /** @implements NamingStrategy<File> */
+            new class implements NamingStrategy {
+                public function getDirectoryName(\Arxy\FilesBundle\Model\File $file): ?string
+                {
+                    return null;
+                }
+
+                public function getFileName(\Arxy\FilesBundle\Model\File $file): string
+                {
+                    return (string)$file->getId();
+                }
+            },
+            new FileRepository(),
+        );
+
+        $this->downloader = new FileDownloader($this->manager);
+    }
+
+    public function testDownloadAsSplFilePersisted(): void
+    {
+        $file = $this->manager->upload(new \SplFileObject(__DIR__ . '/files/image1.jpg'));
+        $this->manager->moveFile($file);
+
+        $splFile = $this->downloader->downloadAsSplFile($file);
+
+        self::assertFileEquals($splFile->getPathname(), __DIR__ . '/files/image1.jpg');
+    }
+
+    public function testDownloadAsSplFileNotPersisted(): void
+    {
+        $file = $this->manager->upload(new \SplFileObject(__DIR__ . '/files/image1.jpg'));
+
+        $splFile = $this->downloader->downloadAsSplFile($file);
+
+        self::assertFileEquals($splFile->getPathname(), __DIR__ . '/files/image1.jpg');
+    }
+}