1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
namespace Blacklight\processing\tv; |
4
|
|
|
|
5
|
|
|
use App\Models\Category; |
6
|
|
|
use App\Models\Release; |
7
|
|
|
use App\Models\Settings; |
8
|
|
|
use App\Models\TvEpisode; |
9
|
|
|
use App\Models\TvInfo; |
10
|
|
|
use App\Models\Video; |
11
|
|
|
use Blacklight\ColorCLI; |
12
|
|
|
use Blacklight\processing\Videos; |
13
|
|
|
use Blacklight\utility\Country; |
14
|
|
|
use Illuminate\Support\Facades\DB; |
15
|
|
|
|
16
|
|
|
/** |
17
|
|
|
* Class TV -- abstract extension of Videos |
18
|
|
|
* Contains functions suitable for re-use in all TV scrapers. |
19
|
|
|
*/ |
20
|
|
|
abstract class TV extends Videos |
21
|
|
|
{ |
22
|
|
|
// Television Sources |
23
|
|
|
protected const SOURCE_NONE = 0; // No Scrape source |
24
|
|
|
protected const SOURCE_TVDB = 1; // Scrape source was TVDB |
25
|
|
|
protected const SOURCE_TVMAZE = 2; // Scrape source was TVMAZE |
26
|
|
|
protected const SOURCE_TMDB = 3; // Scrape source was TMDB |
27
|
|
|
protected const SOURCE_TRAKT = 4; // Scrape source was Trakt |
28
|
|
|
protected const SOURCE_IMDB = 5; // Scrape source was IMDB |
29
|
|
|
|
30
|
|
|
// Anime Sources |
31
|
|
|
protected const SOURCE_ANIDB = 10; // Scrape source was AniDB |
32
|
|
|
|
33
|
|
|
// Processing signifiers |
34
|
|
|
protected const PROCESS_TVDB = 0; // Process TVDB First |
35
|
|
|
protected const PROCESS_TVMAZE = -1; // Process TVMaze Second |
36
|
|
|
protected const PROCESS_TMDB = -2; // Process TMDB Third |
37
|
|
|
protected const PROCESS_TRAKT = -3; // Process Trakt Fourth |
38
|
|
|
protected const PROCESS_IMDB = -4; // Process IMDB Fifth |
39
|
|
|
protected const NO_MATCH_FOUND = -6; // Failed All Methods |
40
|
|
|
protected const FAILED_PARSE = -100; // Failed Parsing |
41
|
|
|
|
42
|
|
|
/** |
43
|
|
|
* @var int |
44
|
|
|
*/ |
45
|
|
|
public $tvqty; |
46
|
|
|
|
47
|
|
|
/** |
48
|
|
|
* @string Path to Save Images |
49
|
|
|
*/ |
50
|
|
|
public $imgSavePath; |
51
|
|
|
|
52
|
|
|
/** |
53
|
|
|
* @var array Site ID columns for TV |
54
|
|
|
*/ |
55
|
|
|
public $siteColumns; |
56
|
|
|
|
57
|
|
|
/** |
58
|
|
|
* @var string The TV categories_id lookup SQL language |
59
|
|
|
*/ |
60
|
|
|
public $catWhere; |
61
|
|
|
|
62
|
|
|
/** |
63
|
|
|
* @var \Blacklight\ColorCLI |
64
|
|
|
*/ |
65
|
|
|
protected $colorCli; |
66
|
|
|
|
67
|
|
|
/** |
68
|
|
|
* TV constructor. |
69
|
|
|
* |
70
|
|
|
* @param array $options |
71
|
|
|
* @throws \Exception |
72
|
|
|
*/ |
73
|
|
|
public function __construct(array $options = []) |
74
|
|
|
{ |
75
|
|
|
parent::__construct($options); |
76
|
|
|
$this->colorCli = new ColorCLI(); |
77
|
|
|
$this->catWhere = 'categories_id BETWEEN '.Category::TV_ROOT.' AND '.Category::TV_OTHER.' AND categories_id != '.Category::TV_ANIME; |
78
|
|
|
$this->tvqty = Settings::settingValue('..maxrageprocessed') !== '' ? (int) Settings::settingValue('..maxrageprocessed') : 75; |
|
|
|
|
79
|
|
|
$this->imgSavePath = NN_COVERS.'tvshows'.DS; |
80
|
|
|
$this->siteColumns = ['tvdb', 'trakt', 'tvrage', 'tvmaze', 'imdb', 'tmdb']; |
81
|
|
|
} |
82
|
|
|
|
83
|
|
|
/** |
84
|
|
|
* Retrieve banner image from site using its API. |
85
|
|
|
* |
86
|
|
|
* @param $videoID |
87
|
|
|
* @param $siteId |
88
|
|
|
* |
89
|
|
|
* @return mixed |
90
|
|
|
*/ |
91
|
|
|
abstract protected function getBanner($videoID, $siteId); |
92
|
|
|
|
93
|
|
|
/** |
94
|
|
|
* Retrieve info of TV episode from site using its API. |
95
|
|
|
* |
96
|
|
|
* @param int $siteId |
97
|
|
|
* @param int $series |
98
|
|
|
* @param int $episode |
99
|
|
|
* |
100
|
|
|
* @return array|false False on failure, an array of information fields otherwise. |
101
|
|
|
*/ |
102
|
|
|
abstract protected function getEpisodeInfo($siteId, $series, $episode); |
103
|
|
|
|
104
|
|
|
/** |
105
|
|
|
* Retrieve poster image for TV episode from site using its API. |
106
|
|
|
* |
107
|
|
|
* @param int $videoId ID from videos table. |
108
|
|
|
* |
109
|
|
|
* @return int |
110
|
|
|
*/ |
111
|
|
|
abstract protected function getPoster($videoId): int; |
112
|
|
|
|
113
|
|
|
/** |
114
|
|
|
* Retrieve info of TV programme from site using it's API. |
115
|
|
|
* |
116
|
|
|
* @param string $name Title of programme to look up. Usually a cleaned up version from releases table. |
117
|
|
|
* |
118
|
|
|
* @return array|false False on failure, an array of information fields otherwise. |
119
|
|
|
*/ |
120
|
|
|
abstract protected function getShowInfo($name); |
121
|
|
|
|
122
|
|
|
/** |
123
|
|
|
* Assigns API show response values to a formatted array for insertion |
124
|
|
|
* Returns the formatted array. |
125
|
|
|
* |
126
|
|
|
* @param $show |
127
|
|
|
* |
128
|
|
|
* @return array |
129
|
|
|
*/ |
130
|
|
|
abstract protected function formatShowInfo($show): array; |
131
|
|
|
|
132
|
|
|
/** |
133
|
|
|
* Assigns API episode response values to a formatted array for insertion |
134
|
|
|
* Returns the formatted array. |
135
|
|
|
* |
136
|
|
|
* @param $episode |
137
|
|
|
* |
138
|
|
|
* @return array |
139
|
|
|
*/ |
140
|
|
|
abstract protected function formatEpisodeInfo($episode): array; |
141
|
|
|
|
142
|
|
|
/** |
143
|
|
|
* Retrieve releases for TV processing. |
144
|
|
|
* |
145
|
|
|
* |
146
|
|
|
* @param string $groupID |
147
|
|
|
* @param string $guidChar |
148
|
|
|
* @param int $lookupSetting |
149
|
|
|
* @param int $status |
150
|
|
|
* @return \Illuminate\Database\Eloquent\Collection|int|static[] |
151
|
|
|
*/ |
152
|
|
|
public function getTvReleases($groupID = '', $guidChar = '', $lookupSetting = 1, $status = 0) |
153
|
|
|
{ |
154
|
|
|
$ret = 0; |
155
|
|
|
if ($lookupSetting === 0) { |
156
|
|
|
return $ret; |
157
|
|
|
} |
158
|
|
|
|
159
|
|
|
$qry = Release::query() |
160
|
|
|
->where(['nzbstatus' => 1, 'videos_id' => 0, 'tv_episodes_id' => $status]) |
161
|
|
|
->where('size', '>', 1048576) |
162
|
|
|
->whereBetween('categories_id', [Category::TV_ROOT, Category::TV_OTHER]) |
163
|
|
|
->where('categories_id', '<>', Category::TV_ANIME) |
164
|
|
|
->orderBy('postdate', 'desc') |
165
|
|
|
->limit($this->tvqty); |
166
|
|
|
if ($groupID !== '') { |
167
|
|
|
$qry->where('groups_id', $groupID); |
168
|
|
|
} |
169
|
|
|
if ($guidChar !== '') { |
170
|
|
|
$qry->where('leftguid', $guidChar); |
171
|
|
|
} |
172
|
|
|
if ($lookupSetting === 2) { |
173
|
|
|
$qry->where('isrenamed', '=', 1); |
174
|
|
|
} |
175
|
|
|
|
176
|
|
|
return $qry->get(); |
177
|
|
|
} |
178
|
|
|
|
179
|
|
|
/** |
180
|
|
|
* Updates the release when match for the current scraper is found. |
181
|
|
|
* |
182
|
|
|
* @param $videoId |
183
|
|
|
* @param $releaseId |
184
|
|
|
* @param int $episodeId |
185
|
|
|
*/ |
186
|
|
|
public function setVideoIdFound($videoId, $releaseId, $episodeId): void |
187
|
|
|
{ |
188
|
|
|
Release::query() |
189
|
|
|
->where('id', $releaseId) |
190
|
|
|
->update(['videos_id' => $videoId, 'tv_episodes_id' => $episodeId]); |
191
|
|
|
} |
192
|
|
|
|
193
|
|
|
/** |
194
|
|
|
* Updates the release tv_episodes_id status when scraper match is not found. |
195
|
|
|
* |
196
|
|
|
* @param $status |
197
|
|
|
* @param $Id |
198
|
|
|
*/ |
199
|
|
|
public function setVideoNotFound($status, $Id): void |
200
|
|
|
{ |
201
|
|
|
Release::query() |
202
|
|
|
->where('id', $Id) |
203
|
|
|
->update(['tv_episodes_id' => $status]); |
204
|
|
|
} |
205
|
|
|
|
206
|
|
|
/** |
207
|
|
|
* Inserts a new video ID into the database for TV shows |
208
|
|
|
* If a duplicate is found it is handle by calling update instead. |
209
|
|
|
* |
210
|
|
|
* @param array $show |
211
|
|
|
* |
212
|
|
|
* @return int |
213
|
|
|
*/ |
214
|
|
|
public function add(array $show = []): int |
215
|
|
|
{ |
216
|
|
|
$videoId = false; |
217
|
|
|
|
218
|
|
|
// Check if the country is not a proper code and retrieve if not |
219
|
|
|
if ($show['country'] !== '' && \strlen($show['country']) > 2) { |
220
|
|
|
$show['country'] = Country::countryCode($show['country']); |
221
|
|
|
} |
222
|
|
|
|
223
|
|
|
// Check if video already exists based on site ID info |
224
|
|
|
// if that fails be sure we're not inserting duplicates by checking the title |
225
|
|
|
foreach ($this->siteColumns as $column) { |
226
|
|
|
if ((int) $show[$column] > 0) { |
227
|
|
|
$videoId = $this->getVideoIDFromSiteID($column, $show[$column]); |
228
|
|
|
} |
229
|
|
|
if ($videoId !== false) { |
230
|
|
|
break; |
231
|
|
|
} |
232
|
|
|
} |
233
|
|
|
|
234
|
|
|
if ($videoId === false) { |
235
|
|
|
$title = Video::query()->where('title', $show['title'])->first(['title']); |
236
|
|
|
if ($title === null) { |
237
|
|
|
// Insert the Show |
238
|
|
|
$videoId = Video::query()->insertGetId([ |
239
|
|
|
'type' => $show['type'], |
240
|
|
|
'title' => $show['title'], |
241
|
|
|
'countries_id' => $show['country'] ?? '', |
242
|
|
|
'started' => $show['started'], |
243
|
|
|
'source' => $show['source'], |
244
|
|
|
'tvdb' => $show['tvdb'], |
245
|
|
|
'trakt' => $show['trakt'], |
246
|
|
|
'tvrage' => $show['tvrage'], |
247
|
|
|
'tvmaze' => $show['tvmaze'], |
248
|
|
|
'imdb' => $show['imdb'], |
249
|
|
|
'tmdb' => $show['tmdb'], |
250
|
|
|
]); |
251
|
|
|
// Insert the supplementary show info |
252
|
|
|
TvInfo::query()->insert([ |
253
|
|
|
'videos_id' => $videoId, |
254
|
|
|
'summary' => $show['summary'], |
255
|
|
|
'publisher' => $show['publisher'], |
256
|
|
|
'localzone' => $show['localzone'], |
257
|
|
|
]); |
258
|
|
|
// If we have AKAs\aliases, insert those as well |
259
|
|
|
if (! empty($show['aliases'])) { |
260
|
|
|
$this->addAliases($videoId, $show['aliases']); |
261
|
|
|
} |
262
|
|
|
} |
263
|
|
|
} else { |
264
|
|
|
// If a local match was found, just update missing video info |
265
|
|
|
$this->update($videoId, $show); |
266
|
|
|
} |
267
|
|
|
|
268
|
|
|
return $videoId; |
269
|
|
|
} |
270
|
|
|
|
271
|
|
|
/** |
272
|
|
|
* Inserts a new TV episode into the tv_episodes table following a match to a Video ID. |
273
|
|
|
* |
274
|
|
|
* @param $videoId |
275
|
|
|
* @param array $episode |
276
|
|
|
* @return false|int |
277
|
|
|
*/ |
278
|
|
|
public function addEpisode($videoId, array $episode = []) |
279
|
|
|
{ |
280
|
|
|
$episodeId = $this->getBySeasonEp($videoId, $episode['series'], $episode['episode'], $episode['firstaired']); |
281
|
|
|
|
282
|
|
|
if ($episodeId === false) { |
283
|
|
|
$episodeId = TvEpisode::query()->insert( |
284
|
|
|
[ |
285
|
|
|
'videos_id' => $videoId, |
286
|
|
|
'series' => $episode['series'], |
287
|
|
|
'episode' => $episode['episode'], |
288
|
|
|
'se_complete' => $episode['se_complete'], |
289
|
|
|
'title' => $episode['title'], |
290
|
|
|
'firstaired' => $episode['firstaired'] !== '' ? $episode['firstaired'] : null, |
291
|
|
|
'summary' => $episode['summary'], |
292
|
|
|
] |
293
|
|
|
); |
294
|
|
|
} |
295
|
|
|
|
296
|
|
|
return $episodeId; |
297
|
|
|
} |
298
|
|
|
|
299
|
|
|
/** |
300
|
|
|
* Updates the show info with data from the supplied array |
301
|
|
|
* Only called when a duplicate show is found during insert. |
302
|
|
|
* |
303
|
|
|
* @param int $videoId |
304
|
|
|
* @param array $show |
305
|
|
|
*/ |
306
|
|
|
public function update($videoId, array $show = []): void |
307
|
|
|
{ |
308
|
|
|
if ($show['country'] !== '') { |
309
|
|
|
$show['country'] = Country::countryCode($show['country']); |
310
|
|
|
} |
311
|
|
|
|
312
|
|
|
$ifStringID = 'IF(%s = 0, %s, %s)'; |
313
|
|
|
$ifStringInfo = "IF(%s = '', %s, %s)"; |
314
|
|
|
|
315
|
|
|
DB::update( |
316
|
|
|
sprintf( |
317
|
|
|
' |
318
|
|
|
UPDATE videos v |
319
|
|
|
LEFT JOIN tv_info tvi ON v.id = tvi.videos_id |
320
|
|
|
SET v.countries_id = %s, v.tvdb = %s, v.trakt = %s, v.tvrage = %s, |
321
|
|
|
v.tvmaze = %s, v.imdb = %s, v.tmdb = %s, |
322
|
|
|
tvi.summary = %s, tvi.publisher = %s, tvi.localzone = %s |
323
|
|
|
WHERE v.id = %d', |
324
|
|
|
sprintf($ifStringInfo, 'v.countries_id', escapeString($show['country']), 'v.countries_id'), |
325
|
|
|
sprintf($ifStringID, 'v.tvdb', $show['tvdb'], 'v.tvdb'), |
326
|
|
|
sprintf($ifStringID, 'v.trakt', $show['trakt'], 'v.trakt'), |
327
|
|
|
sprintf($ifStringID, 'v.tvrage', $show['tvrage'], 'v.tvrage'), |
328
|
|
|
sprintf($ifStringID, 'v.tvmaze', $show['tvmaze'], 'v.tvmaze'), |
329
|
|
|
sprintf($ifStringID, 'v.imdb', $show['imdb'], 'v.imdb'), |
330
|
|
|
sprintf($ifStringID, 'v.tmdb', $show['tmdb'], 'v.tmdb'), |
331
|
|
|
sprintf($ifStringInfo, 'tvi.summary', escapeString($show['summary']), 'tvi.summary'), |
332
|
|
|
sprintf($ifStringInfo, 'tvi.publisher', escapeString($show['publisher']), 'tvi.publisher'), |
333
|
|
|
sprintf($ifStringInfo, 'tvi.localzone', escapeString($show['localzone']), 'tvi.localzone'), |
334
|
|
|
$videoId |
335
|
|
|
) |
336
|
|
|
); |
337
|
|
|
if (! empty($show['aliases'])) { |
338
|
|
|
$this->addAliases($videoId, $show['aliases']); |
339
|
|
|
} |
340
|
|
|
} |
341
|
|
|
|
342
|
|
|
/** |
343
|
|
|
* Deletes a TV show entirely from all child tables via the Video ID. |
344
|
|
|
* |
345
|
|
|
* |
346
|
|
|
* @param $id |
347
|
|
|
* |
348
|
|
|
* @return mixed |
349
|
|
|
* @throws \Throwable |
350
|
|
|
*/ |
351
|
|
|
public function delete($id) |
352
|
|
|
{ |
353
|
|
|
return DB::transaction(function () use ($id) { |
354
|
|
|
DB::delete( |
355
|
|
|
sprintf( |
356
|
|
|
' |
357
|
|
|
DELETE v, tvi, tve, va |
358
|
|
|
FROM videos v |
359
|
|
|
LEFT JOIN tv_info tvi ON v.id = tvi.videos_id |
360
|
|
|
LEFT JOIN tv_episodes tve ON v.id = tve.videos_id |
361
|
|
|
LEFT JOIN videos_aliases va ON v.id = va.videos_id |
362
|
|
|
WHERE v.id = %d', |
363
|
|
|
$id |
364
|
|
|
) |
365
|
|
|
); |
366
|
|
|
}, 3); |
367
|
|
|
} |
368
|
|
|
|
369
|
|
|
/** |
370
|
|
|
* Sets the TV show's image column to found (1). |
371
|
|
|
* |
372
|
|
|
* @param $videoId |
373
|
|
|
*/ |
374
|
|
|
public function setCoverFound($videoId): void |
375
|
|
|
{ |
376
|
|
|
TvInfo::query()->where('videos_id', $videoId)->update(['image' => 1]); |
377
|
|
|
} |
378
|
|
|
|
379
|
|
|
/** |
380
|
|
|
* Get site ID from a Video ID and the site's respective column. |
381
|
|
|
* Returns the ID value or false if none found. |
382
|
|
|
* |
383
|
|
|
* |
384
|
|
|
* @param $column |
385
|
|
|
* @param $id |
386
|
|
|
* @return bool|\Illuminate\Database\Eloquent\Model|mixed|null|static |
387
|
|
|
*/ |
388
|
|
|
public function getSiteByID($column, $id) |
389
|
|
|
{ |
390
|
|
|
$return = false; |
391
|
|
|
$video = Video::query()->where('id', $id)->first([$column]); |
392
|
|
|
if ($column === '*') { |
393
|
|
|
$return = $video; |
394
|
|
|
} elseif ($column !== '*' && $video !== null) { |
395
|
|
|
$return = $video[$column]; |
396
|
|
|
} |
397
|
|
|
|
398
|
|
|
return $return; |
399
|
|
|
} |
400
|
|
|
|
401
|
|
|
/** |
402
|
|
|
* Retrieves the Episode ID using the Video ID and either: |
403
|
|
|
* season/episode numbers OR the airdate. |
404
|
|
|
* |
405
|
|
|
* Returns the Episode ID or false if not found |
406
|
|
|
* |
407
|
|
|
* @param $id |
408
|
|
|
* @param $series |
409
|
|
|
* @param $episode |
410
|
|
|
* @param string $airdate |
411
|
|
|
* |
412
|
|
|
* @return int|false |
413
|
|
|
*/ |
414
|
|
|
public function getBySeasonEp($id, $series, $episode, $airdate = '') |
415
|
|
|
{ |
416
|
|
|
if ($series > 0 && $episode > 0) { |
417
|
|
|
$queryString = sprintf('tve.series = %d AND tve.episode = %d', $series, $episode); |
418
|
|
|
} elseif (! empty($airdate)) { |
419
|
|
|
$queryString = sprintf('DATE(tve.firstaired) = %s', escapeString(date('Y-m-d', strtotime($airdate)))); |
420
|
|
|
} else { |
421
|
|
|
return false; |
422
|
|
|
} |
423
|
|
|
|
424
|
|
|
$episodeArr = DB::selectOne( |
425
|
|
|
sprintf( |
426
|
|
|
' |
427
|
|
|
SELECT tve.id |
428
|
|
|
FROM tv_episodes tve |
429
|
|
|
WHERE tve.videos_id = %d |
430
|
|
|
AND %s', |
431
|
|
|
$id, |
432
|
|
|
$queryString |
433
|
|
|
) |
434
|
|
|
); |
435
|
|
|
|
436
|
|
|
return $episodeArr->id ?? false; |
437
|
|
|
} |
438
|
|
|
|
439
|
|
|
/** |
440
|
|
|
* Returns (true) if episodes for a given Video ID exist or don't (false). |
441
|
|
|
* |
442
|
|
|
* |
443
|
|
|
* @param $videoId |
444
|
|
|
* @return bool |
445
|
|
|
*/ |
446
|
|
|
public function countEpsByVideoID($videoId): bool |
447
|
|
|
{ |
448
|
|
|
$count = TvEpisode::query() |
449
|
|
|
->where('videos_id', $videoId)->count(['id']); |
450
|
|
|
|
451
|
|
|
return $count !== null && $count > 0; |
452
|
|
|
} |
453
|
|
|
|
454
|
|
|
/** |
455
|
|
|
* Parses a release searchname for specific TV show data |
456
|
|
|
* Returns an array of show data. |
457
|
|
|
* |
458
|
|
|
* @param $relname |
459
|
|
|
* |
460
|
|
|
* @return array|false |
461
|
|
|
*/ |
462
|
|
|
public function parseInfo($relname) |
463
|
|
|
{ |
464
|
|
|
$showInfo['name'] = $this->parseName($relname); |
|
|
|
|
465
|
|
|
|
466
|
|
|
if (! empty($showInfo['name'])) { |
467
|
|
|
|
468
|
|
|
// Retrieve the country from the cleaned name |
469
|
|
|
$showInfo['country'] = $this->parseCountry($showInfo['name']); |
470
|
|
|
|
471
|
|
|
// Clean show name. |
472
|
|
|
$showInfo['cleanname'] = preg_replace('/ - \d+$/i', '', $this->cleanName($showInfo['name'])); |
473
|
|
|
|
474
|
|
|
// Get the Season/Episode/Airdate |
475
|
|
|
$showInfo += $this->parseSeasonEp($relname); |
476
|
|
|
|
477
|
|
|
if (isset($showInfo['season'], $showInfo['episode'])) { |
478
|
|
|
if (! isset($showInfo['airdate'])) { |
479
|
|
|
// If year is present in the release name, add it to the cleaned name for title search |
480
|
|
|
if (preg_match('/[^a-z0-9](?P<year>(19|20)(\d{2}))[^a-z0-9]/i', $relname, $yearMatch)) { |
481
|
|
|
$showInfo['cleanname'] .= ' ('.$yearMatch['year'].')'; |
482
|
|
|
} |
483
|
|
|
// Check for multi episode release. |
484
|
|
|
if (\is_array($showInfo['episode'])) { |
485
|
|
|
$showInfo['episode'] = $showInfo['episode'][0]; |
486
|
|
|
} |
487
|
|
|
$showInfo['airdate'] = ''; |
488
|
|
|
} |
489
|
|
|
|
490
|
|
|
return $showInfo; |
491
|
|
|
} |
492
|
|
|
} |
493
|
|
|
|
494
|
|
|
return false; |
495
|
|
|
} |
496
|
|
|
|
497
|
|
|
/** |
498
|
|
|
* Parses the release searchname and returns a show title. |
499
|
|
|
* |
500
|
|
|
* @param string $relname |
501
|
|
|
* |
502
|
|
|
* @return string |
503
|
|
|
*/ |
504
|
|
|
private function parseName($relname) |
505
|
|
|
{ |
506
|
|
|
$showName = ''; |
507
|
|
|
|
508
|
|
|
$following = '[^a-z0-9](\d\d-\d\d|\d{1,3}x\d{2,3}|\(?(19|20)\d{2}\)?|(480|720|1080)[ip]|AAC2?|BD-?Rip|Blu-?Ray|D0?\d'. |
509
|
|
|
'|DD5|DiVX|DLMux|DTS|DVD(-?Rip)?|E\d{2,3}|[HX][\-_. ]?26[45]|ITA(-ENG)?|HEVC|[HPS]DTV|PROPER|REPACK|Season|Episode|'. |
510
|
|
|
'S\d+[^a-z0-9]?((E\d+)[abr]?)*|WEB[\-_. ]?(DL|Rip)|XViD)[^a-z0-9]?'; |
511
|
|
|
|
512
|
|
|
// For names that don't start with the title. |
513
|
|
|
if (preg_match('/^([^a-z0-9]{2,}|(sample|proof|repost)-)(?P<name>[\w .-]*?)'.$following.'/i', $relname, $matches)) { |
514
|
|
|
$showName = $matches['name']; |
515
|
|
|
} elseif (preg_match('/^(?P<name>[a-z0-9][\w\' .-]*?)'.$following.'/i', $relname, $matches)) { |
516
|
|
|
// For names that start with the title. |
517
|
|
|
$showName = $matches['name']; |
518
|
|
|
} |
519
|
|
|
// If we still have any of the words in $following, remove them. |
520
|
|
|
$showName = preg_replace('/'.$following.'/i', ' ', $showName); |
521
|
|
|
// Remove leading date if present |
522
|
|
|
$showName = preg_replace('/^\d{6}/', '', $showName); |
523
|
|
|
// Remove periods, underscored, anything between parenthesis. |
524
|
|
|
$showName = preg_replace('/\(.*?\)|[._]/i', ' ', $showName); |
525
|
|
|
// Finally remove multiple spaces and trim leading spaces. |
526
|
|
|
$showName = trim(preg_replace('/\s{2,}/', ' ', $showName)); |
527
|
|
|
|
528
|
|
|
return $showName; |
529
|
|
|
} |
530
|
|
|
|
531
|
|
|
/** |
532
|
|
|
* Parses the release searchname for the season/episode/airdate information. |
533
|
|
|
* |
534
|
|
|
* @param $relname |
535
|
|
|
* |
536
|
|
|
* @return array |
537
|
|
|
*/ |
538
|
|
|
private function parseSeasonEp($relname) |
539
|
|
|
{ |
540
|
|
|
$episodeArr = []; |
541
|
|
|
|
542
|
|
|
// S01E01-E02 and S01E01-02 |
543
|
|
|
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, $matches)) { |
544
|
|
|
$episodeArr['season'] = (int) $matches[2]; |
545
|
|
|
$episodeArr['episode'] = [(int) $matches[3], (int) $matches[4]]; |
546
|
|
|
} |
547
|
|
|
//S01E0102 and S01E01E02 - lame no delimit numbering, regex would collide if there was ever 1000 ep season. |
548
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9]s(\d{2})[^a-z0-9]?e(\d{2})e?(\d{2})[^a-z0-9]/i', $relname, $matches)) { |
549
|
|
|
$episodeArr['season'] = (int) $matches[2]; |
550
|
|
|
$episodeArr['episode'] = (int) $matches[3]; |
551
|
|
|
} |
552
|
|
|
// S01E01 and S01.E01 |
553
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9]s(\d{1,2})[^a-z0-9]?e(\d{1,3})[abr]?[^a-z0-9]/i', $relname, $matches)) { |
554
|
|
|
$episodeArr['season'] = (int) $matches[2]; |
555
|
|
|
$episodeArr['episode'] = (int) $matches[3]; |
556
|
|
|
} |
557
|
|
|
// S01 |
558
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9]s(\d{1,2})[^a-z0-9]/i', $relname, $matches)) { |
559
|
|
|
$episodeArr['season'] = (int) $matches[2]; |
560
|
|
|
$episodeArr['episode'] = 'all'; |
561
|
|
|
} |
562
|
|
|
// S01D1 and S1D1 |
563
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9]s(\d{1,2})[^a-z0-9]?d\d{1}[^a-z0-9]/i', $relname, $matches)) { |
564
|
|
|
$episodeArr['season'] = (int) $matches[2]; |
565
|
|
|
$episodeArr['episode'] = 'all'; |
566
|
|
|
} |
567
|
|
|
// 1x01 and 101 |
568
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9](\d{1,2})x(\d{1,3})[^a-z0-9]/i', $relname, $matches)) { |
569
|
|
|
$episodeArr['season'] = (int) $matches[2]; |
570
|
|
|
$episodeArr['episode'] = (int) $matches[3]; |
571
|
|
|
} |
572
|
|
|
// 2009.01.01 and 2009-01-01 |
573
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9](?P<airdate>(19|20)(\d{2})[.\/-](\d{2})[.\/-](\d{2}))[^a-z0-9]/i', $relname, $matches)) { |
574
|
|
|
$episodeArr['season'] = $matches[4].$matches[5]; |
575
|
|
|
$episodeArr['episode'] = $matches[5].'/'.$matches[6]; |
576
|
|
|
$episodeArr['airdate'] = date('Y-m-d', strtotime(preg_replace('/[^0-9]/i', '/', $matches['airdate']))); //yyyy-mm-dd |
577
|
|
|
} |
578
|
|
|
// 01.01.2009 |
579
|
|
|
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, $matches)) { |
580
|
|
|
$episodeArr['season'] = $matches[5].$matches[6]; |
581
|
|
|
$episodeArr['episode'] = $matches[3].'/'.$matches[4]; |
582
|
|
|
$episodeArr['airdate'] = date('Y-m-d', strtotime(preg_replace('/[^0-9]/i', '/', $matches['airdate']))); //yyyy-mm-dd |
583
|
|
|
} |
584
|
|
|
// 01.01.09 |
585
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9](\d{2})[^a-z0-9](\d{2})[^a-z0-9](\d{2})[^a-z0-9]/i', $relname, $matches)) { |
586
|
|
|
// Add extra logic to capture the proper YYYY year |
587
|
|
|
$episodeArr['season'] = $matches[4] = ($matches[4] <= 99 && $matches[4] > 15) ? '19'.$matches[4] : '20'.$matches[4]; |
588
|
|
|
$episodeArr['episode'] = $matches[2].'/'.$matches[3]; |
589
|
|
|
$tmpAirdate = $episodeArr['season'].'/'.$episodeArr['episode']; |
590
|
|
|
$episodeArr['airdate'] = date('Y-m-d', strtotime(preg_replace('/[^0-9]/i', '/', $tmpAirdate))); //yyyy-mm-dd |
591
|
|
|
} |
592
|
|
|
// 2009.E01 |
593
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9]20(\d{2})[^a-z0-9](\d{1,3})[^a-z0-9]/i', $relname, $matches)) { |
594
|
|
|
$episodeArr['season'] = '20'.$matches[2]; |
595
|
|
|
$episodeArr['episode'] = (int) $matches[3]; |
596
|
|
|
} |
597
|
|
|
// 2009.Part1 |
598
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9](19|20)(\d{2})[^a-z0-9]Part(\d{1,2})[^a-z0-9]/i', $relname, $matches)) { |
599
|
|
|
$episodeArr['season'] = $matches[2].$matches[3]; |
600
|
|
|
$episodeArr['episode'] = (int) $matches[4]; |
601
|
|
|
} |
602
|
|
|
// Part1/Pt1 |
603
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9](?:Part|Pt)[^a-z0-9](\d{1,2})[^a-z0-9]/i', $relname, $matches)) { |
604
|
|
|
$episodeArr['season'] = 1; |
605
|
|
|
$episodeArr['episode'] = (int) $matches[2]; |
606
|
|
|
} |
607
|
|
|
|
608
|
|
|
// Band.Of.Brothers.EP06.Bastogne.DVDRiP.XviD-DEiTY |
609
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9]EP?[^a-z0-9]?(\d{1,3})/i', $relname, $matches)) { |
610
|
|
|
$episodeArr['season'] = 1; |
611
|
|
|
$episodeArr['episode'] = (int) $matches[2]; |
612
|
|
|
} |
613
|
|
|
// Season.1 |
614
|
|
|
elseif (preg_match('/^(.*?)[^a-z0-9]Seasons?[^a-z0-9]?(\d{1,2})/i', $relname, $matches)) { |
615
|
|
|
$episodeArr['season'] = (int) $matches[2]; |
616
|
|
|
$episodeArr['episode'] = 'all'; |
617
|
|
|
} |
618
|
|
|
|
619
|
|
|
return $episodeArr; |
620
|
|
|
} |
621
|
|
|
|
622
|
|
|
/** |
623
|
|
|
* Parses the cleaned release name to determine if it has a country appended. |
624
|
|
|
* |
625
|
|
|
* @param string $showName |
626
|
|
|
* |
627
|
|
|
* @return string |
628
|
|
|
*/ |
629
|
|
|
private function parseCountry($showName): string |
630
|
|
|
{ |
631
|
|
|
// Country or origin matching. |
632
|
|
|
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)) { |
633
|
|
|
$currentCountry = strtolower($countryMatch[1]); |
634
|
|
|
if ($currentCountry === 'canada') { |
635
|
|
|
$country = 'CA'; |
636
|
|
|
} elseif ($currentCountry === 'australia') { |
637
|
|
|
$country = 'AU'; |
638
|
|
|
} elseif ($currentCountry === 'america' || $currentCountry === 'united states') { |
639
|
|
|
$country = 'US'; |
640
|
|
|
} elseif ($currentCountry === 'united kingdom') { |
641
|
|
|
$country = 'UK'; |
642
|
|
|
} else { |
643
|
|
|
$country = strtoupper($countryMatch[1]); |
644
|
|
|
} |
645
|
|
|
} else { |
646
|
|
|
$country = ''; |
647
|
|
|
} |
648
|
|
|
|
649
|
|
|
return $country; |
650
|
|
|
} |
651
|
|
|
|
652
|
|
|
/** |
653
|
|
|
* Supplementary to parseInfo |
654
|
|
|
* Cleans a derived local 'showname' for better matching probability |
655
|
|
|
* Returns the cleaned string. |
656
|
|
|
* |
657
|
|
|
* @param $str |
658
|
|
|
* |
659
|
|
|
* @return string |
660
|
|
|
*/ |
661
|
|
|
public function cleanName($str): string |
662
|
|
|
{ |
663
|
|
|
$str = str_replace(['.', '_'], ' ', $str); |
664
|
|
|
|
665
|
|
|
$str = str_replace(['à', 'á', 'â', 'ã', 'ä', 'æ', 'À', 'Á', 'Â', 'Ã', 'Ä'], 'a', $str); |
666
|
|
|
$str = str_replace(['ç', 'Ç'], 'c', $str); |
667
|
|
|
$str = str_replace(['Σ', 'è', 'é', 'ê', 'ë', 'È', 'É', 'Ê', 'Ë'], 'e', $str); |
668
|
|
|
$str = str_replace(['ì', 'í', 'î', 'ï', 'Ì', 'Í', 'Î', 'Ï'], 'i', $str); |
669
|
|
|
$str = str_replace(['ò', 'ó', 'ô', 'õ', 'ö', 'Ò', 'Ó', 'Ô', 'Õ', 'Ö'], 'o', $str); |
670
|
|
|
$str = str_replace(['ù', 'ú', 'û', 'ü', 'ū', 'Ú', 'Û', 'Ü', 'Ū'], 'u', $str); |
671
|
|
|
$str = str_replace('ß', 'ss', $str); |
672
|
|
|
|
673
|
|
|
$str = str_replace('&', 'and', $str); |
674
|
|
|
$str = preg_replace('/^(history|discovery) channel/i', '', $str); |
675
|
|
|
$str = str_replace(['\'', ':', '!', '"', '#', '*', '’', ',', '(', ')', '?'], '', $str); |
676
|
|
|
$str = str_replace('$', 's', $str); |
677
|
|
|
$str = preg_replace('/\s{2,}/', ' ', $str); |
678
|
|
|
|
679
|
|
|
$str = trim($str, '\"'); |
680
|
|
|
|
681
|
|
|
return trim($str); |
682
|
|
|
} |
683
|
|
|
|
684
|
|
|
/** |
685
|
|
|
* Simple function that compares two strings of text |
686
|
|
|
* Returns percentage of similarity. |
687
|
|
|
* |
688
|
|
|
* @param $ourName |
689
|
|
|
* @param $scrapeName |
690
|
|
|
* @param $probability |
691
|
|
|
* |
692
|
|
|
* @return int|float |
693
|
|
|
*/ |
694
|
|
|
public function checkMatch($ourName, $scrapeName, $probability) |
695
|
|
|
{ |
696
|
|
|
similar_text($ourName, $scrapeName, $matchpct); |
697
|
|
|
|
698
|
|
|
if ($matchpct >= $probability) { |
699
|
|
|
return $matchpct; |
700
|
|
|
} |
701
|
|
|
|
702
|
|
|
return 0; |
703
|
|
|
} |
704
|
|
|
|
705
|
|
|
// |
706
|
|
|
|
707
|
|
|
/** |
708
|
|
|
* Convert 2012-24-07 to 2012-07-24, there is probably a better way. |
709
|
|
|
* |
710
|
|
|
* This shouldn't ever happen as I've never heard of a date starting with year being followed by day value. |
711
|
|
|
* Could this be a mistake? i.e. trying to solve the mm-dd-yyyy/dd-mm-yyyy confusion into a yyyy-mm-dd? |
712
|
|
|
* |
713
|
|
|
* @param string|bool|null $date |
714
|
|
|
* |
715
|
|
|
* @return string |
716
|
|
|
*/ |
717
|
|
|
public function checkDate($date): string |
718
|
|
|
{ |
719
|
|
|
if (! empty($date)) { |
720
|
|
|
$chk = explode(' ', $date); |
721
|
|
|
$chkd = explode('-', $chk[0]); |
722
|
|
|
if ($chkd[1] > 12) { |
723
|
|
|
$date = date('Y-m-d H:i:s', strtotime($chkd[1].' '.$chkd[2].' '.$chkd[0])); |
724
|
|
|
} |
725
|
|
|
} else { |
726
|
|
|
$date = null; |
727
|
|
|
} |
728
|
|
|
|
729
|
|
|
return $date; |
|
|
|
|
730
|
|
|
} |
731
|
|
|
|
732
|
|
|
/** |
733
|
|
|
* Checks API response returns have all REQUIRED attributes set |
734
|
|
|
* Returns true or false. |
735
|
|
|
* |
736
|
|
|
* @param $array |
737
|
|
|
* @param int $type |
738
|
|
|
* |
739
|
|
|
* @return bool |
740
|
|
|
*/ |
741
|
|
|
public function checkRequiredAttr($array, $type): bool |
742
|
|
|
{ |
743
|
|
|
$required = ['failedToMatchType']; |
744
|
|
|
|
745
|
|
|
switch ($type) { |
746
|
|
|
case 'tvdbS': |
747
|
|
|
$required = ['id', 'seriesName', 'overview', 'firstAired']; |
748
|
|
|
break; |
749
|
|
|
case 'tvdbE': |
750
|
|
|
$required = ['episodeName', 'airedSeason', 'airedEpisode', 'firstAired', 'overview']; |
751
|
|
|
break; |
752
|
|
|
case 'tvmazeS': |
753
|
|
|
$required = ['id', 'name', 'summary', 'premiered', 'country']; |
754
|
|
|
break; |
755
|
|
|
case 'tvmazeE': |
756
|
|
|
$required = ['name', 'season', 'number', 'airdate', 'summary']; |
757
|
|
|
break; |
758
|
|
|
case 'tmdbS': |
759
|
|
|
$required = ['id', 'original_name', 'overview', 'first_air_date', 'origin_country']; |
760
|
|
|
break; |
761
|
|
|
case 'tmdbE': |
762
|
|
|
$required = ['name', 'season_number', 'episode_number', 'air_date', 'overview']; |
763
|
|
|
break; |
764
|
|
|
case 'traktS': |
765
|
|
|
$required = ['title', 'ids', 'overview', 'first_aired', 'airs', 'country']; |
766
|
|
|
break; |
767
|
|
|
case 'traktE': |
768
|
|
|
$required = ['title', 'season', 'episode', 'overview', 'first_aired']; |
769
|
|
|
break; |
770
|
|
|
} |
771
|
|
|
|
772
|
|
|
if (\is_array($required)) { |
|
|
|
|
773
|
|
|
foreach ($required as $req) { |
774
|
|
|
if (! \in_array($type, ['tmdbS', 'tmdbE', 'traktS', 'traktE'], false)) { |
775
|
|
|
if (! isset($array->$req)) { |
776
|
|
|
return false; |
777
|
|
|
} |
778
|
|
|
} elseif (! isset($array[$req])) { |
779
|
|
|
return false; |
780
|
|
|
} |
781
|
|
|
} |
782
|
|
|
} |
783
|
|
|
|
784
|
|
|
return true; |
785
|
|
|
} |
786
|
|
|
} |
787
|
|
|
|