Add initial test

Author: MarcialRosales

selenium/test/pageobjects/QueuePage.js

@@ -1,6 +1,7 @@
 const { By, Key, until, Builder } = require('selenium-webdriver')
 
 const BasePage = require('./BasePage')
+const { goTo } = require('../utils')
 
 
 const QUEUE_NAME = By.css('div#main h1 b')
@@ -15,6 +16,9 @@ module.exports = class QueuePage extends BasePage {
   async getName() {
     return this.getText(QUEUE_NAME)
   }
+  async goToQueue(vhost, queue) {
+    return goTo('#/queues/' + encodeURIComponent(vhost) + '/' + encodeURIComponent(queue))
+  }
   async ensureDeleteQueueSectionIsVisible() {    
     await this.click(DELETE_SECTION)
     return this.driver.findElement(DELETE_SECTION).isDisplayed()

selenium/test/queuesAndStreams/view-qq-consumers.js

@@ -0,0 +1,55 @@
+const { By, Key, until, Builder } = require('selenium-webdriver')
+require('chromedriver')
+const assert = require('assert')
+const { buildDriver, goToHome, captureScreensFor, teardown, delay, goToExchanges } = require('../utils')
+const { createQueue, deleteQueue, getManagementUrl } = require('../mgt-api')
+
+const LoginPage = require('../pageobjects/LoginPage')
+const OverviewPage = require('../pageobjects/OverviewPage')
+const QueuesAndStreamsPage = require('../pageobjects/QueuesAndStreamsPage')
+const QueuePage = require('../pageobjects/QueuePage')
+const StreamPage = require('../pageobjects/StreamPage')
+
+describe('Given a quorum queue', function () {
+  let login
+  let queuesAndStreams
+  let queuePage
+  let queueName
+  let stream
+  let overview
+  let captureScreen
+
+  before(async function () {
+    driver = buildDriver()
+    await goToHome(driver)
+    login = new LoginPage(driver)
+    overview = new OverviewPage(driver)
+    queuesAndStreams = new QueuesAndStreamsPage(driver)
+    queuePage = new QueuePage(driver)
+    stream = new StreamPage(driver)
+    captureScreen = captureScreensFor(driver, __filename)
+
+    await login.login('management', 'guest')
+    if (!await overview.isLoaded()) {
+      throw new Error('Failed to login')
+    }
+    await overview.selectRefreshOption("Do not refresh")
+    await overview.clickOnQueuesTab()
+    queueName = "test_" + Math.floor(Math.random() * 1000)
+  
+    createQueue(getManagementUrl(), queueName, "/", "quorum")
+    
+  })
+
+  it('add quorum queue and view it', async function () {    
+    await queuePage.goToQueue("/", queueName)
+    await queuePage.isLoaded()
+    assert.equal(queueName, await queuePage.getName())
+     
+  })
+
+  after(async function () {    
+    await teardown(driver, this, captureScreen)
+    deleteQueue(getManagementUrl(), "/", queueName)
+  })
+})

selenium/test/utils.js

@@ -127,11 +127,11 @@ module.exports = {
   },
 
   goToExchanges: (d) => {
-    return d.driver.get(d.baseUrl + '#/exchanges')
+    return this.goTo('#/exchanges')
   },
-
-  goTo: (d, address) => {
-    return d.get(address)
+    
+  goTo: (d, path) => {
+    return d.ddriver.get(d.baseUrl + path)
   },
 
   delay: async (msec, ref) => {