ServiceNow push to Incident generic implementation (supporting both Case specific and generic Alerts)

docs/user/alerting/action-types/pre-configured-connectors.asciidoc

@@ -28,12 +28,12 @@ two out-of-the box connectors: <<slack-action-type, Slack>> and <<webhook-action
     my-slack1:                  <1>
       actionTypeId: .slack      <2>
       name: 'Slack #xyz'        <3>
-      secrets:                   <4>
+      secrets:
         webhookUrl: 'https://hooks.slack.com/services/abcd/efgh/ijklmnopqrstuvwxyz'
     webhook-service:
       actionTypeId: .webhook
       name: 'Email service'
-      config:
+      config:                   <4>
         url: 'https://email-alert-service.elastic.co'
         method: post
         headers:

x-pack/plugins/actions/common/types.ts

@@ -16,6 +16,7 @@ export interface ActionType {
 }
 
 export interface ActionResult {
+  consumer?: string;
   id: string;
   actionTypeId: string;
   name: string;

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

@@ -106,6 +106,7 @@ describe('create()', () => {
         Object {
           "actionTypeId": "my-action-type",
           "config": Object {},
+          "consumer": undefined,
           "name": "my name",
           "secrets": Object {},
         },
@@ -210,6 +211,7 @@ describe('create()', () => {
             "b": true,
             "c": true,
           },
+          "consumer": undefined,
           "name": "my name",
           "secrets": Object {},
         },

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

@@ -42,6 +42,7 @@ interface ActionUpdate extends SavedObjectAttributes {
 
 interface Action extends ActionUpdate {
   actionTypeId: string;
+  consumer?: string;
 }
 
 interface CreateOptions {
@@ -98,7 +99,7 @@ export class ActionsClient {
    * Create an action
    */
   public async create({ action }: CreateOptions): Promise<ActionResult> {
-    const { actionTypeId, name, config, secrets } = action;
+    const { actionTypeId, name, config, secrets, consumer } = action;
     const actionType = this.actionTypeRegistry.get(actionTypeId);
     const validatedActionTypeConfig = validateConfig(actionType, config);
     const validatedActionTypeSecrets = validateSecrets(actionType, secrets);
@@ -110,6 +111,7 @@ export class ActionsClient {
       name,
       config: validatedActionTypeConfig as SavedObjectAttributes,
       secrets: validatedActionTypeSecrets as SavedObjectAttributes,
+      consumer,
     });
 
     return {
@@ -118,6 +120,7 @@ export class ActionsClient {
       name: result.attributes.name,
       config: result.attributes.config,
       isPreconfigured: false,
+      consumer: result.attributes.consumer,
     };
   }
 
@@ -148,7 +151,7 @@ export class ActionsClient {
 
     this.actionTypeRegistry.ensureActionTypeEnabled(actionTypeId);
 
-    const result = await this.savedObjectsClient.update('action', id, {
+    const result = await this.savedObjectsClient.update<RawAction>('action', id, {
       actionTypeId,
       name,
       config: validatedActionTypeConfig as SavedObjectAttributes,
@@ -161,6 +164,7 @@ export class ActionsClient {
       name: result.attributes.name as string,
       config: result.attributes.config as Record<string, unknown>,
       isPreconfigured: false,
+      consumer: existingObject.attributes.consumer,
     };
   }
 
@@ -177,6 +181,7 @@ export class ActionsClient {
         actionTypeId: preconfiguredActionsList.actionTypeId,
         name: preconfiguredActionsList.name,
         isPreconfigured: true,
+        consumer: preconfiguredActionsList.consumer,
       };
     }
     const result = await this.savedObjectsClient.get<RawAction>('action', id);
@@ -187,6 +192,7 @@ export class ActionsClient {
       name: result.attributes.name,
       config: result.attributes.config,
       isPreconfigured: false,
+      consumer: result.attributes.consumer,
     };
   }
 
@@ -208,6 +214,7 @@ export class ActionsClient {
         actionTypeId: preconfiguredAction.actionTypeId,
         name: preconfiguredAction.name,
         isPreconfigured: true,
+        consumer: preconfiguredAction.consumer,
       })),
     ].sort((a, b) => a.name.localeCompare(b.name));
     return await injectExtraFindData(

x-pack/plugins/actions/server/builtin_action_types/case/api.ts

@@ -41,7 +41,7 @@ const pushToServiceHandler = async ({
   }
 
   const fields = prepareFieldsForTransformation({
-    params,
+    externalCase: params.externalCase,
     mapping,
     defaultPipes,
   });

x-pack/plugins/actions/server/builtin_action_types/case/schema.ts

@@ -67,7 +67,7 @@ export const ExecutorSubActionSchema = schema.oneOf([
 ]);
 
 export const ExecutorSubActionPushParamsSchema = schema.object({
-  caseId: schema.string(),
+  savedObjectId: schema.string(),
   title: schema.string(),
   description: schema.nullable(schema.string()),
   comments: schema.nullable(schema.arrayOf(CommentSchema)),

x-pack/plugins/actions/server/builtin_action_types/case/types.ts

@@ -144,7 +144,7 @@ export interface PipedField {
 }
 
 export interface PrepareFieldsForTransformArgs {
-  params: PushToServiceApiParams;
+  externalCase: Record<string, any>;
   mapping: Map<string, MapRecord>;
   defaultPipes?: string[];
 }

x-pack/plugins/actions/server/builtin_action_types/case/utils.test.ts

@@ -4,28 +4,18 @@
  * you may not use this file except in compliance with the Elastic License.
  */
 
-import axios from 'axios';
-
 import {
   normalizeMapping,
   buildMap,
   mapParams,
   prepareFieldsForTransformation,
   transformFields,
   transformComments,
-  addTimeZoneToDate,
-  throwIfNotAlive,
-  request,
-  patch,
-  getErrorMessage,
 } from './utils';
 
 import { SUPPORTED_SOURCE_FIELDS } from './constants';
 import { Comment, MapRecord, PushToServiceApiParams } from './types';
 
-jest.mock('axios');
-const axiosMock = (axios as unknown) as jest.Mock;
-
 const mapping: MapRecord[] = [
   { source: 'title', target: 'short_description', actionType: 'overwrite' },
   { source: 'description', target: 'description', actionType: 'append' },
@@ -63,7 +53,7 @@ const maliciousMapping: MapRecord[] = [
 ];
 
 const fullParams: PushToServiceApiParams = {
-  caseId: 'd4387ac5-0899-4dc2-bbfa-0dd605c934aa',
+  savedObjectId: 'd4387ac5-0899-4dc2-bbfa-0dd605c934aa',
   title: 'a title',
   description: 'a description',
   createdAt: '2020-03-13T08:34:53.450Z',
@@ -132,7 +122,7 @@ describe('buildMap', () => {
 describe('mapParams', () => {
   test('maps params correctly', () => {
     const params = {
-      caseId: '123',
+      savedObjectId: '123',
       incidentId: '456',
       title: 'Incident title',
       description: 'Incident description',
@@ -148,7 +138,7 @@ describe('mapParams', () => {
 
   test('do not add fields not in mapping', () => {
     const params = {
-      caseId: '123',
+      savedObjectId: '123',
       incidentId: '456',
       title: 'Incident title',
       description: 'Incident description',
@@ -164,7 +154,7 @@ describe('mapParams', () => {
 describe('prepareFieldsForTransformation', () => {
   test('prepare fields with defaults', () => {
     const res = prepareFieldsForTransformation({
-      params: fullParams,
+      externalCase: fullParams.externalCase,
       mapping: finalMapping,
     });
     expect(res).toEqual([
@@ -185,7 +175,7 @@ describe('prepareFieldsForTransformation', () => {
 
   test('prepare fields with default pipes', () => {
     const res = prepareFieldsForTransformation({
-      params: fullParams,
+      externalCase: fullParams.externalCase,
       mapping: finalMapping,
       defaultPipes: ['myTestPipe'],
     });
@@ -209,7 +199,7 @@ describe('prepareFieldsForTransformation', () => {
 describe('transformFields', () => {
   test('transform fields for creation correctly', () => {
     const fields = prepareFieldsForTransformation({
-      params: fullParams,
+      externalCase: fullParams.externalCase,
       mapping: finalMapping,
     });
 
@@ -226,14 +216,7 @@ describe('transformFields', () => {
 
   test('transform fields for update correctly', () => {
     const fields = prepareFieldsForTransformation({
-      params: {
-        ...fullParams,
-        updatedAt: '2020-03-15T08:34:53.450Z',
-        updatedBy: {
-          username: 'anotherUser',
-          fullName: 'Another User',
-        },
-      },
+      externalCase: fullParams.externalCase,
       mapping: finalMapping,
       defaultPipes: ['informationUpdated'],
     });
@@ -262,7 +245,7 @@ describe('transformFields', () => {
 
   test('add newline character to descripton', () => {
     const fields = prepareFieldsForTransformation({
-      params: fullParams,
+      externalCase: fullParams.externalCase,
       mapping: finalMapping,
       defaultPipes: ['informationUpdated'],
     });
@@ -280,7 +263,7 @@ describe('transformFields', () => {
 
   test('append username if fullname is undefined when create', () => {
     const fields = prepareFieldsForTransformation({
-      params: fullParams,
+      externalCase: fullParams.externalCase,
       mapping: finalMapping,
     });
 
@@ -300,14 +283,7 @@ describe('transformFields', () => {
 
   test('append username if fullname is undefined when update', () => {
     const fields = prepareFieldsForTransformation({
-      params: {
-        ...fullParams,
-        updatedAt: '2020-03-15T08:34:53.450Z',
-        updatedBy: {
-          username: 'anotherUser',
-          fullName: 'Another User',
-        },
-      },
+      externalCase: fullParams.externalCase,
       mapping: finalMapping,
       defaultPipes: ['informationUpdated'],
     });
@@ -479,98 +455,3 @@ describe('transformComments', () => {
     ]);
   });
 });
-
-describe('addTimeZoneToDate', () => {
-  test('adds timezone with default', () => {
-    const date = addTimeZoneToDate('2020-04-14T15:01:55.456Z');
-    expect(date).toBe('2020-04-14T15:01:55.456Z GMT');
-  });
-
-  test('adds timezone correctly', () => {
-    const date = addTimeZoneToDate('2020-04-14T15:01:55.456Z', 'PST');
-    expect(date).toBe('2020-04-14T15:01:55.456Z PST');
-  });
-});
-
-describe('throwIfNotAlive ', () => {
-  test('throws correctly when status is invalid', async () => {
-    expect(() => {
-      throwIfNotAlive(404, 'application/json');
-    }).toThrow('Instance is not alive.');
-  });
-
-  test('throws correctly when content is invalid', () => {
-    expect(() => {
-      throwIfNotAlive(200, 'application/html');
-    }).toThrow('Instance is not alive.');
-  });
-
-  test('do NOT throws with custom validStatusCodes', async () => {
-    expect(() => {
-      throwIfNotAlive(404, 'application/json', [404]);
-    }).not.toThrow('Instance is not alive.');
-  });
-});
-
-describe('request', () => {
-  beforeEach(() => {
-    axiosMock.mockImplementation(() => ({
-      status: 200,
-      headers: { 'content-type': 'application/json' },
-      data: { incidentId: '123' },
-    }));
-  });
-
-  test('it fetch correctly with defaults', async () => {
-    const res = await request({ axios, url: '/test' });
-
-    expect(axiosMock).toHaveBeenCalledWith('/test', { method: 'get', data: {} });
-    expect(res).toEqual({
-      status: 200,
-      headers: { 'content-type': 'application/json' },
-      data: { incidentId: '123' },
-    });
-  });
-
-  test('it fetch correctly', async () => {
-    const res = await request({ axios, url: '/test', method: 'post', data: { id: '123' } });
-
-    expect(axiosMock).toHaveBeenCalledWith('/test', { method: 'post', data: { id: '123' } });
-    expect(res).toEqual({
-      status: 200,
-      headers: { 'content-type': 'application/json' },
-      data: { incidentId: '123' },
-    });
-  });
-
-  test('it throws correctly', async () => {
-    axiosMock.mockImplementation(() => ({
-      status: 404,
-      headers: { 'content-type': 'application/json' },
-      data: { incidentId: '123' },
-    }));
-
-    await expect(request({ axios, url: '/test' })).rejects.toThrow();
-  });
-});
-
-describe('patch', () => {
-  beforeEach(() => {
-    axiosMock.mockImplementation(() => ({
-      status: 200,
-      headers: { 'content-type': 'application/json' },
-    }));
-  });
-
-  test('it fetch correctly', async () => {
-    await patch({ axios, url: '/test', data: { id: '123' } });
-    expect(axiosMock).toHaveBeenCalledWith('/test', { method: 'patch', data: { id: '123' } });
-  });
-});
-
-describe('getErrorMessage', () => {
-  test('it returns the correct error message', () => {
-    const msg = getErrorMessage('My connector name', 'An error has occurred');
-    expect(msg).toBe('[Action][My connector name]: An error has occurred');
-  });
-});