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

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