1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70
|
require 'spec_helper'
provider_class = Puppet::Type.type(:rabbitmq_exchange).provider(:rabbitmqadmin)
describe provider_class do
let(:resource) do
Puppet::Type::Rabbitmq_exchange.new(
name: 'test.headers@/',
type: :headers,
internal: :false,
durable: :true,
auto_delete: :false,
arguments: {
'hash-headers' => 'message-distribution-hash'
}
)
end
let(:provider) { provider_class.new(resource) }
it 'returns instances' do
provider_class.expects(:rabbitmqctl_list).with('vhosts').returns <<-EOT
/
EOT
provider_class.expects(:rabbitmqctl_list).with('exchanges', '-p', '/', 'name', 'type', 'internal', 'durable', 'auto_delete', 'arguments').returns <<-EOT
direct false true false []
amq.direct direct false true false []
amq.fanout fanout false true false []
amq.headers headers false true false []
amq.match headers false true false []
amq.rabbitmq.log topic true true false []
amq.rabbitmq.trace topic true true false []
amq.topic topic false true false []
test.headers x-consistent-hash false true false [{"hash-header","message-distribution-hash"}]
EOT
instances = provider_class.instances
expect(instances.size).to eq(9)
end
it 'calls rabbitmqadmin to create as guest' do
provider.expects(:rabbitmqadmin).with('declare', 'exchange', '--vhost=/', '--user=guest', '--password=guest', 'name=test.headers', 'type=headers', 'internal=false', 'durable=true', 'auto_delete=false', 'arguments={"hash-headers":"message-distribution-hash"}', '-c', '/etc/rabbitmq/rabbitmqadmin.conf')
provider.create
end
it 'calls rabbitmqadmin to destroy' do
provider.expects(:rabbitmqadmin).with('delete', 'exchange', '--vhost=/', '--user=guest', '--password=guest', 'name=test.headers', '-c', '/etc/rabbitmq/rabbitmqadmin.conf')
provider.destroy
end
context 'specifying credentials' do
let(:resource) do
Puppet::Type::Rabbitmq_exchange.new(
name: 'test.headers@/',
type: :headers,
internal: 'false',
durable: 'true',
auto_delete: 'false',
user: 'colin',
password: 'secret',
arguments: {
'hash-header' => 'message-distribution-hash'
}
)
end
let(:provider) { provider_class.new(resource) }
it 'calls rabbitmqadmin to create with credentials' do
provider.expects(:rabbitmqadmin).with('declare', 'exchange', '--vhost=/', '--user=colin', '--password=secret', 'name=test.headers', 'type=headers', 'internal=false', 'durable=true', 'auto_delete=false', 'arguments={"hash-header":"message-distribution-hash"}', '-c', '/etc/rabbitmq/rabbitmqadmin.conf')
provider.create
end
end
end
|