Switching Queueing to using JSON instead of YAML

This provides about a 75x speedup, so it's totally
worth it.  The downside is that queueing requires json,
but only on the server side.

1 files changed, 59 insertions, 0 deletions

diff --git a/spec/integration/indirector/catalog/queue.rb b/spec/integration/indirector/catalog/queue.rb
new file mode 100755
index 000000000..22f29aac3
--- /dev/null
+++ b/spec/integration/indirector/catalog/queue.rb
@@ -0,0 +1,59 @@
+#!/usr/bin/env ruby
+
+Dir.chdir(File.dirname(__FILE__)) { (s = lambda { |f| File.exist?(f) ? require(f) : Dir.chdir("..") { s.call(f) } }).call("spec/spec_helper.rb") }
+
+require 'puppet/resource/catalog'
+
+Puppet::Resource::Catalog.indirection.terminus(:queue)
+
+describe Puppet::Resource::Catalog::Queue do
+    before do
+        @catalog = Puppet::Resource::Catalog.new
+
+        @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
+
+    after { Puppet.settings.clear }
+
+    it "should render catalogs to json and send 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(:send_message).with(:catalog, @catalog.to_json)
+
+        request = Puppet::Indirector::Request.new(:catalog, :save, "foo", :instance => @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
+
+        json = @catalog.to_json
+
+        client.expects(:subscribe).with(:catalog).yields(json)
+
+        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