setup/teardown to support datastreams

elastic · Dec 21, 2021 · 0d69c42 · 0d69c42
1 parent 15eb061
commit 0d69c42
Showing 1 changed file with 16 additions and 2 deletions.
diff --git a/x-pack/test/functional/apps/monitoring/_get_lifecycle_methods.js b/x-pack/test/functional/apps/monitoring/_get_lifecycle_methods.js
@@ -8,11 +8,24 @@
 export const getLifecycleMethods = (getService, getPageObjects) => {
   const esArchiver = getService('esArchiver');
   const security = getService('security');
+  const client = getService('es');
   const PageObjects = getPageObjects(['monitoring', 'timePicker', 'security', 'common']);
   let _archive;
 
+  const deleteDataStream = async (index) => {
+    await client.transport.request(
+      {
+        method: 'DELETE',
+        path: `_data_stream/${index}`,
+      },
+      {
+        ignore: [404],
+      }
+    );
+  };
+
   return {
-    async setup(archive, { from, to, useSuperUser = false }) {
+    async setup(archive, { from, to, useSuperUser = false, useCreate = false }) {
       _archive = archive;
       if (!useSuperUser) {
         await security.testUser.setRoles(['monitoring_user', 'kibana_admin', 'test_monitoring']);
@@ -24,7 +37,7 @@ export const getLifecycleMethods = (getService, getPageObjects) => {
       // provide extra height for the page and avoid clusters sending telemetry during tests
       await browser.setWindowSize(1600, 1000);
 
-      await esArchiver.load(archive);
+      await esArchiver.load(archive, { useCreate });
       await kibanaServer.uiSettings.replace({});
 
       await PageObjects.common.navigateToApp('monitoring');
@@ -37,6 +50,7 @@ export const getLifecycleMethods = (getService, getPageObjects) => {
     },
 
     async tearDown() {
+      await deleteDataStream('.monitoring-*-8-*');
       await security.testUser.restoreDefaults();
       return esArchiver.unload(_archive);
     },