[Inventory][ECO] Show alerts for entities

x-pack/plugins/observability_solution/apm/common/utils/join_by_key/index.test.ts

@@ -104,6 +104,53 @@ describe('joinByKey', () => {
     ]);
   });
 
+  it('joins by multiple keys', () => {
+    const joined = joinByKey(
+      [
+        {
+          serviceName: 'opbeans-node',
+          environment: 'production',
+          alertCount: 10,
+        },
+        {
+          serviceName: 'opbeans-node',
+          environment: 'production',
+        },
+        {
+          serviceName: 'opbeans-node',
+          environment: 'staging',
+        },
+        {
+          hostName: 'my-host',
+          cloudProvider: 'aws',
+        },
+        {
+          hostName: 'my-host',
+          alertCount: 10,
+          serviceName: 'opbeans-node',
+        },
+      ],
+      ['serviceName', 'environment', 'hostName']
+    );
+
+    expect(joined).toEqual([
+      {
+        serviceName: 'opbeans-node',
+        environment: 'production',
+        alertCount: 10,
+      },
+      {
+        serviceName: 'opbeans-node',
+        environment: 'staging',
+      },
+      {
+        hostName: 'my-host',
+        cloudProvider: 'aws',
+        alertCount: 10,
+      },
+    ]);
+  });
+
   it('uses the custom merge fn to replace items', () => {
     const joined = joinByKey(
       [

x-pack/plugins/observability_solution/inventory/common/entities.ts

@@ -6,6 +6,9 @@
  */
 import { ENTITY_LATEST, entitiesAliasPattern } from '@kbn/entities-schema';
 import {
+  HOST_NAME,
+  SERVICE_ENVIRONMENT,
+  SERVICE_NAME,
   AGENT_NAME,
   CLOUD_PROVIDER,
   CONTAINER_ID,
@@ -15,9 +18,6 @@ import {
   ENTITY_IDENTITY_FIELDS,
   ENTITY_LAST_SEEN,
   ENTITY_TYPE,
-  HOST_NAME,
-  SERVICE_ENVIRONMENT,
-  SERVICE_NAME,
 } from '@kbn/observability-shared-plugin/common';
 import { isRight } from 'fp-ts/lib/Either';
 import * as t from 'io-ts';
@@ -28,8 +28,19 @@ export const entityTypeRt = t.union([
   t.literal('container'),
 ]);
 
+export const entityColumnIdsRt = t.union([
+  t.literal(ENTITY_DISPLAY_NAME),
+  t.literal(ENTITY_LAST_SEEN),
+  t.literal(ENTITY_TYPE),
+  t.literal('alertsCount'),
+]);
+
+export type EntityColumnIds = t.TypeOf<typeof entityColumnIdsRt>;
+
 export type EntityType = t.TypeOf<typeof entityTypeRt>;
 
+export const DEFAULT_ENTITIES_SORT_FIELD: EntityColumnIds = 'alertsCount';
+
 export const MAX_NUMBER_OF_ENTITIES = 500;
 
 export const ENTITIES_LATEST_ALIAS = entitiesAliasPattern({
@@ -49,6 +60,8 @@ export const defaultEntityDefinitions = [
 
 export const defaultEntityTypes: EntityType[] = ['service', 'host', 'container'];
 
+export const defaultEntitySortField = ENTITY_LAST_SEEN;
+
 const entityArrayRt = t.array(entityTypeRt);
 export const entityTypesRt = new t.Type<EntityType[], string, unknown>(
   'entityTypesRt',
@@ -79,6 +92,7 @@ interface BaseEntity {
   [ENTITY_DISPLAY_NAME]: string;
   [ENTITY_DEFINITION_ID]: string;
   [ENTITY_IDENTITY_FIELDS]: string | string[];
+  alertsCount?: number;
   [key: string]: any;
 }
 

x-pack/plugins/observability_solution/inventory/common/utils/get_identity_fields_values.test.ts

@@ -0,0 +1,85 @@
+/*
+ * 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 {
+  ENTITY_DEFINITION_ID,
+  ENTITY_DISPLAY_NAME,
+  ENTITY_ID,
+  ENTITY_LAST_SEEN,
+} from '@kbn/observability-shared-plugin/common';
+import { Entity } from '../entities';
+import { getIdentityFieldValues } from './get_identity_fields_values';
+
+const commonEntityFields = {
+  [ENTITY_LAST_SEEN]: '2023-10-09T00:00:00Z',
+  [ENTITY_ID]: '1',
+  [ENTITY_DISPLAY_NAME]: 'entity_name',
+  [ENTITY_DEFINITION_ID]: 'entity_definition_id',
+  alertCount: 3,
+};
+
+describe('getIdentityFieldValues', () => {
+  it('should return the value when identityFields is a single string', () => {
+    const entity: Entity = {
+      'entity.identityFields': 'service.name',
+      'service.name': 'my-service',
+      'entity.type': 'service',
+      ...commonEntityFields,
+    };
+
+    const result = getIdentityFieldValues({ entity });
+    expect(result).toEqual(['service.name: "my-service"']);
+  });
+
+  it('should return values when identityFields is an array of strings', () => {
+    const entity: Entity = {
+      'entity.identityFields': ['service.name', 'service.environment'],
+      'service.name': 'my-service',
+      'entity.type': 'service',
+      'service.environment': 'staging',
+      ...commonEntityFields,
+    };
+
+    const result = getIdentityFieldValues({ entity });
+    expect(result).toEqual(['service.name: "my-service"', 'service.environment: "staging"']);
+  });
+
+  it('should return an empty array if identityFields is empty string', () => {
+    const entity: Entity = {
+      'entity.identityFields': '',
+      'service.name': 'my-service',
+      'entity.type': 'service',
+      ...commonEntityFields,
+    };
+
+    const result = getIdentityFieldValues({ entity });
+    expect(result).toEqual([]);
+  });
+  it('should return an empty array if identityFields is empty array', () => {
+    const entity: Entity = {
+      'entity.identityFields': [],
+      'service.name': 'my-service',
+      'entity.type': 'service',
+      ...commonEntityFields,
+    };
+
+    const result = getIdentityFieldValues({ entity });
+    expect(result).toEqual([]);
+  });
+
+  it('should ignore fields that are not present in the entity', () => {
+    const entity: Entity = {
+      'entity.identityFields': ['host.name', 'foo.bar'],
+      'host.name': 'my-host',
+      'entity.type': 'host',
+      ...commonEntityFields,
+    };
+
+    const result = getIdentityFieldValues({ entity });
+    expect(result).toEqual(['host.name: "my-host"']);
+  });
+});

x-pack/plugins/observability_solution/inventory/common/utils/get_identity_fields_values.ts

@@ -0,0 +1,27 @@
+/*
+ * 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 { ENTITY_IDENTITY_FIELDS } from '@kbn/observability-shared-plugin/common';
+import { Entity } from '../entities';
+
+export function getIdentityFieldValues({ entity }: { entity: Entity }) {
+  const mapping: string[] = [];
+
+  const identityFields = entity[ENTITY_IDENTITY_FIELDS];
+
+  if (identityFields) {
+    const fields = Array.isArray(identityFields) ? identityFields : [identityFields];
+
+    fields.forEach((field) => {
+      if (field in entity) {
+        mapping.push(`${[field]}: "${entity[field as keyof Entity]}"`);
+      }
+    });
+  }
+
+  return mapping;
+}