From 1c1e5b02c1e4cb93947b791401408a5539178ef0 Mon Sep 17 00:00:00 2001
From: ghost <localhost>
Date: Fri, 6 Oct 2023 16:11:28 +0300
Subject: [PATCH] add torrents FS storage #11

---
 src/Service/TorrentService.php | 35 ++++++++++++++++++++++++----------
 1 file changed, 25 insertions(+), 10 deletions(-)

diff --git a/src/Service/TorrentService.php b/src/Service/TorrentService.php
index df14e9f..1a195b0 100644
--- a/src/Service/TorrentService.php
+++ b/src/Service/TorrentService.php
@@ -10,18 +10,23 @@ use App\Repository\TorrentRepository;
 use App\Repository\TorrentLocalesRepository;
 use App\Repository\TorrentSensitiveRepository;
 
+use Symfony\Component\HttpKernel\KernelInterface;
+use Symfony\Component\Filesystem\Filesystem;
+
 use Doctrine\ORM\EntityManagerInterface;
 
 class TorrentService
 {
-    private EntityManagerInterface $entityManager;
-    private ParameterBagInterface $parameterBagInterface;
+    private KernelInterface $kernelInterface;
+    private EntityManagerInterface $entityManagerInterface;
 
     public function __construct(
-        EntityManagerInterface $entityManager,
+        KernelInterface $kernelInterface,
+        EntityManagerInterface $entityManagerInterface
     )
     {
-        $this->entityManager = $entityManager;
+        $this->kernelInterface = $kernelInterface;
+        $this->entityManagerInterface = $entityManagerInterface;
     }
 
     public function decodeTorrentByFilepath(string $filepath): array
@@ -79,6 +84,16 @@ class TorrentService
           $this->getTorrentKeywordsByFilepath($filepath)
         );
 
+        $filesystem = new Filesystem();
+        $filesystem->copy(
+            $filepath,
+            sprintf(
+                '%s/var/torrents/%s.torrent',
+                $this->kernelInterface->getProjectDir(),
+                implode('/', str_split($torrent->getId()))
+            )
+        );
+
         if (!empty($locales))
         {
             $this->saveTorrentLocales(
@@ -111,8 +126,8 @@ class TorrentService
         $torrent->setFilename($filepath);
         $torrent->setKeywords($keywords);
 
-        $this->entityManager->persist($torrent);
-        $this->entityManager->flush();
+        $this->entityManagerInterface->persist($torrent);
+        $this->entityManagerInterface->flush();
 
         return $torrent;
     }
@@ -133,8 +148,8 @@ class TorrentService
         $torrentLocales->setValue($value);
         $torrentLocales->setApproved($approved);
 
-        $this->entityManager->persist($torrentLocales);
-        $this->entityManager->flush();
+        $this->entityManagerInterface->persist($torrentLocales);
+        $this->entityManagerInterface->flush();
 
         return $torrentLocales;
     }
@@ -155,8 +170,8 @@ class TorrentService
         $torrentSensitive->setValue($value);
         $torrentSensitive->setApproved($approved);
 
-        $this->entityManager->persist($torrentSensitive);
-        $this->entityManager->flush();
+        $this->entityManagerInterface->persist($torrentSensitive);
+        $this->entityManagerInterface->flush();
 
         return $torrentSensitive;
     }