[APM] Fix service maps load failure when user doesn't have ML permiss…

…ions (#70138)

* checks for statusCode 403 when fetching ML jobs, and returns empty list of jobs instead of throwing

* Catches any error thrown when retrieving service anomalies and logs them
to the console before responding service maps data without anomalies.

Co-authored-by: Elastic Machine <elasticmachine@users.noreply.github.com>

x-pack/plugins/apm/server/lib/service_map/get_service_anomalies.ts

@@ -26,7 +26,7 @@ async function getApmAnomalyDetectionJobs(
     const { jobs } = await ml.anomalyDetectors.jobs(APM_ML_JOB_GROUP_NAME);
     return jobs;
   } catch (error) {
-    if (error.statusCode === 404) {
+    if (error.statusCode === 404 || error.statusCode === 403) {
       return [];
     }
     throw error;
@@ -131,7 +131,7 @@ export async function getServiceAnomalies(
   };
 
   const response = (await ml.mlSystem.mlSearch(params)) as {
-    aggregations: {
+    aggregations?: {
       jobs: {
         buckets: Array<{
           key: string;
@@ -151,6 +151,11 @@ export async function getServiceAnomalies(
       };
     };
   };
+
+  if (!response.aggregations) {
+    return [];
+  }
+
   const anomalyScores = response.aggregations.jobs.buckets.map((jobBucket) => {
     const jobId = jobBucket.key;
     const bucketSource = jobBucket.top_score_hits.hits.hits?.[0]?._source;

x-pack/plugins/apm/server/lib/service_map/get_service_map.ts

@@ -4,6 +4,7 @@
  * you may not use this file except in compliance with the Elastic License.
  */
 import { chunk } from 'lodash';
+import { Logger } from 'kibana/server';
 import {
   AGENT_NAME,
   SERVICE_ENVIRONMENT,
@@ -26,6 +27,7 @@ export interface IEnvOptions {
   setup: Setup & SetupTimeRange;
   serviceName?: string;
   environment?: string;
+  logger: Logger;
 }
 
 async function getConnectionData({
@@ -138,6 +140,7 @@ export type ServicesResponse = PromiseReturnType<typeof getServicesData>;
 export type ServiceMapAPIResponse = PromiseReturnType<typeof getServiceMap>;
 
 export async function getServiceMap(options: IEnvOptions) {
+  const { logger } = options;
   const [connectionData, servicesData] = await Promise.all([
     getConnectionData(options),
     getServicesData(options),
@@ -150,12 +153,18 @@ export async function getServiceMap(options: IEnvOptions) {
     (serviceData) => serviceData[SERVICE_NAME]
   );
 
-  // Get related service anomalies
-  const serviceAnomalies = await getServiceAnomalies(options, serviceNames);
+  let anomalies: ServiceAnomalies = [];
+  try {
+    // Get related service anomalies
+    anomalies = await getServiceAnomalies(options, serviceNames);
+  } catch (error) {
+    logger.warn('Unabled to retrieve anomaly detection data for service maps.');
+    logger.error(error);
+  }
 
   return transformServiceMapResponses({
     ...connectionData,
-    anomalies: serviceAnomalies,
+    anomalies,
     services: servicesData,
   });
 }

x-pack/plugins/apm/server/routes/service_map.ts

@@ -39,7 +39,12 @@ export const serviceMapRoute = createRoute(() => ({
     const {
       query: { serviceName, environment },
     } = context.params;
-    return getServiceMap({ setup, serviceName, environment });
+    return getServiceMap({
+      setup,
+      serviceName,
+      environment,
+      logger: context.logger,
+    });
   },
 }));