Test connection is opened

Author: MarcialRosales

selenium/test/queuesAndStreams/view-mqtt-qos0.js

@@ -1,15 +1,15 @@
 const { By, Key, until, Builder } = require('selenium-webdriver')
 require('chromedriver')
 const assert = require('assert')
-const { buildDriver, goToHome, captureScreensFor, teardown, doUntil, findTableRow, goToQueue } = require('../utils')
+const { buildDriver, goToHome, goToQueue, captureScreensFor, teardown, doUntil, findTableRow } = require('../utils')
 const { createQueue, deleteQueue, getManagementUrl, basicAuthorization } = require('../mgt-api')
 const mqtt = require('mqtt')
 
 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');
+const ConnectionsPage = require('../pageobjects/ConnectionsPage');
 
 
 describe('Given a mqtt 5.0 connection with a qos 0 subscription with zero sessionExpiryInterval', function () {
@@ -36,15 +36,15 @@ describe('Given a mqtt 5.0 connection with a qos 0 subscription with zero sessio
     login = new LoginPage(driver)
     overview = new OverviewPage(driver)
     queuePage = new QueuePage(driver)
+    connectionsPage = new ConnectionsPage(driver)
     queuesAndStreamsPage = new QueuesAndStreamsPage(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()
+    //await overview.selectRefreshOption("Do not refresh")
 
     queueName = "test_" + Math.floor(Math.random() * 1000)
     createQueue(getManagementUrl(), basicAuthorization("management", "guest"), 
@@ -83,32 +83,46 @@ describe('Given a mqtt 5.0 connection with a qos 0 subscription with zero sessio
         }),
         mqttClient.on('connect', function(err) {
           mqttClient.subscribe(queueName, {qos:0}, function (err2) {
-            if (!err2) {              
+            if (!err2) {     
               resolve("ok")
             }else {
               reject(err2)
             }
           })
         })
-      })
+      })    
     assert.equal("ok", await subscribed)
+    
+  })
+
+  it('should be an mqtt connection', async function () {
+    await overview.clickOnConnectionsTab()
+    
+    let table = await doUntil(async function() {       
+      return connectionsPage.getConnectionsTable()
+    }, function(table) { 
+      return table.length > 0
+    }, 6000)
+    assert.equal(table[0][5], "MQTT 5-0")
 
   })
 
   it('should be an mqtt qos0 queue listed', async function () {
-   
-    await doUntil(function() {
+    await overview.clickOnQueuesTab()
+    
+    await doUntil(function() {      
       return queuesAndStreamsPage.getQueuesTable()
     }, function(table) { 
       return findTableRow(table, function(row) {
         return row[2] === 'rabbit_mqtt_qos0_queue'
       })
     })
-    console.log("done")
+    
   })
 
    it('can view mqtt qos0 queue', async function () {
-   
+    await overview.clickOnQueuesTab()
+    
     let table = await doUntil(function() {
       return queuesAndStreamsPage.getQueuesTable()
     }, function(t) { 

selenium/test/utils.js

@@ -126,10 +126,18 @@ module.exports = {
     return d.driver.get(d.baseUrl + '#/login?access_token=' + token)
   },
 
+  goToConnections: (d) => {
+    return d.driver.get(d.baseUrl + '#/connections')
+  },
+
   goToExchanges: (d) => {
     return d.driver.get(d.baseUrl + '#/exchanges')
   },
 
+  goToQueues: (d) => {
+    return d.driver.get(d.baseUrl + '#/queues')
+  },
+    
   goToQueue(d, vhost, queue) {
     return d.driver.get(d.baseUrl + '#/queues/' + encodeURIComponent(vhost) + '/' + encodeURIComponent(queue))
   },