Support both auth mechanism basic and mtls with mqtt

Author: MarcialRosales

selenium/test/authnz-msg-protocols/env.auth-mtls

@@ -0,0 +1 @@
+export MQTT_USE_MTLS=true 

selenium/test/authnz-msg-protocols/mqtt.js

@@ -16,14 +16,13 @@ describe('Having MQTT protocol enbled and the following auth_backends: ' + backe
   let mqttOptions
   let expectations = []
   let mqttProtocol = process.env.MQTT_PROTOCOL || 'mqtt'
+  let usemtls = process.env.MQTT_USE_MTLS || false
   let rabbit = process.env.RABBITMQ_HOSTNAME || 'localhost'
   let mqttUrl = process.env.RABBITMQ_MQTT_URL || "mqtt://" + rabbit + ":1883"
   let username = process.env.RABBITMQ_AMQP_USERNAME
   let password = process.env.RABBITMQ_AMQP_PASSWORD
   let client_id = process.env.RABBITMQ_AMQP_USERNAME || 'selenium-client'
 
-  console.log("RABBITMQ_CERTS : " + process.env.RABBITMQ_CERTS)
-
   before(function () {
     if (backends.includes("http") && username.includes("http")) {
       reset()
@@ -45,14 +44,17 @@ describe('Having MQTT protocol enbled and the following auth_backends: ' + backe
       protocolVersion: 4,
       keepalive: 10000,
       clean: false,
-      reconnectPeriod: '1000',
-      username: username,
-      password: password
+      reconnectPeriod: '1000'
     }
     if (mqttProtocol == 'mqtts') {
-      mqttOptions["ca"] = [fs.readFileSync(process.env.RABBITMQ_CERTS + "/ca_rabbitmq_certificate.pem")]
+      mqttOptions["ca"] = [fs.readFileSync(process.env.RABBITMQ_CERTS + "/ca_rabbitmq_certificate.pem")]      
+    } 
+    if (usemtls) {
       mqttOptions["cert"] = fs.readFileSync(process.env.RABBITMQ_CERTS + "/client_rabbitmq_certificate.pem")
       mqttOptions["key"] = fs.readFileSync(process.env.RABBITMQ_CERTS + "/client_rabbitmq_key.pem")
+    } else {
+      mqttOptions["username"] = username
+      mqttOptions["password"] = password
     }
   })