feat: pauses & resumes downloads

src/Download/Action/Command/ResumeDownloadCommand.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace App\Download\Action\Command;
+
+use OneToMany\RichBundle\Contract\CommandInterface;
+
+/**
+ * @implements CommandInterface<ResumeDownloadCommand>
+ */
+class ResumeDownloadCommand implements CommandInterface
+{
+    public function __construct(
+        public int $downloadId,
+    ) {}
+}

src/Download/Action/Handler/DownloadMediaHandler.php

@@ -38,7 +38,9 @@ readonly class DownloadMediaHandler implements HandlerInterface
         }
 
         try {
-            $this->downloadRepository->updateStatus($download->getId(), 'In Progress');
+            if ($download->getStatus() !== 'Paused') {
+                $this->downloadRepository->updateStatus($download->getId(), 'In Progress');
+            }
 
             $this->downloader->download(
                 $command->mediaType,

src/Download/Action/Handler/PauseDownloadHandler.php

@@ -6,7 +6,6 @@ use App\Download\Action\Command\PauseDownloadCommand;
 use App\Download\Action\Result\PauseDownloadResult;
 use App\Download\Framework\Entity\Download;
 use App\Download\Framework\Repository\DownloadRepository;
-use App\Monitor\Service\MediaFiles;
 use OneToMany\RichBundle\Contract\CommandInterface;
 use OneToMany\RichBundle\Contract\HandlerInterface;
 use OneToMany\RichBundle\Contract\ResultInterface;
@@ -15,11 +14,8 @@ use Symfony\Contracts\Cache\CacheInterface;
 /** @implements HandlerInterface<PauseDownloadCommand, PauseDownloadResult> */
 readonly class PauseDownloadHandler implements HandlerInterface
 {
-    const PAUSED_EXTENSION = '.paused';
-
     public function __construct(
         private DownloadRepository $downloadRepository,
-        private MediaFiles $mediaFiles,
         private CacheInterface $cache,
     ) {}
 
@@ -32,8 +28,6 @@ readonly class PauseDownloadHandler implements HandlerInterface
             return true;
         });
 
-        $download->setFilename($download->getFilename() . self::PAUSED_EXTENSION);
-
         return new PauseDownloadResult(200, 'Success', $download);
     }
 }

src/Download/Action/Handler/ResumeDownloadHandler.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace App\Download\Action\Handler;
+
+use App\Download\Action\Command\DownloadMediaCommand;
+use App\Download\Action\Command\ResumeDownloadCommand;
+use App\Download\Action\Result\ResumeDownloadResult;
+use App\Download\Framework\Entity\Download;
+use App\Download\Framework\Repository\DownloadRepository;
+use OneToMany\RichBundle\Contract\CommandInterface;
+use OneToMany\RichBundle\Contract\HandlerInterface;
+use OneToMany\RichBundle\Contract\ResultInterface;
+use Symfony\Component\Messenger\MessageBusInterface;
+
+/** @implements HandlerInterface<ResumeDownloadCommand, ResumeDownloadResult> */
+readonly class ResumeDownloadHandler implements HandlerInterface
+{
+    public function __construct(
+        private DownloadRepository $downloadRepository,
+        private MessageBusInterface $messageBus,
+    ) {}
+
+    public function handle(CommandInterface $command): ResultInterface
+    {
+        /** @var Download $download */
+        $download = $this->downloadRepository->find($command->downloadId);
+
+        $this->messageBus->dispatch(new DownloadMediaCommand(
+            $download->getUrl(),
+            $download->getTitle(),
+            $download->getFilename(),
+            $download->getMediaType(),
+            $download->getImdbId(),
+            $download->getUser()->getId(),
+            $download->getId()
+        ));
+
+        return new ResumeDownloadResult(200, 'Success', $download);
+    }
+}

src/Download/Action/Input/ResumeDownloadInput.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace App\Download\Action\Input;
+
+use App\Download\Action\Command\PauseDownloadCommand;
+use OneToMany\RichBundle\Attribute\SourceRoute;
+use OneToMany\RichBundle\Contract\CommandInterface;
+use OneToMany\RichBundle\Contract\InputInterface;
+
+/** @implements InputInterface<PauseDownloadInput, PauseDownloadCommand> */
+class ResumeDownloadInput implements InputInterface
+{
+    public function __construct(
+        #[SourceRoute('downloadId')]
+        public int $downloadId,
+    ) {}
+
+    public function toCommand(): CommandInterface
+    {
+        return new PauseDownloadCommand(
+            $this->downloadId,
+        );
+    }
+}

src/Download/Action/Result/ResumeDownloadResult.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace App\Download\Action\Result;
+
+use App\Download\Framework\Entity\Download;
+use OneToMany\RichBundle\Contract\ResultInterface;
+
+/** @implements ResultInterface<ResumeDownloadResult> */
+class ResumeDownloadResult implements ResultInterface
+{
+    public function __construct(
+        public int $status,
+        public string $message,
+        public Download $download,
+    ) {}
+}

src/Download/Downloader/ProcessDownloader.php

@@ -5,12 +5,17 @@ namespace App\Download\Downloader;
 use App\Download\Framework\Entity\Download;
 use App\Monitor\Service\MediaFiles;
 use Doctrine\ORM\EntityManagerInterface;
+use Symfony\Component\Cache\Adapter\RedisAdapter;
 use Symfony\Component\Process\Exception\ProcessFailedException;
 use Symfony\Component\Process\Process;
 use Symfony\Contracts\Cache\CacheInterface;
 
 class ProcessDownloader implements DownloaderInterface
 {
+    /**
+     * @var RedisAdapter $cache
+     */
+
     public function __construct(
         private EntityManagerInterface $entityManager,
         private MediaFiles $mediaFiles,
@@ -24,16 +29,23 @@ class ProcessDownloader implements DownloaderInterface
     {
         /** @var Download $downloadEntity */
         $downloadEntity = $this->entityManager->getRepository(Download::class)->find($downloadId);
-        $downloadEntity->setProgress(0);
         $this->entityManager->flush();
 
         $downloadPreferences = $downloadEntity->getUser()->getDownloadPreferences();
         $path = $this->getDownloadPath($mediaType, $title, $downloadPreferences);
 
-        $process = (new Process([
-            'wget',
-            $url,
-        ]))->setWorkingDirectory($path);
+        $processArgs = ['wget', $url];
+
+        if ($downloadEntity->getStatus() === 'Paused') {
+            $downloadEntity->setStatus('In Progress');
+            $processArgs = ['wget', '-c', $url];
+        } else {
+            $downloadEntity->setProgress(0);
+        }
+
+        fwrite(STDOUT, implode(" ", $processArgs));
+
+        $process = (new Process($processArgs))->setWorkingDirectory($path);
 
         $process->setTimeout(1800); // 30 min
         $process->setIdleTimeout(600); // 10 min
@@ -48,10 +60,10 @@ class ProcessDownloader implements DownloaderInterface
                 // The PauseDownloadHandler will set this to 'true'
                 $doPause = $this->cache->getItem('download.pause.' . $downloadEntity->getId());
 
-                if (true === $doPause->isHit()) {
+                if (true === $doPause->isHit() && true === $doPause->get()) {
                     $downloadEntity->setStatus('Paused');
+                    $this->cache->deleteItem('download.pause.' . $downloadEntity->getId());
                     $this->entityManager->flush();
-                    $doPause->expiresAt(new \DateTimeImmutable('now'));
                     $process->stop();
                 }
 

src/Download/Framework/Controller/ApiController.php

@@ -4,9 +4,11 @@ namespace App\Download\Framework\Controller;
 
 use App\Download\Action\Handler\DeleteDownloadHandler;
 use App\Download\Action\Handler\PauseDownloadHandler;
+use App\Download\Action\Handler\ResumeDownloadHandler;
 use App\Download\Action\Input\DeleteDownloadInput;
 use App\Download\Action\Input\DownloadMediaInput;
 use App\Download\Action\Input\PauseDownloadInput;
+use App\Download\Action\Input\ResumeDownloadInput;
 use App\Download\Framework\Repository\DownloadRepository;
 use App\Util\Broadcaster;
 use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
@@ -68,7 +70,7 @@ class ApiController extends AbstractController
         return $this->json(['status' => 200, 'message' => 'Download Deleted']);
     }
 
-    #[Route('/api/download/{downloadId}', name: 'api_download_pause', methods: ['PUT'])]
+    #[Route('/api/download/{downloadId}/pause', name: 'api_download_pause', methods: ['PATCH'])]
     public function pauseDownload(
         PauseDownloadInput $input,
         PauseDownloadHandler $handler,
@@ -81,4 +83,18 @@ class ApiController extends AbstractController
 
         return $this->json(['status' => 200, 'message' => 'Download Paused']);
     }
+
+    #[Route('/api/download/{downloadId}/resume', name: 'api_download_resume', methods: ['PATCH'])]
+    public function resumeDownload(
+        ResumeDownloadInput $input,
+        ResumeDownloadHandler $handler,
+    ): Response {
+        $result = $handler->handle($input->toCommand());
+        $this->broadcaster->alert(
+            title: 'Success',
+            message: "{$result->download->getTitle()} has been Resumed.",
+        );
+
+        return $this->json(['status' => 200, 'message' => 'Download Resumed']);
+    }
 }