summaryrefslogtreecommitdiff
path: root/lib/chef/resource/conditional.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/chef/resource/conditional.rb')
-rw-r--r--lib/chef/resource/conditional.rb27
1 files changed, 20 insertions, 7 deletions
diff --git a/lib/chef/resource/conditional.rb b/lib/chef/resource/conditional.rb
index 60f65e14e2..e6623be5dd 100644
--- a/lib/chef/resource/conditional.rb
+++ b/lib/chef/resource/conditional.rb
@@ -17,6 +17,7 @@
#
require 'chef/mixin/shell_out'
+require 'chef/guard_interpreter/resource_guard_interpreter'
class Chef
class Resource
@@ -29,12 +30,12 @@ class Chef
private :new
end
- def self.not_if(command=nil, command_opts={}, &block)
- new(:not_if, command, command_opts, &block)
+ def self.not_if(parent_resource, command=nil, command_opts={}, &block)
+ new(:not_if, parent_resource, command, command_opts, &block)
end
- def self.only_if(command=nil, command_opts={}, &block)
- new(:only_if, command, command_opts, &block)
+ def self.only_if(parent_resource, command=nil, command_opts={}, &block)
+ new(:only_if, parent_resource, command, command_opts, &block)
end
attr_reader :positivity
@@ -42,14 +43,16 @@ class Chef
attr_reader :command_opts
attr_reader :block
- def initialize(positivity, command=nil, command_opts={}, &block)
+ def initialize(positivity, parent_resource, command=nil, command_opts={}, &block)
@positivity = positivity
case command
when String
+ @guard_interpreter = new_guard_interpreter(parent_resource, command, command_opts, &block)
@command, @command_opts = command, command_opts
@block = nil
when nil
raise ArgumentError, "only_if/not_if requires either a command or a block" unless block_given?
+ @guard_interpreter = nil
@command, @command_opts = nil, nil
@block = block
else
@@ -69,11 +72,11 @@ class Chef
end
def evaluate
- @command ? evaluate_command : evaluate_block
+ @guard_interpreter ? evaluate_command : evaluate_block
end
def evaluate_command
- shell_out(@command, @command_opts).status.success?
+ @guard_interpreter.evaluate
rescue Chef::Exceptions::CommandTimeout
Chef::Log.warn "Command '#{@command}' timed out"
false
@@ -100,6 +103,16 @@ class Chef
end
end
+ private
+
+ def new_guard_interpreter(parent_resource, command, opts)
+ if parent_resource.guard_interpreter == :default
+ guard_interpreter = Chef::GuardInterpreter::DefaultGuardInterpreter.new(command, opts)
+ else
+ guard_interpreter = Chef::GuardInterpreter::ResourceGuardInterpreter.new(parent_resource, command, opts)
+ end
+ end
+
end
end
end