3rdparty/modules/rabbitmq/spec/unit/puppet/provider/rabbitmq_exchange/rabbitmqadmin_spec.rb

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