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

   1 require 'spec_helper'
   2
   3 provider_class = Puppet::Type.type(:rabbitmq_queue).provider(:rabbitmqadmin)
   4 describe provider_class do
   5   let(:resource) do
   6     Puppet::Type::Rabbitmq_queue.new(
   7       name: 'test@/',
   8       durable: :true,
   9       auto_delete: :false,
  10       arguments: {}
  11     )
  12   end
  13   let(:provider) { provider_class.new(resource) }
  14
  15   it 'returns instances' do
  16     provider_class.expects(:rabbitmqctl).with('list_vhosts', '-q').returns <<-EOT
  17 /
  18 EOT
  19     provider_class.expects(:rabbitmqctl).with('list_queues', '-q', '-p', '/', 'name', 'durable', 'auto_delete', 'arguments').returns <<-EOT
  20 test  true  false []
  21 test2 true  false [{"x-message-ttl",342423},{"x-expires",53253232},{"x-max-length",2332},{"x-max-length-bytes",32563324242},{"x-dead-letter-exchange","amq.direct"},{"x-dead-letter-routing-key","test.routing"}]
  22 EOT
  23     instances = provider_class.instances
  24     expect(instances.size).to eq(2)
  25   end
  26
  27   it 'calls rabbitmqadmin to create' do
  28     provider.expects(:rabbitmqadmin).with('declare', 'queue', '--vhost=/', '--user=guest', '--password=guest', '-c', '/etc/rabbitmq/rabbitmqadmin.conf', 'name=test', 'durable=true', 'auto_delete=false', 'arguments={}')
  29     provider.create
  30   end
  31
  32   it 'calls rabbitmqadmin to destroy' do
  33     provider.expects(:rabbitmqadmin).with('delete', 'queue', '--vhost=/', '--user=guest', '--password=guest', '-c', '/etc/rabbitmq/rabbitmqadmin.conf', 'name=test')
  34     provider.destroy
  35   end
  36
  37   context 'specifying credentials' do
  38     let(:resource) do
  39       Puppet::Type::Rabbitmq_queue.new(
  40         name: 'test@/',
  41         durable: 'true',
  42         auto_delete: 'false',
  43         arguments: {},
  44         user: 'colin',
  45         password: 'secret'
  46       )
  47     end
  48     let(:provider) { provider_class.new(resource) }
  49
  50     it 'calls rabbitmqadmin to create' do
  51       provider.expects(:rabbitmqadmin).with('declare', 'queue', '--vhost=/', '--user=colin', '--password=secret', '-c', '/etc/rabbitmq/rabbitmqadmin.conf', 'name=test', 'durable=true', 'auto_delete=false', 'arguments={}')
  52       provider.create
  53     end
  54   end
  55 end