[RAM] Update Rule Status - UI Changes

x-pack/plugins/triggers_actions_ui/.storybook/context/http.ts

@@ -40,7 +40,7 @@ const getMockRule = () => {
       error: null,
     },
     monitoring: {
-      execution: {
+      run: {
         history: [
           {
             success: true,

x-pack/plugins/triggers_actions_ui/.storybook/decorator.tsx

@@ -88,6 +88,7 @@ export const StorybookContextDecorator: React.FC<StorybookContextDecoratorProps>
       ruleTagFilter: true,
       ruleStatusFilter: true,
       rulesDetailLogs: true,
+      ruleLastRunOutcome: true,
     },
   });
   return (

x-pack/plugins/triggers_actions_ui/common/experimental_features.ts

@@ -17,6 +17,7 @@ export const allowedExperimentalValues = Object.freeze({
   ruleTagFilter: true,
   ruleStatusFilter: true,
   rulesDetailLogs: true,
+  ruleLastRunOutcome: true,
 });
 
 type ExperimentalConfigKeys = Array<keyof ExperimentalFeatures>;

x-pack/plugins/triggers_actions_ui/public/application/hooks/use_bulk_edit_select.tsx

@@ -77,6 +77,7 @@ interface UseBulkEditSelectProps {
   actionTypesFilter?: string[];
   tagsFilter?: string[];
   ruleExecutionStatusesFilter?: string[];
+  ruleLastRunOutcomesFilter?: string[];
   ruleStatusesFilter?: RuleStatus[];
   searchText?: string;
 }
@@ -89,6 +90,7 @@ export function useBulkEditSelect(props: UseBulkEditSelectProps) {
     actionTypesFilter,
     tagsFilter,
     ruleExecutionStatusesFilter,
+    ruleLastRunOutcomesFilter,
     ruleStatusesFilter,
     searchText,
   } = props;
@@ -187,6 +189,7 @@ export function useBulkEditSelect(props: UseBulkEditSelectProps) {
         actionTypesFilter,
         tagsFilter,
         ruleExecutionStatusesFilter,
+        ruleLastRunOutcomesFilter,
         ruleStatusesFilter,
         searchText,
       });
@@ -208,6 +211,7 @@ export function useBulkEditSelect(props: UseBulkEditSelectProps) {
       actionTypesFilter,
       tagsFilter,
       ruleExecutionStatusesFilter,
+      ruleLastRunOutcomesFilter,
       ruleStatusesFilter,
       searchText,
     ]

x-pack/plugins/triggers_actions_ui/public/application/hooks/use_load_rule_aggregations.ts

@@ -7,11 +7,21 @@
 
 import { i18n } from '@kbn/i18n';
 import { useState, useCallback, useMemo } from 'react';
-import { RuleExecutionStatusValues } from '@kbn/alerting-plugin/common';
+import { RuleExecutionStatusValues, RuleLastRunOutcomeValues } from '@kbn/alerting-plugin/common';
 import type { LoadRuleAggregationsProps } from '../lib/rule_api';
 import { loadRuleAggregationsWithKueryFilter } from '../lib/rule_api/aggregate_kuery_filter';
 import { useKibana } from '../../common/lib/kibana';
 
+const initializeAggregationResult = (values: readonly string[]) => {
+  return values.reduce<Record<string, number>>(
+    (prev: Record<string, number>, status: string) => ({
+      ...prev,
+      [status]: 0,
+    }),
+    {}
+  );
+};
+
 type UseLoadRuleAggregationsProps = Omit<LoadRuleAggregationsProps, 'http'> & {
   onError: (message: string) => void;
 };
@@ -21,22 +31,21 @@ export function useLoadRuleAggregations({
   typesFilter,
   actionTypesFilter,
   ruleExecutionStatusesFilter,
+  ruleLastRunOutcomesFilter,
   ruleStatusesFilter,
   tagsFilter,
   onError,
 }: UseLoadRuleAggregationsProps) {
   const { http } = useKibana().services;
 
   const [rulesStatusesTotal, setRulesStatusesTotal] = useState<Record<string, number>>(
-    RuleExecutionStatusValues.reduce<Record<string, number>>(
-      (prev: Record<string, number>, status: string) => ({
-        ...prev,
-        [status]: 0,
-      }),
-      {}
-    )
+    initializeAggregationResult(RuleExecutionStatusValues)
   );
 
+  const [rulesLastRunOutcomesTotal, setRulesLastRunOutcomesTotal] = useState<
+    Record<string, number>
+  >(initializeAggregationResult(RuleLastRunOutcomeValues));
+
   const internalLoadRuleAggregations = useCallback(async () => {
     try {
       const rulesAggs = await loadRuleAggregationsWithKueryFilter({
@@ -45,12 +54,16 @@ export function useLoadRuleAggregations({
         typesFilter,
         actionTypesFilter,
         ruleExecutionStatusesFilter,
+        ruleLastRunOutcomesFilter,
         ruleStatusesFilter,
         tagsFilter,
       });
       if (rulesAggs?.ruleExecutionStatus) {
         setRulesStatusesTotal(rulesAggs.ruleExecutionStatus);
       }
+      if (rulesAggs?.ruleLastRunOutcome) {
+        setRulesLastRunOutcomesTotal(rulesAggs.ruleLastRunOutcome);
+      }
     } catch (e) {
       onError(
         i18n.translate(
@@ -67,18 +80,28 @@ export function useLoadRuleAggregations({
     typesFilter,
     actionTypesFilter,
     ruleExecutionStatusesFilter,
+    ruleLastRunOutcomesFilter,
     ruleStatusesFilter,
     tagsFilter,
     onError,
     setRulesStatusesTotal,
+    setRulesLastRunOutcomesTotal,
   ]);
 
   return useMemo(
     () => ({
       loadRuleAggregations: internalLoadRuleAggregations,
       rulesStatusesTotal,
+      rulesLastRunOutcomesTotal,
       setRulesStatusesTotal,
+      setRulesLastRunOutcomesTotal,
     }),
-    [internalLoadRuleAggregations, rulesStatusesTotal, setRulesStatusesTotal]
+    [
+      internalLoadRuleAggregations,
+      rulesStatusesTotal,
+      rulesLastRunOutcomesTotal,
+      setRulesStatusesTotal,
+      setRulesLastRunOutcomesTotal,
+    ]
   );
 }

x-pack/plugins/triggers_actions_ui/public/application/hooks/use_load_rules.ts

@@ -89,6 +89,7 @@ export function useLoadRules({
   typesFilter,
   actionTypesFilter,
   ruleExecutionStatusesFilter,
+  ruleLastRunOutcomesFilter,
   ruleStatusesFilter,
   tagsFilter,
   sort,
@@ -120,6 +121,7 @@ export function useLoadRules({
         typesFilter,
         actionTypesFilter,
         ruleExecutionStatusesFilter,
+        ruleLastRunOutcomesFilter,
         ruleStatusesFilter,
         tagsFilter,
         sort,
@@ -144,6 +146,7 @@ export function useLoadRules({
         hasEmptyTypesFilter &&
         isEmpty(actionTypesFilter) &&
         isEmpty(ruleExecutionStatusesFilter) &&
+        isEmpty(ruleLastRunOutcomesFilter) &&
         isEmpty(ruleStatusesFilter) &&
         isEmpty(tagsFilter)
       );
@@ -168,6 +171,7 @@ export function useLoadRules({
     typesFilter,
     actionTypesFilter,
     ruleExecutionStatusesFilter,
+    ruleLastRunOutcomesFilter,
     ruleStatusesFilter,
     tagsFilter,
     sort,

x-pack/plugins/triggers_actions_ui/public/application/lib/rule_api/aggregate_helpers.ts

@@ -15,6 +15,7 @@ export interface RuleTagsAggregations {
 
 export const rewriteBodyRes: RewriteRequestCase<RuleAggregations> = ({
   rule_execution_status: ruleExecutionStatus,
+  rule_last_run_outcome: ruleLastRunOutcome,
   rule_enabled_status: ruleEnabledStatus,
   rule_muted_status: ruleMutedStatus,
   rule_snoozed_status: ruleSnoozedStatus,
@@ -26,6 +27,7 @@ export const rewriteBodyRes: RewriteRequestCase<RuleAggregations> = ({
   ruleEnabledStatus,
   ruleMutedStatus,
   ruleSnoozedStatus,
+  ruleLastRunOutcome,
   ruleTags,
 });
 
@@ -41,6 +43,7 @@ export interface LoadRuleAggregationsProps {
   typesFilter?: string[];
   actionTypesFilter?: string[];
   ruleExecutionStatusesFilter?: string[];
+  ruleLastRunOutcomesFilter?: string[];
   ruleStatusesFilter?: RuleStatus[];
   tagsFilter?: string[];
 }

x-pack/plugins/triggers_actions_ui/public/application/lib/rule_api/common_transformations.ts

@@ -6,7 +6,7 @@
  */
 import { RuleExecutionStatus } from '@kbn/alerting-plugin/common';
 import { AsApiContract, RewriteRequestCase } from '@kbn/actions-plugin/common';
-import { Rule, RuleAction, ResolvedRule } from '../../../types';
+import { Rule, RuleAction, ResolvedRule, RuleLastRun } from '../../../types';
 
 const transformAction: RewriteRequestCase<RuleAction> = ({
   group,
@@ -30,6 +30,16 @@ const transformExecutionStatus: RewriteRequestCase<RuleExecutionStatus> = ({
   ...rest,
 });
 
+const transformLastRun: RewriteRequestCase<RuleLastRun> = ({
+  outcome_msg: outcomeMsg,
+  alerts_count: alertsCount,
+  ...rest
+}) => ({
+  outcomeMsg,
+  alertsCount,
+  ...rest,
+});
+
 export const transformRule: RewriteRequestCase<Rule> = ({
   rule_type_id: ruleTypeId,
   created_by: createdBy,
@@ -46,6 +56,8 @@ export const transformRule: RewriteRequestCase<Rule> = ({
   snooze_schedule: snoozeSchedule,
   is_snoozed_until: isSnoozedUntil,
   active_snoozes: activeSnoozes,
+  last_run: lastRun,
+  next_run: nextRun,
   ...rest
 }: any) => ({
   ruleTypeId,
@@ -65,6 +77,8 @@ export const transformRule: RewriteRequestCase<Rule> = ({
   scheduledTaskId,
   isSnoozedUntil,
   activeSnoozes,
+  ...(lastRun ? { lastRun: transformLastRun(lastRun) } : {}),
+  ...(nextRun ? { nextRun } : {}),
   ...rest,
 });
 

x-pack/plugins/triggers_actions_ui/public/application/lib/rule_api/create.ts

@@ -12,7 +12,13 @@ import { transformRule } from './common_transformations';
 
 type RuleCreateBody = Omit<
   RuleUpdates,
-  'createdBy' | 'updatedBy' | 'muteAll' | 'mutedInstanceIds' | 'executionStatus'
+  | 'createdBy'
+  | 'updatedBy'
+  | 'muteAll'
+  | 'mutedInstanceIds'
+  | 'executionStatus'
+  | 'lastRun'
+  | 'nextRun'
 >;
 const rewriteBodyRequest: RewriteResponseCase<RuleCreateBody> = ({
   ruleTypeId,

x-pack/plugins/triggers_actions_ui/public/application/lib/rule_api/map_filters_to_kuery_node.test.ts

@@ -57,6 +57,30 @@ describe('mapFiltersToKueryNode', () => {
     );
   });
 
+  test('should handle ruleLastRunOutcomesFilter', () => {
+    expect(
+      toElasticsearchQuery(
+        mapFiltersToKueryNode({
+          ruleLastRunOutcomesFilter: ['succeeded'],
+        }) as KueryNode
+      )
+    ).toEqual(
+      toElasticsearchQuery(fromKueryExpression('alert.attributes.lastRun.outcome: succeeded'))
+    );
+
+    expect(
+      toElasticsearchQuery(
+        mapFiltersToKueryNode({
+          ruleLastRunOutcomesFilter: ['succeeded', 'failed', 'warning'],
+        }) as KueryNode
+      )
+    ).toEqual(
+      toElasticsearchQuery(
+        fromKueryExpression('alert.attributes.lastRun.outcome: (succeeded or failed or warning)')
+      )
+    );
+  });
+
   test('should handle ruleStatusesFilter', () => {
     expect(
       toElasticsearchQuery(
@@ -260,6 +284,7 @@ describe('mapFiltersToKueryNode', () => {
           typesFilter: ['type', 'filter'],
           actionTypesFilter: ['action', 'types', 'filter'],
           ruleExecutionStatusesFilter: ['alert', 'statuses', 'filter'],
+          ruleLastRunOutcomesFilter: ['warning', 'failed'],
           tagsFilter: ['a', 'b', 'c'],
         }) as KueryNode
       )
@@ -271,6 +296,7 @@ describe('mapFiltersToKueryNode', () => {
         alert.attributes.actions:{ actionTypeId:types } OR
         alert.attributes.actions:{ actionTypeId:filter }) and
       alert.attributes.executionStatus.status:(alert or statuses or filter) and
+      alert.attributes.lastRun.outcome:(warning or failed) and
       alert.attributes.tags:(a or b or c)`
         )
       )

x-pack/plugins/triggers_actions_ui/public/application/lib/rule_api/map_filters_to_kuery_node.ts

@@ -12,6 +12,7 @@ export const mapFiltersToKueryNode = ({
   typesFilter,
   actionTypesFilter,
   ruleExecutionStatusesFilter,
+  ruleLastRunOutcomesFilter,
   ruleStatusesFilter,
   tagsFilter,
   searchText,
@@ -20,6 +21,7 @@ export const mapFiltersToKueryNode = ({
   actionTypesFilter?: string[];
   tagsFilter?: string[];
   ruleExecutionStatusesFilter?: string[];
+  ruleLastRunOutcomesFilter?: string[];
   ruleStatusesFilter?: RuleStatus[];
   searchText?: string;
 }): KueryNode | null => {
@@ -51,6 +53,16 @@ export const mapFiltersToKueryNode = ({
     );
   }
 
+  if (ruleLastRunOutcomesFilter && ruleLastRunOutcomesFilter.length) {
+    filterKueryNode.push(
+      nodeBuilder.or(
+        ruleLastRunOutcomesFilter.map((resf) =>
+          nodeBuilder.is('alert.attributes.lastRun.outcome', resf)
+        )
+      )
+    );
+  }
+
   if (ruleStatusesFilter && ruleStatusesFilter.length) {
     const snoozedFilter = nodeBuilder.or([
       fromKueryExpression('alert.attributes.muteAll: true'),

x-pack/plugins/triggers_actions_ui/public/application/lib/rule_api/rules_helpers.ts

@@ -18,6 +18,7 @@ export interface LoadRulesProps {
   actionTypesFilter?: string[];
   tagsFilter?: string[];
   ruleExecutionStatusesFilter?: string[];
+  ruleLastRunOutcomesFilter?: string[];
   ruleStatusesFilter?: RuleStatus[];
   sort?: Sorting;
 }

x-pack/plugins/triggers_actions_ui/public/application/lib/rule_api/rules_kuery_filter.ts

@@ -18,6 +18,7 @@ export async function loadRulesWithKueryFilter({
   typesFilter,
   actionTypesFilter,
   ruleExecutionStatusesFilter,
+  ruleLastRunOutcomesFilter,
   ruleStatusesFilter,
   tagsFilter,
   sort = { field: 'name', direction: 'asc' },
@@ -32,6 +33,7 @@ export async function loadRulesWithKueryFilter({
     actionTypesFilter,
     tagsFilter,
     ruleExecutionStatusesFilter,
+    ruleLastRunOutcomesFilter,
     ruleStatusesFilter,
     searchText,
   });