[9.1] [SLO] Use internal es client for fetching remote cluster info !! (#224870) (#226410)

# Backport

This will backport the following commits from `main` to `9.1`:
- [[SLO] Use internal es client for fetching remote cluster info !!
(#224870)](#224870)

<!--- Backport version: 9.6.6 -->

### Questions ?
Please refer to the [Backport tool
documentation](https://github.com/sorenlouv/backport)

<!--BACKPORT
[{"author":{"name":"Shahzad","email":"[email protected]"},"sourceCommit":{"committedDate":"2025-07-03T12:24:13Z","message":"[SLO]
Use internal es client for fetching remote cluster info !!
(#224870)\n\n## Summary\n\nUse internal es client for fetching remote
cluster info
!!","sha":"f3e826cbf68c2dfd74113440a14c744c18b76931","branchLabelMapping":{"^v9.2.0$":"main","^v(\\d+).(\\d+).\\d+$":"$1.$2"}},"sourcePullRequest":{"labels":["release_note:skip","Team:obs-ux-management","backport:version","v9.1.0","v8.19.0","v9.0.3","v8.18.3","v8.17.8","v9.2.0"],"title":"[SLO]
Use internal es client for fetching remote cluster info
!!","number":224870,"url":"https://github.com/elastic/kibana/pull/224870","mergeCommit":{"message":"[SLO]
Use internal es client for fetching remote cluster info !!
(#224870)\n\n## Summary\n\nUse internal es client for fetching remote
cluster info
!!","sha":"f3e826cbf68c2dfd74113440a14c744c18b76931"}},"sourceBranch":"main","suggestedTargetBranches":["9.1","8.19","9.0","8.18","8.17"],"targetPullRequestStates":[{"branch":"9.1","label":"v9.1.0","branchLabelMappingKey":"^v(\\d+).(\\d+).\\d+$","isSourceBranch":false,"state":"NOT_CREATED"},{"branch":"8.19","label":"v8.19.0","branchLabelMappingKey":"^v(\\d+).(\\d+).\\d+$","isSourceBranch":false,"state":"NOT_CREATED"},{"branch":"9.0","label":"v9.0.3","branchLabelMappingKey":"^v(\\d+).(\\d+).\\d+$","isSourceBranch":false,"state":"NOT_CREATED"},{"branch":"8.18","label":"v8.18.3","branchLabelMappingKey":"^v(\\d+).(\\d+).\\d+$","isSourceBranch":false,"state":"NOT_CREATED"},{"branch":"8.17","label":"v8.17.8","branchLabelMappingKey":"^v(\\d+).(\\d+).\\d+$","isSourceBranch":false,"state":"NOT_CREATED"},{"branch":"main","label":"v9.2.0","branchLabelMappingKey":"^v9.2.0$","isSourceBranch":true,"state":"MERGED","url":"https://github.com/elastic/kibana/pull/224870","number":224870,"mergeCommit":{"message":"[SLO]
Use internal es client for fetching remote cluster info !!
(#224870)\n\n## Summary\n\nUse internal es client for fetching remote
cluster info !!","sha":"f3e826cbf68c2dfd74113440a14c744c18b76931"}}]}]
BACKPORT-->

Co-authored-by: Shahzad <[email protected]>

Author: kibanamachine

x-pack/solutions/observability/plugins/slo/server/routes/slo/find_groups.ts

@@ -23,12 +23,7 @@ export const findSLOGroupsRoute = createSloServerRoute({
     await assertPlatinumLicense(plugins);
     const { scopedClusterClient, soClient, spaceId } = await getScopedClients({ request, logger });
 
-    const findSLOGroups = new FindSLOGroups(
-      scopedClusterClient.asCurrentUser,
-      soClient,
-      logger,
-      spaceId
-    );
+    const findSLOGroups = new FindSLOGroups(scopedClusterClient, soClient, logger, spaceId);
     return await findSLOGroups.execute(params?.query ?? {});
   },
 });

x-pack/solutions/observability/plugins/slo/server/routes/slo/find_slo.ts

@@ -28,7 +28,7 @@ export const findSLORoute = createSloServerRoute({
     });
 
     const summarySearchClient = new DefaultSummarySearchClient(
-      scopedClusterClient.asCurrentUser,
+      scopedClusterClient,
       soClient,
       logger,
       spaceId

x-pack/solutions/observability/plugins/slo/server/routes/slo/get_slo_stats_overview.ts

@@ -29,7 +29,7 @@ export const getSLOStatsOverview = createSloServerRoute({
 
     const slosOverview = new GetSLOStatsOverview(
       soClient,
-      scopedClusterClient.asCurrentUser,
+      scopedClusterClient,
       spaceId,
       logger,
       rulesClient,

x-pack/solutions/observability/plugins/slo/server/services/find_slo_groups.ts

@@ -4,7 +4,7 @@
  * 2.0; you may not use this file except in compliance with the Elastic License
  * 2.0.
  */
-import { ElasticsearchClient, Logger, SavedObjectsClientContract } from '@kbn/core/server';
+import { IScopedClusterClient, Logger, SavedObjectsClientContract } from '@kbn/core/server';
 import {
   FindSLOGroupsParams,
   FindSLOGroupsResponse,
@@ -38,7 +38,7 @@ function toPagination(params: FindSLOGroupsParams): Pagination {
 
 export class FindSLOGroups {
   constructor(
-    private esClient: ElasticsearchClient,
+    private scopedClusterClient: IScopedClusterClient,
     private soClient: SavedObjectsClientContract,
     private logger: Logger,
     private spaceId: string
@@ -53,11 +53,11 @@ export class FindSLOGroups {
     const parsedFilters = parseStringFilters(filters, this.logger);
 
     const settings = await getSloSettings(this.soClient);
-    const { indices } = await getSummaryIndices(this.esClient, settings);
+    const { indices } = await getSummaryIndices(this.scopedClusterClient.asInternalUser, settings);
 
     const hasSelectedTags = groupBy === 'slo.tags' && groupsFilter.length > 0;
 
-    const response = await typedSearch(this.esClient, {
+    const response = await typedSearch(this.scopedClusterClient.asCurrentUser, {
       index: indices,
       size: 0,
       query: {

x-pack/solutions/observability/plugins/slo/server/services/get_slo_stats_overview.ts

@@ -6,7 +6,7 @@
  */
 
 import { RulesClientApi } from '@kbn/alerting-plugin/server/types';
-import { ElasticsearchClient } from '@kbn/core-elasticsearch-server';
+import { IScopedClusterClient } from '@kbn/core-elasticsearch-server';
 import { SavedObjectsClientContract } from '@kbn/core-saved-objects-api-server';
 import { Logger } from '@kbn/logging';
 import { AlertConsumers, SLO_RULE_TYPE_IDS } from '@kbn/rule-data-utils';
@@ -20,7 +20,7 @@ import { getElasticsearchQueryOrThrow, parseStringFilters } from './transform_ge
 export class GetSLOStatsOverview {
   constructor(
     private soClient: SavedObjectsClientContract,
-    private esClient: ElasticsearchClient,
+    private scopedClusterClient: IScopedClusterClient,
     private spaceId: string,
     private logger: Logger,
     private rulesClient: RulesClientApi,
@@ -29,13 +29,13 @@ export class GetSLOStatsOverview {
 
   public async execute(params: GetSLOStatsOverviewParams): Promise<GetSLOStatsOverviewResponse> {
     const settings = await getSloSettings(this.soClient);
-    const { indices } = await getSummaryIndices(this.esClient, settings);
+    const { indices } = await getSummaryIndices(this.scopedClusterClient.asInternalUser, settings);
 
     const kqlQuery = params.kqlQuery ?? '';
     const filters = params.filters ?? '';
     const parsedFilters = parseStringFilters(filters, this.logger);
 
-    const response = await typedSearch(this.esClient, {
+    const response = await typedSearch(this.scopedClusterClient.asCurrentUser, {
       index: indices,
       size: 0,
       query: {

x-pack/solutions/observability/plugins/slo/server/services/summary_search_client/summary_search_client.test.ts

@@ -16,6 +16,7 @@ import {
 } from '../fixtures/summary_search_document';
 import { DefaultSummarySearchClient } from './summary_search_client';
 import type { Sort, SummarySearchClient } from './types';
+import { IScopedClusterClient } from '@kbn/core-elasticsearch-server';
 
 const defaultSort: Sort = {
   field: 'sli_value',
@@ -27,11 +28,13 @@ const defaultPagination: Pagination = {
 };
 
 describe('Summary Search Client', () => {
-  let esClientMock: ElasticsearchClientMock;
+  let scopedClusterClient: IScopedClusterClient;
   let service: SummarySearchClient;
+  let esClientMock: ElasticsearchClientMock;
 
   beforeEach(() => {
-    esClientMock = elasticsearchServiceMock.createElasticsearchClient();
+    scopedClusterClient = elasticsearchServiceMock.createScopedClusterClient();
+    esClientMock = scopedClusterClient.asCurrentUser as ElasticsearchClientMock;
     const soClientMock = {
       getCurrentNamespace: jest.fn().mockReturnValue('default'),
       get: jest.fn().mockResolvedValue({
@@ -42,7 +45,7 @@ describe('Summary Search Client', () => {
       }),
     } as any;
     service = new DefaultSummarySearchClient(
-      esClientMock,
+      scopedClusterClient,
       soClientMock,
       loggerMock.create(),
       'default'

x-pack/solutions/observability/plugins/slo/server/services/summary_search_client/summary_search_client.ts

@@ -6,7 +6,7 @@
  */
 
 import type { estypes } from '@elastic/elasticsearch';
-import { ElasticsearchClient, Logger, SavedObjectsClientContract } from '@kbn/core/server';
+import { IScopedClusterClient, Logger, SavedObjectsClientContract } from '@kbn/core/server';
 import { isCCSRemoteIndexName } from '@kbn/es-query';
 import { ALL_VALUE } from '@kbn/slo-schema';
 import { assertNever } from '@kbn/std';
@@ -32,7 +32,7 @@ import { isCursorPagination } from './types';
 
 export class DefaultSummarySearchClient implements SummarySearchClient {
   constructor(
-    private esClient: ElasticsearchClient,
+    private scopedClusterClient: IScopedClusterClient,
     private soClient: SavedObjectsClientContract,
     private logger: Logger,
     private spaceId: string
@@ -47,7 +47,7 @@ export class DefaultSummarySearchClient implements SummarySearchClient {
   ): Promise<Paginated<SummaryResult>> {
     const parsedFilters = parseStringFilters(filters, this.logger);
     const settings = await getSloSettings(this.soClient);
-    const { indices } = await getSummaryIndices(this.esClient, settings);
+    const { indices } = await getSummaryIndices(this.scopedClusterClient.asInternalUser, settings);
 
     const esParams = createEsParams({
       index: indices,
@@ -83,7 +83,7 @@ export class DefaultSummarySearchClient implements SummarySearchClient {
 
     try {
       const summarySearch = await typedSearch<EsSummaryDocument, typeof esParams>(
-        this.esClient,
+        this.scopedClusterClient.asCurrentUser,
         esParams
       );
 
@@ -173,7 +173,7 @@ export class DefaultSummarySearchClient implements SummarySearchClient {
     // Always attempt to delete temporary summary documents with an existing non-temp summary document
     // The temp summary documents are _eventually_ removed as we get through the real summary documents
 
-    await this.esClient.deleteByQuery({
+    await this.scopedClusterClient.asCurrentUser.deleteByQuery({
       index: SUMMARY_DESTINATION_INDEX_PATTERN,
       wait_for_completion: false,
       conflicts: 'proceed',