You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
280 lines
8.9 KiB
280 lines
8.9 KiB
1 year ago
|
<?php declare(strict_types = 0);
|
||
|
|
/*
|
||
|
|
** Zabbix
|
||
|
|
** Copyright (C) 2001-2023 Zabbix SIA
|
||
|
|
**
|
||
|
|
** This program is free software; you can redistribute it and/or modify
|
||
|
|
** it under the terms of the GNU General Public License as published by
|
||
|
|
** the Free Software Foundation; either version 2 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 General Public License for more details.
|
||
|
|
**
|
||
|
|
** You should have received a copy of the GNU General Public License
|
||
|
|
** along with this program; if not, write to the Free Software
|
||
|
|
** Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
|
||
|
|
**/
|
||
|
|
|
||
|
|
|
||
|
|
class CControllerActionCreate extends CController {
|
||
|
|
|
||
|
|
protected function init(): void {
|
||
|
|
$this->setPostContentType(self::POST_CONTENT_TYPE_JSON);
|
||
|
|
}
|
||
|
|
|
||
|
|
protected function checkInput(): bool {
|
||
|
|
$fields = [
|
||
|
|
'eventsource' => 'required|db actions.eventsource|in '.implode(',', [
|
||
|
|
EVENT_SOURCE_TRIGGERS, EVENT_SOURCE_DISCOVERY,
|
||
|
|
EVENT_SOURCE_AUTOREGISTRATION, EVENT_SOURCE_INTERNAL, EVENT_SOURCE_SERVICE
|
||
|
|
]),
|
||
|
|
'name' => 'required|db actions.name|not_empty',
|
||
|
|
'status' => 'db actions.status|in '.ACTION_STATUS_ENABLED,
|
||
|
|
'operations' => 'array',
|
||
|
|
'recovery_operations' => 'array',
|
||
|
|
'update_operations' => 'array',
|
||
|
|
'esc_period' => 'db actions.esc_period|not_empty',
|
||
|
|
'conditions' => 'array',
|
||
|
|
'evaltype' => 'db actions.evaltype|in '.implode(',', [
|
||
|
|
CONDITION_EVAL_TYPE_AND_OR, CONDITION_EVAL_TYPE_AND, CONDITION_EVAL_TYPE_OR,
|
||
|
|
CONDITION_EVAL_TYPE_EXPRESSION
|
||
|
|
]),
|
||
|
|
'formula' => 'db actions.formula',
|
||
|
|
'notify_if_canceled' => 'db actions.notify_if_canceled|in '.ACTION_NOTIFY_IF_CANCELED_TRUE,
|
||
|
|
'pause_symptoms' => 'db actions.pause_symptoms|in '.ACTION_PAUSE_SYMPTOMS_TRUE,
|
||
|
|
'pause_suppressed' => 'db actions.pause_suppressed|in '.ACTION_PAUSE_SUPPRESSED_TRUE
|
||
|
|
];
|
||
|
|
|
||
|
|
$ret = $this->validateInput($fields);
|
||
|
|
|
||
|
|
if (!$ret) {
|
||
|
|
$this->setResponse(
|
||
|
|
new CControllerResponseData(['main_block' => json_encode([
|
||
|
|
'error' => [
|
||
|
|
'title' => _('Cannot add action'),
|
||
|
|
'messages' => array_column(get_and_clear_messages(), 'message')
|
||
|
|
]
|
||
|
|
])])
|
||
|
|
);
|
||
|
|
}
|
||
|
|
|
||
|
|
return $ret;
|
||
|
|
}
|
||
|
|
|
||
|
|
protected function checkPermissions(): bool {
|
||
|
|
switch ($this->getInput('eventsource')) {
|
||
|
|
case EVENT_SOURCE_TRIGGERS:
|
||
|
|
return $this->checkAccess(CRoleHelper::UI_CONFIGURATION_TRIGGER_ACTIONS);
|
||
|
|
|
||
|
|
case EVENT_SOURCE_DISCOVERY:
|
||
|
|
return $this->checkAccess(CRoleHelper::UI_CONFIGURATION_DISCOVERY_ACTIONS);
|
||
|
|
|
||
|
|
case EVENT_SOURCE_AUTOREGISTRATION:
|
||
|
|
return $this->checkAccess(CRoleHelper::UI_CONFIGURATION_AUTOREGISTRATION_ACTIONS);
|
||
|
|
|
||
|
|
case EVENT_SOURCE_INTERNAL:
|
||
|
|
return $this->checkAccess(CRoleHelper::UI_CONFIGURATION_INTERNAL_ACTIONS);
|
||
|
|
|
||
|
|
case EVENT_SOURCE_SERVICE:
|
||
|
|
return $this->checkAccess(CRoleHelper::UI_CONFIGURATION_SERVICE_ACTIONS);
|
||
|
|
}
|
||
|
|
|
||
|
|
return false;
|
||
|
|
}
|
||
|
|
|
||
|
|
protected function doAction(): void {
|
||
|
|
$eventsource = $this->getInput('eventsource');
|
||
|
|
|
||
|
|
$action = [
|
||
|
|
'name' => $this->getInput('name'),
|
||
|
|
'status' => $this->hasInput('status') ? ACTION_STATUS_ENABLED : ACTION_STATUS_DISABLED,
|
||
|
|
'eventsource' => $eventsource,
|
||
|
|
'operations' => $this->getInput('operations', []),
|
||
|
|
'recovery_operations' => $this->getInput('recovery_operations', []),
|
||
|
|
'update_operations' => $this->getInput('update_operations', [])
|
||
|
|
];
|
||
|
|
|
||
|
|
$filter = [
|
||
|
|
'conditions' => $this->getInput('conditions', []),
|
||
|
|
'evaltype' => $this->getInput('evaltype')
|
||
|
|
];
|
||
|
|
|
||
|
|
if ($filter['conditions']) {
|
||
|
|
if ($filter['evaltype'] == CONDITION_EVAL_TYPE_EXPRESSION) {
|
||
|
|
if (count($filter['conditions']) > 1) {
|
||
|
|
$filter['formula'] = $this->getInput('formula');
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
// If only one or no conditions are left, reset the evaltype to "and/or".
|
||
|
|
$filter['evaltype'] = CONDITION_EVAL_TYPE_AND_OR;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
foreach ($filter['conditions'] as &$condition) {
|
||
|
|
if ($filter['evaltype'] != CONDITION_EVAL_TYPE_EXPRESSION) {
|
||
|
|
unset($condition['formulaid']);
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($condition['conditiontype'] == CONDITION_TYPE_SUPPRESSED) {
|
||
|
|
unset($condition['value']);
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($condition['conditiontype'] != CONDITION_TYPE_EVENT_TAG_VALUE) {
|
||
|
|
unset($condition['value2']);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
unset($condition);
|
||
|
|
|
||
|
|
$action['filter'] = $filter;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (array_key_exists('formula', $filter)) {
|
||
|
|
$action['filter']['conditions'] = CConditionHelper::sortConditionsByFormula($action['filter']);
|
||
|
|
}
|
||
|
|
|
||
|
|
foreach (['operations', 'recovery_operations', 'update_operations'] as $operation_group) {
|
||
|
|
foreach ($action[$operation_group] as &$operation) {
|
||
|
|
switch ($operation_group) {
|
||
|
|
case 'operations':
|
||
|
|
if ($eventsource == EVENT_SOURCE_TRIGGERS) {
|
||
|
|
if (array_key_exists('opconditions', $operation)) {
|
||
|
|
foreach ($operation['opconditions'] as &$opcondition) {
|
||
|
|
unset($opcondition['opconditionid'], $opcondition['operationid']);
|
||
|
|
}
|
||
|
|
unset($opcondition);
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
$operation['opconditions'] = [];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
elseif ($eventsource == EVENT_SOURCE_DISCOVERY || $eventsource == EVENT_SOURCE_AUTOREGISTRATION) {
|
||
|
|
unset($operation['esc_period'], $operation['esc_step_from'], $operation['esc_step_to'],
|
||
|
|
$operation['evaltype']
|
||
|
|
);
|
||
|
|
}
|
||
|
|
elseif ($eventsource == EVENT_SOURCE_INTERNAL || $eventsource == EVENT_SOURCE_SERVICE) {
|
||
|
|
unset($operation['evaltype']);
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
|
||
|
|
case 'recovery_operations':
|
||
|
|
if (array_key_exists('evaltype', $operation)) {
|
||
|
|
unset($operation['evaltype']);
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($operation['operationtype'] != OPERATION_TYPE_MESSAGE) {
|
||
|
|
unset($operation['opmessage']['mediatypeid']);
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($operation['operationtype'] == OPERATION_TYPE_COMMAND) {
|
||
|
|
unset($operation['opmessage']);
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($operation['operationtype'] == OPERATION_TYPE_RECOVERY_MESSAGE) {
|
||
|
|
if (!array_key_exists('opmessage', $operation)) {
|
||
|
|
$operation['opmessage']['default_msg'] = 1;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
|
||
|
|
case 'update_operations':
|
||
|
|
if (array_key_exists('evaltype', $operation)) {
|
||
|
|
unset($operation['evaltype']);
|
||
|
|
}
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
if (array_key_exists('opmessage', $operation)) {
|
||
|
|
if (!array_key_exists('default_msg', $operation['opmessage'])) {
|
||
|
|
$operation['opmessage']['default_msg'] = 1;
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($operation['opmessage']['default_msg'] == 1) {
|
||
|
|
unset($operation['opmessage']['subject'], $operation['opmessage']['message']);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (array_key_exists('opmessage_grp', $operation) || array_key_exists('opmessage_usr', $operation)) {
|
||
|
|
if (!array_key_exists('opmessage_grp', $operation)) {
|
||
|
|
$operation['opmessage_grp'] = [];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!array_key_exists('opmessage_usr', $operation)) {
|
||
|
|
$operation['opmessage_usr'] = [];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (array_key_exists('opcommand_grp', $operation) || array_key_exists('opcommand_hst', $operation)) {
|
||
|
|
if (array_key_exists('opcommand_grp', $operation)) {
|
||
|
|
foreach ($operation['opcommand_grp'] as &$opcommand_grp) {
|
||
|
|
unset($opcommand_grp['opcommand_grpid']);
|
||
|
|
}
|
||
|
|
unset($opcommand_grp);
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
$operation['opcommand_grp'] = [];
|
||
|
|
}
|
||
|
|
|
||
|
|
if (array_key_exists('opcommand_hst', $operation)) {
|
||
|
|
foreach ($operation['opcommand_hst'] as &$opcommand_hst) {
|
||
|
|
unset($opcommand_hst['opcommand_hstid']);
|
||
|
|
}
|
||
|
|
unset($opcommand_hst);
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
$operation['opcommand_hst'] = [];
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
unset($operation['eventsource'], $operation['recovery']);
|
||
|
|
}
|
||
|
|
unset($operation);
|
||
|
|
}
|
||
|
|
|
||
|
|
if (in_array($eventsource, [EVENT_SOURCE_TRIGGERS, EVENT_SOURCE_INTERNAL, EVENT_SOURCE_SERVICE])) {
|
||
|
|
$action['esc_period'] = $this->getInput('esc_period', DB::getDefault('actions', 'esc_period'));
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($eventsource == EVENT_SOURCE_TRIGGERS) {
|
||
|
|
$action['pause_symptoms'] = $this->getInput('pause_symptoms', ACTION_PAUSE_SYMPTOMS_FALSE);
|
||
|
|
$action['pause_suppressed'] = $this->getInput('pause_suppressed', ACTION_PAUSE_SUPPRESSED_FALSE);
|
||
|
|
$action['notify_if_canceled'] = $this->getInput('notify_if_canceled', ACTION_NOTIFY_IF_CANCELED_FALSE);
|
||
|
|
unset($action['operations'][0]['mediatypeid']);
|
||
|
|
}
|
||
|
|
|
||
|
|
switch ($eventsource) {
|
||
|
|
case EVENT_SOURCE_DISCOVERY:
|
||
|
|
case EVENT_SOURCE_AUTOREGISTRATION:
|
||
|
|
unset($action['recovery_operations']);
|
||
|
|
// break; is not missing here
|
||
|
|
|
||
|
|
case EVENT_SOURCE_INTERNAL:
|
||
|
|
unset($action['update_operations']);
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
|
||
|
|
$result = API::Action()->create($action);
|
||
|
|
|
||
|
|
$output = [];
|
||
|
|
|
||
|
|
if ($result) {
|
||
|
|
$output['success']['title'] = _('Action added');
|
||
|
|
|
||
|
|
if ($messages = get_and_clear_messages()) {
|
||
|
|
$output['success']['messages'] = array_column($messages, 'message');
|
||
|
|
}
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
$output['error'] = [
|
||
|
|
'title' => _('Cannot add action'),
|
||
|
|
'messages' => array_column(get_and_clear_messages(), 'message')
|
||
|
|
];
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->setResponse(new CControllerResponseData(['main_block' => json_encode($output)]));
|
||
|
|
}
|
||
|
|
}
|