mirror of
https://github.com/NamelessMC/Nameless
synced 2026-08-18 06:29:04 -04:00
63 lines
1.5 KiB
PHP
63 lines
1.5 KiB
PHP
<?php
|
|
/**
|
|
* Queue query runs any pending tasks
|
|
*
|
|
* @var Cache $cache
|
|
* @var \DI\Container $container
|
|
* @var Navigation $cc_nav
|
|
* @var Navigation $navigation
|
|
* @var Navigation $staffcp_nav
|
|
* @var Pages $pages
|
|
* @var Smarty $smarty
|
|
* @var TemplateBase $template
|
|
* @var User $user
|
|
* @var Widgets $widgets
|
|
*/
|
|
|
|
header('Content-type: application/json;charset=utf-8');
|
|
|
|
define('PAGE', 'queue_query');
|
|
require_once(ROOT_PATH . '/core/templates/frontend_init.php');
|
|
|
|
// TODO: mixed type for $output when PHP 8.0+
|
|
function return_json($output, ?bool $error = false) {
|
|
echo json_encode(['error' => $error, 'output' => $output], JSON_PRETTY_PRINT);
|
|
die();
|
|
}
|
|
|
|
$cache->setCache('queue');
|
|
$last_run = intval($cache->retrieve('last_run') ?? 0);
|
|
|
|
$interval = floatval(Settings::get('queue_interval') ?? 1);
|
|
$runner = Settings::get('queue_runner');
|
|
|
|
if ($runner == 'cron') {
|
|
if (!isset($_GET['cron'])) {
|
|
return_json('Invalid cron URL', true);
|
|
}
|
|
|
|
if (Input::get('key') != Settings::get('cron_key')) {
|
|
return_json('Invalid cron key', true);
|
|
}
|
|
}
|
|
|
|
$date = date('U');
|
|
$next_run = $last_run + ($interval * 60);
|
|
$diff = $next_run - $date;
|
|
|
|
if ($last_run && $diff > 0) {
|
|
return_json("Please wait $diff seconds before executing the queue", true);
|
|
}
|
|
|
|
// Update last run immediately
|
|
$cache->store('last_run', $date);
|
|
|
|
// Load modules + template
|
|
Module::loadPage($user, $pages, $cache, $smarty, [$navigation, $cc_nav, $staffcp_nav], $widgets, $template);
|
|
|
|
$template->onPageLoad();
|
|
|
|
// Process queue
|
|
$tasks = Queue::process($container);
|
|
|
|
return_json($tasks);
|