[Response Ops][Alerting] Only load maintenance windows when there are alerts during rule execution and caching loaded maintenance windows

x-pack/plugins/alerting/server/alert/create_alert_factory.ts

@@ -156,8 +156,6 @@ export function createAlertFactory<
             autoRecoverAlerts,
             // flappingSettings.enabled is false, as we only want to use this function to get the recovered alerts
             flappingSettings: DISABLE_FLAPPING_SETTINGS,
-            // no maintenance window IDs are passed as we only want to use this function to get recovered alerts
-            maintenanceWindowIds: [],
           });
           return Object.keys(currentRecoveredAlerts ?? {}).map(
             (alertId: string) => currentRecoveredAlerts[alertId]

x-pack/plugins/alerting/server/alerts_client/alerts_client.ts

@@ -38,7 +38,6 @@ import type { AlertRule, LogAlertsOpts, ProcessAlertsOpts, SearchResult } from '
 import {
   IAlertsClient,
   InitializeExecutionOpts,
-  ProcessAndLogAlertsOpts,
   TrackedAlerts,
   ReportedAlert,
   ReportedAlertData,
@@ -62,11 +61,10 @@ import {
 } from './lib';
 import { isValidAlertIndexName } from '../alerts_service';
 import { resolveAlertConflicts } from './lib/alert_conflict_resolver';
-import { MaintenanceWindow } from '../application/maintenance_window/types';
 import {
   filterMaintenanceWindows,
   filterMaintenanceWindowsIds,
-} from '../task_runner/get_maintenance_windows';
+} from '../task_runner/maintenance_windows';
 
 // Term queries can take up to 10,000 terms
 const CHUNK_SIZE = 10000;
@@ -77,6 +75,10 @@ export interface AlertsClientParams extends CreateAlertsClientParams {
   dataStreamAdapter: DataStreamAdapter;
 }
 
+interface AlertsAffectedByMaintenanceWindows {
+  alertIds: string[];
+  maintenanceWindowIds: string[];
+}
 export class AlertsClient<
   AlertData extends RuleAlertData,
   LegacyState extends AlertInstanceState,
@@ -121,7 +123,14 @@ export class AlertsClient<
       LegacyContext,
       ActionGroupIds,
       RecoveryActionGroupId
-    >({ logger: this.options.logger, ruleType: this.options.ruleType });
+    >({
+      alertingEventLogger: this.options.alertingEventLogger,
+      logger: this.options.logger,
+      maintenanceWindowsService: this.options.maintenanceWindowsService,
+      request: this.options.request,
+      ruleType: this.options.ruleType,
+      spaceId: this.options.spaceId,
+    });
     this.indexTemplateAndPattern = getIndexTemplateAndPattern({
       context: this.options.ruleType.alerts?.context!,
       namespace: this.options.ruleType.alerts?.isSpaceAware
@@ -301,45 +310,25 @@ export class AlertsClient<
     return this.legacyAlertsClient.checkLimitUsage();
   }
 
-  public processAlerts(opts: ProcessAlertsOpts) {
-    this.legacyAlertsClient.processAlerts(opts);
+  public async processAlerts(opts: ProcessAlertsOpts) {
+    await this.legacyAlertsClient.processAlerts(opts);
   }
 
   public logAlerts(opts: LogAlertsOpts) {
     this.legacyAlertsClient.logAlerts(opts);
   }
 
-  public processAndLogAlerts(opts: ProcessAndLogAlertsOpts) {
-    this.legacyAlertsClient.processAndLogAlerts(opts);
-  }
-
   public getProcessedAlerts(
     type: 'new' | 'active' | 'activeCurrent' | 'recovered' | 'recoveredCurrent'
   ) {
     return this.legacyAlertsClient.getProcessedAlerts(type);
   }
 
-  public async persistAlerts(maintenanceWindows?: MaintenanceWindow[]): Promise<{
-    alertIds: string[];
-    maintenanceWindowIds: string[];
-  } | null> {
+  public async persistAlerts(): Promise<AlertsAffectedByMaintenanceWindows> {
     // Persist alerts first
     await this.persistAlertsHelper();
 
-    // Try to update the persisted alerts with maintenance windows with a scoped query
-    let updateAlertsMaintenanceWindowResult = null;
-    try {
-      updateAlertsMaintenanceWindowResult = await this.updateAlertsMaintenanceWindowIdByScopedQuery(
-        maintenanceWindows ?? []
-      );
-    } catch (e) {
-      this.options.logger.debug(
-        `Failed to update alert matched by maintenance window scoped query ${this.ruleInfoMessage}`,
-        this.logTags
-      );
-    }
-
-    return updateAlertsMaintenanceWindowResult;
+    return await this.updatePersistedAlertsWithMaintenanceWindowIds();
   }
 
   public getAlertsToSerialize() {
@@ -692,18 +681,39 @@ export class AlertsClient<
     }
   }
 
-  private async updateAlertsMaintenanceWindowIdByScopedQuery(
-    maintenanceWindows: MaintenanceWindow[]
-  ) {
+  private async updatePersistedAlertsWithMaintenanceWindowIds(): Promise<AlertsAffectedByMaintenanceWindows> {
+    // check if there are any alerts
+    const newAlerts = Object.values(this.legacyAlertsClient.getProcessedAlerts('new'));
+    const activeAlerts = Object.values(this.legacyAlertsClient.getProcessedAlerts('active'));
+    const recoveredAlerts = Object.values(this.legacyAlertsClient.getProcessedAlerts('recovered'));
+
+    // return if there are no alerts written
+    if (
+      (!newAlerts.length && !activeAlerts.length && !recoveredAlerts.length) ||
+      !this.options.maintenanceWindowsService
+    ) {
+      return {
+        alertIds: [],
+        maintenanceWindowIds: [],
+      };
+    }
+
+    const { maintenanceWindows } =
+      await this.options.maintenanceWindowsService.loadMaintenanceWindows({
+        eventLogger: this.options.alertingEventLogger,
+        request: this.options.request,
+        ruleTypeCategory: this.ruleType.category,
+        spaceId: this.options.spaceId,
+      });
+
     const maintenanceWindowsWithScopedQuery = filterMaintenanceWindows({
-      maintenanceWindows,
+      maintenanceWindows: maintenanceWindows ?? [],
       withScopedQuery: true,
     });
     const maintenanceWindowsWithoutScopedQueryIds = filterMaintenanceWindowsIds({
-      maintenanceWindows,
+      maintenanceWindows: maintenanceWindows ?? [],
       withScopedQuery: false,
     });
-
     if (maintenanceWindowsWithScopedQuery.length === 0) {
       return {
         alertIds: [],
@@ -723,8 +733,6 @@ export class AlertsClient<
     const alertsAffectedByScopedQuery: string[] = [];
     const appliedMaintenanceWindowIds: string[] = [];
 
-    const newAlerts = Object.values(this.getProcessedAlerts('new'));
-
     for (const [scopedQueryMaintenanceWindowId, alertIds] of Object.entries(aggsResult)) {
       // Go through matched alerts, find the in memory object
       alertIds.forEach((alertId) => {