Files
newznab-tmux-NNTmux/app/Services/TvProcessing/Providers/AbstractTvProvider.php
T
2026-02-13 14:11:33 +01:00

827 lines
32 KiB
PHP

<?php
namespace App\Services\TvProcessing\Providers;
use App\Models\Category;
use App\Models\Release;
use App\Models\Settings;
use App\Models\TvEpisode;
use App\Models\TvInfo;
use App\Models\Video;
use App\Services\Releases\ReleaseBrowseService;
use Illuminate\Support\Facades\DB;
/**
* Class AbstractTvProvider -- abstract extension of BaseVideoProvider
* Contains functions suitable for re-use in all TV scrapers.
*/
abstract class AbstractTvProvider extends BaseVideoProvider
{
// Television Sources
protected const SOURCE_NONE = 0; // No Scrape source
protected const SOURCE_TVDB = 1; // Scrape source was TVDB
protected const SOURCE_TVMAZE = 2; // Scrape source was TVMAZE
protected const SOURCE_TMDB = 3; // Scrape source was TMDB
protected const SOURCE_TRAKT = 4; // Scrape source was Trakt
protected const SOURCE_IMDB = 5; // Scrape source was IMDB
// Anime Sources
protected const SOURCE_ANIDB = 10; // Scrape source was AniDB
// Processing signifiers
protected const PROCESS_TVDB = 0; // Process TVDB First
protected const PROCESS_TVMAZE = -1; // Process TVMaze Second
protected const PROCESS_TMDB = -2; // Process TMDB Third
protected const PROCESS_TRAKT = -3; // Process Trakt Fourth
protected const PROCESS_IMDB = -4; // Process IMDB Fifth
protected const NO_MATCH_FOUND = -6; // Failed All Methods
protected const FAILED_PARSE = -100; // Failed Parsing
public int $tvqty;
/**
* @string Path to Save Images
*/
public string $imgSavePath;
/**
* @var array<string, mixed> Site ID columns for TV
*/
public array $siteColumns;
/**
* @var string The TV categories_id lookup SQL language
*/
public string $catWhere;
/**
* AbstractTvProvider constructor.
*
* @throws \Exception
*/
public function __construct()
{
parent::__construct();
$this->catWhere = 'categories_id BETWEEN '.Category::TV_ROOT.' AND '.Category::TV_OTHER.' AND categories_id != '.Category::TV_ANIME;
try {
$this->tvqty = Settings::settingValue('maxrageprocessed') !== '' ? (int) Settings::settingValue('maxrageprocessed') : 75;
} catch (\Illuminate\Database\QueryException $e) {
// Table doesn't exist yet (e.g., during migrations or tests)
$this->tvqty = 75;
}
$this->imgSavePath = storage_path('covers/tvshows/');
$this->siteColumns = ['tvdb', 'trakt', 'tvrage', 'tvmaze', 'imdb', 'tmdb']; // @phpstan-ignore assign.propertyType
}
/**
* Retrieve banner image from site using its API.
*/
abstract public function getBanner(int $videoID, int $siteId): mixed;
/**
* Retrieve info of TV episode from site using its API.
*
* @return array<string, mixed>|false False on failure, an array of information fields otherwise.
*/
abstract public function getEpisodeInfo(int|string $siteId, int|string $series, int|string $episode): array|bool;
/**
* Retrieve poster image for TV episode from site using its API.
*
* @param int $videoId ID from videos table.
*/
abstract public function getPoster(int $videoId): int;
/**
* Retrieve info of TV programme from site using it's API.
*
* @param string $name Title of programme to look up. Usually a cleaned up version from releases table.
* @return array<string, mixed>|false False on failure, an array of information fields otherwise.
*/
abstract public function getShowInfo(string $name): bool|array;
/**
* Assigns API show response values to a formatted array for insertion
* Returns the formatted array.
*
* @return array<string, mixed>
*/
abstract public function formatShowInfo(mixed $show): array;
/**
* Assigns API episode response values to a formatted array for insertion
* Returns the formatted array.
*
* @return array<string, mixed>
*/
abstract public function formatEpisodeInfo(mixed $episode): array;
/**
* @return Release[]|\Illuminate\Database\Eloquent\Builder[]|\Illuminate\Database\Eloquent\Collection<int, mixed>|\Illuminate\Database\Query\Builder[]|\Illuminate\Support\Collection<int, mixed>|int
*/
public function getTvReleases(string $groupID = '', string $guidChar = '', int $lookupSetting = 1, int $status = 0): array|\Illuminate\Database\Eloquent\Collection|int|\Illuminate\Support\Collection // @phpstan-ignore missingType.generics
{
$ret = 0;
if ($lookupSetting === 0) {
return $ret;
}
$qry = Release::query()
->where(['videos_id' => 0, 'tv_episodes_id' => $status])
->where('size', '>', 1048576)
->whereBetween('categories_id', [Category::TV_ROOT, Category::TV_OTHER])
->where('categories_id', '<>', Category::TV_ANIME)
->orderByDesc('postdate')
->limit($this->tvqty);
if ($groupID !== '') {
$qry->where('groups_id', $groupID);
}
if ($guidChar !== '') {
$qry->where('leftguid', $guidChar);
}
if ($lookupSetting === 2) {
$qry->where('isrenamed', '=', 1);
}
return $qry->get();
}
public function setVideoIdFound(int $videoId, int $releaseId, int $episodeId): void
{
// Use Eloquent model update to trigger the ReleaseObserver
$release = Release::find($releaseId);
if ($release) {
$release->videos_id = $videoId;
$release->tv_episodes_id = $episodeId;
$release->save();
}
ReleaseBrowseService::bumpCacheVersion();
}
/**
* Updates the release tv_episodes_id status when scraper match is not found.
*/
public function setVideoNotFound(mixed $status, mixed $Id): void
{
Release::query()
->where('id', $Id)
->update(['tv_episodes_id' => $status]);
}
/**
* Inserts a new video ID into the database for TV shows
* If a duplicate is found it is handle by calling update instead.
*
* @param array<string, mixed> $show
*/
public function add(array $show = []): int
{
$videoId = false;
// Check if the country is not a proper code and retrieve if not
if ($show['country'] !== '' && \strlen($show['country']) > 2) {
$show['country'] = countryCode($show['country']);
}
// Check if video already exists based on site ID info
// if that fails be sure we're not inserting duplicates by checking the title
foreach ($this->siteColumns as $column) {
if ((int) $show[$column] > 0) {
$videoId = $this->getVideoIDFromSiteID($column, $show[$column]);
}
if ($videoId !== false) {
break;
}
}
if ($videoId === false) {
$title = Video::query()->where('title', $show['title'])->first(['title']);
if ($title === null) {
// Insert the Show using Eloquent create() to trigger VideoObserver
$video = Video::create([
'type' => $show['type'],
'title' => $show['title'],
'countries_id' => $show['country'] ?? '',
'started' => $show['started'],
'source' => $show['source'],
'tvdb' => $show['tvdb'],
'trakt' => $show['trakt'],
'tvrage' => $show['tvrage'],
'tvmaze' => $show['tvmaze'],
'imdb' => $show['imdb'],
'tmdb' => $show['tmdb'],
]);
$videoId = $video->id;
// Insert the supplementary show info
TvInfo::query()->insertOrIgnore([
'videos_id' => $videoId,
'summary' => $show['summary'],
'publisher' => $show['publisher'],
'localzone' => $show['localzone'],
]);
// If we have AKAs\aliases, insert those as well
if (! empty($show['aliases'])) {
$this->addAliases($videoId, $show['aliases']);
}
}
} else {
// If a local match was found, just update missing video info
$this->update($videoId, $show);
}
return $videoId;
}
/**
* @param array<string, mixed> $episode
*/
public function addEpisode(int $videoId, array $episode = []): bool|int
{
$episodeId = $this->getBySeasonEp($videoId, $episode['series'], $episode['episode'], $episode['firstaired']);
if ($episodeId === false) {
$episodeId = TvEpisode::query()->insertOrIgnore(
[
'videos_id' => $videoId,
'series' => $episode['series'],
'episode' => $episode['episode'],
'se_complete' => $episode['se_complete'],
'title' => $episode['title'],
'firstaired' => $episode['firstaired'] !== '' ? $episode['firstaired'] : null,
'summary' => $episode['summary'],
]
);
}
return $episodeId;
}
/**
* @param array<string, mixed> $show
*/
public function update(int $videoId, array $show = []): void
{
if ($show['country'] !== '') {
$show['country'] = countryCode($show['country']);
}
$ifStringID = 'IF(%s = 0, %s, %s)';
$ifStringInfo = "IF(%s = '', %s, %s)";
DB::update(
sprintf(
'
UPDATE videos v
LEFT JOIN tv_info tvi ON v.id = tvi.videos_id
SET v.countries_id = %s, v.tvdb = %s, v.trakt = %s, v.tvrage = %s,
v.tvmaze = %s, v.imdb = %s, v.tmdb = %s,
tvi.summary = %s, tvi.publisher = %s, tvi.localzone = %s
WHERE v.id = %d',
sprintf($ifStringInfo, 'v.countries_id', escapeString($show['country']), 'v.countries_id'),
sprintf($ifStringID, 'v.tvdb', $show['tvdb'], 'v.tvdb'),
sprintf($ifStringID, 'v.trakt', $show['trakt'], 'v.trakt'),
sprintf($ifStringID, 'v.tvrage', $show['tvrage'], 'v.tvrage'),
sprintf($ifStringID, 'v.tvmaze', $show['tvmaze'], 'v.tvmaze'),
sprintf($ifStringID, 'v.imdb', $show['imdb'], 'v.imdb'),
sprintf($ifStringID, 'v.tmdb', $show['tmdb'], 'v.tmdb'),
sprintf($ifStringInfo, 'tvi.summary', escapeString($show['summary']), 'tvi.summary'),
sprintf($ifStringInfo, 'tvi.publisher', escapeString($show['publisher']), 'tvi.publisher'),
sprintf($ifStringInfo, 'tvi.localzone', escapeString($show['localzone']), 'tvi.localzone'),
$videoId
)
);
if (! empty($show['aliases'])) {
$this->addAliases($videoId, $show['aliases']);
}
}
/**
* @throws \Throwable
*/
public function delete(int $id): void
{
DB::transaction(function () use ($id) {
DB::delete(
sprintf(
'
DELETE v, tvi, tve, va
FROM videos v
LEFT JOIN tv_info tvi ON v.id = tvi.videos_id
LEFT JOIN tv_episodes tve ON v.id = tve.videos_id
LEFT JOIN videos_aliases va ON v.id = va.videos_id
WHERE v.id = %d',
$id
)
);
}, 3);
}
public function setCoverFound(int $videoId): void
{
TvInfo::query()->where('videos_id', $videoId)->update(['image' => 1]);
}
/**
* @return Video|false|\Illuminate\Database\Eloquent\Builder|\Illuminate\Database\Eloquent\Model
*/
public function getSiteByID(string $column, int $id): \Illuminate\Database\Eloquent\Model|bool|\Illuminate\Database\Eloquent\Builder|Video // @phpstan-ignore missingType.generics
{
$return = false;
$video = Video::query()->where('id', $id)->first([$column]);
if ($column === '*') {
$return = $video;
} elseif ($column !== '*' && $video !== null) {
$return = $video[$column];
}
return $return;
}
/**
* Retrieves the Episode ID using the Video ID and either:
* season/episode numbers OR the airdate.
*
* Returns the Episode ID or false if not found
*
* @return int|false
*/
public function getBySeasonEp(int|string $id, int|string $series, int|string $episode, string $airdate = ''): bool|int
{
if ($series > 0 && $episode > 0) {
$queryString = sprintf('tve.series = %d AND tve.episode = %d', $series, $episode);
} elseif (! empty($airdate)) {
$queryString = sprintf('DATE(tve.firstaired) = %s', escapeString(date('Y-m-d', strtotime($airdate))));
} else {
return false;
}
$episodeArr = DB::selectOne(
sprintf(
'
SELECT tve.id
FROM tv_episodes tve
WHERE tve.videos_id = %d
AND %s',
$id,
$queryString
)
);
return $episodeArr->id ?? false;
}
/**
* Returns (true) if episodes for a given Video ID exist or don't (false).
*/
public function countEpsByVideoID(int $videoId): bool
{
$count = TvEpisode::query()
->where('videos_id', $videoId)->count('id');
return $count !== null && $count > 0;
}
/**
* @return array<string, mixed>|false
*/
public function parseInfo(string $relname): bool|array
{
$showInfo['name'] = $this->parseName($relname);
if (! empty($showInfo['name'])) {
// Retrieve the country from the cleaned name
$showInfo['country'] = $this->parseCountry($showInfo['name']);
// Clean show name.
$showInfo['cleanname'] = preg_replace('/ - \d+$/i', '', $this->cleanName($showInfo['name']));
$showInfo['cleanname'] = $this->normalizeShowTitle($showInfo['cleanname']);
// Get the Season/Episode/Airdate
$showInfo += $this->parseSeasonEp($relname);
// --- Post-parse correction for daily talk shows misclassified as Season = Year ---
if (isset($showInfo['season'], $showInfo['episode']) && ! isset($showInfo['airdate'])) {
if (is_numeric($showInfo['season']) && (int) $showInfo['season'] >= 1900 && (int) $showInfo['season'] <= (int) date('Y') + 1) {
if (preg_match('/(?P<year>(19|20)\d{2})[.\-\/](?P<month>\d{2})[.\-\/](?P<day>\d{2})/i', $relname, $dateHits)) {
$year = (int) $dateHits['year'];
$month = (int) $dateHits['month'];
$day = (int) $dateHits['day'];
if ($month >= 1 && $month <= 12 && $day >= 1 && $day <= 31) {
$showInfo['airdate'] = sprintf('%04d-%02d-%02d', $year, $month, $day);
$showInfo['season'] = 0;
$showInfo['episode'] = 0;
}
}
}
}
if (isset($showInfo['season'], $showInfo['episode'])) {
if (! isset($showInfo['airdate'])) {
if (preg_match('/[^a-z0-9](?P<year>(19|20)(\d{2}))[^a-z0-9]/i', $relname, $yearMatch)) {
$showInfo['cleanname'] .= ' ('.$yearMatch['year'].')';
}
if (\is_array($showInfo['episode'])) {
$showInfo['episode'] = $showInfo['episode'][0];
}
$showInfo['airdate'] = '';
}
return $showInfo;
}
}
return false;
}
/**
* Parses the release searchname and returns a show title.
*/
private function parseName(string $relname): string
{
$showName = '';
$following = '[^a-z0-9]([(|\[]\w+[)|\]]\s)*?(\d\d-\d\d|\d{1,3}x\d{2,3}|\(?(19|20)\d{2}\)?|(480|720|1080|2160)[ip]|AAC2?|BD-?Rip|Blu-?Ray|D0?\d|DD5|DiVX|DLMux|DTS|DVD(-?Rip)?|E\d{2,3}|[HX][\-_. ]?26[45]|ITA(-ENG)?|HEVC|[HPS]DTV|PROPER|REPACK|Season|Episode|S\d+[^a-z0-9]?((E\d+)[abr]?)*|WEB[\-_. ]?(DL|Rip)|XViD)[^a-z0-9]?';
// Handle fansub/release group prefixes like [SubsPlease], [Erai-raws], [ASW], etc.
$cleanRelname = preg_replace('/^\[[^\]]+\][_\s]*/i', '', $relname);
if (preg_match('/^([^a-z0-9]{2,}|(sample|proof|repost)-)(?P<name>[\w .\-!&]+?)'.$following.'/i', $cleanRelname, $hits)) {
$showName = $hits['name'];
} elseif (preg_match('/^(?P<name>[\w!&][\s\w\'._\-!&]*?)'.$following.'/i', $cleanRelname, $hits)) {
$showName = $hits['name'];
}
// If still no match, try extracting name before common delimiters
if (empty($showName)) {
// Try to extract name before - SxxExx pattern
if (preg_match('/^(?P<name>.+?)[_\s]*[-_\s]+S\d{1,2}E\d{1,3}/i', $cleanRelname, $hits)) {
$showName = $hits['name'];
}
// Try to extract name before standalone episode number like "- 06 [" or "_09_["
elseif (preg_match('/^(?P<name>.+?)[_\s]+[-_]+[_\s]*\d{1,3}[_\s]*[\[(]/i', $cleanRelname, $hits)) {
$showName = $hits['name'];
}
// Handle anime-style "Show_Name_-_Episode_Title_-_XX_[quality]" format (extract before first _-_)
elseif (preg_match('/^(?P<name>.+?)_-_.+?_-_\d{1,3}_[\[(]/i', $cleanRelname, $hits)) {
$showName = $hits['name'];
}
// Simpler pattern: extract everything before "_-_" for anime releases
elseif (preg_match('/^(?P<name>[^_]+(?:_[^_-]+)*)_-_/i', $cleanRelname, $hits)) {
$showName = $hits['name'];
}
}
$showName = preg_replace('/'.$following.'/i', ' ', $showName);
$showName = preg_replace('/^\d{6}/', '', $showName);
$showName = $this->convertAcronyms($showName);
$showName = preg_replace('/\(.*?\)|[._]/i', ' ', $showName);
$showName = trim(preg_replace('/\s{2,}/', ' ', $showName));
return $showName;
}
/**
* Convert acronyms with dots to condensed form.
*/
private function convertAcronyms(string $str): string
{
return preg_replace_callback(
'/\b((?:[A-Za-z]\.){2,}[A-Za-z]?\.?)\b/',
function ($matches) {
return str_replace('.', '', $matches[1]);
},
$str
);
}
/**
* Normalize well-known daily/talk show titles to their canonical names.
* Also includes German-to-English mappings for popular shows.
*/
protected function normalizeShowTitle(string $cleanName): string
{
$normalized = strtolower(trim($cleanName));
$aliases = [
// English show aliases
'grits' => 'Girls Raised in the South',
'shield' => 'Agents of S.H.I.E.L.D.',
'stephen colbert' => 'The Late Show with Stephen Colbert',
'late show with stephen colbert' => 'The Late Show with Stephen Colbert',
'late show stephen colbert' => 'The Late Show with Stephen Colbert',
'the late show stephen colbert' => 'The Late Show with Stephen Colbert',
'colbert' => 'The Late Show with Stephen Colbert',
'daily show' => 'The Daily Show',
'the daily show' => 'The Daily Show',
'daily show with jon stewart' => 'The Daily Show with Jon Stewart',
'the daily show with jon stewart' => 'The Daily Show with Jon Stewart',
'daily show with trevor noah' => 'The Daily Show with Trevor Noah',
'the daily show with trevor noah' => 'The Daily Show with Trevor Noah',
'seth meyers' => 'Late Night with Seth Meyers',
'late night with seth meyers' => 'Late Night with Seth Meyers',
'late night seth meyers' => 'Late Night with Seth Meyers',
'jimmy kimmel' => 'Jimmy Kimmel Live!',
'jimmy kimmel live' => 'Jimmy Kimmel Live!',
'the late late show with james corden' => 'The Late Late Show with James Corden',
'late late show with james corden' => 'The Late Late Show with James Corden',
'late show with james corden' => 'The Late Late Show with James Corden',
'james corden' => 'The Late Late Show with James Corden',
'late late show james corden' => 'The Late Late Show with James Corden',
'jimmy fallon' => 'The Tonight Show Starring Jimmy Fallon',
'the tonight show starring jimmy fallon' => 'The Tonight Show Starring Jimmy Fallon',
'tonight show with jimmy fallon' => 'The Tonight Show Starring Jimmy Fallon',
'tonight show jimmy fallon' => 'The Tonight Show Starring Jimmy Fallon',
// German title to English title mappings
'oak island fluch und legende' => 'The Curse of Oak Island',
'oak island - fluch und legende' => 'The Curse of Oak Island',
'tierische freundschaften' => 'Animal Odd Couples',
'zwischen meer und maloche' => 'Zwischen Meer und Maloche',
'die schatzsucher von oak island' => 'The Curse of Oak Island',
'game of thrones das lied von eis und feuer' => 'Game of Thrones',
'die simpsons' => 'The Simpsons',
'die wilden siebziger' => 'That 70s Show',
'how i met your mother' => 'How I Met Your Mother',
'scrubs die anfanger' => 'Scrubs',
'scrubs die anfaenger' => 'Scrubs',
'der prinz von bel-air' => 'The Fresh Prince of Bel-Air',
'prinz von bel-air' => 'The Fresh Prince of Bel-Air',
'der prinz von bel air' => 'The Fresh Prince of Bel-Air',
'alarm fur cobra 11' => 'Alarm for Cobra 11',
'alarm fuer cobra 11' => 'Alarm for Cobra 11',
'soko' => 'SOKO',
'der bergdoktor' => 'Der Bergdoktor',
'das boot' => 'Das Boot',
'babylon berlin' => 'Babylon Berlin',
'dark' => 'Dark',
'tatort' => 'Tatort',
'polizeiruf 110' => 'Polizeiruf 110',
];
if (isset($aliases[$normalized])) {
return $aliases[$normalized];
}
return $cleanName;
}
/**
* Parses the release searchname for the season/episode/airdate information.
*
* @return array<string, mixed>
*/
private function parseSeasonEp(string $relname): array
{
$episodeArr = [];
// S01E01-E02 and S01E01-02
if (preg_match('/^(.*?)[^a-z0-9]s(\d{1,2})[^a-z0-9]?e(\d{1,3})[e-](\d{1,3})[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = (int) $hits[2];
$episodeArr['episode'] = [(int) $hits[3], (int) $hits[4]];
}
// S01E0102 and S01E01E02
elseif (preg_match('/^(.*?)[^a-z0-9]s(\d{2})[^a-z0-9]?e(\d{2})e?(\d{2})[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = (int) $hits[2];
$episodeArr['episode'] = (int) $hits[3];
}
// S01E01 and S01.E01
elseif (preg_match('/^(.*?)[^a-z0-9]s(\d{1,2})[^a-z0-9]?e(\d{1,3})[abr]?[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = (int) $hits[2];
$episodeArr['episode'] = (int) $hits[3];
}
// S01
elseif (preg_match('/^(.*?)[^a-z0-9]s(\d{1,2})[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = (int) $hits[2];
$episodeArr['episode'] = 'all';
}
// S01D1 and S1D1
elseif (preg_match('/^(.*?)[^a-z0-9]s(\d{1,2})[^a-z0-9]?d\d{1}[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = (int) $hits[2];
$episodeArr['episode'] = 'all';
}
// 1x01 and 101
elseif (preg_match('/^(.*?)[^a-z0-9](\d{1,2})x(\d{1,3})[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = (int) $hits[2];
$episodeArr['episode'] = (int) $hits[3];
}
// 2009.01.01 and 2009-01-01
elseif (preg_match('/^(.*?)[^a-z0-9](?P<airdate>(19|20)(\d{2})[.\/-](\d{2})[.\/-](\d{2}))[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = 0;
$episodeArr['episode'] = 0;
$episodeArr['airdate'] = date('Y-m-d', strtotime(preg_replace('/[^0-9]/i', '/', $hits['airdate'])));
}
// 01.01.2009
elseif (preg_match('/^(.*?)[^a-z0-9](?P<airdate>(\d{2})[^a-z0-9](\d{2})[^a-z0-9](19|20)(\d{2}))[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = 0;
$episodeArr['episode'] = 0;
$episodeArr['airdate'] = date('Y-m-d', strtotime(preg_replace('/[^0-9]/i', '/', $hits['airdate'])));
}
// 01.01.09
elseif (preg_match('/^(.*?)[^a-z0-9](\d{2})[^a-z0-9](\d{2})[^a-z0-9](\d{2})[^a-z0-9]?/i', $relname, $hits)) {
$year = ($hits[4] <= 99 && $hits[4] > 15) ? '19'.$hits[4] : '20'.$hits[4];
$airdate = $year.'/'.$hits[2].'/'.$hits[3];
$episodeArr['season'] = 0;
$episodeArr['episode'] = 0;
$episodeArr['airdate'] = date('Y-m-d', strtotime($airdate));
}
// 2009.E01
elseif (preg_match('/^(.*?)[^a-z0-9]20(\d{2})[^a-z0-9](\d{1,3})[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = '20'.$hits[2];
$episodeArr['episode'] = (int) $hits[3];
}
// 2009.Part1
elseif (preg_match('/^(.*?)[^a-z0-9](19|20)(\d{2})[^a-z0-9]Part(\d{1,2})[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = $hits[2].$hits[3];
$episodeArr['episode'] = (int) $hits[4];
}
// Part1/Pt1
elseif (preg_match('/^(.*?)[^a-z0-9](?:Part|Pt)[^a-z0-9](\d{1,2})[^a-z0-9]?/i', $relname, $hits)) {
$episodeArr['season'] = 1;
$episodeArr['episode'] = (int) $hits[2];
}
// Band.Of.Brothers.EP06.Bastogne.DVDRiP.XviD-DEiTY
elseif (preg_match('/^(.*?)[^a-z0-9]EP?[^a-z0-9]?(\d{1,3})/i', $relname, $hits)) {
$episodeArr['season'] = 1;
$episodeArr['episode'] = (int) $hits[2];
}
// Anime style: [Fansub]_Show_Name_-_06_[quality] or Show_-_Episode_Title_-_06_[
elseif (preg_match('/[_\s][-_][_\s](\d{1,3})[_\s]*[\[(]/i', $relname, $hits)) {
$episodeArr['season'] = 1;
$episodeArr['episode'] = (int) $hits[1];
}
// Season.1
elseif (preg_match('/^(.*?)[^a-z0-9]Seasons?[^a-z0-9]?(\d{1,2})/i', $relname, $hits)) {
$episodeArr['season'] = (int) $hits[2];
$episodeArr['episode'] = 'all';
}
return $episodeArr;
}
/**
* Parses the cleaned release name to determine if it has a country appended.
*/
private function parseCountry(string $showName): string
{
if (preg_match('/[^a-z0-9](US|UK|AU|NZ|CA|NL|Canada|Australia|America|United[^a-z0-9]States|United[^a-z0-9]Kingdom)/i', $showName, $countryMatch)) {
$currentCountry = strtolower($countryMatch[1]);
if ($currentCountry === 'canada') {
$country = 'CA';
} elseif ($currentCountry === 'australia') {
$country = 'AU';
} elseif ($currentCountry === 'america' || $currentCountry === 'united states') {
$country = 'US';
} elseif ($currentCountry === 'united kingdom') {
$country = 'UK';
} else {
$country = strtoupper($countryMatch[1]);
}
} else {
$country = '';
}
return $country;
}
/**
* Supplementary to parseInfo
* Cleans a derived local 'showname' for better matching probability
*/
public function cleanName(string $str): string
{
$str = str_replace(['.', '_'], ' ', $str);
$str = str_replace(['à', 'á', 'â', 'ã', 'ä', 'æ', 'À', 'Á', 'Â', 'Ã', 'Ä'], 'a', $str);
$str = str_replace(['ç', 'Ç'], 'c', $str);
$str = str_replace(['Σ', 'è', 'é', 'ê', 'ë', 'È', 'É', 'Ê', 'Ë'], 'e', $str);
$str = str_replace(['ì', 'í', 'î', 'ï', 'Ì', 'Í', 'Î', 'Ï'], 'i', $str);
$str = str_replace(['ò', 'ó', 'ô', 'õ', 'ö', 'Ò', 'Ó', 'Ô', 'Õ', 'Ö'], 'o', $str);
$str = str_replace(['ù', 'ú', 'û', 'ü', 'ū', 'Ú', 'Û', 'Ü', 'Ū'], 'u', $str);
$str = str_replace('ß', 'ss', $str);
$str = str_replace('&', 'and', $str);
$str = preg_replace('/^(history|discovery) channel/i', '', $str);
$str = str_replace(["'", ':', '!', '"', '#', '*', "'", ',', '(', ')', '?'], '', $str);
$str = str_replace('$', 's', $str);
// Remove language tags that are commonly found in release names
$str = preg_replace('/\b(German|French|Spanish|Italian|Dutch|Russian|Japanese|Korean|Chinese|Portuguese|Swedish|Norwegian|Danish|Finnish|Polish|Czech|Hungarian|Romanian|Greek|Turkish|Arabic|Hebrew|Hindi|Thai|Vietnamese|Indonesian|Malay|Tagalog|DL|Dubbed|Subbed|MULTI|MULTi)\b/i', '', $str);
// Remove common subtitle/episode indicators that aren't part of the show title
$str = preg_replace('/\s+-\s+.*(wo andere|where others|Arbeiten|Working).*$/i', '', $str);
// Clean up trailing hyphens, episode numbers, and other artifacts
$str = preg_replace('/\s*-\s*$/', '', $str); // Trailing hyphen
$str = preg_replace('/\s+\d{1,3}\s*$/', '', $str); // Trailing episode number
$str = preg_replace('/\s+-$/', '', $str); // Another trailing hyphen cleanup
$str = preg_replace('/\s{2,}/', ' ', $str);
$str = trim($str, '"-'); // Trim quotes and hyphens from both ends
return trim($str);
}
/**
* Simple function that compares two strings of text
*/
public function checkMatch(mixed $ourName, mixed $scrapeName, mixed $probability): float|int
{
similar_text($ourName, $scrapeName, $matchpct);
if ($matchpct >= $probability) {
return $matchpct;
}
return 0;
}
/**
* Convert 2012-24-07 to 2012-07-24
*/
public function checkDate(bool|string|null $date): string
{
if (! empty($date)) {
$chk = explode(' ', $date);
$chkd = explode('-', $chk[0]);
if ($chkd[1] > 12) {
$date = date('Y-m-d H:i:s', strtotime($chkd[1].' '.$chkd[2].' '.$chkd[0]));
}
} else {
$date = null;
}
return $date;
}
/**
* Checks API response returns have all REQUIRED attributes set
*/
public function checkRequiredAttr(mixed $array, string $type): bool
{
$required = ['failedToMatchType'];
switch ($type) {
case 'tvdbS':
$required = ['tvdb_id', 'name', 'overview', 'first_air_time'];
break;
case 'tvdbE':
$required = ['name', 'seasonNumber', 'number', 'aired', 'overview'];
break;
case 'tvmazeS':
$required = ['id', 'name', 'summary', 'premiered', 'country'];
break;
case 'tvmazeE':
$required = ['name', 'season', 'number', 'airdate', 'summary'];
break;
case 'tmdbS':
$required = ['id', 'name', 'overview', 'first_air_date', 'origin_country'];
break;
case 'tmdbE':
$required = ['name', 'season_number', 'episode_number', 'air_date', 'overview'];
break;
case 'traktS':
$required = ['title', 'ids', 'overview', 'first_aired', 'airs', 'country'];
break;
case 'traktE':
$required = ['title', 'season', 'number', 'overview', 'first_aired'];
break;
}
foreach ($required as $req) {
if (! \in_array($type, ['tmdbS', 'tmdbE', 'traktS', 'traktE'], false)) {
if (! isset($array->$req)) {
return false;
}
} elseif (! isset($array[$req])) {
return false;
}
}
return true;
}
/**
* Truncates title for display.
*/
protected function truncateTitle(string $title, int $maxLength = 45): string
{
if (mb_strlen($title) <= $maxLength) {
return $title;
}
return mb_substr($title, 0, $maxLength - 3).'...';
}
}