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

   1 require 'puppet'
   2 require 'mocha/api'
   3 RSpec.configure do |config|
   4   config.mock_with :mocha
   5 end
   6 provider_class = Puppet::Type.type(:rabbitmq_binding).provider(:rabbitmqadmin)
   7 describe provider_class do
   8   before :each do
   9     @resource = Puppet::Type::Rabbitmq_binding.new(
  10       {:name => 'source@target@/',
  11        :destination_type => :queue,
  12        :routing_key => 'blablub',
  13        :arguments => {}
  14       }
  15     )
  16     @provider = provider_class.new(@resource)
  17   end
  18
  19   it 'should return instances' do
  20     provider_class.expects(:rabbitmqctl).with('list_vhosts', '-q').returns <<-EOT
  21 /
  22 EOT
  23     provider_class.expects(:rabbitmqctl).with('list_bindings', '-q', '-p', '/', 'source_name', 'destination_name', 'destination_kind', 'routing_key', 'arguments').returns <<-EOT
  24     queue queue queue []
  25 EOT
  26     instances = provider_class.instances
  27     instances.size.should == 1
  28   end
  29
  30   it 'should call rabbitmqadmin to create' do
  31     @provider.expects(:rabbitmqadmin).with('declare', 'binding', '--vhost=/', '--user=guest', '--password=guest', '-c', '/etc/rabbitmq/rabbitmqadmin.conf', 'source=source', 'destination=target', 'arguments={}', 'routing_key=blablub', 'destination_type=queue')
  32     @provider.create
  33   end
  34
  35   it 'should call rabbitmqadmin to destroy' do
  36     @provider.expects(:rabbitmqadmin).with('delete', 'binding', '--vhost=/', '--user=guest', '--password=guest', '-c', '/etc/rabbitmq/rabbitmqadmin.conf', 'source=source', 'destination_type=queue', 'destination=target', 'properties_key=blablub')
  37     @provider.destroy
  38   end
  39
  40   context 'specifying credentials' do
  41     before :each do
  42       @resource = Puppet::Type::Rabbitmq_binding.new(
  43         {:name => 'source@test2@/',
  44          :destination_type => :queue,
  45          :routing_key => 'blablubd',
  46          :arguments => {},
  47          :user => 'colin',
  48          :password => 'secret'
  49         }
  50       )
  51       @provider = provider_class.new(@resource)
  52     end
  53
  54     it 'should call rabbitmqadmin to create' do
  55       @provider.expects(:rabbitmqadmin).with('declare', 'binding', '--vhost=/', '--user=colin', '--password=secret', '-c', '/etc/rabbitmq/rabbitmqadmin.conf', 'source=source', 'destination=test2', 'arguments={}', 'routing_key=blablubd', 'destination_type=queue')
  56       @provider.create
  57     end
  58   end
  59 end