adding processor event in the query, and refactoring theme

Author: cauemarcondes

x-pack/plugins/apm/public/plugin.ts

@@ -42,6 +42,7 @@ import {
   fetchLandingPageData,
   hasData,
 } from './services/rest/observability_dashboard';
+import { getTheme } from './utils/get_theme';
 
 export type ApmPluginSetup = void;
 export type ApmPluginStart = void;
@@ -78,11 +79,13 @@ export class ApmPlugin implements Plugin<ApmPluginSetup, ApmPluginStart> {
     pluginSetupDeps.home.featureCatalogue.register(featureCatalogueEntry);
 
     if (plugins.observability) {
-      const isDarkMode = core.uiSettings.get('theme:darkMode');
+      const theme = getTheme({
+        isDarkMode: core.uiSettings.get('theme:darkMode'),
+      });
       plugins.observability.dashboard.register({
         appName: 'apm',
         fetchData: async (params) => {
-          return fetchLandingPageData(params, { isDarkMode });
+          return fetchLandingPageData(params, { theme });
         },
         hasData,
       });

x-pack/plugins/apm/public/services/rest/observability.dashboard.test.ts

@@ -6,6 +6,9 @@
 
 import { fetchLandingPageData, hasData } from './observability_dashboard';
 import * as createCallApmApi from './createCallApmApi';
+import { getTheme } from '../../utils/get_theme';
+
+const theme = getTheme({ isDarkMode: false });
 
 describe('Observability dashboard data', () => {
   const callApmApiMock = jest.spyOn(createCallApmApi, 'callApmApi');
@@ -43,7 +46,7 @@ describe('Observability dashboard data', () => {
           endTime: '2',
           bucketSize: '3',
         },
-        { isDarkMode: false }
+        { theme }
       );
       expect(response).toEqual({
         title: 'APM',
@@ -85,7 +88,7 @@ describe('Observability dashboard data', () => {
           endTime: '2',
           bucketSize: '3',
         },
-        { isDarkMode: false }
+        { theme }
       );
       expect(response).toEqual({
         title: 'APM',

x-pack/plugins/apm/public/services/rest/observability_dashboard.ts

@@ -6,23 +6,20 @@
 
 import { i18n } from '@kbn/i18n';
 import { sum } from 'lodash';
-import lightTheme from '@elastic/eui/dist/eui_theme_light.json';
-import darkTheme from '@elastic/eui/dist/eui_theme_dark.json';
 // eslint-disable-next-line @kbn/eslint/no-restricted-paths
 import { FetchDataParams } from '../../../../observability/public/data_handler';
 import { ApmFetchDataResponse } from '../../../../observability/public/typings/fetch_data_response';
 import { callApmApi } from './createCallApmApi';
+import { Theme } from '../../utils/get_theme';
 
 interface Options {
-  isDarkMode: boolean;
+  theme: Theme;
 }
 
 export const fetchLandingPageData = async (
   { startTime, endTime, bucketSize }: FetchDataParams,
-  { isDarkMode }: Options
+  { theme }: Options
 ): Promise<ApmFetchDataResponse> => {
-  const theme = isDarkMode ? darkTheme : lightTheme;
-
   const data = await callApmApi({
     pathname: '/api/apm/observability_dashboard',
     params: { query: { start: startTime, end: endTime, bucketSize } },

x-pack/plugins/apm/public/utils/get_theme.ts

@@ -0,0 +1,13 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+import lightTheme from '@elastic/eui/dist/eui_theme_light.json';
+import darkTheme from '@elastic/eui/dist/eui_theme_dark.json';
+
+export type Theme = ReturnType<typeof getTheme>;
+
+export function getTheme({ isDarkMode }: { isDarkMode: boolean }) {
+  return isDarkMode ? darkTheme : lightTheme;
+}

x-pack/plugins/apm/server/lib/observability_dashboard/get_service_count.ts

@@ -4,8 +4,12 @@
  * you may not use this file except in compliance with the Elastic License.
  */
 
+import { ProcessorEvent } from '../../../common/processor_event';
 import { rangeFilter } from '../../../common/utils/range_filter';
-import { SERVICE_NAME } from '../../../common/elasticsearch_fieldnames';
+import {
+  SERVICE_NAME,
+  PROCESSOR_EVENT,
+} from '../../../common/elasticsearch_fieldnames';
 import { Setup, SetupTimeRange } from '../helpers/setup_request';
 
 export async function getServiceCount({
@@ -23,7 +27,22 @@ export async function getServiceCount({
     ],
     body: {
       size: 0,
-      query: { bool: { filter: [{ range: rangeFilter(start, end) }] } },
+      query: {
+        bool: {
+          filter: [
+            { range: rangeFilter(start, end) },
+            {
+              terms: {
+                [PROCESSOR_EVENT]: [
+                  ProcessorEvent.error,
+                  ProcessorEvent.transaction,
+                  ProcessorEvent.metric,
+                ],
+              },
+            },
+          ],
+        },
+      },
       aggs: { serviceCount: { cardinality: { field: SERVICE_NAME } } },
     },
   };