[Synthetics] Detect and display missing/corrupted Synthetics integrations in monitor UIs

x-pack/platform/plugins/private/translations/translations/de-DE.json

@@ -41776,7 +41776,6 @@
     "xpack.synthetics.monitorManagement.createLocationMonitors": "Überwachen erstellen",
     "xpack.synthetics.monitorManagement.createMonitorLabel": "Überwachen erstellen",
     "xpack.synthetics.monitorManagement.createPrivateLocations": "Privaten Standort erstellen",
-    "xpack.synthetics.monitorManagement.deleteLocation": "Standort löschen",
     "xpack.synthetics.monitorManagement.deleteLocationLabel": "Standort löschen",
     "xpack.synthetics.monitorManagement.deleteLocationName": "Möchten Sie „{location}“ löschen?",
     "xpack.synthetics.monitorManagement.deleteMonitorNameLabel": "Möchten Sie {monitorCount, number} ausgewählte {monitorCount, plural, one {monitor} other {Monitors}} löschen?",

x-pack/platform/plugins/private/translations/translations/fr-FR.json

@@ -42206,8 +42206,7 @@
     "xpack.synthetics.monitorManagement.createLocationMonitors": "Créer le moniteur",
     "xpack.synthetics.monitorManagement.createMonitorLabel": "Créer le moniteur",
     "xpack.synthetics.monitorManagement.createPrivateLocations": "Créer un emplacement privé",
-    "xpack.synthetics.monitorManagement.deleteLocation": "Supprimer l’emplacement",
-    "xpack.synthetics.monitorManagement.deleteLocationLabel": "Supprimer l'emplacement",
+    "xpack.synthetics.monitorManagement.deleteLocationLabel": "Supprimer l’emplacement",
     "xpack.synthetics.monitorManagement.deleteLocationName": "Supprimer \"{location}\"",
     "xpack.synthetics.monitorManagement.deleteMonitorNameLabel": "Supprimer {monitorCount, number} {monitorCount, plural, one {moniteur sélectionné} other {moniteurs sélectionnés}} ?",
     "xpack.synthetics.monitorManagement.disabled.label": "Désactivé",

x-pack/platform/plugins/private/translations/translations/ja-JP.json

@@ -42268,7 +42268,6 @@
     "xpack.synthetics.monitorManagement.createLocationMonitors": "監視の作成",
     "xpack.synthetics.monitorManagement.createMonitorLabel": "監視の作成",
     "xpack.synthetics.monitorManagement.createPrivateLocations": "非公開の場所を作成",
-    "xpack.synthetics.monitorManagement.deleteLocation": "場所を削除",
     "xpack.synthetics.monitorManagement.deleteLocationLabel": "場所を削除",
     "xpack.synthetics.monitorManagement.deleteLocationName": "「{location}」を削除",
     "xpack.synthetics.monitorManagement.deleteMonitorNameLabel": "{monitorCount, number}個の選択した{monitorCount, plural, one {monitor} other {モニター}}を削除しますか？",

x-pack/platform/plugins/private/translations/translations/zh-CN.json

@@ -42246,7 +42246,6 @@
     "xpack.synthetics.monitorManagement.createLocationMonitors": "创建监测",
     "xpack.synthetics.monitorManagement.createMonitorLabel": "创建监测",
     "xpack.synthetics.monitorManagement.createPrivateLocations": "创建专用位置",
-    "xpack.synthetics.monitorManagement.deleteLocation": "删除位置",
     "xpack.synthetics.monitorManagement.deleteLocationLabel": "删除位置",
     "xpack.synthetics.monitorManagement.deleteLocationName": "删除“{location}”",
     "xpack.synthetics.monitorManagement.deleteMonitorNameLabel": "删除 {monitorCount, number} 个选定的{monitorCount, plural, one {监测} other {监测}}？",

x-pack/solutions/observability/plugins/synthetics/common/constants/synthetics/rest_api.ts

@@ -30,6 +30,8 @@ export enum SYNTHETICS_API_URLS {
   SERVICE_ALLOWED = '/internal/synthetics/service/allowed',
   SYNTHETICS_PROJECT_APIKEY = '/internal/synthetics/service/api_key',
   SYNTHETICS_HAS_INTEGRATION_MONITORS = '/internal/synthetics/fleet/has_integration_monitors',
+  SYNTHETICS_MONITORS_HEALTH = '/internal/synthetics/monitors/_health',
+  SYNTHETICS_MONITOR_HEALTH = '/internal/synthetics/monitors/{monitorId}/_health',
   PRIVATE_LOCATIONS_CLEANUP = `/internal/synthetics/private_locations/_cleanup`,
   SYNC_GLOBAL_PARAMS = `/internal/synthetics/sync_global_params`,
   SYNC_GLOBAL_PARAMS_SETTINGS = `/internal/synthetics/sync_global_params/_settings`,

x-pack/solutions/observability/plugins/synthetics/common/runtime_types/index.ts

@@ -14,3 +14,4 @@ export * from './snapshot';
 export * from './network_events';
 export * from './monitor_management';
 export * from './monitor_management/synthetics_private_locations';
+export * from './monitor_health';

x-pack/solutions/observability/plugins/synthetics/common/runtime_types/monitor_health.ts

@@ -0,0 +1,40 @@
+/*
+ * 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.
+ */
+
+export enum PrivateLocationHealthStatusValue {
+  Healthy = 'healthy',
+  MissingPackagePolicy = 'missing_package_policy',
+  MissingAgentPolicy = 'missing_agent_policy',
+  MissingLocation = 'missing_location',
+}
+
+export interface PrivateLocationHealthStatus {
+  locationId: string;
+  locationLabel: string;
+  status: PrivateLocationHealthStatusValue;
+  packagePolicyId: string;
+  agentPolicyId?: string;
+  reason?: string;
+}
+
+export interface MonitorHealthStatus {
+  configId: string;
+  monitorName: string;
+  isHealthy: boolean;
+  privateLocations: PrivateLocationHealthStatus[];
+}
+
+export interface MonitorHealthError {
+  configId: string;
+  message: string;
+  statusCode: number;
+}
+
+export interface MonitorsHealthResponse {
+  monitors: MonitorHealthStatus[];
+  errors: MonitorHealthError[];
+}

x-pack/solutions/observability/plugins/synthetics/common/runtime_types/monitor_management/state.ts

@@ -24,6 +24,7 @@ const FetchMonitorQueryArgsCommon = {
   projects: t.array(t.string),
   schedules: t.array(t.string),
   monitorQueryIds: t.array(t.string),
+  configIds: t.array(t.string),
   sortField: t.string,
   sortOrder: t.union([t.literal('desc'), t.literal('asc')]),
   showFromAllSpaces: t.boolean,

x-pack/solutions/observability/plugins/synthetics/public/apps/synthetics/components/common/hooks/status_labels.ts

@@ -0,0 +1,46 @@
+/*
+ * 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 { i18n } from '@kbn/i18n';
+import { PrivateLocationHealthStatusValue } from '../../../../../../common/runtime_types';
+
+export const STATUS_LABELS: Record<
+  Exclude<PrivateLocationHealthStatusValue, PrivateLocationHealthStatusValue.Healthy>,
+  string
+> = {
+  [PrivateLocationHealthStatusValue.MissingPackagePolicy]: i18n.translate(
+    'xpack.synthetics.monitorHealth.status.missingPackagePolicy',
+    {
+      defaultMessage:
+        'The Fleet package policy for this monitor and private location pair does not exist.',
+    }
+  ),
+  [PrivateLocationHealthStatusValue.MissingAgentPolicy]: i18n.translate(
+    'xpack.synthetics.monitorHealth.status.missingAgentPolicy',
+    {
+      defaultMessage: 'The agent policy referenced by this private location no longer exists.',
+    }
+  ),
+  [PrivateLocationHealthStatusValue.MissingLocation]: i18n.translate(
+    'xpack.synthetics.monitorHealth.status.missingLocation',
+    {
+      defaultMessage: 'The monitor references a private location that no longer exists.',
+    }
+  ),
+};
+
+export const getStatusLabel = (status: PrivateLocationHealthStatusValue): string | undefined => {
+  if (status === PrivateLocationHealthStatusValue.Healthy) return undefined;
+  return STATUS_LABELS[status];
+};
+
+export const RESET_FIXABLE_STATUSES = new Set([
+  PrivateLocationHealthStatusValue.MissingPackagePolicy,
+]);
+
+export const isFixableByResetStatus = (status: PrivateLocationHealthStatusValue): boolean =>
+  RESET_FIXABLE_STATUSES.has(status);

x-pack/solutions/observability/plugins/synthetics/public/apps/synthetics/components/common/hooks/use_monitor_integration_health.test.ts

@@ -0,0 +1,235 @@
+/*
+ * 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 { renderHook, act } from '@testing-library/react';
+import * as reactRedux from 'react-redux';
+import { PrivateLocationHealthStatusValue } from '../../../../../../common/runtime_types';
+import { useMonitorIntegrationHealth } from './use_monitor_integration_health';
+
+jest.mock('react-redux', () => ({
+  ...jest.requireActual('react-redux'),
+  useSelector: jest.fn(),
+  useDispatch: jest.fn(),
+}));
+
+jest.mock('../../../state/monitor_management/api', () => ({
+  resetMonitorAPI: jest.fn(),
+  resetMonitorBulkAPI: jest.fn(),
+}));
+
+import { resetMonitorAPI, resetMonitorBulkAPI } from '../../../state/monitor_management/api';
+
+const mockedResetMonitorAPI = resetMonitorAPI as jest.MockedFunction<typeof resetMonitorAPI>;
+const mockedResetMonitorBulkAPI = resetMonitorBulkAPI as jest.MockedFunction<
+  typeof resetMonitorBulkAPI
+>;
+
+const healthyMonitor = {
+  configId: 'mon-1',
+  monitorName: 'Monitor 1',
+  isHealthy: true,
+  privateLocations: [
+    {
+      locationId: 'loc-1',
+      locationLabel: 'Location 1',
+      status: PrivateLocationHealthStatusValue.Healthy,
+      packagePolicyId: 'mon-1-loc-1',
+    },
+  ],
+};
+
+const unhealthyMonitor = {
+  configId: 'mon-2',
+  monitorName: 'Monitor 2',
+  isHealthy: false,
+  privateLocations: [
+    {
+      locationId: 'loc-1',
+      locationLabel: 'Location 1',
+      status: PrivateLocationHealthStatusValue.MissingPackagePolicy,
+      packagePolicyId: 'mon-2-loc-1',
+      reason: 'Missing',
+    },
+    {
+      locationId: 'loc-2',
+      locationLabel: 'Location 2',
+      status: PrivateLocationHealthStatusValue.Healthy,
+      packagePolicyId: 'mon-2-loc-2',
+    },
+  ],
+};
+
+const setupSelectors = (healthData: { monitors: (typeof healthyMonitor)[]; errors: unknown[] }) => {
+  (reactRedux.useSelector as jest.Mock).mockImplementation((selector: any) => {
+    const fakeState = {
+      monitorList: {
+        data: { monitors: [] },
+        loaded: true,
+        loading: false,
+      },
+      monitorHealth: {
+        data: healthData,
+        loading: false,
+        loaded: true,
+        error: null,
+      },
+    };
+    return selector(fakeState);
+  });
+};
+
+describe('useMonitorIntegrationHealth', () => {
+  let dispatchSpy: jest.Mock;
+
+  beforeEach(() => {
+    jest.clearAllMocks();
+    dispatchSpy = jest.fn();
+    (reactRedux.useDispatch as jest.Mock).mockReturnValue(dispatchSpy);
+  });
+
+  describe('status helpers', () => {
+    it('isUnhealthy returns true for unhealthy monitors', () => {
+      setupSelectors({ monitors: [healthyMonitor, unhealthyMonitor], errors: [] });
+
+      const { result } = renderHook(() =>
+        useMonitorIntegrationHealth({ configIds: ['mon-1', 'mon-2'] })
+      );
+
+      expect(result.current.isUnhealthy('mon-1')).toBe(false);
+      expect(result.current.isUnhealthy('mon-2')).toBe(true);
+      expect(result.current.isUnhealthy('non-existent')).toBe(false);
+    });
+
+    it('getUnhealthyLocationStatuses returns only unhealthy locations', () => {
+      setupSelectors({ monitors: [unhealthyMonitor], errors: [] });
+
+      const { result } = renderHook(() => useMonitorIntegrationHealth({ configIds: ['mon-2'] }));
+
+      const statuses = result.current.getUnhealthyLocationStatuses('mon-2');
+      expect(statuses).toHaveLength(1);
+      expect(statuses[0].locationId).toBe('loc-1');
+      expect(statuses[0].status).toBe(PrivateLocationHealthStatusValue.MissingPackagePolicy);
+    });
+
+    it('getUnhealthyMonitorCountForLocation counts monitors with unhealthy status at that location', () => {
+      setupSelectors({ monitors: [healthyMonitor, unhealthyMonitor], errors: [] });
+
+      const { result } = renderHook(() =>
+        useMonitorIntegrationHealth({ configIds: ['mon-1', 'mon-2'] })
+      );
+
+      expect(result.current.getUnhealthyMonitorCountForLocation('loc-1')).toBe(1);
+      expect(result.current.getUnhealthyMonitorCountForLocation('loc-2')).toBe(0);
+    });
+
+    it('getUnhealthyConfigIdsForLocation returns config IDs of unhealthy monitors', () => {
+      setupSelectors({ monitors: [healthyMonitor, unhealthyMonitor], errors: [] });
+
+      const { result } = renderHook(() =>
+        useMonitorIntegrationHealth({ configIds: ['mon-1', 'mon-2'] })
+      );
+
+      expect(result.current.getUnhealthyConfigIdsForLocation('loc-1')).toEqual(['mon-2']);
+    });
+  });
+
+  describe('resetMonitor', () => {
+    it('calls resetMonitorAPI and re-fetches health', async () => {
+      setupSelectors({ monitors: [unhealthyMonitor], errors: [] });
+      mockedResetMonitorAPI.mockResolvedValue({ id: 'mon-2', reset: true });
+
+      const { result } = renderHook(() => useMonitorIntegrationHealth({ configIds: ['mon-2'] }));
+
+      let resetResult: { error?: Error } | undefined;
+      await act(async () => {
+        resetResult = await result.current.resetMonitor('mon-2');
+      });
+
+      expect(resetResult).toEqual({});
+      expect(mockedResetMonitorAPI).toHaveBeenCalledWith({ id: 'mon-2' });
+      expect(result.current.isResetting).toBe(false);
+      const healthDispatches = dispatchSpy.mock.calls.filter(
+        ([action]: any) => action.type === '[MONITOR HEALTH] GET'
+      );
+      expect(healthDispatches.length).toBeGreaterThanOrEqual(2);
+    });
+
+    it('returns error and sets isResetting to false on API failure', async () => {
+      setupSelectors({ monitors: [unhealthyMonitor], errors: [] });
+      mockedResetMonitorAPI.mockRejectedValue(new Error('Server error'));
+
+      const { result } = renderHook(() => useMonitorIntegrationHealth({ configIds: ['mon-2'] }));
+
+      let resetResult: { error?: Error } | undefined;
+      await act(async () => {
+        resetResult = await result.current.resetMonitor('mon-2');
+      });
+
+      expect(resetResult?.error).toBeInstanceOf(Error);
+      expect(resetResult?.error?.message).toBe('Server error');
+      expect(result.current.isResetting).toBe(false);
+    });
+  });
+
+  describe('resetMonitors (bulk)', () => {
+    it('returns error and does not refetch when a result item has reset: false', async () => {
+      setupSelectors({ monitors: [unhealthyMonitor], errors: [] });
+      mockedResetMonitorBulkAPI.mockResolvedValue({
+        result: [{ id: 'mon-2', reset: false, error: 'fleet error' }],
+      });
+
+      const { result } = renderHook(() => useMonitorIntegrationHealth({ configIds: ['mon-2'] }));
+
+      let resetResult: { error?: Error } | undefined;
+      await act(async () => {
+        resetResult = await result.current.resetMonitors(['mon-2']);
+      });
+
+      expect(resetResult?.error).toBeInstanceOf(Error);
+      expect(result.current.isResetting).toBe(false);
+      const healthDispatches = dispatchSpy.mock.calls.filter(
+        ([action]: any) => action.type === '[MONITOR HEALTH] GET'
+      );
+      expect(healthDispatches.length).toBe(1); // only initial fetch, no refetch
+    });
+
+    it('returns error and does not refetch when top-level errors are present', async () => {
+      setupSelectors({ monitors: [unhealthyMonitor], errors: [] });
+      mockedResetMonitorBulkAPI.mockResolvedValue({
+        result: [{ id: 'mon-2', reset: false }],
+      });
+
+      const { result } = renderHook(() => useMonitorIntegrationHealth({ configIds: ['mon-2'] }));
+
+      let resetResult: { error?: Error } | undefined;
+      await act(async () => {
+        resetResult = await result.current.resetMonitors(['mon-2']);
+      });
+
+      expect(resetResult?.error).toBeInstanceOf(Error);
+      expect(result.current.isResetting).toBe(false);
+    });
+
+    it('calls resetMonitorBulkAPI and re-fetches health', async () => {
+      setupSelectors({ monitors: [unhealthyMonitor], errors: [] });
+      mockedResetMonitorBulkAPI.mockResolvedValue({
+        result: [{ id: 'mon-2', reset: true }],
+      });
+
+      const { result } = renderHook(() => useMonitorIntegrationHealth({ configIds: ['mon-2'] }));
+
+      let resetResult: { error?: Error } | undefined;
+      await act(async () => {
+        resetResult = await result.current.resetMonitors(['mon-2']);
+      });
+
+      expect(resetResult).toEqual({});
+      expect(mockedResetMonitorBulkAPI).toHaveBeenCalledWith({ ids: ['mon-2'] });
+      expect(result.current.isResetting).toBe(false);
+    });
+  });
+});