Friendica/friendica-github
1
0
Fork 0
mirror of https://github.com/friendica/friendica synced 2025-04-23 07:10:14 +00:00
Code Issues Projects Releases Packages Wiki Activity

New endpoint for monitoring services

Browse source
This commit is contained in:
Michael 2024-07-21 14:33:44 +00:00
parent 8e094a2dd0
commit 53d121de51
6 changed files with 173 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

144
src/Module/Stats.php Normal file
View file

@ -0,0 +1,144 @@
<?php
/**
* @copyright Copyright (C) 2010-2024, the Friendica project
*
* @license GNU AGPL version 3 or any later version
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*
*/
namespace Friendica\Module;
use Friendica\App;
use Friendica\BaseModule;
use Friendica\Core\Config\Capability\IManageConfigValues;
use Friendica\Core\KeyValueStorage\Capability\IManageKeyValuePairs;
use Friendica\Core\L10n;
use Friendica\Core\Worker;
use Friendica\Database\Database;
use Friendica\Util\DateTimeFormat;
use Friendica\Util\Profiler;
use Psr\Log\LoggerInterface;
use Friendica\Network\HTTPException;
class Stats extends BaseModule
{
/** @var IManageConfigValues */
protected $config;
/** @var Database */
protected $dba;
/** @var LoggerInterface */
protected $logger;
/** @var IManageKeyValuePairs */
protected $keyValue;
public function __construct(L10n $l10n, App\BaseURL $baseUrl, App\Arguments $args, LoggerInterface $logger, Profiler $profiler, IManageConfigValues $config, IManageKeyValuePairs $keyValue, Database $dba, Response $response, array $server, array $parameters = [])
{
parent::__construct($l10n, $baseUrl, $args, $logger, $profiler, $response, $server, $parameters);
$this->config = $config;
$this->keyValue = $keyValue;
$this->dba = $dba;
}
protected function content(array $request = []): string
{
if (!$this->isAllowed($request)) {
throw new HTTPException\NotFoundException($this->l10n->t('Page not found.'));
}
return '';
}
protected function rawContent(array $request = [])
{
if (!$this->isAllowed($request)) {
return;
}
$statistics = [
'worker' => [
'lastExecution' => [
'datetime' => DateTimeFormat::utc($this->keyValue->get('last_worker_execution'), DateTimeFormat::JSON),
'timestamp' => strtotime($this->keyValue->get('last_worker_execution')),
],
'jpm' => [
1 => $this->dba->count('workerqueue', ["`done` AND `executed` > ?", DateTimeFormat::utc('now - 1 minute')]),
3 => round($this->dba->count('workerqueue', ["`done` AND `executed` > ?", DateTimeFormat::utc('now - 3 minute')]) / 3),
5 => round($this->dba->count('workerqueue', ["`done` AND `executed` > ?", DateTimeFormat::utc('now - 5 minute')]) / 5),
],
'active' => [],
'deferred' => [],
'total' => [],
],
'users' => [
'total' => intval($this->keyValue->get('nodeinfo_total_users')),
'activeHalfyear' => intval($this->keyValue->get('nodeinfo_active_users_halfyear')),
'activeMonth' => intval($this->keyValue->get('nodeinfo_active_users_monthly')),
'activeWeek' => intval($this->keyValue->get('nodeinfo_active_users_weekly')),
],
'usage' => [
'localPosts' => intval($this->keyValue->get('nodeinfo_local_posts')),
'localComments' => intval($this->keyValue->get('nodeinfo_local_comments')),
],
];
$statistics = $this->getJobsPerPriority($statistics);
$this->jsonExit($statistics);
}
private function isAllowed(array $request): bool
{
return empty(!$request['key']) && $request['key'] == $this->config->get('system', 'stats_key');
}
private function getJobsPerPriority(array $statistics): array
{
$statistics['worker']['active'] = $statistics['worker']['total'] = [
Worker::PRIORITY_UNDEFINED => 0,
Worker::PRIORITY_CRITICAL => 0,
Worker::PRIORITY_HIGH => 0,
Worker::PRIORITY_MEDIUM => 0,
Worker::PRIORITY_LOW => 0,
Worker::PRIORITY_NEGLIGIBLE => 0,
'total' => 0,
];
for ($i = 1; $i <= $this->config->get('system', 'worker_defer_limit'); $i++) {
$statistics['worker']['deferred'][$i] = 0;
}
$statistics['worker']['deferred']['total'] = 0;
$jobs = $this->dba->p("SELECT COUNT(*) AS `entries`, `priority` FROM `workerqueue` WHERE NOT `done` AND `retrial` = ? GROUP BY `priority`", 0);
while ($entry = $this->dba->fetch($jobs)) {
$running = $this->dba->count('workerqueue-view', ['priority' => $entry['priority']]);
$statistics['worker']['active']['total'] += $running;
$statistics['worker']['active'][$entry['priority']] = $running;
$statistics['worker']['total']['total'] += $entry['entries'];
$statistics['worker']['total'][$entry['priority']] = $entry['entries'];
}
$this->dba->close($jobs);
$statistics['worker']['active'][Worker::PRIORITY_UNDEFINED] = max(0, Worker::activeWorkers() - $statistics['worker']['active']['total']);
$jobs = $this->dba->p("SELECT COUNT(*) AS `entries`, `retrial` FROM `workerqueue` WHERE NOT `done` AND `retrial` > ? GROUP BY `retrial`", 0);
while ($entry = $this->dba->fetch($jobs)) {
$statistics['worker']['deferred']['total'] += $entry['entries'];
$statistics['worker']['deferred'][$entry['retrial']] = $entry['entries'];
}
$this->dba->close($jobs);
return $statistics;
}
}