feat: torrentio api for movie results

2025-04-21 16:11:57 -05:00
parent 77907601f8
commit fb4651c925
14 changed files with 210 additions and 13 deletions
--- a/src/Torrentio/Client/Torrentio.php
+++ b/src/Torrentio/Client/Torrentio.php
@@ -0,0 +1,118 @@
+<?php
+
+namespace App\Torrentio\Client;
+
+use App\Torrentio\Client\Rule\DownloadOptionFilter\Resolution;
+use App\Torrentio\Client\Rule\RuleEngine;
+use App\Torrentio\MediaResult;
+use App\Torrentio\Result\ResultFactory;
+use Symfony\Component\DependencyInjection\Attribute\Autowire;
+use Symfony\Contracts\Cache\CacheInterface;
+use Symfony\Contracts\Cache\ItemInterface;
+
+/**
+ * ToDo: Fix
+ */
+class Torrentio
+{
+    private string $baseUrl = 'https://torrentio.strem.fun/providers%253Dyts%252Ceztv%252Crarbg%252C1337x%252Cthepiratebay%252Ckickasstorrents%252Ctorrentgalaxy%252Cmagnetdl%252Chorriblesubs%252Cnyaasi%7Csort%253Dqualitysize%7Cqualityfilter%253D480p%252Cscr%252Ccam%7Crealdebrid={realDebridKey}/stream/movie/{imdbCode}.json';
+//    private string $baseUrl = 'https://torrentio.strem.fun/providers=yts,eztv,rarbg,1337x,thepiratebay,kickasstorrents,torrentgalaxy,magnetdl,horriblesubs|sort=qualitysize|qualityfilter=480p,cam,unknown|debridoptions=nodownloadlinks|realdebrid=QYYBR7OSQ4VEFKWASDEZ2B4VO67KHUJY6IWOT7HHA7ATXO7QCYDQ/stream/{imdbCode}.json';
+
+    private string $searchUrl;
+
+    public function __construct(
+        #[Autowire(env: 'REAL_DEBRID_KEY')] private string $realDebridKey,
+        private CacheInterface $cache,
+    ) {
+        $this->searchUrl = str_replace('{realDebridKey}', $this->realDebridKey, $this->baseUrl);
+    }
+
+    public function search(string $imdbCode, string $type, array $filter = []): array
+    {
+        $cacheKey = "torrentio.{$imdbCode}";
+
+        $results = $this->cache->get($cacheKey, function (ItemInterface $item) use ($imdbCode) {
+            $item->expiresAt(new \DateTimeImmutable("today 11:59 pm"));
+            $response = file_get_contents(str_replace('{imdbCode}', $imdbCode, $this->searchUrl));
+            return json_decode(
+                $response,
+                true
+            );
+        });
+
+        return $this->parse($results, $filter);
+    }
+
+    public function searchBySeriesSeason(MediaResult $series): MediaResult
+    {
+        $imdbCode = $series->imdbId;
+//        foreach ($series->episodes as $season => $episodes) {
+//            foreach ($episodes as $key => $episode) {
+//                $cacheKey = "torrentio.$series->imdbId.$season.{$episode['episode_number']}";
+//                $downloadOptions = $this->cache->get($cacheKey, function (ItemInterface $item) use ($imdbCode, $season, $episode) {
+//                    $item->expiresAt(new \DateTimeImmutable("today 11:59 pm"));
+//                    $response = file_get_contents(str_replace('{imdbCode}', "$imdbCode:$season:{$episode['episode_number']}", $this->searchUrl));
+//                    return json_decode(
+//                        $response,
+//                        true
+//                    );
+//                });
+//                $series->episodes[$season][$key]['download_options'] = $this->parse($downloadOptions, []);
+//            }
+//        }
+        return $series;
+    }
+
+    public function fetchEpisodeResults(string $imdbId, int $season, int $episode): array
+    {
+        $cacheKey = "torrentio.$imdbId.$season.$episode";
+        $results = $this->cache->get($cacheKey, function (ItemInterface $item) use ($imdbId, $season, $episode) {
+            $item->expiresAt(new \DateTimeImmutable("today 11:59 pm"));
+            $response = file_get_contents(str_replace('{imdbCode}', "$imdbId:$season:$episode", $this->searchUrl));
+            return json_decode(
+                $response,
+                true
+            );
+        });
+
+        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));
+            }
+        }
+
+        $results = [];
+        foreach ($data['streams'] as $stream) {
+            if (!str_starts_with($stream['url'], "https")) {
+                continue;
+            }
+
+            if (
+                array_key_exists('behaviorHints', $stream) &&
+                array_key_exists('bingeGroup', $stream['behaviorHints'])
+            ) {
+                $bingeGroup = $stream['behaviorHints']['bingeGroup'];
+            } else {
+                $bingeGroup = '-';
+            }
+
+            $result = ResultFactory::map(
+                $stream['url'],
+                $stream['title'],
+                $bingeGroup
+            );
+
+            if ($ruleEngine->validateAll($result)) {
+                $results[] = $result;
+            }
+        }
+
+        return $results;
+    }
+}