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

Fix safe backfill

Browse Source
This commit is contained in:
DariusIII
2019-01-28 14:12:42 +01:00
parent ef270cd638
commit 1526455be3
4 changed files with 17 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
misc/update/multiprocessing/.do_not_run/switch.php
+12 -2
View File
@@ -16,6 +16,7 @@ use Blacklight\Binaries;
use Blacklight\Nfo;
use Blacklight\NNTP;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
// Are we coming from python or php ? $options[0] => (string): python|php
// The type of process we want to do: $options[1] => (string): releases
@@ -28,16 +29,18 @@ switch ($options[1]) {
// $options[3] => (int) backfill type from tmux settings. 1 = Backfill interval , 2 = Bakfill all
case 'backfill':
if (in_array((int)$options[3], [1, 2], false)) {
$value = Settings::settingValue('site.tmux.backfill_qty');
if ($value !== false) {
$value = (int) Settings::settingValue('site.tmux.backfill_qty');
if ($value !== null) {
try {
$nntp = nntp();
} catch (Exception $e) {
Log::error($e->getTraceAsString());
echo $e->getMessage();
}
try {
(new Backfill())->backfillAllGroups($options[2], ($options[3] === 1 ? '' : $value['value']));
} catch (Exception $e) {
Log::error($e->getTraceAsString());
echo $e->getMessage();
}
}
@@ -53,11 +56,13 @@ switch ($options[1]) {
try {
$nntp = nntp();
} catch (Exception $e) {
Log::error($e->getTraceAsString());
echo $e->getMessage();
}
try {
(new Backfill())->backfillAllGroups($options[2], $options[3]);
} catch (Exception $e) {
Log::error($e->getTraceAsString());
echo $e->getMessage();
}
break;
@@ -68,11 +73,13 @@ switch ($options[1]) {
try {
$nntp = nntp();
} catch (Exception $e) {
Log::error($e->getTraceAsString());
echo $e->getMessage();
}
try {
(new Backfill())->backfillAllGroups($options[2], 10000, 'normal');
} catch (Exception $e) {
Log::error($e->getTraceAsString());
echo $e->getMessage();
}
break;
@@ -97,16 +104,19 @@ switch ($options[1]) {
return;
}
} catch (Exception $e) {
Log::error($e->getTraceAsString());
echo $e->getMessage();
}
try {
$binaries = new Binaries(['NNTP' => $nntp, 'Groups' => null]);
} catch (Exception $e) {
Log::error($e->getTraceAsString());
echo $e->getMessage();
}
try {
$return = $binaries->scan($groupMySQL, $options[4], $options[5], ((int) Settings::settingValue('..safepartrepair') === 1 ? 'update' : 'backfill'));
} catch (Exception $e) {
Log::error($e->getTraceAsString());
echo $e->getMessage();
}
if (empty($return)) {