[Tests] remove _type from OpenSearch Archiver

_type was removed in opensearch-project/OpenSearch#2239 OpenSearch Archiver loads data to OpenSearch from data.json into OpenSearch for E2E tests and integration tests but will need to verify if this causes breakage in migration from older versions of the application. Issue resolved: n/a Signed-off-by: Kawika Avilla <kavilla414@gmail.com>
kavilla · Feb 26, 2022 · d5420d1 · d5420d1
1 parent fa47ac3
commit d5420d1
Show file tree

Hide file tree

Showing 4 changed files with 27 additions and 7 deletions.
diff --git a/packages/osd-opensearch-archiver/src/lib/docs/__tests__/index_doc_records_stream.ts b/packages/osd-opensearch-archiver/src/lib/docs/__tests__/index_doc_records_stream.ts
@@ -41,9 +41,21 @@ import { createStubStats, createStubClient, createPersonDocRecords } from './stu
 
 const recordsToBulkBody = (records: any[]) => {
   return records.reduce((acc, record) => {
-    const { index, type, id, source } = record.value;
-
-    return [...acc, { index: { _index: index, _type: type, _id: id } }, source];
+    const { index, id, source } = record.value;
+
+    return [
+      ...acc,
+      {
+        index: {
+          _index: index,
+          // TODO: verify no BWC issues here
+          // Removed: https://github.com/opensearch-project/OpenSearch/pull/2239
+          // _type: type,
+          _id: id,
+        },
+      },
+      source,
+    ];
   }, [] as any[]);
 };
 

diff --git a/packages/osd-opensearch-archiver/src/lib/docs/generate_doc_records_stream.ts b/packages/osd-opensearch-archiver/src/lib/docs/generate_doc_records_stream.ts
@@ -87,7 +87,9 @@ export function createGenerateDocRecordsStream({
                 // always rewrite the .kibana_* index to .kibana_1 so that
                 // when it is loaded it can skip migration, if possible
                 index: hit._index.startsWith('.kibana') ? '.kibana_1' : hit._index,
-                type: hit._type,
+                // TODO: verify no BWC issues here
+                // Removed: https://github.com/opensearch-project/OpenSearch/pull/2239
+                // type: hit._type,
                 id: hit._id,
                 source: hit._source,
               },

diff --git a/packages/osd-opensearch-archiver/src/lib/docs/index_doc_records_stream.ts b/packages/osd-opensearch-archiver/src/lib/docs/index_doc_records_stream.ts
@@ -50,7 +50,9 @@ export function createIndexDocRecordsStream(
         {
           [operation]: {
             _index: doc.index,
-            _type: doc.type,
+            // TODO: verify no BWC issues here
+            // Removed: https://github.com/opensearch-project/OpenSearch/pull/2239
+            // _type: doc.type,
             _id: doc.id,
           },
         },

diff --git a/test/functional/apps/management/_handle_version_conflict.js b/test/functional/apps/management/_handle_version_conflict.js
@@ -66,7 +66,9 @@ export default function ({ getService, getPageObjects }) {
       await PageObjects.settings.setScriptedFieldScript(`doc['bytes'].value`);
       const response = await opensearch.update({
         index: '.kibana',
-        type: '_doc',
+        // TODO: verify no BWC issues here
+        // Removed: https://github.com/opensearch-project/OpenSearch/pull/2239
+        // type: '_doc',
         id: 'index-pattern:logstash-*',
         body: {
           doc: { 'index-pattern': { fieldFormatMap: '{"geo.src":{"id":"number"}}' } },
@@ -93,7 +95,9 @@ export default function ({ getService, getPageObjects }) {
       await PageObjects.settings.setFieldFormat('url');
       const response = await opensearch.update({
         index: '.kibana',
-        type: '_doc',
+        // TODO: verify no BWC issues here
+        // Removed: https://github.com/opensearch-project/OpenSearch/pull/2239
+        // type: '_doc',
         id: 'index-pattern:logstash-*',
         body: {
           doc: { 'index-pattern': { fieldFormatMap: '{"geo.dest":{"id":"number"}}' } },