|
@@ -1,7 +1,6 @@
|
|
|
package com.provectus.kafka.ui.smokesuite.ksqldb;
|
|
|
|
|
|
import static com.provectus.kafka.ui.pages.ksqldb.enums.KsqlMenuTabs.STREAMS;
|
|
|
-import static com.provectus.kafka.ui.pages.ksqldb.enums.KsqlQueryConfig.SHOW_STREAMS;
|
|
|
import static com.provectus.kafka.ui.pages.ksqldb.enums.KsqlQueryConfig.SHOW_TABLES;
|
|
|
import static com.provectus.kafka.ui.pages.panels.enums.MenuItem.KSQL_DB;
|
|
|
import static org.apache.commons.lang3.RandomStringUtils.randomAlphabetic;
|
|
@@ -14,9 +13,6 @@ import io.qase.api.annotation.QaseId;
|
|
|
import java.util.ArrayList;
|
|
|
import java.util.List;
|
|
|
import org.testng.Assert;
|
|
|
-import java.util.ArrayList;
|
|
|
-import java.util.List;
|
|
|
-import org.testng.Assert;
|
|
|
import org.testng.annotations.AfterClass;
|
|
|
import org.testng.annotations.BeforeClass;
|
|
|
import org.testng.annotations.Test;
|
|
@@ -34,8 +30,6 @@ public class KsqlDbTest extends BaseTest {
|
|
|
.setName("SECOND_TABLE_" + randomAlphabetic(4).toUpperCase())
|
|
|
.setStreamName(DEFAULT_STREAM.getName());
|
|
|
private static final List<String> TOPIC_NAMES_LIST = new ArrayList<>();
|
|
|
- .setName("SECOND_TABLE_" + randomAlphabetic(4).toUpperCase())
|
|
|
- .setStreamName(DEFAULT_STREAM.getName());
|
|
|
|
|
|
@BeforeClass(alwaysRun = true)
|
|
|
public void beforeClass() {
|
|
@@ -86,15 +80,22 @@ public class KsqlDbTest extends BaseTest {
|
|
|
softly.assertAll();
|
|
|
}
|
|
|
|
|
|
- @QaseId(278)
|
|
|
+ @QaseId(86)
|
|
|
@Test(priority = 4)
|
|
|
- public void checkShowStreamsRequestExecution() {
|
|
|
- navigateToKsqlDbAndExecuteRequest(SHOW_STREAMS.getQuery());
|
|
|
+ public void clearResultsForExecutedRequest() {
|
|
|
+ navigateToKsqlDbAndExecuteRequest(SHOW_TABLES.getQuery());
|
|
|
SoftAssert softly = new SoftAssert();
|
|
|
softly.assertTrue(ksqlQueryForm.areResultsVisible(), "areResultsVisible()");
|
|
|
- softly.assertTrue(ksqlQueryForm.getItemByName(DEFAULT_STREAM.getName()).isVisible(),
|
|
|
- String.format("getItemByName(%s)", FIRST_TABLE.getName()));
|
|
|
softly.assertAll();
|
|
|
+ ksqlQueryForm
|
|
|
+ .clickClearResultsBtn();
|
|
|
+ softly.assertFalse(ksqlQueryForm.areResultsVisible(), "areResultsVisible()");
|
|
|
+ softly.assertAll();
|
|
|
+ }
|
|
|
+
|
|
|
+ @AfterClass(alwaysRun = true)
|
|
|
+ public void afterClass() {
|
|
|
+ TOPIC_NAMES_LIST.forEach(topicName -> apiService.deleteTopic(topicName));
|
|
|
}
|
|
|
|
|
|
@Step
|