From c31acce6499932fd39babcb4a984f58260df4239 Mon Sep 17 00:00:00 2001
From: Joe Portner <5295965+jportner@users.noreply.github.com>
Date: Thu, 27 Aug 2020 13:54:09 -0400
Subject: [PATCH] Fix more broken usages of `bulkCreate` (#76005)

---
 .../tutorial/saved_objects_installer.js       |  9 +++++---
 .../tutorial/saved_objects_installer.test.js  | 21 +++++++++++++++++++
 .../models/data_recognizer/data_recognizer.ts |  7 ++++---
 3 files changed, 31 insertions(+), 6 deletions(-)

diff --git a/src/plugins/home/public/application/components/tutorial/saved_objects_installer.js b/src/plugins/home/public/application/components/tutorial/saved_objects_installer.js
index 790c6d9c2574..dd63827c38c5 100644
--- a/src/plugins/home/public/application/components/tutorial/saved_objects_installer.js
+++ b/src/plugins/home/public/application/components/tutorial/saved_objects_installer.js
@@ -62,9 +62,12 @@ class SavedObjectsInstallerUi extends React.Component {
 
     let resp;
     try {
-      resp = await this.props.bulkCreate(this.props.savedObjects, {
-        overwrite: this.state.overwrite,
-      });
+      // Filter out the saved object version field, if present, to avoid inadvertently triggering optimistic concurrency control.
+      const objectsToCreate = this.props.savedObjects.map(
+        // eslint-disable-next-line no-unused-vars
+        ({ version, ...savedObject }) => savedObject
+      );
+      resp = await this.props.bulkCreate(objectsToCreate, { overwrite: this.state.overwrite });
     } catch (error) {
       if (!this._isMounted) {
         return;
diff --git a/src/plugins/home/public/application/components/tutorial/saved_objects_installer.test.js b/src/plugins/home/public/application/components/tutorial/saved_objects_installer.test.js
index 6cc02184fbc1..e7b7d8ed1d7f 100644
--- a/src/plugins/home/public/application/components/tutorial/saved_objects_installer.test.js
+++ b/src/plugins/home/public/application/components/tutorial/saved_objects_installer.test.js
@@ -79,4 +79,25 @@ describe('bulkCreate', () => {
 
     expect(component).toMatchSnapshot();
   });
+
+  test('should filter out saved object version before calling bulkCreate', async () => {
+    const bulkCreateMock = jest.fn().mockResolvedValue({
+      savedObjects: [savedObject],
+    });
+    const component = mountWithIntl(
+      <SavedObjectsInstaller.WrappedComponent
+        bulkCreate={bulkCreateMock}
+        savedObjects={[{ ...savedObject, version: 'foo' }]}
+      />
+    );
+
+    findTestSubject(component, 'loadSavedObjects').simulate('click');
+
+    // Ensure all promises resolve
+    await new Promise((resolve) => process.nextTick(resolve));
+    // Ensure the state changes are reflected
+    component.update();
+
+    expect(bulkCreateMock).toHaveBeenCalledWith([savedObject], expect.any(Object));
+  });
 });
diff --git a/x-pack/plugins/ml/server/models/data_recognizer/data_recognizer.ts b/x-pack/plugins/ml/server/models/data_recognizer/data_recognizer.ts
index cc42a545c11e..206baacd9832 100644
--- a/x-pack/plugins/ml/server/models/data_recognizer/data_recognizer.ts
+++ b/x-pack/plugins/ml/server/models/data_recognizer/data_recognizer.ts
@@ -20,6 +20,7 @@ import { getAuthorizationHeader } from '../../lib/request_authorization';
 import { MlInfoResponse } from '../../../common/types/ml_server_info';
 import {
   KibanaObjects,
+  KibanaObjectConfig,
   ModuleDataFeed,
   ModuleJob,
   Module,
@@ -100,7 +101,7 @@ interface ObjectExistResponse {
   id: string;
   type: string;
   exists: boolean;
-  savedObject?: any;
+  savedObject?: { id: string; type: string; attributes: KibanaObjectConfig };
 }
 
 interface SaveResults {
@@ -678,14 +679,14 @@ export class DataRecognizer {
     let results = { saved_objects: [] as any[] };
     const filteredSavedObjects = objectExistResults
       .filter((o) => o.exists === false)
-      .map((o) => o.savedObject);
+      .map((o) => o.savedObject!);
     if (filteredSavedObjects.length) {
       results = await this.savedObjectsClient.bulkCreate(
         // Add an empty migrationVersion attribute to each saved object to ensure
         // it is automatically migrated to the 7.0+ format with a references attribute.
         filteredSavedObjects.map((doc) => ({
           ...doc,
-          migrationVersion: doc.migrationVersion || {},
+          migrationVersion: {},
         }))
       );
     }