[Feature/Reporting] Export Saved Search CSV as Dashboard Panel Action (…

…#34571) (#37401)

src/legacy/core_plugins/kibana/public/dashboard/store/panel_actions_store.ts

@@ -28,7 +28,9 @@ class PanelActionsStore {
    */
   public initializeFromRegistry(panelActionsRegistry: ContextMenuAction[]) {
     panelActionsRegistry.forEach(panelAction => {
-      this.actions.push(panelAction);
+      if (!this.actions.includes(panelAction)) {
+        this.actions.push(panelAction);
+      }
     });
   }
 }

src/legacy/core_plugins/kibana/public/discover/embeddable/search_embeddable.ts

@@ -110,6 +110,10 @@ export class SearchEmbeddable extends Embeddable {
     return this.inspectorAdaptors;
   }
 
+  public getPanelTitle() {
+    return this.panelTitle;
+  }
+
   public onContainerStateChanged(containerState: ContainerState) {
     this.customization = containerState.embeddableCustomization || {};
     this.filters = containerState.filters;

x-pack/plugins/reporting/server/lib/esqueue/helpers/cancellation_token.js → x-pack/plugins/reporting/common/cancellation_token.ts

@@ -7,12 +7,15 @@
 import { isFunction } from 'lodash';
 
 export class CancellationToken {
+  private isCancelled: boolean;
+  private _callbacks: any[];
+
   constructor() {
     this.isCancelled = false;
     this._callbacks = [];
   }
 
-  on = (callback) => {
+  on(callback: Function) {
     if (!isFunction(callback)) {
       throw new Error('Expected callback to be a function');
     }
@@ -23,10 +26,10 @@ export class CancellationToken {
     }
 
     this._callbacks.push(callback);
-  };
+  }
 
-  cancel = () => {
+  cancel() {
     this.isCancelled = true;
     this._callbacks.forEach(callback => callback());
-  };
+  }
 }

x-pack/plugins/reporting/common/constants.ts

@@ -9,12 +9,16 @@ export const PLUGIN_ID = 'reporting';
 export const JOB_COMPLETION_NOTIFICATIONS_SESSION_KEY =
   'xpack.reporting.jobCompletionNotifications';
 
-export const API_BASE_URL = '/api/reporting';
+export const API_BASE_URL = '/api/reporting'; // "Generation URL" from share menu
+export const API_BASE_URL_V1 = '/api/reporting/v1'; //
+export const API_BASE_GENERATE_V1 = `${API_BASE_URL_V1}/generate`;
+
+export const CONTENT_TYPE_CSV = 'text/csv';
 
 export const WHITELISTED_JOB_CONTENT_TYPES = [
   'application/json',
   'application/pdf',
-  'text/csv',
+  CONTENT_TYPE_CSV,
   'image/png',
 ];
 
@@ -41,4 +45,5 @@ export const KIBANA_REPORTING_TYPE = 'reporting';
 export const PDF_JOB_TYPE = 'printable_pdf';
 export const PNG_JOB_TYPE = 'PNG';
 export const CSV_JOB_TYPE = 'csv';
+export const CSV_FROM_SAVEDOBJECT_JOB_TYPE = 'csv_from_savedobject';
 export const USES_HEADLESS_JOB_TYPES = [PDF_JOB_TYPE, PNG_JOB_TYPE];

x-pack/plugins/reporting/export_types/common/execute_job/add_force_now_query_string.test.ts

@@ -15,7 +15,15 @@ beforeEach(() => {
 test(`fails if no URL is passed`, async () => {
   await expect(
     addForceNowQuerystring({
-      job: {},
+      job: {
+        title: 'cool-job-bro',
+        type: 'csv',
+        jobParams: {
+          savedObjectId: 'abc-123',
+          isImmediate: false,
+          savedObjectType: 'search',
+        },
+      },
       server: mockServer,
     })
   ).rejects.toBeDefined();
@@ -24,7 +32,17 @@ test(`fails if no URL is passed`, async () => {
 test(`adds forceNow to hash's query, if it exists`, async () => {
   const forceNow = '2000-01-01T00:00:00.000Z';
   const { urls } = await addForceNowQuerystring({
-    job: { relativeUrl: '/app/kibana#/something', forceNow },
+    job: {
+      title: 'cool-job-bro',
+      type: 'csv',
+      jobParams: {
+        savedObjectId: 'abc-123',
+        isImmediate: false,
+        savedObjectType: 'search',
+      },
+      relativeUrl: '/app/kibana#/something',
+      forceNow,
+    },
     server: mockServer,
   });
 
@@ -38,6 +56,13 @@ test(`appends forceNow to hash's query, if it exists`, async () => {
 
   const { urls } = await addForceNowQuerystring({
     job: {
+      title: 'cool-job-bro',
+      type: 'csv',
+      jobParams: {
+        savedObjectId: 'abc-123',
+        isImmediate: false,
+        savedObjectType: 'search',
+      },
       relativeUrl: '/app/kibana#/something?_g=something',
       forceNow,
     },
@@ -52,6 +77,13 @@ test(`appends forceNow to hash's query, if it exists`, async () => {
 test(`doesn't append forceNow query to url, if it doesn't exists`, async () => {
   const { urls } = await addForceNowQuerystring({
     job: {
+      title: 'cool-job-bro',
+      type: 'csv',
+      jobParams: {
+        savedObjectId: 'abc-123',
+        isImmediate: false,
+        savedObjectType: 'search',
+      },
       relativeUrl: '/app/kibana#/something',
     },
     server: mockServer,

x-pack/plugins/reporting/export_types/common/execute_job/add_force_now_query_string.ts

@@ -3,12 +3,12 @@
  * or more contributor license agreements. Licensed under the Elastic License;
  * you may not use this file except in compliance with the Elastic License.
  */
-// @ts-ignore
+
 import url from 'url';
 import { getAbsoluteUrlFactory } from '../../../common/get_absolute_url';
-import { ConditionalHeaders, KbnServer, ReportingJob } from '../../../types';
+import { ConditionalHeaders, JobDocPayload, KbnServer } from '../../../types';
 
-function getSavedObjectAbsoluteUrl(job: ReportingJob, relativeUrl: string, server: KbnServer) {
+function getSavedObjectAbsoluteUrl(job: JobDocPayload, relativeUrl: string, server: KbnServer) {
   const getAbsoluteUrl: any = getAbsoluteUrlFactory(server);
 
   const { pathname: path, hash, search } = url.parse(relativeUrl);
@@ -21,7 +21,7 @@ export const addForceNowQuerystring = async ({
   logo,
   server,
 }: {
-  job: ReportingJob;
+  job: JobDocPayload;
   conditionalHeaders?: ConditionalHeaders;
   logo?: any;
   server: KbnServer;
@@ -34,7 +34,7 @@ export const addForceNowQuerystring = async ({
     job.urls = [getSavedObjectAbsoluteUrl(job, job.relativeUrl, server)];
   }
 
-  const urls = job.urls.map(jobUrl => {
+  const urls = job.urls.map((jobUrl: string) => {
     if (!job.forceNow) {
       return jobUrl;
     }

x-pack/plugins/reporting/export_types/common/execute_job/decrypt_job_headers.test.ts

@@ -23,7 +23,17 @@ describe('headers', () => {
   test(`fails if it can't decrypt headers`, async () => {
     await expect(
       decryptJobHeaders({
-        job: { relativeUrl: '/app/kibana#/something', timeRange: {} },
+        job: {
+          title: 'cool-job-bro',
+          type: 'csv',
+          jobParams: {
+            savedObjectId: 'abc-123',
+            isImmediate: false,
+            savedObjectType: 'search',
+          },
+          relativeUrl: '/app/kibana#/something',
+          timeRange: {},
+        },
         server: mockServer,
       })
     ).rejects.toBeDefined();
@@ -37,7 +47,17 @@ describe('headers', () => {
 
     const encryptedHeaders = await encryptHeaders(headers);
     const { decryptedHeaders } = await decryptJobHeaders({
-      job: { relativeUrl: '/app/kibana#/something', headers: encryptedHeaders },
+      job: {
+        title: 'cool-job-bro',
+        type: 'csv',
+        jobParams: {
+          savedObjectId: 'abc-123',
+          isImmediate: false,
+          savedObjectType: 'search',
+        },
+        relativeUrl: '/app/kibana#/something',
+        headers: encryptedHeaders,
+      },
       server: mockServer,
     });
     expect(decryptedHeaders).toEqual(headers);

x-pack/plugins/reporting/export_types/common/execute_job/decrypt_job_headers.ts

@@ -5,13 +5,13 @@
  */
 // @ts-ignore
 import { cryptoFactory } from '../../../server/lib/crypto';
-import { CryptoFactory, KbnServer, ReportingJob } from '../../../types';
+import { CryptoFactory, JobDocPayload, KbnServer } from '../../../types';
 
 export const decryptJobHeaders = async ({
   job,
   server,
 }: {
-  job: ReportingJob;
+  job: JobDocPayload;
   server: KbnServer;
 }) => {
   const crypto: CryptoFactory = cryptoFactory(server);