starred/newznab-tmux
1
0
Fork 0
mirror of https://github.com/NNTmux/newznab-tmux.git synced 2026-09-02 19:28:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update TV processing pipeline

Browse Source
This commit is contained in:
DariusIII
2025-11-04 14:52:25 +01:00
parent c966899f5b
commit 4a54d57ed9
10 changed files with 815 additions and 61 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Blacklight/processing/PostProcess.php
+18 -2
View File
@@ -194,12 +194,28 @@ class PostProcess
* @param string $guidChar (Optional) First letter of a release GUID to use to get work.
* @param int|string|null $processTV (Optional) 0 Don't process, 1 process all releases,
* 2 process renamed releases only, '' check site setting
* @param string $mode (Optional) Processing mode: 'pipeline' (default) or 'parallel'
*
* @throws \Exception
*/
public function processTv(string $groupID = '', string $guidChar = '', int|string|null $processTV = ''): void
public function processTv(string $groupID = '', string $guidChar = '', int|string|null $processTV = '', string $mode = 'pipeline'): void
{
$this->tvProcessor->process($groupID, $guidChar, $processTV);
// If no GUID character specified, use parallel-pipeline processing via Forking
if ($guidChar === '') {
$forking = new \Blacklight\libraries\Forking;
$options = [];
// Convert processTV setting to renamed-only flag
$processTV = (is_numeric($processTV) ? $processTV : \App\Models\Settings::settingValue('lookuptv'));
if ($processTV == 2) {
$options = [0 => true]; // renamed only
}
$forking->processWorkType('postProcess_tv', $options);
} else {
// Process single GUID bucket with pipeline
$this->tvProcessor->process($groupID, $guidChar, $processTV, $mode);
}
}
/**