mirror of
https://github.com/NNTmux/newznab-tmux.git
synced 2026-08-29 01:08:56 +00:00
Code style fixes
This commit is contained in:
DariusIII
+265
-264
@@ -1,135 +1,169 @@
|
||||
<?php
|
||||
/**
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program (see LICENSE.txt in the base directory. If
|
||||
* not, see:
|
||||
*
|
||||
* @link <http://www.gnu.org/licenses/>.
|
||||
*
|
||||
* @author niel
|
||||
* @copyright 2015 nZEDb
|
||||
*/
|
||||
|
||||
namespace Blacklight\processing;
|
||||
/**
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU General Public License as published by
|
||||
* the Free Software Foundation, either version 3 of the License, or
|
||||
* (at your option) any later version.
|
||||
*
|
||||
* This program is distributed in the hope that it will be useful,
|
||||
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
* GNU General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU General Public License
|
||||
* along with this program (see LICENSE.txt in the base directory. If
|
||||
* not, see:
|
||||
*
|
||||
* @link <http://www.gnu.org/licenses/>.
|
||||
*
|
||||
* @author niel
|
||||
* @copyright 2015 nZEDb
|
||||
*/
|
||||
|
||||
use App\Models\TvInfo;
|
||||
use App\Models\Video;
|
||||
use App\Models\VideoAlias;
|
||||
use Illuminate\Support\Facades\Cache;
|
||||
namespace Blacklight\processing;
|
||||
|
||||
use App\Models\TvInfo;
|
||||
use App\Models\Video;
|
||||
use App\Models\VideoAlias;
|
||||
use Illuminate\Support\Facades\Cache;
|
||||
|
||||
/**
|
||||
* Parent class for TV/Film and any similar classes to inherit from.
|
||||
*/
|
||||
abstract class Videos
|
||||
{
|
||||
// Video Type Identifiers
|
||||
protected const TYPE_TV = 0; // Type of video is a TV Programme/Show
|
||||
|
||||
protected const TYPE_FILM = 1; // Type of video is a Film/Movie
|
||||
|
||||
protected const TYPE_ANIME = 2; // Type of video is a Anime
|
||||
|
||||
public bool $echooutput;
|
||||
|
||||
/**
|
||||
* Parent class for TV/Film and any similar classes to inherit from.
|
||||
* @var array sites The sites that we have an ID columns for in our video table.
|
||||
*/
|
||||
abstract class Videos
|
||||
private static $sites = ['imdb', 'tmdb', 'trakt', 'tvdb', 'tvmaze', 'tvrage'];
|
||||
|
||||
/**
|
||||
* @var array Temp Array of cached failed lookups
|
||||
*/
|
||||
public array $titleCache;
|
||||
|
||||
public function __construct()
|
||||
{
|
||||
// Video Type Identifiers
|
||||
protected const TYPE_TV = 0; // Type of video is a TV Programme/Show
|
||||
$this->echooutput = config('nntmux.echocli');
|
||||
$this->titleCache = [];
|
||||
}
|
||||
|
||||
protected const TYPE_FILM = 1; // Type of video is a Film/Movie
|
||||
/**
|
||||
* Main processing director function for scrapers
|
||||
* Calls work query function and initiates processing.
|
||||
*/
|
||||
abstract protected function processSite(int $groupID, string $guidChar, int $process, bool $local = false): void;
|
||||
|
||||
protected const TYPE_ANIME = 2; // Type of video is a Anime
|
||||
/**
|
||||
* Get video info from a Video ID and column.
|
||||
*
|
||||
* @return array|false False if invalid site, or ID not found; Site id value otherwise.
|
||||
*/
|
||||
protected function getSiteIDFromVideoID(string $siteColumn, int $videoID): bool|array
|
||||
{
|
||||
if (\in_array($siteColumn, self::$sites, false)) {
|
||||
$result = Video::query()->where('id', $videoID)->first([$siteColumn]);
|
||||
|
||||
public bool $echooutput;
|
||||
|
||||
/**
|
||||
* @var array sites The sites that we have an ID columns for in our video table.
|
||||
*/
|
||||
private static $sites = ['imdb', 'tmdb', 'trakt', 'tvdb', 'tvmaze', 'tvrage'];
|
||||
|
||||
/**
|
||||
* @var array Temp Array of cached failed lookups
|
||||
*/
|
||||
public array $titleCache;
|
||||
|
||||
public function __construct()
|
||||
{
|
||||
$this->echooutput = config('nntmux.echocli');
|
||||
$this->titleCache = [];
|
||||
return $result !== null ? $result[$siteColumn] : false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Main processing director function for scrapers
|
||||
* Calls work query function and initiates processing.
|
||||
*/
|
||||
abstract protected function processSite(int $groupID, string $guidChar, int $process, bool $local = false): void;
|
||||
return false;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get video info from a Video ID and column.
|
||||
*
|
||||
* @return array|false False if invalid site, or ID not found; Site id value otherwise.
|
||||
*/
|
||||
protected function getSiteIDFromVideoID(string $siteColumn, int $videoID): bool|array
|
||||
{
|
||||
if (\in_array($siteColumn, self::$sites, false)) {
|
||||
$result = Video::query()->where('id', $videoID)->first([$siteColumn]);
|
||||
/**
|
||||
* Get TV show local timezone from a Video ID.
|
||||
*
|
||||
* @return string Empty string if no query return or tz style timezone
|
||||
*/
|
||||
protected function getLocalZoneFromVideoID(int $videoID): string
|
||||
{
|
||||
$result = TvInfo::query()->where('videos_id', $videoID)->first(['localzone']);
|
||||
|
||||
return $result !== null ? $result[$siteColumn] : false;
|
||||
}
|
||||
return $result !== null ? $result['localzone'] : '';
|
||||
}
|
||||
|
||||
return false;
|
||||
/**
|
||||
* Get video info from a Site ID and column.
|
||||
*/
|
||||
protected function getVideoIDFromSiteID(string $siteColumn, int $siteID): bool|int
|
||||
{
|
||||
$result = false;
|
||||
if (\in_array($siteColumn, self::$sites, false)) {
|
||||
$result = Video::query()->where($siteColumn, $siteID)->first();
|
||||
}
|
||||
if (! empty($result)) {
|
||||
$query = $result->toArray();
|
||||
|
||||
return $query['id'];
|
||||
}
|
||||
|
||||
/**
|
||||
* Get TV show local timezone from a Video ID.
|
||||
*
|
||||
* @return string Empty string if no query return or tz style timezone
|
||||
*/
|
||||
protected function getLocalZoneFromVideoID(int $videoID): string
|
||||
{
|
||||
$result = TvInfo::query()->where('videos_id', $videoID)->first(['localzone']);
|
||||
return false;
|
||||
}
|
||||
|
||||
return $result !== null ? $result['localzone'] : '';
|
||||
public function getByTitle(string $title, int $type, int $source = 0)
|
||||
{
|
||||
// Check if we already have an entry for this show.
|
||||
$res = $this->getTitleExact($title, $type, $source);
|
||||
if ($res !== 0) {
|
||||
return $res;
|
||||
}
|
||||
|
||||
/**
|
||||
* Get video info from a Site ID and column.
|
||||
*/
|
||||
protected function getVideoIDFromSiteID(string $siteColumn, int $siteID): bool|int
|
||||
{
|
||||
$result = false;
|
||||
if (\in_array($siteColumn, self::$sites, false)) {
|
||||
$result = Video::query()->where($siteColumn, $siteID)->first();
|
||||
}
|
||||
if (! empty($result)) {
|
||||
$query = $result->toArray();
|
||||
|
||||
return $query['id'];
|
||||
}
|
||||
|
||||
return false;
|
||||
// Check alt. title (Strip ' and :) Maybe strip more in the future.
|
||||
$res = $this->getAlternativeTitleExact($title, $type, $source);
|
||||
if ($res !== 0) {
|
||||
return $res;
|
||||
}
|
||||
|
||||
public function getByTitle(string $title, int $type, int $source = 0)
|
||||
{
|
||||
// Check if we already have an entry for this show.
|
||||
$res = $this->getTitleExact($title, $type, $source);
|
||||
$title2 = str_ireplace(' and ', ' & ', $title);
|
||||
if ((string) $title !== (string) $title2) {
|
||||
$res = $this->getTitleExact($title2, $type, $source);
|
||||
if ($res !== 0) {
|
||||
return $res;
|
||||
}
|
||||
|
||||
// Check alt. title (Strip ' and :) Maybe strip more in the future.
|
||||
$res = $this->getAlternativeTitleExact($title, $type, $source);
|
||||
$pieces = explode(' ', $title2);
|
||||
$title2 = '%';
|
||||
foreach ($pieces as $piece) {
|
||||
$title2 .= str_ireplace(["'", '!'], '', $piece).'%';
|
||||
}
|
||||
$res = $this->getTitleLoose($title2, $type, $source);
|
||||
if ($res !== 0) {
|
||||
return $res;
|
||||
}
|
||||
}
|
||||
|
||||
$title2 = str_ireplace(' and ', ' & ', $title);
|
||||
if ((string) $title !== (string) $title2) {
|
||||
$res = $this->getTitleExact($title2, $type, $source);
|
||||
if ($res !== 0) {
|
||||
return $res;
|
||||
}
|
||||
$pieces = explode(' ', $title2);
|
||||
// Some words are spelled correctly 2 ways
|
||||
// example theatre and theater
|
||||
$title2 = str_ireplace('er', 're', $title);
|
||||
if ((string) $title !== (string) $title2) {
|
||||
$res = $this->getTitleExact($title2, $type, $source);
|
||||
if ($res !== 0) {
|
||||
return $res;
|
||||
}
|
||||
$pieces = explode(' ', $title2);
|
||||
$title2 = '%';
|
||||
foreach ($pieces as $piece) {
|
||||
$title2 .= str_ireplace(["'", '!'], '', $piece).'%';
|
||||
}
|
||||
$res = $this->getTitleLoose($title2, $type, $source);
|
||||
if ($res !== 0) {
|
||||
return $res;
|
||||
}
|
||||
} else {
|
||||
// If there was not an exact title match, look for title with missing chars
|
||||
// example release name :Zorro 1990, tvrage name Zorro (1990)
|
||||
// Only search if the title contains more than one word to prevent incorrect matches
|
||||
$pieces = explode(' ', $title);
|
||||
if (\count($pieces) > 1) {
|
||||
$title2 = '%';
|
||||
foreach ($pieces as $piece) {
|
||||
$title2 .= str_ireplace(["'", '!'], '', $piece).'%';
|
||||
@@ -139,194 +173,161 @@
|
||||
return $res;
|
||||
}
|
||||
}
|
||||
|
||||
// Some words are spelled correctly 2 ways
|
||||
// example theatre and theater
|
||||
$title2 = str_ireplace('er', 're', $title);
|
||||
if ((string) $title !== (string) $title2) {
|
||||
$res = $this->getTitleExact($title2, $type, $source);
|
||||
if ($res !== 0) {
|
||||
return $res;
|
||||
}
|
||||
$pieces = explode(' ', $title2);
|
||||
$title2 = '%';
|
||||
foreach ($pieces as $piece) {
|
||||
$title2 .= str_ireplace(["'", '!'], '', $piece).'%';
|
||||
}
|
||||
$res = $this->getTitleLoose($title2, $type, $source);
|
||||
if ($res !== 0) {
|
||||
return $res;
|
||||
}
|
||||
} else {
|
||||
// If there was not an exact title match, look for title with missing chars
|
||||
// example release name :Zorro 1990, tvrage name Zorro (1990)
|
||||
// Only search if the title contains more than one word to prevent incorrect matches
|
||||
$pieces = explode(' ', $title);
|
||||
if (\count($pieces) > 1) {
|
||||
$title2 = '%';
|
||||
foreach ($pieces as $piece) {
|
||||
$title2 .= str_ireplace(["'", '!'], '', $piece).'%';
|
||||
}
|
||||
$res = $this->getTitleLoose($title2, $type, $source);
|
||||
if ($res !== 0) {
|
||||
return $res;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
public function getTitleExact(string $title, int $type, int $source = 0): int
|
||||
{
|
||||
$return = 0;
|
||||
if (! empty($title)) {
|
||||
$sql = Video::query()->where(['title' => $title, 'type' => $type]);
|
||||
return 0;
|
||||
}
|
||||
|
||||
public function getTitleExact(string $title, int $type, int $source = 0): int
|
||||
{
|
||||
$return = 0;
|
||||
if (! empty($title)) {
|
||||
$sql = Video::query()->where(['title' => $title, 'type' => $type]);
|
||||
if ($source > 0) {
|
||||
$sql->where('source', $source);
|
||||
}
|
||||
$query = $sql->first();
|
||||
if (! empty($query)) {
|
||||
$result = $query->toArray();
|
||||
$return = $result['id'];
|
||||
}
|
||||
// Try for an alias
|
||||
if (empty($return)) {
|
||||
$sql = Video::query()
|
||||
->join('videos_aliases', 'videos.id', '=', 'videos_aliases.videos_id')
|
||||
->where(['videos_aliases.title' => $title, 'videos.type' => $type]);
|
||||
if ($source > 0) {
|
||||
$sql->where('source', $source);
|
||||
$sql->where('videos.source', $source);
|
||||
}
|
||||
$query = $sql->first();
|
||||
if (! empty($query)) {
|
||||
$result = $query->toArray();
|
||||
$return = $result['id'];
|
||||
}
|
||||
// Try for an alias
|
||||
if (empty($return)) {
|
||||
$sql = Video::query()
|
||||
->join('videos_aliases', 'videos.id', '=', 'videos_aliases.videos_id')
|
||||
->where(['videos_aliases.title' => $title, 'videos.type' => $type]);
|
||||
if ($source > 0) {
|
||||
$sql->where('videos.source', $source);
|
||||
}
|
||||
$query = $sql->first();
|
||||
if (! empty($query)) {
|
||||
$result = $query->toArray();
|
||||
$return = $result['id'];
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return $return;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return int|mixed
|
||||
*/
|
||||
public function getTitleLoose($title, $type, int $source = 0): mixed
|
||||
{
|
||||
$return = 0;
|
||||
return $return;
|
||||
}
|
||||
|
||||
if (! empty($title)) {
|
||||
/**
|
||||
* @return int|mixed
|
||||
*/
|
||||
public function getTitleLoose($title, $type, int $source = 0): mixed
|
||||
{
|
||||
$return = 0;
|
||||
|
||||
if (! empty($title)) {
|
||||
$sql = Video::query()
|
||||
->where('title', 'like', rtrim($title, '%'))
|
||||
->where('type', $type);
|
||||
if ($source > 0) {
|
||||
$sql->where('source', $source);
|
||||
}
|
||||
$query = $sql->first();
|
||||
if (! empty($query)) {
|
||||
$result = $query->toArray();
|
||||
$return = $result['id'];
|
||||
}
|
||||
// Try for an alias
|
||||
if (empty($return)) {
|
||||
$sql = Video::query()
|
||||
->where('title', 'like', rtrim($title, '%'))
|
||||
->join('videos_aliases', 'videos.id', '=', 'videos_aliases.videos_id')
|
||||
->where('videos_aliases.title', '=', rtrim($title, '%'))
|
||||
->where('type', $type);
|
||||
if ($source > 0) {
|
||||
$sql->where('source', $source);
|
||||
$sql->where('videos.source', $source);
|
||||
}
|
||||
$query = $sql->first();
|
||||
if (! empty($query)) {
|
||||
$result = $query->toArray();
|
||||
$return = $result['id'];
|
||||
}
|
||||
// Try for an alias
|
||||
if (empty($return)) {
|
||||
$sql = Video::query()
|
||||
->join('videos_aliases', 'videos.id', '=', 'videos_aliases.videos_id')
|
||||
->where('videos_aliases.title', '=', rtrim($title, '%'))
|
||||
->where('type', $type);
|
||||
if ($source > 0) {
|
||||
$sql->where('videos.source', $source);
|
||||
}
|
||||
$query = $sql->first();
|
||||
if (! empty($query)) {
|
||||
$result = $query->toArray();
|
||||
$return = $result['id'];
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return $return;
|
||||
}
|
||||
|
||||
/**
|
||||
* @return int|mixed
|
||||
*/
|
||||
public function getAlternativeTitleExact(string $title, int $type, int $source = 0): mixed
|
||||
{
|
||||
$return = 0;
|
||||
if (! empty($title)) {
|
||||
if ($source > 0) {
|
||||
$query = Video::query()
|
||||
->whereRaw("REPLACE(title,'\'','') = ?", $title)
|
||||
->orWhereRaw("REPLACE(title,':','') = ?", $title)
|
||||
->where('type', '=', $type)
|
||||
->where('source', '=', $source)
|
||||
->first();
|
||||
} else {
|
||||
$query = Video::query()
|
||||
->whereRaw("REPLACE(title,'\'','') = ?", $title)
|
||||
->orWhereRaw("REPLACE(title,':','') = ?", $title)
|
||||
->where('type', '=', $type)
|
||||
->first();
|
||||
}
|
||||
if (! empty($query)) {
|
||||
$result = $query->toArray();
|
||||
|
||||
return $result['id'];
|
||||
}
|
||||
}
|
||||
|
||||
return $return;
|
||||
}
|
||||
|
||||
/**
|
||||
* Inserts aliases for videos.
|
||||
*/
|
||||
public function addAliases($videoId, array $aliases = []): void
|
||||
{
|
||||
if (! empty($aliases) && $videoId > 0) {
|
||||
foreach ($aliases as $key => $title) {
|
||||
// Check for tvmaze style aka
|
||||
if (\is_array($title) && ! empty($title['name'])) {
|
||||
$title = $title['name'];
|
||||
}
|
||||
// Check if we have the AKA already
|
||||
$check = $this->getAliases($videoId, $title);
|
||||
|
||||
if ($check === false) {
|
||||
VideoAlias::insertOrIgnore(['videos_id' => $videoId, 'title' => $title, 'created_at' => now(), 'updated_at' => now()]);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Retrieves all aliases for given VideoID or VideoID for a given alias.
|
||||
*
|
||||
*
|
||||
* @return VideoAlias[]|bool|\Illuminate\Database\Eloquent\Builder[]|\Illuminate\Database\Eloquent\Collection|mixed
|
||||
*/
|
||||
public function getAliases(int $videoId, string $alias = ''): mixed
|
||||
{
|
||||
$return = false;
|
||||
$expiresAt = now()->addMinutes(config('nntmux.cache_expiry_medium'));
|
||||
return $return;
|
||||
}
|
||||
|
||||
if ($videoId > 0 || $alias !== '') {
|
||||
$aliasCache = Cache::get(md5($videoId.$alias));
|
||||
if ($aliasCache !== null) {
|
||||
$return = $aliasCache;
|
||||
} else {
|
||||
$sql = VideoAlias::query();
|
||||
if ($videoId > 0) {
|
||||
$sql->where('videos_id', $videoId);
|
||||
} elseif ($alias !== '') {
|
||||
$sql->where('title', $alias);
|
||||
}
|
||||
$return = $sql->get();
|
||||
Cache::put(md5($videoId.$alias), $return, $expiresAt);
|
||||
/**
|
||||
* @return int|mixed
|
||||
*/
|
||||
public function getAlternativeTitleExact(string $title, int $type, int $source = 0): mixed
|
||||
{
|
||||
$return = 0;
|
||||
if (! empty($title)) {
|
||||
if ($source > 0) {
|
||||
$query = Video::query()
|
||||
->whereRaw("REPLACE(title,'\'','') = ?", $title)
|
||||
->orWhereRaw("REPLACE(title,':','') = ?", $title)
|
||||
->where('type', '=', $type)
|
||||
->where('source', '=', $source)
|
||||
->first();
|
||||
} else {
|
||||
$query = Video::query()
|
||||
->whereRaw("REPLACE(title,'\'','') = ?", $title)
|
||||
->orWhereRaw("REPLACE(title,':','') = ?", $title)
|
||||
->where('type', '=', $type)
|
||||
->first();
|
||||
}
|
||||
if (! empty($query)) {
|
||||
$result = $query->toArray();
|
||||
|
||||
return $result['id'];
|
||||
}
|
||||
}
|
||||
|
||||
return $return;
|
||||
}
|
||||
|
||||
/**
|
||||
* Inserts aliases for videos.
|
||||
*/
|
||||
public function addAliases($videoId, array $aliases = []): void
|
||||
{
|
||||
if (! empty($aliases) && $videoId > 0) {
|
||||
foreach ($aliases as $key => $title) {
|
||||
// Check for tvmaze style aka
|
||||
if (\is_array($title) && ! empty($title['name'])) {
|
||||
$title = $title['name'];
|
||||
}
|
||||
// Check if we have the AKA already
|
||||
$check = $this->getAliases($videoId, $title);
|
||||
|
||||
if ($check === false) {
|
||||
VideoAlias::insertOrIgnore(['videos_id' => $videoId, 'title' => $title, 'created_at' => now(), 'updated_at' => now()]);
|
||||
}
|
||||
}
|
||||
|
||||
return $return->isEmpty() ? false : $return;
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Retrieves all aliases for given VideoID or VideoID for a given alias.
|
||||
*
|
||||
*
|
||||
* @return VideoAlias[]|bool|\Illuminate\Database\Eloquent\Builder[]|\Illuminate\Database\Eloquent\Collection|mixed
|
||||
*/
|
||||
public function getAliases(int $videoId, string $alias = ''): mixed
|
||||
{
|
||||
$return = false;
|
||||
$expiresAt = now()->addMinutes(config('nntmux.cache_expiry_medium'));
|
||||
|
||||
if ($videoId > 0 || $alias !== '') {
|
||||
$aliasCache = Cache::get(md5($videoId.$alias));
|
||||
if ($aliasCache !== null) {
|
||||
$return = $aliasCache;
|
||||
} else {
|
||||
$sql = VideoAlias::query();
|
||||
if ($videoId > 0) {
|
||||
$sql->where('videos_id', $videoId);
|
||||
} elseif ($alias !== '') {
|
||||
$sql->where('title', $alias);
|
||||
}
|
||||
$return = $sql->get();
|
||||
Cache::put(md5($videoId.$alias), $return, $expiresAt);
|
||||
}
|
||||
}
|
||||
|
||||
return $return->isEmpty() ? false : $return;
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user