52 lines
2.4 KiB
JavaScript
52 lines
2.4 KiB
JavaScript
const assert = require('assert')
|
|
const { tokenFor, openIdConfiguration } = require('../utils')
|
|
const { reset, expectUser, expectVhost, expectResource, allow, verifyAll } = require('../mock_http_backend')
|
|
const {execSync} = require('child_process')
|
|
|
|
const profiles = process.env.PROFILES || ""
|
|
var backends = ""
|
|
for (const element of profiles.split(" ")) {
|
|
if ( element.startsWith("auth_backends-") ) {
|
|
backends = element.substring(element.indexOf("-")+1)
|
|
}
|
|
}
|
|
|
|
describe('Having AMQP 1.0 protocol enabled and the following auth_backends: ' + backends, function () {
|
|
let expectations = []
|
|
let username = process.env.RABBITMQ_AMQP_USERNAME
|
|
let password = process.env.RABBITMQ_AMQP_PASSWORD
|
|
let usemtls = process.env.AMQP_USE_MTLS
|
|
let amqpClientCommand = "npm run amqp10_roundtriptest" +
|
|
(usemtls ? "" : " " + username + " " + password)
|
|
|
|
before(function () {
|
|
if (backends.includes("http") && username.includes("http")) {
|
|
reset()
|
|
expectations.push(expectUser({ "username": username, "password": password}, "allow"))
|
|
expectations.push(expectVhost({ "username": username, "vhost": "/"}, "allow"))
|
|
expectations.push(expectResource({ "username": username, "vhost": "/", "resource": "queue", "name": "my-queue", "permission":"configure", "tags":""}, "allow"))
|
|
expectations.push(expectResource({ "username": username, "vhost": "/", "resource": "queue", "name": "my-queue", "permission":"read", "tags":""}, "allow"))
|
|
expectations.push(expectResource({ "username": username, "vhost": "/", "resource": "exchange", "name": "amq.default", "permission":"write", "tags":""}, "allow"))
|
|
}else if (backends.includes("oauth") && username.includes("oauth")) {
|
|
let oauthProviderUrl = process.env.OAUTH_PROVIDER_URL
|
|
let oauthClientId = process.env.OAUTH_CLIENT_ID
|
|
let oauthClientSecret = process.env.OAUTH_CLIENT_SECRET
|
|
console.log("oauthProviderUrl : " + oauthProviderUrl)
|
|
let openIdConfig = openIdConfiguration(oauthProviderUrl)
|
|
console.log("Obtained token_endpoint : " + openIdConfig.token_endpoint)
|
|
password = tokenFor(oauthClientId, oauthClientSecret, openIdConfig.token_endpoint)
|
|
console.log("Obtained access token : " + password)
|
|
}
|
|
})
|
|
|
|
it('can open an AMQP 1.0 connection', function () {
|
|
console.log(execSync(amqpClientCommand).toString())
|
|
})
|
|
|
|
after(function () {
|
|
if ( backends.includes("http") ) {
|
|
verifyAll(expectations)
|
|
}
|
|
})
|
|
})
|