feat: presents popular tv shows on landing page

.env

@@ -18,3 +18,20 @@
 APP_ENV=dev
 APP_SECRET=
 ###< symfony/framework-bundle ###
+
+###> doctrine/doctrine-bundle ###
+# Format described at https://www.doctrine-project.org/projects/doctrine-dbal/en/latest/reference/configuration.html#connecting-using-a-url
+# IMPORTANT: You MUST configure your server version, either here or in config/packages/doctrine.yaml
+#
+# DATABASE_URL="sqlite:///%kernel.project_dir%/var/data.db"
+# DATABASE_URL="mysql://app:!ChangeMe!@127.0.0.1:3306/app?serverVersion=8.0.32&charset=utf8mb4"
+# DATABASE_URL="mysql://app:!ChangeMe!@127.0.0.1:3306/app?serverVersion=10.11.2-MariaDB&charset=utf8mb4"
+DATABASE_URL="postgresql://app:!ChangeMe!@127.0.0.1:5432/app?serverVersion=16&charset=utf8"
+###< doctrine/doctrine-bundle ###
+
+###> symfony/messenger ###
+# Choose one of the transports below
+# MESSENGER_TRANSPORT_DSN=amqp://guest:guest@localhost:5672/%2f/messages
+# MESSENGER_TRANSPORT_DSN=redis://localhost:6379/messages
+MESSENGER_TRANSPORT_DSN=doctrine://default?auto_setup=0
+###< symfony/messenger ###

.env.dist

@@ -1 +1,10 @@
+APP_SECRET="%%app_secret%%"
 DATABASE_URL="%%db_url%%"
+DOWNLOAD_DIR=%%download_dir%%
+REAL_DEBRID_KEY="%%rd_key%%"
+TMDB_API=%%tmdb_api%%
+MERCURE_URL=%%mercure_url%%
+MERCURE_PUBLIC_URL=%%mercure_public_url%%
+MERCURE_JWT_SECRET="%%mercure_jwt_secret%%"
+JELLYFIN_URL=%%jellyfin_url%%
+JELLYFIN_TOKEN=%%jellyfin_token%%

Dockerfile

@@ -1 +1,4 @@
 FROM registry.caldwell.digital/library/php:8.4-apache
+
+COPY ./bash/vhost.conf /etc/apache2/sites-enabled/vhost.conf
+RUN rm /etc/apache2/sites-enabled/000-default.conf

Dockerfile.prod

@@ -2,5 +2,4 @@ FROM registry.caldwell.digital/library/php:8.4-apache
 
 COPY --chown=www-data:www-data . /var/www
 COPY ./bash/vhost.conf /etc/apache2/sites-enabled/vhost.conf
-
 RUN rm /etc/apache2/sites-enabled/000-default.conf

assets/app.js

@@ -8,3 +8,13 @@ import './bootstrap.js';
 import './styles/app.css';
 
 console.log('This log comes from assets/app.js - welcome to AssetMapper! 🎉');
+
+let alert = document.querySelector('.alert');
+var observer = new MutationObserver(function(mutations) {
+    if (document.contains(alert)) {
+        observer.disconnect();
+    }
+});
+
+observer.observe(document, {attributes: false, childList: true, characterData: false, subtree:true});
+

assets/controllers.json

@@ -1,4 +1,24 @@
 {
-    "controllers": [],
+    "controllers": {
+        "@symfony/ux-live-component": {
+            "live": {
+                "enabled": true,
+                "fetch": "eager",
+                "autoimport": {
+                    "@symfony/ux-live-component/dist/live.min.css": true
+                }
+            }
+        },
+        "@symfony/ux-turbo": {
+            "turbo-core": {
+                "enabled": true,
+                "fetch": "eager"
+            },
+            "mercure-turbo-stream": {
+                "enabled": true,
+                "fetch": "eager"
+            }
+        }
+    },
     "entrypoints": []
 }

assets/controllers/alert_controller.js

@@ -0,0 +1,18 @@
+import { Controller } from '@hotwired/stimulus';
+
+export default class extends Controller {
+    connect() {
+        let timer = setTimeout(() => {
+                this.element.remove();
+            },
+            "3000"
+        );
+
+        this.element.addEventListener('mouseout', () => timer = setTimeout(() => {
+                this.element.remove();
+            },
+            "3000"
+        ));
+        this.element.addEventListener('mouseover', () => clearTimeout(timer));
+    }
+}

assets/controllers/download_button_controller.js

@@ -0,0 +1,37 @@
+import { Controller } from '@hotwired/stimulus';
+
+/*
+* The following line makes this controller "lazy": it won't be downloaded until needed
+* See https://github.com/symfony/stimulus-bridge#lazy-controllers
+*/
+/* stimulusFetch: 'lazy' */
+export default class extends Controller {
+    static values = {
+        url: String,
+        title: String,
+        filename: String,
+        mediaType: String,
+        imdbId: String,
+    }
+
+    download() {
+        fetch('/download', {
+            method: 'POST',
+            headers: {
+                'Content-Type': 'application/json',
+                'Accept': 'application/json',
+            },
+            body: JSON.stringify({
+                url: this.urlValue,
+                title: this.element.dataset['title'],
+                filename: this.filenameValue,
+                mediaType: this.mediaTypeValue,
+                imdbId: this.imdbIdValue
+            })
+        })
+            .then(res => res.json())
+            .then(json => {
+            console.log(json)
+        })
+    }
+}

assets/controllers/movie_results_controller.js

@@ -7,6 +7,8 @@ import { Controller } from '@hotwired/stimulus';
 /* stimulusFetch: 'lazy' */
 export default class extends Controller {
     static values = {
+        title: String,
+        tmdbId: String,
         imdbId: String
     };
 
@@ -20,11 +22,12 @@ export default class extends Controller {
 
     async setOptions() {
         if (this.options.length === 0) {
-            await fetch(`/torrentio/movies/${this.imdbIdValue}`)
+            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);
                 });
         }
     }

assets/controllers/result_filter_controller.js

@@ -21,7 +21,7 @@ export default class extends Controller {
     }
 
     static outlets = ['movie-results', 'tv-results']
-    static targets = ['resolution', 'codec', 'language', 'provider', 'season']
+    static targets = ['resolution', 'codec', 'language', 'provider', 'season', 'selectAll', 'downloadSelected']
     static values = {
         'media-type': String,
         'episodes': Array,
@@ -29,7 +29,8 @@ export default class extends Controller {
 
     connect() {
         if (this.mediaTypeValue === "tvshows") {
-            this.activeFilter['season'] = 1;}
+            this.activeFilter['season'] = 1;
+        }
     }
 
     async movieResultsOutletConnected(outlet) {
@@ -148,7 +149,7 @@ export default class extends Controller {
                 } else if (true === firstIncluded) {
                     count = 1;
                     selectedCount = selectedCount + 1;
-                    // option.selectInput.checked = true;
+                    option.querySelector('input[type="checkbox"]').checked = true;
                     firstIncluded = false;
                 } else {
                     count = count + 1;
@@ -158,8 +159,30 @@ export default class extends Controller {
                     resultList.countTarget.innerText = count;
                 }
             });
+
         }
 
         await results.forEach((list) => filterOperation(list, currentSeason));
     }
+
+    uncheckSelectAllBtn() {
+        this.selectAllTarget.checked = false;
+    }
+
+    selectAllEpisodes() {
+        this.tvResultsOutlets.forEach((episode) => {
+            if (episode.isActive()) {
+                episode.selectEpisodeForDownload()
+            }
+        });
+    }
+
+    downloadSelectedEpisodes() {
+        this.tvResultsOutlets.forEach(episode => {
+            if (episode.isActive() && episode.isSelected()) {
+                episode.download();
+            }
+        });
+        this.selectAllTarget.checked = false;
+    }
 }

assets/controllers/tv_results_controller.js

@@ -7,6 +7,7 @@ import { Controller } from '@hotwired/stimulus';
 /* stimulusFetch: 'lazy' */
 export default class extends Controller {
     static values = {
+        title: String,
         tmdbId: String,
         imdbId: String,
         season: String,
@@ -14,7 +15,7 @@ export default class extends Controller {
         active: Boolean,
     };
 
-    static targets = ['list', 'count']
+    static targets = ['list', 'count', 'episodeSelector']
     static outlets = ['loading-icon']
 
     options = []
@@ -31,6 +32,12 @@ export default class extends Controller {
                 .then(response => {
                     this.element.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.episodeSelectorTarget.disabled = true;
+                    }
                     this.optionsLoaded = true;
                     this.loadingIconOutlet.increaseCount();
                 });
@@ -47,6 +54,7 @@ export default class extends Controller {
 
     setInActive() {
         this.activeValue = false;
+        this.episodeSelectorTarget.checked = false;
         this.element.classList.add('hidden');
     }
 
@@ -54,7 +62,30 @@ export default class extends Controller {
         return this.activeValue;
     }
 
+    isSelected() {
+        return this.episodeSelectorTarget.checked;
+    }
+
+    selectEpisodeForDownload() {
+        if (true === this.isActive() && this.episodeSelectorTarget.disabled === false) {
+            this.episodeSelectorTarget.checked = !this.episodeSelectorTarget.checked;
+        }
+    }
+
     toggleList() {
         this.listTarget.classList.toggle('hidden');
     }
+
+    download() {
+        this.options.forEach(option => {
+            const optionSelector = option.querySelector('input[type="checkbox"]');
+            if (true === optionSelector.checked) {
+                const downloadBtn = option.querySelector('button.download-btn');
+                const downloadBtnController = this.application.getControllerForElementAndIdentifier(downloadBtn, 'download-button');
+                downloadBtnController.download();
+                optionSelector.checked = false;
+                this.episodeSelectorTarget.checked = false;
+            }
+        })
+    }
 }

bash/app/wget_download.sh

@@ -0,0 +1,2 @@
+# $1 = movies/tvshows/etc, $2 = title of media, $3 = URL of download
+cd /var/download/${1} && if [ ! -d "${2}" ]; then mkdir "${2}"; fi && cd "${2}" && wget "${3}"

bash/vhost.conf

@@ -4,6 +4,11 @@
     DocumentRoot /var/www/public
     DirectoryIndex /index.php
 
+    <LocationMatch "/hub/">
+        ProxyPass http://mercure:80/
+        ProxyPassReverse http://mercure:80/
+    </LocationMatch>
+
     <Directory /var/www/public>
         AllowOverride None
         Order Allow,Deny

build.xml

@@ -10,6 +10,10 @@
     </target>
 
     <target name="compileAssets" description="Run composer">
+        <exec executable="php">
+            <arg value="bin/console" />
+            <arg value="tailwind:build" />
+        </exec>
         <exec executable="php">
             <arg value="bin/console" />
             <arg value="asset-map:compile" />
@@ -20,7 +24,16 @@
         <copy file="${project.basedir}/.env.dist" tofile="${project.basedir}/.env.local" overwrite="true">
             <filterchain>
                 <replacetokens begintoken="%%" endtoken="%%">
+                    <token key="app_secret" value="${APP_SECRET}" />
                     <token key="db_url" value="${DATABASE_URL}" />
+                    <token key="download_dir" value="${DOWNLOAD_DIR}" />
+                    <token key="rd_key" value="${REAL_DEBRID_KEY}" />
+                    <token key="tmdb_api" value="${TMDB_API}" />
+                    <token key="mercure_url" value="${MERCURE_URL}" />
+                    <token key="mercure_public_url" value="${MERCURE_PUBLIC_URL}" />
+                    <token key="mercure_jwt_secret" value="${MERCURE_JWT_SECRET}" />
+                    <token key="jellyfin_url" value="${JELLYFIN_URL}" />
+                    <token key="jellyfin_token" value="${JELLYFIN_TOKEN}" />
                 </replacetokens>
             </filterchain>
         </copy>

compose.yml

@@ -17,6 +17,31 @@ services:
     volumes:
       - ./:/var/www
 
+  worker:
+    build: .
+    volumes:
+      - ./:/var/www
+      - ./var/download:/var/download
+    command: php ./bin/console messenger:consume async -v --time-limit=3600 --limit=10
+
+  mercure:
+    image: dunglas/mercure
+    restart: unless-stopped
+    ports:
+      - "3000:80"
+    environment:
+      SERVER_NAME: ':80'
+      MERCURE_PUBLISHER_JWT_KEY: '!ChangeThisMercureHubJWTSecretKey!'
+      MERCURE_SUBSCRIBER_JWT_KEY: '!ChangeThisMercureHubJWTSecretKey!'
+      MERCURE_EXTRA_DIRECTIVES: |
+        cors_origins *
+        anonymous
+    command: /usr/bin/caddy run --config /etc/caddy/dev.Caddyfile
+    volumes:
+      - mercure_data:/data
+      - mercure_config:/config
+
+
   database:
     image: mariadb:10.11.2
     ports:
@@ -36,3 +61,5 @@ services:
 
 volumes:
   mysql:
+  mercure_data:
+  mercure_config:

composer.json

@@ -8,20 +8,30 @@
         "ext-ctype": "*",
         "ext-iconv": "*",
         "1tomany/rich-bundle": "^1.8",
+        "doctrine/dbal": "^3",
+        "doctrine/doctrine-bundle": "^2.14",
+        "doctrine/doctrine-migrations-bundle": "^3.4",
+        "doctrine/orm": "^3.3",
         "nihilarr/parse-torrent-name": "^0.0.1",
         "nyholm/psr7": "*",
         "p3k/emoji-detector": "^1.2",
         "php-tmdb/api": "^4.1",
         "symfony/asset": "7.2.*",
         "symfony/console": "7.2.*",
+        "symfony/doctrine-messenger": "7.2.*",
         "symfony/dotenv": "7.2.*",
         "symfony/flex": "^2",
+        "symfony/form": "7.2.*",
         "symfony/framework-bundle": "7.2.*",
+        "symfony/mercure-bundle": "^0.3.9",
+        "symfony/messenger": "7.2.*",
         "symfony/runtime": "7.2.*",
         "symfony/security-bundle": "7.2.*",
         "symfony/stimulus-bundle": "^2.24",
         "symfony/twig-bundle": "7.2.*",
         "symfony/ux-icons": "^2.24",
+        "symfony/ux-live-component": "^2.24",
+        "symfony/ux-turbo": "^2.24",
         "symfony/ux-twig-component": "^2.24",
         "symfony/yaml": "7.2.*",
         "symfonycasts/tailwind-bundle": "^0.10.0",

config/bundles.php

@@ -11,4 +11,9 @@ return [
     OneToMany\RichBundle\RichBundle::class => ['all' => true],
     Symfony\Bundle\SecurityBundle\SecurityBundle::class => ['all' => true],
     Symfony\UX\StimulusBundle\StimulusBundle::class => ['all' => true],
+    Doctrine\Bundle\DoctrineBundle\DoctrineBundle::class => ['all' => true],
+    Doctrine\Bundle\MigrationsBundle\DoctrineMigrationsBundle::class => ['all' => true],
+    Symfony\UX\LiveComponent\LiveComponentBundle::class => ['all' => true],
+    Symfony\Bundle\MercureBundle\MercureBundle::class => ['all' => true],
+    Symfony\UX\Turbo\TurboBundle::class => ['all' => true],
 ];

config/packages/csrf.yaml

@@ -0,0 +1,11 @@
+# Enable stateless CSRF protection for forms and logins/logouts
+framework:
+    form:
+        csrf_protection:
+            token_id: submit
+
+    csrf_protection:
+        stateless_token_ids:
+            - submit
+            - authenticate
+            - logout

config/packages/doctrine.yaml

@@ -0,0 +1,60 @@
+doctrine:
+    dbal:
+        url: '%env(resolve:DATABASE_URL)%'
+
+        # IMPORTANT: You MUST configure your server version,
+        # either here or in the DATABASE_URL env var (see .env file)
+        #server_version: '16'
+
+        profiling_collect_backtrace: '%kernel.debug%'
+        use_savepoints: true
+    orm:
+        auto_generate_proxy_classes: true
+        enable_lazy_ghost_objects: true
+        report_fields_where_declared: true
+        validate_xml_mapping: true
+        naming_strategy: doctrine.orm.naming_strategy.underscore_number_aware
+        identity_generation_preferences:
+            Doctrine\DBAL\Platforms\PostgreSQLPlatform: identity
+        auto_mapping: true
+        mappings:
+#            App:
+#                type: attribute
+#                is_bundle: false
+#                dir: '%kernel.project_dir%/src/Entity'
+#                prefix: 'App\Entity'
+#                alias: App
+            Download:
+                type: attribute
+                is_bundle: false
+                dir: '%kernel.project_dir%/src/Download/Framework/Entity'
+                prefix: 'App\Download\Framework\Entity'
+                alias: Download
+        controller_resolver:
+            auto_mapping: false
+
+when@test:
+    doctrine:
+        dbal:
+            # "TEST_TOKEN" is typically set by ParaTest
+            dbname_suffix: '_test%env(default::TEST_TOKEN)%'
+
+when@prod:
+    doctrine:
+        orm:
+            auto_generate_proxy_classes: false
+            proxy_dir: '%kernel.build_dir%/doctrine/orm/Proxies'
+            query_cache_driver:
+                type: pool
+                pool: doctrine.system_cache_pool
+            result_cache_driver:
+                type: pool
+                pool: doctrine.result_cache_pool
+
+    framework:
+        cache:
+            pools:
+                doctrine.result_cache_pool:
+                    adapter: cache.app
+                doctrine.system_cache_pool:
+                    adapter: cache.system

config/packages/doctrine_migrations.yaml

@@ -0,0 +1,6 @@
+doctrine_migrations:
+    migrations_paths:
+        # namespace is arbitrary but should be different from App\Migrations
+        # as migrations classes should NOT be autoloaded
+        'DoctrineMigrations': '%kernel.project_dir%/migrations'
+    enable_profiler: false

config/packages/mercure.yaml

@@ -0,0 +1,8 @@
+mercure:
+    hubs:
+        default:
+            url: '%env(MERCURE_URL)%'
+            public_url: '%env(MERCURE_PUBLIC_URL)%'
+            jwt:
+                secret: '%env(MERCURE_JWT_SECRET)%'
+                publish: '*'

config/packages/messenger.yaml

@@ -0,0 +1,27 @@
+framework:
+    messenger:
+        # Uncomment this (and the failed transport below) to send failed messages to this transport for later handling.
+        # failure_transport: failed
+
+        transports:
+            # https://symfony.com/doc/current/messenger.html#transport-configuration
+            async: '%env(MESSENGER_TRANSPORT_DSN)%'
+            failed: 'doctrine://default?queue_name=failed'
+
+        default_bus: messenger.bus.default
+
+        buses:
+            messenger.bus.default: []
+
+        routing:
+            # Route your messages to the transports
+            # 'App\Message\YourMessage': async
+            'App\Download\Action\Command\DownloadMediaCommand': async
+
+# when@test:
+#    framework:
+#        messenger:
+#            transports:
+#                # replace with your transport name here (e.g., my_transport: 'in-memory://')
+#                # For more Messenger testing tools, see https://github.com/zenstruck/messenger-test
+#                async: 'in-memory://'

config/routes.yaml

@@ -4,5 +4,5 @@ controllersIndex:
         namespace: App\Controller
     type: attribute
     defaults:
-        schemes: [ https ]
+        schemes: [ 'https' ]
 

config/routes/ux_live_component.yaml

@@ -0,0 +1,5 @@
+live_component:
+    resource: '@LiveComponentBundle/config/routes.php'
+    prefix: '/_components'
+    # adjust prefix to add localization to your components
+    #prefix: '/{_locale}/_components'

config/services.yaml

@@ -22,3 +22,4 @@ services:
 
     # add more service definitions when explicit configuration is needed
     # please note that last definitions always *replace* previous ones
+    App\Download\Downloader\DownloaderInterface: "@App\\Download\\Downloader\\ProcessDownloader"

deploy.compose.yml

@@ -1,5 +1,36 @@
 services:
   php:
-    image: code.caldwell.digital/home/torsearch/app:${TAG}
+    image: registry.caldwell.digital/home/torsearch/app:${TAG}
     ports:
       - "8001:80"
+    deploy:
+      replicas: 2
+
+  worker:
+    image: registry.caldwell.digital/home/torsearch/app:${TAG}
+    volumes:
+      - /mnt/media/downloads:/var/download
+    command: php ./bin/console messenger:consume async -v --time-limit=3600 --limit=10
+    deploy:
+      replicas: 2
+
+  mercure:
+    image: dunglas/mercure
+    restart: unless-stopped
+    ports:
+      - "3000:80"
+    environment:
+      SERVER_NAME: ':80'
+      MERCURE_PUBLISHER_JWT_KEY: '!ChangeThisMercureHubJWTSecretKey!'
+      MERCURE_SUBSCRIBER_JWT_KEY: '!ChangeThisMercureHubJWTSecretKey!'
+      MERCURE_EXTRA_DIRECTIVES: |
+        cors_origins *
+        anonymous
+    command: /usr/bin/caddy run --config /etc/caddy/dev.Caddyfile
+    volumes:
+      - mercure_data:/data
+      - mercure_config:/config
+
+volumes:
+  mercure_config:
+  mercure_data:

importmap.php

@@ -22,4 +22,10 @@ return [
     '@symfony/stimulus-bundle' => [
         'path' => './vendor/symfony/stimulus-bundle/assets/dist/loader.js',
     ],
+    '@symfony/ux-live-component' => [
+        'path' => './vendor/symfony/ux-live-component/assets/dist/live_controller.js',
+    ],
+    '@hotwired/turbo' => [
+        'version' => '7.3.0',
+    ],
 ];

migrations/Version20241211055503.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20241211055503 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('CREATE TABLE messenger_messages (id BIGINT AUTO_INCREMENT NOT NULL, body LONGTEXT NOT NULL, headers LONGTEXT NOT NULL, queue_name VARCHAR(190) NOT NULL, created_at DATETIME NOT NULL COMMENT \'(DC2Type:datetime_immutable)\', available_at DATETIME NOT NULL COMMENT \'(DC2Type:datetime_immutable)\', delivered_at DATETIME DEFAULT NULL COMMENT \'(DC2Type:datetime_immutable)\', INDEX IDX_75EA56E0FB7336F0 (queue_name), INDEX IDX_75EA56E0E3BD61CE (available_at), INDEX IDX_75EA56E016BA31DB (delivered_at), PRIMARY KEY(id)) DEFAULT CHARACTER SET utf8mb4 COLLATE `utf8mb4_unicode_ci` ENGINE = InnoDB');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('DROP TABLE messenger_messages');
+    }
+}

migrations/Version20241218024301.php

@@ -0,0 +1,43 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20241218024301 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('CREATE TABLE episode (id INT AUTO_INCREMENT NOT NULL, series_id_id INT DEFAULT NULL, imdb_id VARCHAR(255) DEFAULT NULL, tvdb_id VARCHAR(255) DEFAULT NULL, title VARCHAR(255) DEFAULT NULL, year VARCHAR(5) DEFAULT NULL, poster VARCHAR(500) DEFAULT NULL, season VARCHAR(255) DEFAULT NULL, episode VARCHAR(255) DEFAULT NULL, episode_code VARCHAR(255) DEFAULT NULL, download_directory VARCHAR(500) DEFAULT NULL, INDEX IDX_DDAA1CDAACB7A4A (series_id_id), PRIMARY KEY(id)) DEFAULT CHARACTER SET utf8mb4 COLLATE `utf8mb4_unicode_ci` ENGINE = InnoDB');
+        $this->addSql('CREATE TABLE series (id INT AUTO_INCREMENT NOT NULL, imdb_id VARCHAR(255) NOT NULL, tvdb_id VARCHAR(255) DEFAULT NULL, title VARCHAR(255) DEFAULT NULL, year VARCHAR(5) DEFAULT NULL, poster VARCHAR(500) DEFAULT NULL, directory VARCHAR(255) DEFAULT NULL, number_seasons INT DEFAULT NULL, number_episodes INT DEFAULT NULL, PRIMARY KEY(id)) DEFAULT CHARACTER SET utf8mb4 COLLATE `utf8mb4_unicode_ci` ENGINE = InnoDB');
+        $this->addSql('ALTER TABLE episode ADD CONSTRAINT FK_DDAA1CDAACB7A4A FOREIGN KEY (series_id_id) REFERENCES series (id)');
+        $this->addSql('DROP INDEX IDX_75EA56E016BA31DB ON messenger_messages');
+        $this->addSql('DROP INDEX IDX_75EA56E0FB7336F0 ON messenger_messages');
+        $this->addSql('DROP INDEX IDX_75EA56E0E3BD61CE ON messenger_messages');
+        $this->addSql('ALTER TABLE messenger_messages CHANGE id id INT AUTO_INCREMENT NOT NULL');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE episode DROP FOREIGN KEY FK_DDAA1CDAACB7A4A');
+        $this->addSql('DROP TABLE episode');
+        $this->addSql('DROP TABLE series');
+        $this->addSql('ALTER TABLE messenger_messages CHANGE id id BIGINT AUTO_INCREMENT NOT NULL');
+        $this->addSql('CREATE INDEX IDX_75EA56E016BA31DB ON messenger_messages (delivered_at)');
+        $this->addSql('CREATE INDEX IDX_75EA56E0FB7336F0 ON messenger_messages (queue_name)');
+        $this->addSql('CREATE INDEX IDX_75EA56E0E3BD61CE ON messenger_messages (available_at)');
+    }
+}

migrations/Version20241226201901.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20241226201901 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+
+    }
+}

migrations/Version20241226205937.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20241226205937 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('CREATE TABLE download (id INT AUTO_INCREMENT NOT NULL, imdb_id VARCHAR(20) DEFAULT NULL, title VARCHAR(255) DEFAULT NULL, url VARCHAR(1024) NOT NULL, filename VARCHAR(1024) DEFAULT NULL, status VARCHAR(255) DEFAULT NULL, progress INT DEFAULT NULL, PRIMARY KEY(id)) DEFAULT CHARACTER SET utf8mb4 COLLATE `utf8mb4_unicode_ci` ENGINE = InnoDB');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('DROP TABLE download');
+    }
+}

migrations/Version20241226214700.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20241226214700 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE download ADD media_type VARCHAR(255) DEFAULT NULL');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE download DROP media_type');
+    }
+}

migrations/Version20250202035615.php

@@ -0,0 +1,31 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20250202035615 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE download ADD batch_id VARCHAR(255) DEFAULT NULL');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('ALTER TABLE download DROP batch_id');
+    }
+}

migrations/Version20250217221120.php

@@ -0,0 +1,32 @@
+<?php
+
+declare(strict_types=1);
+
+namespace DoctrineMigrations;
+
+use Doctrine\DBAL\Schema\Schema;
+use Doctrine\Migrations\AbstractMigration;
+
+/**
+ * Auto-generated Migration: Please modify to your needs!
+ */
+final class Version20250217221120 extends AbstractMigration
+{
+    public function getDescription(): string
+    {
+        return '';
+    }
+
+    public function up(Schema $schema): void
+    {
+        // this up() migration is auto-generated, please modify it to your needs
+        $this->addSql('CREATE TABLE processed_messages (id INT AUTO_INCREMENT NOT NULL, run_id INT NOT NULL, attempt SMALLINT NOT NULL, message_type VARCHAR(255) NOT NULL, description VARCHAR(255) DEFAULT NULL, dispatched_at DATETIME NOT NULL COMMENT \'(DC2Type:datetime_immutable)\', received_at DATETIME NOT NULL COMMENT \'(DC2Type:datetime_immutable)\', finished_at DATETIME NOT NULL COMMENT \'(DC2Type:datetime_immutable)\', wait_time BIGINT NOT NULL, handle_time BIGINT NOT NULL, memory_usage INT NOT NULL, transport VARCHAR(255) NOT NULL, tags VARCHAR(255) DEFAULT NULL, failure_type VARCHAR(255) DEFAULT NULL, failure_message LONGTEXT DEFAULT NULL, results JSON DEFAULT NULL COMMENT \'(DC2Type:json)\', PRIMARY KEY(id)) DEFAULT CHARACTER SET utf8mb4 COLLATE `utf8mb4_unicode_ci` ENGINE = InnoDB');
+    }
+
+    public function down(Schema $schema): void
+    {
+        // this down() migration is auto-generated, please modify it to your needs
+        $this->addSql('CREATE TABLE preferences (id INT AUTO_INCREMENT NOT NULL, value VARCHAR(255) CHARACTER SET utf8mb4 NOT NULL COLLATE `utf8mb4_unicode_ci`, PRIMARY KEY(id)) DEFAULT CHARACTER SET utf8mb4 COLLATE `utf8mb4_unicode_ci` ENGINE = InnoDB COMMENT = \'\' ');
+        $this->addSql('DROP TABLE processed_messages');
+    }
+}

src/Controller/AlertController.php

@@ -0,0 +1,37 @@
+<?php
+
+namespace App\Controller;
+
+use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
+use Symfony\Component\DependencyInjection\Attribute\Autowire;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\Mercure\HubInterface;
+use Symfony\Component\Mercure\Update;
+use Symfony\Component\Routing\Attribute\Route;
+use Twig\Environment;
+
+final class AlertController extends AbstractController
+{
+    public function __construct(
+        #[Autowire(service: 'twig')] private readonly Environment $renderer,
+        private readonly HubInterface $hub,
+    ) {}
+
+    #[Route('/alert', name: 'app_alert')]
+    public function index(): Response
+    {
+        $update = new Update(
+            'alerts',
+            $this->renderer->render('broadcast/Alert.html.twig', [
+                'alert_id' => 1,
+                'title' => 'Added to queue',
+                'message' => 'This is a testy test!',
+            ])
+        );
+
+        $this->hub->publish($update);
+        return $this->json([
+            'Success' => 'Published'
+        ]);
+    }
+}

src/Controller/DownloadController.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace App\Controller;
+
+use App\Download\Action\Input\DownloadMediaInput;
+use App\Download\Framework\Repository\DownloadRepository;
+use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\Messenger\MessageBusInterface;
+use Symfony\Component\Routing\Attribute\Route;
+
+class DownloadController extends AbstractController
+{
+    public function __construct(
+        private DownloadRepository $downloadRepository,
+        private MessageBusInterface $bus,
+    ) {}
+
+    #[Route('/download', name: 'app_download', methods: ['POST'])]
+    public function download(
+        DownloadMediaInput $input,
+    ): Response {
+        $download = $this->downloadRepository->insert(
+            $input->url,
+            $input->title,
+            $input->filename,
+            $input->imdbId,
+            $input->mediaType,
+            "",
+        );
+        $input->downloadId = $download->getId();
+        try {
+            $this->bus->dispatch($input->toCommand());
+        } catch (\Throwable $exception) {
+            return $this->json(['error' => $exception->getMessage()], Response::HTTP_INTERNAL_SERVER_ERROR);
+        }
+
+        return $this->json(['status' => 200, 'message' => 'Added to Queue']);
+    }
+}

src/Controller/IndexController.php

@@ -2,17 +2,27 @@
 
 namespace App\Controller;
 
+use App\Download\Framework\Repository\DownloadRepository;
+use App\Tmdb\Tmdb;
 use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
 use Symfony\Component\HttpFoundation\Response;
 use Symfony\Component\Routing\Attribute\Route;
 
 final class IndexController extends AbstractController
 {
+    public function __construct(
+        private readonly DownloadRepository $downloadRepository,
+        private readonly Tmdb $tmdb,
+    ) {}
+
     #[Route('/', name: 'app_index')]
     public function index(): Response
     {
         return $this->render('index/index.html.twig', [
-            'controller_name' => 'IndexController',
+            'active_downloads' => $this->downloadRepository->getActivePaginated(),
+            'recent_downloads' => $this->downloadRepository->latest(5),
+            'popular_movies' => $this->tmdb->popularMovies(1, 6),
+            'popular_tvshows' => $this->tmdb->popularTvShows(1, 6),
         ]);
     }
 }

src/Controller/TorrentioController.php

@@ -17,7 +17,7 @@ final class TorrentioController extends AbstractController
         private readonly GetTvShowOptionsHandler $getTvShowOptionsHandler,
     ) {}
 
-    #[Route('/torrentio/movies/{imdbId}', name: 'app_torrentio_movies')]
+    #[Route('/torrentio/movies/{tmdbId}/{imdbId}', name: 'app_torrentio_movies')]
     public function movieOptions(GetMovieOptionsInput $input): Response
     {
         $results = $this->getMovieOptionsHandler->handle($input->toCommand());

src/Download/Action/Command/DownloadMediaCommand.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Download\Action\Command;
+
+use OneToMany\RichBundle\Contract\CommandInterface;
+
+/**
+ * @implements CommandInterface<DownloadMediaCommand>
+ */
+class DownloadMediaCommand implements CommandInterface
+{
+    public function __construct(
+        public string $url,
+        public string $title,
+        public string $filename,
+        public string $mediaType,
+        public string $imdbId,
+        public ?int $downloadId = null,
+    ) {}
+}

src/Download/Action/Command/GetDownloadOptionsCommand.php

@@ -1,14 +0,0 @@
-<?php
-
-namespace App\Download\Action\Command;
-
-use OneToMany\RichBundle\Contract\CommandInterface;
-
-class GetDownloadOptionsCommand implements CommandInterface
-{
-    /** @implements CommandInterface<GetDownloadOptionsCommand> */
-    public function __construct(
-        public string $tmdbId,
-        public string $mediaType,
-    ) {}
-}

src/Download/Action/Handler/DownloadMediaHandler.php

@@ -0,0 +1,56 @@
+<?php
+
+namespace App\Download\Action\Handler;
+
+use App\Download\Action\Command\DownloadMediaCommand;
+use App\Download\Action\Result\DownloadMediaResult;
+use App\Download\Framework\Repository\DownloadRepository;
+use App\Download\Downloader\DownloaderInterface;
+use OneToMany\RichBundle\Contract\CommandInterface;
+use OneToMany\RichBundle\Contract\HandlerInterface;
+use OneToMany\RichBundle\Contract\ResultInterface;
+use Symfony\Component\Messenger\Exception\UnrecoverableMessageHandlingException;
+
+/** @implements HandlerInterface<DownloadMediaCommand, DownloadMediaResult> */
+readonly class DownloadMediaHandler implements HandlerInterface
+{
+    public function __construct(
+        private DownloaderInterface $downloader,
+        private DownloadRepository $downloadRepository,
+    ) {}
+
+    public function handle(CommandInterface $command): ResultInterface
+    {
+        if (null === $command->downloadId) {
+            $download = $this->downloadRepository->insert(
+                $command->url,
+                $command->title,
+                $command->filename,
+                $command->imdbId,
+                $command->mediaType,
+                ""
+            );
+        } else {
+            $download = $this->downloadRepository->find($command->downloadId);
+        }
+
+
+        try {
+            $this->downloadRepository->updateStatus($download->getId(), 'In Progress');
+
+            $this->downloader->download(
+                $command->mediaType,
+                $command->title,
+                $command->url,
+                $download->getId()
+            );
+
+            $this->downloadRepository->updateStatus($download->getId(), 'Complete');
+
+        } catch (\Throwable $exception) {
+            throw new UnrecoverableMessageHandlingException($exception->getMessage(), 500);
+        }
+
+        return new DownloadMediaResult(200, "Success.");
+    }
+}

src/Download/Action/Handler/GetDownloadOptionsHandler.php

@@ -1,22 +0,0 @@
-<?php
-
-namespace App\Download\Action\Handler;
-
-use App\Tmdb\Tmdb;
-use App\Torrentio\Client\Torrentio;
-use OneToMany\RichBundle\Contract\CommandInterface;
-use OneToMany\RichBundle\Contract\HandlerInterface;
-use OneToMany\RichBundle\Contract\ResultInterface;
-
-class GetDownloadOptionsHandler implements HandlerInterface
-{
-    public function __construct(
-        private readonly Tmdb $tmdb,
-        private readonly Torrentio $torrentio,
-    ) {}
-
-    public function handle(CommandInterface $command): ResultInterface
-    {
-        $media = $this->tmdb->mediaDetails($command->tmdbId, $command->mediaType);
-    }
-}

src/Download/Action/Input/DownloadMediaInput.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace App\Download\Action\Input;
+
+use App\Download\Action\Command\DownloadMediaCommand;
+use OneToMany\RichBundle\Attribute\SourceRequest;
+use OneToMany\RichBundle\Contract\CommandInterface;
+use OneToMany\RichBundle\Contract\InputInterface;
+
+/** @implements InputInterface<DownloadMediaInput> */
+class DownloadMediaInput implements InputInterface
+{
+    public function __construct(
+        #[SourceRequest('url')]
+        public string $url,
+
+        #[SourceRequest('title')]
+        public string $title,
+
+        #[SourceRequest('filename')]
+        public string $filename,
+
+        #[SourceRequest('mediaType')]
+        public string $mediaType,
+
+        #[SourceRequest('imdbId')]
+        public string $imdbId,
+
+        public ?int $downloadId = null,
+    ) {}
+
+    public function toCommand(): CommandInterface
+    {
+        return new DownloadMediaCommand(
+            $this->url,
+            $this->title,
+            $this->filename,
+            $this->mediaType,
+            $this->imdbId,
+            $this->downloadId,
+        );
+    }
+}

src/Download/Action/Input/GetDownloadOptionsInput.php

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

src/Download/Action/Result/DownloadMediaResult.php

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

src/Download/Action/Result/GetDownloadOptionsResult.php

@@ -1,12 +0,0 @@
-<?php
-
-namespace App\Download\Action\Result;
-
-use App\Tmdb\TmdbResult;
-
-class GetDownloadOptionsResult
-{
-    public function __construct(
-        public TmdbResult $media,
-    ) {}
-}

src/Download/Downloader/DownloaderInterface.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Download\Downloader;
+
+
+use App\Message\DownloadMessage;
+use App\Message\DownloadMovieMessage;
+use App\Message\DownloadTvShowMessage;
+
+interface DownloaderInterface
+{
+    /**
+     * @param string $baseDir
+     * @param string $title
+     * @param string $url
+     * @return void
+     * Downloads the requested file.
+     */
+    public function download(string $baseDir, string $title, string $url, ?int $downloadId): void;
+}

src/Download/Downloader/ProcessDownloader.php

@@ -0,0 +1,64 @@
+<?php
+
+namespace App\Download\Downloader;
+
+use App\Download\Framework\Entity\Download;
+use Doctrine\ORM\EntityManagerInterface;
+use Symfony\Component\Process\Exception\ProcessFailedException;
+use Symfony\Component\Process\Process;
+
+class ProcessDownloader implements DownloaderInterface
+{
+    public function __construct(
+        private EntityManagerInterface $entityManager,
+    ) {}
+
+    /**
+     * @inheritDoc
+     */
+    public function download(string $baseDir, string $title, string $url, ?int $downloadId): void
+    {
+        /** @var Download $downloadEntity */
+        $downloadEntity = $this->entityManager->getRepository(Download::class)->find($downloadId);
+        $downloadEntity->setProgress(0);
+        $this->entityManager->flush();
+
+        $process = new Process([
+            '/bin/sh',
+            '/var/www/bash/app/wget_download.sh',
+            $baseDir,
+            $title,
+            $url
+        ]);
+
+        $process->setTimeout(1800); // 30 min
+        $process->setIdleTimeout(600); // 10 min
+
+        $process->start();
+
+        try {
+            $progress = 0;
+            $this->entityManager->flush();
+            $process->wait(function ($type, $buffer) use ($progress, $downloadEntity): void {
+                if (Process::ERR === $type) {
+                    $pregMatchOutput = [];
+                    preg_match('/[\d]+%/', $buffer, $pregMatchOutput);
+
+                    if (!empty($pregMatchOutput)) {
+                        if ($pregMatchOutput[0] !== $progress) {
+                            $progress = (int) $pregMatchOutput[0];
+                            $downloadEntity->setProgress($progress);
+                            $this->entityManager->flush();
+                        }
+                    }
+                }
+                fwrite(STDOUT, $buffer);
+            });
+            $downloadEntity->setProgress(100);
+        } catch (ProcessFailedException $exception) {
+            $downloadEntity->setStatus('Failed');
+        }
+
+        $this->entityManager->flush();
+    }
+}

src/Download/Downloader/WgetDownloader.php

@@ -0,0 +1,27 @@
+<?php
+
+namespace App\Download\Downloader;
+
+use App\Message\DownloadMessage;
+use App\Message\DownloadMovieMessage;
+use App\Message\DownloadTvShowMessage;
+
+class WgetDownloader implements DownloaderInterface
+{
+
+    /**
+     * @inheritDoc
+     * SSHs into the NAS and performs the download.
+     * This way retains the fast DL speed on the NAS.
+     */
+    public function download(string $baseDir, string $title, string $url, ?int $downloadId): void
+    {
+        // SSHs into the NAS, cds into movies dir, makes new dir based on filename, cds into that dir, downloads movie
+        system(sprintf(
+            'sh /var/www/bash/app/wget_download.sh "%s" "%s" "%s"',
+            $baseDir,
+            $title,
+            $url
+        ));
+    }
+}

src/Download/Framework/Entity/Download.php

@@ -0,0 +1,149 @@
+<?php
+
+namespace App\Download\Framework\Entity;
+
+use App\Download\Framework\Repository\DownloadRepository;
+use Doctrine\ORM\Mapping as ORM;
+use Symfony\UX\Turbo\Attribute\Broadcast;
+
+#[ORM\Entity(repositoryClass: DownloadRepository::class)]
+#[Broadcast(template: 'broadcast/Download.stream.html.twig')]
+class Download
+{
+    #[ORM\Id]
+    #[ORM\GeneratedValue]
+    #[ORM\Column]
+    private ?int $id = null;
+
+    #[ORM\Column(length: 20, nullable: true)]
+    private ?string $imdbId = null;
+
+    #[ORM\Column(length: 255, nullable: true)]
+    private ?string $mediaType = null;
+
+    #[ORM\Column(length: 255, nullable: true)]
+    private ?string $title = null;
+
+    #[ORM\Column(length: 1024)]
+    private ?string $url = null;
+
+    #[ORM\Column(length: 1024, nullable: true)]
+    private ?string $filename = null;
+
+    #[ORM\Column(length: 255, nullable: true)]
+    private ?string $status = null;
+
+    #[ORM\Column(nullable: true)]
+    private ?int $progress = null;
+
+    #[ORM\Column(length: 255, nullable: true)]
+    private ?string $batchId = null;
+
+    public function getId(): ?int
+    {
+        return $this->id;
+    }
+
+    public function setId(int $id): static
+    {
+        $this->id = $id;
+
+        return $this;
+    }
+
+    public function getImdbId(): ?string
+    {
+        return $this->imdbId;
+    }
+
+    public function setImdbId(?string $imdbId): static
+    {
+        $this->imdbId = $imdbId;
+
+        return $this;
+    }
+
+    public function getMediaType(): ?string
+    {
+        return $this->mediaType;
+    }
+
+    public function setMediaType(?string $mediaType): static
+    {
+        $this->mediaType = $mediaType;
+
+        return $this;
+    }
+
+    public function getTitle(): ?string
+    {
+        return $this->title;
+    }
+
+    public function setTitle(?string $title): static
+    {
+        $this->title = $title;
+
+        return $this;
+    }
+
+    public function getUrl(): ?string
+    {
+        return $this->url;
+    }
+
+    public function setUrl(string $url): static
+    {
+        $this->url = $url;
+
+        return $this;
+    }
+
+    public function getFilename(): ?string
+    {
+        return $this->filename;
+    }
+
+    public function setFilename(?string $filename): static
+    {
+        $this->filename = $filename;
+
+        return $this;
+    }
+
+    public function getStatus(): ?string
+    {
+        return $this->status;
+    }
+
+    public function setStatus(?string $status): static
+    {
+        $this->status = $status;
+
+        return $this;
+    }
+
+    public function getProgress(): ?int
+    {
+        return $this->progress;
+    }
+
+    public function setProgress(?int $progress): static
+    {
+        $this->progress = $progress;
+
+        return $this;
+    }
+
+    public function getBatchId(): ?string
+    {
+        return $this->batchId;
+    }
+
+    public function setBatchId(?string $batchId): static
+    {
+        $this->batchId = $batchId;
+
+        return $this;
+    }
+}

src/Download/Framework/MessageHandler/DownloadMediaMessageHandler.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Download\Framework\MessageHandler;
+
+use App\Download\Action\Command\DownloadMediaCommand;
+use App\Download\Action\Handler\DownloadMediaHandler;
+use Symfony\Component\Messenger\Attribute\AsMessageHandler;
+
+#[AsMessageHandler(handles: DownloadMediaCommand::class)]
+class DownloadMediaMessageHandler
+{
+    public function __construct(
+        private DownloadMediaHandler $downloadMediaHandler,
+    ) {}
+
+    public function __invoke(DownloadMediaCommand $command)
+    {
+        $this->downloadMediaHandler->handle($command);
+    }
+}

src/Download/Framework/Repository/DownloadRepository.php

@@ -0,0 +1,130 @@
+<?php
+
+namespace App\Download\Framework\Repository;
+
+use App\Download\Framework\Entity\Download;
+use App\ValueObject\DownloadRequest;
+use Doctrine\Bundle\DoctrineBundle\Repository\ServiceEntityRepository;
+use Doctrine\Persistence\ManagerRegistry;
+use Knp\Component\Pager\Paginator;
+use Knp\Component\Pager\PaginatorInterface;
+
+/**
+ * @extends ServiceEntityRepository<Download>
+ */
+class DownloadRepository extends ServiceEntityRepository
+{
+    private ManagerRegistry $managerRegistry;
+
+    public function __construct(ManagerRegistry $registry, ManagerRegistry $managerRegistry)
+    {
+        parent::__construct($registry, Download::class);
+        $this->managerRegistry = $managerRegistry;
+    }
+
+    public function getCompletePaginated(int $pageNumber = 1, int $perPage = 10)
+    {
+        $firstResult = ($pageNumber - 1) * $perPage;
+        $query = $this->createQueryBuilder('d')
+            ->andWhere('d.status IN (:statuses)')
+            ->orderBy('d.id', 'DESC')
+            ->setParameter('statuses', ['Complete'])
+            ->setFirstResult($firstResult)
+            ->setMaxResults($perPage)
+            ->getQuery();
+
+        return new \Doctrine\ORM\Tools\Pagination\Paginator($query);
+    }
+
+    public function getActivePaginated(int $pageNumber = 1, int $perPage = 5)
+    {
+        $firstResult = ($pageNumber - 1) * $perPage;
+        $query = $this->createQueryBuilder('d')
+            ->andWhere('d.status IN (:statuses)')
+            ->orderBy('d.id', 'DESC')
+            ->setParameter('statuses', ['New', 'In Progress'])
+            ->setFirstResult($firstResult)
+            ->setMaxResults($perPage)
+            ->getQuery();
+
+        return new \Doctrine\ORM\Tools\Pagination\Paginator($query);
+    }
+
+    public function insert(
+        string $url,
+        string $title,
+        string $filename,
+        string $imdbId,
+        string $mediaType,
+        string $batchId,
+        string $status = 'New'
+    ): Download {
+        $download = (new Download())
+            ->setUrl($url)
+            ->setTitle($title)
+            ->setFilename($filename)
+            ->setImdbId($imdbId)
+            ->setMediaType($mediaType)
+            ->setBatchId($batchId)
+            ->setStatus($status);
+
+        $this->getEntityManager()->persist($download);
+        $this->getEntityManager()->flush();
+
+        return $download;
+    }
+
+    public function insertFromDownloadRequest(DownloadRequest $request): Download
+    {
+        $download = (new Download())
+            ->setUrl($request->downloadUrl)
+            ->setTitle($request->seriesName)
+            ->setFilename($request->filename)
+            ->setImdbId($request->imdbCode)
+            ->setMediaType($request->mediaType)
+            ->setStatus('New');
+
+        $this->getEntityManager()->persist($download);
+        $this->getEntityManager()->flush();
+
+        return $download;
+    }
+
+    public function updateStatus(int $id, string $status): Download
+    {
+        $download = $this->find($id);
+        $download->setStatus($status);
+        $this->getEntityManager()->flush();
+        return $download;
+    }
+
+    public function delete(int $id)
+    {
+        $entity = $this->find($id);
+        $this->getEntityManager()->remove($entity);
+        $this->getEntityManager()->flush();
+    }
+
+    public function getPendingByBatchId(string $batchId): ?array
+    {
+        $query = $this->createQueryBuilder('d')
+            ->andWhere('d.status IN (:statuses)')
+            ->andWhere('d.batchId = :batchId')
+            ->setParameter('statuses', ['New', 'In Progress'])
+            ->setParameter('batchId', $batchId)
+            ->getQuery();
+
+        return $query->getResult();
+    }
+
+    public function latest(int $limit = 1)
+    {
+        return $this->createQueryBuilder('d')
+            ->andWhere('d.status IN (:statuses)')
+            ->setParameter('statuses', ['Complete'])
+            ->setMaxResults($limit)
+            ->orderBy('d.id', 'DESC')
+            ->getQuery()
+            ->getResult();
+    }
+}

src/Search/Action/Command/GetMediaInfoCommand.php

@@ -4,9 +4,9 @@ namespace App\Search\Action\Command;
 
 use OneToMany\RichBundle\Contract\CommandInterface;
 
+/** @implements CommandInterface<GetMediaInfoCommand> */
 class GetMediaInfoCommand implements CommandInterface
 {
-    /** @implements CommandInterface<GetMediaInfoCommand> */
     public function __construct(
         public string $tmdbId,
         public string $mediaType,

src/Search/Action/Command/SearchCommand.php

@@ -4,12 +4,9 @@ namespace App\Search\Action\Command;
 
 use OneToMany\RichBundle\Contract\CommandInterface;
 
+/** @implements CommandInterface<SearchCommand> */
 class SearchCommand implements CommandInterface
 {
-    /**
-     * @param string $term
-     * @implements CommandInterface<SearchCommand>
-     */
     public function __construct(
         public string $term
     ) {}

src/Search/Action/Handler/GetMediaInfoHandler.php

@@ -2,12 +2,14 @@
 
 namespace App\Search\Action\Handler;
 
+use App\Search\Action\Command\GetMediaInfoCommand;
 use App\Search\Action\Result\GetMediaInfoResult;
 use App\Tmdb\Tmdb;
 use OneToMany\RichBundle\Contract\CommandInterface;
 use OneToMany\RichBundle\Contract\HandlerInterface;
 use OneToMany\RichBundle\Contract\ResultInterface;
 
+/** @implements HandlerInterface<GetMediaInfoCommand, GetMediaInfoResult> */
 class GetMediaInfoHandler implements HandlerInterface
 {
     public function __construct(

src/Search/Action/Handler/SearchHandler.php

@@ -8,13 +8,13 @@ use OneToMany\RichBundle\Contract\CommandInterface;
 use OneToMany\RichBundle\Contract\HandlerInterface;
 use OneToMany\RichBundle\Contract\ResultInterface;
 
+/*** @implements HandlerInterface<SearchResult> */
 class SearchHandler implements HandlerInterface
 {
     public function __construct(
         private Tmdb $tmdb,
     ) {}
 
-    /*** @implements HandlerInterface<SearchResult> */
     public function handle(CommandInterface $command): ResultInterface
     {
         return new SearchResult(

src/Search/Action/Input/GetMediaInfoInput.php

@@ -2,12 +2,13 @@
 
 namespace App\Search\Action\Input;
 
-use App\Download\Action\Command\GetDownloadOptionsCommand;
+use App\Download\Action\Command\DownloadMediaCommand;
 use App\Search\Action\Command\GetMediaInfoCommand;
 use OneToMany\RichBundle\Attribute\SourceRoute;
 use OneToMany\RichBundle\Contract\CommandInterface;
 use OneToMany\RichBundle\Contract\InputInterface;
 
+/** @implements InputInterface<GetMediaInfoInput> */
 class GetMediaInfoInput implements InputInterface
 {
     public function __construct(

src/Search/Action/Input/SearchInput.php

@@ -8,9 +8,7 @@ use OneToMany\RichBundle\Attribute\SourceRequest;
 use OneToMany\RichBundle\Contract\CommandInterface;
 use OneToMany\RichBundle\Contract\InputInterface;
 
-/**
- * @implements InputInterface<SearchCommand>
- */
+/** @implements InputInterface<SearchCommand> */
 class SearchInput implements InputInterface
 {
     public function __construct(

src/Search/Action/Result/GetMediaInfoResult.php

@@ -5,9 +5,9 @@ namespace App\Search\Action\Result;
 use App\Tmdb\TmdbResult;
 use OneToMany\RichBundle\Contract\ResultInterface;
 
+/** @implements ResultInterface<GetMediaInfoResult> */
 class GetMediaInfoResult implements ResultInterface
 {
-    /** @implements ResultInterface<GetMediaInfoResult> */
     public function __construct(
         public TmdbResult $media,
     ) {}

src/Search/Action/Result/SearchResult.php

@@ -4,6 +4,7 @@ namespace App\Search\Action\Result;
 
 use OneToMany\RichBundle\Contract\ResultInterface;
 
+/** @implements ResultInterface<SearchResult> */
 class SearchResult implements ResultInterface
 {
     public function __construct(

src/Tmdb/Tmdb.php

@@ -94,12 +94,35 @@ class Tmdb
         $this->tvRepository = new TvRepository($this->client);
     }
 
-    public function popularMovies(int $page = 1)
+    public function popularMovies(int $page = 1, ?int $limit = null)
     {
         $movies = $this->movieRepository->getPopular(['page' => $page]);
 
-        foreach ($movies as $movie) {
-            $this->parseResult($movie);
+        $movies = $movies->map(function ($movie) use ($movies) {
+            return $this->parseResult($movies[$movie], "movie");
+        });
+
+        $movies = array_values($movies->toArray());
+
+        if (null !== $limit) {
+            $movies = array_slice($movies, 0, $limit);
+        }
+
+        return $movies;
+    }
+
+    public function popularTvShows(int $page = 1, ?int $limit = null)
+    {
+        $movies = $this->tvRepository->getPopular(['page' => $page]);
+
+        $movies = $movies->map(function ($movie) use ($movies) {
+            return $this->parseResult($movies[$movie], "movie");
+        });
+
+        $movies = array_values($movies->toArray());
+
+        if (null !== $limit) {
+            $movies = array_slice($movies, 0, $limit);
         }
 
         return $movies;

src/Torrentio/Action/Command/GetMovieOptionsCommand.php

@@ -7,6 +7,7 @@ use OneToMany\RichBundle\Contract\CommandInterface;
 class GetMovieOptionsCommand implements CommandInterface
 {
     public function __construct(
+        public string $tmdbId,
         public string $imdbId,
     ) {}
 }

src/Torrentio/Action/Handler/GetMovieOptionsHandler.php

@@ -2,6 +2,7 @@
 
 namespace App\Torrentio\Action\Handler;
 
+use App\Tmdb\Tmdb;
 use App\Torrentio\Action\Result\GetMovieOptionsResult;
 use App\Torrentio\Client\Torrentio;
 use OneToMany\RichBundle\Contract\CommandInterface;
@@ -11,13 +12,15 @@ use OneToMany\RichBundle\Contract\ResultInterface;
 class GetMovieOptionsHandler implements HandlerInterface
 {
     public function __construct(
+        private readonly Tmdb $tmdb,
         private readonly Torrentio $torrentio,
     ) {}
 
     public function handle(CommandInterface $command): ResultInterface
     {
         return new GetMovieOptionsResult(
-            results: $this->torrentio->search($command->imdbId, 'movies')
+            media: $this->tmdb->mediaDetails($command->tmdbId, 'movies'),
+            results: $this->torrentio->search($command->imdbId, 'movies'),
         );
     }
 }

src/Torrentio/Action/Handler/GetTvShowOptionsHandler.php

@@ -3,12 +3,14 @@
 namespace App\Torrentio\Action\Handler;
 
 use App\Tmdb\Tmdb;
+use App\Torrentio\Action\Command\GetTvShowOptionsCommand;
 use App\Torrentio\Action\Result\GetTvShowOptionsResult;
 use App\Torrentio\Client\Torrentio;
 use OneToMany\RichBundle\Contract\CommandInterface;
 use OneToMany\RichBundle\Contract\HandlerInterface;
 use OneToMany\RichBundle\Contract\ResultInterface;
 
+/** @implements HandlerInterface<GetTvShowOptionsCommand, GetTvShowOptionsResult> */
 class GetTvShowOptionsHandler implements HandlerInterface
 {
     public function __construct(

src/Torrentio/Action/Input/GetMovieOptionsInput.php

@@ -10,12 +10,15 @@ use OneToMany\RichBundle\Contract\InputInterface;
 class GetMovieOptionsInput implements InputInterface
 {
     public function __construct(
+        #[SourceRoute('tmdbId')]
+        public string $tmdbId,
+
         #[SourceRoute('imdbId')]
         public string $imdbId,
     ) {}
 
     public function toCommand(): CommandInterface
     {
-        return new GetMovieOptionsCommand($this->imdbId);
+        return new GetMovieOptionsCommand($this->tmdbId, $this->imdbId);
     }
 }

src/Torrentio/Action/Result/GetMovieOptionsResult.php

@@ -2,11 +2,13 @@
 
 namespace App\Torrentio\Action\Result;
 
+use App\Tmdb\TmdbResult;
 use OneToMany\RichBundle\Contract\ResultInterface;
 
 class GetMovieOptionsResult implements ResultInterface
 {
     public function __construct(
+        public TmdbResult $media,
         public array $results
     ) {}
 }

src/Torrentio/Result/ResultFactory.php

@@ -15,7 +15,8 @@ class ResultFactory
         $ptn = (object) (new PTN())->parse($title);
         return new TorrentioResult(
             self::trimTitle($title),
-            $url,
+            urldecode($url),
+            self::setFilename($url),
             self::setSize($title),
             self::setSeeders($title),
             self::setProvider($title),
@@ -33,6 +34,12 @@ class ResultFactory
         );
     }
 
+    public static function setFilename(string $url)
+    {
+        $file = explode("/", urldecode($url));
+        return end($file);
+    }
+
     public static function setSize(string $title): string
     {
         $sizeMatch = [];

src/Torrentio/Result/TorrentioResult.php

@@ -7,6 +7,7 @@ class TorrentioResult
     public function __construct(
         public ?string $title = "-",
         public ?string $url = "-",
+        public ?string $filename = "-",
         public ?string $size = "-",
         public ?string $seeders = "-",
         public ?string $provider = "-",

src/Twig/Components/ActiveDownloadList.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace App\Twig\Components;
+
+use App\Download\Framework\Repository\DownloadRepository;
+use Symfony\UX\LiveComponent\Attribute\AsLiveComponent;
+use Symfony\UX\LiveComponent\Attribute\LiveAction;
+use Symfony\UX\LiveComponent\DefaultActionTrait;
+
+#[AsLiveComponent]
+final class ActiveDownloadList
+{
+    use DefaultActionTrait;
+
+    public function __construct(
+        private DownloadRepository $downloadRepository,
+    ) {}
+
+    #[LiveAction]
+    public function getDownloads()
+    {
+        return $this->downloadRepository->getActivePaginated();
+    }
+}

src/Twig/Components/Alert.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace App\Twig\Components;
+
+use Symfony\UX\LiveComponent\Attribute\AsLiveComponent;
+use Symfony\UX\LiveComponent\DefaultActionTrait;
+
+#[AsLiveComponent]
+final class Alert
+{
+    use DefaultActionTrait;
+}

symfony.lock

@@ -2,6 +2,33 @@
     "1tomany/rich-bundle": {
         "version": "v1.8.3"
     },
+    "doctrine/doctrine-bundle": {
+        "version": "2.14",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "2.13",
+            "ref": "8d96c0b51591ffc26794d865ba3ee7d193438a83"
+        },
+        "files": [
+            "config/packages/doctrine.yaml",
+            "src/Entity/.gitignore",
+            "src/Repository/.gitignore"
+        ]
+    },
+    "doctrine/doctrine-migrations-bundle": {
+        "version": "3.4",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "3.1",
+            "ref": "1d01ec03c6ecbd67c3375c5478c9a423ae5d6a33"
+        },
+        "files": [
+            "config/packages/doctrine_migrations.yaml",
+            "migrations/.gitignore"
+        ]
+    },
     "php-http/discovery": {
         "version": "1.20",
         "recipe": {
@@ -54,6 +81,18 @@
             ".env.dev"
         ]
     },
+    "symfony/form": {
+        "version": "7.2",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "7.2",
+            "ref": "7d86a6723f4a623f59e2bf966b6aad2fc461d36b"
+        },
+        "files": [
+            "config/packages/csrf.yaml"
+        ]
+    },
     "symfony/framework-bundle": {
         "version": "7.2",
         "recipe": {
@@ -82,6 +121,30 @@
             "ref": "fadbfe33303a76e25cb63401050439aa9b1a9c7f"
         }
     },
+    "symfony/mercure-bundle": {
+        "version": "0.3",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "0.3",
+            "ref": "528285147494380298f8f991ee8c47abebaf79db"
+        },
+        "files": [
+            "config/packages/mercure.yaml"
+        ]
+    },
+    "symfony/messenger": {
+        "version": "7.2",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "6.0",
+            "ref": "ba1ac4e919baba5644d31b57a3284d6ba12d52ee"
+        },
+        "files": [
+            "config/packages/messenger.yaml"
+        ]
+    },
     "symfony/routing": {
         "version": "7.2",
         "recipe": {
@@ -148,6 +211,27 @@
             "assets/icons/symfony.svg"
         ]
     },
+    "symfony/ux-live-component": {
+        "version": "2.24",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "2.6",
+            "ref": "73e69baf18f47740d6f58688c5464b10cdacae06"
+        },
+        "files": [
+            "config/routes/ux_live_component.yaml"
+        ]
+    },
+    "symfony/ux-turbo": {
+        "version": "2.24",
+        "recipe": {
+            "repo": "github.com/symfony/recipes",
+            "branch": "main",
+            "version": "2.20",
+            "ref": "c85ff94da66841d7ff087c19cbcd97a2df744ef9"
+        }
+    },
     "symfony/ux-twig-component": {
         "version": "2.24",
         "recipe": {

templates/broadcast/Alert.html.twig

@@ -0,0 +1,5 @@
+<turbo-stream action="prepend" target="alert_list">
+    <template>
+        <twig:Alert :title="title|default('')" :message="message" :alert_id="alert_id" data-controller="alert" />
+    </template>
+</turbo-stream>

templates/broadcast/Download.stream.html.twig

@@ -0,0 +1,69 @@
+{# Learn how to use Turbo Streams: https://github.com/symfony/ux-turbo#broadcast-doctrine-entities-update #}
+{% block create %}
+    <turbo-stream action="append" target="active_downloads">
+        <template>
+            <tr id="ad_download_{{ entity.id }}">
+                <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800 min-w-[45ch] max-w-[45ch] truncate">
+                    {{ entity.title }}
+                </td>
+                <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
+                    <span class="p-1.5 bg-purple-600 rounded-full">
+                        <span class="w-4 inline-block text-center text-gray-50">{{ entity.progress }}</span>
+                    </span>
+                </td>
+            </tr>
+        </template>
+    </turbo-stream>
+
+    <turbo-stream action="prepend" target="alert_list">
+        <template>
+            <twig:Alert title="Success" message="{{ entity.title }} has been added to the Download queue" alert_id="{{ entity.id }}" data-controller="alert" />
+        </template>
+    </turbo-stream>
+{% endblock %}
+
+{% block update %}
+    {% if entity.status != "Complete" %}
+        <turbo-stream action="update" target="ad_download_{{ id }}">
+            <template>
+                <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800 min-w-[45ch] max-w-[45ch] truncate">
+                    {{ entity.title }}
+                </td>
+                <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
+                    <span class="p-1.5 bg-purple-600 rounded-full">
+                        <span class="w-4 inline-block text-center text-gray-50">{{ entity.progress }}</span>
+                    </span>
+                </td>
+            </template>
+        </turbo-stream>
+    {% else %}
+        <turbo-stream action="remove" target="ad_download_{{ id }}">
+        </turbo-stream>
+
+        <turbo-stream action="prepend" target="alert_list">
+            <template>
+                <twig:Alert title="Finished downloading" message="{{ entity.title }}" alert_id="{{ entity.id }}" data-controller="alert" />
+            </template>
+        </turbo-stream>
+
+        <turbo-stream action="prepend" target="recent_downloads">
+            <template>
+                <tr id="recent_download_{{ entity.id }}">
+                    <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800 min-w-[45ch] max-w-[45ch] truncate">
+                        {{ entity.title }}
+                    </td>
+                    <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
+                    <span class="p-1.5 bg-purple-600 rounded-full">
+                        <span class="w-4 inline-block text-center text-gray-50">{{ entity.progress }}</span>
+                    </span>
+                    </td>
+                </tr>
+            </template>
+        </turbo-stream>
+    {% endif %}
+{% endblock %}
+
+{% block remove %}
+    <turbo-stream action="remove" target="ad_download_{{ id }}"></turbo-stream>
+{#    <turbo-stream action="remove" target="cd_download_{{ id }}"></turbo-stream>#}
+{% endblock %}

templates/components/ActiveDownloadList.html.twig

@@ -0,0 +1,39 @@
+<div{{ attributes }} class="min-w-48">
+    <table id="active_downloads" class="divide-y divide-gray-200 dark:divide-gray-50 dark:bg-gray-50 table-fixed" {{ turbo_stream_listen('App\\Download\\Framework\\Entity\\Download') }}>
+        <thead>
+        <tr class="dark:bg-gray-50">
+            <th scope="col"
+                class="px-6 py-3 text-start text-xs font-medium text-stone-500 uppercase dark:text-stone-800  min-w-[55ch] max-w-[55ch] truncate">
+                Title
+            </th>
+            <th scope="col"
+                class="px-6 py-3 text-start text-xs font-medium text-gray-500 uppercase dark:text-stone-800">
+                Progress
+            </th>
+        </tr>
+        </thead>
+        <tbody class="divide-y divide-gray-200 dark:divide-gray-50">
+        {% if this.getDownloads()|length > 0 %}
+            {% for download in this.getDownloads() %}
+                <tr  id="ad_download_{{ download.id }}">
+                    <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800 min-w-[45ch] max-w-[45ch] truncate">
+                        {{ download.title }}
+                    </td>
+                    <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
+                        <span class="p-1.5 bg-purple-600 rounded-full">
+                            <span class="w-4 inline-block text-center text-gray-50">{{ download.progress }}</span>
+                        </span>
+                    </td>
+                </tr>
+            {% endfor %}
+        {% else %}
+            <tr>
+                <td class="px-6 py-4 whitespace-nowrap text-xs uppercase text-center col-span-2 font-medium text-gray-800 dark:text-stone-800" colspan="2">
+                    No active downloads
+                </td>
+            </tr>
+        {% endif %}
+        </tbody>
+    </table>
+</div>
+

templates/components/Alert.html.twig

@@ -0,0 +1,23 @@
+<li {{ attributes }} id="alert_{{ alert_id }}" class="alert p-4 text-green-800 border border-green-300 rounded-lg bg-green-50 dark:bg-gray-800 dark:text-green-400 dark:border-green-800" role="alert">
+    <div class="flex items-center">
+        <svg class="shrink-0 w-4 h-4 me-2" aria-hidden="true" xmlns="http://www.w3.org/2000/svg" fill="currentColor" viewBox="0 0 20 20">
+            <path d="M10 .5a9.5 9.5 0 1 0 9.5 9.5A9.51 9.51 0 0 0 10 .5ZM9.5 4a1.5 1.5 0 1 1 0 3 1.5 1.5 0 0 1 0-3ZM12 15H8a1 1 0 0 1 0-2h1v-3H8a1 1 0 0 1 0-2h2a1 1 0 0 1 1 1v4h1a1 1 0 0 1 0 2Z"/>
+        </svg>
+        <span class="sr-only">Info</span>
+        <h3 class="text-lg font-medium">{{ title|default('') }}</h3>
+    </div>
+    <div class="mt-2 text-sm">
+        {{ message }}
+    </div>
+{#    <div class="flex">#}
+{#        <button type="button" class="text-white bg-green-800 hover:bg-green-900 focus:ring-4 focus:outline-none focus:ring-green-300 font-medium rounded-lg text-xs px-3 py-1.5 me-2 text-center inline-flex items-center dark:bg-green-600 dark:hover:bg-green-700 dark:focus:ring-green-800">#}
+{#            <svg class="me-2 h-3 w-3" aria-hidden="true" xmlns="http://www.w3.org/2000/svg" fill="currentColor" viewBox="0 0 20 14">#}
+{#                <path d="M10 0C4.612 0 0 5.336 0 7c0 1.742 3.546 7 10 7 6.454 0 10-5.258 10-7 0-1.664-4.612-7-10-7Zm0 10a3 3 0 1 1 0-6 3 3 0 0 1 0 6Z"/>#}
+{#            </svg>#}
+{#            View more#}
+{#        </button>#}
+{#        <button type="button" class="text-green-800 bg-transparent border border-green-800 hover:bg-green-900 hover:text-white focus:ring-4 focus:outline-none focus:ring-green-300 font-medium rounded-lg text-xs px-3 py-1.5 text-center dark:hover:bg-green-600 dark:border-green-600 dark:text-green-400 dark:hover:text-white dark:focus:ring-green-800" data-dismiss-target="#alert-additional-content-3" aria-label="Close">#}
+{#            Dismiss#}
+{#        </button>#}
+{#    </div>#}
+</li>

templates/components/Header.html.twig

@@ -12,4 +12,10 @@
             </div>
         </div>
     </div>
+    <div {{ turbo_stream_listen('alerts') }} class="absolute top-10 right-10 size-96">
+        <div >
+            <ul id="alert_list">
+            </ul>
+        </div>
+    </div>
 </header>

templates/components/NavBar.html.twig

@@ -3,7 +3,7 @@
         <ul class="mt-6 space-y-1">
             <li>
                 <a
-                        href="#"
+                        href="{{ path('app_index') }}"
                         class="block rounded-lg
                          bg-orange-500 hover:bg-opacity-80 bg-clip-padding backdrop-filter backdrop-blur-md bg-opacity-60
                          px-4 py-2 text-sm font-medium text-gray-50"

templates/components/Poster.html.twig

@@ -1,4 +1,14 @@
 <div{{ attributes }}>
-    <img src="{{ image }}" class="w-40 rounded-md" />
-    <h3 class="text-center text-gray-50 text-extrabold">{{ title }}</h3>
+    <a href="{{ path('app_search_result', {
+        mediaType: mediaType,
+        tmdbId: tmdbId
+    }) }}">
+        <img src="{{ image }}" class="w-40 rounded-md" />
+    </a>
+    <a href="{{ path('app_search_result', {
+        mediaType: mediaType,
+        tmdbId: tmdbId
+    }) }}">
+        <h3 class="text-center text-gray-50 max-w-[16ch] text-extrabold">{{ title }}</h3>
+    </a>
 </div>

templates/components/SearchBar.html.twig

@@ -1,6 +1,6 @@
 <div {{ attributes }} class="w-full max-w-sm min-w-[200px]">
     <div class="relative">
-        <form action="{{ url('app_search') }}">
+        <form action="{{ path('app_search') }}">
             <input
                     name="term"
                     class="w-full bg-orange-500 rounded-md bg-clip-padding backdrop-filter

templates/components/SearchResult.html.twig

@@ -10,7 +10,7 @@
             </p>
         </div>
         <a class="h-9 rounded-md py-1 px-2 bg-green-600 text-gray-50"
-           href="{{ url('app_search_result', {mediaType: mediaType, tmdbId: tmdbId}) }}"
+           href="{{ path('app_search_result', {mediaType: mediaType, tmdbId: tmdbId}) }}"
            >choose</a>
     </div>
 </div>

templates/index/index.html.twig

@@ -1,64 +1,17 @@
 {% extends 'base.html.twig' %}
 
-{% block title %}Dashboard &mdash - Torsearch{% endblock %}
+{% block title %}Dashboard — Torsearch{% endblock %}
 
 {% block body %}
     <div class="p-4 flex flex-col grow gap-4">
         <h2 class="mb-2 text-3xl font-bold text-gray-50">Dashboard</h2>
         <div class="flex flex-row gap-4">
             <twig:Card title="Active Downloads" class="w-full">
-                <table class="divide-y divide-gray-200 dark:divide-gray-50 dark:bg-gray-50">
-                    <thead>
-                    <tr class="dark:bg-gray-50">
-                        <th scope="col"
-                            class="px-6 py-3 text-start text-xs font-medium text-stone-500 uppercase dark:text-stone-800">
-                            Title
-                        </th>
-                        <th scope="col"
-                            class="px-6 py-3 text-start text-xs font-medium text-gray-500 uppercase dark:text-stone-800">
-                            Progress
-                        </th>
-                    </tr>
-                    </thead>
-                    <tbody class="divide-y divide-gray-200 dark:divide-gray-50">
-                    <tr>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800">
-                            The Wolf of Wallstreet
-                        </td>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
-                                <span class="p-1.5 bg-purple-600 rounded-full">
-                                    <span class="text-gray-50">11</span>
-                                </span>
-                        </td>
-                    </tr>
-
-                    <tr>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800">
-                            Inception
-                        </td>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
-                                <span class="p-1.5 bg-purple-600 rounded-full">
-                                    <span class="text-gray-50">36</span>
-                                </span>
-                        </td>
-                    </tr>
-
-                    <tr>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800">
-                            Hop
-                        </td>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
-                                <span class="p-1.5 bg-purple-600 rounded-full">
-                                    <span class="text-gray-50">0</span>
-                                </span>
-                        </td>
-                    </tr>
-                    </tbody>
-                </table>
+                <twig:ActiveDownloadList />
             </twig:Card>
 
             <twig:Card title="Recent Downloads" class="w-full">
-                <table class="divide-y divide-gray-200 dark:divide-gray-50 dark:bg-gray-50">
+                <table id="recent_downloads" class="divide-y divide-gray-200 dark:divide-gray-50 dark:bg-gray-50 table-fixed">
                     <thead>
                     <tr class="dark:bg-gray-50">
                         <th scope="col"
@@ -66,56 +19,65 @@
                             Title
                         </th>
                         <th scope="col"
-                            class="px-6 py-3 text-start text-xs font-medium text-end text-gray-500 uppercase dark:text-stone-800">
+                            class="px-6 py-3 text-start text-xs font-medium text-gray-500 uppercase dark:text-stone-800">
                             Status
                         </th>
                     </tr>
                     </thead>
                     <tbody class="divide-y divide-gray-200 dark:divide-gray-50">
-                    <tr>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800">
-                            The Family Plan
-                        </td>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
-                                <span class="p-1 bg-green-600 rounded-lg">
-                                    <span class="text-gray-50">Complete</span>
-                                </span>
-                        </td>
-                    </tr>
-
-                    <tr>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800">
-                            It
-                        </td>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
-                                <span class="p-1 bg-green-600 rounded-lg">
-                                    <span class="text-gray-50">Complete</span>
-                                </span>
-                        </td>
-                    </tr>
-
-                    <tr>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800">
-                            Silicon Cowboys
-                        </td>
-                        <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
-                                <span class="p-1 bg-green-600 rounded-lg">
-                                    <span class="text-gray-50">Complete</span>
-                                </span>
-                        </td>
-                    </tr>
+                    {% if recent_downloads|length > 0 %}
+                        {% for download in recent_downloads %}
+                            <tr>
+                                <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800">
+                                    {{ download.title }}
+                                </td>
+                                <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50">
+                                    <span class="p-1 bg-green-600 rounded-lg">
+                                        <span class="text-gray-50">Complete</span>
+                                    </span>
+                                </td>
+                            </tr>
+                        {% endfor %}
+                        <tr class="bg-blue-400">
+                            <td class="px-6 py-3 whitespace-nowrap text-xs uppercase text-center col-span-2 font-medium text-rose-400 dark:text-stone-800" colspan="2">
+                                <a href="#">View all downloads</a>
+                            </td>
+                        </tr>
+                    {% else %}
+                        <tr>
+                            <td class="px-6 py-4 whitespace-nowrap text-xs uppercase text-center col-span-2 font-medium text-gray-800 dark:text-stone-800" colspan="2">
+                                No recent downloads
+                            </td>
+                        </tr>
+                    {% endif %}
                     </tbody>
                 </table>
             </twig:Card>
         </div>
-        <div class="">
+        <div class="flex flex-col gap-4">
             <twig:Card title="Popular Movies" contentClass="flex flex-row justify-between w-full">
-                <twig:Poster imdbId="" title="A Working Man" description="" image="https://image.tmdb.org/t/p/w500/xUkUZ8eOnrOnnJAfusZUqKYZiDu.jpg" year="" />
-                <twig:Poster imdbId="" title="In the Lost Lands" description="" image="https://image.tmdb.org/t/p/w500/iHf6bXPghWB6gT8kFkL1zo00x6X.jpg" year="" />
-                <twig:Poster imdbId="" title="A Minecraft Movie" description="" image="https://image.tmdb.org/t/p/w500/yFHHfHcUgGAxziP1C3lLt0q2T4s.jpg" year="" />
-                <twig:Poster imdbId="" title="G20" description="" image="https://image.tmdb.org/t/p/w500/wv6oWAleCJZUk5htrGg413t3GCy.jpg" year="" />
-                <twig:Poster imdbId="" title="Novocaine" description="" image="https://image.tmdb.org/t/p/w500/xmMHGz9dVRaMY6rRAlEX4W0Wdhm.jpg" year="" />
-                <twig:Poster imdbId="" title="Gunslingers" description="" image="https://image.tmdb.org/t/p/w500/O7REXWPANWXvX2jhQydHjAq2DV.jpg" year="" />
+                {% for movie in popular_movies %}
+                    <twig:Poster imdbId=""
+                                 tmdbId="{{ movie.tmdbId }}"
+                                 title="{{ movie.title }}"
+                                 description="{{ movie.description }}"
+                                 image="{{ movie.poster }}"
+                                 year="{{ movie.year }}"
+                                 mediaType="movies"
+                    />
+                {% endfor %}
+            </twig:Card>
+            <twig:Card title="Popular TV Shows" contentClass="flex flex-row justify-between w-full">
+                {% for movie in popular_tvshows %}
+                    <twig:Poster imdbId=""
+                                 tmdbId="{{ movie.tmdbId }}"
+                                 title="{{ movie.title }}"
+                                 description="{{ movie.description }}"
+                                 image="{{ movie.poster }}"
+                                 year="{{ movie.year }}"
+                                mediaType="tvshows"
+                    />
+                {% endfor %}
             </twig:Card>
         </div>
     </div>

templates/search/partial/filter.html.twig

@@ -1,63 +1,84 @@
-<div id="filter" class="w-full p-4 flex flex-row gap-4 bg-stone-500 text-md text-gray-500 dark:text-gray-50 rounded-lg"
+<div id="filter" class="flex flex-col gap-4"
         {{ stimulus_controller('result_filter') }}
         {{ stimulus_action('result_filter', 'filter', 'change') }}
      data-result-filter-media-type-value="{{ results.media.mediaType }}"
      data-result-filter-movie-results-outlet=".results"
      data-result-filter-tv-results-outlet=".results"
 >
-    <label for="resolution">
-        Resolution
-        <select id="resolution" data-result-filter-target="resolution" class="px-1 py-0.5 bg-stone-100 text-gray-800 rounded-sm">
-            <option {{ filter.resolution == "n/a" ? "selected" }}
-                    value="">n/a</option>
-            <option {{ filter.resolution == "720p" ? "selected" }}
-                    value="720p">720p</option>
-            <option {{ filter.resolution == "1080p" ? "selected" }}
-                    value="1080p">1080p</option>
-            <option {{ filter.resolution == "2160p" ? "selected" }}
-                    value="2160p">2160p</option>
-        </select>
-    </label>
-    <label for="codec">
-        Codec
-        <select id="codec" data-result-filter-target="codec" class="px-1 py-0.5 bg-stone-100 text-sm text-gray-800 rounded-sm">
-            <option {{ filter.codec == "n/a" ? "selected" }}
-                    value="">n/a</option>
-            <option {{ filter.codec == "-" ? "selected" }}
-                    value="-">-</option>
-            <option {{ filter.codec == "h264" ? "selected" }}
-                    value="h264">h264</option>
-            <option {{ filter.codec == "h265" ? "selected" }}
-                    value="h265">h265/HEVC</option>
-        </select>
-    </label>
-    <label for="language">
-        Language
-        <select id="language" data-result-filter-target="language" class="px-1 py-0.5 bg-stone-100 text-gray-800 rounded-sm">
-            <option selected value="{{ filter.language }}">{{ filter.language }}</option>
-        </select>
-    </label>
-    <label for="provider">
-        Provider
-        <select id="provider" data-result-filter-target="provider" class="px-1 py-0.5 bg-stone-100 text-gray-800 rounded-sm">
-            <option selected value="">n/a</option>
-        </select>
-    </label>
-    {% if results.media.mediaType == "tvshows" %}
-        <label for="season">
-            Season
-            <select id="season" name="season" value="1" data-result-filter-target="season" class="px-1 py-0.5 bg-stone-100 text-gray-800 rounded-sm">
-                <option selected value="1">1</option>
-                {% for season in range(2, results.media.episodes|length) %}
-                    <option value="{{ season }}">{{ season }}</option>
-                {% endfor %}
+    <div class="w-full p-4 flex flex-row gap-4 bg-stone-500 text-md text-gray-500 dark:text-gray-50 rounded-lg">
+        <label for="resolution">
+            Resolution
+            <select id="resolution" data-result-filter-target="resolution" class="px-1 py-0.5 bg-stone-100 text-gray-800 rounded-md">
+                <option {{ filter.resolution == "n/a" ? "selected" }}
+                        value="">n/a</option>
+                <option {{ filter.resolution == "720p" ? "selected" }}
+                        value="720p">720p</option>
+                <option {{ filter.resolution == "1080p" ? "selected" }}
+                        value="1080p">1080p</option>
+                <option {{ filter.resolution == "2160p" ? "selected" }}
+                        value="2160p">2160p</option>
             </select>
         </label>
-        {#                        <label for="episodeNumber">#}
-        {#                            Episode#}
-        {#                            <select id="episodeNumber" name="episodeNumber" data-result-filter-target="episode" class="px-1 py-0.5 bg-stone-100 text-gray-800 rounded-sm">#}
-        {#                                <option selected value="">n/a</option>#}
-        {#                            </select>#}
-        {#                        </label>#}
+        <label for="codec">
+            Codec
+            <select id="codec" data-result-filter-target="codec" class="px-1 py-0.5 bg-stone-100 text-sm text-gray-800 rounded-md">
+                <option {{ filter.codec == "n/a" ? "selected" }}
+                        value="">n/a</option>
+                <option {{ filter.codec == "-" ? "selected" }}
+                        value="-">-</option>
+                <option {{ filter.codec == "h264" ? "selected" }}
+                        value="h264">h264</option>
+                <option {{ filter.codec == "h265" ? "selected" }}
+                        value="h265">h265/HEVC</option>
+            </select>
+        </label>
+        <label for="language">
+            Language
+            <select id="language" data-result-filter-target="language" class="px-1 py-0.5 bg-stone-100 text-gray-800 rounded-md">
+                <option selected value="{{ filter.language }}">{{ filter.language }}</option>
+            </select>
+        </label>
+        <label for="provider">
+            Provider
+            <select id="provider" data-result-filter-target="provider" class="px-1 py-0.5 bg-stone-100 text-gray-800 rounded-md">
+                <option selected value="">n/a</option>
+            </select>
+        </label>
+        {% if results.media.mediaType == "tvshows" %}
+            <label for="season">
+                Season
+                <select id="season" name="season" value="1" data-result-filter-target="season" class="px-1 py-0.5 bg-stone-100 text-gray-800 rounded-md"
+                        {{ stimulus_action('result_filter', 'uncheckSelectAllBtn', 'change') }}>
+                    <option selected value="1">1</option>
+                    {% for season in range(2, results.media.episodes|length) %}
+                        <option value="{{ season }}">{{ season }}</option>
+                    {% endfor %}
+                </select>
+            </label>
+            {#                        <label for="episodeNumber">#}
+            {#                            Episode#}
+            {#                            <select id="episodeNumber" name="episodeNumber" data-result-filter-target="episode" class="px-1 py-0.5 bg-stone-100 text-gray-800 rounded-sm">#}
+            {#                                <option selected value="">n/a</option>#}
+            {#                            </select>#}
+            {#                        </label>#}
+        {% endif %}
+        <span {{ stimulus_controller('loading_icon', {total: (results.media.mediaType == "tvshows") ? results.media.episodes[1]|length : 1, count: 0}) }}
+            class="loading-icon"
+        >
+            <twig:ux:icon name="codex:loader" height="20" width="20" data-loading-icon-target="icon" class="text-end" />
+        </span>
+    </div>
+
+    {% if results.media.mediaType == "tvshows" %}
+    <div class="flex flex-row gap-2 justify-end px-8">
+        <button class="px-1.5 py-1 bg-green-600 rounded-md text-sm"
+                {{ stimulus_target('result_filter', 'downloadSelected') }}
+                {{ stimulus_action('result_filter', 'downloadSelectedEpisodes', 'click') }}
+        >Download Selected</button>
+        <input type="checkbox" name="selectAll" id="selectAll"
+                {{ stimulus_target('result_filter', 'selectAll') }}
+                {{ stimulus_action('result_filter', 'selectAllEpisodes', 'change') }}
+        />
+    </div>
     {% endif %}
 </div>

templates/search/result.html.twig

@@ -17,17 +17,12 @@
                             {{ results.media.description }}
                         </p>
                     </div>
-                    <span {{ stimulus_controller('loading_icon', {total: (results.media.mediaType == "tvshows") ? results.media.episodes[1]|length : 1, count: 0}) }}
-                        class="loading-icon"
-                    >
-                        <twig:ux:icon name="codex:loader" height="20" width="20" data-loading-icon-target="icon" />
-                    </span>
                 </div>
 
                 {{ include('search/partial/filter.html.twig') }}
 
                 {% if "movies" == results.media.mediaType %}
-                <div class="results" {{ stimulus_controller('movie_results', {imdbId: results.media.imdbId}) }}>
+                <div class="results" {{ stimulus_controller('movie_results', {title: results.media.title, tmdbId: results.media.tmdbId, imdbId: results.media.imdbId}) }}>
                 </div>
                 {% elseif "tvshows" == results.media.mediaType %}
                     {% for season, episodes in results.media.episodes %}
@@ -35,7 +30,9 @@
                         {% for episode in episodes %}
                             <div class="results {{ (active == false) ? 'hidden' }}"
                                  data-tv-results-loading-icon-outlet=".loading-icon"
+                                 data-download-button-outlet=".download-btn"
                                  {{ stimulus_controller('tv_results', {
+                                    title: results.media.title,
                                     tmdbId: results.media.tmdbId,
                                     imdbId: results.media.imdbId,
                                     season: season,

templates/torrentio/movies.html.twig

@@ -1,69 +1,5 @@
 <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">
-        <table class="w-full text-sm text-left rtl:text-right text-gray-500 dark:text-gray-400" {{ stimulus_target('movie_results', 'list') }} >
-            <thead class="text-xs text-gray-700 uppercase bg-gray-50 dark:bg-gray-700 dark:text-gray-400">
-            <tr class="dark:bg-stone-600 overflow-hidden">
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Size
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Resolution
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Codec
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Seeders
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Provider
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Language
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                </th>
-            </tr>
-            </thead>
-            <tbody>
-            {% for result in results.results %}
-                <tr class="bg-white border-b dark:bg-slate-700 dark:border-gray-600 border-gray-200" data-languages="{{ result.languages|json_encode }}" data-provider="{{ result.provider }}">
-                    <td id="size" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
-                        {{ result.size }}
-                    </td>
-                    <td id="resolution" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
-                        {{ result.resolution }}
-                    </td>
-                    <td id="codec" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
-                        {{ result.codec }}
-                    </td>
-                    <td id="seeders" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
-                        {{ result.seeders }}
-                    </td>
-                    <td id="provider" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50" data-provider="{{ result.provider }}">
-                        {{ result.provider }}
-                    </td>
-                    <td id="language" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50" data-languages="{{ result.languages|json_encode }}">
-                        {{ result.languageFlags }}
-                    </td>
-                    <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50 flex flex-row gap-2 items-center justify-end">
-                        <span class="p-1.5 bg-green-600 rounded-md text-gray-50">
-                            Download
-                        </span>
-                        <label for="select">
-                            <input id="select" type="checkbox" name="select" />
-                        </label>
-                    </td>
-                </tr>
-            {% endfor %}
-            </tbody>
-        </table>
+        {{ include('torrentio/partial/option-table.html.twig', {controller: 'movie-results'}) }}
     </div>
 </div>

templates/torrentio/partial/option-table.html.twig

@@ -0,0 +1,76 @@
+<table class="w-full text-sm text-left rtl:text-right text-gray-500 dark:text-gray-400 {{ results.media.mediaType == "tvshows" ? "hidden" }}"
+       {{ stimulus_target(controller, "list") }}
+>
+    <thead class="text-xs text-gray-700 uppercase bg-gray-50 dark:bg-gray-700 dark:text-gray-400">
+    <tr class="dark:bg-stone-600 overflow-hidden">
+        <th scope="col"
+            class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
+            Size
+        </th>
+        <th scope="col"
+            class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
+            Resolution
+        </th>
+        <th scope="col"
+            class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
+            Codec
+        </th>
+        <th scope="col"
+            class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
+            Seeders
+        </th>
+        <th scope="col"
+            class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
+            Provider
+        </th>
+        <th scope="col"
+            class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
+            Language
+        </th>
+        <th scope="col"
+            class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
+        </th>
+    </tr>
+    </thead>
+    <tbody>
+    {% for result in results.results %}
+        <tr class="bg-white border-b dark:bg-slate-700 dark:border-gray-600 border-gray-200" data-languages="{{ result.languages|json_encode }}" {% if "tvshows" == results.media.mediaType %} data-season="{{ results.season }} {% endif %}">
+            <td id="size" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
+                {{ result.size }}
+            </td>
+            <td id="resolution" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
+                {{ result.resolution }}
+            </td>
+            <td id="codec" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
+                {{ result.codec }}
+            </td>
+            <td id="seeders" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
+                {{ result.seeders }}
+            </td>
+            <td id="provider" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50" data-provider="{{ result.provider }}">
+                {{ result.provider }}
+            </td>
+            <td id="language" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50" data-languages="{{ result.languages|json_encode }}">
+                {{ result.languageFlags|raw }}
+            </td>
+            <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50 flex flex-row gap-2 items-center justify-end">
+                        <button class="download-btn p-1.5 bg-green-600 rounded-md text-gray-50"
+                            {{ stimulus_controller('download_button', {
+                                url: result.url,
+                                title: results.media.title,
+                                filename: result.filename,
+                                mediaType: results.media.mediaType,
+                                imdbId: results.media.imdbId
+                            }) }}
+                            {{ stimulus_action('download_button', 'download', 'click') }}
+                        >
+                            Download
+                        </button>
+                <label for="select">
+                    <input id="select" type="checkbox" name="select" />
+                </label>
+            </td>
+        </tr>
+    {% endfor %}
+    </tbody>
+</table>

templates/torrentio/tvshows.html.twig

@@ -10,80 +10,19 @@
                 ><span {{ stimulus_target('tv-results', 'count') }}>{{ results.results|length }}</span> results</small>
             </span>
         </div>
-        <div class="flex flex-col items-end hover:cursor-pointer"
-             {{ stimulus_action('tv-results', 'toggleList', 'click') }}>
-            <svg xmlns="http://www.w3.org/2000/svg" width="2em" height="2em" viewBox="0 0 32 32">
-                <path fill="currentColor" d="m16 10l10 10l-1.4 1.4l-8.6-8.6l-8.6 8.6L6 20z"/>
-            </svg>
+        <div class="flex flex-col gap-4 justify-between">
+            <input type="checkbox"
+                   {{ stimulus_target('tv-results', 'episodeSelector') }}
+            />
+            <div class="flex flex-col items-end hover:cursor-pointer"
+                    {{ stimulus_action('tv-results', 'toggleList', 'click') }}>
+                <svg xmlns="http://www.w3.org/2000/svg" width="2em" height="2em" viewBox="0 0 32 32">
+                    <path fill="currentColor" d="m16 10l10 10l-1.4 1.4l-8.6-8.6l-8.6 8.6L6 20z"/>
+                </svg>
+            </div>
         </div>
     </div>
     <div class="inline-block overflow-hidden rounded-lg">
-        <table class="w-full text-sm text-left rtl:text-right text-gray-500 dark:text-gray-400 hidden"
-               data-tv-results-target="list"
-        >
-            <thead class="text-xs text-gray-700 uppercase bg-gray-50 dark:bg-gray-700 dark:text-gray-400">
-            <tr class="dark:bg-stone-600 overflow-hidden">
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Size
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Resolution
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Codec
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Seeders
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Provider
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                    Language
-                </th>
-                <th scope="col"
-                    class="px-6 py-4 font-medium text-gray-900 whitespace-nowrap dark:text-white">
-                </th>
-            </tr>
-            </thead>
-            <tbody>
-            {% for result in results.results %}
-                <tr class="bg-white border-b dark:bg-slate-700 dark:border-gray-600 border-gray-200" data-languages="{{ result.languages|json_encode }}" data-season="{{ results.season }}">
-                    <td id="size" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
-                        {{ result.size }}
-                    </td>
-                    <td id="resolution" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
-                        {{ result.resolution }}
-                    </td>
-                    <td id="codec" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
-                        {{ result.codec }}
-                    </td>
-                    <td id="seeders" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50">
-                        {{ result.seeders }}
-                    </td>
-                    <td id="provider" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50" data-provider="{{ result.provider }}">
-                        {{ result.provider }}
-                    </td>
-                    <td id="language" class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-gray-50" data-languages="{{ result.languages|json_encode }}">
-                        {{ result.languageFlags|raw }}
-                    </td>
-                    <td class="px-6 py-4 whitespace-nowrap text-sm text-end text-gray-800 dark:text-gray-50 flex flex-row gap-2 items-center justify-end">
-                        <span class="p-1.5 bg-green-600 rounded-md text-gray-50">
-                            Download
-                        </span>
-                        <label for="select">
-                            <input id="select" type="checkbox" name="select" />
-                        </label>
-                    </td>
-                </tr>
-            {% endfor %}
-            </tbody>
-        </table>
+        {{ include('torrentio/partial/option-table.html.twig', {controller: 'tv-results'}) }}
     </div>
 </div>