Define minimum license required for each action type

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

@@ -31,6 +31,7 @@ describe('register()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     expect(actionTypeRegistry.has('my-action-type')).toEqual(true);
@@ -55,12 +56,14 @@ describe('register()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     expect(() =>
       actionTypeRegistry.register({
         id: 'my-action-type',
         name: 'My action type',
+        minimumLicenseRequired: 'basic',
         executor,
       })
     ).toThrowErrorMatchingInlineSnapshot(
@@ -73,6 +76,7 @@ describe('register()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     expect(mockTaskManager.registerTaskDefinitions).toHaveBeenCalledTimes(1);
@@ -94,13 +98,15 @@ describe('get()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     const actionType = actionTypeRegistry.get('my-action-type');
     expect(actionType).toMatchInlineSnapshot(`
       Object {
         "executor": [Function],
         "id": "my-action-type",
+        "minimumLicenseRequired": "basic",
         "name": "My action type",
       }
     `);
@@ -120,6 +126,7 @@ describe('list()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     const actionTypes = actionTypeRegistry.list();
@@ -144,6 +151,7 @@ describe('has()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     expect(actionTypeRegistry.has('my-action-type'));

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

@@ -65,6 +65,7 @@ describe('create()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     savedObjectsClient.create.mockResolvedValueOnce(savedObjectCreateResult);
@@ -100,6 +101,7 @@ describe('create()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       validate: {
         config: schema.object({
           param1: schema.string(),
@@ -140,6 +142,7 @@ describe('create()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     savedObjectsClient.create.mockResolvedValueOnce({
@@ -233,6 +236,7 @@ describe('create()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     savedObjectsClient.create.mockResolvedValueOnce(savedObjectCreateResult);
@@ -346,6 +350,7 @@ describe('update()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     savedObjectsClient.get.mockResolvedValueOnce({
@@ -407,6 +412,7 @@ describe('update()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       validate: {
         config: schema.object({
           param1: schema.string(),
@@ -440,6 +446,7 @@ describe('update()', () => {
     actionTypeRegistry.register({
       id: 'my-action-type',
       name: 'My action type',
+      minimumLicenseRequired: 'basic',
       executor,
     });
     savedObjectsClient.get.mockResolvedValueOnce({

x-pack/plugins/actions/server/builtin_action_types/email.ts

@@ -118,6 +118,7 @@ export function getActionType(params: GetActionTypeParams): ActionType {
   const { logger, configurationUtilities } = params;
   return {
     id: '.email',
+    minimumLicenseRequired: 'gold',
     name: i18n.translate('xpack.actions.builtin.emailTitle', {
       defaultMessage: 'Email',
     }),

x-pack/plugins/actions/server/builtin_action_types/es_index.ts

@@ -38,6 +38,7 @@ const ParamsSchema = schema.object({
 export function getActionType({ logger }: { logger: Logger }): ActionType {
   return {
     id: '.index',
+    minimumLicenseRequired: 'basic',
     name: i18n.translate('xpack.actions.builtin.esIndexTitle', {
       defaultMessage: 'Index',
     }),

x-pack/plugins/actions/server/builtin_action_types/pagerduty.ts

@@ -96,6 +96,7 @@ export function getActionType({
 }): ActionType {
   return {
     id: '.pagerduty',
+    minimumLicenseRequired: 'gold',
     name: i18n.translate('xpack.actions.builtin.pagerdutyTitle', {
       defaultMessage: 'PagerDuty',
     }),

x-pack/plugins/actions/server/builtin_action_types/server_log.ts

@@ -35,6 +35,7 @@ const ParamsSchema = schema.object({
 export function getActionType({ logger }: { logger: Logger }): ActionType {
   return {
     id: '.server-log',
+    minimumLicenseRequired: 'basic',
     name: i18n.translate('xpack.actions.builtin.serverLogTitle', {
       defaultMessage: 'Server log',
     }),

x-pack/plugins/actions/server/builtin_action_types/servicenow.ts

@@ -89,6 +89,7 @@ export function getActionType({
 }): ActionType {
   return {
     id: '.servicenow',
+    minimumLicenseRequired: 'gold',
     name: i18n.translate('xpack.actions.builtin.servicenowTitle', {
       defaultMessage: 'ServiceNow',
     }),

x-pack/plugins/actions/server/builtin_action_types/slack.ts

@@ -50,6 +50,7 @@ export function getActionType({
 }): ActionType {
   return {
     id: '.slack',
+    minimumLicenseRequired: 'gold',
     name: i18n.translate('xpack.actions.builtin.slackTitle', {
       defaultMessage: 'Slack',
     }),

x-pack/plugins/actions/server/builtin_action_types/webhook.ts

@@ -66,6 +66,7 @@ export function getActionType({
 }): ActionType {
   return {
     id: '.webhook',
+    minimumLicenseRequired: 'gold',
     name: i18n.translate('xpack.actions.builtin.webhookTitle', {
       defaultMessage: 'Webhook',
     }),

x-pack/plugins/actions/server/lib/action_executor.test.ts

@@ -12,6 +12,7 @@ import { encryptedSavedObjectsMock } from '../../../encrypted_saved_objects/serv
 import { savedObjectsClientMock, loggingServiceMock } from '../../../../../src/core/server/mocks';
 import { eventLoggerMock } from '../../../event_log/server/mocks';
 import { spacesServiceMock } from '../../../spaces/server/spaces_service/spaces_service.mock';
+import { LicenseType } from '../../../licensing/common/types';
 
 const actionExecutor = new ActionExecutor({ isESOUsingEphemeralEncryptionKey: false });
 const savedObjectsClient = savedObjectsClientMock.create();
@@ -53,6 +54,7 @@ test('successfully executes', async () => {
   const actionType = {
     id: 'test',
     name: 'Test',
+    minimumLicenseRequired: 'basic' as LicenseType,
     executor: jest.fn(),
   };
   const actionSavedObject = {
@@ -99,6 +101,7 @@ test('provides empty config when config and / or secrets is empty', async () =>
   const actionType = {
     id: 'test',
     name: 'Test',
+    minimumLicenseRequired: 'basic' as LicenseType,
     executor: jest.fn(),
   };
   const actionSavedObject = {
@@ -123,6 +126,7 @@ test('throws an error when config is invalid', async () => {
   const actionType = {
     id: 'test',
     name: 'Test',
+    minimumLicenseRequired: 'basic' as LicenseType,
     validate: {
       config: schema.object({
         param1: schema.string(),
@@ -155,6 +159,7 @@ test('throws an error when params is invalid', async () => {
   const actionType = {
     id: 'test',
     name: 'Test',
+    minimumLicenseRequired: 'basic' as LicenseType,
     validate: {
       params: schema.object({
         param1: schema.string(),
@@ -194,6 +199,7 @@ test('returns an error if actionType is not enabled', async () => {
   const actionType = {
     id: 'test',
     name: 'Test',
+    minimumLicenseRequired: 'basic' as LicenseType,
     executor: jest.fn(),
   };
   const actionSavedObject = {

x-pack/plugins/actions/server/lib/validate_with_schema.test.ts

@@ -14,15 +14,26 @@ const executor: ExecutorType = async options => {
 };
 
 test('should validate when there are no validators', () => {
-  const actionType: ActionType = { id: 'foo', name: 'bar', executor };
+  const actionType: ActionType = {
+    id: 'foo',
+    name: 'bar',
+    minimumLicenseRequired: 'basic',
+    executor,
+  };
   const testValue = { any: ['old', 'thing'] };
 
   const result = validateConfig(actionType, testValue);
   expect(result).toEqual(testValue);
 });
 
 test('should validate when there are no individual validators', () => {
-  const actionType: ActionType = { id: 'foo', name: 'bar', executor, validate: {} };
+  const actionType: ActionType = {
+    id: 'foo',
+    name: 'bar',
+    minimumLicenseRequired: 'basic',
+    executor,
+    validate: {},
+  };
 
   let result;
   const testValue = { any: ['old', 'thing'] };
@@ -42,6 +53,7 @@ test('should validate when validators return incoming value', () => {
   const actionType: ActionType = {
     id: 'foo',
     name: 'bar',
+    minimumLicenseRequired: 'basic',
     executor,
     validate: {
       params: selfValidator,
@@ -69,6 +81,7 @@ test('should validate when validators return different values', () => {
   const actionType: ActionType = {
     id: 'foo',
     name: 'bar',
+    minimumLicenseRequired: 'basic',
     executor,
     validate: {
       params: selfValidator,
@@ -99,6 +112,7 @@ test('should throw with expected error when validators fail', () => {
   const actionType: ActionType = {
     id: 'foo',
     name: 'bar',
+    minimumLicenseRequired: 'basic',
     executor,
     validate: {
       params: erroringValidator,
@@ -127,6 +141,7 @@ test('should work with @kbn/config-schema', () => {
   const actionType: ActionType = {
     id: 'foo',
     name: 'bar',
+    minimumLicenseRequired: 'basic',
     executor,
     validate: {
       params: testSchema,

x-pack/plugins/actions/server/plugin.test.ts

@@ -4,13 +4,19 @@
  * you may not use this file except in compliance with the Elastic License.
  */
 
-import { ActionsPlugin, ActionsPluginsSetup, ActionsPluginsStart } from './plugin';
 import { PluginInitializerContext } from '../../../../src/core/server';
 import { coreMock, httpServerMock } from '../../../../src/core/server/mocks';
 import { licensingMock } from '../../licensing/server/mocks';
 import { encryptedSavedObjectsMock } from '../../encrypted_saved_objects/server/mocks';
 import { taskManagerMock } from '../../task_manager/server/mocks';
 import { eventLogMock } from '../../event_log/server/mocks';
+import { ActionType } from './types';
+import {
+  ActionsPlugin,
+  ActionsPluginsSetup,
+  ActionsPluginsStart,
+  PluginSetupContract,
+} from './plugin';
 
 describe('Actions Plugin', () => {
   describe('setup()', () => {
@@ -90,6 +96,54 @@ describe('Actions Plugin', () => {
         );
       });
     });
+
+    describe('registerType()', () => {
+      let setup: PluginSetupContract;
+      const sampleActionType: ActionType = {
+        id: 'test',
+        name: 'test',
+        minimumLicenseRequired: 'basic',
+        async executor() {},
+      };
+
+      beforeEach(async () => {
+        setup = await plugin.setup(coreSetup, pluginsSetup);
+      });
+
+      it('should throw error when license type is invalid', async () => {
+        expect(() =>
+          setup.registerType({
+            ...sampleActionType,
+            minimumLicenseRequired: 'foo' as any,
+          })
+        ).toThrowErrorMatchingInlineSnapshot(`"\\"foo\\" is not a valid license type"`);
+      });
+
+      it('should throw error when license type is less than gold', async () => {
+        expect(() =>
+          setup.registerType({
+            ...sampleActionType,
+            minimumLicenseRequired: 'basic',
+          })
+        ).toThrowErrorMatchingInlineSnapshot(
+          `"Third party action type \\"test\\" can only set minimumLicenseRequired to a gold license or higher"`
+        );
+      });
+
+      it('should not throw when license type is gold', async () => {
+        setup.registerType({
+          ...sampleActionType,
+          minimumLicenseRequired: 'gold',
+        });
+      });
+
+      it('should not throw when license type is higher than gold', async () => {
+        setup.registerType({
+          ...sampleActionType,
+          minimumLicenseRequired: 'platinum',
+        });
+      });
+    });
   });
   describe('start()', () => {
     let plugin: ActionsPlugin;