<?php declare(strict_types = 0);
class CControllerQueueDetails extends CController {
protected function init() {
$this->disableCsrfValidation();
}
protected function checkInput() {
return true;
}
protected function checkPermissions() {
return $this->checkAccess(CRoleHelper::UI_ADMINISTRATION_QUEUE);
}
protected function doAction() {
global $ZBX_SERVER, $ZBX_SERVER_PORT;
$zabbix_server = new CZabbixServer($ZBX_SERVER, $ZBX_SERVER_PORT,
timeUnitToSeconds(CSettingsHelper::get(CSettingsHelper::CONNECT_TIMEOUT)),
timeUnitToSeconds(CSettingsHelper::get(CSettingsHelper::SOCKET_TIMEOUT)), ZBX_SOCKET_BYTES_LIMIT
);
$queue_data = $zabbix_server->getQueue(CZabbixServer::QUEUE_DETAILS, CSessionHelper::getId(),
CSettingsHelper::get(CSettingsHelper::SEARCH_LIMIT)
);
if ($zabbix_server->getError()) {
$items = [];
$hosts = [];
$queue_data = [];
$proxies = [];
error($zabbix_server->getError());
show_error_message(_('Cannot display item queue.'));
}
else {
$queue_data = array_column($queue_data, null, 'itemid');
$items = CArrayHelper::renameObjectsKeys(API::Item()->get([
'output' => ['hostid', 'name_resolved'],
'selectHosts' => ['name'],
'itemids' => array_keys($queue_data),
'webitems' => true,
'preservekeys' => true
]), ['name_resolved' => 'name']);
if (count($queue_data) != count($items)) {
$items += API::DiscoveryRule()->get([
'output' => ['hostid', 'name'],
'selectHosts' => ['name'],
'itemids' => array_diff(array_keys($queue_data), array_keys($items)),
'preservekeys' => true
]);
}
$hosts = API::Host()->get([
'output' => ['proxyid'],
'hostids' => array_unique(array_column($items, 'hostid')),
'preservekeys' => true
]);
$proxyids = array_flip(array_column($hosts, 'proxyid'));
unset($proxyids[0]);
$proxies = $proxyids
? API::Proxy()->get([
'output' => ['proxyid', 'name'],
'proxyids' => array_keys($proxyids),
'preservekeys' => true
])
: [];
}
$total_count = $zabbix_server->getTotalCount();
$response = new CControllerResponseData([