github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-23 17:28:26 -04:00
Code Issues Projects Releases Packages Wiki Activity

Reverting changes not related to event log aggregation

Browse source
This commit is contained in:
Ying Mao 2022-03-07 11:19:27 -05:00
parent 939340e252
commit 40a93a4b3c
1 changed files with 0 additions and 82 deletions
Download patch file Download diff file Expand all files Collapse all files

82
x-pack/plugins/alerting/server/routes/get_rule_execution_log.ts
View file

@ -1,82 +0,0 @@
/*
* Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
* or more contributor license agreements. Licensed under the Elastic License
* 2.0; you may not use this file except in compliance with the Elastic License
* 2.0.
*/
import { IRouter } from 'kibana/server';
import { schema } from '@kbn/config-schema';
import { ILicenseState } from '../lib';
import { GetAlertSummaryParams } from '../rules_client';
import { RewriteRequestCase, RewriteResponseCase, verifyAccessAndContext } from './lib';
import {
AlertingRequestHandlerContext,
INTERNAL_BASE_ALERTING_API_PATH,
AlertSummary,
} from '../types';
const paramSchema = schema.object({
id: schema.string(),
});
const querySchema = schema.object({
date_start: schema.maybe(schema.string()),
date_end: schema.maybe(schema.string()),
});
const rewriteReq: RewriteRequestCase<GetAlertSummaryParams> = ({
date_start: dateStart,
number_of_executions: numberOfExecutions,
...rest
}) => ({
...rest,
numberOfExecutions,
dateStart,
});
const rewriteBodyRes: RewriteResponseCase<AlertSummary> = ({
ruleTypeId,
muteAll,
statusStartDate,
statusEndDate,
errorMessages,
lastRun,
executionDuration: { valuesWithTimestamp, ...executionDuration },
...rest
}) => ({
...rest,
rule_type_id: ruleTypeId,
mute_all: muteAll,
status_start_date: statusStartDate,
status_end_date: statusEndDate,
error_messages: errorMessages,
last_run: lastRun,
execution_duration: {
...executionDuration,
values_with_timestamp: valuesWithTimestamp,
},
});
export const getRuleExecutionLogRoute = (
router: IRouter<AlertingRequestHandlerContext>,
licenseState: ILicenseState
) => {
router.get(
{
path: `${INTERNAL_BASE_ALERTING_API_PATH}/rule/{id}/_execution_log`,
validate: {
params: paramSchema,
query: querySchema,
},
},
router.handleLegacyErrors(
verifyAccessAndContext(licenseState, async function (context, req, res) {
const rulesClient = context.alerting.getRulesClient();
const { id } = req.params;
const execLog = await rulesClient.getExecutionLogForRule(rewriteReq({ id, ...req.query }));
return res.ok({ body: rewriteBodyRes(execLog) });
})
)
);
};