Fix init

x-pack/plugins/actions/server/builtin_action_types/resilient/index.ts

@@ -4,21 +4,98 @@
  * you may not use this file except in compliance with the Elastic License.
  */
 
-import { createConnector } from '../case/utils';
+import { curry } from 'lodash';
+import { schema } from '@kbn/config-schema';
 
-import { api } from './api';
-import { config } from './config';
 import { validate } from './validators';
+import {
+  ExternalIncidentServiceConfiguration,
+  ExternalIncidentServiceSecretConfiguration,
+  ExecutorParamsSchema,
+} from './schema';
+import { ActionsConfigurationUtilities } from '../../actions_config';
+import { ActionType, ActionTypeExecutorOptions, ActionTypeExecutorResult } from '../../types';
 import { createExternalService } from './service';
-import { ResilientSecretConfiguration, ResilientPublicConfiguration } from './schema';
-
-export const getActionType = createConnector({
-  api,
-  config,
-  validate,
-  createExternalService,
-  validationSchema: {
-    config: ResilientPublicConfiguration,
-    secrets: ResilientSecretConfiguration,
-  },
-});
+import { api } from './api';
+import { ExecutorParams, ExecutorSubActionPushParams } from './types';
+import * as i18n from './translations';
+import { Logger } from '../../../../../../src/core/server';
+
+// TODO: to remove, need to support Case
+import { buildMap, mapParams } from '../case/utils';
+import { PushToServiceResponse } from './case_types';
+
+interface GetActionTypeParams {
+  logger: Logger;
+  configurationUtilities: ActionsConfigurationUtilities;
+}
+
+// action type definition
+export function getActionType(params: GetActionTypeParams): ActionType {
+  const { logger, configurationUtilities } = params;
+  return {
+    id: '.resilient',
+    minimumLicenseRequired: 'platinum',
+    name: i18n.NAME,
+    validate: {
+      config: schema.object(ExternalIncidentServiceConfiguration, {
+        validate: curry(validate.config)(configurationUtilities),
+      }),
+      secrets: schema.object(ExternalIncidentServiceSecretConfiguration, {
+        validate: curry(validate.secrets)(configurationUtilities),
+      }),
+      params: ExecutorParamsSchema,
+    },
+    executor: curry(executor)({ logger }),
+  };
+}
+
+// action executor
+async function executor(
+  { logger }: { logger: Logger },
+  execOptions: ActionTypeExecutorOptions
+): Promise<ActionTypeExecutorResult> {
+  const { actionId, config, params, secrets } = execOptions;
+  const { subAction, subActionParams } = params as ExecutorParams;
+  let data: PushToServiceResponse | null = null;
+
+  const externalService = createExternalService({
+    config,
+    secrets,
+  });
+
+  if (!api[subAction]) {
+    const errorMessage = `[Action][ExternalService] Unsupported subAction type ${subAction}.`;
+    logger.error(errorMessage);
+    throw new Error(errorMessage);
+  }
+
+  if (subAction !== 'pushToService') {
+    const errorMessage = `[Action][ExternalService] subAction ${subAction} not implemented.`;
+    logger.error(errorMessage);
+    throw new Error(errorMessage);
+  }
+
+  if (subAction === 'pushToService') {
+    const pushToServiceParams = subActionParams as ExecutorSubActionPushParams;
+
+    const { comments, externalId, ...restParams } = pushToServiceParams;
+    const mapping = config.incidentConfiguration
+      ? buildMap(config.incidentConfiguration.mapping)
+      : null;
+    const externalObject =
+      config.incidentConfiguration && mapping ? mapParams(restParams, mapping) : {};
+
+    data = await api.pushToService({
+      externalService,
+      mapping,
+      params: { ...pushToServiceParams, externalObject },
+      secrets,
+      logger,
+    });
+
+    logger.debug(`response push to service for incident id: ${data.id}`);
+  }
+
+  return { status: 'ok', data: data ?? {}, actionId };
+}