moved Legacy Task Manager implementation into the New Platform Plugin

Author: gmmorris

src/core/server/mocks.ts

@@ -37,6 +37,7 @@ export { elasticsearchServiceMock } from './elasticsearch/elasticsearch_service.
 export { httpServiceMock } from './http/http_service.mock';
 export { loggingServiceMock } from './logging/logging_service.mock';
 export { savedObjectsClientMock } from './saved_objects/service/saved_objects_client.mock';
+export { savedObjectsRepositoryMock } from './saved_objects/service/lib/repository.mock';
 export { uiSettingsServiceMock } from './ui_settings/ui_settings_service.mock';
 import { uuidServiceMock } from './uuid/uuid_service.mock';
 

x-pack/legacy/plugins/actions/server/action_type_registry.test.ts

@@ -10,7 +10,7 @@ import { ExecutorType } from './types';
 import { ActionExecutor, ExecutorError, TaskRunnerFactory } from './lib';
 import { configUtilsMock } from './actions_config.mock';
 
-const mockTaskManager = taskManagerMock.create();
+const mockTaskManager = taskManagerMock.setup();
 const actionTypeRegistryParams = {
   taskManager: mockTaskManager,
   taskRunnerFactory: new TaskRunnerFactory(new ActionExecutor()),

x-pack/legacy/plugins/actions/server/action_type_registry.ts

@@ -6,11 +6,14 @@
 
 import Boom from 'boom';
 import { i18n } from '@kbn/i18n';
-import { TaskManagerSetupContract } from './shim';
-import { RunContext } from '../../task_manager/server';
+import {
+  RunContext,
+  TaskManagerSetupContract,
+} from '../../../../plugins/kibana_task_manager/server';
 import { ExecutorError, TaskRunnerFactory } from './lib';
 import { ActionType } from './types';
 import { ActionsConfigurationUtilities } from './actions_config';
+
 interface ConstructorOptions {
   taskManager: TaskManagerSetupContract;
   taskRunnerFactory: TaskRunnerFactory;

x-pack/legacy/plugins/actions/server/actions_client.test.ts

@@ -23,7 +23,7 @@ const defaultKibanaIndex = '.kibana';
 const savedObjectsClient = savedObjectsClientMock.create();
 const scopedClusterClient = elasticsearchServiceMock.createScopedClusterClient();
 
-const mockTaskManager = taskManagerMock.create();
+const mockTaskManager = taskManagerMock.setup();
 
 const actionTypeRegistryParams = {
   taskManager: mockTaskManager,

x-pack/legacy/plugins/actions/server/builtin_action_types/index.test.ts

@@ -20,7 +20,7 @@ export function createActionTypeRegistry(): {
 } {
   const logger = loggingServiceMock.create().get() as jest.Mocked<Logger>;
   const actionTypeRegistry = new ActionTypeRegistry({
-    taskManager: taskManagerMock.create(),
+    taskManager: taskManagerMock.setup(),
     taskRunnerFactory: new TaskRunnerFactory(new ActionExecutor()),
     actionsConfigUtils: configUtilsMock,
   });

x-pack/legacy/plugins/actions/server/create_execute_function.ts

@@ -5,7 +5,7 @@
  */
 
 import { SavedObjectsClientContract } from 'src/core/server';
-import { TaskManagerStartContract } from './shim';
+import { TaskManagerStartContract } from '../../../../plugins/kibana_task_manager/server';
 import { GetBasePathFunction } from './types';
 
 interface CreateExecuteFunctionOptions {

x-pack/legacy/plugins/actions/server/lib/task_runner_factory.test.ts

@@ -7,7 +7,10 @@
 import sinon from 'sinon';
 import { ExecutorError } from './executor_error';
 import { ActionExecutor } from './action_executor';
-import { ConcreteTaskInstance, TaskStatus } from '../../../task_manager/server';
+import {
+  ConcreteTaskInstance,
+  TaskStatus,
+} from '../../../../../plugins/kibana_task_manager/server';
 import { TaskRunnerFactory } from './task_runner_factory';
 import { actionTypeRegistryMock } from '../action_type_registry.mock';
 import { actionExecutorMock } from './action_executor.mock';

x-pack/legacy/plugins/actions/server/lib/task_runner_factory.ts

@@ -6,7 +6,7 @@
 
 import { ActionExecutorContract } from './action_executor';
 import { ExecutorError } from './executor_error';
-import { RunContext } from '../../../task_manager/server';
+import { RunContext } from '../../../../../plugins/kibana_task_manager/server';
 import { PluginStartContract as EncryptedSavedObjectsStartContract } from '../../../../../plugins/encrypted_saved_objects/server';
 import { ActionTaskParams, GetBasePathFunction, SpaceIdToNamespaceFunction } from '../types';
 

x-pack/legacy/plugins/actions/server/shim.ts

@@ -8,7 +8,10 @@ import Hapi from 'hapi';
 import { Legacy } from 'kibana';
 import * as Rx from 'rxjs';
 import { ActionsConfigType } from './types';
-import { TaskManager } from '../../task_manager/server';
+import {
+  TaskManagerStartContract,
+  TaskManagerSetupContract,
+} from '../../../../plugins/kibana_task_manager/server';
 import { XPackMainPlugin } from '../../xpack_main/server/xpack_main';
 import KbnServer from '../../../../../src/legacy/server/kbn_server';
 import { LegacySpacesPlugin as SpacesPluginStartContract } from '../../spaces';
@@ -27,7 +30,7 @@ import { LicensingPluginSetup } from '../../../../plugins/licensing/server';
 // Extend PluginProperties to indicate which plugins are guaranteed to exist
 // due to being marked as dependencies
 interface Plugins extends Hapi.PluginProperties {
-  task_manager: TaskManager;
+  task_manager: TaskManagerStartContract & TaskManagerSetupContract;
 }
 
 export interface Server extends Legacy.Server {
@@ -41,14 +44,9 @@ export interface KibanaConfig {
 /**
  * Shim what we're thinking setup and start contracts will look like
  */
-export type TaskManagerStartContract = Pick<TaskManager, 'schedule' | 'fetch' | 'remove'>;
 export type XPackMainPluginSetupContract = Pick<XPackMainPlugin, 'registerFeature'>;
 export type SecurityPluginSetupContract = Pick<SecurityPlugin, '__legacyCompat'>;
 export type SecurityPluginStartContract = Pick<SecurityPlugin, 'authc'>;
-export type TaskManagerSetupContract = Pick<
-  TaskManager,
-  'addMiddleware' | 'registerTaskDefinitions'
->;
 
 /**
  * New platform interfaces

x-pack/legacy/plugins/alerting/server/alert_type_registry.test.ts

@@ -8,8 +8,7 @@ import { TaskRunnerFactory } from './task_runner';
 import { AlertTypeRegistry } from './alert_type_registry';
 import { taskManagerMock } from '../../task_manager/server/task_manager.mock';
 
-const taskManager = taskManagerMock.create();
-
+const taskManager = taskManagerMock.setup();
 const alertTypeRegistryParams = {
   taskManager,
   taskRunnerFactory: new TaskRunnerFactory(),