Add globalSearch x-pack plugin

.eslintrc.js

@@ -220,7 +220,7 @@ module.exports = {
                   '!src/core/server/index.ts', // relative import
                   '!src/core/server/mocks{,.ts}',
                   '!src/core/server/types{,.ts}',
-                  '!src/core/server/test_utils',
+                  '!src/core/server/test_utils{,.ts}',
                   // for absolute imports until fixed in
                   // https://github.com/elastic/kibana/issues/36096
                   '!src/core/server/*.test.mocks{,.ts}',

.github/CODEOWNERS

@@ -139,6 +139,7 @@
 /config/kibana.yml @elastic/kibana-platform
 /x-pack/plugins/features/  @elastic/kibana-platform
 /x-pack/plugins/licensing/  @elastic/kibana-platform
+/x-pack/plugins/global_search/  @elastic/kibana-platform
 /x-pack/plugins/cloud/ @elastic/kibana-platform
 /packages/kbn-config-schema/ @elastic/kibana-platform
 /src/legacy/server/config/ @elastic/kibana-platform

src/core/server/saved_objects/routes/integration_tests/bulk_create.test.ts

@@ -21,7 +21,7 @@ import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
 import { registerBulkCreateRoute } from '../bulk_create';
 import { savedObjectsClientMock } from '../../../../../core/server/mocks';
-import { setupServer } from './test_utils';
+import { setupServer } from '../test_utils';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;
 

src/core/server/saved_objects/routes/integration_tests/bulk_get.test.ts

@@ -21,7 +21,7 @@ import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
 import { registerBulkGetRoute } from '../bulk_get';
 import { savedObjectsClientMock } from '../../../../../core/server/mocks';
-import { setupServer } from './test_utils';
+import { setupServer } from '../test_utils';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;
 

src/core/server/saved_objects/routes/integration_tests/bulk_update.test.ts

@@ -21,7 +21,7 @@ import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
 import { registerBulkUpdateRoute } from '../bulk_update';
 import { savedObjectsClientMock } from '../../../../../core/server/mocks';
-import { setupServer } from './test_utils';
+import { setupServer } from '../test_utils';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;
 

src/core/server/saved_objects/routes/integration_tests/create.test.ts

@@ -21,7 +21,7 @@ import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
 import { registerCreateRoute } from '../create';
 import { savedObjectsClientMock } from '../../service/saved_objects_client.mock';
-import { setupServer } from './test_utils';
+import { setupServer } from '../test_utils';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;
 

src/core/server/saved_objects/routes/integration_tests/delete.test.ts

@@ -21,7 +21,7 @@ import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
 import { registerDeleteRoute } from '../delete';
 import { savedObjectsClientMock } from '../../../../../core/server/mocks';
-import { setupServer } from './test_utils';
+import { setupServer } from '../test_utils';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;
 

src/core/server/saved_objects/routes/integration_tests/export.test.ts

@@ -27,7 +27,7 @@ import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
 import { SavedObjectConfig } from '../../saved_objects_config';
 import { registerExportRoute } from '../export';
-import { setupServer, createExportableType } from './test_utils';
+import { setupServer, createExportableType } from '../test_utils';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;
 const exportSavedObjectsToStream = exportMock.exportSavedObjectsToStream as jest.Mock;

src/core/server/saved_objects/routes/integration_tests/find.test.ts

@@ -23,7 +23,7 @@ import querystring from 'querystring';
 import { UnwrapPromise } from '@kbn/utility-types';
 import { registerFindRoute } from '../find';
 import { savedObjectsClientMock } from '../../../../../core/server/mocks';
-import { setupServer } from './test_utils';
+import { setupServer } from '../test_utils';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;
 

src/core/server/saved_objects/routes/integration_tests/import.test.ts

@@ -22,7 +22,7 @@ import { UnwrapPromise } from '@kbn/utility-types';
 import { registerImportRoute } from '../import';
 import { savedObjectsClientMock } from '../../../../../core/server/mocks';
 import { SavedObjectConfig } from '../../saved_objects_config';
-import { setupServer, createExportableType } from './test_utils';
+import { setupServer, createExportableType } from '../test_utils';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;
 

src/core/server/saved_objects/routes/integration_tests/log_legacy_import.test.ts

@@ -21,7 +21,7 @@ import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
 import { registerLogLegacyImportRoute } from '../log_legacy_import';
 import { loggingServiceMock } from '../../../logging/logging_service.mock';
-import { setupServer } from './test_utils';
+import { setupServer } from '../test_utils';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;
 

src/core/server/saved_objects/routes/integration_tests/resolve_import_errors.test.ts

@@ -21,7 +21,7 @@ import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
 import { registerResolveImportErrorsRoute } from '../resolve_import_errors';
 import { savedObjectsClientMock } from '../../../../../core/server/mocks';
-import { setupServer, createExportableType } from './test_utils';
+import { setupServer, createExportableType } from '../test_utils';
 import { SavedObjectConfig } from '../../saved_objects_config';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;

src/core/server/saved_objects/routes/integration_tests/update.test.ts

@@ -21,7 +21,7 @@ import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
 import { registerUpdateRoute } from '../update';
 import { savedObjectsClientMock } from '../../../../../core/server/mocks';
-import { setupServer } from './test_utils';
+import { setupServer } from '../test_utils';
 
 type setupServerReturn = UnwrapPromise<ReturnType<typeof setupServer>>;
 

src/core/server/saved_objects/routes/integration_tests/test_utils.ts → src/core/server/saved_objects/routes/test_utils.ts

@@ -17,14 +17,14 @@
  * under the License.
  */
 
-import { ContextService } from '../../../context';
-import { createHttpServer, createCoreContext } from '../../../http/test_utils';
-import { coreMock } from '../../../mocks';
-import { SavedObjectsType } from '../../types';
+import { ContextService } from '../../context';
+import { createHttpServer, createCoreContext } from '../../http/test_utils';
+import { coreMock } from '../../mocks';
+import { SavedObjectsType } from '../types';
 
-const coreId = Symbol('core');
+const defaultCoreId = Symbol('core');
 
-export const setupServer = async () => {
+export const setupServer = async (coreId: symbol = defaultCoreId) => {
   const coreContext = createCoreContext({ coreId });
   const contextService = new ContextService(coreContext);
 

src/core/server/test_utils.ts

@@ -19,3 +19,4 @@
 
 export { createHttpServer } from './http/test_utils';
 export { ServiceStatusLevelSnapshotSerializer } from './status/test_utils';
+export { setupServer } from './saved_objects/routes/test_utils';

src/core/types/index.ts

@@ -26,3 +26,4 @@ export * from './capabilities';
 export * from './app_category';
 export * from './ui_settings';
 export * from './saved_objects';
+export * from './serializable';

src/core/types/serializable.ts

@@ -0,0 +1,32 @@
+/*
+ * Licensed to Elasticsearch B.V. under one or more contributor
+ * license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright
+ * ownership. Elasticsearch B.V. licenses this file to you under
+ * the Apache License, Version 2.0 (the "License"); you may
+ * not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+export type Serializable =
+  | string
+  | number
+  | boolean
+  | null
+  | SerializableArray
+  | SerializableRecord;
+
+// we need interfaces instead of types here to allow cyclic references
+// eslint-disable-next-line @typescript-eslint/no-empty-interface
+export interface SerializableArray extends Array<Serializable> {}
+// eslint-disable-next-line @typescript-eslint/no-empty-interface
+export interface SerializableRecord extends Record<string, Serializable> {}

x-pack/.i18nrc.json

@@ -18,6 +18,7 @@
     "xpack.endpoint": "plugins/endpoint",
     "xpack.features": "plugins/features",
     "xpack.fileUpload": "plugins/file_upload",
+    "xpack.globalSearch": ["plugins/global_search"],
     "xpack.graph": ["plugins/graph"],
     "xpack.grokDebugger": "plugins/grokdebugger",
     "xpack.idxMgmt": "plugins/index_management",

x-pack/legacy/plugins/reporting/server/routes/generation.test.ts

@@ -6,8 +6,7 @@
 
 import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
-// eslint-disable-next-line @kbn/eslint/no-restricted-paths
-import { setupServer } from 'src/core/server/saved_objects/routes/integration_tests/test_utils';
+import { setupServer } from 'src/core/server/test_utils';
 import { registerJobGenerationRoutes } from './generation';
 import { createMockReportingCore } from '../../test_helpers';
 import { ReportingCore } from '..';

x-pack/legacy/plugins/reporting/server/routes/jobs.test.ts

@@ -6,8 +6,7 @@
 
 import supertest from 'supertest';
 import { UnwrapPromise } from '@kbn/utility-types';
-// eslint-disable-next-line @kbn/eslint/no-restricted-paths
-import { setupServer } from 'src/core/server/saved_objects/routes/integration_tests/test_utils';
+import { setupServer } from 'src/core/server/test_utils';
 import { registerJobInfoRoutes } from './jobs';
 import { createMockReportingCore } from '../../test_helpers';
 import { ReportingCore } from '..';

x-pack/plugins/global_search/common/errors.test.ts

@@ -0,0 +1,22 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { GlobalSearchFindError } from './errors';
+
+describe('GlobalSearchFindError', () => {
+  describe('#invalidLicense', () => {
+    it('create an error with the correct `type`', () => {
+      const error = GlobalSearchFindError.invalidLicense('foobar');
+      expect(error.message).toBe('foobar');
+      expect(error.type).toBe('invalid-license');
+    });
+
+    it('can be identified via instanceof', () => {
+      const error = GlobalSearchFindError.invalidLicense('foo');
+      expect(error instanceof GlobalSearchFindError).toBe(true);
+    });
+  });
+});

x-pack/plugins/global_search/common/errors.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;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+// only one type for now, but already present for future-proof reasons
+export type GlobalSearchFindErrorType = 'invalid-license';
+
+/**
+ * Error thrown from the {@link GlobalSearchPluginStart.find | GlobalSearch find API}'s result observable
+ *
+ * @public
+ */
+export class GlobalSearchFindError extends Error {
+  public static invalidLicense(message: string) {
+    return new GlobalSearchFindError('invalid-license', message);
+  }
+
+  private constructor(public readonly type: GlobalSearchFindErrorType, message: string) {
+    super(message);
+
+    // Set the prototype explicitly, see:
+    // https://github.com/Microsoft/TypeScript/wiki/Breaking-Changes#extending-built-ins-like-error-array-and-map-may-no-longer-work
+    Object.setPrototypeOf(this, GlobalSearchFindError.prototype);
+  }
+}

x-pack/plugins/global_search/common/license_checker.mock.ts

@@ -0,0 +1,24 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { ILicenseChecker } from './license_checker';
+
+const createLicenseCheckerMock = (): jest.Mocked<ILicenseChecker> => {
+  const mock = {
+    getState: jest.fn(),
+    getLicense: jest.fn(),
+    clean: jest.fn(),
+  };
+
+  mock.getLicense.mockReturnValue(undefined);
+  mock.getState.mockReturnValue({ valid: true });
+
+  return mock;
+};
+
+export const licenseCheckerMock = {
+  create: createLicenseCheckerMock,
+};

x-pack/plugins/global_search/common/license_checker.test.ts

@@ -0,0 +1,63 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { Observable, of, BehaviorSubject } from 'rxjs';
+import { licenseMock } from '../../licensing/common/licensing.mock';
+import { ILicense, LicenseCheck } from '../../licensing/common/types';
+import { LicenseChecker } from './license_checker';
+
+describe('LicenseChecker', () => {
+  const createLicense = (check: LicenseCheck): ILicense => {
+    const license = licenseMock.createLicenseMock();
+    license.check.mockReturnValue(check);
+    return license;
+  };
+
+  const createLicense$ = (check: LicenseCheck): Observable<ILicense> => of(createLicense(check));
+
+  it('returns the correct state of the license', () => {
+    let checker = new LicenseChecker(createLicense$({ state: 'valid' }));
+    expect(checker.getState()).toEqual({ valid: true });
+
+    checker = new LicenseChecker(createLicense$({ state: 'expired' }));
+    expect(checker.getState()).toEqual({ valid: false, message: 'expired' });
+
+    checker = new LicenseChecker(createLicense$({ state: 'invalid' }));
+    expect(checker.getState()).toEqual({ valid: false, message: 'invalid' });
+
+    checker = new LicenseChecker(createLicense$({ state: 'unavailable' }));
+    expect(checker.getState()).toEqual({ valid: false, message: 'unavailable' });
+  });
+
+  it('updates the state when the license changes', () => {
+    const license$ = new BehaviorSubject<ILicense>(createLicense({ state: 'valid' }));
+
+    const checker = new LicenseChecker(license$);
+    expect(checker.getState()).toEqual({ valid: true });
+
+    license$.next(createLicense({ state: 'expired' }));
+    expect(checker.getState()).toEqual({ valid: false, message: 'expired' });
+
+    license$.next(createLicense({ state: 'valid' }));
+    expect(checker.getState()).toEqual({ valid: true });
+  });
+
+  it('removes the subscription when calling `clean`', () => {
+    const mockUnsubscribe = jest.fn();
+    const mockObs = {
+      subscribe: jest.fn().mockReturnValue({ unsubscribe: mockUnsubscribe }),
+    };
+
+    const checker = new LicenseChecker(mockObs as any);
+
+    expect(mockObs.subscribe).toHaveBeenCalledTimes(1);
+    expect(mockUnsubscribe).not.toHaveBeenCalled();
+
+    checker.clean();
+
+    expect(mockUnsubscribe).toHaveBeenCalledTimes(1);
+  });
+});

x-pack/plugins/global_search/common/license_checker.ts

@@ -0,0 +1,49 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { Observable, Subscription } from 'rxjs';
+import { ILicense } from '../../licensing/common/types';
+
+export type LicenseState = { valid: false; message: string } | { valid: true };
+
+export type CheckLicense = (license: ILicense) => LicenseState;
+
+const checkLicense: CheckLicense = (license) => {
+  const check = license.check('globalSearch', 'basic');
+  switch (check.state) {
+    case 'expired':
+      return { valid: false, message: 'expired' };
+    case 'invalid':
+      return { valid: false, message: 'invalid' };
+    case 'unavailable':
+      return { valid: false, message: 'unavailable' };
+    case 'valid':
+      return { valid: true };
+    default:
+      throw new Error(`Invalid license state: ${check.state}`);
+  }
+};
+
+export type ILicenseChecker = PublicMethodsOf<LicenseChecker>;
+
+export class LicenseChecker {
+  private subscription: Subscription;
+  private state: LicenseState = { valid: false, message: 'unknown' };
+
+  constructor(license$: Observable<ILicense>) {
+    this.subscription = license$.subscribe((license) => {
+      this.state = checkLicense(license);
+    });
+  }
+
+  public getState() {
+    return this.state;
+  }
+
+  public clean() {
+    this.subscription.unsubscribe();
+  }
+}