Add queues and streams page and test suite

Author: MarcialRosales

deps/rabbitmq_management/priv/www/js/tmpl/queues.ejs

@@ -1,9 +1,9 @@
 
 <h1>Queues</h1>
-<div class="section">
+<div class="section" id="queues-paging-section">
   <%= paginate_ui(queues, 'queues') %>
 </div>
-<div class="updatable">
+<div class="updatable" id="queues-table-section">
 <% if (queues.items.length > 0) { %>
 <table class="list">
  <thead>
@@ -222,7 +222,7 @@
 </div>
 
 <% if (ac.canAccessVhosts()) { %>
-<div class="section-hidden">
+<div class="section-hidden" id="add-new-queue">
   <h2>Add a new queue</h2>
   <div class="hider">
     <form action="#/queues" method="put">

selenium/suites/mgt/queuesAndStreams.sh

@@ -0,0 +1,9 @@
+#!/usr/bin/env bash
+
+SCRIPT="$( cd "$( dirname "${BASH_SOURCE[0]}" )" && pwd )"
+
+TEST_CASES_PATH=/queuesAndStreams
+TEST_CONFIG_PATH=/basic-auth
+
+source $SCRIPT/../../bin/suite_template $@
+run

selenium/test/pageobjects/QueuePage.js

@@ -0,0 +1,16 @@
+const { By, Key, until, Builder } = require('selenium-webdriver')
+
+const BasePage = require('./BasePage')
+
+
+const QUEUE_NAME = By.css('div#main h1 p')
+
+
+module.exports = class QueuePage extends BasePage {
+  async isLoaded() {
+    return this.waitForDisplayed(QUEUE_NAME)
+  }
+  async getName() {
+    return this.getText(QUEUE_NAME)
+  }
+}

selenium/test/pageobjects/QueuesAndStreamsPage.js

@@ -0,0 +1,34 @@
+const { By, Key, until, Builder } = require('selenium-webdriver')
+
+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 TABLE_SECTION = By.css('div#queues-table-section table')
+
+module.exports = class QueuesAndStreamsPage extends BasePage {
+  async isLoaded () {
+    return this.waitForDisplayed(PAGING_SECTION)
+  }
+  async getPagingSectionHeaderText() {
+    return this.getText(PAGING_SECTION_HEADER)
+  }
+  async getQueuesTable(firstNColumns) {
+    return this.getTable(TABLE_SECTION, firstNColumns)
+  }
+  async clickOnQueue(vhost, name) {
+    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")
+    }
+  }
+}

selenium/test/pageobjects/StreamPage.js

@@ -0,0 +1,16 @@
+const { By, Key, until, Builder } = require('selenium-webdriver')
+
+const BasePage = require('./BasePage')
+
+
+const STREAM_NAME = By.css('div#main h1 p')
+
+
+module.exports = class StreamPage extends BasePage {
+  async isLoaded() {
+    return this.waitForDisplayed(STREAM_NAME)
+  }
+  async getName() {
+    return this.getText(STREAM_NAME)
+  }
+}

selenium/test/queuesAndStreams/management.js

@@ -0,0 +1,49 @@
+const { By, Key, until, Builder } = require('selenium-webdriver')
+require('chromedriver')
+const assert = require('assert')
+const { buildDriver, goToHome, captureScreensFor, teardown, delay } = require('../utils')
+
+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('Queues and Streams management', function () {
+  let login
+  let queuesAndStreams
+  let queue
+  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)
+    queue = new QueuePage(driver)
+    stream = new StreamPage(driver)
+    captureScreen = captureScreensFor(driver, __filename)
+
+    await login.login('guest', 'guest')
+    if (!await overview.isLoaded()) {
+      throw new Error('Failed to login')
+    }
+    overview.clickOnQueuesTab()
+  })
+
+  it('display summary of queues and streams', async function () {
+    assert.equal("All queues (0)", await queuesAndStreams.getPagingSectionHeaderText())
+  })
+
+  it('add queue and view it', async function () {
+    await queuesAndStreams.ensureAddQueueSectionIsVisible()
+    
+  })
+
+  after(async function () {
+    await teardown(driver, this, captureScreen)
+  })
+})

selenium/test/utils.js

@@ -62,7 +62,9 @@ module.exports = {
     chromeCapabilities.set('goog:chromeOptions', {
       args: [
           "--lang=en",
-          "--disable-search-engine-choice-screen"
+          "--disable-search-engine-choice-screen",
+          "--disable-popup-blocking",
+          "--credentials_enable_service=false"
       ]
     });
     driver = builder