wip: semi-working PHP8.5/FrankenPHP w/ async

.gitignore

@@ -18,3 +18,4 @@ bolt.db
 ###> phpstan/phpstan ###
 phpstan.neon
 ###< phpstan/phpstan ###
+.php-cs-fixer.cache

Dockerfile

@@ -1,16 +1,17 @@
-FROM dunglas/frankenphp:php8.4
+FROM registry.caldwell.digital/home/frankenphp:1.9.0-php8.5.0-ubuntu
 
 ENV SERVER_NAME=":80"
 ENV CADDY_GLOBAL_OPTIONS="auto_https off"
 ENV APP_RUNTIME="Runtime\\FrankenPhpSymfony\\Runtime"
 ENV APP_VERSION="0.0.1"
+ENV SERVER_ROOT="/app/public"
 
-RUN install-php-extensions \
-	pdo_mysql \
-	gd \
-	intl \
-	zip \
-	opcache
+#RUN install-php-extensions \
+#	pdo_mysql \
+#	gd \
+#	intl \
+#	zip \
+#	opcache
 
 RUN apt update && apt install -y wget
 

assets/app.js

@@ -6,6 +6,7 @@ import './bootstrap.js';
  * which should already be in your base.html.twig.
  */
 import './styles/app.css';
+import PullToRefresh from 'pulltorefreshjs';
 
 console.log('This log comes from assets/app.js - welcome to AssetMapper! 🎉');
 
@@ -18,3 +19,10 @@ var observer = new MutationObserver(function(mutations) {
 
 observer.observe(document, {attributes: false, childList: true, characterData: false, subtree:true});
 
+const ptr = PullToRefresh.init({
+    mainElement: 'body',
+    onRefresh() {
+        window.location.reload();
+    }
+});
+

assets/controllers/download_list_controller.js

@@ -7,7 +7,7 @@ import { getComponent } from '@symfony/ux-live-component';
 
 /* stimulusFetch: 'lazy' */
 export default class extends Controller {
-    static targets = ['download']
+    static targets = ['download', 'deleteFileInput']
 
     async initialize() {
         this.component = await getComponent(this.element);
@@ -42,7 +42,8 @@ export default class extends Controller {
     }
 
     deleteDownload(data) {
-        fetch(`/api/download/${data.params.id}`, {method: 'DELETE'})
+        const deleteFileInput = document.querySelector(`#delete_file_${data.params.id}`)
+        fetch(`/api/download/${data.params.id}?deleteFile=${deleteFileInput.checked}`, {method: 'DELETE'})
             .then(res => res.json())
             .then(json => console.debug(json));
     }

assets/controllers/movie_results_controller.js

@@ -20,24 +20,19 @@ export default class extends Controller {
 
     options = []
     optionsLoaded = false
+    resultCountEl = null
 
     async connect() {
-        await this.setOptions();
+        this.resultCountEl = document.querySelector('#movie_results_count');
     }
 
-    async setOptions() {
-        if (false === this.optionsLoaded) {
-            this.optionsLoaded = true;
-            await fetch(`/torrentio/movies/${this.tmdbIdValue}/${this.imdbIdValue}`)
-                .then(res => res.text())
-                .then(response => {
-                    this.element.innerHTML = response;
-                    this.options = this.element.querySelectorAll('tbody tr');
-                    this.options.forEach((option) => option.querySelector('.download-btn').dataset['title'] = this.titleValue);
-                    this.dispatch('optionsLoaded', {detail: {options: this.options}})
-                    this.loadingIconOutlet.toggleIcon();
-                });
-        }
+    async listTargetConnected() {
+        this.optionsLoaded = true;
+        this.options = this.element.querySelectorAll('tbody tr');
+        this.options.forEach((option) => option.querySelector('.download-btn').dataset['title'] = this.titleValue);
+        this.dispatch('optionsLoaded', {detail: {options: this.options}})
+        this.loadingIconOutlet.toggleIcon();
+        this.resultCountEl.innerText = this.options.length;
     }
 
     // Keeps compatible with Filter & TV Shows
@@ -102,5 +97,6 @@ export default class extends Controller {
                 count = count + 1;
             }
         });
+        this.resultCountEl.innerText = count;
     }
 }

assets/controllers/tv_results_controller.js

@@ -25,37 +25,18 @@ export default class extends Controller {
     optionsLoaded = false
     isOpen = false
 
-    async connect() {
-        await this.setOptions();
-    }
-
-    async setOptions() {
-        if (this.optionsLoaded === false) {
-            this.optionsLoaded = true;
-            let response;
-
-            try {
-                response = await fetch(`/torrentio/tvshows/${this.tmdbIdValue}/${this.imdbIdValue}/${this.seasonValue}/${this.episodeValue}`)
-            } catch (error) {
-                console.log('There was an error', error);
-            }
-
-            if (response?.ok) {
-                response = await response.text()
-                this.listContainerTarget.innerHTML = response;
-                this.options = this.element.querySelectorAll('tbody tr');
-                if (this.options.length > 0) {
-                    this.options.forEach((option) => option.querySelector('.download-btn').dataset['title'] = this.titleValue);
-                    this.options[0].querySelector('input[type="checkbox"]').checked = true;
-                } else {
-                    this.countTarget.innerText = 0;
-                    this.episodeSelectorTarget.disabled = true;
-                }
-                this.dispatch('optionsLoaded', {detail: {options: this.options}})
-                this.loadingIconOutlet.increaseCount();
-            } else {
-                console.log(`HTTP Response Code: ${response?.status}`)
-            }
+    async listTargetConnected() {
+        this.options = this.element.querySelectorAll('tbody tr');
+        if (this.options.length > 0) {
+            this.options.forEach((option) =>
+                option.querySelector('.download-btn').dataset['title'] = this.titleValue
+            );
+            this.options[0].querySelector('input[type="checkbox"]').checked = true;
+            this.dispatch('optionsLoaded', {detail: {options: this.options}})
+            this.loadingIconOutlet.increaseCount();
+        } else {
+            this.countTarget.innerText = 0;
+            this.episodeSelectorTarget.disabled = true;
         }
     }
 
@@ -134,6 +115,7 @@ export default class extends Controller {
                 "codec": option.querySelector('#codec').textContent.trim(),
                 "provider": option.querySelector('#provider').textContent.trim(),
                 "languages": JSON.parse(option.dataset['languages']),
+                "quality": option.dataset['quality'],
             }
 
             let include = true;

bash/caddy/Caddyfile

@@ -1,6 +1,11 @@
-dev.caldwell.digital:443
+{
+    log {
+        level DEBUG
+    }
+}
 
-tls /etc/ssl/wildcard.crt /etc/ssl/wildcard.pem
-
-reverse_proxy app:80
+dev.caldwell.digital:443 {
+    tls /etc/ssl/wildcard.crt /etc/ssl/wildcard.pem
 
+    reverse_proxy app:80
+}

compose.yml

@@ -2,6 +2,7 @@ services:
   caddy:
     image: caddy:2.9.1
     restart: unless-stopped
+    tty: true
     cap_add:
       - NET_ADMIN
     ports:
@@ -22,6 +23,9 @@ services:
       - mercure_data:/data
       - mercure_config:/config
     tty: true
+    ports:
+      - "8001:80"
+    command: "frankenphp php-server --root=/app/public"
     environment:
       TZ: America/Chicago
       MERCURE_PUBLISHER_JWT_KEY: '!ChangeThisMercureHubJWTSecretKey!'

config/routes.yaml

@@ -6,6 +6,14 @@ controllersBase:
     defaults:
         schemes: [ 'https' ]
 
+controllersLibrary:
+    resource:
+        path: ../src/Library/Framework/Controller/
+        namespace: App\Library\Framework\Controller
+    type: attribute
+    defaults:
+        schemes: [ 'https' ]
+
 controllersSearch:
     resource:
         path: ../src/Search/Framework/Controller/

docker/app/Caddyfile

@@ -3,6 +3,8 @@
 
 	frankenphp {
 		{$FRANKENPHP_CONFIG}
+		num_threads 10
+		max_threads 20
 	}
 }
 

importmap.php

@@ -64,4 +64,7 @@ return [
         'version' => '2.4.3',
         'type' => 'css',
     ],
+    'pulltorefreshjs' => [
+        'version' => '0.1.22',
+    ],
 ];

public/test.php

@@ -0,0 +1,60 @@
+<?php
+
+require_once '../vendor/autoload.php';
+
+use App\Torrentio\Result\ResultFactory;
+
+$realDebridKey = "";
+$tasks = [];
+$results = [];
+$start = microtime(true);
+for ($i = 1; $i <= 20; $i++) {
+    $tasks[] = \Async\spawn(function () use ($i, &$results, &$realDebridKey) {
+        $baseUrl = "https://torrentio.strem.fun/providers%253Dyts%252Ceztv%252Crarbg%252C1337x%252Cthepiratebay%252Ckickasstorrents%252Ctorrentgalaxy%252Cmagnetdl%252Chorriblesubs%252Cnyaasi%7Csort%253Dqualitysize%7Cqualityfilter%253D480p%252Cscr%252Ccam%7Crealdebrid={$realDebridKey}/stream/movie/tt0412142:1:$i.json";
+        $options = \json_decode(file_get_contents($baseUrl), true);
+
+        foreach ($options['streams'] as $stream) {
+            if (!str_starts_with($stream['url'], "https")) {
+                continue;
+            }
+
+            if (
+                array_key_exists('behaviorHints', $stream) &&
+                array_key_exists('bingeGroup', $stream['behaviorHints'])
+            ) {
+                $bingeGroup = $stream['behaviorHints']['bingeGroup'];
+            } else {
+                $bingeGroup = '-';
+            }
+
+            $result = ResultFactory::map(
+                $stream['url'],
+                $stream['title'],
+                $bingeGroup
+            );
+
+            $results[] = $result;
+        }
+    });
+}
+\Async\awaitAll($tasks);
+$end = microtime(true) - $start;
+dd($end, $results);
+
+//
+//
+//// Spawn multiple concurrent coroutines
+//Async\spawn(function() {
+//    echo "Starting coroutine 1\n";
+//    sleep(2); // Non-blocking in async context
+//    echo "Coroutine 1 completed\n";
+//});
+//
+//Async\spawn(function() {
+//    echo "Starting coroutine 2\n";
+//    sleep(1); // Non-blocking in async context
+//    echo "Coroutine 2 completed\n";
+//});
+//
+//echo "All coroutines started\n";
+

src/Base/Service/MediaFiles.php

@@ -5,6 +5,7 @@ namespace App\Base\Service;
 use Aimeos\Map;
 use App\Download\Framework\Entity\Download;
 use Nihilarr\PTN;
+use Psr\Log\LoggerInterface;
 use Symfony\Component\DependencyInjection\Attribute\Autowire;
 use Symfony\Component\Filesystem\Filesystem;
 use Symfony\Component\Finder\Finder;
@@ -21,6 +22,7 @@ class MediaFiles
     private string $tvShowsPath;
 
     private Filesystem $filesystem;
+    private LoggerInterface $logger;
 
     public function __construct(
         #[Autowire(param: 'media.base_path')]
@@ -33,12 +35,14 @@ class MediaFiles
         string $tvShowsPath,
 
         Filesystem $filesystem,
+        LoggerInterface $logger,
     ) {
         $this->finder = new Finder();
         $this->basePath = $basePath;
         $this->moviesPath = $moviesPath;
         $this->tvShowsPath = $tvShowsPath;
         $this->filesystem = $filesystem;
+        $this->logger = $logger;
     }
 
     public function getPathByType(string $mediaType): string
@@ -140,7 +144,7 @@ class MediaFiles
         return $path;
     }
 
-    public function episodeExists(string $tvshowTitle, int $seasonNumber, int $episodeNumber)
+    public function episodeExists(string $tvshowTitle, int $seasonNumber, int $episodeNumber): SplFileInfo|false
     {
         $existingEpisodes = $this->getEpisodes($tvshowTitle, false);
 
@@ -220,4 +224,26 @@ class MediaFiles
     {
         $this->filesystem->chmod($filepath, $permissions);
     }
+
+    /**
+     * @param string $filepath
+     * @return bool
+     * Returns true if file was deleted
+     * Returns false is file not found or was not deleted
+     */
+    public function removeFile(string $filepath): bool
+    {
+        if (true === $this->filesystem->exists($filepath)) {
+            try {
+                $this->filesystem->remove($filepath);
+                return true;
+            } catch (\Throwable $exception) {
+                $this->logger->error($exception->getMessage(), ['file' => $filepath]);
+                return false;
+            }
+        }
+
+        $this->logger->warning('> [MediaFiles] Attempted to remove file, but it did not exist.', ['file' => $filepath]);
+        return false;
+    }
 }

src/Download/Action/Command/DeleteDownloadCommand.php

@@ -11,5 +11,6 @@ class DeleteDownloadCommand implements CommandInterface
 {
     public function __construct(
         public int $downloadId,
+        public bool $deleteFile = false,
     ) {}
 }

src/Download/Action/Handler/DeleteDownloadHandler.php

@@ -5,6 +5,8 @@ namespace App\Download\Action\Handler;
 use App\Download\Action\Command\DeleteDownloadCommand;
 use App\Download\Action\Result\DeleteDownloadResult;
 use App\Download\Framework\Repository\DownloadRepository;
+use App\Library\Action\Command\DeleteMediaFileCommand;
+use App\Library\Action\Handler\DeleteMediaFileHandler;
 use OneToMany\RichBundle\Contract\CommandInterface;
 use OneToMany\RichBundle\Contract\HandlerInterface;
 use OneToMany\RichBundle\Contract\ResultInterface;
@@ -14,13 +16,26 @@ readonly class DeleteDownloadHandler implements HandlerInterface
 {
     public function __construct(
         private DownloadRepository $downloadRepository,
+        private DeleteMediaFileHandler $deleteMediaFileHandler,
     ) {}
 
     public function handle(CommandInterface $command): ResultInterface
     {
         $download = $this->downloadRepository->find($command->downloadId);
+
+        if (true === $command->deleteFile) {
+            $deletedFileResult = $this->deleteMediaFileHandler->handle(new DeleteMediaFileCommand(
+                filename: $download->getFilename(),
+                downloadId: $command->downloadId
+            ));
+        }
         $this->downloadRepository->delete($command->downloadId);
 
-        return new DeleteDownloadResult(200, 'Success', $download);
+        return new DeleteDownloadResult(
+            status: 200,
+            message: 'Success',
+            download: $download,
+            deleteMediaFileResult: $deletedFileResult ?? null
+        );
     }
 }

src/Download/Action/Input/DeleteDownloadInput.php

@@ -3,6 +3,7 @@
 namespace App\Download\Action\Input;
 
 use App\Download\Action\Command\DeleteDownloadCommand;
+use OneToMany\RichBundle\Attribute\SourceQuery;
 use OneToMany\RichBundle\Attribute\SourceRoute;
 use OneToMany\RichBundle\Contract\CommandInterface;
 use OneToMany\RichBundle\Contract\InputInterface;
@@ -13,12 +14,15 @@ class DeleteDownloadInput implements InputInterface
     public function __construct(
         #[SourceRoute('downloadId')]
         public int $downloadId,
+        #[SourceQuery('deleteFile')]
+        public bool $deleteFile = false,
     ) {}
 
     public function toCommand(): CommandInterface
     {
         return new DeleteDownloadCommand(
             $this->downloadId,
+            $this->deleteFile,
         );
     }
 }

src/Download/Action/Result/DeleteDownloadResult.php

@@ -12,5 +12,6 @@ class DeleteDownloadResult implements ResultInterface
         public int $status,
         public string $message,
         public Download $download,
+        public ?DeleteMediaFileResult $deleteMediaFileResult = null,
     ) {}
 }

src/Download/Action/Result/DeleteMediaFileResult.php

@@ -0,0 +1,14 @@
+<?php
+
+namespace App\Download\Action\Result;
+
+use OneToMany\RichBundle\Contract\ResultInterface;
+
+class DeleteMediaFileResult implements ResultInterface
+{
+    public function __construct(
+        public string $message,
+        public string $filepath,
+        public bool $isDeleted,
+    ) {}
+}

src/Download/Framework/Controller/ApiController.php

@@ -66,7 +66,7 @@ class ApiController extends AbstractController
             message: "{$result->download->getTitle()} has been deleted.",
         );
 
-        return $this->json(['status' => 200, 'message' => 'Download Deleted']);
+        return $this->json($result);
     }
 
     #[Route('/api/download/{downloadId}/pause', name: 'api_download_pause', methods: ['PATCH'])]

src/Download/Framework/Entity/Download.php

@@ -7,6 +7,7 @@ use App\User\Framework\Entity\User;
 use Doctrine\ORM\Mapping as ORM;
 use Gedmo\Timestampable\Traits\TimestampableEntity;
 use Nihilarr\PTN;
+use Symfony\Component\Serializer\Attribute\Ignore;
 use Symfony\UX\Turbo\Attribute\Broadcast;
 
 #[ORM\Entity(repositoryClass: DownloadRepository::class)]
@@ -44,6 +45,7 @@ class Download
     #[ORM\Column(length: 255, nullable: true)]
     private ?string $episodeId = null;
 
+    #[Ignore]
     #[ORM\ManyToOne(inversedBy: 'downloads')]
     private ?User $user = null;
 

src/Library/Action/Command/DeleteMediaFileCommand.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace App\Library\Action\Command;
+
+use OneToMany\RichBundle\Contract\CommandInterface;
+
+/**
+ * @implements CommandInterface<DeleteMediaFileCommand>
+ */
+class DeleteMediaFileCommand implements CommandInterface
+{
+    public function __construct(
+        public string $filename,
+        public ?int $downloadId = null,
+    ) {}
+}

src/Library/Action/Command/LibrarySearchCommand.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace App\Library\Action\Command;
+
+use OneToMany\RichBundle\Contract\CommandInterface;
+
+class LibrarySearchCommand implements CommandInterface
+{
+    public function __construct(
+        public ?string $term = null,
+        public ?string $title = null,
+        public ?string $imdbId = null,
+        public ?string $season = null,
+        public ?string $episode = null,
+    ) {}
+}

src/Library/Action/Handler/DeleteMediaFileHandler.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace App\Library\Action\Handler;
+
+use App\Base\Service\MediaFiles;
+use App\Download\Action\Result\DeleteMediaFileResult;
+use App\Download\Framework\Entity\Download;
+use App\Download\Framework\Repository\DownloadRepository;
+use App\Library\Action\Command\DeleteMediaFileCommand;
+use OneToMany\RichBundle\Contract\CommandInterface;
+use OneToMany\RichBundle\Contract\HandlerInterface;
+use OneToMany\RichBundle\Contract\ResultInterface;
+
+/**
+ * @implements HandlerInterface<DeleteMediaFileCommand,DeleteMediaFileResult>
+ */
+class DeleteMediaFileHandler implements HandlerInterface
+{
+    public function __construct(
+        private readonly DownloadRepository $downloadRepository,
+        private readonly MediaFiles $mediaFiles,
+    ) {}
+
+    public function handle(CommandInterface $command): ResultInterface
+    {
+        /** @var Download $downloadRecord */
+        $downloadRecord = $this->downloadRepository->find($command->downloadId);
+        $filepath = $this->getFullFilepath($downloadRecord);
+        $result = $this->mediaFiles->removeFile($filepath);
+
+        return new DeleteMediaFileResult(
+            message: true === $result ? 'File removed' : 'File not removed',
+            filepath: $filepath,
+            isDeleted: $result
+        );
+    }
+
+    private function getFullFilepath(Download $download): string
+    {
+        return $this->mediaFiles->getPathByType($download->getMediaType()) . DIRECTORY_SEPARATOR . $download->getFilename();
+    }
+}

src/Library/Action/Handler/LibrarySearchHandler.php

@@ -0,0 +1,83 @@
+<?php
+
+namespace App\Library\Action\Handler;
+
+use App\Base\Service\MediaFiles;
+use App\Library\Action\Command\LibrarySearchCommand;
+use App\Library\Action\Result\LibrarySearchResult;
+use App\Library\Dto\MediaFileDto;
+use Nihilarr\PTN;
+use OneToMany\RichBundle\Contract\CommandInterface;
+use OneToMany\RichBundle\Contract\HandlerInterface;
+use OneToMany\RichBundle\Contract\ResultInterface;
+
+/**
+ * @implements HandlerInterface<LibrarySearchCommand,LibrarySearchHandler>
+ */
+class LibrarySearchHandler implements HandlerInterface
+{
+    private array $searchTypes = [
+        'episode_by_title' => 'episodeByTitle',
+        'movie_by_title' => 'movieByTitle',
+    ];
+
+    public function __construct(
+        private readonly MediaFiles $mediaFiles,
+    ) {}
+
+    public function handle(CommandInterface $command): ResultInterface
+    {
+        $searchType = $this->getSearchType($command);
+        $function   = $this->searchTypes[$searchType];
+        return $this->$function($command);
+    }
+
+    private function getSearchType(CommandInterface $command): ?string
+    {
+        if (!is_null($command->title) &&
+            is_null($command->imdbId) &&
+            is_null($command->season) &&
+            is_null($command->episode)
+        ) {
+            return 'movie_by_title';
+        }
+
+        if ((!is_null($command->title) || is_null($command->imdbId)) &&
+            !is_null($command->season) &&
+            !is_null($command->episode)
+        ) {
+            return 'episode_by_title';
+        }
+        return null;
+    }
+
+    private function episodeByTitle(CommandInterface $command): ?LibrarySearchResult
+    {
+        $result = $this->mediaFiles->episodeExists(
+            $command->title,
+            (int) $command->season,
+            (int) $command->episode,
+        );
+        $exists =  $result instanceof \SplFileInfo;
+
+        return new LibrarySearchResult(
+            input: $command,
+            exists: $exists,
+            file: true === $exists ? MediaFileDto::fromSplFileInfo($result) : null,
+            ptn: true === $exists ? (object) new PTN()->parse($result->getFilename()) : null,
+        );
+    }
+
+    private function movieByTitle(CommandInterface $command): ?LibrarySearchResult
+    {
+        $result = $this->mediaFiles->movieExists($command->title);
+        $exists =  $result instanceof \SplFileInfo;
+
+        return new LibrarySearchResult(
+            input: $command,
+            exists: $exists,
+            file: true === $exists ? MediaFileDto::fromSplFileInfo($result) : null,
+            ptn: true === $exists ? (object) new PTN()->parse($result->getFilename()) : null,
+        );
+    }
+}

src/Library/Action/Input/DeleteMediaFileInput.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace App\Library\Action\Input;
+
+use App\Library\Action\Command\DeleteMediaFileCommand;
+use OneToMany\RichBundle\Attribute\SourceRequest;
+use OneToMany\RichBundle\Contract\CommandInterface;
+use OneToMany\RichBundle\Contract\InputInterface;
+
+/**
+ * @implements InputInterface<DeleteMediaFileInput,DeleteMediaFileCommand>
+ */
+class DeleteMediaFileInput implements InputInterface
+{
+    public function __construct(
+        #[SourceRequest('filename')]
+        public string $filename,
+        #[SourceRequest('downloadId', nullify: true)]
+        public ?int $downloadId = null,
+    ) {}
+
+    public function toCommand(): CommandInterface
+    {
+        return new DeleteMediaFileCommand(
+            $this->filename,
+            $this->downloadId,
+        );
+    }
+}

src/Library/Action/Input/LibrarySearchInput.php

@@ -0,0 +1,38 @@
+<?php
+
+namespace App\Library\Action\Input;
+
+use App\Library\Action\Command\LibrarySearchCommand;
+use OneToMany\RichBundle\Attribute\SourceQuery;
+use OneToMany\RichBundle\Contract\CommandInterface;
+use OneToMany\RichBundle\Contract\InputInterface;
+
+/**
+ * @implements InputInterface<LibrarySearchInput, LibrarySearchCommand>
+ */
+class LibrarySearchInput implements InputInterface
+{
+    public function __construct(
+        #[SourceQuery('term', nullify: true)]
+        private ?string $term = null,
+        #[SourceQuery('title', nullify: true)]
+        private ?string $title = null,
+        #[SourceQuery('imdbId', nullify: true)]
+        private ?string $imdbId = null,
+        #[SourceQuery('season', nullify: true)]
+        private ?string $season = null,
+        #[SourceQuery('episode', nullify: true)]
+        private ?string $episode = null,
+    ) {}
+
+    public function toCommand(): CommandInterface
+    {
+        return new LibrarySearchCommand(
+            term: $this->term,
+            title: $this->title,
+            imdbId: $this->imdbId,
+            season: $this->season,
+            episode: $this->episode,
+        );
+    }
+}

src/Library/Action/Result/DeleteMediaFileResult.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace App\Library\Action\Result;
+
+use OneToMany\RichBundle\Contract\ResultInterface;
+
+/**
+ * @implements ResultInterface
+ */
+class DeleteMediaFileResult implements ResultInterface
+{
+    public function __construct(
+        public string $status,
+    ) {}
+}

src/Library/Action/Result/LibrarySearchResult.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace App\Library\Action\Result;
+
+use App\Library\Dto\MediaFileDto;
+use OneToMany\RichBundle\Contract\ResultInterface;
+
+class LibrarySearchResult implements ResultInterface
+{
+    public function __construct(
+        public object|array $input,
+        public bool $exists,
+        public ?MediaFileDto $file = null,
+        public ?object $ptn = null,
+    ) {}
+}

src/Library/Dto/MediaFileDto.php

@@ -0,0 +1,23 @@
+<?php
+
+namespace App\Library\Dto;
+
+readonly class MediaFileDto
+{
+    public function __construct(
+        public string $path,
+        public string $filename,
+        public string $extension,
+        public string $size,
+    ) {}
+
+    public static function fromSplFileInfo(\SplFileInfo|false $fileInfo): self|false
+    {
+        return false === $fileInfo ? false : new static(
+            path: $fileInfo->getRealPath(),
+            filename: $fileInfo->getFilename(),
+            extension: $fileInfo->getExtension(),
+            size: $fileInfo->getSize(),
+        );
+    }
+}

src/Library/Framework/Controller/Api.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace App\Library\Framework\Controller;
+
+use App\Library\Action\Handler\LibrarySearchHandler;
+use App\Library\Action\Input\LibrarySearchInput;
+use App\Library\Action\Result\LibrarySearchResult;
+use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\Routing\Attribute\Route;
+use Symfony\UX\Turbo\TurboBundle;
+
+class Api extends AbstractController
+{
+    #[Route('/api/library/search', name: 'api.library.search', methods: ['GET'])]
+    public function search(LibrarySearchInput $input, LibrarySearchHandler $handler, Request $request): Response
+    {
+        $result = $handler->handle($input->toCommand());
+
+        if ($request->headers->get('Turbo-Frame')) {
+            return $this->sendFragmentResponse($result, $request);
+        }
+
+        return $this->json($handler->handle($input->toCommand()));
+    }
+
+    private function sendFragmentResponse(LibrarySearchResult $result, Request $request): Response
+    {
+        $request->setRequestFormat(TurboBundle::STREAM_FORMAT);
+        return $this->renderBlock(
+            'search/fragments.html.twig',
+            $request->query->get('block'),
+            [
+                'result' => $result,
+                'target' => $request->query->get('target')
+            ]
+        );
+    }
+}

src/Search/Action/Handler/GetMediaInfoHandler.php

@@ -2,7 +2,6 @@
 
 namespace App\Search\Action\Handler;
 
-use App\Base\Service\MediaFiles;
 use App\Search\Action\Command\GetMediaInfoCommand;
 use App\Search\Action\Result\GetMediaInfoResult;
 use App\Tmdb\Tmdb;
@@ -15,19 +14,12 @@ class GetMediaInfoHandler implements HandlerInterface
 {
     public function __construct(
         private readonly Tmdb $tmdb,
-        private readonly MediaFiles $mediaFiles
     ) {}
 
     public function handle(CommandInterface $command): ResultInterface
     {
         $media = $this->tmdb->mediaDetails($command->imdbId, $command->mediaType);
 
-        if ("tvshows" === $command->mediaType) {
-            foreach ($media->episodes[$command->season] as $key => $episode) {
-                $media->episodes[$command->season][$key]['file'] = $this->mediaFiles->episodeExists($media->title, $command->season, $episode['episode_number']);
-            }
-        }
-
         return new GetMediaInfoResult($media, $command->season);
     }
 }

src/Search/Framework/Command/SearchCommand.php

@@ -0,0 +1,213 @@
+<?php
+
+namespace App\Search\Framework\Command;
+
+use Aimeos\Map;
+use App\Download\Action\Command\DownloadMediaCommand;
+use App\Download\Action\Handler\DownloadMediaHandler;
+use App\Download\Framework\Repository\DownloadRepository;
+use App\Search\Action\Handler\SearchHandler;
+use App\Search\Action\Command\SearchCommand as CommandInput;
+use App\Search\Action\Result\SearchResult;
+use App\Tmdb\TmdbResult;
+use App\Torrentio\Action\Command\GetMovieOptionsCommand;
+use App\Torrentio\Action\Command\GetTvShowOptionsCommand;
+use App\Torrentio\Action\Handler\GetMovieOptionsHandler;
+use App\Torrentio\Action\Handler\GetTvShowOptionsHandler;
+use App\Torrentio\Result\TorrentioResult;
+use App\User\Framework\Repository\UserRepository;
+use Symfony\Component\Console\Attribute\AsCommand;
+use Symfony\Component\Console\Command\Command;
+use Symfony\Component\Console\Helper\Table;
+use Symfony\Component\Console\Input\InputArgument;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Input\InputOption;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\Console\Question\ChoiceQuestion;
+use Symfony\Component\Console\Question\Question;
+use Symfony\Component\Console\Style\SymfonyStyle;
+use Symfony\Component\Messenger\MessageBusInterface;
+
+#[AsCommand('search')]
+class SearchCommand extends Command
+{
+    private SearchHandler $searchHandler;
+    private GetTvShowOptionsHandler $getTvShowOptionsHandler;
+    private GetMovieOptionsHandler $getMovieOptionsHandler;
+    private UserRepository $userRepository;
+    private DownloadRepository $downloadRepository;
+    private DownloadMediaHandler $downloadMediaHandler;
+    private MessageBusInterface $bus;
+
+    public function __construct(SearchHandler $searchHandler, GetTvShowOptionsHandler $getTvShowOptionsHandler,
+        GetMovieOptionsHandler $getMovieOptionsHandler,
+        UserRepository $userRepository,
+        DownloadRepository $downloadRepository,
+        DownloadMediaHandler $downloadMediaHandler,
+        MessageBusInterface $bus,
+        ?string $name = null
+    ) {
+        parent::__construct($name);
+        $this->searchHandler = $searchHandler;
+        $this->getTvShowOptionsHandler = $getTvShowOptionsHandler;
+        $this->getMovieOptionsHandler = $getMovieOptionsHandler;
+        $this->userRepository = $userRepository;
+        $this->downloadRepository = $downloadRepository;
+        $this->downloadMediaHandler = $downloadMediaHandler;
+        $this->bus = $bus;
+    }
+
+    protected function configure()
+    {
+        $this->addArgument('term', InputArgument::REQUIRED);
+        $this->addOption('local', 'l', InputOption::VALUE_NONE, 'Perform the download locally instead of submitting it to the queue.');
+    }
+
+    public function run(InputInterface $input, OutputInterface $output): int
+    {
+        $io = new SymfonyStyle($input, $output);
+        $command = new CommandInput($input->getArgument('term'));
+
+        // Perform search
+        $mediaOptions = $this->searchHandler->handle($command);
+
+        // Render results and ask the User to pick one
+        $mediaChoice = $this->askToChooseMediaOption($io, $output, $mediaOptions);
+
+        // Find download options based on the User's choice
+        $downloadOptions = $this->fetchDownloadOptions($mediaChoice);
+
+        // Render results and ask the User to pick one
+        $downloadChoice = $this->askToChooseDownloadOption($io, $output, $downloadOptions);
+
+        // Have user confirm download action
+        $confirmation = $this->askToConfirmDownload($io, $output, $downloadChoice);
+
+        // Begin download or submit to the queue
+        if (true === $confirmation) {
+            $downloadLocally = $input->getOption('local');
+            $this->submitDownload($io, $mediaChoice, $downloadChoice, $downloadLocally);
+        } else {
+            $io->success('No results found.');
+        }
+
+        $io->success('Success!');
+
+        return Command::SUCCESS;
+    }
+
+    private function askToChooseMediaOption(SymfonyStyle $io, OutputInterface $output, SearchResult $result): TmdbResult
+    {
+        $table = new Table($output)
+            ->setHeaders(['ID', 'Title', 'Year', 'IMDb ID', 'Description'])
+            ->setRows(
+                Map::from($result->results)
+                    ->map(fn ($result, $index) => [$index, $result->title, $result->year, $result->imdbId, substr($result->description, 0, 80) . '...'])
+                    ->toArray()
+            );
+
+        $table->render();
+
+        $question = new Question('Enter the ID of the correct result: ');
+        $choiceId = $io->askQuestion($question);
+        $choice = $result->results[$choiceId];
+
+        $io->info('You chose: ' . $choice->title);
+        $io->table(
+            ['ID', 'Title', 'Year', 'IMDb ID', 'Description'],
+            [
+                [$choiceId, $choice->title, $choice->year, $choice->imdbId, substr($choice->description, 0, 80) . '...'],
+            ]
+        );
+
+        return $choice;
+    }
+
+    private function fetchDownloadOptions(TmdbResult $result): array
+    {
+        $handlers = [
+            'movies' => $this->getMovieOptionsHandler,
+            'tvshows' => $this->getTvShowOptionsHandler,
+        ];
+
+        $handler = $handlers[$result->mediaType];
+
+        if ("movies" === $result->mediaType) {
+            $command = new GetMovieOptionsCommand(
+                $result->tmdbId,
+                $result->imdbId
+            );
+        } else {
+            $command = new GetTvShowOptionsCommand(
+                $result->tmdbId,
+                $result->imdbId,
+                1,
+                1
+            );
+        }
+
+        $result = $handler->handle($command);
+        return $result->results;
+    }
+
+    private function askToChooseDownloadOption(SymfonyStyle $io, OutputInterface $output, array $options): TorrentioResult
+    {
+        $table = new Table($output)
+            ->setHeaders(['ID', 'Size', 'Resolution', 'Codec', 'Seeders', 'Provider', 'Language'])
+            ->setRows(
+                Map::from($options)
+                    ->map(fn (TorrentioResult $result, $index) => [$index, $result->size, $result->resolution, $result->codec, $result->seeders, $result->provider, implode(', ', $result->languages)])
+                    ->toArray()
+            );
+        $table->render();
+
+        $question = new Question('Enter the ID of the item to download: ');
+        $choiceId = $io->askQuestion($question);
+        $choice = $options[$choiceId];
+        $io->info('You chose: ' . $choice->title);
+
+        return $choice;
+    }
+
+    private function askToConfirmDownload(SymfonyStyle $io, OutputInterface $output, TorrentioResult $downloadOption): bool
+    {
+        $question = new ChoiceQuestion('Are you sure you want to download the above file?', ['yes', 'no']);
+        $choice = $io->askQuestion($question);
+        return $choice === 'yes';
+    }
+
+    private function submitDownload(SymfonyStyle $io, TmdbResult $mediaChoice, TorrentioResult $downloadOption, bool $downloadLocally = false): void
+    {
+        $io->writeln('> Adding download record');
+        $user = $this->userRepository->find(1);
+        $download = $this->downloadRepository->insert(
+            $user,
+            $downloadOption->url,
+            $downloadOption->title,
+            $downloadOption->filename,
+            $mediaChoice->imdbId,
+            $mediaChoice->mediaType,
+        );
+
+        $io->writeln('> Download record added: ' . $download->getId());
+        $downloadCommand = new DownloadMediaCommand(
+            $download->getUrl(),
+            $download->getTitle(),
+            $download->getFilename(),
+            $download->getMEdiaType(),
+            $download->getImdbId(),
+            $download->getUser()->getId(),
+            $download->getId()
+        );
+
+        if (true === $downloadLocally) {
+            $io->writeln('> Beginning local download');
+            $this->downloadMediaHandler->handle($downloadCommand);
+        } else {
+            $io->writeln('> Submitting download to queue');
+            $this->bus->dispatch($downloadCommand);
+        }
+
+        $io->writeln('> Download added to queue');
+    }
+}

src/Search/Framework/Controller/WebController.php

@@ -37,7 +37,8 @@ final class WebController extends AbstractController
     public function result(
         GetMediaInfoInput $input,
         ?int $season = null,
-    ): Response {
+    ): Response
+    {
         $result = $this->getMediaInfoHandler->handle($input->toCommand());
 
         return $this->render('search/result.html.twig', [
@@ -52,32 +53,4 @@ final class WebController extends AbstractController
             ]
         ]);
     }
-
-    private function warmDownloadOptionCache(TmdbResult $result)
-    {
-        if ($result->mediaType === 'tvshows') {
-            // dispatches a job to get the download options
-            // for each episode and load them in cache
-            foreach ($result->episodes as $season => $episodes) {
-                // Only do the first 2 seasons, so we reduce
-                // getting rate-limited by Torrentio
-                if ($season > 2) {
-                    return;
-                }
-                foreach ($episodes as $episode) {
-                    $this->bus->dispatch(new GetTvShowOptionsCommand(
-                        tmdbId: $result->tmdbId,
-                        imdbId: $result->imdbId,
-                        season: $season,
-                        episode: $episode['episode_number'],
-                    ));
-                }
-            }
-        } elseif ($result->mediaType === 'movies') {
-            $this->bus->dispatch(new GetMovieOptionsCommand(
-                $result->tmdbId,
-                $result->imdbId,
-            ));
-        }
-    }
 }

src/Tmdb/Tmdb.php

@@ -2,10 +2,12 @@
 
 namespace App\Tmdb;
 
+use \Async;
 use Aimeos\Map;
 use App\Base\Enum\MediaType;
 use App\ValueObject\ResultFactory;
 use Psr\Cache\CacheItemPoolInterface;
+use Psr\Log\LoggerInterface;
 use Symfony\Component\DependencyInjection\Attribute\Autowire;
 use Symfony\Component\EventDispatcher\EventDispatcherInterface;
 use Symfony\Contracts\Cache\ItemInterface;
@@ -42,6 +44,7 @@ class Tmdb
     public function __construct(
         private readonly CacheItemPoolInterface $cache,
         private readonly EventDispatcherInterface $eventDispatcher,
+        private readonly LoggerInterface $logger,
         #[Autowire(env: 'TMDB_API')] string $apiKey,
     ) {
         $this->client = new Client(
@@ -214,7 +217,6 @@ class Tmdb
             if ($season['episode_count'] <= 0 || $season['name'] === 'Specials') {
                 continue;
             }
-
             $series['episodes'][$season['season_number']] = Map::from(
                 $client->getApi()->getSeason($series['id'], $season['season_number'])['episodes']
             )->map(function ($data) {
@@ -301,6 +303,7 @@ class Tmdb
             description: $data['overview'],
             year: (new \DateTime($data['release_date']))->format('Y'),
             mediaType: "movies",
+            episodeAirDate: (new \DateTime($data['release_date']))->format('m/d/Y'),
         );
     }
 

src/Torrentio/Action/Handler/GetTvShowOptionsHandler.php

@@ -3,6 +3,7 @@
 namespace App\Torrentio\Action\Handler;
 
 use App\Base\Service\MediaFiles;
+use App\Library\Dto\MediaFileDto;
 use App\Tmdb\Tmdb;
 use App\Torrentio\Action\Command\GetTvShowOptionsCommand;
 use App\Torrentio\Action\Result\GetTvShowOptionsResult;
@@ -28,7 +29,7 @@ class GetTvShowOptionsHandler implements HandlerInterface
 
         return new GetTvShowOptionsResult(
             media: $media,
-            file: $file,
+            file: MediaFileDto::fromSplFileInfo($file),
             season: $command->season,
             episode: $command->episode,
             results: $this->torrentio->fetchEpisodeResults(

src/Torrentio/Action/Result/GetTvShowOptionsResult.php

@@ -2,15 +2,15 @@
 
 namespace App\Torrentio\Action\Result;
 
+use App\Library\Dto\MediaFileDto;
 use App\Tmdb\TmdbResult;
 use OneToMany\RichBundle\Contract\ResultInterface;
-use Symfony\Component\Finder\SplFileInfo;
 
 class GetTvShowOptionsResult implements ResultInterface
 {
     public function __construct(
         public TmdbResult $media,
-        public bool|SplFileInfo $file,
+        public MediaFileDto|false $file,
         public string $season,
         public string $episode,
         public array $results

src/Torrentio/Framework/Controller/WebController.php

@@ -9,12 +9,15 @@ use App\Torrentio\Action\Input\GetMovieOptionsInput;
 use App\Torrentio\Action\Input\GetTvShowOptionsInput;
 use App\Torrentio\Exception\TorrentioRateLimitException;
 use Carbon\Carbon;
+use OneToMany\RichBundle\Contract\ResultInterface;
 use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
 use Symfony\Component\HttpFoundation\Request;
 use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\HttpKernel\Attribute\Cache;
 use Symfony\Component\Routing\Attribute\Route;
 use Symfony\Contracts\Cache\CacheInterface;
 use Symfony\Contracts\Cache\ItemInterface;
+use Symfony\UX\Turbo\TurboBundle;
 
 final class WebController extends AbstractController
 {
@@ -24,8 +27,9 @@ final class WebController extends AbstractController
         private readonly Broadcaster $broadcaster,
     ) {}
 
+    #[Cache(expires: 3600, public: false, mustRevalidate: true)]
     #[Route('/torrentio/movies/{tmdbId}/{imdbId}', name: 'app_torrentio_movies')]
-    public function movieOptions(GetMovieOptionsInput $input, CacheInterface $cache): Response
+    public function movieOptions(GetMovieOptionsInput $input, CacheInterface $cache, Request $request): Response
     {
         $cacheId = sprintf(
             "page.torrentio.movies.%s.%s",
@@ -33,17 +37,22 @@ final class WebController extends AbstractController
             $input->imdbId
         );
 
-        return $cache->get($cacheId, function (ItemInterface $item) use ($input) {
+        $results =  $cache->get($cacheId, function (ItemInterface $item) use ($input, $request) {
             $item->expiresAt(Carbon::now()->addHour()->setMinute(0)->setSecond(0));
-            $results = $this->getMovieOptionsHandler->handle($input->toCommand());
-            return $this->render('torrentio/movies.html.twig', [
-                'results' => $results,
-            ]);
+            return $this->getMovieOptionsHandler->handle($input->toCommand());
         });
+
+        if ($request->headers->get('Turbo-Frame')) {
+            return $this->sendFragmentResponse($results, $request);
+        }
+
+        return $this->render('torrentio/movies.html.twig', [
+            'results' => $results,
+        ]);
     }
 
     #[Route('/torrentio/tvshows/{tmdbId}/{imdbId}/{season?}/{episode?}', name: 'app_torrentio_tvshows')]
-    public function tvShowOptions(GetTvShowOptionsInput $input, CacheInterface $cache): Response
+    public function tvShowOptions(GetTvShowOptionsInput $input, CacheInterface $cache, Request $request): Response
     {
         $cacheId = sprintf(
             "page.torrentio.tvshows.%s.%s.%s.%s",
@@ -54,13 +63,18 @@ final class WebController extends AbstractController
         );
 
         try {
-//            return $cache->get($cacheId, function (ItemInterface $item) use ($input) {
-//                $item->expiresAt(Carbon::now()->addHour()->setMinute(0)->setSecond(0));
-                $results = $this->getTvShowOptionsHandler->handle($input->toCommand());
-                return $this->render('torrentio/tvshows.html.twig', [
-                    'results' => $results,
-                ]);
-//            });
+            $results = $cache->get($cacheId, function (ItemInterface $item) use ($input) {
+                $item->expiresAt(Carbon::now()->addHour()->setMinute(0)->setSecond(0));
+                return $this->getTvShowOptionsHandler->handle($input->toCommand());
+            });
+
+            if ($request->headers->get('Turbo-Frame')) {
+                return $this->sendFragmentResponse($results, $request);
+            }
+
+            return $this->render('torrentio/tvshows.html.twig', [
+                'results' => $results,
+            ]);
         } catch (TorrentioRateLimitException $exception) {
             $this->broadcaster->alert('Warning', 'Torrentio has rate limited your requests. Please wait a few minutes before trying again.', 'warning');
             return $this->render('bare.html.twig',
@@ -73,29 +87,16 @@ final class WebController extends AbstractController
         }
     }
 
-    #[Route('/torrentio/tvshows/clear/{tmdbId}/{imdbId}/{season?}/{episode?}', name: 'app_clear_torrentio_tvshows')]
-    public function clearTvShowOptions(GetTvShowOptionsInput $input, CacheInterface $cache, Request $request): Response
+    private function sendFragmentResponse(ResultInterface $result, Request $request): Response
     {
-        $cacheId = sprintf(
-            "page.torrentio.tvshows.%s.%s.%s.%s",
-            $input->tmdbId,
-            $input->imdbId,
-            $input->season,
-            $input->episode,
+        $request->setRequestFormat(TurboBundle::STREAM_FORMAT);
+        return $this->renderBlock(
+            'torrentio/fragments.html.twig',
+            $request->query->get('block'),
+            [
+                'results' => $result,
+                'target' => $request->query->get('target')
+            ]
         );
-        $cache->delete($cacheId);
-
-        $this->broadcaster->alert(
-            title: 'Success',
-            message: 'Torrentio cache Cleared.'
-        );
-
-        return $cache->get($cacheId, function (ItemInterface $item) use ($input) {
-            $item->expiresAt(Carbon::now()->addHour()->setMinute(0)->setSecond(0));
-            $results = $this->getTvShowOptionsHandler->handle($input->toCommand());
-            return $this->render('torrentio/tvshows.html.twig', [
-                'results' => $results,
-            ]);
-        });
     }
 }

src/Twig/Extensions/UtilExtension.php

@@ -47,7 +47,7 @@ class UtilExtension
     }
 
     #[AsTwigFilter('episode_id_from_results')]
-    public function episodeId($result): ?string
+    public function episodeIdFromResults($result): ?string
     {
         if (!$result instanceof GetTvShowOptionsResult) {
             return null;
@@ -56,4 +56,11 @@ class UtilExtension
         return "S". str_pad($result->season, 2, "0", STR_PAD_LEFT) .
             "E". str_pad($result->episode, 2, "0", STR_PAD_LEFT);
     }
+
+    #[AsTwigFunction('episode_id')]
+    public function episodeId($season, $episode): ?string
+    {
+        return "S". str_pad($season, 2, "0", STR_PAD_LEFT) .
+            "E". str_pad($episode, 2, "0", STR_PAD_LEFT);
+    }
 }

templates/components/DownloadListRow.html.twig

@@ -7,7 +7,7 @@
         </a>
 
         {% if download.mediaType == "tvshows" and download.episodeId != null %}
-            &mdash; <span class="ml-1">(S{{ download.episodeId }})</span>
+            &mdash; <span class="ml-1">({{ download.episodeId }})</span>
         {% endif %}
     </td>
 
@@ -44,7 +44,12 @@
 
         {% set delete_button = component('ux:icon', {name: 'ic:twotone-cancel', height: '17.75px', width: '17.75px', class: 'rounded-full align-middle text-red-600 hover:text-red-700' }) %}
         <twig:Modal heading="But wait!" button_text="{{ delete_button }}" submit_action="{{ stimulus_action('download_list', 'deleteDownload', 'click', {id: download.id}) }}" show_cancel show_submit>
-            Are you sure you want to delete <span class="font-bold">{{ download.filename }}</span>?
+            <p class="mb-1">Are you sure you want to delete the following record?</p>
+            <p class="mb-1 ml-4 italic">{{ download.filename }}</p>
+            <div class="">
+                <input id="delete_file_{{ download.id }}" class="accent-orange-500" type="checkbox" value="false" name="delete_file" />
+                <label for="delete_file_{{ download.id }}">Delete the file as well?</label>
+            </div>
         </twig:Modal>
     </td>
 </tr>

templates/components/Poster.html.twig

@@ -3,12 +3,12 @@
         mediaType: mediaType,
         imdbId: imdbId
     }) }}">
-        <img src="{{ image }}" class="w-full md:w-40 rounded-md" />
+        <img src="{{ preload(image) }}" class="w-full md:w-40 rounded-md" />
     </a>
     <a href="{{ path('app_search_result', {
         mediaType: mediaType,
         imdbId: imdbId
     }) }}">
-        <h3 class="text-center text-white md:text-xl md:text-base md:max-w-[16ch]">{{ title }}</h3>
+        <h3 class="text-center text-white md:text-md md:text-base md:max-w-[16ch]">{{ title }}</h3>
     </a>
 </div>

templates/components/TvEpisodeList.html.twig

@@ -40,30 +40,17 @@
                                     {{ episode['air_date']|date(null, 'UTC') }}
                                 </small>
 
-                                {% if episode['file'] != false %}
-                                    <span data-controller="popover">
-                                        <template data-popover-target="content">
-                                            <div data-popover-target="card" class="absolute z-40 p-1 bg-stone-400 p-1 text-black rounded-md m-1 animate-fade">
-                                                <p class="font-bold text-sm text-left">Existing file(s) for this episode:</p>
-                                                <ul class="list-disc ml-3">
-                                                    <li class="font-normal">{{ episode['file'].realPath|strip_media_path }} &mdash; <strong>{{ episode['file'].size|filesize }}</strong></li>
-                                                </ul>
-                                            </div>
-                                        </template>
-                                        <small
-                                                class="py-1 px-1.5 mr-1 grow-0 font-bold bg-blue-600 rounded-lg text-center text-white"
-                                                data-action="mouseenter->popover#show mouseleave->popover#hide"
-                                        >
-                                            exists
-                                        </small>
-                                    </span>
-                                {% endif %}
-
-                                {% if episode['file'] == false %}
+                                <twig:Turbo:Frame id="meb_{{ this.imdbId }}_{{ episode_id(episode['season_number'], episode['episode_number']) }}" src="{{ path('api.library.search', {
+                                        title: this.title,
+                                        season: episode['season_number'],
+                                        episode: episode['episode_number'],
+                                        block: 'media_exists_badge',
+                                        target: "meb_" ~ this.imdbId ~"_" ~ episode_id(episode['season_number'], episode['episode_number'])
+                                }) }}">
                                     <small class="py-1 px-1.5 mr-1 grow-0 font-bold bg-rose-600 rounded-lg text-white" title="Episode has not been downloaded yet.">
                                         missing
                                     </small>
-                                {% endif %}
+                                </twig:Turbo:Frame>
                             </div>
                         </div>
                         <div class="flex flex-col gap-4 justify-between">
@@ -87,8 +74,15 @@
                             </button>
                         </div>
                     </div>
-                    <div {{ stimulus_target('tv-results', 'listContainer') }} class="inline-block overflow-hidden rounded-lg">
-
+                    <div class="inline-block overflow-hidden rounded-lg">
+                        <twig:Turbo:Frame id="results_{{ episode_id(episode['season_number'], episode['episode_number']) }}" src="{{ path('app_torrentio_tvshows', {
+                            tmdbId: this.tmdbId,
+                            imdbId: this.imdbId,
+                            season: episode['season_number'],
+                            episode: episode['episode_number'],
+                            target: 'results_' ~ episode_id(episode['season_number'], episode['episode_number']),
+                            block: 'tvshow_results'
+                        }) }}" />
                     </div>
                 </div>
             </div>

templates/search/fragments.html.twig

@@ -0,0 +1,32 @@
+{% block media_exists_badge %}
+    <turbo-stream action="replace" targets="#{{ target }}">
+        <template>
+            {% if result.exists == true %}
+                <span data-controller="popover">
+            <template data-popover-target="content">
+                <div data-popover-target="card"
+                     class="absolute z-40 p-1 bg-stone-400 p-1 text-black rounded-md m-1 animate-fade">
+                    <p class="font-bold text-sm text-left">Existing file(s) for this media:</p>
+                    <ul class="list-disc ml-3">
+                        <li class="font-normal">{{ result.file.filename|strip_media_path }} &mdash; <strong>{{ result.file.size|filesize }}</strong></li>
+                    </ul>
+                </div>
+            </template>
+            <small
+                    class="py-1 px-1.5 mr-1 grow-0 font-bold bg-blue-600 rounded-lg text-center text-white"
+                    data-action="mouseenter->popover#show mouseleave->popover#hide"
+            >
+                exists
+            </small>
+        </span>
+            {% endif %}
+
+            {% if result.exists == false %}
+                <small class="py-1 px-1.5 mr-1 grow-0 font-bold bg-rose-600 rounded-lg text-white"
+                       title="Media has not been downloaded yet.">
+                    missing
+                </small>
+            {% endif %}
+        </template>
+    </turbo-stream>
+{% endblock %}

templates/search/result.html.twig

@@ -49,9 +49,32 @@
 
 
                         </div>
+
                         <p class="text-gray-50">
                             {{ results.media.description }}
                         </p>
+
+                        {% if "movies" == results.media.mediaType %}
+                        <div class="flex flex-row justify-start items-end grow">
+                            <span class="py-1 px-1.5 mr-1 grow-0 font-bold text-xs bg-green-600 rounded-lg hover:cursor-pointer hover:bg-green-700 text-white">
+                                <span id="movie_results_count">-</span> results
+                            </span>
+
+                            <small class="py-1 px-1.5 mr-1 grow-0 font-bold bg-gray-700 rounded-lg font-normal text-white" title="Release date {{ results.media.episodeAirDate }}">
+                                {{ results.media.episodeAirDate|date(null, 'UTC') }}
+                            </small>
+
+                            <twig:Turbo:Frame id="meb_{{ results.media.imdbId }}" src="{{ path('api.library.search', {
+                                title: results.media.title,
+                                block: 'media_exists_badge',
+                                target: "meb_" ~ results.media.imdbId
+                            }) }}">
+                                <small class="py-1 px-1.5 mr-1 grow-0 font-bold bg-rose-600 rounded-lg text-white" title="Movie has not been downloaded yet.">
+                                    missing
+                                </small>
+                            </twig:Turbo:Frame>
+                        </div>
+                        {% endif %}
                     </div>
                 </div>
 
@@ -62,6 +85,12 @@
                      {{ stimulus_controller('movie_results', {title: results.media.title, tmdbId: results.media.tmdbId, imdbId: results.media.imdbId}) }}
                      data-movie-results-loading-icon-outlet=".loading-icon"
                 >
+                    <twig:Turbo:Frame id="movie_results_frame" src="{{ path('app_torrentio_movies', {
+                        tmdbId: results.media.tmdbId,
+                        imdbId: results.media.imdbId,
+                        target: 'movie_results_frame',
+                        block: 'movie_results'
+                    }) }}" />
                 </div>
                 {% elseif "tvshows" == results.media.mediaType %}
                     <twig:TvEpisodeList

templates/torrentio/fragments.html.twig

@@ -0,0 +1,21 @@
+{% block movie_results %}
+    <turbo-stream action="replace" targets="#{{ target }}">
+        <template>
+            <div class="p-4 flex flex-col gap-6 bg-orange-500 bg-clip-padding backdrop-filter backdrop-blur-md bg-opacity-60 rounded-md">
+                <div class="overflow-hidden rounded-md">
+                    {{ include('torrentio/partial/option-table.html.twig', {controller: 'movie-results'}) }}
+                </div>
+            </div>
+        </template>
+    </turbo-stream>
+{% endblock %}
+
+{% block tvshow_results %}
+    <turbo-stream action="replace" targets="#{{ target }}">
+        <template>
+            <div id="{{ target }}">
+                {{ include('torrentio/partial/option-table.html.twig', {controller: 'tv-results'}) }}
+            </div>
+        </template>
+    </turbo-stream>
+{% endblock %}

templates/torrentio/index.html.twig

@@ -1,20 +0,0 @@
-{% extends 'base.html.twig' %}
-
-{% block title %}Hello TorrentioController!{% endblock %}
-
-{% block body %}
-<style>
-    .example-wrapper { margin: 1em auto; max-width: 800px; width: 95%; font: 18px/1.5 sans-serif; }
-    .example-wrapper code { background: #F5F5F5; padding: 2px 6px; }
-</style>
-
-<div class="example-wrapper">
-    <h1>Hello {{ controller_name }}! ✅</h1>
-
-    This friendly message is coming from:
-    <ul>
-        <li>Your controller at <code>/var/www/src/Controller/TorrentioController.php</code></li>
-        <li>Your template at <code>/var/www/templates/torrentio/index.html.twig</code></li>
-    </ul>
-</div>
-{% endblock %}

templates/torrentio/movies.html.twig

@@ -1,13 +1,4 @@
 <div class="p-4 flex flex-col gap-6 bg-orange-500 bg-clip-padding backdrop-filter backdrop-blur-md bg-opacity-60 rounded-md">
-    {% if results.file != false %}
-    <div class="p-3 bg-stone-400 p-1 text-black rounded-md m-1 animate-fade">
-        <p class="font-bold text-sm text-left">Existing file(s) for this movie:</p>
-        <ul class="list-disc ml-3 overflow-scroll">
-            <li class="font-normal">{{ results.file.realPath|strip_media_path }} &mdash; <strong>{{ results.file.size|filesize }}</strong></li>
-        </ul>
-    </div>
-    {% endif %}
-
     <div class="overflow-hidden rounded-md">
         {{ include('torrentio/partial/option-table.html.twig', {controller: 'movie-results'}) }}
     </div>