diff options
Diffstat (limited to 'spec/integration/transaction_spec.rb')
| -rwxr-xr-x | spec/integration/transaction_spec.rb | 247 |
1 files changed, 247 insertions, 0 deletions
diff --git a/spec/integration/transaction_spec.rb b/spec/integration/transaction_spec.rb new file mode 100755 index 000000000..6a4dbae67 --- /dev/null +++ b/spec/integration/transaction_spec.rb @@ -0,0 +1,247 @@ +#!/usr/bin/env ruby + +require File.dirname(__FILE__) + '/../spec_helper' + +require 'puppet_spec/files' +require 'puppet/transaction' +require 'puppet_spec/files' + +describe Puppet::Transaction do + include PuppetSpec::Files + + def mk_catalog(*resources) + catalog = Puppet::Resource::Catalog.new(Puppet::Node.new("mynode")) + resources.each { |res| catalog.add_resource res } + catalog + end + + it "should not apply generated resources if the parent resource fails" do + catalog = Puppet::Resource::Catalog.new + resource = Puppet::Type.type(:file).new :path => "/foo/bar", :backup => false + catalog.add_resource resource + + child_resource = Puppet::Type.type(:file).new :path => "/foo/bar/baz", :backup => false + + resource.expects(:eval_generate).returns([child_resource]) + + transaction = Puppet::Transaction.new(catalog) + + resource.expects(:retrieve).raises "this is a failure" + resource.stubs(:err) + + child_resource.expects(:retrieve).never + + transaction.evaluate + end + + it "should not apply virtual resources" do + catalog = Puppet::Resource::Catalog.new + resource = Puppet::Type.type(:file).new :path => "/foo/bar", :backup => false + resource.virtual = true + catalog.add_resource resource + + transaction = Puppet::Transaction.new(catalog) + + resource.expects(:evaluate).never + + transaction.evaluate + end + + it "should apply exported resources" do + catalog = Puppet::Resource::Catalog.new + path = tmpfile("exported_files") + resource = Puppet::Type.type(:file).new :path => path, :backup => false, :ensure => :file + resource.exported = true + catalog.add_resource resource + + catalog.apply + FileTest.should be_exist(path) + end + + it "should not apply virtual exported resources" do + catalog = Puppet::Resource::Catalog.new + resource = Puppet::Type.type(:file).new :path => "/foo/bar", :backup => false + resource.exported = true + resource.virtual = true + catalog.add_resource resource + + transaction = Puppet::Transaction.new(catalog) + + resource.expects(:evaluate).never + + transaction.evaluate + end + + # Verify that one component requiring another causes the contained + # resources in the requiring component to get refreshed. + it "should propagate events from a contained resource through its container to its dependent container's contained resources" do + transaction = nil + file = Puppet::Type.type(:file).new :path => tmpfile("event_propagation"), :ensure => :present + execfile = File.join(tmpdir("exec_event"), "exectestingness2") + exec = Puppet::Type.type(:exec).new :command => "touch #{execfile}", :path => ENV['PATH'] + catalog = mk_catalog(file) + + fcomp = Puppet::Type.type(:component).new(:name => "Foo[file]") + catalog.add_resource fcomp + catalog.add_edge(fcomp, file) + + ecomp = Puppet::Type.type(:component).new(:name => "Foo[exec]") + catalog.add_resource ecomp + catalog.add_resource exec + catalog.add_edge(ecomp, exec) + + ecomp[:subscribe] = Puppet::Resource.new(:foo, "file") + exec[:refreshonly] = true + + exec.expects(:refresh) + catalog.apply + end + + # Make sure that multiple subscriptions get triggered. + it "should propagate events to all dependent resources" do + path = tmpfile("path") + file1 = tmpfile("file1") + file2 = tmpfile("file2") + file = Puppet::Type.type(:file).new( + :path => path, + :ensure => "file" + ) + exec1 = Puppet::Type.type(:exec).new( + :path => ENV["PATH"], + :command => "touch %s" % file1, + :refreshonly => true, + :subscribe => Puppet::Resource.new(:file, path) + ) + exec2 = Puppet::Type.type(:exec).new( + :path => ENV["PATH"], + :command => "touch %s" % file2, + :refreshonly => true, + :subscribe => Puppet::Resource.new(:file, path) + ) + + catalog = mk_catalog(file, exec1, exec2) + catalog.apply + FileTest.should be_exist(file1) + FileTest.should be_exist(file2) + end + + it "should not let one failed refresh result in other refreshes failing" do + path = tmpfile("path") + newfile = tmpfile("file") + file = Puppet::Type.type(:file).new( + :path => path, + :ensure => "file" + ) + exec1 = Puppet::Type.type(:exec).new( + :path => ENV["PATH"], + :command => "touch /this/cannot/possibly/exist", + :logoutput => true, + :refreshonly => true, + :subscribe => file, + :title => "one" + ) + exec2 = Puppet::Type.type(:exec).new( + :path => ENV["PATH"], + :command => "touch %s" % newfile, + :logoutput => true, + :refreshonly => true, + :subscribe => [file, exec1], + :title => "two" + ) + + exec1.stubs(:err) + + catalog = mk_catalog(file, exec1, exec2) + catalog.apply + FileTest.should be_exists(newfile) + end + + it "should still trigger skipped resources" do + catalog = mk_catalog() + catalog.add_resource(*Puppet::Type.type(:schedule).mkdefaultschedules) + + Puppet[:ignoreschedules] = false + file = Puppet::Type.type(:file).new( + :name => tmpfile("file"), + :ensure => "file", + :backup => false + ) + + fname = tmpfile("exec") + exec = Puppet::Type.type(:exec).new( + :name => "touch #{fname}", + :path => "/usr/bin:/bin", + :schedule => "monthly", + :subscribe => Puppet::Resource.new("file", file.name) + ) + + catalog.add_resource(file, exec) + + # Run it once + catalog.apply + FileTest.should be_exists(fname) + + # Now remove it, so it can get created again + File.unlink(fname) + + file[:content] = "some content" + + catalog.apply + FileTest.should be_exists(fname) + + # Now remove it, so it can get created again + File.unlink(fname) + + # And tag our exec + exec.tag("testrun") + + # And our file, so it runs + file.tag("norun") + + Puppet[:tags] = "norun" + + file[:content] = "totally different content" + + catalog.apply + FileTest.should be_exists(fname) + end + + it "should not attempt to evaluate resources with failed dependencies" do + exec = Puppet::Type.type(:exec).new( + :command => "/bin/mkdir /this/path/cannot/possibly/exit", + :title => "mkdir" + ) + + file1 = Puppet::Type.type(:file).new( + :title => "file1", + :path => tmpfile("file1"), + :require => exec, + :ensure => :file + ) + + file2 = Puppet::Type.type(:file).new( + :title => "file2", + :path => tmpfile("file2"), + :require => file1, + :ensure => :file + ) + + catalog = mk_catalog(exec, file1, file2) + catalog.apply + + FileTest.should_not be_exists(file1[:path]) + FileTest.should_not be_exists(file2[:path]) + end + + # #801 -- resources only checked in noop should be rescheduled immediately. + it "should immediately reschedule noop resources" do + Puppet::Type.type(:schedule).mkdefaultschedules + resource = Puppet::Type.type(:notify).new(:name => "mymessage", :noop => true) + catalog = Puppet::Resource::Catalog.new + catalog.add_resource resource + + trans = catalog.apply + + trans.resource_harness.should be_scheduled(trans.resource_status(resource), resource) + end +end |