You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2023/04/04 15:12:27 UTC
[streampipes] branch SP-1479 created (now b0e06e114)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch SP-1479
in repository https://gitbox.apache.org/repos/asf/streampipes.git
at b0e06e114 [#1289] Fix cypress test for data lake configuration
This branch includes the following new commits:
new b0e06e114 [#1289] Fix cypress test for data lake configuration
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[streampipes] 01/01: [#1289] Fix cypress test for data lake configuration
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch SP-1479
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit b0e06e114a91506252cb86eaa296a6dbf8fee4ed
Author: Philipp Zehnder <te...@users.noreply.github.com>
AuthorDate: Tue Apr 4 17:11:59 2023 +0200
[#1289] Fix cypress test for data lake configuration
---
ui/cypress/support/utils/PrepareTestDataUtils.ts | 8 ++--
.../tests/datalake/configuration.smoke.spec.ts | 53 ++++++++++++----------
2 files changed, 33 insertions(+), 28 deletions(-)
diff --git a/ui/cypress/support/utils/PrepareTestDataUtils.ts b/ui/cypress/support/utils/PrepareTestDataUtils.ts
index 6ff139280..c90726f26 100644
--- a/ui/cypress/support/utils/PrepareTestDataUtils.ts
+++ b/ui/cypress/support/utils/PrepareTestDataUtils.ts
@@ -19,7 +19,6 @@
import { FileManagementUtils } from './FileManagementUtils';
import { ConnectUtils } from './connect/ConnectUtils';
import { GenericAdapterBuilder } from '../builder/GenericAdapterBuilder';
-import { UserInputBuilder } from '../builder/UserInputBuilder';
export class PrepareTestDataUtils {
public static dataName = 'prepared_data';
@@ -38,7 +37,9 @@ export class PrepareTestDataUtils {
storeInDataLake,
);
- ConnectUtils.addGenericStreamAdapter(adapter);
+ ConnectUtils.addGenericAdapter(adapter);
+
+ ConnectUtils.startAdapter(adapter, true);
}
private static getDataLakeTestAdapter(
@@ -53,7 +54,8 @@ export class PrepareTestDataUtils {
'radio',
'speed',
'fastest_\\(ignore_original_time\\)',
- );
+ )
+ .addProtocolInput('radio', 'replayonce', 'yes');
if (format === 'csv') {
adapterBuilder
diff --git a/ui/cypress/tests/datalake/configuration.smoke.spec.ts b/ui/cypress/tests/datalake/configuration.smoke.spec.ts
index 6fe4ce897..bbb1afae1 100644
--- a/ui/cypress/tests/datalake/configuration.smoke.spec.ts
+++ b/ui/cypress/tests/datalake/configuration.smoke.spec.ts
@@ -39,38 +39,41 @@ describe('Test Truncate data in datalake', () => {
.should('be.visible')
.click();
- // Check if amount of events is zero
+ // Check if amount of events is zero. The should('have.text, '0') is required to check for text equality
cy.dataCy('datalake-number-of-events', { timeout: 10000 })
.should('be.visible')
- .contains('0');
+ .should($element => {
+ const text = $element.text().trim();
+ expect(text).to.equal('0');
+ });
});
-});
-describe('Delete data in datalake', () => {
- before('Setup Test', () => {
- cy.initStreamPipesTest();
- DataLakeUtils.loadRandomDataSetIntoDataLake();
- PipelineUtils.deletePipeline();
- });
+ describe('Delete data in datalake', () => {
+ before('Setup Test', () => {
+ cy.initStreamPipesTest();
+ DataLakeUtils.loadRandomDataSetIntoDataLake();
+ PipelineUtils.deletePipeline();
+ });
- it('Perform Test', () => {
- DataLakeUtils.goToDatalakeConfiguration();
+ it('Perform Test', () => {
+ DataLakeUtils.goToDatalakeConfiguration();
- // Check if amount of events is correct
- cy.dataCy('datalake-number-of-events', { timeout: 10000 })
- .should('be.visible')
- .contains('10');
+ // Check if amount of events is correct
+ cy.dataCy('datalake-number-of-events', { timeout: 10000 })
+ .should('be.visible')
+ .contains('10');
- // Delete data
- cy.dataCy('datalake-delete-btn').should('be.visible').click();
- cy.dataCy('confirm-delete-data-btn', { timeout: 10000 })
- .should('be.visible')
- .click();
+ // Delete data
+ cy.dataCy('datalake-delete-btn').should('be.visible').click();
+ cy.dataCy('confirm-delete-data-btn', { timeout: 10000 })
+ .should('be.visible')
+ .click();
- // Check if amount of events is zero
- cy.dataCy('datalake-number-of-events', { timeout: 10000 }).should(
- 'have.length',
- 0,
- );
+ // Check if amount of events is zero
+ cy.dataCy('datalake-number-of-events', { timeout: 10000 }).should(
+ 'have.length',
+ 0,
+ );
+ });
});
});