Add queue and filter

Author: MarcialRosales

selenium/test/pageobjects/QueuesAndStreamsPage.js

@@ -6,8 +6,11 @@ const BasePage = require('./BasePage')
 const PAGING_SECTION = By.css('div#queues-paging-section')
 const PAGING_SECTION_HEADER = By.css('div#queues-paging-section h2')
 const ADD_NEW_QUEUE_SECTION = By.css('div#add-new-queue')
+const FILTER_BY_QUEUE_NAME = By.css('div.filter input#queues-name')
 
 const TABLE_SECTION = By.css('div#queues-table-section table')
+const FORM_QUEUE_NAME = By.css('div#add-new-queue form input[name="name"]')
+const ADD_BUTTON = By.css('div#add-new-queue form input[type=submit]')
 
 module.exports = class QueuesAndStreamsPage extends BasePage {
   async isLoaded () {
@@ -23,12 +26,16 @@ module.exports = class QueuesAndStreamsPage extends BasePage {
     return this.click(By.css(
       "div#queues-table-section table tbody tr td a[href='#/queue/" + vhost + "/" + name + "']"))
   }
-  async ensureAddQueueSectionIsVisible() {
-    if (!await this.isDisplayed(ADD_NEW_QUEUE_SECTION)) {
-      console.log("add new queue section is not visible")
-      return this.click(ADD_NEW_QUEUE_SECTION)
-    }else {
-      console.log("add new queue section is visible")
-    }
+  async ensureAddQueueSectionIsVisible() {    
+    await this.click(ADD_NEW_QUEUE_SECTION)
+    return driver.findElement(ADD_NEW_QUEUE_SECTION).isDisplayed()
+  }
+  async fillInAddNewQueue(queueDetails) {
+    await this.sendKeys(FORM_QUEUE_NAME, queueDetails.name)
+    return this.click(ADD_BUTTON)    
+  }
+  async filter(filterValue) {
+    return this.sendKeys(FILTER_BY_QUEUE_NAME, filterValue)
+    
   }
 }

selenium/test/queuesAndStreams/management.js

@@ -31,16 +31,27 @@ describe('Queues and Streams management', function () {
     if (!await overview.isLoaded()) {
       throw new Error('Failed to login')
     }
+    await overview.selectRefreshOption("Do not refresh")
     overview.clickOnQueuesTab()
   })
 
   it('display summary of queues and streams', async function () {
-    assert.equal("All queues (0)", await queuesAndStreams.getPagingSectionHeaderText())
+    let text = await queuesAndStreams.getPagingSectionHeaderText()
+    assert.equal(true, text.startsWith('All queues') )
   })
 
-  it('add queue and view it', async function () {
+  it('add queue', async function () {
     await queuesAndStreams.ensureAddQueueSectionIsVisible()
-    
+    let queueName = "test_" + Math.floor(Math.random() * 1000)
+    await queuesAndStreams.fillInAddNewQueue({"name" : queueName})
+    await queuesAndStreams.filter(queueName)
+
+    let table = await queuesAndStreams.getQueuesTable(5)
+    assert.equal(1, table.length)
+    assert.equal(table[0][0], '/')
+    assert.equal(table[0][1], queueName)
+    assert.equal(table[0][2], 'classic')
+    assert.equal(table[0][4], 'running')
   })
 
   after(async function () {