X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=bin%2Fworker.php;h=a742132480b923adc203faded953d028660a768d;hb=3f6549d9a85f6b9cdaaef83ffb7dfe9fdb688675;hp=0f8dd98adb89cc82babf034d5ac23c59022c9da3;hpb=cd52d0b3e9841bbae2df33a996c529296dbf5e53;p=friendica.git diff --git a/bin/worker.php b/bin/worker.php index 0f8dd98adb..a742132480 100755 --- a/bin/worker.php +++ b/bin/worker.php @@ -1,64 +1,87 @@ #!/usr/bin/env php . + * + * Starts the background processing */ +if (php_sapi_name() !== 'cli') { + header($_SERVER["SERVER_PROTOCOL"] . ' 403 Forbidden'); + exit(); +} + +use Dice\Dice; use Friendica\App; -use Friendica\Core\Addon; -use Friendica\Core\Config; +use Friendica\App\Mode; +use Friendica\Core\Update; use Friendica\Core\Worker; +use Friendica\DI; +use Psr\Log\LoggerInterface; // Get options -$shortopts = ''; -$shortopts .= 'sc'; -$longopts = [ 'spawn', 'cron' ]; +$shortopts = 'sn'; +$longopts = ['spawn', 'no_cron']; $options = getopt($shortopts, $longopts); // Ensure that worker.php is executed from the base path of the installation -if (!file_exists("boot.php") && (sizeof($_SERVER["argv"]) != 0)) { +if (!file_exists("index.php") && (sizeof($_SERVER["argv"]) != 0)) { $directory = dirname($_SERVER["argv"][0]); - if (substr($directory, 0, 1) != "/") { - $directory = $_SERVER["PWD"]."/".$directory; + if (substr($directory, 0, 1) != '/') { + $directory = $_SERVER["PWD"] . '/' . $directory; } - $directory = realpath($directory."/.."); + $directory = realpath($directory . '/..'); chdir($directory); } -require_once "boot.php"; +require dirname(__DIR__) . '/vendor/autoload.php'; + +$dice = (new Dice())->addRules(include __DIR__ . '/../static/dependencies.config.php'); +$dice = $dice->addRule(LoggerInterface::class,['constructParams' => ['worker']]); -$a = new App(dirname(__DIR__)); +DI::init($dice); +\Friendica\Core\Logger\Handler\ErrorHandler::register($dice->create(\Psr\Log\LoggerInterface::class)); -Config::load(); +DI::mode()->setExecutor(Mode::WORKER); // Check the database structure and possibly fixes it -check_db(true); +Update::check(DI::basePath(), true); // Quit when in maintenance -if (Config::get('system', 'maintenance', false, true)) { +if (!DI::mode()->has(App\Mode::MAINTENANCEDISABLED)) { return; } -$a->set_baseurl(Config::get('system', 'url')); - -Addon::loadHooks(); - $spawn = array_key_exists('s', $options) || array_key_exists('spawn', $options); if ($spawn) { Worker::spawnWorker(); - killme(); + exit(); } -$run_cron = array_key_exists('c', $options) || array_key_exists('cron', $options); +$run_cron = !array_key_exists('n', $options) && !array_key_exists('no_cron', $options); -Worker::processQueue($run_cron); +$process = DI::process()->create(getmypid(), basename(__FILE__)); -Worker::unclaimProcess(); +Worker::processQueue($run_cron, $process); -Worker::endProcess(); +Worker::unclaimProcess($process); -killme(); +DI::process()->delete($process);