integration test

elastic · Sep 21, 2023 · 6b86213 · 6b86213
1 parent 8e83d29
commit 6b86213
Show file tree

Hide file tree

Showing 2 changed files with 57 additions and 4 deletions.
diff --git a/x-pack/plugins/fleet/server/services/epm/elasticsearch/template/template.ts b/x-pack/plugins/fleet/server/services/epm/elasticsearch/template/template.ts
@@ -542,9 +542,7 @@ async function getIndexTemplate(
     name: dataStreamName,
     expand_wildcards: ['open', 'hidden'],
   });
-  const indexTemplateName = dataStream.data_streams[0].template;
-
-  return indexTemplateName;
+  return dataStream.data_streams[0].template;
 }
 
 export function generateTemplateIndexPattern(dataStream: RegistryDataStream): string {

diff --git a/x-pack/test/fleet_api_integration/apis/epm/install_hidden_datastreams.ts b/x-pack/test/fleet_api_integration/apis/epm/install_hidden_datastreams.ts
@@ -23,7 +23,7 @@ export default function (providerContext: FtrProviderContext) {
     skipIfNoDockerRegistry(providerContext);
     setupFleetAndAgents(providerContext);
 
-    after(async () => {
+    afterEach(async () => {
       await deletePackage('apm', '8.8.0');
     });
 
@@ -88,5 +88,60 @@ export default function (providerContext: FtrProviderContext) {
       // datastream rolled over
       expect(Object.keys(ds).length).greaterThan(1);
     });
+
+    it('should not rollover datastreams when successfully updated mappings', async function () {
+      await supertest
+        .post(`/api/fleet/epm/packages/apm/8.8.0`)
+        .set('kbn-xsrf', 'xxxx')
+        .send({ force: true })
+        .expect(200);
+
+      await es.index({
+        index: 'metrics-apm.app.default-default',
+        document: {
+          '@timestamp': '2023-05-30T07:50:00.000Z',
+          agent: {
+            name: 'go',
+          },
+          data_stream: {
+            dataset: 'metrics-apm.app.default',
+            namespace: 'default',
+            type: 'metrics',
+          },
+          ecs: {
+            version: '8.8.0-dev',
+          },
+          event: {
+            agent_id_status: 'missing',
+            ingested: '2023-05-30T07:57:12Z',
+          },
+          observer: {
+            hostname: '047e282994fb',
+            type: 'apm-server',
+            version: '8.8.0',
+          },
+        },
+      });
+
+      let ds = await es.indices.get({
+        index: 'metrics-apm.app.default*',
+        expand_wildcards: ['open', 'hidden'],
+      });
+      const indicesBefore = Object.keys(ds).length;
+
+      await supertest
+        .post(`/api/fleet/epm/packages/apm/8.8.0`)
+        .set('kbn-xsrf', 'xxxx')
+        .send({ force: true })
+        .expect(200);
+
+      ds = await es.indices.get({
+        index: 'metrics-apm.app.default*',
+        expand_wildcards: ['open', 'hidden'],
+      });
+      const indicesAfter = Object.keys(ds).length;
+      // datastream did not roll over
+      expect(indicesAfter).equal(indicesBefore);
+    });
   });
 }