adcoelho
diff --git a/‎src/platform/packages/shared/kbn-alerts-as-data-utils/src/schemas/generated/dataset_quality_schema.ts‎
Lines changed: 84 additions & 0 deletions b/‎src/platform/packages/shared/kbn-alerts-as-data-utils/src/schemas/generated/dataset_quality_schema.ts‎
Lines changed: 84 additions & 0 deletions
diff --git a/‎src/platform/packages/shared/kbn-router-utils/src/get_router_link_props/index.ts‎
Lines changed: 5 additions & 6 deletions b/‎src/platform/packages/shared/kbn-router-utils/src/get_router_link_props/index.ts‎
Lines changed: 5 additions & 6 deletions
diff --git a/‎src/platform/packages/shared/kbn-rule-data-utils/index.ts‎
Lines changed: 1 addition & 0 deletions b/‎src/platform/packages/shared/kbn-rule-data-utils/index.ts‎
Lines changed: 1 addition & 0 deletions
diff --git a/‎src/platform/packages/shared/kbn-rule-data-utils/src/rule_constants.ts‎
Lines changed: 10 additions & 0 deletions b/‎src/platform/packages/shared/kbn-rule-data-utils/src/rule_constants.ts‎
Lines changed: 10 additions & 0 deletions
diff --git a/‎src/platform/packages/shared/kbn-rule-data-utils/src/rule_types/stack_rules.ts‎
Lines changed: 3 additions & 0 deletions b/‎src/platform/packages/shared/kbn-rule-data-utils/src/rule_types/stack_rules.ts‎
Lines changed: 3 additions & 0 deletions
diff --git a/‎src/platform/packages/shared/response-ops/rule_params/degraded_docs/index.ts‎
Lines changed: 12 additions & 0 deletions b/‎src/platform/packages/shared/response-ops/rule_params/degraded_docs/index.ts‎
Lines changed: 12 additions & 0 deletions
diff --git a/‎src/platform/packages/shared/response-ops/rule_params/degraded_docs/latest.ts‎
Lines changed: 10 additions & 0 deletions b/‎src/platform/packages/shared/response-ops/rule_params/degraded_docs/latest.ts‎
Lines changed: 10 additions & 0 deletions
diff --git a/‎src/platform/packages/shared/response-ops/rule_params/degraded_docs/v1.ts‎
Lines changed: 30 additions & 0 deletions b/‎src/platform/packages/shared/response-ops/rule_params/degraded_docs/v1.ts‎
Lines changed: 30 additions & 0 deletions
diff --git a/‎x-pack/platform/plugins/shared/alerting/server/integration_tests/__snapshots__/alert_as_data_fields.test.ts.snap‎
Lines changed: 40 additions & 0 deletions b/‎x-pack/platform/plugins/shared/alerting/server/integration_tests/__snapshots__/alert_as_data_fields.test.ts.snap‎
Lines changed: 40 additions & 0 deletions
diff --git a/‎x-pack/platform/plugins/shared/alerting/server/integration_tests/alert_as_data_fields.test.ts‎
Lines changed: 1 addition & 0 deletions b/‎x-pack/platform/plugins/shared/alerting/server/integration_tests/alert_as_data_fields.test.ts‎
Lines changed: 1 addition & 0 deletions
@@ -0,0 +1,84 @@
+/*
+ * 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", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+// ---------------------------------- WARNING ----------------------------------
+// this file was generated, and should not be edited by hand
+// ---------------------------------- WARNING ----------------------------------
+import * as rt from 'io-ts';
+import type { Either } from 'fp-ts/lib/Either';
+import { AlertSchema } from './alert_schema';
+import { EcsSchema } from './ecs_schema';
+const ISO_DATE_PATTERN = /^d{4}-d{2}-d{2}Td{2}:d{2}:d{2}.d{3}Z$/;
+export const IsoDateString = new rt.Type<string, string, unknown>(
+  'IsoDateString',
+  rt.string.is,
+  (input, context): Either<rt.Errors, string> => {
+    if (typeof input === 'string' && ISO_DATE_PATTERN.test(input)) {
+      return rt.success(input);
+    } else {
+      return rt.failure(input, context);
+    }
+  },
+  rt.identity
+);
+export type IsoDateStringC = typeof IsoDateString;
+export const schemaUnknown = rt.unknown;
+export const schemaUnknownArray = rt.array(rt.unknown);
+export const schemaString = rt.string;
+export const schemaStringArray = rt.array(schemaString);
+export const schemaNumber = rt.number;
+export const schemaNumberArray = rt.array(schemaNumber);
+export const schemaDate = rt.union([IsoDateString, schemaNumber]);
+export const schemaDateArray = rt.array(schemaDate);
+export const schemaDateRange = rt.partial({
+  gte: schemaDate,
+  lte: schemaDate,
+});
+export const schemaDateRangeArray = rt.array(schemaDateRange);
+export const schemaStringOrNumber = rt.union([schemaString, schemaNumber]);
+export const schemaStringOrNumberArray = rt.array(schemaStringOrNumber);
+export const schemaBoolean = rt.boolean;
+export const schemaBooleanArray = rt.array(schemaBoolean);
+const schemaGeoPointCoords = rt.type({
+  type: schemaString,
+  coordinates: schemaNumberArray,
+});
+const schemaGeoPointString = schemaString;
+const schemaGeoPointLatLon = rt.type({
+  lat: schemaNumber,
+  lon: schemaNumber,
+});
+const schemaGeoPointLocation = rt.type({
+  location: schemaNumberArray,
+});
+const schemaGeoPointLocationString = rt.type({
+  location: schemaString,
+});
+export const schemaGeoPoint = rt.union([
+  schemaGeoPointCoords,
+  schemaGeoPointString,
+  schemaGeoPointLatLon,
+  schemaGeoPointLocation,
+  schemaGeoPointLocationString,
+]);
+export const schemaGeoPointArray = rt.array(schemaGeoPoint);
+// prettier-ignore
+const DatasetQualityAlertRequired = rt.type({
+});
+// prettier-ignore
+const DatasetQualityAlertOptional = rt.partial({
+  'kibana.alert.evaluation.threshold': schemaStringOrNumber,
+  'kibana.alert.evaluation.value': schemaString,
+  'kibana.alert.grouping': schemaUnknown,
+  'kibana.alert.reason': schemaString,
+});
+
+// prettier-ignore
+export const DatasetQualityAlertSchema = rt.intersection([DatasetQualityAlertRequired, DatasetQualityAlertOptional, AlertSchema, EcsSchema]);
+// prettier-ignore
+export type DatasetQualityAlert = rt.TypeOf<typeof DatasetQualityAlertSchema>;
@@ -9,19 +9,18 @@
 
 export interface RouterLinkProps {
   href: string | undefined;
-  onClick: (event: React.MouseEvent<HTMLAnchorElement | HTMLButtonElement, MouseEvent>) => void;
+  onClick: (event: React.MouseEvent<Element, MouseEvent>) => void;
 }
 
 interface GetRouterLinkPropsDeps {
   href?: string;
-  onClick(event: React.MouseEvent<HTMLAnchorElement | HTMLButtonElement>): void;
+  onClick(event: React.MouseEvent<Element, MouseEvent>): void;
 }
 
-const isModifiedEvent = (event: React.MouseEvent<HTMLAnchorElement | HTMLButtonElement>) =>
+const isModifiedEvent = (event: React.MouseEvent<Element, MouseEvent>) =>
   !!(event.metaKey || event.altKey || event.ctrlKey || event.shiftKey);
 
-const isLeftClickEvent = (event: React.MouseEvent<HTMLAnchorElement | HTMLButtonElement>) =>
-  event.button === 0;
+const isLeftClickEvent = (event: React.MouseEvent<Element, MouseEvent>) => event.button === 0;
 
 /**
  *
@@ -36,7 +35,7 @@ const isLeftClickEvent = (event: React.MouseEvent<HTMLAnchorElement | HTMLButton
  * manage behaviours such as leftClickEvent and event with modifiers (Ctrl, Shift, etc)
  */
 export const getRouterLinkProps = ({ href, onClick }: GetRouterLinkPropsDeps): RouterLinkProps => {
-  const guardedClickHandler = (event: React.MouseEvent<HTMLAnchorElement | HTMLButtonElement>) => {
+  const guardedClickHandler = (event: React.MouseEvent<Element, MouseEvent>) => {
     if (event.defaultPrevented) {
       return;
     }
 
@@ -16,3 +16,4 @@ export * from './src/alerts_as_data_status';
 export * from './src/alerts_as_data_cases';
 export * from './src/routes/stack_rule_paths';
 export * from './src/rule_types';
+export * from './src/rule_constants';
@@ -0,0 +1,10 @@
+/*
+ * 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", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+export const ALERT_KEY_JOINER = ',';
@@ -11,6 +11,8 @@ export const STACK_ALERTS_FEATURE_ID = 'stackAlerts';
 export const ES_QUERY_ID = '.es-query';
 export const ML_ANOMALY_DETECTION_RULE_TYPE_ID = 'xpack.ml.anomaly_detection_alert';
 
+export const DEGRADED_DOCS_RULE_TYPE_ID = 'datasetQuality.degradedDocs';
+
 /**
  * These rule types are not the only stack rules. There are more.
  * The variable holds all stack rule types that support multiple
@@ -19,4 +21,5 @@ export const ML_ANOMALY_DETECTION_RULE_TYPE_ID = 'xpack.ml.anomaly_detection_ale
 export const STACK_RULE_TYPE_IDS_SUPPORTED_BY_OBSERVABILITY = [
   ES_QUERY_ID,
   ML_ANOMALY_DETECTION_RULE_TYPE_ID,
+  DEGRADED_DOCS_RULE_TYPE_ID,
 ];
@@ -0,0 +1,12 @@
+/*
+ * 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", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+export { degradedDocsParamsSchema } from './latest';
+
+export type { DegradedDocsRuleParams } from './latest';
@@ -0,0 +1,10 @@
+/*
+ * 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", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+export * from './v1';
@@ -0,0 +1,30 @@
+/*
+ * 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", the "GNU Affero General Public License v3.0 only", and the "Server Side
+ * Public License v 1"; you may not use this file except in compliance with, at
+ * your election, the "Elastic License 2.0", the "GNU Affero General Public
+ * License v3.0 only", or the "Server Side Public License, v 1".
+ */
+
+import { COMPARATORS } from '@kbn/alerting-comparators';
+import type { TypeOf } from '@kbn/config-schema';
+import { schema } from '@kbn/config-schema';
+import { oneOfLiterals } from '../common/utils';
+
+const comparators = Object.values(COMPARATORS);
+
+const searchConfigSchema = schema.object({
+  index: schema.string(),
+});
+
+export const degradedDocsParamsSchema = schema.object({
+  timeUnit: schema.string(),
+  timeSize: schema.number(),
+  threshold: schema.arrayOf(schema.number()),
+  comparator: oneOfLiterals(comparators),
+  groupBy: schema.maybe(schema.arrayOf(schema.string())),
+  searchConfiguration: searchConfigSchema,
+});
+
+export type DegradedDocsRuleParams = TypeOf<typeof degradedDocsParamsSchema>;
@@ -64,6 +64,7 @@ const ruleTypes: string[] = [
   'siem.thresholdRule',
   'siem.newTermsRule',
   'siem.notifications',
+  'datasetQuality.degradedDocs',
 ];
 
 describe('Alert as data fields checks', () => {