Sha256: 79508f2548710997dd4a3bbc4bdd2fd89e4c8932773cc1ef5769403277cf8d57

Contents?: true

Size: 1.63 KB

Versions: 39

Compression:

Stored size: 1.63 KB

Contents

#! /usr/bin/env ruby
require 'spec_helper'

require 'puppet/resource/catalog'

describe "Puppet::Resource::Catalog::Queue" do
  before do
    Puppet::Resource::Catalog.indirection.terminus(:queue)
    @catalog = Puppet::Resource::Catalog.new("foo", Puppet::Node::Environment::NONE)

    @one = Puppet::Resource.new(:file, "/one")
    @two = Puppet::Resource.new(:file, "/two")
    @catalog.add_resource(@one, @two)

    @catalog.add_edge(@one, @two)

    Puppet[:trace] = true
  end

  it "should render catalogs to pson and publish them via the queue client when catalogs are saved" do
    terminus = Puppet::Resource::Catalog.indirection.terminus(:queue)

    client = mock 'client'
    terminus.stubs(:client).returns client

    client.expects(:publish_message).with(:catalog, @catalog.to_pson)

    request = Puppet::Indirector::Request.new(:catalog, :save, "foo", @catalog)

    terminus.save(request)
  end

  it "should intern catalog messages when they are passed via a subscription" do
    client = mock 'client'
    Puppet::Resource::Catalog::Queue.stubs(:client).returns client

    pson = @catalog.to_pson

    client.expects(:subscribe).with(:catalog).yields(pson)

    Puppet.expects(:err).never

    result = []
    Puppet::Resource::Catalog::Queue.subscribe do |catalog|
      result << catalog
    end

    catalog = result.shift
    catalog.should be_instance_of(Puppet::Resource::Catalog)

    catalog.resource(:file, "/one").should be_instance_of(Puppet::Resource)
    catalog.resource(:file, "/two").should be_instance_of(Puppet::Resource)
    catalog.should be_edge(catalog.resource(:file, "/one"), catalog.resource(:file, "/two"))
  end
end

Version data entries

39 entries across 39 versions & 1 rubygems

Version Path
puppet-3.8.7 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.7-x86-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.7-x64-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.6 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.6-x86-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.6-x64-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.5 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.5-x86-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.5-x64-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.4 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.4-x86-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.4-x64-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.3 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.3-x86-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.3-x64-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.2 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.2-x86-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.2-x64-mingw32 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.1 spec/integration/indirector/catalog/queue_spec.rb
puppet-3.8.1-x86-mingw32 spec/integration/indirector/catalog/queue_spec.rb