Add transform UI services

Author: pheyos

x-pack/test/functional/services/index.ts

@@ -47,6 +47,7 @@ import { UptimeProvider } from './uptime';
 import { InfraSourceConfigurationFormProvider } from './infra_source_configuration_form';
 import { InfraLogStreamProvider } from './infra_log_stream';
 import { MachineLearningProvider } from './ml';
+import { TransformProvider } from './transform';
 
 import { SecurityServiceProvider, SpacesServiceProvider } from '../../common/services';
 
@@ -89,4 +90,5 @@ export const services = {
   infraSourceConfigurationForm: InfraSourceConfigurationFormProvider,
   infraLogStream: InfraLogStreamProvider,
   ml: MachineLearningProvider,
+  transform: TransformProvider,
 };

x-pack/test/functional/services/transform.ts

@@ -0,0 +1,34 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { FtrProviderContext } from '../ftr_provider_context';
+
+import {
+  TransformAPIProvider,
+  TransformManagementProvider,
+  TransformNavigationProvider,
+  TransformSourceSelectionProvider,
+  TransformTableProvider,
+  TransformWizardProvider,
+} from './transform_ui';
+
+export function TransformProvider(context: FtrProviderContext) {
+  const api = TransformAPIProvider(context);
+  const management = TransformManagementProvider(context);
+  const navigation = TransformNavigationProvider(context);
+  const sourceSelection = TransformSourceSelectionProvider(context);
+  const table = TransformTableProvider(context);
+  const wizard = TransformWizardProvider(context);
+
+  return {
+    api,
+    management,
+    navigation,
+    sourceSelection,
+    table,
+    wizard,
+  };
+}

x-pack/test/functional/services/transform_ui/api.ts

@@ -0,0 +1,48 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+import expect from '@kbn/expect';
+
+import { isEmpty } from 'lodash';
+import { FtrProviderContext } from '../../ftr_provider_context';
+
+export function TransformAPIProvider({ getService }: FtrProviderContext) {
+  const es = getService('es');
+  const log = getService('log');
+  const retry = getService('retry');
+
+  return {
+    async deleteIndices(indices: string) {
+      log.debug(`Deleting indices: '${indices}'...`);
+      if ((await es.indices.exists({ index: indices })) === false) {
+        log.debug(`Indices '${indices}' don't exist. Nothing to delete.`);
+        return;
+      }
+
+      const deleteResponse = await es.indices.delete({
+        index: indices,
+      });
+      expect(deleteResponse)
+        .to.have.property('acknowledged')
+        .eql(true, 'Response for delete request should be acknowledged');
+
+      await retry.waitForWithTimeout(`'${indices}' indices to be deleted`, 30 * 1000, async () => {
+        const getRepsonse = await es.indices.get({
+          index: indices,
+        });
+
+        if (isEmpty(getRepsonse)) {
+          return true;
+        } else {
+          throw new Error(`expected indices '${indices}' to be deleted`);
+        }
+      });
+    },
+
+    async cleanTransformIndices() {
+      await this.deleteIndices('.transform-*');
+    },
+  };
+}

x-pack/test/functional/services/transform_ui/index.ts

@@ -0,0 +1,12 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+export { TransformAPIProvider } from './api';
+export { TransformManagementProvider } from './management';
+export { TransformNavigationProvider } from './navigation';
+export { TransformSourceSelectionProvider } from './source_selection';
+export { TransformTableProvider } from './transform_table';
+export { TransformWizardProvider } from './wizard';

x-pack/test/functional/services/transform_ui/management.ts

@@ -0,0 +1,42 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { FtrProviderContext } from '../../ftr_provider_context';
+
+export function TransformManagementProvider({ getService }: FtrProviderContext) {
+  const testSubjects = getService('testSubjects');
+
+  return {
+    async assertTransformListPageExists() {
+      await testSubjects.existOrFail('transformPageTransformList');
+    },
+
+    async assertNoTransformsFoundMessageExists() {
+      await testSubjects.existOrFail('transformNoTransformsFound');
+    },
+
+    async assertTransformsTableExists() {
+      await testSubjects.existOrFail('~transformListTable');
+    },
+
+    async assertCreateNewTransformButtonExists() {
+      await testSubjects.existOrFail('transformButtonCreate');
+    },
+
+    async assertTransformStatsBarExists() {
+      await testSubjects.existOrFail('transformStatsBar');
+    },
+
+    async startTransformCreation() {
+      if (await testSubjects.exists('transformNoTransformsFound')) {
+        await testSubjects.click('transformCreateFirstButton');
+      } else {
+        await testSubjects.click('transformButtonCreate');
+      }
+      await testSubjects.existOrFail('transformSelectSourceModal');
+    },
+  };
+}

x-pack/test/functional/services/transform_ui/navigation.ts

@@ -0,0 +1,17 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { FtrProviderContext } from '../../ftr_provider_context';
+
+export function TransformNavigationProvider({ getPageObjects }: FtrProviderContext) {
+  const PageObjects = getPageObjects(['common']);
+
+  return {
+    async navigateTo() {
+      return await PageObjects.common.navigateToApp('transform');
+    },
+  };
+}

x-pack/test/functional/services/transform_ui/source_selection.ts

@@ -0,0 +1,30 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+
+import { FtrProviderContext } from '../../ftr_provider_context';
+
+export function TransformSourceSelectionProvider({ getService }: FtrProviderContext) {
+  const testSubjects = getService('testSubjects');
+
+  return {
+    async assertSourceListContainsEntry(sourceName: string) {
+      await testSubjects.existOrFail(`savedObjectTitle${sourceName}`);
+    },
+
+    async filterSourceSelection(sourceName: string) {
+      await testSubjects.setValue('savedObjectFinderSearchInput', sourceName, {
+        clearWithKeyboard: true,
+      });
+      await this.assertSourceListContainsEntry(sourceName);
+    },
+
+    async selectSource(sourceName: string) {
+      await this.filterSourceSelection(sourceName);
+      await testSubjects.clickWhenNotDisabled(`savedObjectTitle${sourceName}`);
+      await testSubjects.existOrFail('transformPageCreateTransform');
+    },
+  };
+}

x-pack/test/functional/services/transform_ui/transform_table.ts

@@ -0,0 +1,87 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License;
+ * you may not use this file except in compliance with the Elastic License.
+ */
+import expect from '@kbn/expect';
+
+import { FtrProviderContext } from '../../ftr_provider_context';
+
+export function TransformTableProvider({ getService }: FtrProviderContext) {
+  const testSubjects = getService('testSubjects');
+
+  return new (class TransformTable {
+    public async parseTransformTable() {
+      const table = await testSubjects.find('~transformListTable');
+      const $ = await table.parseDomContent();
+      const rows = [];
+
+      for (const tr of $.findTestSubjects('~transformListRow').toArray()) {
+        const $tr = $(tr);
+
+        rows.push({
+          id: $tr
+            .findTestSubject('transformListColumnId')
+            .find('.euiTableCellContent')
+            .text()
+            .trim(),
+          description: $tr
+            .findTestSubject('transformListColumnDescription')
+            .find('.euiTableCellContent')
+            .text()
+            .trim(),
+          sourceIndex: $tr
+            .findTestSubject('transformListColumnSourceIndex')
+            .find('.euiTableCellContent')
+            .text()
+            .trim(),
+          destinationIndex: $tr
+            .findTestSubject('transformListColumnDestinationIndex')
+            .find('.euiTableCellContent')
+            .text()
+            .trim(),
+          status: $tr
+            .findTestSubject('transformListColumnStatus')
+            .find('.euiTableCellContent')
+            .text()
+            .trim(),
+          mode: $tr
+            .findTestSubject('transformListColumnMode')
+            .find('.euiTableCellContent')
+            .text()
+            .trim(),
+          progress: $tr
+            .findTestSubject('transformListColumnProgress')
+            .findTestSubject('transformListProgress')
+            .attr('value'),
+        });
+      }
+
+      return rows;
+    }
+
+    public async refreshTransformList() {
+      await testSubjects.click('transformRefreshTransformListButton');
+      await this.waitForTransformsToLoad();
+    }
+
+    public async waitForTransformsToLoad() {
+      await testSubjects.existOrFail('~transformListTable', { timeout: 60 * 1000 });
+      await testSubjects.existOrFail('transformListTable loaded', { timeout: 30 * 1000 });
+    }
+
+    public async filterWithSearchString(filter: string) {
+      await this.waitForTransformsToLoad();
+      const tableListContainer = await testSubjects.find('transformListTableContainer');
+      const searchBarInput = await tableListContainer.findByClassName('euiFieldSearch');
+      await searchBarInput.clearValueWithKeyboard();
+      await searchBarInput.type(filter);
+    }
+
+    public async assertTransformRowFields(transformId: string, expectedRow: object) {
+      const rows = await this.parseTransformTable();
+      const transformRow = rows.filter(row => row.id === transformId)[0];
+      expect(transformRow).to.eql(expectedRow);
+    }
+  })();
+}