[Fleet] Replace Console API with internal API

x-pack/plugins/fleet/common/constants/routes.ts

@@ -212,6 +212,14 @@ export const DOWNLOAD_SOURCE_API_ROUTES = {
   DELETE_PATTERN: `${API_ROOT}/agent_download_sources/{sourceId}`,
 };
 
+// Fleet debug routes
+
+export const FLEET_DEBUG_ROUTES = {
+  INDEX_PATTERN: `${INTERNAL_ROOT}/debug/index`,
+  SAVED_OBJECTS_PATTERN: `${INTERNAL_ROOT}/debug/saved_objects`,
+  SAVED_OBJECT_NAMES_PATTERN: `${INTERNAL_ROOT}/debug/saved_object_names`,
+};
+
 // API versioning constants
 export const API_VERSIONS = {
   public: {

x-pack/plugins/fleet/common/services/routes.ts

@@ -24,6 +24,7 @@ import {
   FLEET_SERVER_HOST_API_ROUTES,
   FLEET_PROXY_API_ROUTES,
   UNINSTALL_TOKEN_ROUTES,
+  FLEET_DEBUG_ROUTES,
 } from '../constants';
 
 export const epmRouteService = {
@@ -322,3 +323,9 @@ export const downloadSourceRoutesService = {
     DOWNLOAD_SOURCE_API_ROUTES.DELETE_PATTERN.replace('{sourceId}', downloadSourceId),
   getCreatePath: () => DOWNLOAD_SOURCE_API_ROUTES.CREATE_PATTERN,
 };
+
+export const debugRoutesService = {
+  getIndexPath: () => FLEET_DEBUG_ROUTES.INDEX_PATTERN,
+  getSavedObjectsPath: () => FLEET_DEBUG_ROUTES.SAVED_OBJECTS_PATTERN,
+  getSavedObjectNamesPath: () => FLEET_DEBUG_ROUTES.SAVED_OBJECT_NAMES_PATTERN,
+};

x-pack/plugins/fleet/public/applications/fleet/sections/debug/components/fleet_index_debugger.tsx

@@ -20,30 +20,33 @@ import { useQuery } from '@tanstack/react-query';
 import { i18n } from '@kbn/i18n';
 import { FormattedMessage } from '@kbn/i18n-react';
 
+import { AGENTS_INDEX, AGENT_ACTIONS_INDEX, API_VERSIONS } from '../../../../../../common';
+
 import { sendRequest } from '../../../hooks';
 
+import { debugRoutesService } from '../../../../../../common/services';
+
+import { ENROLLMENT_API_KEYS_INDEX } from '../../../constants';
+
 import { CodeBlock } from './code_block';
 
 const fetchIndex = async (index?: string) => {
   if (!index) return;
-  const path = `/${index}/_search`;
   const response = await sendRequest({
     method: 'post',
-    path: `/api/console/proxy`,
-    query: {
-      path,
-      method: 'GET',
-    },
+    path: debugRoutesService.getIndexPath(),
+    body: { index },
+    version: API_VERSIONS.internal.v1,
   });
 
   return response;
 };
 
 export const FleetIndexDebugger = () => {
   const indices = [
-    { label: '.fleet-agents', value: '.fleet-agents' },
-    { label: '.fleet-actions', value: '.fleet-actions' },
-    { label: '.fleet-enrollment-api-keys', value: '.fleet-enrollment-api-keys' },
+    { label: AGENTS_INDEX, value: AGENTS_INDEX },
+    { label: AGENT_ACTIONS_INDEX, value: AGENT_ACTIONS_INDEX },
+    { label: ENROLLMENT_API_KEYS_INDEX, value: ENROLLMENT_API_KEYS_INDEX },
   ];
   const [index, setIndex] = useState<string | undefined>();
 

x-pack/plugins/fleet/public/applications/fleet/sections/debug/components/saved_object_debugger.tsx

@@ -22,50 +22,39 @@ import { FormattedMessage } from '@kbn/i18n-react';
 
 import { sendRequest } from '../../../hooks';
 
+import { debugRoutesService } from '../../../../../../common/services';
+
 import {
   OUTPUT_SAVED_OBJECT_TYPE,
   AGENT_POLICY_SAVED_OBJECT_TYPE,
   PACKAGE_POLICY_SAVED_OBJECT_TYPE,
   PACKAGES_SAVED_OBJECT_TYPE,
   DOWNLOAD_SOURCE_SAVED_OBJECT_TYPE,
   FLEET_SERVER_HOST_SAVED_OBJECT_TYPE,
-  INGEST_SAVED_OBJECT_INDEX,
+  API_VERSIONS,
 } from '../../../../../../common/constants';
 
 import { CodeBlock } from './code_block';
 import { SavedObjectNamesCombo } from './saved_object_names_combo';
 
 const fetchSavedObjects = async (type?: string, name?: string) => {
   if (!type || !name) return;
-  const path = `/${INGEST_SAVED_OBJECT_INDEX}/_search`;
-  const body = {
-    query: {
-      bool: {
-        must: {
-          match: { [`${type}.name`]: name },
-        },
-        filter: {
-          term: {
-            type,
-          },
-        },
-      },
-    },
-  };
+
   const response = await sendRequest({
     method: 'post',
-    path: `/api/console/proxy`,
-    query: {
-      path,
-      method: 'GET',
+    path: debugRoutesService.getSavedObjectsPath(),
+    body: {
+      type,
+      name,
     },
-    body,
+    version: API_VERSIONS.internal.v1,
   });
 
   if (response.error) {
     throw new Error(response.error.message);
   }
-  return response.data?.hits;
+
+  return response.data?.saved_objects;
 };
 
 export const SavedObjectDebugger: React.FunctionComponent = () => {

x-pack/plugins/fleet/public/applications/fleet/sections/debug/components/saved_object_names_combo.tsx

@@ -12,35 +12,15 @@ import { EuiComboBox } from '@elastic/eui';
 import { i18n } from '@kbn/i18n';
 
 import { sendRequest } from '../../../hooks';
-import { INGEST_SAVED_OBJECT_INDEX } from '../../../../../../common/constants';
+import { debugRoutesService } from '../../../../../../common/services';
+import { API_VERSIONS } from '../../../../../../common/constants';
 
 const fetchSavedObjectNames = async (type: string) => {
-  const path = `/${INGEST_SAVED_OBJECT_INDEX}/_search`;
-  const body = {
-    size: 0,
-    query: {
-      bool: {
-        filter: {
-          term: {
-            type,
-          },
-        },
-      },
-    },
-    aggs: {
-      names: {
-        terms: { field: `${type}.name`, size: 500 },
-      },
-    },
-  };
   const response = await sendRequest({
     method: 'post',
-    path: `/api/console/proxy`,
-    query: {
-      path,
-      method: 'GET',
-    },
-    body,
+    path: debugRoutesService.getSavedObjectNamesPath(),
+    body: { type },
+    version: API_VERSIONS.internal.v1,
   });
 
   if (response.error) {

x-pack/plugins/fleet/server/constants/index.ts

@@ -38,6 +38,7 @@ export {
   PRECONFIGURATION_API_ROUTES,
   DOWNLOAD_SOURCE_API_ROOT,
   DOWNLOAD_SOURCE_API_ROUTES,
+  FLEET_DEBUG_ROUTES,
   // Saved Object indices
   INGEST_SAVED_OBJECT_INDEX,
   // Saved object types

x-pack/plugins/fleet/server/routes/debug/handler.ts

@@ -0,0 +1,47 @@
+/*
+ * 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 type { TypeOf } from '@kbn/config-schema';
+
+import type { FleetRequestHandler } from '../../types';
+import { fetchIndex, fetchSavedObjectNames, fetchSavedObjects } from '../../services/debug';
+import type {
+  FetchIndexRequestSchema,
+  FetchSavedObjectNamesRequestSchema,
+  FetchSavedObjectsRequestSchema,
+} from '../../types/rest_spec/debug';
+
+export const fetchIndexHandler: FleetRequestHandler<
+  undefined,
+  undefined,
+  TypeOf<typeof FetchIndexRequestSchema.body>
+> = async (context, request, response) => {
+  const coreContext = await context.core;
+  const esClient = coreContext.elasticsearch.client.asInternalUser;
+  const res = await fetchIndex(esClient, request.body.index);
+  return response.ok({ body: res });
+};
+
+export const fetchSavedObjectsHandler: FleetRequestHandler<
+  undefined,
+  undefined,
+  TypeOf<typeof FetchSavedObjectsRequestSchema.body>
+> = async (context, request, response) => {
+  const soClient = (await context.fleet).internalSoClient;
+  const res = await fetchSavedObjects(soClient, request.body.type, request.body.name);
+  return response.ok({ body: res });
+};
+
+export const fetchSavedObjectNamesHandler: FleetRequestHandler<
+  undefined,
+  undefined,
+  TypeOf<typeof FetchSavedObjectNamesRequestSchema.body>
+> = async (context, request, response) => {
+  const soClient = (await context.fleet).internalSoClient;
+  const res = await fetchSavedObjectNames(soClient, request.body.type);
+  return response.ok({ body: res });
+};

x-pack/plugins/fleet/server/routes/debug/index.ts

@@ -0,0 +1,73 @@
+/*
+ * 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 type { FleetAuthzRouter } from '../../services/security';
+
+import { FLEET_DEBUG_ROUTES } from '../../constants';
+import { API_VERSIONS } from '../../../common/constants';
+
+import {
+  FetchIndexRequestSchema,
+  FetchSavedObjectNamesRequestSchema,
+  FetchSavedObjectsRequestSchema,
+} from '../../types/rest_spec/debug';
+
+import {
+  fetchIndexHandler,
+  fetchSavedObjectNamesHandler,
+  fetchSavedObjectsHandler,
+} from './handler';
+
+export const registerRoutes = (router: FleetAuthzRouter) => {
+  router.versioned
+    .post({
+      path: FLEET_DEBUG_ROUTES.INDEX_PATTERN,
+      access: 'internal',
+      fleetAuthz: {
+        fleet: { all: true },
+      },
+    })
+    .addVersion(
+      {
+        version: API_VERSIONS.internal.v1,
+        validate: { request: FetchIndexRequestSchema },
+      },
+      fetchIndexHandler
+    );
+
+  router.versioned
+    .post({
+      path: FLEET_DEBUG_ROUTES.SAVED_OBJECTS_PATTERN,
+      access: 'internal',
+      fleetAuthz: {
+        fleet: { all: true },
+      },
+    })
+    .addVersion(
+      {
+        version: API_VERSIONS.internal.v1,
+        validate: { request: FetchSavedObjectsRequestSchema },
+      },
+      fetchSavedObjectsHandler
+    );
+
+  router.versioned
+    .post({
+      path: FLEET_DEBUG_ROUTES.SAVED_OBJECT_NAMES_PATTERN,
+      access: 'internal',
+      fleetAuthz: {
+        fleet: { all: true },
+      },
+    })
+    .addVersion(
+      {
+        version: API_VERSIONS.internal.v1,
+        validate: { request: FetchSavedObjectNamesRequestSchema },
+      },
+      fetchSavedObjectNamesHandler
+    );
+};

x-pack/plugins/fleet/server/routes/index.ts

@@ -26,6 +26,7 @@ import { registerRoutes as registerFleetServerHostRoutes } from './fleet_server_
 import { registerRoutes as registerFleetProxiesRoutes } from './fleet_proxies';
 import { registerRoutes as registerMessageSigningServiceRoutes } from './message_signing_service';
 import { registerRoutes as registerUninstallTokenRoutes } from './uninstall_token';
+import { registerRoutes as registerDebugRoutes } from './debug';
 
 export function registerRoutes(fleetAuthzRouter: FleetAuthzRouter, config: FleetConfigType) {
   // Always register app routes for permissions checking
@@ -47,6 +48,7 @@ export function registerRoutes(fleetAuthzRouter: FleetAuthzRouter, config: Fleet
   registerHealthCheckRoutes(fleetAuthzRouter);
   registerMessageSigningServiceRoutes(fleetAuthzRouter);
   registerUninstallTokenRoutes(fleetAuthzRouter, config);
+  registerDebugRoutes(fleetAuthzRouter);
 
   // Conditional config routes
   if (config.agents.enabled) {

x-pack/plugins/fleet/server/services/debug/index.ts

@@ -0,0 +1,35 @@
+/*
+ * 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 type { ElasticsearchClient, SavedObjectsClientContract } from '@kbn/core/server';
+
+export async function fetchIndex(esClient: ElasticsearchClient, index: string) {
+  return esClient.search({ index });
+}
+
+export async function fetchSavedObjects(
+  soClient: SavedObjectsClientContract,
+  type: string,
+  name: string
+) {
+  return soClient.find({
+    type,
+    search: `\"${name}\"`, // Search for phrase
+    searchFields: ['name'], // SO type automatically inferred
+  });
+}
+
+export async function fetchSavedObjectNames(soClient: SavedObjectsClientContract, type: string) {
+  return soClient.find({
+    type,
+    aggs: {
+      names: {
+        terms: { field: `${type}.attributes.name` }, // cf. SavedObjectsFindOptions definition in packages/core/saved-objects/core-saved-objects-api-server/src/apis/find.ts
+      },
+    },
+  });
+}

x-pack/plugins/fleet/server/types/rest_spec/debug.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 { schema } from '@kbn/config-schema';
+
+export const FetchIndexRequestSchema = {
+  body: schema.object({
+    index: schema.string(),
+  }),
+};
+
+export const FetchSavedObjectsRequestSchema = {
+  body: schema.object({
+    type: schema.string(),
+    name: schema.string(),
+  }),
+};
+
+export const FetchSavedObjectNamesRequestSchema = {
+  body: schema.object({
+    type: schema.string(),
+  }),
+};