feat: movie download monitor

src/Controller/IndexController.php

@@ -2,7 +2,11 @@
 
 namespace App\Controller;
 
+use App\Download\Action\Command\MonitorMovieCommand;
+use App\Download\Action\Handler\MonitorMovieHandler;
+use App\Download\Framework\Entity\MovieMonitor;
 use App\Download\Framework\Repository\DownloadRepository;
+use App\Download\Framework\Repository\MovieMonitorRepository;
 use App\Tmdb\Tmdb;
 use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
 use Symfony\Component\HttpFoundation\Response;

src/Download/Action/Command/MonitorMovieCommand.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace App\Download\Action\Command;
+
+use App\Download\Framework\Entity\MovieMonitor;
+use OneToMany\RichBundle\Contract\CommandInterface;
+
+class MonitorMovieCommand implements CommandInterface
+{
+    public function __construct(
+        public int $movieMonitorId,
+    ) {}
+}

src/Download/Action/Handler/MonitorMovieHandler.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace App\Download\Action\Handler;
+
+use App\Download\Action\Command\DownloadMediaCommand;
+use App\Download\Action\Command\MonitorMovieCommand;
+use App\Download\Action\Result\MonitorMovieResult;
+use App\Download\Framework\Repository\MovieMonitorRepository;
+use App\Download\Service\MonitorOptionEvaluator;
+use App\Torrentio\Action\Command\GetMovieOptionsCommand;
+use App\Torrentio\Action\Handler\GetMovieOptionsHandler;
+use DateTimeImmutable;
+use OneToMany\RichBundle\Contract\CommandInterface;
+use OneToMany\RichBundle\Contract\HandlerInterface;
+use OneToMany\RichBundle\Contract\ResultInterface;
+use Symfony\Component\Messenger\MessageBusInterface;
+
+/** @implements HandlerInterface<MonitorMovieCommand> */
+readonly class MonitorMovieHandler implements HandlerInterface
+{
+    public function __construct(
+        private MovieMonitorRepository $movieMonitorRepository,
+        private GetMovieOptionsHandler $getMovieOptionsHandler,
+        private MonitorOptionEvaluator $monitorOptionEvaluator,
+        private MessageBusInterface $bus,
+    ) {}
+
+    public function handle(CommandInterface $command): ResultInterface
+    {
+        $monitor = $this->movieMonitorRepository->find($command->movieMonitorId);
+        $results = $this->getMovieOptionsHandler->handle(
+            new GetMovieOptionsCommand($monitor->getTmdbId(), $monitor->getImdbId())
+        );
+
+        $result = $this->monitorOptionEvaluator->evaluateOptions($monitor, $results->results);
+
+        if (null !== $result) {
+            $this->bus->dispatch(new DownloadMediaCommand(
+                $result->url,
+                $result->title,
+                $result->filename,
+                'movies',
+                $monitor->getImdbId(),
+            ));
+            $monitor->setStatus('Complete');
+            $monitor->setDownloadedAt(new DateTimeIMmutable());
+        }
+
+        $monitor->setLastSearch(new DateTimeImmutable());
+        $monitor->setSearchCount($monitor->getSearchCount() + 1);
+        $this->movieMonitorRepository->getEntityManager()->flush();
+
+        return new MonitorMovieResult(
+            status: 'OK',
+            result: [
+                'monitor' => $monitor,
+            ]
+        );
+    }
+}

src/Download/Action/Input/MonitorMovieInput.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace App\Download\Action\Input;
+
+use App\Download\Action\Command\MonitorMovieCommand;
+use OneToMany\RichBundle\Attribute\SourceRoute;
+use OneToMany\RichBundle\Contract\CommandInterface;
+use OneToMany\RichBundle\Contract\InputInterface;
+
+class MonitorMovieInput implements InputInterface
+{
+    public function __construct(
+        #[SourceRoute('tmdbId')]
+        public string $tmdbId,
+
+        #[SourceRoute('imdbId')]
+        public string $imdbId,
+    ) {}
+
+    public function toCommand(): CommandInterface
+    {
+        return new MonitorMovieCommand($this->tmdbId, $this->imdbId);
+    }
+}

src/Download/Action/Result/MonitorMovieResult.php

@@ -0,0 +1,13 @@
+<?php
+
+namespace App\Download\Action\Result;
+
+use OneToMany\RichBundle\Contract\ResultInterface;
+
+class MonitorMovieResult implements ResultInterface
+{
+    public function __construct(
+        public string $status,
+        public array $result,
+    ) {}
+}

src/Download/Framework/Entity/MovieMonitor.php

@@ -0,0 +1,158 @@
+<?php
+
+namespace App\Download\Framework\Entity;
+
+use App\Download\Framework\Repository\MovieMonitorRepository;
+use App\User\Framework\Entity\User;
+use Doctrine\DBAL\Types\Types;
+use Doctrine\ORM\Mapping as ORM;
+
+#[ORM\Entity(repositoryClass: MovieMonitorRepository::class)]
+class MovieMonitor
+{
+    #[ORM\Id]
+    #[ORM\GeneratedValue]
+    #[ORM\Column]
+    private ?int $id = null;
+
+    #[ORM\ManyToOne(inversedBy: 'yes')]
+    #[ORM\JoinColumn(nullable: false)]
+    private ?User $user = null;
+
+    #[ORM\Column(length: 255, nullable: true)]
+    private ?string $title = null;
+
+    #[ORM\Column(length: 255)]
+    private ?string $imdbId = null;
+
+    #[ORM\Column(length: 255)]
+    private ?string $tmdbId = null;
+
+    #[ORM\Column(length: 255)]
+    private ?string $status = null;
+
+    #[ORM\Column(nullable: true)]
+    private ?int $searchCount = null;
+
+    #[ORM\Column(type: Types::DATETIME_MUTABLE, nullable: true)]
+    private ?\DateTimeInterface $lastSearch = null;
+
+    #[ORM\Column]
+    private ?\DateTimeImmutable $createdAt = null;
+
+    #[ORM\Column(nullable: true)]
+    private ?\DateTimeImmutable $downloadedAt = null;
+
+    public function getId(): ?int
+    {
+        return $this->id;
+    }
+
+    public function getUser(): ?User
+    {
+        return $this->user;
+    }
+
+    public function setUser(?User $user): static
+    {
+        $this->user = $user;
+
+        return $this;
+    }
+
+    public function getTitle(): ?string
+    {
+        return $this->title;
+    }
+
+    public function setTitle(?string $title): static
+    {
+        $this->title = $title;
+
+        return $this;
+    }
+
+    public function getImdbId(): ?string
+    {
+        return $this->imdbId;
+    }
+
+    public function setImdbId(string $imdbId): static
+    {
+        $this->imdbId = $imdbId;
+
+        return $this;
+    }
+
+    public function getTmdbId(): ?string
+    {
+        return $this->tmdbId;
+    }
+
+    public function setTmdbId(string $tmdbId): static
+    {
+        $this->tmdbId = $tmdbId;
+
+        return $this;
+    }
+
+    public function getStatus(): ?string
+    {
+        return $this->status;
+    }
+
+    public function setStatus(string $status): static
+    {
+        $this->status = $status;
+
+        return $this;
+    }
+
+    public function getSearchCount(): ?int
+    {
+        return $this->searchCount;
+    }
+
+    public function setSearchCount(?int $searchCount): static
+    {
+        $this->searchCount = $searchCount;
+
+        return $this;
+    }
+
+    public function getLastSearch(): ?\DateTimeInterface
+    {
+        return $this->lastSearch;
+    }
+
+    public function setLastSearch(?\DateTimeInterface $lastSearch): static
+    {
+        $this->lastSearch = $lastSearch;
+
+        return $this;
+    }
+
+    public function getCreatedAt(): ?\DateTimeImmutable
+    {
+        return $this->createdAt;
+    }
+
+    public function setCreatedAt(\DateTimeImmutable $createdAt): static
+    {
+        $this->createdAt = $createdAt;
+
+        return $this;
+    }
+
+    public function getDownloadedAt(): ?\DateTimeImmutable
+    {
+        return $this->downloadedAt;
+    }
+
+    public function setDownloadedAt(?\DateTimeImmutable $downloadedAt): static
+    {
+        $this->downloadedAt = $downloadedAt;
+
+        return $this;
+    }
+}

src/Download/Framework/Repository/MovieMonitorRepository.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace App\Download\Framework\Repository;
+
+use App\Download\Framework\Entity\MovieMonitor;
+use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
+use Doctrine\Persistence\ManagerRegistry;
+
+/**
+ * @extends ServiceEntityRepository<MovieMonitor>
+ */
+class MovieMonitorRepository extends ServiceEntityRepository
+{
+    public function __construct(ManagerRegistry $registry)
+    {
+        parent::__construct($registry, MovieMonitor::class);
+    }
+
+//    /**
+//     * @return MovieMonitor[] Returns an array of MovieMonitor objects
+//     */
+//    public function findByExampleField($value): array
+//    {
+//        return $this->createQueryBuilder('m')
+//            ->andWhere('m.exampleField = :val')
+//            ->setParameter('val', $value)
+//            ->orderBy('m.id', 'ASC')
+//            ->setMaxResults(10)
+//            ->getQuery()
+//            ->getResult()
+//        ;
+//    }
+
+//    public function findOneBySomeField($value): ?MovieMonitor
+//    {
+//        return $this->createQueryBuilder('m')
+//            ->andWhere('m.exampleField = :val')
+//            ->setParameter('val', $value)
+//            ->getQuery()
+//            ->getOneOrNullResult()
+//        ;
+//    }
+}

src/Download/Service/MonitorOptionEvaluator.php

@@ -0,0 +1,91 @@
+<?php
+
+namespace App\Download\Service;
+
+use Aimeos\Map;
+use App\Download\Framework\Entity\MovieMonitor;
+use App\Torrentio\Result\TorrentioResult;
+
+class MonitorOptionEvaluator
+{
+    /**
+     * @param MovieMonitor $monitor
+     * @param TorrentioResult[] $results
+     * @return TorrentioResult|null
+     * @throws \Throwable
+     */
+    public function evaluateOptions(MovieMonitor $monitor, array $results): ?TorrentioResult
+    {
+        $sizeLow = 500;
+        $sizeHigh = 4096;
+
+        $bestMatches = [];
+        $matches = [];
+
+        $userPreferences = $monitor->getUser()->getUserPreferenceValues();
+
+        foreach ($results as $result) {
+            if (!in_array($userPreferences['language'], $result->languages)) {
+                continue;
+            }
+
+            if ($result->resolution === $userPreferences['resolution']
+                && $result->codec === $userPreferences['codec']
+            ) {
+                $bestMatches[] = $result;
+            }
+
+            if ($userPreferences['resolution'] === '2160p'
+                && $userPreferences['codec'] === $result->codec
+                && $result->resolution === '1080p'
+            ) {
+                $matches[] = $result;
+            }
+
+            if ($userPreferences['codec'] === 'h264'
+                && $userPreferences['resolution'] === $result->resolution
+                && $result->codec === 'h265'
+            ) {
+                $matches[] = $result;
+            }
+        }
+
+        $sizeMatches = [];
+
+        foreach ($bestMatches as $result) {
+            $size = 0;
+            if (str_contains($result->size, 'GB')) {
+                $size = (int) trim(str_replace('GB', '', $result->size)) * 1024;
+            } else {
+                $size = (int) trim(str_replace('MB', '', $result->size));
+            }
+
+            if ($size > $sizeLow && $size < $sizeHigh) {
+                $sizeMatches[] = $result;
+            }
+        }
+
+        if (!empty($sizeMatches)) {
+            return Map::from($sizeMatches)->usort(fn($a, $b) => $a->seeders <=> $b->seeders)->last();
+        }
+
+        foreach ($matches as $result) {
+            $size = 0;
+            if (str_contains($result->size, 'GB')) {
+                $size = (int) trim(str_replace('GB', '', $result->size)) * 1024;
+            } else {
+                $size = (int) trim(str_replace('MB', '', $result->size));
+            }
+
+            if ($size > $sizeLow && $size < $sizeHigh) {
+                $sizeMatches[] = $result;
+            }
+        }
+
+        if (!empty($sizeMatches)) {
+            return Map::from($sizeMatches)->usort(fn($a, $b) => $a->seeders <=> $b->seeders)->last();
+        }
+
+        return null;
+    }
+}

src/Torrentio/Result/ResultFactory.php

@@ -8,6 +8,14 @@ use Nihilarr\PTN;
 
 class ResultFactory
 {
+    public static $codecMap = [
+        'h264' => 'h264',
+        'h265' => 'h265',
+        'x264' => 'h264',
+        'x265' => 'h265',
+        '-' => '-'
+    ];
+
     public static function map(
         string $url,
         string $title,
@@ -25,7 +33,7 @@ class ResultFactory
             $ptn->season ?? "-",
             $bingeGroup,
             $ptn->resolution ?? "-",
-            $ptn->codec ?? "-",
+            self::setCodec($ptn->codec ?? "-"),
             $ptn,
             substr(base64_encode($url), strlen($url) - 10),
             $ptn->episode ?? "-",
@@ -101,6 +109,11 @@ class ResultFactory
         }
     }
 
+    public static function setCodec(string $codec): string
+    {
+        return self::$codecMap[strtolower($codec)] ?? $codec;
+    }
+
     private static function setEpisode(string $title)
     {
         $value = [];

src/User/Framework/Entity/User.php

@@ -3,7 +3,7 @@
 namespace App\User\Framework\Entity;
 
 use Aimeos\Map;
-use App\User\Framework\Repository\PreferencesRepository;
+use App\Download\Framework\Entity\MovieMonitor;
 use App\User\Framework\Repository\UserRepository;
 use Doctrine\Common\Collections\ArrayCollection;
 use Doctrine\Common\Collections\Collection;
@@ -40,9 +40,16 @@ class User implements UserInterface, PasswordAuthenticatedUserInterface
     #[ORM\OneToMany(targetEntity: UserPreference::class, mappedBy: 'user', cascade: ['persist', 'remove'])]
     private Collection $userPreferences;
 
+    /**
+     * @var Collection<int, MovieMonitor>
+     */
+    #[ORM\OneToMany(targetEntity: MovieMonitor::class, mappedBy: 'user', orphanRemoval: true)]
+    private Collection $yes;
+
     public function __construct()
     {
         $this->userPreferences = new ArrayCollection();
+        $this->yes = new ArrayCollection();
     }
 
     public function getId(): ?int
@@ -204,4 +211,34 @@ class User implements UserInterface, PasswordAuthenticatedUserInterface
             })
             ->toArray();
     }
+
+    /**
+     * @return Collection<int, MovieMonitor>
+     */
+    public function getYes(): Collection
+    {
+        return $this->yes;
+    }
+
+    public function addYe(MovieMonitor $ye): static
+    {
+        if (!$this->yes->contains($ye)) {
+            $this->yes->add($ye);
+            $ye->setUser($this);
+        }
+
+        return $this;
+    }
+
+    public function removeYe(MovieMonitor $ye): static
+    {
+        if ($this->yes->removeElement($ye)) {
+            // set the owning side to null (unless already changed)
+            if ($ye->getUser() === $this) {
+                $ye->setUser(null);
+            }
+        }
+
+        return $this;
+    }
 }