[App Search] Schema: Set up server routes, grand foray into shared/connected Kea logic

x-pack/plugins/enterprise_search/public/applications/app_search/components/schema/types.ts

@@ -0,0 +1,30 @@
+/*
+ * 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,
+  IndexJob,
+  SchemaConflicts,
+  FieldCoercionErrors,
+} from '../../../shared/schema/types';
+
+export interface SchemaApiResponse {
+  schema: Schema;
+  mostRecentIndexJob: IndexJob;
+  unconfirmedFields: string[];
+  unsearchedUnconfirmedFields: boolean;
+}
+
+export interface MetaEngineSchemaApiResponse {
+  schema: Schema;
+  fields: SchemaConflicts;
+  conflictingFields: SchemaConflicts;
+}
+
+export interface ReindexJobApiResponse {
+  fieldCoercionErrors: FieldCoercionErrors;
+}

x-pack/plugins/enterprise_search/server/routes/app_search/index.ts

@@ -16,6 +16,7 @@ import { registerEnginesRoutes } from './engines';
 import { registerOnboardingRoutes } from './onboarding';
 import { registerResultSettingsRoutes } from './result_settings';
 import { registerRoleMappingsRoutes } from './role_mappings';
+import { registerSchemaRoutes } from './schema';
 import { registerSearchSettingsRoutes } from './search_settings';
 import { registerSearchUIRoutes } from './search_ui';
 import { registerSettingsRoutes } from './settings';
@@ -28,6 +29,7 @@ export const registerAppSearchRoutes = (dependencies: RouteDependencies) => {
   registerAnalyticsRoutes(dependencies);
   registerDocumentsRoutes(dependencies);
   registerDocumentRoutes(dependencies);
+  registerSchemaRoutes(dependencies);
   registerCurationsRoutes(dependencies);
   registerSynonymsRoutes(dependencies);
   registerSearchSettingsRoutes(dependencies);

x-pack/plugins/enterprise_search/server/routes/app_search/schema.test.ts

@@ -0,0 +1,81 @@
+/*
+ * 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 { MockRouter, mockRequestHandler, mockDependencies } from '../../__mocks__';
+
+import { registerSchemaRoutes } from './schema';
+
+describe('schema routes', () => {
+  describe('GET /api/app_search/engines/{engineName}/schema', () => {
+    let mockRouter: MockRouter;
+
+    beforeEach(() => {
+      jest.clearAllMocks();
+      mockRouter = new MockRouter({
+        method: 'get',
+        path: '/api/app_search/engines/{engineName}/schema',
+      });
+
+      registerSchemaRoutes({
+        ...mockDependencies,
+        router: mockRouter.router,
+      });
+    });
+
+    it('creates a request handler', () => {
+      expect(mockRequestHandler.createRequest).toHaveBeenCalledWith({
+        path: '/as/engines/:engineName/schema',
+      });
+    });
+  });
+
+  describe('POST /api/app_search/engines/{engineName}/schema', () => {
+    let mockRouter: MockRouter;
+
+    beforeEach(() => {
+      jest.clearAllMocks();
+      mockRouter = new MockRouter({
+        method: 'post',
+        path: '/api/app_search/engines/{engineName}/schema',
+      });
+
+      registerSchemaRoutes({
+        ...mockDependencies,
+        router: mockRouter.router,
+      });
+    });
+
+    it('creates a request handler', () => {
+      expect(mockRequestHandler.createRequest).toHaveBeenCalledWith({
+        path: '/as/engines/:engineName/schema',
+      });
+    });
+  });
+
+  describe('GET /api/app_search/engines/{engineName}/reindex_job/{reindexJobId}', () => {
+    let mockRouter: MockRouter;
+
+    beforeEach(() => {
+      jest.clearAllMocks();
+      mockRouter = new MockRouter({
+        method: 'get',
+        path: '/api/app_search/engines/{engineName}/reindex_job/{reindexJobId}',
+      });
+
+      registerSchemaRoutes({
+        ...mockDependencies,
+        router: mockRouter.router,
+      });
+    });
+
+    it('creates a request handler', () => {
+      expect(mockRequestHandler.createRequest).toHaveBeenCalledWith({
+        path: '/as/engines/:engineName/reindex_job/:reindexJobId',
+      });
+    });
+  });
+});

x-pack/plugins/enterprise_search/server/routes/app_search/schema.ts

@@ -0,0 +1,59 @@
+/*
+ * 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';
+
+import { skipBodyValidation } from '../../lib/route_config_helpers';
+import { RouteDependencies } from '../../plugin';
+
+export function registerSchemaRoutes({
+  router,
+  enterpriseSearchRequestHandler,
+}: RouteDependencies) {
+  router.get(
+    {
+      path: '/api/app_search/engines/{engineName}/schema',
+      validate: {
+        params: schema.object({
+          engineName: schema.string(),
+        }),
+      },
+    },
+    enterpriseSearchRequestHandler.createRequest({
+      path: '/as/engines/:engineName/schema',
+    })
+  );
+
+  router.post(
+    skipBodyValidation({
+      path: '/api/app_search/engines/{engineName}/schema',
+      validate: {
+        params: schema.object({
+          engineName: schema.string(),
+        }),
+      },
+    }),
+    enterpriseSearchRequestHandler.createRequest({
+      path: '/as/engines/:engineName/schema',
+    })
+  );
+
+  router.get(
+    {
+      path: '/api/app_search/engines/{engineName}/reindex_job/{reindexJobId}',
+      validate: {
+        params: schema.object({
+          engineName: schema.string(),
+          reindexJobId: schema.string(),
+        }),
+      },
+    },
+    enterpriseSearchRequestHandler.createRequest({
+      path: '/as/engines/:engineName/reindex_job/:reindexJobId',
+    })
+  );
+}