*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
use Chevere\ThrowableHandler\Documents\PlainDocument;
use Chevereto\Config\Config;
use Chevereto\Legacy\Classes\DB;
use Chevereto\Legacy\Classes\Image;
use Chevereto\Legacy\Classes\L10n;
use Chevereto\Legacy\Classes\Lock;
use Chevereto\Legacy\Classes\Queue;
use Chevereto\Legacy\Classes\Settings;
use Chevereto\Legacy\Classes\User;
use Chevereto\Legacy\Classes\Variable;
use function Chevere\Message\message;
use function Chevere\ThrowableHandler\throwableHandler;
use function Chevere\Writer\writers;
use function Chevere\xrDebug\PHP\throwableHandler as XrDebugThrowableHandler;
use function Chevereto\Legacy\checkUpdates;
use function Chevereto\Legacy\cheveretoVersionInstalled;
use function Chevereto\Legacy\feedbackAlert;
use function Chevereto\Legacy\feedbackStep;
use function Chevereto\Legacy\G\datetime_add;
use function Chevereto\Legacy\G\datetime_sub;
use function Chevereto\Legacy\G\datetimegmt;
use function Chevereto\Legacy\getSetting;
use function Chevereto\Legacy\isSafeToExecute;
use function Chevereto\Legacy\updateCheveretoNews;
use function Chevereto\Vars\env;
if (cheveretoVersionInstalled() === '') {
echo "[!] Chevereto is not installed.\n";
exit(255);
}
if (getSetting('maintenance')) {
echo "[!] Chevereto is in maintenance mode.\n";
exit(255);
}
$jobs = [
'deleteExpiredFiles',
'cleanUnconfirmedUsers',
'removeDeleteLog',
'storageDelete',
'deleteExpiredUploads',
];
if ((bool) env()['CHEVERETO_ENABLE_UPDATE_CHECK']) {
$jobs[] = 'checkForUpdates';
}
if ((bool) env()['CHEVERETO_ENABLE_NEWS_CHECK']) {
$jobs[] = 'checkForNews';
}
if (Config::enabled()->htaccessCheck()) {
$jobs[] = 'checkHtaccess';
}
shuffle($jobs);
$time_start = microtime(true);
$errors = [];
$namespace = env()['CHEVERETO_TENANT_HANDLE'] ?? false;
foreach ($jobs as $job) {
if (! isSafeToExecute()) {
echo "[OK] Exit - (time is up)\n";
writeLastRan($time_start);
exit(0);
}
feedbackStep('Job:', $job);
try {
$job();
} catch (Throwable $throwable) {
feedbackAlert($throwable->getMessage());
$errors[$job] = $throwable->getMessage();
$publicHandler = throwableHandler($throwable);
if ($namespace) {
$publicHandler = $publicHandler
->withId($namespace . $publicHandler->id());
}
$internalHandler = $publicHandler->withIsDebug(true);
$docInternal = new PlainDocument($internalHandler);
$logMessage = '[' . $publicHandler->id() . '] '
. $docInternal->__toString()
. "\n\n";
try {
$errorLog = ini_get('error_log');
$fp = fopen($errorLog, 'a');
fwrite($fp, $logMessage);
fclose($fp);
} catch (Throwable) {
if (PHP_SAPI === 'cli') {
error_log($logMessage);
} else {
writers()->error()->write($logMessage);
}
}
$extra = <<Incident {$publicHandler->id()}
Backtrace
HTML;
XrDebugThrowableHandler($throwable, $extra);
}
}
writeLastRan($time_start);
function writeLastRan(float $time_start): void
{
$datetimegmt = datetimegmt();
Variable::set('cron_last_ran', $datetimegmt);
$time_taken = microtime(true) - $time_start;
$ceil = ceil($time_taken);
$round = round($time_taken, 2);
echo <<=')) {
$sql = <<create()) {
Queue::process([
'type' => $job,
]);
$lock->destroy();
return;
}
echoLocked($job);
}
function deleteExpiredFiles(): void
{
$job = 'delete-expired-files';
$lock = new Lock($job);
if ($lock->create()) {
Image::deleteExpired(50);
$lock->destroy();
return;
}
echoLocked($job);
}
function cleanUnconfirmedUsers(): void
{
$job = 'clean-unconfirmed-users';
$lock = new Lock($job);
if ($lock->create()) {
User::cleanUnconfirmed(5);
$lock->destroy();
return;
}
echoLocked($job);
}
function removeDeleteLog(): void
{
$job = 'remove-delete-log';
$lock = new Lock($job);
if ($lock->create()) {
$db = DB::getInstance();
$db->query('DELETE FROM ' . DB::getTable('deletions') . ' WHERE deleted_date_gmt <= :time;');
$db->bind(':time', datetime_sub(datetimegmt(), 'P3M'));
$db->exec();
$lock->destroy();
return;
}
echoLocked($job);
}
function checkForNews(): void
{
if (! checkoutUpdate('news_check_datetimegmt', 'PT4H')) {
feedbackAlert('Skipping news check');
return;
}
L10n::setLocale(Settings::get('default_language'));
$job = 'check-news';
$lock = new Lock($job);
if ($lock->create()) {
updateCheveretoNews();
$lock->destroy();
return;
}
echoLocked($job);
}
function checkForUpdates(): void
{
if (! checkoutUpdate('update_check_datetimegmt', 'P1D')) {
feedbackAlert('Skipping updates check');
return;
}
L10n::setLocale(Settings::get('default_language'));
$job = 'check-updates';
$lock = new Lock($job);
if ($lock->create()) {
checkUpdates();
$lock->destroy();
return;
}
echoLocked($job);
}
function checkoutUpdate(string $datetimeSetting, string $past): bool
{
$get = Variable::fetch($datetimeSetting);
return $get === null
|| datetime_add(
$get,
$past
) < datetimegmt();
}
function checkHtaccess()
{
include __DIR__ . '/htaccess-enforce.php';
}
function deleteExpiredUploads(): void
{
$job = 'delete-expired-uploads';
$lock = new Lock($job);
if ($lock->create()) {
$uploadsTable = DB::getTable('uploads');
$uploadsChunksTable = DB::getTable('uploads_chunks');
$db = DB::getInstance();
$db->query(
<<bind(':time', datetime_sub(datetimegmt(), 'P1D'));
$chunks = $db->fetchAll();
if (! $chunks) {
$lock->destroy();
return;
}
$ids = [];
foreach ($chunks as $chunk) {
$ids[] = (int) $chunk['id'];
$chunkPath = $chunk['path'];
if (file_exists($chunkPath)) {
unlink($chunkPath);
}
}
$ids = array_unique($ids);
$idsString = implode(',', $ids);
$db->query(
<<exec();
$lock->destroy();
return;
}
echoLocked($job);
}