108 lines
2.9 KiB
PHP
108 lines
2.9 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
namespace Icinga\Module\Director\Job;
|
||
|
|
|
||
|
|
use Icinga\Application\Benchmark;
|
||
|
|
use Icinga\Module\Director\IcingaConfig\IcingaConfig;
|
||
|
|
use Icinga\Module\Director\Hook\JobHook;
|
||
|
|
use Icinga\Module\Director\Web\Form\QuickForm;
|
||
|
|
use Icinga\Module\Director\Util;
|
||
|
|
|
||
|
|
class ConfigJob extends JobHook
|
||
|
|
{
|
||
|
|
protected $housekeeping;
|
||
|
|
|
||
|
|
public function run()
|
||
|
|
{
|
||
|
|
$this->housekeeping()->runAllTasks();
|
||
|
|
}
|
||
|
|
|
||
|
|
public function isPending()
|
||
|
|
{
|
||
|
|
return $this->housekeeping()->hasPendingTasks();
|
||
|
|
}
|
||
|
|
|
||
|
|
public static function getDescription(QuickForm $form)
|
||
|
|
{
|
||
|
|
return $form->translate(
|
||
|
|
'The Housekeeping job provides various task that keep your Director'
|
||
|
|
. ' database fast and clean'
|
||
|
|
);
|
||
|
|
}
|
||
|
|
|
||
|
|
protected function housekeeping()
|
||
|
|
{
|
||
|
|
if ($this->housekeeping === null) {
|
||
|
|
$this->housekeeping = new Housekeeping($this->db());
|
||
|
|
}
|
||
|
|
|
||
|
|
return $this->housekeeping;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Re-render the current configuration
|
||
|
|
*/
|
||
|
|
public function renderAction()
|
||
|
|
{
|
||
|
|
$config = new IcingaConfig($this->db());
|
||
|
|
Benchmark::measure('Rendering config');
|
||
|
|
if ($config->hasBeenModified()) {
|
||
|
|
Benchmark::measure('Config rendered, storing to db');
|
||
|
|
$config->store();
|
||
|
|
Benchmark::measure('All done');
|
||
|
|
$checksum = $config->getHexChecksum();
|
||
|
|
$this->printf(
|
||
|
|
"New config with checksum %s has been generated\n",
|
||
|
|
$checksum
|
||
|
|
);
|
||
|
|
} else {
|
||
|
|
$checksum = $config->getHexChecksum();
|
||
|
|
$this->printf(
|
||
|
|
"Config with checksum %s already exists\n",
|
||
|
|
$checksum
|
||
|
|
);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Deploy the current configuration
|
||
|
|
*
|
||
|
|
* Does nothing if config didn't change unless you provide
|
||
|
|
* the --force parameter
|
||
|
|
*/
|
||
|
|
public function deployAction()
|
||
|
|
{
|
||
|
|
$api = $this->api();
|
||
|
|
$db = $this->db();
|
||
|
|
|
||
|
|
$checksum = $this->params->get('checksum');
|
||
|
|
if ($checksum) {
|
||
|
|
$config = IcingaConfig::load(Util::hex2binary($checksum), $db);
|
||
|
|
} else {
|
||
|
|
$config = IcingaConfig::generate($db);
|
||
|
|
$checksum = $config->getHexChecksum();
|
||
|
|
}
|
||
|
|
|
||
|
|
$api->wipeInactiveStages($db);
|
||
|
|
$current = $api->getActiveChecksum($db);
|
||
|
|
if ($current === $checksum) {
|
||
|
|
if ($this->params->get('force')) {
|
||
|
|
echo "Config matches active stage, deploying anyway\n";
|
||
|
|
} else {
|
||
|
|
echo "Config matches active stage, nothing to do\n";
|
||
|
|
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
} else {
|
||
|
|
if ($api->dumpConfig($config, $db)) {
|
||
|
|
$this->printf("Config '%s' has been deployed\n", $checksum);
|
||
|
|
} else {
|
||
|
|
$this->fail(
|
||
|
|
sprintf("Failed to deploy config '%s'\n", $checksum)
|
||
|
|
);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|