[8.15] [ResponseOps][Cases] Fix a bug with cases telemetry where data from other spaces are not included (#193166)

x-pack/plugins/cases/server/telemetry/collect_telemetry_data.ts

@@ -11,7 +11,7 @@ import { getCasesSystemActionData } from './queries/case_system_action';
 import { getUserCommentsTelemetryData } from './queries/comments';
 import { getConfigurationTelemetryData } from './queries/configuration';
 import { getConnectorsTelemetryData } from './queries/connectors';
-import { getPushedTelemetryData } from './queries/pushes';
+import { getPushedTelemetryData } from './queries/push';
 import { getUserActionsTelemetryData } from './queries/user_actions';
 import type { CasesTelemetry, CollectTelemetryDataParams } from './types';
 

x-pack/plugins/cases/server/telemetry/index.ts

@@ -5,12 +5,7 @@
  * 2.0.
  */
 
-import type {
-  CoreSetup,
-  ISavedObjectsRepository,
-  Logger,
-  PluginInitializerContext,
-} from '@kbn/core/server';
+import type { CoreSetup, Logger, PluginInitializerContext } from '@kbn/core/server';
 import { SavedObjectsErrorHelpers } from '@kbn/core/server';
 import type { TaskManagerSetupContract } from '@kbn/task-manager-plugin/server';
 import type { UsageCollectionSetup } from '@kbn/usage-collection-plugin/server';
@@ -25,6 +20,7 @@ import {
 } from '../../common/constants';
 import type { CasesTelemetry } from './types';
 import { casesSchema } from './schema';
+import { TelemetrySavedObjectsClient } from './telemetry_saved_objects_client';
 
 export { scheduleCasesTelemetryTask } from './schedule_telemetry_task';
 
@@ -42,13 +38,18 @@ export const createCasesTelemetry = ({
   usageCollection,
   logger,
 }: CreateCasesTelemetryArgs) => {
-  const getInternalSavedObjectClient = async (): Promise<ISavedObjectsRepository> => {
+  const getInternalSavedObjectClient = async (): Promise<TelemetrySavedObjectsClient> => {
     const [coreStart] = await core.getStartServices();
-    return coreStart.savedObjects.createInternalRepository([
+    const soClient = coreStart.savedObjects.createInternalRepository([
       ...SAVED_OBJECT_TYPES,
       FILE_SO_TYPE,
       CASE_RULES_SAVED_OBJECT,
     ]);
+
+    // Wrapping the internalRepository with the `TelemetrySavedObjectsClient`
+    // to ensure some best practices when collecting "all the telemetry"
+    // (i.e.: `.find` requests should query all spaces)
+    return new TelemetrySavedObjectsClient(soClient);
   };
 
   taskManager.registerTaskDefinitions({

x-pack/plugins/cases/server/telemetry/queries/alerts.test.ts

@@ -7,12 +7,15 @@
 
 import { loggingSystemMock, savedObjectsRepositoryMock } from '@kbn/core/server/mocks';
 import { getAlertsTelemetryData } from './alerts';
+import { TelemetrySavedObjectsClient } from '../telemetry_saved_objects_client';
 
 describe('alerts', () => {
   const logger = loggingSystemMock.createLogger();
 
   describe('getAlertsTelemetryData', () => {
     const savedObjectsClient = savedObjectsRepositoryMock.create();
+    const telemetrySavedObjectsClient = new TelemetrySavedObjectsClient(savedObjectsClient);
+
     savedObjectsClient.find.mockResolvedValue({
       total: 5,
       saved_objects: [],
@@ -35,7 +38,10 @@ describe('alerts', () => {
     });
 
     it('it returns the correct res', async () => {
-      const res = await getAlertsTelemetryData({ savedObjectsClient, logger });
+      const res = await getAlertsTelemetryData({
+        savedObjectsClient: telemetrySavedObjectsClient,
+        logger,
+      });
       expect(res).toEqual({
         all: {
           total: 5,
@@ -48,7 +54,7 @@ describe('alerts', () => {
     });
 
     it('should call find with correct arguments', async () => {
-      await getAlertsTelemetryData({ savedObjectsClient, logger });
+      await getAlertsTelemetryData({ savedObjectsClient: telemetrySavedObjectsClient, logger });
       expect(savedObjectsClient.find).toBeCalledWith({
         aggs: {
           counts: {
@@ -117,6 +123,7 @@ describe('alerts', () => {
         page: 0,
         perPage: 0,
         type: 'cases-comments',
+        namespaces: ['*'],
       });
     });
   });

x-pack/plugins/cases/server/telemetry/queries/case_system_action.test.ts

@@ -7,12 +7,14 @@
 
 import { loggingSystemMock, savedObjectsRepositoryMock } from '@kbn/core/server/mocks';
 import { getCasesSystemActionData } from './case_system_action';
+import { TelemetrySavedObjectsClient } from '../telemetry_saved_objects_client';
 
 describe('casesSystemAction', () => {
   const logger = loggingSystemMock.createLogger();
 
   describe('getCasesSystemActionData', () => {
     const savedObjectsClient = savedObjectsRepositoryMock.create();
+    const telemetrySavedObjectsClient = new TelemetrySavedObjectsClient(savedObjectsClient);
 
     beforeEach(() => {
       jest.clearAllMocks();
@@ -26,7 +28,10 @@ describe('casesSystemAction', () => {
     });
 
     it('calculates the metrics correctly', async () => {
-      const res = await getCasesSystemActionData({ savedObjectsClient, logger });
+      const res = await getCasesSystemActionData({
+        savedObjectsClient: telemetrySavedObjectsClient,
+        logger,
+      });
       expect(res).toEqual({ totalCasesCreated: 4, totalRules: 2 });
     });
 
@@ -38,8 +43,49 @@ describe('casesSystemAction', () => {
         page: 1,
       });
 
-      const res = await getCasesSystemActionData({ savedObjectsClient, logger });
+      const res = await getCasesSystemActionData({
+        savedObjectsClient: telemetrySavedObjectsClient,
+        logger,
+      });
+
       expect(res).toEqual({ totalCasesCreated: 0, totalRules: 0 });
     });
+
+    it('should call find with correct arguments', async () => {
+      savedObjectsClient.find.mockResolvedValue({
+        total: 1,
+        saved_objects: [],
+        per_page: 1,
+        page: 1,
+      });
+
+      await getCasesSystemActionData({
+        savedObjectsClient: telemetrySavedObjectsClient,
+        logger,
+      });
+
+      expect(savedObjectsClient.find.mock.calls[0][0]).toMatchInlineSnapshot(`
+        Object {
+          "aggs": Object {
+            "counterSum": Object {
+              "sum": Object {
+                "field": "cases-rules.attributes.counter",
+              },
+            },
+            "totalRules": Object {
+              "cardinality": Object {
+                "field": "cases-rules.attributes.rules.id",
+              },
+            },
+          },
+          "namespaces": Array [
+            "*",
+          ],
+          "page": 1,
+          "perPage": 1,
+          "type": "cases-rules",
+        }
+      `);
+    });
   });
 });

x-pack/plugins/cases/server/telemetry/queries/case_system_action.ts

@@ -26,6 +26,7 @@ export const getCasesSystemActionData = async ({
         cardinality: { field: `${CASE_RULES_SAVED_OBJECT}.attributes.rules.id` },
       },
     },
+    namespaces: ['*'],
   });
 
   return {

x-pack/plugins/cases/server/telemetry/queries/cases.test.ts

@@ -15,6 +15,7 @@ import type {
   FileAttachmentAggregationResults,
 } from '../types';
 import { getCasesTelemetryData } from './cases';
+import { TelemetrySavedObjectsClient } from '../telemetry_saved_objects_client';
 
 const MOCK_FIND_TOTAL = 5;
 const SOLUTION_TOTAL = 1;
@@ -23,6 +24,7 @@ describe('getCasesTelemetryData', () => {
   describe('getCasesTelemetryData', () => {
     const logger = loggingSystemMock.createLogger();
     const savedObjectsClient = savedObjectsRepositoryMock.create();
+    const telemetrySavedObjectsClient = new TelemetrySavedObjectsClient(savedObjectsClient);
 
     const mockFind = (aggs: object, so: SavedObjectsFindResponse['saved_objects'] = []) => {
       savedObjectsClient.find.mockResolvedValueOnce({
@@ -322,7 +324,10 @@ describe('getCasesTelemetryData', () => {
         };
       };
 
-      const res = await getCasesTelemetryData({ savedObjectsClient, logger });
+      const res = await getCasesTelemetryData({
+        savedObjectsClient: telemetrySavedObjectsClient,
+        logger,
+      });
 
       const allAttachmentsTotal = 5;
       const allAttachmentsAverage = allAttachmentsTotal / MOCK_FIND_TOTAL;
@@ -406,7 +411,7 @@ describe('getCasesTelemetryData', () => {
     it('should call find with correct arguments', async () => {
       mockResponse();
 
-      await getCasesTelemetryData({ savedObjectsClient, logger });
+      await getCasesTelemetryData({ savedObjectsClient: telemetrySavedObjectsClient, logger });
 
       expect(savedObjectsClient.find.mock.calls[0][0]).toMatchInlineSnapshot(`
         Object {
@@ -660,6 +665,9 @@ describe('getCasesTelemetryData', () => {
               },
             },
           },
+          "namespaces": Array [
+            "*",
+          ],
           "page": 0,
           "perPage": 0,
           "type": "cases",
@@ -974,6 +982,9 @@ describe('getCasesTelemetryData', () => {
               },
             },
           },
+          "namespaces": Array [
+            "*",
+          ],
           "page": 0,
           "perPage": 0,
           "type": "cases-comments",
@@ -1023,6 +1034,7 @@ describe('getCasesTelemetryData', () => {
         page: 0,
         perPage: 0,
         type: 'cases-comments',
+        namespaces: ['*'],
       });
 
       expect(savedObjectsClient.find.mock.calls[3][0]).toEqual({
@@ -1068,6 +1080,7 @@ describe('getCasesTelemetryData', () => {
         page: 0,
         perPage: 0,
         type: 'cases-user-actions',
+        namespaces: ['*'],
       });
 
       for (const [index, sortField] of ['created_at', 'updated_at', 'closed_at'].entries()) {
@@ -1079,6 +1092,7 @@ describe('getCasesTelemetryData', () => {
           sortField,
           sortOrder: 'desc',
           type: 'cases',
+          namespaces: ['*'],
         });
       }
 
@@ -1172,6 +1186,9 @@ describe('getCasesTelemetryData', () => {
             "function": "is",
             "type": "function",
           },
+          "namespaces": Array [
+            "*",
+          ],
           "page": 0,
           "perPage": 0,
           "type": "file",

x-pack/plugins/cases/server/telemetry/queries/cases.ts

@@ -5,7 +5,7 @@
  * 2.0.
  */
 
-import type { ISavedObjectsRepository, SavedObjectsFindResponse } from '@kbn/core/server';
+import type { SavedObjectsFindResponse } from '@kbn/core/server';
 import { FILE_SO_TYPE } from '@kbn/files-plugin/common';
 import { fromKueryExpression } from '@kbn/es-query';
 import {
@@ -37,6 +37,7 @@ import {
 } from './utils';
 import type { CasePersistedAttributes } from '../../common/types/case';
 import { CasePersistedStatus } from '../../common/types/case';
+import type { TelemetrySavedObjectsClient } from '../telemetry_saved_objects_client';
 
 export const getLatestCasesDates = async ({
   savedObjectsClient,
@@ -48,6 +49,7 @@ export const getLatestCasesDates = async ({
       sortField,
       sortOrder: 'desc',
       type: CASE_SAVED_OBJECT,
+      namespaces: ['*'],
     });
 
   const savedObjects = await Promise.all([
@@ -145,7 +147,7 @@ export const getCasesTelemetryData = async ({
 };
 
 const getCasesSavedObjectTelemetry = async (
-  savedObjectsClient: ISavedObjectsRepository
+  savedObjectsClient: TelemetrySavedObjectsClient
 ): Promise<SavedObjectsFindResponse<unknown, CaseAggregationResult>> => {
   const caseByOwnerAggregationQuery = OWNERS.reduce(
     (aggQuery, owner) => ({
@@ -169,6 +171,7 @@ const getCasesSavedObjectTelemetry = async (
     page: 0,
     perPage: 0,
     type: CASE_SAVED_OBJECT,
+    namespaces: ['*'],
     aggs: {
       ...caseByOwnerAggregationQuery,
       ...getCountsAggregationQuery(CASE_SAVED_OBJECT),
@@ -231,7 +234,7 @@ const getAssigneesAggregations = () => ({
 });
 
 const getCommentsSavedObjectTelemetry = async (
-  savedObjectsClient: ISavedObjectsRepository
+  savedObjectsClient: TelemetrySavedObjectsClient
 ): Promise<SavedObjectsFindResponse<unknown, AttachmentAggregationResult>> => {
   const attachmentRegistries = () => ({
     externalReferenceTypes: {
@@ -275,6 +278,7 @@ const getCommentsSavedObjectTelemetry = async (
     page: 0,
     perPage: 0,
     type: CASE_COMMENT_SAVED_OBJECT,
+    namespaces: ['*'],
     aggs: {
       ...attachmentsByOwnerAggregationQuery,
       ...attachmentRegistries(),
@@ -288,7 +292,7 @@ const getCommentsSavedObjectTelemetry = async (
 };
 
 const getFilesTelemetry = async (
-  savedObjectsClient: ISavedObjectsRepository
+  savedObjectsClient: TelemetrySavedObjectsClient
 ): Promise<SavedObjectsFindResponse<unknown, FileAttachmentAggregationResults>> => {
   const averageSize = () => ({
     averageSize: {
@@ -332,17 +336,19 @@ const getFilesTelemetry = async (
     perPage: 0,
     type: FILE_SO_TYPE,
     filter: filterCaseIdExists,
+    namespaces: ['*'],
     aggs: { ...filesByOwnerAggregationQuery, ...averageSize(), ...top20MimeTypes() },
   });
 };
 
 const getAlertsTelemetry = async (
-  savedObjectsClient: ISavedObjectsRepository
+  savedObjectsClient: TelemetrySavedObjectsClient
 ): Promise<SavedObjectsFindResponse<unknown, ReferencesAggregation>> => {
   return savedObjectsClient.find<unknown, ReferencesAggregation>({
     page: 0,
     perPage: 0,
     type: CASE_COMMENT_SAVED_OBJECT,
+    namespaces: ['*'],
     filter: getOnlyAlertsCommentsFilter(),
     aggs: {
       ...getReferencesAggregationQuery({
@@ -355,12 +361,13 @@ const getAlertsTelemetry = async (
 };
 
 const getConnectorsTelemetry = async (
-  savedObjectsClient: ISavedObjectsRepository
+  savedObjectsClient: TelemetrySavedObjectsClient
 ): Promise<SavedObjectsFindResponse<unknown, ReferencesAggregation>> => {
   return savedObjectsClient.find<unknown, ReferencesAggregation>({
     page: 0,
     perPage: 0,
     type: CASE_USER_ACTION_SAVED_OBJECT,
+    namespaces: ['*'],
     filter: getOnlyConnectorsFilter(),
     aggs: {
       ...getReferencesAggregationQuery({