starred/newznab-tmux
1
0
Fork 0
mirror of https://github.com/NNTmux/newznab-tmux.git synced 2026-08-29 01:08:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update switch.php and Forking class once more

Browse Source
This commit is contained in:
DariusIII
2017-12-26 13:30:33 +01:00
parent 8a81eafa70
commit 57d42dae9c
2 changed files with 20 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files
misc/update/multiprocessing/.do_not_run/switch.php
+8 -5
View File
@@ -7,6 +7,7 @@ if (!isset($argv[1])) {
require_once dirname(__DIR__, 4) . DIRECTORY_SEPARATOR . 'bootstrap/autoload.php';
use App\Models\Settings;
use App\Models\Tmux;
use \nntmux\db\DB;
use \nntmux\processing\PostProcess;
use \nntmux\processing\ProcessReleases;
@@ -30,7 +31,7 @@ switch ($options[1]) {
case 'backfill':
if (in_array((int)$options[3], [1, 2], false)) {
$pdo = new DB();
$value = $pdo->queryOneRow("SELECT value FROM tmux WHERE setting = 'backfill_qty'");
$value = Tmux::value('backfill_qty');
if ($value !== false) {
$nntp = nntp($pdo);
(new Backfill())->backfillAllGroups($options[2], ($options[3] === 1 ? '' : $value['value']));
@@ -252,7 +253,7 @@ switch ($options[1]) {
case 'pp_movie':
if (charCheck($options[2])) {
$pdo = new DB();
(new PostProcess(['Settings' => $pdo]))->processMovies('', $options[2], (isset($options[3]) ? $options[3] : ''));
(new PostProcess(['Settings' => $pdo]))->processMovies('', $options[2], $options[3] ?? '');
}
break;
@@ -273,11 +274,12 @@ switch ($options[1]) {
* Create / process releases for a groupID.
*
* @param ProcessReleases|ProcessReleasesMultiGroup $releases
* @param int $groupID
* @param int $groupID
* @throws \Exception
*/
function processReleases($releases, $groupID)
{
$releaseCreationLimit = (Settings::settingValue('..maxnzbsprocessed') != '' ? (int)Settings::settingValue('..maxnzbsprocessed') : 1000);
$releaseCreationLimit = (Settings::settingValue('..maxnzbsprocessed') !== '' ? (int)Settings::settingValue('..maxnzbsprocessed') : 1000);
$releases->processIncompleteCollections($groupID);
$releases->processCollectionSizes($groupID);
$releases->deleteUnwantedCollections($groupID);
@@ -327,9 +329,10 @@ function collectionCheck(&$pdo, $groupID)
* Connect to usenet, return NNTP object.
*
* @param DB $pdo
* @param bool $alternate Use alternate NNTP provider.
* @param bool $alternate Use alternate NNTP provider.
*
* @return NNTP
* @throws \Exception
*/
function &nntp(&$pdo, $alternate = false)
{
nntmux/libraries/Forking.php
+12 -12
View File
@@ -717,23 +717,23 @@ class Forking extends \fork_daemon
/**
* Only 1 exit method is used for post process, since they are all similar.
*
* @param $groups
*
* @param array $groups
* @param string $identifier
*/
public function postProcessChildWorker($groups, $identifier = '')
{
$type = '';
if ($this->processAdditional) {
$type = 'pp_additional ';
} elseif ($this->processNFO) {
$type = 'pp_nfo ';
} elseif ($this->processMovies) {
$type = 'pp_movie ';
} elseif ($this->processTV) {
$type = 'pp_tv ';
}
foreach ($groups as $group) {
$type = '';
if ($this->processAdditional) {
$type = 'pp_additional ';
} elseif ($this->processNFO) {
$type = 'pp_nfo ';
} elseif ($this->processMovies) {
$type = 'pp_movie ';
} elseif ($this->processTV) {
$type = 'pp_tv ';
}
if ($type !== '') {
$this->_executeCommand(
$this->dnr_path.$type.$group['id'].(isset($group['renamed']) ? (' '.$group['renamed']) : '').'"'