fix: better logging for monitor cleanup

assets/styles/app.css

@@ -64,6 +64,16 @@ dialog[data-dialog-target="dialog"][closing] {
     animation: fade-out 200ms forwards;
 }
 
+.r-tablecell {
+    display: none;
+}
+
+@media screen and (min-width: 768px) {
+    .r-tablecell {
+        display: inline-table;
+    }
+}
+
 .options-table {
     display: flex;
 

config/routes.yaml

@@ -29,3 +29,11 @@ controllersMonitor:
     type: attribute
     defaults:
         schemes: ['https']
+
+controllersTorrentio:
+    resource:
+        path: ../src/Torrentio/Framework/Controller
+        namespace: App\Torrentio\Framework\Controller
+    type: attribute
+    defaults:
+        schemes: ['https']

src/Monitor/Framework/Entity/Monitor.php

@@ -4,6 +4,7 @@ namespace App\Monitor\Framework\Entity;
 
 use App\Monitor\Framework\Repository\MonitorRepository;
 use App\User\Framework\Entity\User;
+use Carbon\Carbon;
 use Doctrine\Common\Collections\ArrayCollection;
 use Doctrine\Common\Collections\Collection;
 use Doctrine\DBAL\Types\Types;
@@ -148,7 +149,7 @@ class Monitor
 
     public function getLastSearch(): ?\DateTimeInterface
     {
-        return $this->lastSearch;
+        return Carbon::parse($this->lastSearch);
     }
 
     public function setLastSearch(?\DateTimeInterface $lastSearch): static

src/Monitor/Framework/Scheduler/MonitorDispatcher.php

@@ -7,6 +7,7 @@ use App\Monitor\Action\Command\MonitorTvEpisodeCommand;
 use App\Monitor\Action\Command\MonitorTvSeasonCommand;
 use App\Monitor\Action\Command\MonitorTvShowCommand;
 use App\Monitor\Framework\Repository\MonitorRepository;
+use Carbon\Carbon;
 use Psr\Log\LoggerInterface;
 use Symfony\Component\Messenger\MessageBusInterface;
 use Symfony\Component\Scheduler\Attribute\AsCronTask;
@@ -23,6 +24,8 @@ class MonitorDispatcher
     public function __invoke() {
         $this->logger->info('[MonitorDispatcher] Executing MonitorDispatcher');
 
+        $this->cleanupStuckMonitors();
+
         $monitorHandlers = [
             'movie' => MonitorMovieCommand::class,
             'tvepisode' => MonitorTvEpisodeCommand::class,
@@ -41,4 +44,18 @@ class MonitorDispatcher
             $this->bus->dispatch(new $command($monitor->getId()));
         }
     }
+
+    private function cleanupStuckMonitors(): void
+    {
+        $hoursStuck = 4;
+        $monitors = $this->monitorRepository->findBy(['status' => 'In Progress']);
+        foreach ($monitors as $monitor) {
+            // Reset the status to active so it will be executed again
+            if ($monitor->getLastSearch()->diffInHours(Carbon::today()) > $hoursStuck) {
+                $this->logger->info('[MonitorDispatcher] Cleaning up monitor: ' . $monitor->getId() . ' (' . $monitor->getTitle() . '), resetting status to \'Active\' from \''. $monitor->getStatus() .'\' after being stuck for ' . $hoursStuck  . ' hours.');
+                $monitor->setStatus('Active');
+            }
+        }
+        $this->monitorRepository->getEntityManager()->flush();
+    }
 }

src/Torrentio/Client/Torrentio.php

@@ -32,7 +32,7 @@ class Torrentio
         ]);
     }
 
-    public function search(string $imdbCode, string $type, array $filter = []): array
+    public function search(string $imdbCode, string $type, bool $parseResults = true): array
     {
         $cacheKey = "torrentio.{$imdbCode}";
 
@@ -56,10 +56,14 @@ class Torrentio
             return [];
         });
 
-        return $this->parse($results, $filter);
+        if (true === $parseResults) {
+            return $this->parse($results);
+        }
+
+        return $results;
     }
 
-    public function fetchEpisodeResults(string $imdbId, int $season, int $episode): array
+    public function fetchEpisodeResults(string $imdbId, int $season, int $episode, bool $parseResults = true): array
     {
         $cacheKey = "torrentio.$imdbId.$season.$episode";
         $results = $this->cache->get($cacheKey, function (ItemInterface $item) use ($imdbId, $season, $episode) {
@@ -86,18 +90,15 @@ class Torrentio
             throw new TorrentioRateLimitException();
         }
 
-        return $this->parse($results, []);
-    }
-
-    public function parse(array $data, array $filter): array
-    {
-        $ruleEngine = new RuleEngine();
-        foreach ($filter as $rule => $value) {
-            if ('resolution' === $rule) {
-                $ruleEngine->addRule(new Resolution($value));
-            }
+        if (true === $parseResults) {
+            return $this->parse($results);
         }
 
+        return $results;
+    }
+
+    public function parse(array $data): array
+    {
         $results = [];
         foreach ($data['streams'] as $stream) {
             if (!str_starts_with($stream['url'], "https")) {
@@ -119,9 +120,7 @@ class Torrentio
                 $bingeGroup
             );
 
-            if ($ruleEngine->validateAll($result)) {
-                $results[] = $result;
-            }
+            $results[] = $result;
         }
 
         return $results;

src/Torrentio/Framework/Controller/ApiController.php

@@ -0,0 +1,116 @@
+<?php
+
+namespace App\Torrentio\Framework\Controller;
+
+use App\Torrentio\Action\Handler\GetMovieOptionsHandler;
+use App\Torrentio\Action\Handler\GetTvShowOptionsHandler;
+use App\Torrentio\Action\Input\GetMovieOptionsInput;
+use App\Torrentio\Action\Input\GetTvShowOptionsInput;
+use App\Torrentio\Client\Torrentio;
+use App\Torrentio\Exception\TorrentioRateLimitException;
+use App\Util\Broadcaster;
+use Carbon\Carbon;
+use Symfony\Bundle\FrameworkBundle\Controller\AbstractController;
+use Symfony\Component\HttpFoundation\Request;
+use Symfony\Component\HttpFoundation\Response;
+use Symfony\Component\Routing\Attribute\Route;
+use Symfony\Contracts\Cache\CacheInterface;
+use Symfony\Contracts\Cache\ItemInterface;
+
+final class ApiController extends AbstractController
+{
+    public function __construct(
+        private readonly GetMovieOptionsHandler $getMovieOptionsHandler,
+        private readonly GetTvShowOptionsHandler $getTvShowOptionsHandler,
+        private readonly Broadcaster $broadcaster,
+        private readonly Torrentio $torrentio,
+    ) {}
+
+    #[Route('/api/torrentio/{imdbId}/{season?}/{episode?}', name: 'api_torrentio')]
+    public function api(string $imdbId, ?int $season, ?int $episode): Response
+    {
+        if (null !== $season && null !== $episode) {
+            return $this->json(
+                $this->torrentio->fetchEpisodeResults($imdbId, $season, $episode, false)
+            );
+        }
+        return $this->json(
+            $this->torrentio->search($imdbId, 'movies', false),
+        );
+    }
+
+    #[Route('/torrentio/movies/{tmdbId}/{imdbId}', name: 'app_torrentio_movies')]
+    public function movieOptions(GetMovieOptionsInput $input, CacheInterface $cache): Response
+    {
+        $cacheId = sprintf(
+            "page.torrentio.movies.%s.%s",
+            $input->tmdbId,
+            $input->imdbId
+        );
+
+        return $cache->get($cacheId, function (ItemInterface $item) use ($input) {
+            $item->expiresAt(Carbon::now()->addHour()->setMinute(0)->setSecond(0));
+            $results = $this->getMovieOptionsHandler->handle($input->toCommand());
+            return $this->render('torrentio/movies.html.twig', [
+                'results' => $results,
+            ]);
+        });
+    }
+
+    #[Route('/torrentio/tvshows/{tmdbId}/{imdbId}/{season?}/{episode?}', name: 'app_torrentio_tvshows')]
+    public function tvShowOptions(GetTvShowOptionsInput $input, CacheInterface $cache): Response
+    {
+        $cacheId = sprintf(
+            "page.torrentio.tvshows.%s.%s.%s.%s",
+            $input->tmdbId,
+            $input->imdbId,
+            $input->season,
+            $input->episode,
+        );
+
+        try {
+//            return $cache->get($cacheId, function (ItemInterface $item) use ($input) {
+//                $item->expiresAt(Carbon::now()->addHour()->setMinute(0)->setSecond(0));
+                $results = $this->getTvShowOptionsHandler->handle($input->toCommand());
+                return $this->render('torrentio/tvshows.html.twig', [
+                    'results' => $results,
+                ]);
+//            });
+        } catch (TorrentioRateLimitException $exception) {
+            $this->broadcaster->alert('Warning', 'Torrentio has rate limited your requests. Please wait a few minutes before trying again.', 'warning');
+            return $this->render('bare.html.twig',
+                [],
+                new Response('Too many requests',
+                    Response::HTTP_TOO_MANY_REQUESTS,
+                    ['Retry-After' => 4000]
+                )
+            );
+        }
+    }
+
+    #[Route('/torrentio/tvshows/clear/{tmdbId}/{imdbId}/{season?}/{episode?}', name: 'app_clear_torrentio_tvshows')]
+    public function clearTvShowOptions(GetTvShowOptionsInput $input, CacheInterface $cache, Request $request): Response
+    {
+        $cacheId = sprintf(
+            "page.torrentio.tvshows.%s.%s.%s.%s",
+            $input->tmdbId,
+            $input->imdbId,
+            $input->season,
+            $input->episode,
+        );
+        $cache->delete($cacheId);
+
+        $this->broadcaster->alert(
+            title: 'Success',
+            message: 'Torrentio cache Cleared.'
+        );
+
+        return $cache->get($cacheId, function (ItemInterface $item) use ($input) {
+            $item->expiresAt(Carbon::now()->addHour()->setMinute(0)->setSecond(0));
+            $results = $this->getTvShowOptionsHandler->handle($input->toCommand());
+            return $this->render('torrentio/tvshows.html.twig', [
+                'results' => $results,
+            ]);
+        });
+    }
+}

src/Torrentio/Framework/Controller/WebController.php

@@ -1,6 +1,6 @@
 <?php
 
-namespace App\Controller;
+namespace App\Torrentio\Framework\Controller;
 
 use App\Torrentio\Action\Handler\GetMovieOptionsHandler;
 use App\Torrentio\Action\Handler\GetTvShowOptionsHandler;
@@ -16,7 +16,7 @@ use Symfony\Component\Routing\Attribute\Route;
 use Symfony\Contracts\Cache\CacheInterface;
 use Symfony\Contracts\Cache\ItemInterface;
 
-final class TorrentioController extends AbstractController
+final class WebController extends AbstractController
 {
     public function __construct(
         private readonly GetMovieOptionsHandler $getMovieOptionsHandler,
@@ -54,13 +54,13 @@ final class TorrentioController extends AbstractController
         );
 
         try {
-            return $cache->get($cacheId, function (ItemInterface $item) use ($input) {
-                $item->expiresAt(Carbon::now()->addHour()->setMinute(0)->setSecond(0));
+//            return $cache->get($cacheId, function (ItemInterface $item) use ($input) {
+//                $item->expiresAt(Carbon::now()->addHour()->setMinute(0)->setSecond(0));
                 $results = $this->getTvShowOptionsHandler->handle($input->toCommand());
                 return $this->render('torrentio/tvshows.html.twig', [
                     'results' => $results,
                 ]);
-            });
+//            });
         } catch (TorrentioRateLimitException $exception) {
             $this->broadcaster->alert('Warning', 'Torrentio has rate limited your requests. Please wait a few minutes before trying again.', 'warning');
             return $this->render('bare.html.twig',

templates/components/DownloadList.html.twig

@@ -11,21 +11,17 @@
         <thead>
         <tr class="bg-orange-500 bg-filter bg-blur-lg bg-opacity-80 text-gray-950">
             <th scope="col"
-                class="px-6 py-3 text-start text-xs font-medium text-stone-500 uppercase dark:text-stone-800 {% if this.isWidget == true %}min-w-[45ch] max-w-[45ch]{% endif %} truncate">
+                class="px-6 py-3 text-start text-xs font-medium text-stone-500 uppercase dark:text-stone-800 truncate">
                 Title
             </th>
-
-            {% if this.isWidget == false %}
-                <th scope="col"
-                    class="px-6 py-3 text-start text-xs font-medium text-stone-500 uppercase dark:text-stone-800 truncate">
-                    Filename
-                </th>
-                <th scope="col"
-                    class="px-6 py-3 text-start text-xs font-medium text-stone-500 uppercase dark:text-stone-800 truncate">
-                    Media type
-                </th>
-            {% endif %}
-
+            <th scope="col"
+                class="px-6 py-3 text-start text-xs font-medium text-stone-500 uppercase dark:text-stone-800 truncate {{ isWidget == true ? "hidden" : "r-tablecell" }}">
+                Filename
+            </th>
+            <th scope="col"
+                class="px-6 py-3 text-start text-xs font-medium text-stone-500 uppercase dark:text-stone-800 truncate {{ isWidget == true ? "hidden" : "r-tablecell" }}">
+                Media type
+            </th>
             <th scope="col"
                 class="px-6 py-3 text-start text-xs font-medium text-gray-500 uppercase dark:text-stone-800">
                 Progress
@@ -38,7 +34,7 @@
         <tbody id="{{ table_body_id }}" class="divide-y divide-gray-200 dark:divide-gray-50">
         {% if this.downloads.items|length > 0 %}
             {% for download in this.downloads.items %}
-                <twig:DownloadListRow download="{{ download }}" isWidget="{{ this.isWidget }}" />
+                <twig:DownloadListRow download="{{ download }}" isWidget="{{ isWidget }}" />
             {% endfor %}
             {% if this.isWidget == true and this.downloads.items|length > this.perPage %}
                 <tr  id="download_view_all">

templates/components/DownloadListRow.html.twig

@@ -1,7 +1,7 @@
 <tr{{ attributes }} class="hover:bg-gray-200" id="ad_download_{{ download.id }}">
     <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800 truncate">
         <a href="{{ path('app_search_result', {imdbId: download.imdbId, mediaType: download.mediaType}) }}"
-           class="mr-1 hover:underline rounded-md"
+           class="mr-1 hover:underline rounded-md max-w-[10ch] md:max-w-[unset] truncate"
         >
             {{ download.title }}
         </a>
@@ -11,14 +11,13 @@
         {% endif %}
     </td>
 
-    {% if isWidget == false %}
-        <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800 max-w-[60ch] truncate">
-            {{ download.filename }}
-        </td>
-        <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800 truncate">
-            {{ download.mediaType }}
-        </td>
-    {% endif %}
+    <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800 max-w-[60ch] {{ isWidget == true ? "hidden" : "r-tablecell" }} truncate">
+       {{ download.filename }}
+    </td>
+
+    <td class="px-6 py-4 whitespace-nowrap text-sm font-medium text-gray-800 dark:text-stone-800 truncate {{ isWidget == true ? "hidden" : "r-tablecell" }}">
+        {{ download.mediaType }}
+    </td>
 
     <td class="px-6 py-4 whitespace-nowrap text-sm align-middle text-gray-800 dark:text-gray-50">
         {% if download.progress < 100 %}
@@ -32,7 +31,7 @@
             <twig:StatusBadge color="green" status="Complete" />
         {% endif %}
     </td>
-    <td id="action_buttons_{{ download.id }}" class="px-6 py-4 flex flex-row items-center">
+    <td id="hidden md:table-cell action_buttons_{{ download.id }}" class="px-6 py-4 flex flex-row items-center">
         {% if download.status == 'In Progress' and download.progress < 100 %}
             <button id="pause_{{ download.id }}" class="text-orange-500 hover:text-orange-600 mr-1 self-start" {{ stimulus_action('download_list', 'pauseDownload', 'click', {id: download.id}) }}>
                 <twig:ux:icon name="icon-park-twotone:pause-one" width="16.75px" height="16.75px" class="rounded-full" />

templates/components/MonitorList.html.twig

@@ -16,32 +16,32 @@
                 ID
             </th>
             <th scope="col"
-                class="px-6 py-3 text-start text-xs font-medium uppercase">
+                class="hidden md:table-cell px-6 py-3 text-start text-xs font-medium uppercase">
                 Search Count
             </th>
             <th scope="col"
-                class="px-6 py-3 text-start text-xs font-medium uppercase">
+                class="hidden md:table-cell px-6 py-3 text-start text-xs font-medium uppercase">
                 Created at
             </th>
             <th scope="col"
-                class="px-6 py-3 text-start text-xs font-medium uppercase">
+                class="hidden md:table-cell px-6 py-3 text-start text-xs font-medium uppercase">
                 Last Search Date
             </th>
             <th scope="col"
-                class="px-6 py-3 text-start text-xs font-medium uppercase">
+                class="hidden md:table-cell px-6 py-3 text-start text-xs font-medium uppercase">
                 Type
             </th>
             <th scope="col"
                 class="px-6 py-3 text-start text-xs font-medium uppercase">
                 Status
             </th>
-            <th></th>
+            <th class="hidden md:table-cell"></th>
         </tr>
         </thead>
         <tbody id="monitors" class="divide-y divide-gray-50">
         {% if this.monitors.items|length > 0 %}
             {% for monitor in this.monitors.items %}
-                <twig:MonitorListRow :monitor="monitor" />
+                <twig:MonitorListRow :monitor="monitor" isWidget="{{ this.isWidget }}" />
             {% endfor %}
             {% if this.isWidget and this.monitors.items|length > 5 %}
                 <tr  id="monitor_view_all">

templates/components/MonitorListRow.html.twig

@@ -9,16 +9,16 @@
     <td class="px-6 py-4 whitespace-nowrap text-sm text-gray-800">
         {{ monitor|monitor_media_id }}
     </td>
-    <td class="px-6 py-4 whitespace-nowrap text-sm text-gray-800">
+    <td class="hidden md:table-cell px-6 py-4 whitespace-nowrap text-sm text-gray-800">
         {{ monitor.searchCount }}
     </td>
-    <td class="px-6 py-4 whitespace-nowrap text-sm text-gray-800">
+    <td class="hidden md:table-cell px-6 py-4 whitespace-nowrap text-sm text-gray-800">
         {{ monitor.createdAt|date('m/d/Y h:i a') }}
     </td>
-    <td class="px-6 py-4 whitespace-nowrap text-sm text-gray-800">
+    <td class="hidden md:table-cell px-6 py-4 whitespace-nowrap text-sm text-gray-800">
         {{ monitor.lastSearch|date('m/d/Y h:i a') }}
     </td>
-    <td class="px-6 py-4 whitespace-nowrap text-sm text-gray-800">
+    <td class="hidden md:table-cell px-6 py-4 whitespace-nowrap text-sm text-gray-800">
         {% if monitor.monitorType == "tvshow" %}
             <twig:StatusBadge color="blue" number="300" text="black" status="{{ monitor.monitorType|monitor_type }}" />
         {% elseif monitor.monitorType == "tvseason" %}
@@ -36,7 +36,7 @@
             <twig:StatusBadge color="green" status="{{ monitor.status }}" />
         {% endif %}
     </td>
-    <td class="px-6 py-4 flex flex-row align-middle justify-center">
+    <td class="hidden md:table-cell px-6 py-4 flex flex-row align-middle justify-center">
         {% set delete_button = component('ux:icon', {name: 'ic:twotone-cancel', width: '18px', class: 'rounded-full align-middle text-red-600' }) %}
         <twig:Modal heading="But wait!" button_text="{{ delete_button }}" submit_action="{{ stimulus_action('monitor_list', 'deleteMonitor', 'click', {id: monitor.id}) }}" show_cancel show_submit>
             Are you sure you want to delete this monitor?<br />

templates/components/SearchResult.html.twig

@@ -12,7 +12,7 @@
             <h3 class="mb-4 text-xl font-medium leading-tight font-bold text-gray-50">
                 {{ title }} - {{ year }}
             </h3>
-            <p class="hidden md:text-gray-50">
+            <p class="hidden md:block md:text-gray-50">
                 {{ description }}
             </p>
         </div>

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

@@ -63,7 +63,7 @@
                                 title: results.media.title,
                                 filename: result.filename,
                                 mediaType: results.media.mediaType,
-                                imdbId: results.media.imdbId,
+                                imdbId: results.media.imdbId ?? app.current_route_parameters.imdbId,
                                 episodeId: results|episode_id_from_results
                             }) }}
                             {{ stimulus_action('download_button', 'download', 'click') }}

templates/user/preferences.html.twig

@@ -3,7 +3,7 @@
 {% block h2 %}Preferences{% endblock %}
 
 {% block body %}
-<div class="p-4 flex flex-row gap-2">
+<div class="p-4 flex flex-col md:flex-row gap-2">
     <twig:Card title="Media Preferences" class="w-full">
         <p class="text-gray-50 mb-2">Define a filter to be pre-applied to your download options.</p>
         <form id="media_preferences" class="flex flex-col max-w-64" name="media_preferences" method="post" action="{{ path('app_save_media_preferences') }}">