From 5ae3092e91edeee944336c6c8d3d2025b2c52966 Mon Sep 17 00:00:00 2001
From: neptunian <sandra.gonzales@elastic.co>
Date: Wed, 7 Oct 2020 13:41:16 -0400
Subject: [PATCH] build datastream name from index name

---
 .../epm/elasticsearch/template/template.ts    | 20 ++-----------------
 1 file changed, 2 insertions(+), 18 deletions(-)

diff --git a/x-pack/plugins/ingest_manager/server/services/epm/elasticsearch/template/template.ts b/x-pack/plugins/ingest_manager/server/services/epm/elasticsearch/template/template.ts
index e0fea59107c26..561108f96869d 100644
--- a/x-pack/plugins/ingest_manager/server/services/epm/elasticsearch/template/template.ts
+++ b/x-pack/plugins/ingest_manager/server/services/epm/elasticsearch/template/template.ts
@@ -400,13 +400,8 @@ const updateExistingIndex = async ({
   delete mappings.properties.stream;
   delete mappings.properties.data_stream;
 
-  // get the data_stream values from the index template to compose data stream name
-  const indexMappings = await getIndexMappings(indexName, callCluster);
-  const dataStream = indexMappings[indexName].mappings.properties.data_stream.properties;
-  if (!dataStream.type.value || !dataStream.dataset.value || !dataStream.namespace.value)
-    throw new Error(`data_stream values are missing from the index template ${indexName}`);
-  const dataStreamName = `${dataStream.type.value}-${dataStream.dataset.value}-${dataStream.namespace.value}`;
-
+  const [, dsType, dsTemplateName, dsNamespace] = indexName.split('-');
+  const dataStreamName = `${dsType}-${dsTemplateName}-${dsNamespace}`;
   // try to update the mappings first
   try {
     await callCluster('indices.putMapping', {
@@ -438,14 +433,3 @@ const updateExistingIndex = async ({
     throw new Error(`could not update index template settings for ${indexName}`);
   }
 };
-
-const getIndexMappings = async (indexName: string, callCluster: CallESAsCurrentUser) => {
-  try {
-    const indexMappings = await callCluster('indices.getMapping', {
-      index: indexName,
-    });
-    return indexMappings;
-  } catch (err) {
-    throw new Error(`could not get mapping from ${indexName}`);
-  }
-};