feat: saved ems assets archive in target dir

theus77 · Oct 12, 2024 · a426f50 · a426f50
1 parent 0e784ab
commit a426f50
Show file tree

Hide file tree

Showing 2 changed files with 28 additions and 0 deletions.
diff --git a/EMS/common-bundle/src/Storage/StorageManager.php b/EMS/common-bundle/src/Storage/StorageManager.php
@@ -553,6 +553,13 @@ public function extractFromArchive(string $hash): TempDirectory
             case MimeTypes::APPLICATION_ZIP->value:
                 $tempDir = TempDirectory::createFromZipArchive($archiveFile->path);
                 break;
+            case MimeTypes::APPLICATION_JSON->value:
+                $archive = Archive::fromStructure($archiveFile->getContents(), $this->hashAlgo);
+                $tempDir = TempDirectory::create();
+                foreach ($archive->iterator() as $file) {
+                    $tempDir->add($this->getStream($file->getHash()), $file->getFilename());
+                }
+                break;
             default:
                 throw new \RuntimeException(\sprintf('Archive format %s not supported', $type));
         }

diff --git a/EMS/helpers/src/File/TempDirectory.php b/EMS/helpers/src/File/TempDirectory.php
@@ -4,6 +4,7 @@
 
 namespace EMS\Helpers\File;
 
+use Psr\Http\Message\StreamInterface;
 use Symfony\Component\Filesystem\Filesystem;
 use Symfony\Component\Finder\Finder;
 
@@ -78,4 +79,24 @@ public function moveTo(string $directory): void
             $this->filesystem->rename($file->getPathname(), $directory.\DIRECTORY_SEPARATOR.$file->getRelativePathname());
         }
     }
+
+    public function add(StreamInterface $stream, string $filename): void
+    {
+        $explodedPath = \explode(\DIRECTORY_SEPARATOR, $this->path.\DIRECTORY_SEPARATOR.$filename);
+        \array_pop($explodedPath);
+        $this->filesystem->mkdir(\implode(\DIRECTORY_SEPARATOR, $explodedPath));
+        if (!$handle = \fopen($this->path.\DIRECTORY_SEPARATOR.$filename, 'w')) {
+            throw new \RuntimeException(\sprintf('Can\'t open a temporary file %s', $this->path));
+        }
+
+        while (!$stream->eof()) {
+            if (false === \fwrite($handle, $stream->read(File::DEFAULT_CHUNK_SIZE))) {
+                throw new \RuntimeException(\sprintf('Can\'t write in temporary file %s', $this->path));
+            }
+        }
+
+        if (false === \fclose($handle)) {
+            throw new \RuntimeException(\sprintf('Can\'t close the temporary file %s', $this->path));
+        }
+    }
 }