Merge pull request #19329 from nextcloud/feature/noid/warn-admins-about-delayed-cron
Warn admins about delayed cron executions
This commit is contained in:
commit
a1fb57d2e2
|
@ -28,17 +28,25 @@
|
||||||
namespace OCA\Settings\Settings\Admin;
|
namespace OCA\Settings\Settings\Admin;
|
||||||
|
|
||||||
use OCP\AppFramework\Http\TemplateResponse;
|
use OCP\AppFramework\Http\TemplateResponse;
|
||||||
|
use OCP\AppFramework\Utility\ITimeFactory;
|
||||||
use OCP\IConfig;
|
use OCP\IConfig;
|
||||||
|
use OCP\IDBConnection;
|
||||||
use OCP\Settings\ISettings;
|
use OCP\Settings\ISettings;
|
||||||
|
|
||||||
class Server implements ISettings {
|
class Server implements ISettings {
|
||||||
|
|
||||||
|
/** @var IDBConnection */
|
||||||
|
private $connection;
|
||||||
|
/** @var ITimeFactory */
|
||||||
|
private $timeFactory;
|
||||||
/** @var IConfig */
|
/** @var IConfig */
|
||||||
private $config;
|
private $config;
|
||||||
|
|
||||||
/**
|
public function __construct(IDBConnection $connection,
|
||||||
* @param IConfig $config
|
ITimeFactory $timeFactory,
|
||||||
*/
|
IConfig $config) {
|
||||||
public function __construct(IConfig $config) {
|
$this->connection = $connection;
|
||||||
|
$this->timeFactory = $timeFactory;
|
||||||
$this->config = $config;
|
$this->config = $config;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -50,6 +58,7 @@ class Server implements ISettings {
|
||||||
// Background jobs
|
// Background jobs
|
||||||
'backgroundjobs_mode' => $this->config->getAppValue('core', 'backgroundjobs_mode', 'ajax'),
|
'backgroundjobs_mode' => $this->config->getAppValue('core', 'backgroundjobs_mode', 'ajax'),
|
||||||
'lastcron' => $this->config->getAppValue('core', 'lastcron', false),
|
'lastcron' => $this->config->getAppValue('core', 'lastcron', false),
|
||||||
|
'cronMaxAge' => $this->cronMaxAge(),
|
||||||
'cronErrors' => $this->config->getAppValue('core', 'cronErrors'),
|
'cronErrors' => $this->config->getAppValue('core', 'cronErrors'),
|
||||||
'cli_based_cron_possible' => function_exists('posix_getpwuid'),
|
'cli_based_cron_possible' => function_exists('posix_getpwuid'),
|
||||||
'cli_based_cron_user' => function_exists('posix_getpwuid') ? posix_getpwuid(fileowner(\OC::$configDir . 'config.php'))['name'] : '',
|
'cli_based_cron_user' => function_exists('posix_getpwuid') ? posix_getpwuid(fileowner(\OC::$configDir . 'config.php'))['name'] : '',
|
||||||
|
@ -58,6 +67,24 @@ class Server implements ISettings {
|
||||||
return new TemplateResponse('settings', 'settings/admin/server', $parameters, '');
|
return new TemplateResponse('settings', 'settings/admin/server', $parameters, '');
|
||||||
}
|
}
|
||||||
|
|
||||||
|
protected function cronMaxAge(): int {
|
||||||
|
$query = $this->connection->getQueryBuilder();
|
||||||
|
$query->select('last_checked')
|
||||||
|
->from('jobs')
|
||||||
|
->orderBy('last_checked', 'ASC')
|
||||||
|
->setMaxResults(1);
|
||||||
|
|
||||||
|
$result = $query->execute();
|
||||||
|
if ($row = $result->fetch()) {
|
||||||
|
$maxAge = (int) $row['last_checked'];
|
||||||
|
} else {
|
||||||
|
$maxAge = $this->timeFactory->getTime();
|
||||||
|
}
|
||||||
|
$result->closeCursor();
|
||||||
|
|
||||||
|
return $maxAge;
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return string the section ID, e.g. 'sharing'
|
* @return string the section ID, e.g. 'sharing'
|
||||||
*/
|
*/
|
||||||
|
|
|
@ -29,26 +29,40 @@
|
||||||
<div class="section" id="backgroundjobs">
|
<div class="section" id="backgroundjobs">
|
||||||
<h2 class="inlineblock"><?php p($l->t('Background jobs'));?></h2>
|
<h2 class="inlineblock"><?php p($l->t('Background jobs'));?></h2>
|
||||||
<p class="cronlog inlineblock">
|
<p class="cronlog inlineblock">
|
||||||
<?php if ($_['lastcron'] !== false):
|
<?php if ($_['lastcron'] !== false) {
|
||||||
$relative_time = relative_modified_date($_['lastcron']);
|
$relative_time = relative_modified_date($_['lastcron']);
|
||||||
|
$maxAgeRelativeTime = relative_modified_date($_['cronMaxAge']);
|
||||||
|
|
||||||
$formatter = \OC::$server->getDateTimeFormatter();
|
$formatter = \OC::$server->getDateTimeFormatter();
|
||||||
$absolute_time = $formatter->formatDateTime($_['lastcron'], 'long', 'long');
|
$absolute_time = $formatter->formatDateTime($_['lastcron'], 'long', 'long');
|
||||||
if (time() - $_['lastcron'] <= 600): ?>
|
$maxAgeAbsoluteTime = $formatter->formatDateTime($_['cronMaxAge'], 'long', 'long');
|
||||||
<span class="status success"></span>
|
if (time() - $_['lastcron'] > 600) { ?>
|
||||||
<span class="crondate" title="<?php p($absolute_time);?>">
|
|
||||||
<?php p($l->t("Last job ran %s.", [$relative_time]));?>
|
|
||||||
</span>
|
|
||||||
<?php else: ?>
|
|
||||||
<span class="status error"></span>
|
<span class="status error"></span>
|
||||||
<span class="crondate" title="<?php p($absolute_time);?>">
|
<span class="crondate" title="<?php p($absolute_time);?>">
|
||||||
<?php p($l->t("Last job execution ran %s. Something seems wrong.", [$relative_time]));?>
|
<?php p($l->t("Last job execution ran %s. Something seems wrong.", [$relative_time]));?>
|
||||||
</span>
|
</span>
|
||||||
<?php endif;
|
<?php } else if (time() - $_['cronMaxAge'] > 12*3600) {
|
||||||
else: ?>
|
if ($_['backgroundjobs_mode'] === 'cron') { ?>
|
||||||
|
<span class="status warning"></span>
|
||||||
|
<span class="crondate" title="<?php p($maxAgeAbsoluteTime);?>">
|
||||||
|
<?php p($l->t("Some jobs haven’t been executed since %s. Please consider increasing the execution frequency.", [$maxAgeRelativeTime]));?>
|
||||||
|
</span>
|
||||||
|
<?php } else { ?>
|
||||||
|
<span class="status error"></span>
|
||||||
|
<span class="crondate" title="<?php p($maxAgeAbsoluteTime);?>">
|
||||||
|
<?php p($l->t("Some jobs didn’t execute since %s. Please consider switching to system cron.", [$maxAgeRelativeTime]));?>
|
||||||
|
</span>
|
||||||
|
<?php }
|
||||||
|
} else { ?>
|
||||||
|
<span class="status success"></span>
|
||||||
|
<span class="crondate" title="<?php p($absolute_time);?>">
|
||||||
|
<?php p($l->t("Last job ran %s.", [$relative_time]));?>
|
||||||
|
</span>
|
||||||
|
<?php }
|
||||||
|
} else { ?>
|
||||||
<span class="status error"></span>
|
<span class="status error"></span>
|
||||||
<?php p($l->t("Background job didn’t run yet!"));
|
<?php p($l->t("Background job didn’t run yet!"));
|
||||||
endif; ?>
|
} ?>
|
||||||
</p>
|
</p>
|
||||||
<a target="_blank" rel="noreferrer noopener" class="icon-info"
|
<a target="_blank" rel="noreferrer noopener" class="icon-info"
|
||||||
title="<?php p($l->t('Open documentation'));?>"
|
title="<?php p($l->t('Open documentation'));?>"
|
||||||
|
|
|
@ -1,4 +1,5 @@
|
||||||
<?php
|
<?php
|
||||||
|
declare(strict_types=1);
|
||||||
/**
|
/**
|
||||||
* @copyright Copyright (c) 2016 Lukas Reschke <lukas@statuscode.ch>
|
* @copyright Copyright (c) 2016 Lukas Reschke <lukas@statuscode.ch>
|
||||||
*
|
*
|
||||||
|
@ -31,25 +32,46 @@ namespace OCA\Settings\Tests\Settings\Admin;
|
||||||
|
|
||||||
use OCA\Settings\Settings\Admin\Server;
|
use OCA\Settings\Settings\Admin\Server;
|
||||||
use OCP\AppFramework\Http\TemplateResponse;
|
use OCP\AppFramework\Http\TemplateResponse;
|
||||||
|
use OCP\AppFramework\Utility\ITimeFactory;
|
||||||
use OCP\IConfig;
|
use OCP\IConfig;
|
||||||
|
use OCP\IDBConnection;
|
||||||
|
use PHPUnit\Framework\MockObject\MockObject;
|
||||||
use Test\TestCase;
|
use Test\TestCase;
|
||||||
|
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @group DB
|
||||||
|
*/
|
||||||
class ServerTest extends TestCase {
|
class ServerTest extends TestCase {
|
||||||
/** @var Server */
|
/** @var Server */
|
||||||
private $admin;
|
private $admin;
|
||||||
/** @var IConfig */
|
/** @var IDBConnection */
|
||||||
|
private $connection;
|
||||||
|
/** @var ITimeFactory|MockObject */
|
||||||
|
private $timeFactory;
|
||||||
|
/** @var IConfig|MockObject */
|
||||||
private $config;
|
private $config;
|
||||||
|
|
||||||
protected function setUp(): void {
|
protected function setUp(): void {
|
||||||
parent::setUp();
|
parent::setUp();
|
||||||
|
$this->connection = \OC::$server->getDatabaseConnection();
|
||||||
|
$this->timeFactory = $this->createMock(ITimeFactory::class);
|
||||||
$this->config = $this->createMock(IConfig::class);
|
$this->config = $this->createMock(IConfig::class);
|
||||||
|
|
||||||
$this->admin = new Server(
|
$this->admin = $this->getMockBuilder(Server::class)
|
||||||
$this->config
|
->onlyMethods(['cronMaxAge'])
|
||||||
);
|
->setConstructorArgs([
|
||||||
|
$this->connection,
|
||||||
|
$this->timeFactory,
|
||||||
|
$this->config,
|
||||||
|
])
|
||||||
|
->getMock();
|
||||||
}
|
}
|
||||||
|
|
||||||
public function testGetForm() {
|
public function testGetForm(): void {
|
||||||
|
$this->admin->expects($this->once())
|
||||||
|
->method('cronMaxAge')
|
||||||
|
->willReturn(1337);
|
||||||
$this->config
|
$this->config
|
||||||
->expects($this->at(0))
|
->expects($this->at(0))
|
||||||
->method('getAppValue')
|
->method('getAppValue')
|
||||||
|
@ -72,6 +94,7 @@ class ServerTest extends TestCase {
|
||||||
'backgroundjobs_mode' => 'ajax',
|
'backgroundjobs_mode' => 'ajax',
|
||||||
'lastcron' => false,
|
'lastcron' => false,
|
||||||
'cronErrors' => '',
|
'cronErrors' => '',
|
||||||
|
'cronMaxAge' => 1337,
|
||||||
'cli_based_cron_possible' => true,
|
'cli_based_cron_possible' => true,
|
||||||
'cli_based_cron_user' => function_exists('posix_getpwuid') ? posix_getpwuid(fileowner(\OC::$configDir . 'config.php'))['name'] : '', // to not explode here because of posix extension not being disabled - which is already checked in the line above
|
'cli_based_cron_user' => function_exists('posix_getpwuid') ? posix_getpwuid(fileowner(\OC::$configDir . 'config.php'))['name'] : '', // to not explode here because of posix extension not being disabled - which is already checked in the line above
|
||||||
],
|
],
|
||||||
|
@ -81,11 +104,11 @@ class ServerTest extends TestCase {
|
||||||
$this->assertEquals($expected, $this->admin->getForm());
|
$this->assertEquals($expected, $this->admin->getForm());
|
||||||
}
|
}
|
||||||
|
|
||||||
public function testGetSection() {
|
public function testGetSection(): void {
|
||||||
$this->assertSame('server', $this->admin->getSection());
|
$this->assertSame('server', $this->admin->getSection());
|
||||||
}
|
}
|
||||||
|
|
||||||
public function testGetPriority() {
|
public function testGetPriority(): void {
|
||||||
$this->assertSame(0, $this->admin->getPriority());
|
$this->assertSame(0, $this->admin->getPriority());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue